Skip to content

A
amos-boot-biz
Commit 7634484e authored by suhuiguang's avatar suhuiguang
Browse files
Options

feat(综合搜索)：2次需求变更增加字段

1.、是否球馆、发证日期
parent 549b47c1
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 3 deletions
amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/DataHandlerServiceImpl.java
View file @ 7634484e
...@@ -1504,7 +1504,8 @@ public class DataHandlerServiceImpl { ...@@ -1504,7 +1504,8 @@ public class DataHandlerServiceImpl {
StopWatch watch = new StopWatch(); StopWatch watch = new StopWatch();
watch.start(); watch.start();
Integer maxVersion = useInfoService.getBaseMapper().selectMaxVersion(); Integer maxVersion = useInfoService.getBaseMapper().selectMaxVersion();
List<String> refreshRecords = useInfoService.getBaseMapper().selectUseInfoOfOneVersionAll(maxVersion); Integer nextVersion = maxVersion + 1;
List<String> refreshRecords = useInfoService.getBaseMapper().selectUseInfoOfOneVersionAll(nextVersion);
while (!refreshRecords.isEmpty()) { while (!refreshRecords.isEmpty()) {
List<ESEquipmentInfo> esEquipmentInfos = refreshRecords.parallelStream().map(record -> { List<ESEquipmentInfo> esEquipmentInfos = refreshRecords.parallelStream().map(record -> {
ESEquipmentInfo esEquipmentInfo = null; ESEquipmentInfo esEquipmentInfo = null;
...@@ -1561,8 +1562,8 @@ public class DataHandlerServiceImpl { ...@@ -1561,8 +1562,8 @@ public class DataHandlerServiceImpl {
if(!esEquipmentInfos.isEmpty()){ if(!esEquipmentInfos.isEmpty()){
esEquipmentDao.saveAll(esEquipmentInfos); esEquipmentDao.saveAll(esEquipmentInfos);
} }
useInfoService.getBaseMapper().updateVersionBatch(refreshRecords, maxVersion + 1); useInfoService.getBaseMapper().updateVersionBatch(refreshRecords, nextVersion);
refreshRecords = useInfoService.getBaseMapper().selectUseInfoOfOneVersionAll(maxVersion); refreshRecords = useInfoService.getBaseMapper().selectUseInfoOfOneVersionAll(nextVersion);
} }
watch.stop(); watch.stop();
log.info("综合统计设备信息入库结束，耗时：{}秒", watch.getTotalTimeSeconds()); log.info("综合统计设备信息入库结束，耗时：{}秒", watch.getTotalTimeSeconds());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment