floraachy
/
pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加执行任务列表接口 

Former-commit-id: 96060f7cecabd94b935f2f96acef08b6057b651d
This commit is contained in:
zhangwei 2023-12-06 15:15:46 +08:00
parent 90f781d195
commit 8f044d5f37
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rpc/internal/logic/participantservice/applylistlogic.go
View File

@ -24,8 +24,10 @@ func NewApplyListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ApplyLi
// applyList 执行任务列表 // applyList 执行任务列表
func (l *ApplyListLogic) ApplyList(in *pcmCore.ApplyListReq) (*pcmCore.ApplyListResp, error) { func (l *ApplyListLogic) ApplyList(in *pcmCore.ApplyListReq) (*pcmCore.ApplyListResp, error) {
result := pcmCore.ApplyListResp{} result := pcmCore.ApplyListResp{
l.svcCtx.DbEngin.Raw("SELECT sppi.`name` as participantName,c.yaml_string as yamlString FROM cloud c,sc_participant_phy_info sppi where c.`status` = 'Saved' and sppi.id = c.participant_id").Scan(&result.InfoList) InfoList: make([]*pcmCore.ApplyInfo, 0),
}
l.svcCtx.DbEngin.Raw("SELECT sppi.`name` as ParticipantName,c.yaml_string as YamlString FROM cloud c,sc_participant_phy_info sppi where c.`status` = 'Saved' and sppi.id = c.participant_id").Scan(&result.InfoList)
if len(result.InfoList) != 0 { if len(result.InfoList) != 0 {
l.svcCtx.DbEngin.Exec("update cloud set status = ? where status = ?", "Issued", "Saved") l.svcCtx.DbEngin.Exec("update cloud set status = ? where status = ?", "Issued", "Saved")
} }