From 95652c49ee7c0a4a9b167c6bcbe585ebd58ab2e5 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期四, 11 七月 2019 14:38:58 +0800
Subject: [PATCH] 把areamap arg等数组换成指针形式

---
 ruleserver/ruleToformula.go |   74 ++++++++++++++++++++-----------------
 1 files changed, 40 insertions(+), 34 deletions(-)

diff --git a/ruleserver/ruleToformula.go b/ruleserver/ruleToformula.go
index d4aab7e..02deb86 100644
--- a/ruleserver/ruleToformula.go
+++ b/ruleserver/ruleToformula.go
@@ -89,8 +89,8 @@
 	triggerLine   string
 	directionLine string
 	targetNum     int    // 鍖哄煙鍐呯洰鏍囨暟閲�
-	args          []Arg  // 鍖哄煙鍐呯洰鏍囬泦鍚�
-	filterData    []Arg  // 杩囨护鍚庡尯鍩熷唴鐩爣闆嗗悎
+	args          []*Arg  // 鍖哄煙鍐呯洰鏍囬泦鍚�
+	filterData    []*Arg  // 杩囨护鍚庡尯鍩熷唴鐩爣闆嗗悎
 	time          string // 褰撳墠鏃堕棿锛堢敤浠ュ尮閰嶆椂闂磋鍒欙級
 	keepRight     bool   // 鏄惁闈犲彸琛�
 	isStatic      bool   // 鏄惁闈欐
@@ -115,7 +115,7 @@
 	IsStatic    bool       // 鏄惁闈欐
 	ImageWidth  int        // 鎽勫儚鏈烘媿鎽勭殑鍥惧儚瀹� 鍍忕礌
 	ImageHeight int        // 鎽勫儚鏈烘媿鎽勭殑鍥惧儚楂� 鍍忕礌
-	AreaMapList []AreaMap  // 鏈瑂dk鎻愬彇鐨勬暟鎹寜鐓у尯鍩熷垝鍒嗗悗鐨勬暟鎹泦鍚�
+	AreaMapList []*AreaMap  // 鏈瑂dk鎻愬彇鐨勬暟鎹寜鐓у尯鍩熷垝鍒嗗悗鐨勬暟鎹泦鍚�
 }
 
 // 浠庣畻娉曟ā鍧楀効鎷挎潵鐨勫涓�甯у浘鍍忓悇涓畻娉曟彁鍙栫殑鏁版嵁闆嗗悎
@@ -180,7 +180,7 @@
 		areaMap := AreaMap{cameraId: cameraId, areaId: polygon.Id, areaJson: polygon.Polygon, triggerLine: polygon.TriggerLine, directionLine: polygon.DirectionLine}
 		// 涓烘瘡涓憚鍍忔満鍖哄煙濉厖鏁版嵁
 		areaMap.CountAreaObjs(arg)
-		arg.AreaMapList = append(arg.AreaMapList, areaMap)
+		arg.AreaMapList = append(arg.AreaMapList, &areaMap)
 	}
 }
 
@@ -222,6 +222,25 @@
 		}
 	}
 }
+func (arg *Arg) fillLiker(){
+	bytes := bigCache.Getdbpersonmsg("", arg.Feature, true)
+	var m map[string]float32
+	err1 := json.Unmarshal(bytes, &m)
+	if err1 != nil {
+		logger.Error("getBaseInfo瑙e帇閿欒", err1)
+	}
+	logger.Info("----------------------------------------map鏄�", m)
+	for key, val := range m {
+		logger.Info("_______________________________________瀵规瘮搴撶殑杩斿洖鍊�", key, val)
+		baseinfo, err1 := esutil.Dbpersoninfosbyid(key)
+		if err1 != nil {
+			logger.Error("鏌ヨ搴曞簱浜哄憳淇℃伅鍑洪敊", err1)
+		}
+		baseinfo.CompareScore = val
+		arg.Liker = append(arg.Liker, &baseinfo)
+	}
+	//logger.Info("------------------绗竴娆$湅args:",*arg)
+}
 func Compare(args *SdkDatas, groupRule *protomsg.GroupRule) {
 	compareFlag := 0
 	tableIds := ""
@@ -253,22 +272,7 @@
 						if groupRule.Rules[j].PolygonId == areaMap.areaId {
 							for _, arg := range areaMap.args {
 								if compareFlag == 1 {
-									bytes := bigCache.Getdbpersonmsg("", arg.Feature, true)
-									var m map[string]float32
-									err1 := json.Unmarshal(bytes, &m)
-									if err1 != nil {
-										logger.Error("getBaseInfo瑙e帇閿欒", err1)
-									}
-									logger.Info("----------------------------------------map鏄�", m)
-									for key, val := range m {
-										logger.Info("_______________________________________瀵规瘮搴撶殑杩斿洖鍊�", key, val)
-										baseinfo, err1 := esutil.Dbpersoninfosbyid(key)
-										if err1 != nil {
-											logger.Error("鏌ヨ搴曞簱浜哄憳淇℃伅鍑洪敊", err1)
-										}
-										baseinfo.CompareScore = val * 100
-										arg.Liker = append(arg.Liker, &baseinfo)
-									}
+									arg.fillLiker()
 								}
 								if compareFlag == 2 {
 									array := strings.Split(tableIds, ",")
@@ -289,8 +293,10 @@
 										}
 									}
 								}
-								logger.Info("-------------------鎴愬姛缁檒iker璧嬪�硷細", arg.Liker)
+								logger.Info("-------------------鎴愬姛缁檒iker璧嬪��,闀垮害涓猴細", len(arg.Liker))
 							}
