From 84aeb755f5a7cb9e6f35a43d2435b0d0a6a66d38 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期六, 03 八月 2019 11:29:23 +0800
Subject: [PATCH] 条件过滤中不涉及时间规则的东西

---
 ruleserver/ruleToformula.go |  204 +++++++++++++++++++++++++++++++-------------------
 1 files changed, 126 insertions(+), 78 deletions(-)

diff --git a/ruleserver/ruleToformula.go b/ruleserver/ruleToformula.go
index 3f875ec..5ddfec0 100644
--- a/ruleserver/ruleToformula.go
+++ b/ruleserver/ruleToformula.go
@@ -1,8 +1,6 @@
 package ruleserver
 
 import (
-	"fmt"
-	"os"
 	"ruleprocess/cache"
 	"ruleprocess/logger"
 	"sort"
@@ -16,6 +14,7 @@
 
 // 姣忎釜鐩爣鐨勫弬鏁帮細鐩镐技搴︼紝鍗犳瘮锛屽昂瀵�
 type Arg struct {
+	Id         uint64
 	Score      float64 // 鍖哄煙鍐呯殑鐩爣鐨勭浉浼煎害
 	Proportion float64 // 鍖哄煙鍐呯殑鐩爣鐨勫崰姣�
 	Size       float64 // 鍖哄煙鍐呯殑鐩爣鐨勫昂瀵�
@@ -47,6 +46,7 @@
 
 // sdk杈撳嚭鐨勫浘鐗囦笂鍗曚釜鐩爣鐨勬暟鎹�
 type PhotoMap struct {
+	Id      uint64
 	Rects   Rect    // 鐭╁舰鍖哄煙鍙傛暟
 	Score   float64 // 鐩镐技搴﹀緱鍒嗭紙鏈夊澶х▼搴﹀儚涓�涓洰鏍囥�備汉鑴革紝浜轰綋鎴栬溅绛夌瓑锛�
 	IsYolo  bool    // 鏄惁鏄痽olo鏁版嵁
@@ -72,12 +72,12 @@
 	CameraId   string
 	TaskId     string
 	Sdkdata    []*SdkData
-	RuleResult map[string]interface{} // 杩囧畬瑙勫垯鍚庢墦鐨勬爣绛� face: []FaceResult, yolo: []Result, cacheData: []ResultMsg, timeLabel: 0,1,2,3,4,5
+	RuleResult map[string]interface{} // 杩囧畬瑙勫垯鍚庢墦鐨勬爣绛� face: []FaceResult, yolo: []Result
 }
 
 type ResultMsg struct {
 	*protomsg.SdkMessage
-	RuleResult map[string]interface{} // 杩囧畬瑙勫垯鍚庢墦鐨勬爣绛�
+	RuleResult map[string]interface{} // 杩囧畬瑙勫垯鍚庢墦鐨勬爣绛� face: []FaceResult, yolo: []Result
 }
 
 // 杩囪鍒欏簱鎵撲笂鐨勬爣绛�
@@ -85,17 +85,23 @@
 	TaskId       string // 浠诲姟id
 	SdkName      string
 	RuleGroupId  string // 瑙勫垯缁刬d
-	DefenceState bool   //鏄惁甯冮槻
+	DefenceState bool   // 鏄惁甯冮槻
 	AlarmLevel   int32  // 鎶ヨ绛夌骇
 	RuleText     string // 鏂囧瓧鐗堣鍒欑粍
 	Location     []Rect // 鐩爣鐨勫潗鏍�
 	AlarmPolygon string // 瑙﹀彂鐨勬姤璀︽
+	Others
+}
+type Others struct {
+	CacheData []ResultMsg //(鏈粍瑙勫垯涓惈鏈夋寔缁椂闂寸殑瑙勫垯寮�鍚殑瀹氭椂鍣ㄧ紦瀛樼殑鏁版嵁甯�)
+	LinkCache []ResultMsg
+	TimeLabel string
 }
 
 // 杩囪鍒欏簱鎵撲笂鐨勬爣绛�
 type FaceResult struct {
 	Result
-	Args         []Arg
+	Args []Arg
 }
 type LittleRuleResult struct {
 	SdkName string // 璁板綍涓嬫缁撴灉鏄摢涓猻dk鐨勭粨鏋�
@@ -122,18 +128,30 @@
 		args.RuleResult["face"] = []FaceResult{}
 		//logger.Warn("浼犺繘鍘讳箣鍓嶆槸浠�涔堝痉琛岋細",args.RuleResult["yolo"])
 		if taskGroup != nil && len(taskGroup.GroupRules) > 0 {
+			// 鍏堣繃鐙珛锛屽啀杩囪仈鍔�
 			for _, group := range taskGroup.GroupRules {
 				//logger.Println("------------------------------浠诲姟瑙勫垯锛�",taskRule)
 				taskId := taskGroup.TaskId
 				//logger.Println("------------鏈粍浠诲姟涓嬬殑瑙勫垯缁勭殑鏁伴噺锛�",len(ruleList))
 				temp := group.Rules // temp涓轰竴缁勫畬鏁磋鍒� 鍦ㄦ闇�瑕佸垽鏂鍒欐槸鍚︽槸鑱斿姩瑙勫垯
+				label := Others{}
+				if len(temp) > 0 {
+					if group.SetType != "linkTask" {
+						// 鐙珛浠诲姟鐨勫鐞�
+						RunRule(args, group, taskId, message, label)
+					}
+				}
+			}
+			for _, group := range taskGroup.GroupRules {
+				//logger.Println("------------------------------浠诲姟瑙勫垯锛�",taskRule)
+				taskId := taskGroup.TaskId
+				//logger.Println("------------鏈粍浠诲姟涓嬬殑瑙勫垯缁勭殑鏁伴噺锛�",len(ruleList))
+				temp := group.Rules // temp涓轰竴缁勫畬鏁磋鍒� 鍦ㄦ闇�瑕佸垽鏂鍒欐槸鍚︽槸鑱斿姩瑙勫垯
+				label := Others{}
 				if len(temp) > 0 {
 					if group.SetType == "linkTask" {
 						// groupId涓惈鏈塴ink鍒欎负鑱斿姩浠诲姟
-						LinkTask(args, group, taskId, message)
-					} else {
-						// 鐙珛浠诲姟鐨勫鐞�
-						RunRule(args, group, taskId, message)
+						LinkTask(args, group, taskId, message, label)
 					}
 				}
 			}
@@ -141,7 +159,7 @@
 	}
 }
 
-func RunRule(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage) 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))
@@ -212,7 +230,7 @@
 			}
 		}
 	}
