liuxiulin 8 月之前
父節點
當前提交
db7183a5c5
共有 2 個文件被更改,包括 9 次插入1 次删除
  1. 7 1
      pkg/deviceStatus/deviceStatus.go
  2. 2 0
      services/devicemanager/manager.go

+ 7 - 1
pkg/deviceStatus/deviceStatus.go

@@ -1,6 +1,7 @@
 package deviceStatus
 
 import (
+	"fmt"
 	"github.com/gogf/gf/database/gredis"
 	"github.com/gogf/gf/encoding/gjson"
 )
@@ -44,12 +45,17 @@ func NewDevStatusManager(host string, port int) *DevStatusManager {
 
 func (mgr *DevStatusManager) GetDeviceStatus(id string) (*gjson.Json, error) {
 	key := KeyPrefix + id
-
+	fmt.Println(key)
+	var status SplitStatus
 	// get status from redis
 	result, err := mgr.redisClient.DoVar("GET", key)
 	if err != nil {
 		return nil, err
 	}
+	err = result.Struct(&status)
+	fmt.Printf("struct:-----------------%v", status)
 
+	fmt.Printf("result:----------------%v:", result)
+	fmt.Printf("resultStr:----------------%v:", result.String())
 	return gjson.New(result), nil
 }

+ 2 - 0
services/devicemanager/manager.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"fmt"
 	"sparrow/pkg/deviceStatus"
 	"sparrow/pkg/online"
 	"sparrow/pkg/otaUpgrade"
@@ -121,6 +122,7 @@ func (dm *DeviceManager) GetProgress(args rpcs.ArgsOtaProgress, reply *rpcs.Repl
 
 func (dm *DeviceManager) GetDeviceStatus(args rpcs.ArgsGetStatus, reply *rpcs.ReplyStatus) error {
 	status, err := dm.statusManager.GetDeviceStatus(args.Id)
+	fmt.Printf("status:----------------%v:", status)
 	if err != nil {
 		return err
 	}