From a2a865382442afeb7f7470e68d334c2df5235491 Mon Sep 17 00:00:00 2001 From: devad Date: Wed, 3 Jan 2024 13:01:03 +0800 Subject: [PATCH] =?UTF-8?q?cloud=20app=E9=87=8D=E5=90=AF=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: devad Former-commit-id: 3ad235d75ed10f15ca614dd773f2e2ab5e444f73 --- rpc/internal/logic/participantservice/restartlistlogic.go | 2 +- rpc/pb/pcmCore.proto | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/rpc/internal/logic/participantservice/restartlistlogic.go b/rpc/internal/logic/participantservice/restartlistlogic.go index 0e7661f6..15b907ca 100644 --- a/rpc/internal/logic/participantservice/restartlistlogic.go +++ b/rpc/internal/logic/participantservice/restartlistlogic.go @@ -28,7 +28,7 @@ func (l *RestartListLogic) RestartList(in *pcmCore.ApplyListReq) (*pcmCore.Apply result := pcmCore.ApplyListResp{ InfoList: make([]*pcmCore.ApplyInfo, 0), } - l.svcCtx.DbEngin.Raw("SELECT sppi.`name` as ParticipantName, c.ns_id as namespace,c.name as name FROM cloud c,sc_participant_phy_info sppi where c.`status` = 'WaitRestart' and sppi.id = c.participant_id").Scan(&result.InfoList) + l.svcCtx.DbEngin.Raw("SELECT sppi.`name` as ParticipantName, c.ns_id as namespace,c.name as name , c.kind as kind FROM cloud c,sc_participant_phy_info sppi where c.`status` = 'WaitRestart' and sppi.id = c.participant_id").Scan(&result.InfoList) if len(result.InfoList) != 0 { l.svcCtx.DbEngin.Exec("update cloud set status = ? where status = ?", "Issued", "WaitRestart") } diff --git a/rpc/pb/pcmCore.proto b/rpc/pb/pcmCore.proto index b7874a61..6e937374 100644 --- a/rpc/pb/pcmCore.proto +++ b/rpc/pb/pcmCore.proto @@ -296,7 +296,8 @@ message ApplyInfo{ string participantName = 1; string yamlString = 2; string namespace =3; - string name =4; + string name = 4; + string kind = 5; } // participant ε‚δΈŽθ€