人脸的路径存成数组，sdkName固定为人脸

panlei

2019-07-03 15e5410c4fab8b9041729ad9a6efaea7c66d5fae

人脸的路径存成数组，sdkName固定为人脸

 insertdata/insertDataToEs.go

@@ -20,34 +20,34 @@
var weedfsUrl = "http://192.168.1.182:6333/submit"
// 人脸的数据结构
type PerVideoPicture struct {
    Id              string `json:"id"`
    CameraId        string `json:"cameraId"`
    CameraAddr      string `json:"cameraAddr"`
    PicDate         string `json:"picDate"`
    PicMaxUrl       string `json:"picMaxUrl"`
    TaskId          string `json:"taskId"`
    TaskName        string `json:"taskName"`
    SdkName         string `json:"sdkName"`
    Content         string `json:"content"`
    LikeDate        string `json:"likeDate"`
    Sex             int32  `json:"sex"`
    Age             int32  `json:"age"`
    AgeDescription  string `json:"ageDescription"`
    Race            int32  `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"`
    IsAlarm         string `json:"isAlarm"`
    IsAckAlarm      string `json:"isAckAlarm"`
    IsCollect       string `json:"isCollect"`
    IsDelete        int    `json:"isDelete"`
    BaseInfo        []Base `json:"baseInfo"`
    Id              string   `json:"id"`
    CameraId        string   `json:"cameraId"`
    CameraAddr      string   `json:"cameraAddr"`
    PicDate         string   `json:"picDate"`
    PicMaxUrl       string   `json:"picMaxUrl"`
    TaskId          string   `json:"taskId"`
    TaskName        string   `json:"taskName"`
    SdkName         string   `json:"sdkName"`
    Content         string   `json:"content"`
    LikeDate        string   `json:"likeDate"`
    Sex             int32    `json:"sex"`
    Age             int32    `json:"age"`
    AgeDescription  string   `json:"ageDescription"`
    Race            int32    `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"`
    IsAlarm         string   `json:"isAlarm"`
    IsAckAlarm      string   `json:"isAckAlarm"`
    IsCollect       string   `json:"isCollect"`
    IsDelete        int      `json:"isDelete"`
    BaseInfo        []Base   `json:"baseInfo"`
}

type Base struct {
@@ -139,7 +139,7 @@
                    strings.Split(bigPhotoUrl["fileUrl"].(string), "/")[1],
                    msg.Tasklab.Taskid,
                    msg.Tasklab.Taskname,
                    face.SdkName,
                    "人脸",
                    "",
                    time.Now().Format("2006-01-02 15:04:05"), // 只检测，没有比对时间
                    face.ThftRes.Gender,
@@ -149,7 +149,7 @@
                    face.ThftRes.Smile,
                    face.ThftRes.Beauty,
                    "不是每个人脸算法都有",
                    strings.Split(resp["fileUrl"].(string), "/")[1],
                    []string{strings.Split(resp["fileUrl"].(string), "/")[1]},
                    "暂无集群",
                    localConfig.ServerId,
                    localConfig.ServerName,
@@ -170,8 +170,8 @@
                }
                err = EsReq("POST", "http://192.168.1.182:9200/videopersons/perVideoPicture", requstbody)
                log.Println(err)
            }else {
                log.Println("跟底库的相似数据---------：",face.Liker)
            } else {
                log.Println("跟底库的相似数据---------：", face.Liker)
            }
        }
    }
@@ -196,10 +196,10 @@
            i := protomsg.Image{}
            err = proto.Unmarshal(bdata, &i)
            //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
            resp, err =util.DrawPolygonOnImage(msg.Cid,i)
            resp, err = util.DrawPolygonOnImage(msg.Cid, i)
            if err != nil {
                log.Println("画框或上传图片服务器出错",err)
            }else{
                log.Println("画框或上传图片服务器出错", err)
            } else {
                log.Println("已报警并上传改帧图片到服务器")
            }
        } else {
@@ -210,7 +210,7 @@
        // log.Println("图片上传返回值：", resp)
        // 查询本机信息
        localConfig, err := cache.GetServerInfo()
        if err !=nil {
        if err != nil {
            log.Println("查询本机信息失败！")
        }
        // 查询cameraName
@@ -250,7 +250,7 @@
        }
        err = EsReq("POST", "http://192.168.1.182:9200/personaction/perVideoAction", requstbody)
        if err != nil {
            log.Println("往ES插入数据失败",err)
            log.Println("往ES插入数据失败", err)
        } else {
            log.Println("__________________________________________往ES插入数据yolo成功")
        }
@@ -286,7 +286,7 @@
}

// 把报警等级转化成汉字
func ChangeToString(i int32) string{
func ChangeToString(i int32) string {
    alarm := ""
    if i == 1 {
        alarm = "一级"
@@ -304,4 +304,4 @@
        alarm = "五级"
    }
    return alarm
}
}