---

panlei

2019-07-27 16bad47d4f13758fb183abb577b93a8d80d77318

 insertdata/insertDataToEs.go

@@ -1,6 +1,7 @@
package insertdata

import (
   "encoding/base64"
   "encoding/json"
   "errors"
   "fmt"
@@ -176,9 +177,9 @@
            }
            race := getRaceString(face.ThftRes.Race)
            ageDescription := getDescription(face.ThftRes.Age)

            esDataId := uuid.NewV4().String()
            pervideo := PerVideoPicture{
               uuid.NewV4().String(),
               esDataId,
               msg.Cid,
               camera.Addr,
               i.Timestamp,
@@ -195,7 +196,7 @@
               race,
               face.ThftRes.Smile,
               face.ThftRes.Beauty,
               string(face.Feature),
               base64.StdEncoding.EncodeToString(face.Feature),
               []string{strings.Split(resp["fileUrl"].(string), "/")[1]},
               "暂无集群",
               localConfig.ServerId,
@@ -221,7 +222,7 @@
            } 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{}, Type:1})
               ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:1})
            }
         }
      }
@@ -252,8 +253,9 @@
      logger.Error("查询摄像机信息失败")
   }

   esDataId := uuid.NewV4().String()
   pervideo := PerVideoPicture{
      uuid.NewV4().String(),
      esDataId,
      msg.Cid,
      camera.Addr,
      i.Timestamp,
@@ -297,7 +299,7 @@
   } 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{}, Type:1 })
      ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:1 })
   }
   //if msg.RuleResult["cacheData"] != nil {
   //   InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
@@ -371,8 +373,9 @@
         }
         url = append(url, strings.Split(resp1["fileUrl"].(string), "/")[1])
      }
      esDataId := uuid.NewV4().String()
      peraction := Personaction{
         uuid.NewV4().String(),
         esDataId,
         msg.Cid,
         camera.Name,
         camera.Addr,
@@ -406,7 +409,7 @@
      } 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{}, Type:2 })
         ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:2 })
         logger.Warn("__________________________________________往ES插入yolo数据成功")
         //os.Exit(1)
      }
@@ -441,8 +444,9 @@
      logger.Error("查询摄像机信息失败")
   }
   serverIp, err := GetLocalIP()
   esDataId := uuid.NewV4().String()
   peraction := Personaction{
      uuid.NewV4().String(),
      esDataId,
      msg.Cid,
      camera.Name,
      camera.Addr,
@@ -476,7 +480,7 @@
   } 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{}, Type:2 })
      ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:2 })
      logger.Warn("__________________________________________往ES插入yolo数据成功")
      //os.Exit(1)
   }