update

services/apiprovider/actions.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"encoding/json"
 	"errors"
-	"fmt"
 	"github.com/gogf/gf/encoding/gjson"
 	"sparrow/pkg/productconfig"
 	"sparrow/pkg/rpcs"
@@ -445,14 +444,12 @@ func SubmitSceneTask(req *http.Request, r render.Render) {
 func SubmitTaskLifecycle(req *http.Request, r render.Render) {
 
 	var ruleReq rpcs.ArgsSubmitTaskLifecycle
-	fmt.Printf("------------%s", req.Body)
 	decoder := json.NewDecoder(req.Body)
 	err := decoder.Decode(&ruleReq)
 	if err != nil {
 		r.JSON(http.StatusOK, renderError(ErrWrongRequestFormat, err))
 		return
 	}
-	fmt.Printf("--------------------%s", ruleReq.TaskId)
 	reply := rpcs.ReplySubmitTask{}
 	err = server.RPCCallByName(nil, rpcs.SceneAccessServiceName, "SceneService.SubmitTaskLifecycle", ruleReq, &reply)
 	if err != nil {

services/timer-service/internal/scheduler.go

@@ -51,10 +51,8 @@ func (t *TaskSchedule) AddMessageHandle(msg *rule.TaskLifecycleMessage) error {
 func (t *TaskSchedule) RemoveMessageHandle(msg *rule.TaskLifecycleMessage) error {
 
 	gcron.Remove(msg.TaskId)
-	err := t.tasks.Remove(msg.TaskId)
-	if err != nil {
-		server.Log.Errorf("remove taskid :%s error:%s", msg.TaskId, err)
-	}
+	_ = t.tasks.Remove(msg.TaskId)
+
 	server.Log.Debugf("RemoveMessageHandle :%s", msg.TaskId)
 	return nil
 }