From 0f837a7c62db5a496d35d0c6d24a02ae29f8299e Mon Sep 17 00:00:00 2001
From: zhangwei <894646498@qq.com>
Date: Wed, 27 Dec 2023 15:57:13 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4redis?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Former-commit-id: f15cf213cd5734b55d11db580fefca63b98f642f
---
 api/internal/logic/core/committasklogic.go | 15 +--------------
 1 file changed, 1 insertion(+), 14 deletions(-)

diff --git a/api/internal/logic/core/committasklogic.go b/api/internal/logic/core/committasklogic.go
index d6b9f359..0f9ee580 100644
--- a/api/internal/logic/core/committasklogic.go
+++ b/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
 }