换ip

panlei

2019-07-19 68c576e6f05a8913bc8f6f60dd2ca03314a7136d

 insertdata/insertDataToEs.go

@@ -209,9 +209,12 @@
            logger.Info("json parse error ", err)
            return
         }
         err1 := EsReq("POST", videoPersonUrl, requstbody)
         resp1, err1 := EsReq("POST", videoPersonUrl, requstbody)
         if err1 != nil {
            logger.Error("上传ES出错！---", err1)
         } else {
            logger.Info("插入es返回的信息：", resp1)
            ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}})
         }
      }
   }
@@ -278,9 +281,13 @@
      logger.Info("json parse error ", err)
      return
   }
   err1 := EsReq("POST", videoPersonUrl, requstbody)
   resp1, err1 := EsReq("POST", videoPersonUrl, requstbody)

   if err1 != nil {
      logger.Error("上传ES出错！---", err1)
   } else {
      logger.Info("插入es返回的信息：", resp1)
      ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}})
   }
   //if msg.RuleResult["cacheData"] != nil {
   //   InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
@@ -362,10 +369,13 @@
         return

      }
      err = EsReq("POST", personAction, requstbody)
      if err != nil {
      resp1, err2 := EsReq("POST", personAction, requstbody)
      if err2 != nil {
         logger.Error("往ES插入数据失败", err)
      } else {
         logger.Debug("插入es返回的数据信息是：", resp1)
         // 发出录像信号
         ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}})
         logger.Warn("__________________________________________往ES插入yolo数据成功")
         //os.Exit(1)
      }
@@ -432,10 +442,12 @@
      return

   }
   err = EsReq("POST", personAction, requstbody)
   if err != nil {
   resp1, err1 := EsReq("POST", personAction, requstbody)
   if err1 != nil {
      logger.Error("往ES插入数据失败", err)
   } else {
      logger.Info("插入es返回的信息：", resp1)
      ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}})
      logger.Warn("__________________________________________往ES插入yolo数据成功")
      //os.Exit(1)
   }