~jinersong/ruleprocess.git

			@@ -117,7 +117,7 @@
			// 拿到本摄像机的区域
			cameraPolygons := GetPolygons(args.CameraId)
			// 把所有的sdk提取的数据都按所属摄像机的区域归置
			//logger.Debug("当前摄像机id为：",message.Cid,"当前摄像机执行的任务是：",message.Tasklab.Taskname)
			logger.Debug("当前摄像机id为：",message.Cid,"当前摄像机执行的任务是：",message.Tasklab.Taskname,"--任务id为：",message.Tasklab.Taskid)
			for _, arg := range args.Sdkdata {
			SdkDataFormat(args.CameraId, arg, cameraPolygons)
			}
			@@ -336,6 +336,7 @@
			}
			}
			}
			logger.Info("face标签的长度：",len(faces))
			//for _,face := range faces {
			// //logger.Debug("————————————————________________看看人脸的坐标:",face.Location)
			//}
			@@ -363,14 +364,6 @@
			if faceFlag {
			args.RuleResult["face"] = append(args.RuleResult["face"].([]FaceResult), FaceResult{Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, []Rect{}, polygonId, islink,label,}, faces})
			//logger.Info("-------------------face结果标签", len(args.RuleResult["face"].([]FaceResult)))
			logger.Info("过完规则时查看人脸标签：")
			if args.RuleResult["face"] != nil && len(args.RuleResult["face"].([]FaceResult)) > 0 {
			for _, faceResult := range args.RuleResult["face"].([]FaceResult) {
			for _,arg := range faceResult.Args {
			logger.Info("人员分值是：",arg.Score,"liker的数量为",arg.Liker)
			}
			}
			}
			}
			return true
			} else {
			@@ -378,8 +371,8 @@
			}

			} else {
			// 结果为假时也要走，有时候为假的状态反转数据也需要记录下来
			//timeFlag := TimerAlarm(args, groupRule.GroupId, result.(bool))
			// 结果为假时也要走，有杀死定时器的操作
			TimerAlarm(&label, groupRule.GroupId, result.(bool))
			//fmt.Println(timeFlag)
			return false
			}
			@@ -499,26 +492,33 @@
			result, _ := expression.Evaluate(nil) // 得到数学公式的结果
			if result.(bool) {
			logger.Info("___________________________________________________________________联动任务报警")
			// 把数组里缓存的数据取出来一起报警
			label.LinkCache = []ResultMsg{}
			for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults {
			label.LinkCache = append(label.LinkCache, ruleRes.CacheData)
			}
			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
			if TimeEleList[groupRule.GroupId] != nil { // 极偶尔有情况会等于nil，不知道为啥，做个判断以防宕机
			// 把数组里缓存的数据取出来一起报警
			label.LinkCache = []ResultMsg{}
			for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults {
			label.LinkCache = append(label.LinkCache, ruleRes.CacheData)
			}
			}
			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
			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 {
			logger.Warn("数组不圆满不打标签")
			// 倒是把打的组规则标签给去掉了啊
			if len(args.RuleResult["yolo"].([]Result)) > 1 {
			lens := len(args.RuleResult["yolo"].([]Result))-1
			args.RuleResult["yolo"] = args.RuleResult["yolo"].([]Result)[0:lens]
			}
			}
			} else { // 没有报警，
			//logger.Info("这帧图像在任务下的一整条规则下（联动任务下就是跟本摄像机像相关的小规则）的判断结果为false")
			@@ -547,24 +547,28 @@
			if rule.PolygonId == am.areaId { // 算法和区域都得对的上

			if rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a972" && rule.SdkArgAlias != "time_rule"{
			//logger.Debug("当前小规则是：",rule)
			flag := "false"
			// 把没有相似者的人脸从filterData中删除
			for index := 0; index < len(am.filterData); {
			// 将达不到阈值的相似者从相似者数组中删除
			logger.Info("看看相似者人数：",len(am.filterData[index].Liker))
			if len(am.filterData[index].Liker) == 0 {
			// Go 语言中切片删除元素的本质是：以被删除元素为分界点，将前后两个部分的内存重新连接起来。不用怀疑，数组删除元素就这么坑爹
			am.filterData = append(am.filterData[:index], am.filterData[index+1:]...)
			} else {
			index++
			if rule.RuleWithPre == "\|\|" {
			return LittleRuleResult{}
			} else {
			//logger.Debug("当前小规则是：",rule)
			flag := "false"
			// 把没有相似者的人脸从filterData中删除
			for index := 0; index < len(am.filterData); {
			// 将达不到阈值的相似者从相似者数组中删除
			logger.Info("看看相似者人数：",len(am.filterData[index].Liker))
			if len(am.filterData[index].Liker) == 0 {
			// Go 语言中切片删除元素的本质是：以被删除元素为分界点，将前后两个部分的内存重新连接起来。不用怀疑，数组删除元素就这么坑爹
			am.filterData = append(am.filterData[:index], am.filterData[index+1:]...)
			} else {
			index++
			}
			}
			if len(am.filterData) > 0 {
			flag = "true"
			}
			logger.Info("---------人脸比对符合条件的数量为：",len(am.filterData))
			return LittleRuleResult{am.sdkName, rule.RuleWithPre + "" + flag, rule.Sort}
			}
			if len(am.filterData) > 0 {
			flag = "true"
			}
			logger.Info("---------人脸比对符合条件的数量为：",len(am.filterData))
			return LittleRuleResult{am.sdkName, rule.RuleWithPre + "" + flag, rule.Sort}
			}
			if rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a97e" { // 人脸检测
			//logger.Debug("当前小规则是：",rule)
			@@ -578,6 +582,7 @@
			//logger.Info("过滤后的args的长度为：",len(args))
			} else {
			args = am.args
			//不清空之前的过滤数据，继续塞
			//logger.Info("没过滤的args的长度为：",len(args))
			}
			// 先清空过滤后的数据，再往里塞本次过滤后的数据