panlei
2019-07-30 44441d5439df4e81d641b115c94b079ace31a5c6
insertdata/insertDataToEs.go
@@ -120,8 +120,10 @@
   logger.Debug("插入数据前看看报警标志位:", timeLabel)
   if timeLabel == "01" { // 无定时器状态要插入的报警数据
      InsertFace(msg)
      ruleserver.BodyIsSame(msg.SdkMessage)
      InsertYolo(msg)
      flag := ruleserver.BodyIsSame(msg.SdkMessage)
      if !flag {
         InsertYolo(msg)
      }
   }
   if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧
      InsertFace(msg)
@@ -354,9 +356,8 @@
      }
      serverIp, err := GetLocalIP()
      url := []string{}
      url = append(url, strings.Split(resp["fileUrl"].(string), "/")[1])
      if msg.RuleResult["cacheData"] != nil {
         InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
         //InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
         // 把缓存的数据上传后得到地址存进去
         // 解压缩并上传图片
         msg1 := msg.RuleResult["cacheData"].(ruleserver.ResultMsg)
@@ -366,7 +367,7 @@
         }
         i := protomsg.Image{}
         err = proto.Unmarshal(bdata, &i)
         resp1, err1 := util.DrawPolygonOnImage(msg.Cid, i, msg.RuleResult["yolo"].([]ruleserver.Result), weedfsUrl)
         resp1, err1 := util.DrawPolygonOnImage(msg1.Cid, i, msg1.RuleResult["yolo"].([]ruleserver.Result), weedfsUrl)
         if err1 != nil {
            logger.Error("缓存数据画框或上传图片服务器出错", err)
         } else {
@@ -374,6 +375,7 @@
         }
         url = append(url, strings.Split(resp1["fileUrl"].(string), "/")[1])
      }
      url = append(url, strings.Split(resp["fileUrl"].(string), "/")[1])
      esDataId := uuid.NewV4().String()
      peraction := Personaction{
         esDataId,