fix: 修复TenantActor

pkg/mqtt/manager.go

@@ -93,7 +93,7 @@ func (m *Manager) CleanWorker() {
 				continue
 			}
 
-			if uint16(curTime-con.LastHbTime) > uint16(3*con.KeepAlive/2) {
+			if uint16(curTime-con.LastHbTime) > 3*con.KeepAlive/2 {
 				server.Log.Infof("connection %v inactive , removing", con)
 				con.Close()
 				delete(m.IdToConn, con.DeviceID)

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"
 )
@@ -35,13 +36,14 @@ func NewManager(host string, port, db int) *Manager {
 
 func (mgr *Manager) GetStatus(id string) (*Status, error) {
 	key := KeyPrefix + id
-	var status *Status
+	status := new(Status)
 	// get status from redis
 	result, err := mgr.redisClient.DoVar("GET", key)
 	if err != nil {
 		return nil, err
 	}
-	err = result.Struct(&status)
+	fmt.Printf("get status:%v", result.String())
+	err = result.Struct(status)
 	if err != nil {
 		return nil, err
 	}