From ec4c0cc329b602921ac3bcc25472395d698ef71f Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期五, 26 七月 2019 10:23:53 +0800 Subject: [PATCH] faceFeature change to base64 --- insertdata/insertDataToEs.go | 50 ++++++++++++++++++++++++++++---------------------- 1 files changed, 28 insertions(+), 22 deletions(-) diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go index ee1e825..a8681aa 100644 --- a/insertdata/insertDataToEs.go +++ b/insertdata/insertDataToEs.go @@ -1,6 +1,7 @@ package insertdata import ( + "encoding/base64" "encoding/json" "errors" "fmt" @@ -144,7 +145,7 @@ panic("瑙e帇缂╁浘鐗囨椂鍑虹幇閿欒") } alarmRules := []AlarmRule{} - alarm := ChangeToString(faceResult.AlarmLevel) + alarm := ChangeToString(faceResult.DefenceState,faceResult.AlarmLevel) alarmRules = append(alarmRules, AlarmRule{faceResult.RuleGroupId, alarm, faceResult.RuleText}) i := protomsg.Image{} err = proto.Unmarshal(bdata, &i) @@ -195,7 +196,7 @@ race, face.ThftRes.Smile, face.ThftRes.Beauty, - string(face.Feature), + base64.StdEncoding.EncodeToString(face.Feature), []string{strings.Split(resp["fileUrl"].(string), "/")[1]}, "鏆傛棤闆嗙兢", localConfig.ServerId, @@ -221,7 +222,7 @@ } else { logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", resp1) // 鍙戝嚭褰曞儚淇″彿 - ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}}) + ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:1}) } } } @@ -297,7 +298,7 @@ } else { logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", resp1) // 鍙戝嚭褰曞儚淇″彿 - ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}}) + ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:1 }) } //if msg.RuleResult["cacheData"] != nil { // InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) @@ -312,7 +313,7 @@ alarmRules := []AlarmRule{} for _, yoloResult := range msg.RuleResult["yolo"].([]ruleserver.Result) { sdkNames = sdkNames + yoloResult.SdkName - alarm := ChangeToString(yoloResult.AlarmLevel) + alarm := ChangeToString(yoloResult.DefenceState,yoloResult.AlarmLevel) alarmRules = append(alarmRules, AlarmRule{yoloResult.RuleGroupId, alarm, yoloResult.RuleText}) } isAlarm := 0 @@ -406,7 +407,7 @@ } else { logger.Debug("鎻掑叆es杩斿洖鐨勬暟鎹俊鎭槸锛�", resp1) // 鍙戝嚭褰曞儚淇″彿 - ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}}) + ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:2 }) logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛") //os.Exit(1) } @@ -476,7 +477,7 @@ } else { logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", resp1) // 鍙戝嚭褰曞儚淇″彿 - ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}}) + ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:2 }) logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛") //os.Exit(1) } @@ -511,23 +512,28 @@ } // 鎶婃姤璀︾瓑绾ц浆鍖栨垚姹夊瓧 -func ChangeToString(i int32) string { +func ChangeToString(defenceState bool,i int32) string { alarm := "" - if i == 1 { - alarm = "涓�绾�" + if defenceState { + if i == 1 { + alarm = "涓�绾�" + } + if i == 2 { + alarm = "浜岀骇" + } + if i == 3 { + alarm = "涓夌骇" + } + if i == 4 { + alarm = "鍥涚骇" + } + if i == 5 { + alarm = "浜旂骇" + } + } else { + alarm = "鎾ら槻" } - if i == 2 { - alarm = "浜岀骇" - } - if i == 3 { - alarm = "涓夌骇" - } - if i == 4 { - alarm = "鍥涚骇" - } - if i == 5 { - alarm = "浜旂骇" - } + return alarm } -- Gitblit v1.8.0