| | |
|---|
| | | * 每次拿重试次数大于零 |
|---|
| | | * 按ID asc排序的十条数据 |
|---|
| | | */ |
|---|
| | | List<MallMqRecord> mallMqRecords = mallMqRecordMapper.selectByStateLimitTen(2); |
|---|
| | | if(CollUtil.isEmpty(mallMqRecords)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | DateTime dateTime = DateUtil.offsetMinute(new Date(), -5); |
|---|
| | | for(MallMqRecord mallMqRecord : mallMqRecords){ |
|---|
| | | if(DateUtil.compare(dateTime,mallMqRecord.getCreateTime()) <= 0){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | Integer retryTimes = mallMqRecord.getRetryTimes(); |
|---|
| | | if(retryTimes <= 0){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | retryTimes = retryTimes - 1; |
|---|
| | | mallMqRecord.setRetryTimes(retryTimes); |
|---|
| | | mallMqRecordMapper.updateById(mallMqRecord); |
|---|
| | | |
|---|
| | | Long orderId = mallMqRecord.getOrderId(); |
|---|
| | | if(mallMqRecord.getState() == 2){ |
|---|
| | | agentProducer.sendPerkMoneyMsg(orderId); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // List<MallMqRecord> mallMqRecords = mallMqRecordMapper.selectByStateLimitTen(2); |
|---|
| | | // if(CollUtil.isEmpty(mallMqRecords)){ |
|---|
| | | // return; |
|---|
| | | // } |
|---|
| | | // DateTime dateTime = DateUtil.offsetMinute(new Date(), -5); |
|---|
| | | // for(MallMqRecord mallMqRecord : mallMqRecords){ |
|---|
| | | // if(DateUtil.compare(dateTime,mallMqRecord.getCreateTime()) <= 0){ |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | // Integer retryTimes = mallMqRecord.getRetryTimes(); |
|---|
| | | // if(retryTimes <= 0){ |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | // retryTimes = retryTimes - 1; |
|---|
| | | // mallMqRecord.setRetryTimes(retryTimes); |
|---|
| | | // mallMqRecordMapper.updateById(mallMqRecord); |
|---|
| | | // |
|---|
| | | // Long orderId = mallMqRecord.getOrderId(); |
|---|
| | | // if(mallMqRecord.getState() == 2){ |
|---|
| | | // agentProducer.sendPerkMoneyMsg(orderId); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
