Commit 82a82c49 authored by suhuiguang's avatar suhuiguang

fix(jg): 3库数据同步

1.同步异常日志处理;空指针
parent 11a5bb06
...@@ -32,7 +32,7 @@ public class DataRefreshDispatcher implements IDataRefreshDispatch { ...@@ -32,7 +32,7 @@ public class DataRefreshDispatcher implements IDataRefreshDispatch {
dataRefreshHandler.doRefresh(message); dataRefreshHandler.doRefresh(message);
markRefreshSuccess(message); markRefreshSuccess(message);
} catch (Exception e) { } catch (Exception e) {
log.error("三库数据刷新执行失败,消息内容:{}, 错误日志:{}", messages, e.getMessage(), e); log.error("三库数据刷新执行失败,消息内容:{}, 错误日志:{}", message, e.getMessage(), e);
message.setErrorMsg(e.getMessage()); message.setErrorMsg(e.getMessage());
markRefreshFailure(message); markRefreshFailure(message);
} }
......
...@@ -58,6 +58,9 @@ public class EquipmentRefreshHandler implements IDataRefreshHandler { ...@@ -58,6 +58,9 @@ public class EquipmentRefreshHandler implements IDataRefreshHandler {
String record = message.getDataId(); String record = message.getDataId();
ESEquipmentInfo esEquipmentInfo = new ESEquipmentInfo(); ESEquipmentInfo esEquipmentInfo = new ESEquipmentInfo();
Map<String, Object> detail = useInfoService.getBaseMapper().queryDetail(record); Map<String, Object> detail = useInfoService.getBaseMapper().queryDetail(record);
if(detail == null) {
return;
}
StatisticsDataUpdateService.formatUseDate(detail); StatisticsDataUpdateService.formatUseDate(detail);
BeanUtil.copyProperties(detail, esEquipmentInfo, true); BeanUtil.copyProperties(detail, esEquipmentInfo, true);
List<IdxBizJgInspectionDetectionInfo> inspectionDetectionInfos = iIdxBizJgInspectionDetectionInfoService.queryLastedGroupByInspectType(record); List<IdxBizJgInspectionDetectionInfo> inspectionDetectionInfos = iIdxBizJgInspectionDetectionInfoService.queryLastedGroupByInspectType(record);
......
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