| | |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "basic.com/pubsub/protomsg.git" |
|---|
| | | "basic.com/fileServer/WeedFSClient.git" |
|---|
| | | "bytes" |
|---|
| | | "encoding/base64" |
|---|
| | | "errors" |
|---|
| | |
|---|
| | | faceArr, err, pI := service.GetFaceFeaFromSdk(fileBytes, time.Second*5) |
|---|
| | | if err ==nil && len(faceArr) >0 { |
|---|
| | | var faceBase64= "" |
|---|
| | | var field = "" |
|---|
| | | var rcFace *protomsg.Rect |
|---|
| | | for _,r := range faceArr { |
|---|
| | | rcFace = r.Pos.RcFace |
|---|
| | |
|---|
| | | } |
|---|
| | | //根据人脸坐标扣出人脸小图 |
|---|
| | | cutFaceImgData := util.SubImg(*pI, int(rcFace.Left), int(rcFace.Top), int(rcFace.Right), int(rcFace.Bottom)) |
|---|
| | | fileInfo, e := esutil.PostFormData(weedfsUri, "测试人脸切图", "file", cutFaceImgData) |
|---|
| | | if e != nil { |
|---|
| | | fmt.Println(e.Error()) |
|---|
| | | |
|---|
| | | weedFilePath, e := WeedFSClient.UploadFile(weedfsUri, "testCutFace", cutFaceImgData) |
|---|
| | | if e !=nil{ |
|---|
| | | util.ResponseFormat(c,code.ComError,"文件上传失败") |
|---|
| | | } else { |
|---|
| | | field = fileInfo[picUrlField].(string) // 文件路径 |
|---|
| | | util.ResponseFormat(c,code.Success,weedFilePath + ";" + faceBase64) |
|---|
| | | } |
|---|
| | | if strings.Contains(field,"/"){ |
|---|
| | | idx := strings.Index(field, "/") |
|---|
| | | field = field[idx+1:] |
|---|
| | | } |
|---|
| | | fmt.Println("field:",field) |
|---|
| | | util.ResponseFormat(c,code.Success,field + ";" + faceBase64) |
|---|
| | | } else { |
|---|
| | | util.ResponseFormat(c,code.ComError,"未提取到人脸") |
|---|
| | | } |
|---|
| | |
|---|
| | | return |
|---|
| | | } |
|---|
| | | extNames := make([]string, 0) |
|---|
| | | isAllFiald := true |
|---|
| | | addResult := make(map[string]interface{}, 0) |
|---|
| | | details := make([]string, 0) |
|---|
| | | successList := make([]string, 0) |
|---|
| | | failList := make([]string,0) |
|---|
| | | for _, head := range fileHeaders { |
|---|
| | | //文件的名称 |
|---|
| | | filename := head.Filename |
|---|
| | |
|---|
| | | if err != nil { |
|---|
| | | log.Fatal(err) |
|---|
| | | } |
|---|
| | | //data, _ := ioutil.ReadAll(file) |
|---|
| | | // weedfs 上传 |
|---|
| | | |
|---|
| | | field, _, err1 := uploadFileReturnAddr(file, filename, tableId) |
|---|
| | | extNames = append(extNames, field) |
|---|
| | | if isAllFiald && err1 == nil { |
|---|
| | | isAllFiald = false |
|---|
| | | } |
|---|
| | | //extNames = append(extNames, field) |
|---|
| | | |
|---|
| | | if err1 != nil { |
|---|
| | | if field == "" { |
|---|
| | | details = append(details, filename+"上传失败,"+err1.Error()) |
|---|
| | | failList = append(failList, filename+"上传失败,"+err1.Error()) |
|---|
| | | } else { |
|---|
| | | details = append(details, filename+"加入底库失败,"+err1.Error()) |
|---|
| | | successList = append(successList, filename+"加入底库失败,"+err1.Error()) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | addResult["isAllFiald"] = isAllFiald |
|---|
| | | addResult["successList"] = successList |
|---|
| | | addResult["failList"] = failList |
|---|
| | | addResult["fields"] = extNames |
|---|
| | | addResult["detail"] = details |
|---|
| | | //addResult["detail"] = details |
|---|
| | | //fields := fdfsclient.UploadFileByBuffer100(bytess, extNames) // fastdfs 上传 |
|---|
| | | if !isAllFiald { |
|---|
| | | if len(successList)>0 { |
|---|
| | | util.ResponseFormat(c, code.Success, addResult) |
|---|
| | | } else { |
|---|
| | | util.ResponseFormat(c, code.ServiceInsideError, err.Error()) |
|---|