-	// 杩欐杩囩殑鏄椂闂磋鍒欙紙鏃堕棿娈电瓑锛�
+	// 杩欐杩囩殑鏄椂闂存瑙勫垯锛堟椂闂存绛夛級
 	for j := 0; j < len(groupRule.Rules); j++ {
 		for _, sdkData := range args.Sdkdata {
 			sdk, err := cache.GetSdkById(groupRule.Rules[j].SdkId)
@@ -255,57 +273,19 @@
 			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)
-		expression, err := govaluate.NewEvaluableExpression(completeFormula)
-		if strings.HasPrefix(completeFormula, "&&") || strings.HasPrefix(completeFormula, "||") || err != nil{
+		expression, err2 := govaluate.NewEvaluableExpression(completeFormula)
+		if strings.HasPrefix(completeFormula, "&&") || strings.HasPrefix(completeFormula, "||") || err2 != nil {
 			panic("瑙勫垯鏈夎锛屽緱鍒扮殑鏁板鍏紡涓嶅彲瑙f瀽")
 		}
 		result, _ := expression.Evaluate(nil) // 寰楀埌鏁板鍏紡鐨勭粨鏋�
 
 		if result.(bool) {
-			// 鏈�鍚庢垚鍔熸姤璀︽墠鎶婄鍚堟潯浠剁殑浜鸿劯鏁版嵁濉炶繘缁撴灉鏍囩閲�
-			// 閰嶄簡浜鸿劯鐨勭畻娉曟墠鎶婁汉鑴哥殑鏁版嵁鐢╁嚭鏉ユ墦鏍囩
-			faces := []Arg{}
-			faceFlag := false
-			for j := 0; j < len(groupRule.Rules); j++ {
-				if groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a97e" || groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a972" {
-					faceFlag = true
-				}
-			}
-			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)...)
-					}
-				}
-			}
-			//for _,face := range faces  {
-			//	//logger.Debug("鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�擾_______________鐪嬬湅浜鸿劯鐨勫潗鏍�:",face.Location)
-			//}
-			logger.Warn("___________________________________________________________________________缁堜簬璧板畬涓囬噷闀垮緛")
-			// 鎶婁粬浠殑浣嶇疆鏁版嵁涔熶紶涓嬪幓
-			locations := []Rect{}
-			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)...)
-					}
-				}
-			}
-			//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})
-				//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},faces})
-				//logger.Info("-------------------face缁撴灉鏍囩", len(args.RuleResult["face"].([]FaceResult)))
-			}
 			// 鏈�鍚庤繃鎸佺画鏃堕棿绛夋椂闂寸淮搴︾殑鏉′欢   鎶婃椂闂磋鍒欎綅缃皟鏁村埌杩欎釜浣嶇疆鏄负浜嗙紦瀛樻暟鎹�
 			for j := 0; j < len(groupRule.Rules); j++ {
 				for _, sdkData := range args.Sdkdata {
@@ -323,16 +303,56 @@
 				}
 			}
 			// 杩涜瀹氭椂鍣ㄧ殑澶勭悊鍜屽垽鏂�
