| | |
|---|
| | | package controller |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "gat1400Exchange/config" |
|---|
| | | "gat1400Exchange/service" |
|---|
| | | "net/http" |
|---|
| | | "time" |
|---|
| | | |
|---|
| | |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 如果开启了下级, 身份应该是消息代理, 不再转发到服务器 |
|---|
| | | face := req.FaceListObject.FaceObject[0] |
|---|
| | | |
|---|
| | | 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) |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 设备保活 |
|---|
| | | service.KeepDeviceAlive(face.DeviceID) |
|---|
| | | |
|---|
| | | rspMsg := vo.ResponseStatus{ |
|---|
| | | RequestURL: c.FullPath(), |
|---|
