diff --git a/src/main/java/com/baiyee/adcallback/task/NewPlatFormRecordTask.java b/src/main/java/com/baiyee/adcallback/task/NewPlatFormRecordTask.java index 7a920c9..8c084fc 100644 --- a/src/main/java/com/baiyee/adcallback/task/NewPlatFormRecordTask.java +++ b/src/main/java/com/baiyee/adcallback/task/NewPlatFormRecordTask.java @@ -89,8 +89,7 @@ public class NewPlatFormRecordTask { } // 偏移十分钟 DateTime offsetMinute = ObjectUtil.isNull(beginTime) ? - DateUtil.offsetMinute(date, -9) : - DateUtil.offsetMinute(beginTime, -9); + DateUtil.offsetMinute(date, -9) : beginTime; beginTime = offsetMinute; log.info("================ the begin time as {} end time as {} ================", offsetMinute, date); List dtoList = backDataEntityService.queryNewPlateFormDTO diff --git a/src/main/java/com/baiyee/adcallback/task/PlatFormRecordTask.java b/src/main/java/com/baiyee/adcallback/task/PlatFormRecordTask.java index eda5562..3b34e87 100644 --- a/src/main/java/com/baiyee/adcallback/task/PlatFormRecordTask.java +++ b/src/main/java/com/baiyee/adcallback/task/PlatFormRecordTask.java @@ -94,8 +94,7 @@ public class PlatFormRecordTask { } // 偏移十分钟 DateTime offsetMinute = ObjectUtil.isNull(beginTime) ? - DateUtil.offsetMinute(date, -10) : - DateUtil.offsetMinute(beginTime, -10); + DateUtil.offsetMinute(date, -10) : beginTime; beginTime = offsetMinute; log.info("================ the begin time as {} end time as {} ================", offsetMinute, date); List dtoList = backDataEntityService.queryPlateFormDTO diff --git a/src/main/java/com/baiyee/adcallback/task/TripartiteRecordTask.java b/src/main/java/com/baiyee/adcallback/task/TripartiteRecordTask.java index b047327..0aa67ec 100644 --- a/src/main/java/com/baiyee/adcallback/task/TripartiteRecordTask.java +++ b/src/main/java/com/baiyee/adcallback/task/TripartiteRecordTask.java @@ -57,7 +57,7 @@ public class TripartiteRecordTask { DateTime date = DateUtil.date(); // 偏移十五分钟 DateTime offsetMinute = ObjectUtil.isNull(beginTime) ? - DateUtil.offsetMinute(date, -15) : DateUtil.offsetMinute(beginTime, -15); + DateUtil.offsetMinute(date, -15) : beginTime; beginTime = offsetMinute; log.info("================ the begin time as {} end time as {} ================", offsetMinute, date); List dtoList = tripartiteService.queryTripartiteData(offsetMinute, date); @@ -82,7 +82,7 @@ public class TripartiteRecordTask { Set originSet = Sets.newHashSet(list); // 分批发送 List> partition = - Lists.partition(Lists.newArrayList(originSet), 500); + Lists.partition(Lists.newArrayList(originSet), 1000); int num = 0; for (List formDTOList : partition) { TripartiteTransmitDTO dto = new TripartiteTransmitDTO();