定时器缓冲容错

panlei

2019-07-13 dd753957ef55cbb17dce17771fb17469f90088e6

 insertdata/insertDataToEs.go

@@ -118,7 +118,7 @@

   }
   if timeLabel == "12" { // 并非报警数据，只是状态改变的数据
      ChangeStatusFace(msg)
      //ChangeStatusFace(msg)
      ChangeStatusYolo(msg)
   }
}
@@ -169,7 +169,7 @@
            uuid.NewV4().String(),
            msg.Cid,
            camera.Addr,
            time.Now().Format("2006-01-02 15:04:05"),
            i.Timestamp,
            strings.Split(bigPhotoUrl["fileUrl"].(string), "/")[1],
            msg.Tasklab.Taskid,
            msg.Tasklab.Taskname,
@@ -210,7 +210,7 @@
   }
}
func ChangeStatusFace(msg ruleserver.ResultMsg) {
   logger.Info("往ES插非报警但是状态转换数据")
   logger.Info("往ES插入人脸非报警但是状态转换数据")
      // 上传大图
      // 解压缩并上传图片
      bdata, err := util.UnCompress(msg.Data)
@@ -238,7 +238,7 @@
         uuid.NewV4().String(),
         msg.Cid,
         camera.Addr,
         time.Now().Format("2006-01-02 15:04:05"),
         i.Timestamp,
         strings.Split(bigPhotoUrl["fileUrl"].(string), "/")[1],
         msg.Tasklab.Taskid,
         msg.Tasklab.Taskname,
@@ -275,7 +275,9 @@
      if err1 != nil {
         logger.Error("上传ES出错！---", err1)
      }
      InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      //if msg.RuleResult["cacheData"] != nil {
      //   InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      //}
}

// 往es中插入yolo数据
@@ -291,15 +293,15 @@
      }
      isAlarm := 0
      resp := make(map[string]interface{})
      // 解压缩并上传图片
      bdata, err := util.UnCompress(msg.Data)
      if err != nil {
         panic("解压缩图片时出现错误")
      }
      i := protomsg.Image{}
      err = proto.Unmarshal(bdata, &i)
      if len(alarmRules) > 0 {
         isAlarm = 1
         // 解压缩并上传图片
         bdata, err := util.UnCompress(msg.Data)
         if err != nil {
            panic("解压缩图片时出现错误")
         }
         i := protomsg.Image{}
         err = proto.Unmarshal(bdata, &i)
         //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
         resp, err = util.DrawPolygonOnImage(msg.Cid, i, msg.RuleResult["yolo"].([]ruleserver.Result))
         if err != nil {
@@ -339,7 +341,7 @@
         serverIp,
         "",
         []string{strings.Split(resp["fileUrl"].(string), "/")[1]},
         time.Now().Format("2006-01-02 15:04:05"),
         i.Timestamp,
         "",
         isAlarm,
         0,
@@ -360,8 +362,9 @@
         logger.Warn("__________________________________________往ES插入yolo数据成功")
         //os.Exit(1)
      }
      logger.Debug("============瞅瞅缓存数据：",msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      if msg.RuleResult["cacheData"] != nil {
         InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      }
   }
}
func ChangeStatusYolo(msg ruleserver.ResultMsg) {
@@ -408,7 +411,7 @@
      serverIp,
      "",
      []string{strings.Split(resp["fileUrl"].(string), "/")[1]},
      time.Now().Format("2006-01-02 15:04:05"),
      i.Timestamp,
      "",
      0,
      0,