-			timeFlag := TimerAlarm(args, groupRule.GroupId, result.(bool))
-			if timeFlag == "01" || timeFlag == "10" || timeFlag == "11" { // 婊¤冻瀹氭椂鍣ㄦ潯浠�
+			timeFlag := TimerAlarm(&label, groupRule.GroupId, result.(bool))
+			if timeFlag == "01" || timeFlag == "10" || timeFlag == "11" { // 娌℃湁瀹氭椂鍣ㄦ垨鑰呮弧瓒冲畾鏃跺櫒鏉′欢
+				// 鎵撲汉鑴告爣绛惧拰yolo鏍囩
+				// 鏈�鍚庢垚鍔熸姤璀︽墠鎶婄鍚堟潯浠剁殑浜鸿劯鏁版嵁濉炶繘缁撴灉鏍囩閲�
+				// 閰嶄簡浜鸿劯鐨勭畻娉曟墠鎶婁汉鑴哥殑鏁版嵁鐢╁嚭鏉ユ墦鏍囩
+				faces := []Arg{}
+				faceFlag := false
+				for j := 0; j < len(groupRule.Rules); j++ {
+					if groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a97e" || groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a972" {
+						faceFlag = true
+					}
+				}
+				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)...)
+						}
+					}
+				}
+				//for _,face := range faces  {
+				//	//logger.Debug("鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�擾_______________鐪嬬湅浜鸿劯鐨勫潗鏍�:",face.Location)
+				//}
+				logger.Warn("___________________________________________________________________________缁堜簬璧板畬涓囬噷闀垮緛")
+				// 鎶婁粬浠殑浣嶇疆鏁版嵁涔熶紶涓嬪幓
+				locations := []Rect{}
+				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)...)
+						}
+					}
+				}
+				//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, 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, label}, faces})
+					//logger.Info("-------------------face缁撴灉鏍囩", len(args.RuleResult["face"].([]FaceResult)))
+				}
 				return true
 			} else {
 				return false
 			}
+
 		} else {
 			// 缁撴灉涓哄亣鏃朵篃瑕佽蛋锛屾湁鏃跺�欎负鍋囩殑鐘舵�佸弽杞暟鎹篃闇�瑕佽褰曚笅鏉�
-			timeFlag := TimerAlarm(args, groupRule.GroupId, result.(bool))
-			fmt.Println(timeFlag)
+			//timeFlag := TimerAlarm(args, groupRule.GroupId, result.(bool))
+			//fmt.Println(timeFlag)
 			return false
 		}
 	} else {
@@ -340,12 +360,12 @@
 	}
 }
 
