Commit 81af86c1 authored by 刘林's avatar 刘林

fix(jg):场车车牌号刷入ES

parent 87f9ec06
......@@ -139,6 +139,8 @@ public class DataHandlerServiceImpl {
private final StatisticsDataUpdateService statisticsDataUpdateService;
private final IdxBizJgRegisterInfoMapper registerInfoMapper;
/**
* 安装告知压力管道历史数据修复-详情中的设备列表修改为汇总表格式
......@@ -1558,4 +1560,17 @@ public class DataHandlerServiceImpl {
return StringUtils.isNotEmpty(equListCode) ? statisticsDataUpdateService.getTechParams(equListCode, record) : new ArrayList<>();
}
public Integer initFactoryCarNumber2Es() {
List<IdxBizJgRegisterInfo> registerInfoList = registerInfoMapper.selectList(new QueryWrapper<IdxBizJgRegisterInfo>().lambda().isNotNull(IdxBizJgRegisterInfo::getCarNumber));
Map<String, Map<String, Object>> resultMap = new HashMap<>();
if (!CollectionUtils.isEmpty(registerInfoList)) {
registerInfoList.parallelStream().forEach(v->{
Map<String, Object> param = new HashMap<>();
param.put("CAR_NUMBER", v.getCarNumber());
resultMap.put(v.getRecord(), param);
});
tzsServiceFeignClient.commonUpdateEsDataByIds(resultMap);
}
return registerInfoList.size();
}
}
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