liuxiulin hace 1 semana
padre
commit
ded2287341
Se han modificado 1 ficheros con 1 adiciones y 0 borrados
  1. 1 0
      services/controller/controller.go

+ 1 - 0
services/controller/controller.go

@@ -215,6 +215,7 @@ func (c *Controller) processEventToQueue(args rpcs.ArgsOnEvent) (string, error)
 
 // OnEvent 事件消息处理
 func (c *Controller) OnEvent(args rpcs.ArgsOnEvent, reply *rpcs.ReplyOnEvent) error {
+	fmt.Printf("处理事件消息:----------%s", args.DeviceId)
 	t := time.Unix(int64(args.TimeStamp/1000), 0)
 	data, err := c.processEventToQueue(args)
 	if err != nil {