-func putFaceToResult(am *AreaMap,faceList []Arg) []Arg {
+func putFaceToResult(am *AreaMap, faceList []Arg) []Arg {
 	faces := []Arg{}
 	if len(am.filterData) > 0 {
 		for _, data := range am.filterData {
 			flag := true
-			for _,face := range faceList  {
+			for _, face := range faceList {
 				if data.Location.X == face.Location.X && data.Location.Y == face.Location.Y && data.Location.Width == face.Location.Width && data.Location.Height == face.Location.Height {
 					flag = false
 				}
@@ -372,7 +392,7 @@
 }
 
 // 鑱斿姩浠诲姟鐨勫鐞�
-func LinkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage) {
+func LinkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage, label Others) {
 	// new涓�涓畾鏃跺櫒锛屽鏋滀互姝roupId涓烘爣蹇楃殑瀹氭椂鍣ㄤ笉瀛樺湪鐨勮瘽
 	logger.Info("------------------------------------------褰撳墠鏄仈鍔ㄤ换鍔★紝瑙勫垯鏄細", groupRule.GroupText)
 	var flag bool = true
@@ -397,12 +417,12 @@
 				}
 			}
 			if flag1 {
-				TimeEleList[groupRule.GroupId].RuleResults = append(TimeEleList[groupRule.GroupId].RuleResults, &RuleResult{groupRule.Rules[j].CameraId, groupRule.Rules[j].Sort, "", groupRule.Rules[j].RuleWithPre,&ResultMsg{message,args.RuleResult}})
+				TimeEleList[groupRule.GroupId].RuleResults = append(TimeEleList[groupRule.GroupId].RuleResults, &RuleResult{groupRule.Rules[j].CameraId, groupRule.Rules[j].Sort, "", groupRule.Rules[j].RuleWithPre, ResultMsg{}})
 			}
 		}
 	}
 	// 寰�鏁扮粍閲岃祴鍊�
-	isOk := RunRule(args, groupRule, taskId, message)
+	isOk := RunRule(args, groupRule, taskId, message, label)
 	if isOk {
 		logger.Info("杩欏抚鍥惧儚鍦ㄤ换鍔′笅鐨勪竴鏁存潯瑙勫垯涓嬶紙鑱斿姩浠诲姟涓嬪氨鏄窡鏈憚鍍忔満鍍忕浉鍏崇殑灏忚鍒欙級鐨勫垽鏂粨鏋滀负true")
 		// 鏍规嵁cameraId鍘绘洿鏂版垨鑰呮彃鍏ョ粨鏋�,鐒跺悗鍒ゆ柇鏄惁鏁扮粍鏄惁鍙互寰楀嚭鎶ヨ鐨勭粨璁�
@@ -410,6 +430,22 @@
 		for _, va := range timeEle.RuleResults {
 			if va.CameraId == args.CameraId {
 				va.Result = strconv.FormatBool(isOk)
+				tempMap := make(map[string]interface{})
+				for k, result := range args.RuleResult {
+					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}
 				logger.Info("杩欎釜鎽勫儚鏈�--", args.CameraId, "--琚祴浜堜簡result", va.Result)
 			}
 		}
@@ -437,12 +473,21 @@
 				if result.(bool) {
 					logger.Info("___________________________________________________________________鑱斿姩浠诲姟鎶ヨ")
 					// 鎶婃暟缁勯噷缂撳瓨鐨勬暟鎹彇鍑烘潵涓�璧锋姤璀�
-					args.RuleResult["linkCache"] = []*ResultMsg{}
+					label.LinkCache = []ResultMsg{}
 					for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults {
-						args.RuleResult["linkCache"] = append(args.RuleResult["linkCache"].([]*ResultMsg),ruleRes.CacheData)
+						label.LinkCache = append(label.LinkCache, ruleRes.CacheData)
 					}
-					logger.Debug("鑱斿姩浠诲姟缂撳瓨浜嗗嚑涓暟鎹�",len(args.RuleResult["linkCache"].([]*ResultMsg)))
-					os.Exit(1)
+					logger.Debug("鑱斿姩浠诲姟缂撳瓨浜嗗嚑涓暟鎹�", len(label.LinkCache))
+					for i := 0; i < len(args.RuleResult["yolo"].([]Result)); i++ {
+						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
+						}
+					}
 				}
 			}
 		} else {
@@ -456,9 +501,9 @@
 		//		va.Result = strconv.FormatBool(isOk)
 		//	}
 		//}
-		for k,_ := range TimeEleList  {
+		for k, _ := range TimeEleList {
 			if k == groupRule.GroupId {
-				delete(TimeEleList,k)
+				delete(TimeEleList, k)
 				logger.Debug("鍥犱负瀹氭椂鍣ㄧ殑涓�甯ф暟鎹粨鏋滀负false锛屽共鎺夊畾鏃跺櫒")
 			}
 		}
@@ -528,15 +573,18 @@
 							}
 						}
 						am.targetNum = len(am.filterData) // 鎶婄鍚堟潯浠剁殑鐩爣鏁伴噺鏇存柊鍒皌argetNum瀛楁
