panlei
2019-11-13 77e41325d05d81d65ef004cceca46d6d1a649365
target
1个文件已修改
62 ■■■■ 已修改文件
insertdata/insertDataToEs.go 62 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
insertdata/insertDataToEs.go
@@ -68,9 +68,9 @@
    IsCollect       int                   `json:"isCollect"`
    IsDelete        int                   `json:"isDelete"`
    BaseInfo        []*structure.BaseInfo `json:"baseInfo"`
    TargetInfo      []Target
    LinkTag         string          `json:"linkTag"`
    LinkTagInfo     []*PerVideoPicture `json:"linkTagInfo"`
    TargetInfo      []Target              `json:"targetInfo"`
    LinkTag         string                `json:"linkTag"`
    LinkTagInfo     []*PerVideoPicture    `json:"linkTagInfo"`
}
type Target struct {
@@ -91,28 +91,28 @@
//  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
    LinkTag         string          `json:"linkTag"`
    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"`
}
@@ -202,7 +202,7 @@
                target.TargetLocation = Points{TopLeft: Point{face.Location.X, face.Location.Y}, BottomRight: Point{face.Location.X + face.Location.Width, face.Location.Y + face.Location.Height}}
                //logger.Info("人脸的id:",strconv.FormatUint(face.Id, 10))
                var targetInfos []Target
                targetInfos = append(targetInfos,*target)
                targetInfos = append(targetInfos, *target)
                pervideo := PerVideoPicture{
                    face.Uuid,
                    msg.Cid,
@@ -381,7 +381,7 @@
                if (yoloResult.Others.TimeLabel == "01" || yoloResult.Others.TimeLabel == "10") && yoloResult.Others.LinkCache != nil && len(yoloResult.Others.LinkCache) > 1 {
                    for _, msg2 := range yoloResult.Others.LinkCache {
                        // 把msg2的数据装配成一个PerVideoPicture结构体
                        linkTagInfos = append(linkTagInfos,msg2PersonVideo(msg2))
                        linkTagInfos = append(linkTagInfos, msg2PersonVideo(msg2))
                    }
                }
            }
@@ -547,7 +547,7 @@
    return race
}
func msg2PersonVideo (msg structure.ResultMsg) *PerVideoPicture{
func msg2PersonVideo(msg structure.ResultMsg) *PerVideoPicture {
    if msg.RuleResult["yolo"] != nil && len(msg.RuleResult["yolo"].([]structure.Result)) > 0 {
        // 先判断一下数据带的规则标签是否有可以插入的
        flag := false
@@ -573,7 +573,7 @@
                    if yoloResult.IsLink {
                        linkInfo = "联动任务"
                    }
                    alarmRules = append(alarmRules, AlarmRule{yoloResult.RuleGroupId, alarm, yoloResult.RuleText, yoloResult.DefenceState,linkInfo})
                    alarmRules = append(alarmRules, AlarmRule{yoloResult.RuleGroupId, alarm, yoloResult.RuleText, yoloResult.DefenceState, linkInfo})
                    // 上传缓存数据的图片拿到url
                    if yoloResult.Others.CacheData != nil {
                        //InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
@@ -658,7 +658,7 @@
                    "",
                    alarmRules,
                    time.Now().Format("2006-01-02 15:04:05"), // 只检测,没有比对时间
                    "",                                      //暂改为人脸id strconv.FormatUint(face.Id, 10)
                    "",                                       //暂改为人脸id strconv.FormatUint(face.Id, 10)
                    0,
                    "", // 暂改为分值fmt.Sprintf("%.2f",face.Score)
                    "",
@@ -692,4 +692,4 @@
    } else {
        return nil
    }
}
}