---

panlei

2019-07-31 5c029fad17da0b4bff16cb78b5de193cc367be47

 insertdata/insertDataToEs.go

@@ -323,6 +323,7 @@
      // 先判断一下数据带的规则标签是否有可以插入的
      flag := false
      for _, res := range msg.RuleResult["yolo"].([]ruleserver.Result) {
         logger.Info("定时器打的数字标签：",res.Others["timeLabel"].(string))
         if res.Others["timeLabel"].(string) == "01" || res.Others["timeLabel"].(string) == "10" {
            flag = true
         }
@@ -335,6 +336,7 @@
         for _, yoloResult := range msg.RuleResult["yolo"].([]ruleserver.Result) {
            if yoloResult.Others["timeLabel"].(string) == "01" || yoloResult.Others["timeLabel"].(string) == "10" {
               // 拼出sdkname
               logger.Info("应该进来才对的")
               sdkNames = sdkNames + yoloResult.SdkName
               alarm := ChangeToString(yoloResult.DefenceState, yoloResult.AlarmLevel)
               alarmRules = append(alarmRules, AlarmRule{yoloResult.RuleGroupId, alarm, yoloResult.RuleText, yoloResult.DefenceState})
@@ -364,10 +366,12 @@
         }
         linkFlag := false
         for _, yoloResult := range msg.RuleResult["yolo"].([]ruleserver.Result) {
            if (yoloResult.Others["timeLabel"].(string) == "01" || yoloResult.Others["timeLabel"].(string) == "10") && yoloResult.Others["linkCache"] != nil && len(yoloResult.Others["linkCache"].([]*ruleserver.ResultMsg)) > 0{
               for _, msg2 := range yoloResult.Others["linkCache"].([]*ruleserver.ResultMsg) {
            if (yoloResult.Others["timeLabel"].(string) == "01" || yoloResult.Others["timeLabel"].(string) == "10") && yoloResult.Others["linkCache"] != nil && len(yoloResult.Others["linkCache"].([]ruleserver.ResultMsg)) > 0{
               for _, msg2 := range yoloResult.Others["linkCache"].([]ruleserver.ResultMsg) {
                  logger.Warn("插入联动数据")
                  InsertYolo(*msg2)
                  logger.Warn("哈哈哈哈哈",msg2.RuleResult)
                  InsertYolo(msg2)
                  logger.Warn("兄弟难道你陷入了死循环吗")
                  linkFlag = true
               }
            }
@@ -377,6 +381,7 @@
            os.Exit(1)
            return
         }
         logger.Info("--------走到这儿就不一样")
         isAlarm := 0
         resp := make(map[string]interface{})
         // 解压缩并上传图片