移除redis

Former-commit-id: f15cf213cd5734b55d11db580fefca63b98f642f

api/internal/logic/core/committasklogic.go

@@ -2,7 +2,6 @@ package core
 
 import (
 	"context"
-	"encoding/json"
 	"github.com/ghodss/yaml"
 	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/mqs"
 	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/pkg/response"
@@ -62,18 +61,6 @@ func (l *CommitTaskLogic) CommitTask(req *types.CommitTaskReq) error {
 		Metadata:    req.YamlList,
 		Replicas:    req.Replicas,
 	}
-	// 将任务数据转换成消息体
-	reqMessage, err := json.Marshal(task)
-	if err != nil {
-		logx.Error(err)
-		return err
-	}
-
-	mqs.InsQueue.Beta.Add(string(reqMessage))
-	//publish := l.svcCtx.RedisClient.Publish(context.Background(), "cloud", reqMessage)
-	//if publish.Err() != nil {
-	//	return publish.Err()
-	//}
-
+	mqs.InsQueue.Beta.Add(&task)
 	return nil
 }