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 ε‚δΈŽθ€