From d42b09cda8b2bc58c43c200f3aabdb0b2a7e9211 Mon Sep 17 00:00:00 2001 From: sunty <1172534965@qq.com> Date: 星期五, 12 七月 2019 12:02:14 +0800 Subject: [PATCH] fix search controllers --- controllers/fileController.go | 179 ++++++++++++++++++++++++++++++++++------------------------- 1 files changed, 102 insertions(+), 77 deletions(-) diff --git a/controllers/fileController.go b/controllers/fileController.go index a6e6509..3b641e0 100644 --- a/controllers/fileController.go +++ b/controllers/fileController.go @@ -10,9 +10,11 @@ "github.com/satori/go.uuid" "image" "image/jpeg" + "io/ioutil" "log" "mime/multipart" "net/http" + "strings" "webserver/extend/code" "webserver/extend/esutil" "webserver/extend/util" @@ -32,9 +34,9 @@ //var picUrlField = "fid" /**涓婁紶鏂规硶**/ -//var weedfsUri = "http://192.168.1.182:6333/submit" +var weedfsUri = "http://192.168.1.182:6333/submit" -var weedfsUri = "http://192.168.1.182:9500/submit" +//var weedfsUri = "http://192.168.1.182:9500/submit" // @Summary 渚濇嵁鍥剧墖娣诲姞搴曞簱浜哄憳 // @Description 渚濇嵁鍥剧墖娣诲姞搴曞簱杩斿洖鏁版嵁浜哄憳 @@ -100,15 +102,32 @@ //灏嗕笂浼犵殑鍥剧墖浜や汉鑴告娴嬪拰浜鸿劯鎻愬彇锛岃幏寰楃壒寰� - - faceExtArr, err := getFaceFeaFromSdk(file) - if err ==nil && len(faceExtArr) >0 { + fileBytes, _ := ioutil.ReadAll(file) + faceArr, err, pI := service.GetFaceFeaFromSdk(fileBytes) + if err ==nil && len(faceArr) >0 { var faceBase64= "" - for _,r := range faceExtArr { + var field = "" + var rcFace *protomsg.Rect + for _,r := range faceArr { + rcFace = r.Pos.RcFace faceBase64 = base64.StdEncoding.EncodeToString(r.Feats)//鑾峰彇鎻愬彇鍒扮殑绗竴寮犱汉鑴哥壒寰� break } - util.ResponseFormat(c,code.Success,faceBase64) + //鏍规嵁浜鸿劯鍧愭爣鎵e嚭浜鸿劯灏忓浘 + 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()) + + } else { + field = fileInfo[picUrlField].(string) // 鏂囦欢璺緞 + } + 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,"鏈彁鍙栧埌浜鸿劯") } @@ -121,80 +140,78 @@ }*/ func uploadFileReturnAddr(file multipart.File, filename string, tableId string) (string, map[string]interface{}, error) { - defer file.Close() field := "" // weedfs 涓婁紶 - { - fileInfo, e := esutil.PostFormData(weedfsUri, filename, "file", file) - if e != nil { - fmt.Println(e.Error()) - return "", nil, e - } else { - field = fileInfo[picUrlField].(string) // 鏂囦欢璺緞 - } - } - if tableId != "" && field != "" { - // 杩斿洖鐗瑰緛鍊� fileInfo["point"] = v.RcFace fileInfo["feature"] = feat - - /*features := gorun.GetSimpleFaceDetect(picIp+field) // 鐗瑰緛鍊� // linux - if len(features) == 0 { // linux - return field,nil,errors.New("NotFeatureFindError") // linux - }else if len(features) > 1 { // linux - return field,nil,errors.New("TooManyFeatureFindError") // linux - } // linux - feat := features[0]["feature"].([]byte) // linux - if len(feat) != 2560 { // linux - return field,nil,errors.New("NotFeatureFindError") - - } */ // linux - - //灏嗕笂浼犵殑鍥剧墖浜や汉鑴告娴嬪拰浜鸿劯鎻愬彇锛岃幏寰楃壒寰� - var faceBase64="" - faceExtArr, err := getFaceFeaFromSdk(file) - if err ==nil && len(faceExtArr) >0 { - for _,r := range faceExtArr { - faceBase64 = base64.StdEncoding.EncodeToString(r.Feats)//鑾峰彇鎻愬彇鍒扮殑绗竴寮犱汉鑴哥壒寰� - break - } - } - - - dbperson := new(models.Dbtablepersons) - dbperson.FaceFeature = picIp + field // 鍥剧墖璺粡 - dbperson.TableId = tableId // - dbperson.PersonName = filename // 鍥剧墖鍚� - // 婕旂ずbase64缂栫爜 - - dbperson.FaceFeature = faceBase64 // 鐗瑰緛鍊糱ase64 鐮� - - result := addDbPerson(dbperson) - return field, result, nil - } else { - return field, nil, nil - } -} - -func getFaceFeaFromSdk(file multipart.File) ([]*protomsg.ResultFaceExtCom,error){ - s := service.NewFaceSdkService(file) - i, err := s.ReadFromUploadImg() - if err !=nil{ - fmt.Println("readFromUploadImg err:",err) - return nil,err - } - bc, err := service.ImgCompress(i) + fileBytes, err := ioutil.ReadAll(file) if err !=nil { - fmt.Println("ImgCompress err:",err) - return nil,err + return "",nil,err } - s.PushImgMsg(bc) - s.GetFaceFea() - if s.Result == nil{ - return nil,errors.New("no fea") + + //灏嗕笂浼犵殑鍥剧墖浜や汉鑴告娴嬪拰浜鸿劯鎻愬彇锛岃幏寰楃壒寰� + var faceBase64="" + faceArr, err,pI := service.GetFaceFeaFromSdk(fileBytes) + if faceArr ==nil { + return "",nil,errors.New("NotFeatureFindError") + } + var rcFace *protomsg.Rect + if err ==nil && len(faceArr) >0 { + for _,r := range faceArr { + //鎷垮埌浜鸿劯鐨勫潗鏍� + rcFace = r.Pos.RcFace + + faceBase64 = base64.StdEncoding.EncodeToString(r.Feats)//鑾峰彇鎻愬彇鍒扮殑绗竴寮犱汉鑴哥壒寰� + break + } + } + //鏍规嵁浜鸿劯鍧愭爣鎵e嚭浜鸿劯灏忓浘 + cutFaceImgData := util.SubImg(*pI, int(rcFace.Left), int(rcFace.Top), int(rcFace.Right), int(rcFace.Bottom)) + fileInfo, e := esutil.PostFormData(weedfsUri, filename, "file", cutFaceImgData) + if e != nil { + fmt.Println(e.Error()) + return "", nil, e } else { - return s.Result,nil + field = fileInfo[picUrlField].(string) // 鏂囦欢璺緞 } + if strings.Contains(field,"/"){ + idx := strings.Index(field, "/") + field = field[idx+1:] + } + fmt.Println("field:",field) + + dbperson := new(models.Dbtablepersons) + dbperson.PersonPicUrl = field // 鍥剧墖璺粡 + dbperson.TableId = tableId // + dbperson.PersonName = filename // 鍥剧墖鍚� + // 婕旂ずbase64缂栫爜 + + dbperson.FaceFeature = faceBase64 // 鐗瑰緛鍊糱ase64 鐮� + + result := addDbPerson(dbperson) + return field, result, nil + } + +//func getFaceFeaFromSdk(fileBytes []byte) ([]*protomsg.ResultFaceExtCom,error,*protomsg.Image){ +// s := service.NewFaceSdkService(fileBytes) +// i, err := s.ReadFromUploadImg() +// if err !=nil{ +// fmt.Println("readFromUploadImg err:",err) +// return nil,err,i +// } +// bc, err := service.ImgCompress(i) +// if err !=nil { +// fmt.Println("ImgCompress err:",err) +// return nil,err,i +// } +// s.PushImgMsg(bc) +// s.GetFaceFea() +// if s.Result == nil{ +// return nil,errors.New("no fea"),i +// } else { +// return s.Result,nil,i +// } +//} /**涓婁紶鏂规硶**/ @@ -256,6 +273,14 @@ } } +type EsPersonSave struct { + FaceFeature string `json:"faceFeature"` + TableId string `json:"tableId"` + Id string `json:"id"` + PersonPicUrl string `json:"personPicUrl"` + IdCard string `json:"idCard"` +} + // @Summary 涓婁紶鍥剧墖 骞跺垏鍥� // @Description 涓婁紶鍥剧墖 骞跺垏鍥� // @Accept mpfd @@ -263,8 +288,8 @@ // @Tags dbperson 搴曞簱浜哄憳 // @Param file formData file true "搴曞簱浜哄憳鍥剧墖" // @Param tableId formData string false "搴曞簱id,鏈塱d 鍒欏姞鍏ュ簳搴擄紝鏃犲垯鍙笂浼犲浘鐗�" -// @Success 200 {string} json "{"code":200, msg:"鐩綍缁撴瀯鏁版嵁", success:true}" -// @Failure 500 {string} json "{"code":500, msg:"杩斿洖閿欒淇℃伅", success:false}" +// @Success 200 {string} json "{"code":200, msg:"鐩綍缁撴瀯鏁版嵁", success:true, data:""}" +// @Failure 500 {string} json "{"code":500, msg:"杩斿洖閿欒淇℃伅", success:false, data:""}" // @Router /data/api-v/es/ImageUploadReturnPics [POST] func (fc FileController) ImageUploadReturnPics(c *gin.Context) { //寰楀埌涓婁紶鐨勬枃浠� @@ -276,9 +301,9 @@ } //鏂囦欢鐨勫悕绉� filename := header.Filename - fmt.Println(file, err, filename) defer file.Close() field := "" + // weedfs 涓婁紶 uploadData := make([]byte, header.Size) i, err2 := file.ReadAt(uploadData, 0) @@ -301,7 +326,7 @@ // fileInfo["point"] = v.RcFace // 杩斿洖鐗瑰緛鍊� // fileInfo["feature"] = feat //features := gorun.GetSimpleFaceDetect(picIp + "/" + field) // 鐗瑰緛鍊� 鍙湪linux 涓� - //feat := []byte("hello world") // windows 娴嬭瘯鏀惧紑 + result := make(map[string]interface{}, 0) result["uploadImage"] = picIp + field smUrl := make([]string, 0) -- Gitblit v1.8.0