容错5改为3

panlei

2019-07-23 0e669ac6b266466fec8472d02b3ce87134de82a7

 insertdata/insertDataToEs.go

@@ -209,9 +209,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{}})
         }
      }
   }
@@ -278,9 +282,14 @@
      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))
@@ -333,6 +342,11 @@
         logger.Error("查询摄像机信息失败")
      }
      serverIp, err := GetLocalIP()
      if msg.RuleResult["cacheData"] != nil {
         InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
         // 把缓存的数据上传后得到地址存进去
			
      }
      peraction := Personaction{
         uuid.NewV4().String(),
         msg.Cid,
@@ -362,15 +376,15 @@
         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)
      }
      if msg.RuleResult["cacheData"] != nil {
         InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      }
   }
}
@@ -432,10 +446,13 @@
      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)
   }