From af45035c0d893c3bbe7b1076b2bbc433755f36c5 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 19 十一月 2019 19:58:30 +0800
Subject: [PATCH] ---

---
 ruleserver/ruleToformula.go |  480 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 480 insertions(+), 0 deletions(-)

diff --git a/ruleserver/ruleToformula.go b/ruleserver/ruleToformula.go
new file mode 100644
index 0000000..fe7f49b
--- /dev/null
+++ b/ruleserver/ruleToformula.go
@@ -0,0 +1,480 @@
+package ruleserver
+
+import (
+	"basic.com/pubsub/protomsg.git"
+	"github.com/knetic/govaluate"
+	"plugin"
+	"ruleprocess/cache"
+	"ruleprocess/logger"
+	"ruleprocess/structure"
+	"sort"
+	"strconv"
+	"sync"
+)
+
+
+var rw sync.RWMutex // 璇诲啓閿�
+
+// 瀵瑰崟甯у浘鍍忕殑鍒ゆ柇 thisSdkDatas  褰撳墠浼犲叆鐨勮繖甯ф暟鎹紝cacheSdkData 瀹氭椂鍣ㄩ噷缂撳瓨鐨勪竴甯ф暟鎹� 娌℃湁灏辫繑鍥瀗il  (thisSdkDatas SdkDatas, cacheSdkDatas SdkDatas)
+func Judge(args *structure.SdkDatas, message *protomsg.SdkMessage) {
+	defer func() {
+		if err := recover(); err != nil {
+			logger.Error("瑙勫垯妯″潡鍎跨殑寮傚父鎹曡幏锛�",err)
+		}
+	}()
+	if len(args.Sdkdata) > 0 {
+		// 鎷垮埌鏈憚鍍忔満鐨勫尯鍩�
+		cameraPolygons := GetPolygons(args.CameraId)
+		// 鎶婃墍鏈夌殑sdk鎻愬彇鐨勬暟鎹兘鎸夋墍灞炴憚鍍忔満鐨勫尯鍩熷綊缃�
+		logger.Debug("褰撳墠鎽勫儚鏈篿d涓猴細",message.Cid,"褰撳墠鎽勫儚鏈烘墽琛岀殑浠诲姟鏄細",message.Tasklab.Taskname,"--浠诲姟id涓猴細",message.Tasklab.Taskid)
+		CallReadyData(args,cameraPolygons)
+		// 璺戞湰鎽勫儚鏈虹殑鎵�鏈夎鍒欑粍 涓�缁勪竴缁勮窇
+		taskGroup := GetRuleGroup(args.CameraId, args.TaskId) // 鏈憚鍍忔満鏈换鍔′笅鎵�鏈夎鍒欑粍
+		//logger.Println("鐪嬩笅鎽勫儚鏈轰笅鐨勪换鍔＄粍锛�",taskRuleList)
+		// 寰楀埌灞炰簬璇ユ憚鍍忔満鐨勮嫢骞茬粍浠诲姟鐨勫畬鏁磋鍒欙紙璺熸瘡涓�鏉″畬鏁磋鍒欐瘮杈冧箣鍚庡緱鍑烘湰寮犲浘鍍忓浜庢煇涓鍒欐槸鍚︽姤璀︾殑缁撴灉銆傛斁杩沵ap锛屾瘮濡傛湰甯у浘鍍忕殑id锛屾墍纰版挒鎴愬姛鐨勮鍒檌d锛�
+		args.RuleResult = make(map[string]interface{})
+		args.RuleResult["yolo"] = []structure.Result{}
+		args.RuleResult["face"] = []structure.Result{}
+		args.RuleResult["target"] = []structure.Result{}
+		args.RuleResult["plate"] = []structure.Result{}
+		//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 := structure.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 := structure.Others{}
+				if len(temp) > 0 {
+					if group.SetType == "linkTask" {
+						// groupId涓惈鏈塴ink鍒欎负鑱斿姩浠诲姟
+						LinkTask(args, group, taskId, message, label)
+					}
+				}
+			}
+			// 浜轰綋杩借釜
+			// 濡傛灉鏍囩涓惈鏈夋寔缁椂闂撮娆℃姤璀︾殑timeLabel鐨勮瘽鍒欎笉闇�瑕佽繃浜轰綋杩借釜锛屼笉鐒跺氨娌＄殑鎻掑叆浜�
+			fk := TrackOrNot(args.RuleResult)
+			if !fk {
+				BodyIsSame(args,message)
+			}
+		}
+	}
+}
+
+func CallMiddleware(args *structure.SdkDatas,rule protomsg.GroupRule,lable *structure.Others,message *protomsg.SdkMessage) (bool, string, string){
+	p,err :=  plugin.Open("./algorithm/middleware.so")
+	if err != nil {
+		panic(err)
+	}
+	f,err1 := p.Lookup("Entrance")
+	if err1 != nil {
+		panic("娌℃湁鎵惧埌涓棿浠跺叆鍙ｅ嚱鏁�")
+	}
+	a,b,c := f.(func(args *structure.SdkDatas,rule protomsg.GroupRule,label *structure.Others,message *protomsg.SdkMessage)(bool,string, string))(args,rule,lable,message)
+	return a,b,c
+}
+
+func CallReadyData(args *structure.SdkDatas,cameraPolygons []protomsg.CameraPolygon) {
+	p,err :=  plugin.Open("./algorithm/middleware.so")
+	if err != nil {
+		panic(err)
+	}
+	f,err1 := p.Lookup("ReadData")
+	if err1 != nil {
+		panic("娌℃湁鎵惧埌涓棿浠剁殑鏁版嵁鍑嗗鍑芥暟")
+	}
+	f.(func(args *structure.SdkDatas,cameraPolygons []protomsg.CameraPolygon)())(args,cameraPolygons)
+}
+
+func RunRule(args *structure.SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage, label structure.Others) (bool,[]int) {
+	defer func() {
+		if err := recover(); err != nil {
+			logger.Error("姣斿瑙勫垯鏈夎", err)
+		}
+	}()
+	logger.Info("+++++++++++瑙勫垯寮�濮嬭繍琛�+++++++++++++++++褰撳墠澶ц鍒�--锛�", (*groupRule).GroupText)
+	//logger.Warn("浼犺繘鍘讳箣鍚庢槸浠�涔堝痉琛岋細",args.RuleResult["yolo"])
+	Compare(args, groupRule)
+	result := false
+	sdkNames := ""
+	polygonId := ""
+
+	// 鎶婁竴甯ф暟鎹拰涓�缁勮鍒欏彂缁欑畻娉曢儴鍒嗭紝寰楀嚭鍒ゆ柇缁撴灉
+	result,sdkNames,polygonId = CallMiddleware(args,*groupRule,&label,message)
+
+	if result {
+		// 鏈�鍚庤繃鎸佺画鏃堕棿绛夋椂闂寸淮搴︾殑鏉′欢   鎶婃椂闂磋鍒欎綅缃皟鏁村埌杩欎釜浣嶇疆鏄负浜嗙紦瀛樻暟鎹�         锛侊紒锛侊紒锛乸s: 瀵圭敾闈腑鍗曚釜鐩爣鍋氬畾鏃跺櫒鐨勪笉鐢ㄥ啀杩囩敾闈㈠畾鏃跺櫒
+		for j := 0; j < len(groupRule.Rules); j++ {
+			for _, sdkData := range args.Sdkdata {
+				sdk, err := cache.GetSdkById(groupRule.Rules[j].SdkId)
+				if err != nil {
+					logger.Error("娌℃煡鍒皊dk鐨勪俊鎭�---", err)
+				}
+				ipcId := sdk.IpcId
+				if ipcId == sdkData.IpcId {
+					for _, areaMap := range sdkData.AreaMapList {
+						// 鍘诲紑鍚竴涓畾鏃跺櫒
+						duration(groupRule.Rules[j], groupRule.GroupId, areaMap, args, message,label)
+					}
+				}
+			}
+		}
+		// 杩涜瀹氭椂鍣ㄧ殑澶勭悊鍜屽垽鏂�
+		timeFlag := TimerAlarm(&label, groupRule.GroupId, result)
+		if timeFlag == "01" || timeFlag == "10" || timeFlag == "11"{ // 娌℃湁瀹氭椂鍣ㄦ垨鑰呮弧瓒冲畾鏃跺櫒鏉′欢
+			// 鎵撲汉鑴告爣绛惧拰yolo鏍囩
+			// 鏈�鍚庢垚鍔熸姤璀︽墠鎶婄鍚堟潯浠剁殑浜鸿劯鏁版嵁濉炶繘缁撴灉鏍囩閲�
+			// 閰嶄簡浜鸿劯鐨勭畻娉曟墠鎶婁汉鑴哥殑鏁版嵁鐢╁嚭鏉ユ墦鏍囩
+			faces := []*structure.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 {
+						if areaMap.IsEffective {
+							faces = append(faces, putFaceToResult(areaMap, faces)...)
+						}
+					}
+				}
+			}
+			//logger.Info("face鏍囩鐨勯暱搴︼細",len(faces))
+			//for _,face := range faces  {
+			//	//logger.Debug("鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�斺�擾_______________鐪嬬湅浜鸿劯鐨勫潗鏍�:",face.Location)
+			//}
+			logger.Warn("___________________________________________________________________________缁堜簬璧板畬涓囬噷闀垮緛")
+			// 鎶婁粬浠殑浣嶇疆鏁版嵁涔熶紶涓嬪幓
+			yolos := []*structure.Arg{}
+			for _, sdkData := range args.Sdkdata {
+				if sdkData.IpcId == "02D54B61-0F16-C604-8567-FC4BE493C523" && sdkNames != "" { // 鎶妝olo鏁版嵁鐨勫悇涓洰鏍囩殑鍧愭爣杈撳嚭鏂逛究鍚庨潰鐢绘
+					for _, areaMap := range sdkData.AreaMapList {
+						if areaMap.IsEffective {
+							yolos = append(yolos, putYolosToResult(areaMap)...)
+						}
+					}
+				}
+			}
+			logger.Debug("------locations鐨勫唴瀹癸細", yolos)
+			// 澶勭悊鐩爣瀹氭椂鏁版嵁
+			targets := []*structure.Arg{}
+			for _, sdkData := range args.Sdkdata {
+				if sdkData.IpcId == "02D54B61-0F16-C604-8567-FC4BE493C523" && sdkNames != "" { // 杈撳嚭鐩爣鏁版嵁
+					for _, areaMap := range sdkData.AreaMapList {
+						if areaMap.IsEffective {
+							targets = append(targets, putTargetsToResult(areaMap)...)
+						}
+					}
+				}
+			}
+			// 杞﹁締鐩爣缁熻
+			cars := []*structure.Arg{}
+			for _, sdkData := range args.Sdkdata {
+				logger.Info("鐪嬬湅sdkNames",sdkNames)
+				if sdkData.IpcId == "91d923ef-6200-4549-ab1b-8e773e85d729" { // 鎶婅溅鐗屾暟鎹殑鍚勪釜鐩爣鐨勫潗鏍囪緭鍑烘柟渚垮悗闈㈢敾妗�
+					for _, areaMap := range sdkData.AreaMapList {
+						if areaMap.IsEffective {
+							cars = append(cars, putFaceToResult(areaMap, cars)...)
+						}
+					}
+				}
+			}
+			var islink bool
+			if groupRule.SetType == "linkTask" {
+				islink = true
+			} else {
+				islink = false
+			}
+			var labelTypes []int // 0涓簓olo鏍囩锛�1涓篺ace鏍囩 2涓轰袱鑰呮爣绛�
+			if sdkNames != "" && len(targets) == 0 {
+				args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, yolos, polygonId, islink,label})
+				labelTypes = append(labelTypes,0)
+				//logger.Info("-------------------yolo缁撴灉鏍囩闀垮害", len(args.RuleResult["yolo"].([]Result)))
+			}
+			if faceFlag {
+				args.RuleResult["face"] = append(args.RuleResult["face"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, faces, polygonId, islink,label})
+				//logger.Info("-------------------face缁撴灉鏍囩", len(args.RuleResult["face"].([]FaceResult)))
+				labelTypes = append(labelTypes,1)
+			}
+			if len(targets) > 0 {
+				args.RuleResult["target"] = append(args.RuleResult["target"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, targets, polygonId, islink,label})
+				logger.Info("-------------------鐩爣鎸佺画缁撴灉鏍囩", len(args.RuleResult["target"].([]structure.Result)))
+				//labelTypes = append(labelTypes,2)
+			}
+			if len(cars) > 0 {
+				args.RuleResult["plate"] = append(args.RuleResult["plate"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, cars, polygonId, islink,label})
+				logger.Info("-------------------杞︾墝缁撴灉鏍囩", len(args.RuleResult["plate"].([]structure.Result)))
+				//labelTypes = append(labelTypes,2)
+			}
+			// 缁欐寔缁椂闂寸殑绗竴寮犺祴浜堢紦瀛樻暟鎹紙閬嶅巻澶嶅埗锛�
+			//if cacheId != "" { // 鏈夎繖甯ф暟鎹殑缂撳瓨
+			//	tempMap := make(map[string]interface{})
+			//	for k, result := range args.RuleResult {
+			//		if k == "yolo" {
+			//			tempMap[k] = []structure.Result{}
+			//			for _, res := range result.([]structure.Result) {
+			//				tempMap[k] = append(tempMap[k].([]structure.Result), res)
+			//			}
+			//		}
+			//		if k == "face" {
+			//			tempMap[k] = []structure.Result{}
+			//			for _, res := range result.([]structure.Result) {
+			//				tempMap[k] = append(tempMap[k].([]structure.Result), res)
+			//			}
+			//		}
+			//	}
+			//	rw.Lock()
+			//	TimeEleList[cacheId].CacheSdkData.RuleResult = tempMap
+			//	rw.Unlock()
+			//}
+
+			return true,labelTypes
+		} else {
+			return false,[]int{}
+		}
+
+	} else {
+		// 缁撴灉涓哄亣鏃朵篃瑕佽蛋锛屾湁鏉�姝诲畾鏃跺櫒鐨勬搷浣�
+		TimerAlarm(&label, groupRule.GroupId, result)
+		//fmt.Println(timeFlag)
+		logger.Info("涓嶇鍚堣鍒�")
+		return false,[]int{}
+	}
+}
+
+func putFaceToResult(am *structure.AreaMap, faceList []*structure.Arg) []*structure.Arg {
+	faces := []*structure.Arg{}
+	if len(am.FilterData) > 0 {
+		for _, data := range am.FilterData {
+			flag := true
+			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
+				}
+			}
+			if flag {
+				faces = append(faces, data)
+			}
+		}
+	}
+	//logger.Println("-----------------------------------------------鍚浣犳槸绌虹殑锛�",faces)
+	return faces
+}
+
+func putYolosToResult(am *structure.AreaMap) []*structure.Arg {
+	locations := []*structure.Arg{}
+	if len(am.FilterData) > 0 {
+		locations = am.FilterData
+	}
+	//logger.Println("-----------------------------------------------鍚浣犳槸绌虹殑锛�",faces)
+	return locations
+}
+func putTargetsToResult(am *structure.AreaMap) []*structure.Arg {
+	locations := []*structure.Arg{}
+	if len(am.AlarmObj) > 0 {
+		locations = am.AlarmObj
+	}
+	//logger.Println("-----------------------------------------------鍚浣犳槸绌虹殑锛�",faces)
+	return locations
+}
+// 鑱斿姩浠诲姟鐨勫鐞�
+func LinkTask(args *structure.SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage, label structure.Others) {
+	// new涓�涓畾鏃跺櫒锛屽鏋滀互姝roupId涓烘爣蹇楃殑瀹氭椂鍣ㄤ笉瀛樺湪鐨勮瘽
+	logger.Info("------------------------------------------褰撳墠鏄仈鍔ㄤ换鍔★紝瑙勫垯鏄細", groupRule.GroupText)
+	var flag bool = true
+	var timeEle = TimeElement{N: 2, InitN: 2, GroupId: groupRule.GroupId}
+	rw.Lock()
+	for k, timeEle1 := range TimeEleList {
+		if k == groupRule.GroupId {
+			flag = false // 宸茬粡鏈変簡杩欎釜瀹氭椂鍣ㄥ氨缃负false 涓嶅啀鏂板
+			timeEle = *timeEle1
+		}
+	}
+	//for _,ruleRe := range timeEle.RuleResults {
+	//	logger.Info("鑱斿姩鏁扮粍閲岀殑鏁版嵁----",ruleRe.CameraId,ruleRe.Sort)
+	//}
+	if flag { // 濡傛灉杩樻病鏈夎繖涓畾鏃跺櫒鍏冪礌灏辨柊澧炰竴涓�
+		//timeEle := TimeElement{N: 2, InitN: 2, GroupId: groupRule.GroupId} // 鎵旇繘鍘讳竴涓畾鏃跺櫒鍏冪礌
+		//TimeEleList = make(map[string]timeElement)
+		TimeEleList[groupRule.GroupId] = &timeEle // 瀹氭椂鍣ㄥ厓绱犱互瑙勫垯缁刬d涓洪敭
+		//logger.Info("---------------------------------------------鑱斿姩浠诲姟鍒涘缓浜嗚鏁板櫒骞朵笖璁℃暟鍣ㄩ泦鍚堜负锛�", TimeEleList)
+		// 寰楀嚭杩欑粍瀹屾暣瑙勫垯閲屾秹鍙婂埌鍑犱釜鎽勫儚鏈猴紝鍐冲畾鐫�鏁扮粍閲屾湁鍑犱釜缁撴瀯浣�,鍘婚噸娣诲姞鏂瑰紡
+		for j := 0; j < len(groupRule.Rules); j++ {
+			var flag1 bool = true
+			//logger.Info("瑙勫垯缁勪俊鎭細",groupRule.Rules[j].CameraId)
+			for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults {
+				//logger.Info("鑱斿姩鏁扮粍閲岀殑鏁版嵁锛�",ruleRes.CameraId,ruleRes.Sort)
+				if groupRule.Rules[j].CameraId == ruleRes.CameraId {
+					flag1 = false
+				}
+			}
+			if flag1 {
+				TimeEleList[groupRule.GroupId].RuleResults = append(TimeEleList[groupRule.GroupId].RuleResults, &RuleResult{groupRule.Rules[j].CameraId, groupRule.Rules[j].Sort, "", groupRule.Rules[j].RuleWithPre, structure.ResultMsg{}})
+			}
+		}
+	}
+	rw.Unlock()
+	// 寰�鏁扮粍閲岃祴鍊�
+	isOk,labelTypes := RunRule(args, groupRule, taskId, message, label)
+	if isOk {
+		logger.Info("杩欏抚鍥惧儚鍦ㄤ换鍔′笅鐨勪竴鏁存潯瑙勫垯涓嬶紙鑱斿姩浠诲姟涓嬪氨鏄窡鏈憚鍍忔満鍍忕浉鍏崇殑灏忚鍒欙級鐨勫垽鏂粨鏋滀负true")
+		// 鏍规嵁cameraId鍘绘洿鏂版垨鑰呮彃鍏ョ粨鏋�,鐒跺悗鍒ゆ柇鏄惁鏁扮粍鏄惁鍙互寰楀嚭鎶ヨ鐨勭粨璁�
+		// 寰�鑱斿姩浠诲姟鐨勭粨鏋滄暟缁勯噷鏀惧�兼垨鏇存柊
+		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] = []structure.Result{}
+						for _, res := range result.([]structure.Result) {
+							tempMap[k] = append(tempMap[k].([]structure.Result), res)
+						}
+					}
+					if k == "face" {
+						tempMap[k] = []structure.Result{}
+						for _, res := range result.([]structure.Result) {
+							tempMap[k] = append(tempMap[k].([]structure.Result), res)
+						}
+					}
+				}
+				va.CacheData = structure.ResultMsg{message, tempMap}
+				logger.Info("杩欎釜鎽勫儚鏈�--", args.CameraId, "--琚祴浜堜簡result", va.Result)
+			}
+		}
+		// 鍒ゆ柇缁撴灉鏁扮粍鏄惁瀹屾弧(鍗宠璧嬪�煎畬姣�)鍙緱鍑烘姤璀︾粨鏋�
+		var isPerfect = true
+		for _, va := range timeEle.RuleResults {
+			//logger.Info("---------------------鐬呯瀰褰撳墠鏁扮粍________________锛�", *va)
+			if va.Result == "" && va.RuleWithPre != "||" {
+				isPerfect = false
+			}
+		}
+		if isPerfect {
+			logger.Debug("鏁扮粍瀹屾弧浜嗭紝鑱斿姩浠诲姟鍙互鎴愬姛鎶ヨ浜嗭紒")
+			// 灏嗘暟缁勬寜sort鎺掑簭
+			sort.Sort(SubList(timeEle.RuleResults))
+			// 鎺掑簭鍚庡彇鍚勮嚜鐨勭粨鏋滃拰杩炴帴绗︽嫾鍑鸿鍒欒〃杈惧紡寰楀嚭缁撴灉
+			completeFormula := ""
+			for _, va := range timeEle.RuleResults {
+				completeFormula = completeFormula + va.RuleWithPre + "" + va.Result
+			}
+			logger.Info("---------------------------鑱斿姩浠诲姟鐨勫叕寮�", completeFormula)
+			if completeFormula != "" {
+				expression, _ := govaluate.NewEvaluableExpression(completeFormula)
+				result, _ := expression.Evaluate(nil) // 寰楀埌鏁板鍏紡鐨勭粨鏋�
+				if result.(bool) {
+					logger.Info("___________________________________________________________________鑱斿姩浠诲姟鎶ヨ")
+					rw.RLock()
+					if TimeEleList[groupRule.GroupId] != nil {  // 鏋佸伓灏旀湁鎯呭喌浼氱瓑浜巒il锛屼笉鐭ラ亾涓哄暐锛屽仛涓垽鏂互闃插畷鏈�
+						// 鎶婃暟缁勯噷缂撳瓨鐨勬暟鎹彇鍑烘潵涓�璧锋姤璀�
+						label.LinkCache = []structure.ResultMsg{}
+						for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults {
+							label.LinkCache = append(label.LinkCache, ruleRes.CacheData)
+						}
+
+						for i := 0; i < len(args.RuleResult["yolo"].([]structure.Result)); i++ {
+							if args.RuleResult["yolo"].([]structure.Result)[i].RuleGroupId == groupRule.GroupId { // 鎶婅仈鍔ㄦ暟鎹拷鍔犱笂
+								args.RuleResult["yolo"].([]structure.Result)[i].Others.LinkCache = label.LinkCache
+							}
+						}
+						for i := 0; i < len(args.RuleResult["face"].([]structure.Result)); i++ {
+							if args.RuleResult["face"].([]structure.Result)[i].RuleGroupId == groupRule.GroupId { // 鎶婅仈鍔ㄦ暟鎹拷鍔犱笂
+								args.RuleResult["face"].([]structure.Result)[i].Others.LinkCache = label.LinkCache
+							}
+						}
+					}
+					rw.RUnlock()
+				}
+			}
+		} else {
+			logger.Warn("鏁扮粍涓嶅渾婊′笉鎵撴爣绛�")
+			// 鍊掓槸鎶婃墦鐨勭粍瑙勫垯鏍囩缁欏幓鎺変簡鍟�
+			for _,val := range labelTypes {
+				if val == 0 {
+					if len(args.RuleResult["yolo"].([]structure.Result)) >= 1 {
+						lens := len(args.RuleResult["yolo"].([]structure.Result))-1
+						args.RuleResult["yolo"] = args.RuleResult["yolo"].([]structure.Result)[0:lens]
+					}
+				}
+				if val == 1 {
+					if len(args.RuleResult["face"].([]structure.Result)) >= 1 {
+						lens := len(args.RuleResult["face"].([]structure.Result))-1
+						args.RuleResult["face"] = args.RuleResult["face"].([]structure.Result)[0:lens]
+					}
+				}
+			}
+		}
+	} else { // 娌℃湁鎶ヨ锛�
+		//logger.Info("杩欏抚鍥惧儚鍦ㄤ换鍔′笅鐨勪竴鏁存潯瑙勫垯涓嬶紙鑱斿姩浠诲姟涓嬪氨鏄窡鏈憚鍍忔満鍍忕浉鍏崇殑灏忚鍒欙級鐨勫垽鏂粨鏋滀负false")
+		// 鎵�浠ヤ篃瑕佸幓缁撴灉鏁扮粍閲屾斁鍊兼垨鏇存柊   07/30澶囨敞锛�  涓嶅簲鏀惧�硷紝搴斿垹闄ゅ畾鏃跺櫒锛岀瓑涓簍rue鏃跺啀搴﹀紑鍚�
+		//for _, va := range timeEle.RuleResults {
+		//	if args.CameraId != "" && va.CameraId == args.CameraId {
+		//		va.Result = strconv.FormatBool(isOk)
+		//	}
+		//}
+		rw.Lock()
+		for k, _ := range TimeEleList {
+			if k == groupRule.GroupId {
+				delete(TimeEleList, k)
+				logger.Debug("鍥犱负瀹氭椂鍣ㄧ殑涓�甯ф暟鎹粨鏋滀负false锛屽共鎺夊畾鏃跺櫒")
+			}
+		}
+		rw.Unlock()
+		// 鍥犱负鏈抚鏁版嵁涓嶇鍚堣鍒欙紝鎵�浠ヤ篃涓嶇敤缁熻缁撴灉鏁扮粍閲岀殑涓滆タ
+	}
+}
+
+// 濡傛灉鏈夋寔缁椂闂存潯浠剁淮鎶ゅ紑鍚竴涓畾鏃跺櫒
+func duration(rule *protomsg.Rule, groupId string, am *structure.AreaMap, args *structure.SdkDatas, message *protomsg.SdkMessage, label structure.Others){
+	// cacheId := ""
+	if rule.PolygonId == am.AreaId { // 棣栧厛瑙勫垯鎵�瀵瑰簲鐨勫尯鍩焛d瑕佽窡鍖哄煙鏁版嵁鐨刬d瀵圭殑涓�  閰嶇疆鐨勭畻娉曡瀵圭殑涓�
+		if rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a977" {  // 鎺掗櫎瀵圭敾闈腑鍗曚釜鐩爣鐨勭畻娉曪紝涓綋闈欐浠ュ強闈犲彸琛岃繖绉�
+			return
+		}
+		if rule.SdkArgAlias == "duration" {
+			//logger.Info("褰撳墠灏忚鍒欐槸锛�---------", rule)
+			// 鍏堢湅鐪嬪畾鏃跺櫒鍏冪礌闃熷垪涓槸鍚︽湁杩欐潯瑙勫垯鐨勫畾鏃跺櫒,濡傛灉鏈夊氨涓嶈兘鍐嶆鍒涘缓浜�
+			rw.Lock()
+			var flag bool = true
+			for k, _ := range TimeEleList {
+				if k == groupId+"+"+rule.Id {
+					flag = false // 鏈夊氨缃负false
+					//logger.Info("鏈夎繖涓畾鏃跺櫒锛屼笉鍐嶅垱寤轰簡锛�")
+				}
+			}
+
+			if flag {
+				m := make(map[string]interface{})
+				m["yolo"] = []structure.Result{}
+				m["yolo"] = append(m["yolo"].([]structure.Result), structure.Result{args.TaskId, "", "", true, 0, "", am.FilterData, am.AreaJson, false,label})
+				timeLength, _ := strconv.Atoi(rule.SdkArgValue)
+				timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, BufferFlag: 10, CacheSdkData: structure.ResultMsg{message, m}} // 鎵旇繘鍘讳竴涓畾鏃跺櫒鍏冪礌锛堝苟缂撳瓨褰撳墠鐢婚潰甯ф暟鎹級
+				//TimeEleList = make(map[string]timeElement)
+				TimeEleList[groupId+"+"+rule.Id] = &timeEle // 瀹氭椂鍣ㄥ厓绱犱互褰撳墠鎸佺画鏃堕棿灏忚鍒檌d涓洪敭
+				logger.Info("鍒涘缓浜嗚鏁板櫒")
+				//cacheId = groupId+"+"+rule.Id
+			}
+			rw.Unlock()
+		}
+	}
+	return
+}
+

--
Gitblit v1.8.0