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