--

panlei

2019-11-13 2d0ec0a2d038f962648f4b5acaea892113ac112f

 insertdata/insertDataToEs.go

@@ -70,7 +70,42 @@
   BaseInfo        []*structure.BaseInfo `json:"baseInfo"`
   TargetInfo      []Target              `json:"targetInfo"`
   LinkTag         string                `json:"linkTag"`
   LinkTagInfo     []*PerVideoPicture    `json:"linkTagInfo"`
   LinkTagInfo     []*LinkInfo           `json:"linkTagInfo"`
}

type LinkInfo struct {
   Id              string                `json:"id"`
   CameraId        string                `json:"cameraId"`
   CameraAddr      string                `json:"cameraAddr"`
   CameraName      string                `json:"cameraName"`
   PicDate         string                `json:"picDate"`
   PicMaxUrl       string                `json:"picMaxUrl"`
   TaskId          string                `json:"taskId"`
   TaskName        string                `json:"taskName"`
   SdkName         string                `json:"sdkName"`
   Content         string                `json:"content"`
   AlarmRules      []AlarmRule           `json:"alarmRules"`
   LikeDate        string                `json:"likeDate"`
   Sex             string                `json:"sex"`
   Age             int32                 `json:"age"`
   AgeDescription  string                `json:"ageDescription"`
   Race            string                `json:"race"`
   SmileLevel      int32                 `json:"smileLevel"`
   BeautyLevel     int32                 `json:"beautyLevel"`
   FaceFeature     string                `json:"faceFeature"`
   PicSmUrl        []string              `json:"picSmUrl"`
   VideoUrl        string                `json:"videoUrl"`
   AnalyServerId   string                `json:"analyServerId"`
   AnalyServerName string                `json:"analyServerName"`
   AnalyServerIp   string                `json:"analyServerIp"`
   ClusterId       string                `json:"clusterId"`
   DetectScore     float64               `json:"detectScore"`
   IsAlarm         int                   `json:"isAlarm"`
   IsAckAlarm      int                   `json:"isAckAlarm"`
   IsCollect       int                   `json:"isCollect"`
   IsDelete        int                   `json:"isDelete"`
   BaseInfo        []*structure.BaseInfo `json:"baseInfo"`
   TargetInfo      []Target              `json:"targetInfo"`
}

type Target struct {
@@ -91,29 +126,29 @@

//  yolo行为的数据结构
type Personaction struct {
   Id              string             `json:"id"`
   CameraId        string             `json:"cameraId"`
   CameraName      string             `json:"cameraName"`
   CameraAddr      string             `json:"cameraAddr"`
   TaskId          string             `json:"taskId"`
   TaskName        string             `json:"taskName"`
   SdkName         string             `json:"sdkName"`
   Content         string             `json:"content"`
   AlarmRules      []AlarmRule        `json:"alarmRules"`
   AnalyServerId   string             `json:"analyServerId"`
   AnalyServerName string             `json:"analyServerName"`
   AnalyServerIp   string             `json:"analyServerIp"`
   ClusterId       string             `json:"clusterId"`
   PicSmUrl        []string           `json:"picSmUrl"`
   PicDate         string             `json:"picDate"`
   VideoUrl        string             `json:"videoUrl"`
   IsAlarm         int                `json:"isAlarm"`
   IsAckAlarm      int                `json:"isAckAlarm"`
   IsCollect       int                `json:"isCollect"`
   IsDelete        int                `json:"isDelete"`
   TargetInfo      []Target           `json:"targetInfo"`
   LinkTag         string             `json:"linkTag"`
   LinkTagInfo     []*PerVideoPicture `json:"linkTagInfo"`
   Id              string      `json:"id"`
   CameraId        string      `json:"cameraId"`
   CameraName      string      `json:"cameraName"`
   CameraAddr      string      `json:"cameraAddr"`
   TaskId          string      `json:"taskId"`
   TaskName        string      `json:"taskName"`
   SdkName         string      `json:"sdkName"`
   Content         string      `json:"content"`
   AlarmRules      []AlarmRule `json:"alarmRules"`
   AnalyServerId   string      `json:"analyServerId"`
   AnalyServerName string      `json:"analyServerName"`
   AnalyServerIp   string      `json:"analyServerIp"`
   ClusterId       string      `json:"clusterId"`
   PicSmUrl        []string    `json:"picSmUrl"`
   PicDate         string      `json:"picDate"`
   VideoUrl        string      `json:"videoUrl"`
   IsAlarm         int         `json:"isAlarm"`
   IsAckAlarm      int         `json:"isAckAlarm"`
   IsCollect       int         `json:"isCollect"`
   IsDelete        int         `json:"isDelete"`
   TargetInfo      []Target    `json:"targetInfo"`
   LinkTag         string      `json:"linkTag"`
   LinkTagInfo     []*LinkInfo `json:"linkTagInfo"`
}

type AlarmRule struct {
@@ -237,7 +272,7 @@
               face.Liker,
               targetInfos,
               "",
               []*PerVideoPicture{},
               []*LinkInfo{},
            }
            requstbody, err := json.Marshal(pervideo)

@@ -376,7 +411,7 @@
            }
         }

         linkTagInfos := []*PerVideoPicture{}
         linkTagInfos := []*LinkInfo{}
         for _, yoloResult := range msg.RuleResult["yolo"].([]structure.Result) {
            if (yoloResult.Others.TimeLabel == "01" || yoloResult.Others.TimeLabel == "10") && yoloResult.Others.LinkCache != nil && len(yoloResult.Others.LinkCache) > 1 {
               for _, msg2 := range yoloResult.Others.LinkCache {
@@ -442,7 +477,13 @@
               linkTagInfos,
            }
            requstbody, err := json.Marshal(peraction)
            var m map[string]interface{}
            json.Unmarshal(requstbody, &m)
            logger.Info("上传参数json:",m)

            if len(linkTagInfos)>0 {
               logger.Info("联动任务")
            }
            if err != nil {
               logger.Info("json parse error ", err)
               return
@@ -547,7 +588,7 @@
   return race
}

func msg2PersonVideo(msg structure.ResultMsg) *PerVideoPicture {
func msg2PersonVideo(msg structure.ResultMsg) *LinkInfo {
   if msg.RuleResult["yolo"] != nil && len(msg.RuleResult["yolo"].([]structure.Result)) > 0 {
      // 先判断一下数据带的规则标签是否有可以插入的
      flag := false
@@ -645,7 +686,7 @@
         if resp["fileUrl"] != nil {
            url = append(url, resp["fileUrl"].(string))
            //esDataId := uuid.NewV4().String()
            pervideo := &PerVideoPicture{
            pervideo := &LinkInfo{
               msg.Push.PushId + "-" + uuid.NewV4().String(),
               msg.Cid,
               msg.Push.Cam.Addr,
@@ -678,8 +719,6 @@
               0,
               nil,
               targetInfos,
               "",
               []*PerVideoPicture{},
            }
            return pervideo
         } else {