浏览代码

test: device get online

lijian 2 年之前
父节点
当前提交
4a996bcc17
共有 2 个文件被更改,包括 4 次插入0 次删除
  1. 2 0
      pkg/online/online.go
  2. 2 0
      services/devicemanager/manager.go

+ 2 - 0
pkg/online/online.go

@@ -2,6 +2,7 @@ package online
 
 import (
 	"errors"
+	"fmt"
 	"github.com/gogf/gf/database/gredis"
 	"github.com/gogf/gf/util/gconv"
 )
@@ -38,6 +39,7 @@ func (mgr *Manager) GetStatus(id string) (*Status, error) {
 	var status *Status
 	// get status from redis
 	result, err := mgr.redisClient.DoVar("GET", key)
+	fmt.Println(fmt.Sprintf("GetStatus:%v", result.String()))
 	if err != nil {
 		return nil, err
 	}

+ 2 - 0
services/devicemanager/manager.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"fmt"
 	"sparrow/pkg/online"
 	"sparrow/pkg/rpcs"
 	"sparrow/pkg/token"
@@ -36,6 +37,7 @@ func (dm *DeviceManager) ValidateDeviceAccessToken(args rpcs.ArgsValidateDeviceA
 }
 
 func (dm *DeviceManager) GetOnline(args rpcs.ArgsGetOnline, reply *rpcs.ReplyGetOnline) error {
+	fmt.Println(fmt.Sprintf("设备上线%s, 参数:%v", args.Id, args))
 	return dm.onlineManager.GetOnline(args.Id, online.Status{
 		ClientIP:          args.ClientIP,
 		AccessRPCHost:     args.AccessRPCHost,