|
@@ -67,12 +67,13 @@ public class Task {
|
|
|
|
|
|
|
|
log.info("开始执行定时任务: 二手交易平台 - 10分钟后交易提醒 - secondTradeRemind");
|
|
log.info("开始执行定时任务: 二手交易平台 - 10分钟后交易提醒 - secondTradeRemind");
|
|
|
try {
|
|
try {
|
|
|
- Date now = Date.from(LocalDateTime.now().plusMinutes(10).withSecond(0).withNano(0).atZone(ZoneId.systemDefault()).toInstant());
|
|
|
|
|
|
|
+ Date now = Date.from(LocalDateTime.now().withSecond(0).withNano(0).atZone(ZoneId.systemDefault()).toInstant());
|
|
|
|
|
+ Date tenSecondLater = Date.from(LocalDateTime.now().plusMinutes(10).withSecond(0).withNano(0).atZone(ZoneId.systemDefault()).toInstant());
|
|
|
|
|
|
|
|
// 查询所有待交易
|
|
// 查询所有待交易
|
|
|
LambdaQueryWrapper<SecondTradeRecord> wrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<SecondTradeRecord> wrapper = new LambdaQueryWrapper<>();
|
|
|
wrapper.eq(SecondTradeRecord::getTradeStatus, 3);
|
|
wrapper.eq(SecondTradeRecord::getTradeStatus, 3);
|
|
|
- wrapper.eq(SecondTradeRecord::getTransactionTime, now);
|
|
|
|
|
|
|
+ wrapper.between(SecondTradeRecord::getTransactionTime, now, tenSecondLater);
|
|
|
List<SecondTradeRecord> tradeRecordList = secondTradeRecordMapper.selectList(wrapper);
|
|
List<SecondTradeRecord> tradeRecordList = secondTradeRecordMapper.selectList(wrapper);
|
|
|
|
|
|
|
|
for (SecondTradeRecord tradeRecord : tradeRecordList) {
|
|
for (SecondTradeRecord tradeRecord : tradeRecordList) {
|