| | |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 如果开启了下级, 身份应该是消息代理, 不再转发到服务器 |
|---|
| | | 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) |
|---|
| | | |
|---|
| | | // 如果开启了下级, 身份应该是消息代理, 不再转发到服务器 |
|---|
| | | if config.ClientConf.Enable && config.ServeConf.Role == "agent" { |
|---|
| | | a.Repository.MsgForward(&req) |
|---|
| | | } else { |
|---|
| | | 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) |
|---|
| | | a.Repository.FaceForward(req.FaceListObject.FaceObject) |
|---|
| | | go a.Repository.VIIDMsgForward(&req) |
|---|
| | | } else if config.ServeConf.Role == "cascade" { |
|---|
| | | go service.AddFaceNotification(&face) |
|---|
| | | } |
|---|
| | | |
|---|
| | | if config.ForwardConf.SyncServer != "" { |
|---|
| | | go a.Repository.FaceForward(req.FaceListObject.FaceObject) |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 设备保活 |
|---|
