|
|
|
@ -110,12 +110,13 @@ public class SyncTask {
|
|
|
|
|
count.incrementAndGet();
|
|
|
|
|
Date startTime;
|
|
|
|
|
Date endTime = new Date();
|
|
|
|
|
Multimap<String, Trade> multimap = ArrayListMultimap.create();
|
|
|
|
|
Multimap<String, Trade> multimap;
|
|
|
|
|
Pageable pageable = PageRequest.of(DefaultNumberConstants.ZERO_NUMBER, DefaultNumberConstants.FIVE_THOUSAND);
|
|
|
|
|
// 第一次任务往前10分钟
|
|
|
|
|
startTime = lastUpdateTime == null ? DateUtil.offsetMinute(date, -DefaultNumberConstants.TEN_NUMBER) : lastUpdateTime;
|
|
|
|
|
lastUpdateTime = endTime;
|
|
|
|
|
while (true) {
|
|
|
|
|
multimap = ArrayListMultimap.create();
|
|
|
|
|
// 分页查询数据
|
|
|
|
|
Slice<JdpTrade> jdpTradeSlice = jdpTradeService.findJdpOrderByTime(startTime, endTime, pageable);
|
|
|
|
|
List<JdpTrade> jdpOrderList = jdpTradeSlice.getContent();
|
|
|
|
|