Commit c44dd5a1 authored by suhuiguang's avatar suhuiguang

refact(综合搜索):数据同步调整

1.企业同步时去掉删除的企业
parent 4a57667d
...@@ -1424,7 +1424,7 @@ public class DataHandlerServiceImpl { ...@@ -1424,7 +1424,7 @@ public class DataHandlerServiceImpl {
log.info("综合统计企业信息入库开始"); log.info("综合统计企业信息入库开始");
StopWatch watch = new StopWatch(); StopWatch watch = new StopWatch();
watch.start(); watch.start();
List<TzBaseEnterpriseInfo> units = tzBaseEnterpriseInfoMapper.selectList(null); List<TzBaseEnterpriseInfo> units = tzBaseEnterpriseInfoMapper.selectList(new LambdaQueryWrapper<TzBaseEnterpriseInfo>().eq(BaseEntity::getIsDelete, false));
List<EsBaseEnterpriseInfo> esBaseEnterpriseInfos = units.parallelStream().map(enterpriseInfo -> { List<EsBaseEnterpriseInfo> esBaseEnterpriseInfos = units.parallelStream().map(enterpriseInfo -> {
EsBaseEnterpriseInfo esBaseEnterpriseInfo = new EsBaseEnterpriseInfo(); EsBaseEnterpriseInfo esBaseEnterpriseInfo = new EsBaseEnterpriseInfo();
BeanUtil.copyProperties(enterpriseInfo, esBaseEnterpriseInfo); BeanUtil.copyProperties(enterpriseInfo, esBaseEnterpriseInfo);
......
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