liuxiulin 4 주 전
부모
커밋
793057dbee
2개의 변경된 파일5개의 추가작업 그리고 0개의 파일을 삭제
  1. 2 0
      pkg/scene/scene.go
  2. 3 0
      services/scene-service/internal/service/scene.go

+ 2 - 0
pkg/scene/scene.go

@@ -2,6 +2,7 @@ package scene
 
 import (
 	"context"
+	"fmt"
 	"github.com/gogf/gf/database/gredis"
 	"time"
 )
@@ -81,6 +82,7 @@ func (a *Manager) GetScene(key string) (string, error) {
 
 func (a *Manager) DeleteScene(key string) error {
 	// get status from redis
+	fmt.Printf("delete scene4---------: %s\n", key)
 	_, err := a.redisClient.Do("DEL", key)
 	if err != nil {
 		return err

+ 3 - 0
services/scene-service/internal/service/scene.go

@@ -90,11 +90,13 @@ func (m *SceneService) SubmitAction(args rpcs.ArgsSubmitSceneAction, reply *rpcs
 		m.scenes.Set(scene.Id, scene)
 		return m.saveSceneRedis(scene)
 	case "remove":
+		fmt.Printf("delete scene1---------: %s\n", scene.Id)
 		err = srv.Remove(scene.Id)
 		if err != nil {
 			server.Log.Errorf("delete scene error: Id: %s, error: %v\n", scene.Id, err)
 		}
 		m.scenes.Remove(scene.Id)
+		fmt.Printf("delete scene2---------: %s\n", scene.Id)
 		return m.delSceneRedis(scene)
 	case "update":
 		err = srv.Update(scene.Config)
@@ -169,6 +171,7 @@ func (m *SceneService) delSceneRedis(scene SceneInfo) error {
 		Config: scene.Config,
 	}
 	sceneReply := rpcs.ReplyEmptyResult{}
+	fmt.Printf("delete scene3---------: %s\n", scene.Id)
 	err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.DeleteScene", sceneArgs, &sceneReply)
 	if err != nil {
 		server.Log.Errorf("del scene error: Id: %s, error: %v", scene.Id, err)