数据撤回功能

This commit is contained in:
钱涛 2025-04-07 13:50:34 +08:00
parent f4c025e078
commit c32dab5562
1 changed files with 3 additions and 0 deletions

View File

@ -408,6 +408,9 @@ public class PushServiceImpl extends Service implements PushService {
@Override
public void withdrawPushRecord(Long salaryAcctRecordId) {
List<PushRecordPO> pushRecordPOS = getPushRecordMapper().listSome(PushRecordPO.builder().acctRecordId(salaryAcctRecordId).status(PushRecordStatusEnum.RUN_SUCCESS.getValue()).build());
if (CollUtil.isEmpty(pushRecordPOS)) {
return;
}
pushRecordPOS.stream().map(PushRecordPO::getId).forEach(this::withdraw);
}