|
|
|
@ -51,8 +51,11 @@ public class OpFailPackageRetryJob {
|
|
|
|
|
private void batchHandleData(Long startId, Integer quantity) { |
|
|
|
|
List<OpFailRetryPushPackageEntity> batchData = opFailRetryPushPackageMapper.selectWaitData(quantity, startId); |
|
|
|
|
|
|
|
|
|
opFailRetryPushPackageService.retry(batchData); |
|
|
|
|
log.info("OpFailPackageRetryJob batchHandleData startId:{},quantity:{}",startId,quantity); |
|
|
|
|
// opFailRetryPushPackageService.retry(batchData);
|
|
|
|
|
|
|
|
|
|
log.info("OpFailPackageRetryJob batchHandleData end"); |
|
|
|
|
log.info("batchData.size {}",batchData.size()); |
|
|
|
|
if (batchData.size()== quantity) { |
|
|
|
|
batchHandleData(batchData.get(quantity - 1).getId(), quantity); |
|
|
|
|
} |
|
|
|
|