---

panlei

2019-08-01 866988e990d88381b5d5ecb88cb859a4b35d2aaa

 insertdata/insertDataToEs.go

@@ -323,8 +323,8 @@
      // 先判断一下数据带的规则标签是否有可以插入的
      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" {
         logger.Info("定时器打的数字标签：",res.Others.TimeLabel)
         if res.Others.TimeLabel == "01" || res.Others.TimeLabel == "10" {
            flag = true
         }
      }
@@ -334,18 +334,18 @@
         alarmRules := []AlarmRule{}
         url := []string{}
         for _, yoloResult := range msg.RuleResult["yolo"].([]ruleserver.Result) {
            if yoloResult.Others["timeLabel"].(string) == "01" || yoloResult.Others["timeLabel"].(string) == "10" {
            if yoloResult.Others.TimeLabel == "01" || yoloResult.Others.TimeLabel == "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})
               // 上传缓存数据的图片拿到url
               if yoloResult.Others["cacheData"] != nil {
               if yoloResult.Others.CacheData != nil {
                  //InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
                  // 把缓存的数据上传后得到地址存进去
                  // 解压缩并上传图片
                  msgs := yoloResult.Others["cacheData"].([]ruleserver.ResultMsg)
                  msgs := yoloResult.Others.CacheData
                  for _, msg1 := range msgs {
                     bdata, err := util.UnCompress(msg1.Data)
                     if err != nil {
@@ -366,21 +366,14 @@
         }
         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)) > 1{
               for _, msg2 := range yoloResult.Others["linkCache"].([]ruleserver.ResultMsg) {
            if (yoloResult.Others.TimeLabel == "01" || yoloResult.Others.TimeLabel == "10") && yoloResult.Others.LinkCache != nil && len(yoloResult.Others.LinkCache) > 1{
               for _, msg2 := range yoloResult.Others.LinkCache {
                  logger.Warn("插入联动数据")
                  for _,nihao := range msg2.RuleResult["yolo"].([]ruleserver.Result)  {
                     num := 1
                     for k,_ := range nihao.Others {
                        logger.Info("第",num,"次键：",k)
                     }
                     num++
                  }
                  //logger.Warn("哈哈哈哈哈",[0].Others["linkCache"].([]ruleserver.ResultMsg))
                  InsertYolo(msg2)
                  logger.Warn("兄弟难道你陷入了死循环吗")
                  linkFlag = true
                  os.Exit(1)
                  //os.Exit(1)
               }
            }
         }
@@ -390,7 +383,7 @@
            os.Exit(1)
            return
         }
         logger.Info("--------走到这儿就不一样")
         //logger.Info("--------走到这儿就不一样")
         isAlarm := 0
         resp := make(map[string]interface{})
         // 解压缩并上传图片