| | |
| | | } |
| | | |
| | | var deviceId = face.DeviceID |
| | | var faceId = face.FaceID |
| | | var faceImageStr string |
| | | |
| | | // 获取大图, 目前海康的小图分辨率太低 |
| | |
| | | // 转发图像 |
| | | logger.Debug("准备转发,deviceId:%s, image len:%d, server:%s", deviceId, len(faceImageStr), config.ForwardConf.SyncServer) |
| | | if deviceId != "" && faceImageStr != "" && config.ForwardConf.SyncServer != "" { |
| | | pd := c.PackPushData(deviceId, faceImageStr) |
| | | pd := c.PackPushData(deviceId, faceId, faceImageStr) |
| | | if pd == nil { |
| | | return |
| | | } |
| | |
| | | return |
| | | } |
| | | |
| | | func (c CaptureRepository) PackPushData(deviceId, faceImage string) *vo.PushDataInfo { |
| | | func (c CaptureRepository) PackPushData(deviceId, faceId, faceImage string) *vo.PushDataInfo { |
| | | var pd = new(vo.PushDataInfo) |
| | | var device models.Device |
| | | |
| | |
| | | AnalyServerName: "", |
| | | AnalyServerIp: "", |
| | | DataSource: "camera", |
| | | TargetInfo: []vo.TargetInfo{{TargetId: faceId}}, |
| | | } |
| | | |
| | | pd.SourceData = vo.ESInfo{ |
| | |
| | | package vo |
| | | |
| | | type TargetInfo struct { |
| | | TargetId string `json:"targetId"` |
| | | } |
| | | |
| | | type TaskResultInfo struct { |
| | | Id string `json:"id"` |
| | | CameraId string `json:"cameraId"` |
| | |
| | | AnalyServerId string `json:"analyServerId"` |
| | | AnalyServerName string `json:"analyServerName"` |
| | | AnalyServerIp string `json:"analyServerIp"` |
| | | TargetInfo []TargetInfo `json:"targetInfo"` |
| | | DataSource string `json:"dataSource"` // 数据来源:摄像机, 数据栈 |
| | | } |
| | | |