|
|
@@ -152,7 +152,6 @@ func (c *Controller) Offline(args rpcs.ArgsGetStatus, reply *rpcs.ReplyEmptyResu
|
|
|
|
|
|
// OnStatus 状态上报消息处理
|
|
|
func (c *Controller) OnStatus(args rpcs.ArgsOnStatus, reply *rpcs.ReplyOnStatus) error {
|
|
|
- fmt.Printf("收到设备消息:%s", args.DeviceId)
|
|
|
t := time.Unix(int64(args.Timestamp/1000), 0)
|
|
|
data, err := c.processStatusToQueue(args)
|
|
|
if err != nil {
|
lijian