From 374bb1a5adda0a3ef22631291ff6810c546af6c7 Mon Sep 17 00:00:00 2001
From: Jake <450705171@qq.com>
Date: Tue, 14 May 2024 10:40:06 +0800
Subject: [PATCH 1/2] change log level

Former-commit-id: f8155160b352fb6602fd34ca8efff37659ceab65
---
 api/internal/logic/hpc/commithpctasklogic.go | 4 ++++
 api/internal/svc/servicecontext.go           | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/api/internal/logic/hpc/commithpctasklogic.go b/api/internal/logic/hpc/commithpctasklogic.go
index 994f3f91..13281d92 100644
--- a/api/internal/logic/hpc/commithpctasklogic.go
+++ b/api/internal/logic/hpc/commithpctasklogic.go
@@ -2,6 +2,7 @@ package hpc
 
 import (
 	"context"
+	"errors"
 	clientCore "gitlink.org.cn/JointCloud/pcm-coordinator/api/client"
 	"gitlink.org.cn/JointCloud/pcm-coordinator/pkg/constants"
 	"gitlink.org.cn/JointCloud/pcm-coordinator/pkg/models"
@@ -55,6 +56,9 @@ func (l *CommitHpcTaskLogic) CommitHpcTask(req *types.CommitHpcTaskReq) (resp *t
 	adapterId, _ := strconv.ParseInt(req.AdapterId, 10, 64)
 	var adapterName string
 	l.svcCtx.DbEngin.Raw("SELECT name FROM `t_adapter` where id = ?", req.AdapterId).Scan(&adapterName)
+	if len(adapterName) == 0 || adapterName == "" {
+		return nil, errors.New("no corresponding adapter found")
+	}
 	clusterId := clusterIds[rand.Intn(len(clusterIds))]
 	var clusterName string
 	l.svcCtx.DbEngin.Raw("SELECT nickname FROM `t_cluster` where id = ?", clusterId).Scan(&clusterName)
diff --git a/api/internal/svc/servicecontext.go b/api/internal/svc/servicecontext.go
index 1aca2ac4..4bbc6a27 100644
--- a/api/internal/svc/servicecontext.go
+++ b/api/internal/svc/servicecontext.go
@@ -91,7 +91,7 @@ func NewServiceContext(c config.Config) *ServiceContext {
 		NamingStrategy: schema.NamingStrategy{
 			SingularTable: true, // 使用单数表名，启用该选项，此时，`User` 的表名应该是 `t_user`
 		},
-		Logger: logger.Default.LogMode(logger.Info),
+		Logger: logger.Default.LogMode(logger.Error),
 	})
 	if err != nil {
 		logx.Errorf("数据库连接失败, err%v", err)

From 7d067b0082abc973bd324ccbd32b185f45632a0f Mon Sep 17 00:00:00 2001
From: Jake <450705171@qq.com>
Date: Tue, 14 May 2024 10:43:58 +0800
Subject: [PATCH 2/2] merge conflict

Former-commit-id: b6a6a7c963182194e03b9673f5b2e47fe47952f4
---
 api/internal/logic/hpc/commithpctasklogic.go | 28 +++++++++-----------
 1 file changed, 13 insertions(+), 15 deletions(-)

diff --git a/api/internal/logic/hpc/commithpctasklogic.go b/api/internal/logic/hpc/commithpctasklogic.go
index 13281d92..ebd6f252 100644
--- a/api/internal/logic/hpc/commithpctasklogic.go
+++ b/api/internal/logic/hpc/commithpctasklogic.go
@@ -8,7 +8,6 @@ import (
 	"gitlink.org.cn/JointCloud/pcm-coordinator/pkg/models"
 	"k8s.io/apimachinery/pkg/util/json"
 	"math/rand"
-	"strconv"
 	"time"
 
 	"gitlink.org.cn/JointCloud/pcm-coordinator/api/internal/svc"
@@ -51,26 +50,25 @@ func (l *CommitHpcTaskLogic) CommitHpcTask(req *types.CommitHpcTaskReq) (resp *t
 	}
 
 	var clusterIds []int64
-	l.svcCtx.DbEngin.Raw("SELECT id FROM `t_cluster` where adapter_id = ? and label = ?", req.AdapterId, req.ClusterType).Scan(&clusterIds)
-
-	adapterId, _ := strconv.ParseInt(req.AdapterId, 10, 64)
-	var adapterName string
-	l.svcCtx.DbEngin.Raw("SELECT name FROM `t_adapter` where id = ?", req.AdapterId).Scan(&adapterName)
-	if len(adapterName) == 0 || adapterName == "" {
-		return nil, errors.New("no corresponding adapter found")
-	}
-	clusterId := clusterIds[rand.Intn(len(clusterIds))]
-	var clusterName string
-	l.svcCtx.DbEngin.Raw("SELECT nickname FROM `t_cluster` where id = ?", clusterId).Scan(&clusterName)
-
-	env, _ := json.Marshal(req.Environment)
-
+	l.svcCtx.DbEngin.Raw("SELECT id FROM `t_cluster` where adapter_id in ? and label = ?", req.AdapterIds, req.ClusterType).Scan(&clusterIds)
 	if len(clusterIds) == 0 || clusterIds == nil {
 		resp.Code = 400
 		resp.Msg = "no cluster found"
 		return resp, nil
 	}
 
+	var clusterName string
+	var adapterId int64
+	var adapterName string
+	clusterId := clusterIds[rand.Intn(len(clusterIds))]
+	l.svcCtx.DbEngin.Raw("SELECT nickname FROM `t_cluster` where id = ?", clusterId).Scan(&clusterName)
+	l.svcCtx.DbEngin.Raw("SELECT adapter_id FROM `t_cluster` where id = ?", clusterId).Scan(&adapterId)
+	l.svcCtx.DbEngin.Raw("SELECT name FROM `t_adapter` where id = ?", adapterId).Scan(&adapterName)
+	if len(adapterName) == 0 || adapterName == "" {
+		return nil, errors.New("no corresponding adapter found")
+	}
+	env, _ := json.Marshal(req.Environment)
+
 	hpcInfo := models.TaskHpc{
 		TaskId:      taskModel.Id,
 		AdapterId:   uint(adapterId),