~jinersong/ruleprocess.git

			@@ -132,9 +132,10 @@

			// 往es中插入人脸数据
			func InsertFace(msg ruleserver.ResultMsg) {
			if msg.RuleResult["face"] != nil && len(msg.RuleResult["face"].([]ruleserver.Arg)) > 0 {
			if msg.RuleResult["face"] != nil && len(msg.RuleResult["face"].([]ruleserver.FaceResult)) > 0 {
			logger.Info("往ES插人脸数据")
			for _, face := range msg.RuleResult["face"].([]ruleserver.Arg) {
			for _, faceResult := range msg.RuleResult["face"].([]ruleserver.FaceResult) {
			for _,face := range faceResult.Args {
			// 上传大图
			// 解压缩并上传图片
			bdata, err := util.UnCompress(msg.Data)
			@@ -220,6 +221,7 @@
			}
			}
			}
			}
			func ChangeStatusFace(msg ruleserver.ResultMsg) {
			logger.Info("往ES插入人脸非报警但是状态转换数据")
			// 上传大图

			@@ -93,7 +93,7 @@
			// 过规则库打上的标签
			type FaceResult struct {
			Result
			Args []*Arg
			Args []Arg
			}
			type LittleRuleResult struct {
			SdkName string // 记录下此结果是哪个sdk的结果
			@@ -299,7 +299,8 @@
			logger.Info("-------------------yolo结果标签长度", len(args.RuleResult["yolo"].([]Result)))
			}
			if args.RuleResult["face"] != nil {
			logger.Info("-------------------face结果标签", len(args.RuleResult["face"].([]Arg)))
			args.RuleResult["face"] = append(args.RuleResult["face"].([]FaceResult), FaceResult{Result{taskId, sdkNames, groupRule.GroupId, groupRule.AlarmLevel, groupRule.GroupText, []Rect{}, polygonId},faces})
			logger.Info("-------------------face结果标签", len(args.RuleResult["face"].(FaceResult).Args))
			}
			// 最后过持续时间等时间维度的条件把时间规则位置调整到这个位置是为了缓存数据
			for j := 0; j < len(groupRule.Rules); j++ {

	insertdata/insertDataToEs.go	6 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	ruleserver/ruleToformula.go	5 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史