+							areaMap.filterData = areaMap.args
+							logger.Info("=======绗竴娆$湅args锛�",areaMap.filterData)
 						}
 					}
 				}
@@ -318,11 +324,11 @@
 			}
 			ipcId := sdk.IpcId
 			sdkName := sdk.SdkName
-
+			logger.Info("瑙勫垯鐨刬pcId涓巗dkData鐨処pcId:",ipcId,"===",sdkData.IpcId)
 			if ipcId == sdkData.IpcId {
 				logger.Info("褰撳墠璧扮殑瑙勫垯鐨勭畻娉曟槸--锛�", sdkName, "---")
 				for _, areaMap := range sdkData.AreaMapList {
-					ruleResult := filterRule(groupRule.Rules[j], &areaMap)
+					ruleResult := filterRule(groupRule.Rules[j], areaMap)
 					if ruleResult.Result != "" {
 						logger.Info("鏉′欢瑙勫垯缁撴灉锛�", ruleResult.Result)
 						// 濡傛灉姝ょ粨鏋滀负鐪熶笖褰撳墠杩囩殑鏄痽olo绠楁硶锛屽簲璁颁笅姝よ鍒欐墍瀵瑰簲鐨剆dkName,鍙﹀锛岃繕瑕佸幓閲�
@@ -348,7 +354,7 @@
 			sdkName := sdk.SdkName
 			if ipcId == sdkData.IpcId {
 				for _, areaMap := range sdkData.AreaMapList {
-					ruleResult := transferParameters(groupRule.Rules[j], &areaMap)
+					ruleResult := transferParameters(groupRule.Rules[j], areaMap)
 					if ruleResult.Result != "" {
 						logger.Info("鏁伴噺瑙勫垯缁撴灉锛�", ruleResult.Result)
 						if ruleResult.Result == "true" && ipcId == "02D54B61-0F16-C604-8567-FC4BE493C523" && !strings.Contains(sdkNames, sdkName) {
@@ -371,7 +377,7 @@
 			sdkName := sdk.SdkName
 			if ipcId == sdkData.IpcId {
 				for _, areaMap := range sdkData.AreaMapList {
-					ruleResult := timeRuleResult(groupRule.Rules[j], &areaMap)
+					ruleResult := timeRuleResult(groupRule.Rules[j], areaMap)
 					if ruleResult.Result != "" {
 						logger.Info("鏃堕棿瑙勫垯缁撴灉锛�", ruleResult.Result)
 						if ruleResult.Result == "true" && ipcId == "02D54B61-0F16-C604-8567-FC4BE493C523" && !strings.Contains(sdkNames, sdkName) {
@@ -394,7 +400,7 @@
 			if ipcId == sdkData.IpcId {
 				for _, areaMap := range sdkData.AreaMapList {
 					// 鍘诲紑鍚竴涓畾鏃跺櫒
-					duration(groupRule.Rules[j], groupRule.GroupId, &areaMap, args)
+					duration(groupRule.Rules[j], groupRule.GroupId, areaMap, args)
 				}
 			}
 		}
@@ -461,7 +467,7 @@
 				for _, sdkData := range args.Sdkdata {
 					if sdkData.IpcId == "A8B73405-373D-4F23-CED2-A617EBD7EC55" && faceFlag { // sdkData閲屾湁浜鸿劯鏁版嵁涓旈厤缃簡绠楁硶鎵嶆妸绗﹀悎鏉′欢鐨勬暟鎹杩涙爣绛鹃噷鍘�
 						for _, areaMap := range sdkData.AreaMapList {
-							faces = append(faces, putFaceToResult(&areaMap)...)
+							faces = append(faces, putFaceToResult(areaMap)...)
 						}
 					}
 				}
@@ -474,7 +480,7 @@
 				for _, sdkData := range args.Sdkdata {
 					if sdkData.IpcId == "02D54B61-0F16-C604-8567-FC4BE493C523" && sdkNames != "" { // 鎶妝olo鏁版嵁鐨勫悇涓洰鏍囩殑鍧愭爣杈撳嚭鏂逛究鍚庨潰鐢绘
 						for _, areaMap := range sdkData.AreaMapList {
-							locations = append(locations, putYolosToResult(&areaMap)...)
+							locations = append(locations, putYolosToResult(areaMap)...)
 						}
 					}
 				}
@@ -516,7 +522,7 @@
 	faces := []Arg{}
 	if len(am.filterData) > 0 {
 		for _, data := range am.filterData {
-			faces = append(faces, data)
+			faces = append(faces, *data)
 		}
 	}
 
@@ -553,8 +559,8 @@
 			a.targetNum++
 			arg1 := Arg{obj.Score, PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale), float64(obj.Rects.Width * obj.Rects.Height), obj.IsYolo, obj.Rects, obj.Feature, obj.ThftRes, []*protomsg.Baseinfo{}}
 			//logger.Println("鏀捐繘鍘荤殑arg锛�-------", arg1)
-			a.args = append(a.args, arg1)
-			a.filterData = append(a.filterData, arg1)
+			a.args = append(a.args, &arg1)
+			a.filterData = append(a.filterData, &arg1)
 		}
 	}
 	a.time = time.Unix(time.Now().Unix(), 0).String()[11:16]
@@ -682,7 +688,7 @@
 		if rule.PolygonId == am.areaId { // 绠楁硶鍜屽尯鍩熼兘寰楀鐨勪笂
 
 			if rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a972" && rule.SdkArgAlias != "time_rule" {
-				// 鍙渶瑕佽繃婊ら槇鍊硷紝杩囨护瀹屽悗鏁扮粍闀垮害澶т簬0鍗充负鎶ヨ锛屼絾瑕佽�冭檻濡備綍瀵规瘡涓�寮犻兘鎶ヨ鍛�
+				// 鍙渶瑕佽繃婊ら槇鍊硷紝杩囨护瀹屽悗鏁扮粍闀垮害澶т簬0鍗充负鎶ヨ
 				argValue, err := strconv.ParseFloat(rule.SdkArgValue, 64)
 				if err != nil {
 					logger.Error("瑙勫垯閰嶇疆鐨勯槇鍊奸潪娉�")
@@ -722,7 +728,7 @@
 					// 濡傛灉鏄笉瑙勭煩鐨勮繛鎺ョ缁熺粺杩斿洖false 瑙勫垯涔熷彧鑳藉垽鏂汉鑴哥殑鐩镐技搴︼紝鎵�浠ヤ笉瀛樺湪鍒殑杩炴帴绗�
 					if rule.SdkArgAlias == "score" || rule.SdkArgAlias == "proportion" || rule.SdkArgAlias == "size" { // 鍒ゆ柇鐨勬槸鐩镐技鍊硷紝鍗犳瘮锛屽昂瀵哥瓑杩囨护鏉′欢锛屽鏋滃啀鏈夛紝杩樺彲浠ュ啀鍔�
 						logger.Info("--------------------缁堜簬绛夊埌浣犵殑涓嬫枃")
-						var args []Arg
+						var args []*Arg
 						if rule.RuleWithPre == "&&" {
 							args = am.filterData
 						} else {
@@ -771,7 +777,7 @@
 		if rule.PolygonId == am.areaId { // 棣栧厛杩欐潯瑙勫垯寰楁槸杩欎釜绠楁硶鐨勮鍒欙紝鍏舵瑙勫垯鎵�瀵瑰簲鐨勫尯鍩焛d瑕佽窡鍖哄煙鏁版嵁鐨刬d瀵圭殑涓�
 			if rule.SdkArgAlias == "score" || rule.SdkArgAlias == "proportion" || rule.SdkArgAlias == "size" { // 鍒ゆ柇鐨勬槸鐩镐技鍊硷紝鍗犳瘮锛屽昂瀵哥瓑杩囨护鏉′欢锛屽鏋滃啀鏈夛紝杩樺彲浠ュ啀鍔�
 				logger.Info("----------褰撳墠鏉′欢瑙勫垯锛�---------", rule)
-				var args []Arg
+				var args []*Arg
 				if rule.RuleWithPre == "&&" {
 					args = am.filterData
 				} else {

--
Gitblit v1.8.0