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] 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)