From 5383ff22874c1f553776b76956f8c6eb08d429ec Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期五, 02 八月 2019 16:22:22 +0800 Subject: [PATCH] 数值精度保留 --- ruleserver/ruleToformula.go | 72 +++++++++++++++++++----------------- 1 files changed, 38 insertions(+), 34 deletions(-) diff --git a/ruleserver/ruleToformula.go b/ruleserver/ruleToformula.go index 73f84b7..5a396d1 100644 --- a/ruleserver/ruleToformula.go +++ b/ruleserver/ruleToformula.go @@ -88,9 +88,13 @@ RuleText string // 鏂囧瓧鐗堣鍒欑粍 Location []Rect // 鐩爣鐨勫潗鏍� AlarmPolygon string // 瑙﹀彂鐨勬姤璀︽ - Others map[string]interface{} // cacheData: []ResultMsg,(鏈粍瑙勫垯涓惈鏈夋寔缁椂闂寸殑瑙勫垯寮�鍚殑瀹氭椂鍣ㄧ紦瀛樼殑鏁版嵁甯�)锛宭inkCache: []ResultMsg 锛宼imeLabel: 00,01,10,11,12 + Others } - +type Others struct { + CacheData []ResultMsg //(鏈粍瑙勫垯涓惈鏈夋寔缁椂闂寸殑瑙勫垯寮�鍚殑瀹氭椂鍣ㄧ紦瀛樼殑鏁版嵁甯�) + LinkCache []ResultMsg + TimeLabel string +} // 杩囪鍒欏簱鎵撲笂鐨勬爣绛� type FaceResult struct { Result @@ -127,7 +131,7 @@ taskId := taskGroup.TaskId //logger.Println("------------鏈粍浠诲姟涓嬬殑瑙勫垯缁勭殑鏁伴噺锛�",len(ruleList)) temp := group.Rules // temp涓轰竴缁勫畬鏁磋鍒� 鍦ㄦ闇�瑕佸垽鏂鍒欐槸鍚︽槸鑱斿姩瑙勫垯 - label := make(map[string]interface{}) + label := Others{} if len(temp) > 0 { if group.SetType != "linkTask" { // 鐙珛浠诲姟鐨勫鐞� @@ -140,7 +144,7 @@ taskId := taskGroup.TaskId //logger.Println("------------鏈粍浠诲姟涓嬬殑瑙勫垯缁勭殑鏁伴噺锛�",len(ruleList)) temp := group.Rules // temp涓轰竴缁勫畬鏁磋鍒� 鍦ㄦ闇�瑕佸垽鏂鍒欐槸鍚︽槸鑱斿姩瑙勫垯 - label := make(map[string]interface{}) + label := Others{} if len(temp) > 0 { if group.SetType == "linkTask" { // groupId涓惈鏈塴ink鍒欎负鑱斿姩浠诲姟 @@ -152,7 +156,7 @@ } } -func RunRule(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage,label map[string]interface{}) bool { +func RunRule(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage,label Others) bool { defer func() { if err := recover(); err != nil { logger.Error("姣斿瑙勫垯鏈夎", err.(string)) @@ -266,9 +270,9 @@ completeFormula = completeFormula[1:] } logger.Info("-------------------鐪嬬湅鎷旀瘺鍚庣殑琛ㄨ揪寮忥細", completeFormula) - expression, _ := govaluate.NewEvaluableExpression(completeFormula) - result, _ := expression.Evaluate(nil) // 寰楀埌鏁板鍏紡鐨勭粨鏋� - return result.(bool) + //expression, _ := govaluate.NewEvaluableExpression(completeFormula) + //result, _ := expression.Evaluate(nil) // 寰楀埌鏁板鍏紡鐨勭粨鏋� + //return result.(bool) } if completeFormula != "" { logger.Info("缁撴灉鍏紡-----------锛�", completeFormula) @@ -296,7 +300,7 @@ } } // 杩涜瀹氭椂鍣ㄧ殑澶勭悊鍜屽垽鏂� - timeFlag := TimerAlarm(label, groupRule.GroupId, result.(bool)) + timeFlag := TimerAlarm(&label, groupRule.GroupId, result.(bool)) if timeFlag == "01" || timeFlag == "10" || timeFlag == "11" { // 娌℃湁瀹氭椂鍣ㄦ垨鑰呮弧瓒冲畾鏃跺櫒鏉′欢 // 鎵撲汉鑴告爣绛惧拰yolo鏍囩 // 鏈�鍚庢垚鍔熸姤璀︽墠鎶婄鍚堟潯浠剁殑浜鸿劯鏁版嵁濉炶繘缁撴灉鏍囩閲� @@ -328,17 +332,13 @@ } } } - nihao := make(map[string]interface{}) - for k,v := range label{ - nihao[k] = v - } //logger.Debug("------locations鐨勫唴瀹癸細", locations) if sdkNames != "" { - args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]Result), Result{taskId, sdkNames, groupRule.GroupId,groupRule.DefenceState,groupRule.AlarmLevel, groupRule.GroupText, locations, polygonId,nihao}) + args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]Result), Result{taskId, sdkNames, groupRule.GroupId,groupRule.DefenceState,groupRule.AlarmLevel, groupRule.GroupText, locations, polygonId,label}) //logger.Info("-------------------yolo缁撴灉鏍囩闀垮害", len(args.RuleResult["yolo"].([]Result))) } if faceFlag { - args.RuleResult["face"] = append(args.RuleResult["face"].([]FaceResult), FaceResult{Result{taskId, sdkNames, groupRule.GroupId,groupRule.DefenceState,groupRule.AlarmLevel, groupRule.GroupText, []Rect{}, polygonId,nihao},faces}) + args.RuleResult["face"] = append(args.RuleResult["face"].([]FaceResult), FaceResult{Result{taskId, sdkNames, groupRule.GroupId,groupRule.DefenceState,groupRule.AlarmLevel, groupRule.GroupText, []Rect{}, polygonId,label},faces}) //logger.Info("-------------------face缁撴灉鏍囩", len(args.RuleResult["face"].([]FaceResult))) } return true @@ -389,7 +389,7 @@ } // 鑱斿姩浠诲姟鐨勫鐞� -func LinkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage,label map[string]interface{}) { +func LinkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage,label Others) { // new涓�涓畾鏃跺櫒锛屽鏋滀互姝roupId涓烘爣蹇楃殑瀹氭椂鍣ㄤ笉瀛樺湪鐨勮瘽 logger.Info("------------------------------------------褰撳墠鏄仈鍔ㄤ换鍔★紝瑙勫垯鏄細", groupRule.GroupText) var flag bool = true @@ -429,11 +429,17 @@ va.Result = strconv.FormatBool(isOk) tempMap := make(map[string]interface{}) for k,result := range args.RuleResult { - tempMap[k] = result - } - for _,result := range args.RuleResult["yolo"].([]Result) { - for k,_ := range result.Others { - logger.Warn("鏀捐繘鑱斿姩缂撳瓨鐨勯敭鏄�",k) + if k == "yolo" { + tempMap[k] = []Result{} + for _,res := range result.([]Result) { + tempMap[k] = append(tempMap[k].([]Result),res) + } + } + if k == "face" { + tempMap[k] = []FaceResult{} + for _,res := range result.([]FaceResult) { + tempMap[k] = append(tempMap[k].([]FaceResult),res) + } } } va.CacheData = ResultMsg{message,tempMap} @@ -464,22 +470,19 @@ if result.(bool) { logger.Info("___________________________________________________________________鑱斿姩浠诲姟鎶ヨ") // 鎶婃暟缁勯噷缂撳瓨鐨勬暟鎹彇鍑烘潵涓�璧锋姤璀� - label["linkCache"] = []ResultMsg{} + label.LinkCache = []ResultMsg{} for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults { - label["linkCache"] = append(label["linkCache"].([]ResultMsg),ruleRes.CacheData) + label.LinkCache = append(label.LinkCache,ruleRes.CacheData) } - logger.Debug("鑱斿姩浠诲姟缂撳瓨浜嗗嚑涓暟鎹�",len(label["linkCache"].([]ResultMsg))) - //for _,result := range args.RuleResult["yolo"].([]Result) { - // if result.RuleGroupId == groupRule.GroupId { - // result.Others["linkCache"] = label - // } - //} + logger.Debug("鑱斿姩浠诲姟缂撳瓨浜嗗嚑涓暟鎹�",len(label.LinkCache)) for i := 0; i < len(args.RuleResult["yolo"].([]Result)); i++ { - if args.RuleResult["yolo"].([]Result)[i].RuleGroupId == groupRule.GroupId { // 鎶婂師鏉ラ偅涓垹鎺夊啀瀛樹竴浠芥柊鐨� - res := args.RuleResult["yolo"].([]Result)[i] - res.Others["linkCache"] = label["linkCache"] - args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]Result)[:i],args.RuleResult["yolo"].([]Result)[i+1:]...) - args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]Result),res) + if args.RuleResult["yolo"].([]Result)[i].RuleGroupId == groupRule.GroupId { // 鎶婅仈鍔ㄦ暟鎹拷鍔犱笂 + args.RuleResult["yolo"].([]Result)[i].Others.LinkCache = label.LinkCache + } + } + for i := 0; i < len(args.RuleResult["face"].([]FaceResult)); i++ { + if args.RuleResult["face"].([]FaceResult)[i].RuleGroupId == groupRule.GroupId { // 鎶婅仈鍔ㄦ暟鎹拷鍔犱笂 + args.RuleResult["face"].([]FaceResult)[i].Others.LinkCache = label.LinkCache } } } @@ -567,6 +570,7 @@ } } am.targetNum = len(am.filterData) // 鎶婄鍚堟潯浠剁殑鐩爣鏁伴噺鏇存柊鍒皌argetNum瀛楁 + logger.Info("-------------浜鸿劯鐩爣鏁伴噺锛�",am.targetNum) } if am.targetNum > 0 { logger.Info("锛侊紒锛侊紒锛侊紒锛侊紒锛佷汉鑴告娴嬫垚鍔�") -- Gitblit v1.8.0