3改为2

panlei

2019-07-23 3426d9bfe50cfe7d19b22efac095a2f81a902585

 insertdata/insertDataToEs.go

@@ -214,6 +214,7 @@
            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{}})
         }
      }
@@ -287,6 +288,7 @@
      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 {
@@ -340,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,
@@ -378,9 +385,6 @@
         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))
      }
   }
}
@@ -447,6 +451,7 @@
      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)