缓存数据空指针控制

panlei

2019-07-13 a45592706eb49497bda7e69e27cd76bd2da28ae7

 insertdata/insertDataToEs.go

@@ -6,7 +6,6 @@
   "fmt"
   "io/ioutil"
   "net"
   "os"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "strings"
@@ -170,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,
@@ -239,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,
@@ -292,15 +291,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 {
@@ -340,7 +339,7 @@
         serverIp,
         "",
         []string{strings.Split(resp["fileUrl"].(string), "/")[1]},
         time.Now().Format("2006-01-02 15:04:05"),
         i.Timestamp,
         "",
         isAlarm,
         0,
@@ -361,9 +360,9 @@
         logger.Warn("__________________________________________往ES插入yolo数据成功")
         //os.Exit(1)
      }
      logger.Debug("============瞅瞅缓存数据：",msg.RuleResult["cacheData"].(ruleserver.ResultMsg).RuleResult)
      InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      os.Exit(1)
      if msg.RuleResult["cacheData"] != nil {
         InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      }
   }
}
func ChangeStatusYolo(msg ruleserver.ResultMsg) {
@@ -410,7 +409,7 @@
      serverIp,
      "",
      []string{strings.Split(resp["fileUrl"].(string), "/")[1]},
      time.Now().Format("2006-01-02 15:04:05"),
      i.Timestamp,
      "",
      0,
      0,