auxpi/controllers/api/upload.go

package api

import (
	"auxpi/auxpiAll"
	"auxpi/auxpiAll/e"
	"auxpi/bootstrap"
	"auxpi/utils"
	"github.com/astaxie/beego"
	"log"
	"strings"
)

type ApiUpLoadController struct {
	beego.Controller
	utils.UpLoadTools
}

//需要关闭 xsrf
func (this *ApiUpLoadController) Prepare() {
	this.EnableXSRF = false
}

var picType = []string{"png", "jpg", "jpeg", "gif", "bmp"}
var siteConfig = bootstrap.Config()

func (this *ApiUpLoadController) ApiUpLoadHandle() {
	//检测是否开启 token 认证
	if siteConfig.ApiToken != "" {
		//需要进行验证
		apiToken := this.GetString("token")
		if apiToken != siteConfig.ApiToken {
			this.errorResp(e.ERROR_AUTH_CHECK_TOKEN_FAIL)
			return
		}
	}
	//获取上传类型
	apiSelect := this.GetString("apiSelect")
	f, h, err := this.GetFile("image")
	if f == nil {
		this.errorResp(e.ERROR_FILE_IS_EMPTY)
	}
	if h.Size > siteConfig.SiteUpLoadMaxSize<<20 {
		this.errorResp(e.ERROR_FILE_IS_TOO_LARGE)
	}
	defer f.Close()
	if err != nil {
		log.Fatal("File Upload Err", err)
	}
	//验证
	validate := this.validate(h.Header.Get("Content-Type"), h.Filename)
	if validate {
		url := this.HandleUrl(apiSelect, f, h)

		//如果有返回值
		if strings.HasPrefix(url, "http") {
			this.succResp(200, url, h.Filename)
			return
		}
		this.errorResp(e.ERROR_CAN_NOT_GET_IMG_URL)
	}
	//返回失败 json
	this.errorResp(e.ERROR_FILE_TYPE)
	return
}

func (this *ApiUpLoadController) ErrorCapture() {
	this.errorResp(e.METHOD_NOT_ALLOWED)
}

//验证文件后缀&文件MIME
func (this *ApiUpLoadController) validate(contentType string, fileName string) bool {
	//首先检测文件的后缀
	isSuffix := false
	for _, pType := range picType {
		if strings.HasSuffix(fileName, pType) {
			isSuffix = true
			break
		}
	}
	//然后检测 MIME 类型
	//beego.Alert(contentType)
	if strings.HasPrefix(contentType, "image") && isSuffix {
		for _, pType := range picType {
			if strings.HasSuffix(contentType, pType) {
				return true
			}
		}

	}
	return false
}

//错误resp
func (this *ApiUpLoadController) errorResp(code int) {
	result := &auxpi.ErrorJson{}
	result.Code = code
	result.Msg = e.GetMsg(code)
	this.Data["json"] = result
	this.ServeJSON()
}

//成功 resp
func (this *ApiUpLoadController) succResp(code int, url string, name string) {
	result := &auxpi.ResultJson{}
	result.Code = code
	result.Msg = e.GetMsg(code)
	result.Data.Url = url
	result.Data.Name = name
	this.Data["json"] = result
	this.ServeJSON()
}