添加批次操作

This commit is contained in:
Guava
2023-07-03 15:45:41 +08:00
parent 476d79fa7e
commit c0830d7eea

View File

@@ -28,7 +28,7 @@ public class CasesRecommendServiceImpl implements ICasesRecommendService {
private CasesRecommendDao casesRecommendDao; private CasesRecommendDao casesRecommendDao;
@Resource @Resource
private MessageDao dao; private MessageDao messageDao;
@Resource @Resource
private ICasesRecommendPushRecordService iCasesRecommendPushRecordService; private ICasesRecommendPushRecordService iCasesRecommendPushRecordService;
@@ -73,7 +73,7 @@ public class CasesRecommendServiceImpl implements ICasesRecommendService {
iCasesRecommendPushRecordService.rePushOrWithdraw(true, db); iCasesRecommendPushRecordService.rePushOrWithdraw(true, db);
db.setPushProgress(CasesPushStatusEnum.PUSH_REVOKE.getStatus()); db.setPushProgress(CasesPushStatusEnum.PUSH_REVOKE.getStatus());
casesRecommendDao.update(db); casesRecommendDao.update(db);
dao.deleteByFilter(FieldFilters.eq("acceptId", userId), FieldFilters.eq("refType", "99"), messageDao.deleteByFilter(FieldFilters.eq("acceptId", userId), FieldFilters.eq("refType", "99"),
FieldFilters.eq("batchId", casesRecommendPushVo.getCasesRecommendId())); FieldFilters.eq("batchId", casesRecommendPushVo.getCasesRecommendId()));
} else if (CasesPushStatusEnum.PUSH_FAIL.getStatus().equals(db.getPushProgress()) } else if (CasesPushStatusEnum.PUSH_FAIL.getStatus().equals(db.getPushProgress())