liuxiulin il y a 2 mois
Parent
commit
0b9bfcc21f

+ 0 - 2
services/scene-service/internal/service/manager/timer.go

@@ -46,7 +46,6 @@ func (t *TimerSceneService) Add(config string) error {
 	//	server.Log.Errorf("timer scene-manager config error")
 	//	return errors.New("timer scene-manager config error")
 	//}
-	fmt.Printf("task counts:%d \n", t.cron.Size())
 	for _, v := range c.Conditions {
 		err = t.addTask(c.SceneId, v, c.Actions)
 		if err != nil {
@@ -55,7 +54,6 @@ func (t *TimerSceneService) Add(config string) error {
 		}
 
 	}
-	fmt.Printf("task counts:%d \n", t.cron.Size())
 	t.task.Set(c.SceneId, c)
 	//server.Log.Debugf("AddTimeScene :%s", c.SceneId)
 	return nil

+ 1 - 2
services/scene-service/internal/service/scene.go

@@ -81,7 +81,6 @@ func (m *SceneService) SubmitAction(args rpcs.ArgsSubmitSceneAction, reply *rpcs
 		server.Log.Errorf("不支持的场景类型: %s, 场景ID: %s", scene.SceneType, scene.Id)
 		return err
 	}
-	fmt.Printf("提交场景任务:%s\n", gjson.New(scene).MustToJsonString())
 	switch scene.Action {
 	case "add":
 		err = srv.Add(scene.Config)
@@ -179,7 +178,7 @@ func (m *SceneService) RestartScenes() {
 	if err != nil {
 		server.Log.Errorf("get all scene error: %v", err)
 	}
-	fmt.Printf("重启场景:%s", gjson.New(sceneReply).MustToJsonString())
+
 	reply := rpcs.ReplySubmitSceneAction{}
 	for _, v := range sceneReply.Result {
 		if v.Status == 1 {