|
|
|
@@ -55,10 +55,10 @@ func (l *SyncInfoLogic) SyncInfo(in *pcmCore.SyncInfoReq) (*pcmCore.SyncInfoResp |
|
|
|
var kind string |
|
|
|
l.svcCtx.DbEngin.Raw("select type as kind from sc_participant_phy_info where id = ?", in.ParticipantId).Scan(&kind) |
|
|
|
switch kind { |
|
|
|
case constants.CLOUD: |
|
|
|
case constants.CLOUD, constants.SEALOS: |
|
|
|
for _, cloudInfo := range in.CloudInfoList { |
|
|
|
l.svcCtx.DbEngin.Exec("update cloud set status = ?,start_time = ?,result = ? where participant_id = ? and task_id = ? and namespace = ? and name = ?", |
|
|
|
cloudInfo.Status, cloudInfo.StartTime, cloudInfo.Result, in.ParticipantId, cloudInfo.TaskId, cloudInfo.Namespace, cloudInfo.Name) |
|
|
|
l.svcCtx.DbEngin.Exec("update cloud set status = ?,start_time = ?,result = ? where participant_id = ? and id = ?", |
|
|
|
cloudInfo.Status, cloudInfo.StartTime, cloudInfo.Result, in.ParticipantId, cloudInfo.Id) |
|
|
|
syncTask(l.svcCtx.DbEngin, cloudInfo.TaskId) |
|
|
|
} |
|
|
|
case constants.HPC: |
|
|
|
|