提交推送状态初始化

This commit is contained in:
Guava
2023-06-18 11:24:36 +08:00
parent c32ea1352c
commit 649a412a4a

View File

@@ -62,7 +62,7 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
casesRecommend.setCaseCount(casesRecommendLaunch.getCasesIdList().size());
casesRecommend.setUserCount(casesRecommendLaunch.getPushUserIdList().size());
casesRecommend.setRecommendOrgName(casesRecommendLaunch.getRecommendOrgName());
casesRecommend.setPushProgress(CasesPushStatusEnum.PUSH_SUCCESS.name());
casesRecommend.setPushProgress(CasesPushStatusEnum.WAIT_PUSH.name());
casesRecommendDao.save(casesRecommend);
List<String> caseIds = new ArrayList<>();
@@ -105,15 +105,15 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
@Override
public void rePushOrWithdraw(boolean isWithdraw, String casesRecommendId) {
if (StringUtils.isEmpty(casesRecommendId)){
if (StringUtils.isEmpty(casesRecommendId)) {
throw new RuntimeException("缺少必要参数");
}
List<CasesRecommendPushRecord> recordList = findAllByRecommendId(casesRecommendId);
if (isWithdraw){
if (isWithdraw) {
recordList.stream().forEach(record ->
record.setPushStatus(CasesPushStatusEnum.PUSH_REVOKE.getStatus())
record.setPushStatus(CasesPushStatusEnum.PUSH_REVOKE.getStatus())
);
}else {
} else {
recordList.stream().forEach(record ->
record.setPushStatus(CasesPushStatusEnum.PUSH_ING.getStatus())
);