-					}
-					if am.targetNum > 0 {
-						 logger.Info("锛侊紒锛侊紒锛侊紒锛侊紒锛佷汉鑴告娴嬫垚鍔�")
-						return LittleRuleResult{am.sdkName, rule.RuleWithPre + "" + "true", rule.Sort}
+						logger.Info("杩囧畬鏉′欢鍚庣殑鐩爣鏁伴噺涓猴細",am.targetNum)
+						if am.targetNum > 0 {
+							logger.Info("锛侊紒锛侊紒锛侊紒锛侊紒锛佷汉鑴告娴嬫垚鍔�")
+							return LittleRuleResult{am.sdkName, rule.RuleWithPre + "" + "true", rule.Sort}
+						} else {
+							return LittleRuleResult{am.sdkName, rule.RuleWithPre + "" + "false", rule.Sort}
+						}
 					} else {
 						return LittleRuleResult{am.sdkName, rule.RuleWithPre + "" + "false", rule.Sort}
 					}
 				} else {
-					return LittleRuleResult{am.sdkName, rule.RuleWithPre + "" + "false", rule.Sort}
+					return LittleRuleResult{}
 				}
 			} else {
 				return LittleRuleResult{}
@@ -600,7 +648,7 @@
 			// 鍏堢湅鐪嬪畾鏃跺櫒鍏冪礌闃熷垪涓槸鍚︽湁杩欐潯瑙勫垯鐨勫畾鏃跺櫒,濡傛灉鏈夊氨涓嶈兘鍐嶆鍒涘缓浜�
 			var flag bool = true
 			for k, _ := range TimeEleList {
-				if k == rule.Id {
+				if k == groupId+"+"+rule.Id {
 					flag = false // 鏈夊氨缃负false
 					logger.Info("鏈夎繖涓畾鏃跺櫒锛屼笉鍐嶅垱寤轰簡锛�")
 				}
@@ -610,8 +658,8 @@
 				timeLength, _ := strconv.Atoi(rule.SdkArgValue)
 				timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, BufferFlag: 10, CacheSdkData: ResultMsg{message, args.RuleResult}} // 鎵旇繘鍘讳竴涓畾鏃跺櫒鍏冪礌锛堝苟缂撳瓨褰撳墠鐢婚潰甯ф暟鎹級
 				//TimeEleList = make(map[string]timeElement)
-				TimeEleList[rule.Id] = &timeEle // 瀹氭椂鍣ㄥ厓绱犱互褰撳墠鎸佺画鏃堕棿灏忚鍒檌d涓洪敭
-				//logger.Info("鍒涘缓浜嗚鏁板櫒骞朵笖璁℃暟鍣ㄩ泦鍚堜负锛�", TimeEleList)
+				TimeEleList[groupId+"+"+rule.Id] = &timeEle // 瀹氭椂鍣ㄥ厓绱犱互褰撳墠鎸佺画鏃堕棿灏忚鍒檌d涓洪敭
+				logger.Info("鍒涘缓浜嗚鏁板櫒")
 			}
 		}
 	}

--
Gitblit v1.8.0