panlei
2019-07-30 44441d5439df4e81d641b115c94b079ace31a5c6
insertdata/insertDataToEs.go
@@ -120,17 +120,19 @@
   logger.Debug("插入数据前看看报警标志位:", timeLabel)
   if timeLabel == "01" { // 无定时器状态要插入的报警数据
      InsertFace(msg)
      InsertYolo(msg)
      flag := ruleserver.BodyIsSame(msg.SdkMessage)
      if !flag {
         InsertYolo(msg)
      }
   }
   if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧
      InsertFace(msg)
      InsertYolo(msg)
   }
   if timeLabel == "12" { // 并非报警数据,只是状态改变的数据
      //ChangeStatusFace(msg)
      ChangeStatusYolo(msg)
   }
   //if timeLabel == "12" { // 并非报警数据,只是状态改变的数据
   //   //ChangeStatusFace(msg)
   //   ChangeStatusYolo(msg)
   //}
}
// 往es中插入人脸数据
@@ -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,