add log

services/onekey-service/internal/onekey_service.go

@@ -78,6 +78,7 @@ func (s *OneKeyService) initTaskConsumer() error {
 }
 
 func (s *OneKeyService) handleOneKeyTask(msg []byte) {
+	server.Log.Debugf("do task %s", msg)
 	err := s.taskSchedule.DoTask(msg)
 	if err != nil {
 		server.Log.Errorf("do task error :%s", err.Error())

services/scene-access/internal/service/scene.go

@@ -46,7 +46,7 @@ func (s *SceneService) SubmitTask(args rpcs.ArgsSubmitTask, reply *rpcs.ReplyEmp
 	case "oneKey":
 		topic = OneKeyTopic
 	}
-
+	server.Log.Debugf("收到类型为%s的任务: %s", args.Type, args.Data)
 	return s.taskManager.Publish(topic, []byte(args.Data))
 }