|
|
@ -57,7 +57,7 @@ public class TripartiteRecordTask {
|
|
|
|
DateTime date = DateUtil.date();
|
|
|
|
DateTime date = DateUtil.date();
|
|
|
|
// 偏移十五分钟
|
|
|
|
// 偏移十五分钟
|
|
|
|
DateTime offsetMinute = ObjectUtil.isNull(beginTime) ?
|
|
|
|
DateTime offsetMinute = ObjectUtil.isNull(beginTime) ?
|
|
|
|
DateUtil.offsetMinute(date, -15) : DateUtil.offsetMinute(beginTime, -15);
|
|
|
|
DateUtil.offsetMinute(date, -15) : beginTime;
|
|
|
|
beginTime = offsetMinute;
|
|
|
|
beginTime = offsetMinute;
|
|
|
|
log.info("================ the begin time as {} end time as {} ================", offsetMinute, date);
|
|
|
|
log.info("================ the begin time as {} end time as {} ================", offsetMinute, date);
|
|
|
|
List<TripartiteDTO> dtoList = tripartiteService.queryTripartiteData(offsetMinute, date);
|
|
|
|
List<TripartiteDTO> dtoList = tripartiteService.queryTripartiteData(offsetMinute, date);
|
|
|
@ -82,7 +82,7 @@ public class TripartiteRecordTask {
|
|
|
|
Set<TripartitePlatformDTO> originSet = Sets.newHashSet(list);
|
|
|
|
Set<TripartitePlatformDTO> originSet = Sets.newHashSet(list);
|
|
|
|
// 分批发送
|
|
|
|
// 分批发送
|
|
|
|
List<List<TripartitePlatformDTO>> partition =
|
|
|
|
List<List<TripartitePlatformDTO>> partition =
|
|
|
|
Lists.partition(Lists.newArrayList(originSet), 500);
|
|
|
|
Lists.partition(Lists.newArrayList(originSet), 1000);
|
|
|
|
int num = 0;
|
|
|
|
int num = 0;
|
|
|
|
for (List<TripartitePlatformDTO> formDTOList : partition) {
|
|
|
|
for (List<TripartitePlatformDTO> formDTOList : partition) {
|
|
|
|
TripartiteTransmitDTO dto = new TripartiteTransmitDTO();
|
|
|
|
TripartiteTransmitDTO dto = new TripartiteTransmitDTO();
|
|
|
|