添加persons 接口

zhangzengfei

2024-06-03 7eb122e20a75ed800cc96b1565522951286e4081

添加persons 接口

 controller/captureCtl.go

@@ -44,7 +44,7 @@
    }

    face := req.FaceListObject.FaceObject[0]
    logger.Debug("Receive new message, Id:%s Ip:%s faceId:%s, LeftTopX:%d, appearTime:%s", c.RemoteIP(), face.DeviceID, face.FaceID, face.LeftTopX, face.FaceAppearTime)
    logger.Debug("Receive new face message, ip:%s, device id:%s faceId:%s, LeftTopX:%d, appearTime:%s", c.RemoteIP(), face.DeviceID, face.FaceID, face.LeftTopX, face.FaceAppearTime)

    // 如果开启了下级, 身份应该是消息代理, 不再转发到服务器
    if config.ClientConf.Enable && config.ServeConf.Role == "agent" {
@@ -81,7 +81,7 @@
    }

    videoLabel := req.VideoLabelListObject.VideoLabelObject[0]
    logger.Debug("Receive new message, Id:%s Ip:%s ", videoLabel.VideoLabelID, c.RemoteIP())
    logger.Debug("Receive new videoLabel message, Id:%s Ip:%s ", videoLabel.VideoLabelID, c.RemoteIP())

    // 转人员消息
    var person vo.PersonObject
@@ -182,3 +182,40 @@

    c.JSON(http.StatusOK, gin.H{"ResponseStatusObject": rspMsg})
}

func (a CaptureController) Persons(c *gin.Context) {
    var req vo.RequestPersonList
    if err := c.BindJSON(&req); err != nil {
        c.AbortWithStatus(http.StatusBadRequest)
        return
    }

    if len(req.PersonListObject.PersonObject) == 0 {
        c.AbortWithStatus(http.StatusBadRequest)
        return
    }

    person := req.PersonListObject.PersonObject[0]
    logger.Debug("Receive new person message, ip:%s, device Id:%s personId:%s, appearTime:%s", c.RemoteIP(), person.DeviceID, person.PersonID, person.PersonAppearTime)

    // 如果开启了下级, 身份应该是消息代理, 不再转发到服务器
    if config.ClientConf.Enable && config.ServeConf.Role == "agent" {
        go a.Repository.VIIDPersonMsgForward(&req)
    } else if config.ServeConf.Role == "cascade" {
        go service.AddPersonNotification(&person)
    }

    if config.ForwardConf.SyncServer != "" {
        go a.Repository.PersonForward(req.PersonListObject.PersonObject)
    }

    rspMsg := vo.ResponseStatus{
        RequestURL:   c.FullPath(),
        StatusCode:   vo.StatusSuccess,
        StatusString: vo.StatusString[vo.StatusSuccess],
        Id:           person.PersonID,
        LocalTime:    time.Now().Format("20060102150405"),
    }

    c.JSON(http.StatusOK, gin.H{"ResponseStatusObject": rspMsg})
}

 routes/capture.go

@@ -13,6 +13,7 @@
    // 批量人脸新增
    r.POST("/Faces", capCtl.Faces)
    r.POST("/VideoLabels", capCtl.VideoLabels)
    r.POST("/Persons", capCtl.Persons)

    return r
}