Commit 89cbb19a authored by tianbo's avatar tianbo

feat(equip): 更新设备监督管理信息

- 在 CommonEquipDataProcessService 中添加设备监督管理信息的处理逻辑 - 在 EquipChangeDataUpdateServiceImpl 中实现监督管理信息的 ES 数据更新方法 - 在 SingleEquipChangeProcess 中调用监督管理信息的 ES 数据更新方法 - 注释掉设计信息的处理逻辑
parent 0295b58e
......@@ -1028,10 +1028,10 @@ public class CommonEquipDataProcessService {
equipChangeDataUpdateServiceImpl.updateFactoryEsData(record, equipFactoryChangeDataDto);
}
// 设计信息
if (changeDataDto instanceof IdxBizJgDesignInfo) {
IdxBizJgDesignInfo equipDesignChangeDataDto = (IdxBizJgDesignInfo) changeDataDto;
equipChangeDataUpdateServiceImpl.checkDesignChangeData(record, equipDesignChangeDataDto);
}
// if (changeDataDto instanceof IdxBizJgDesignInfo) {
// IdxBizJgDesignInfo equipDesignChangeDataDto = (IdxBizJgDesignInfo) changeDataDto;
// equipChangeDataUpdateServiceImpl.checkDesignChangeData(record, equipDesignChangeDataDto);
// }
// 使用信息
if (changeDataDto instanceof IdxBizJgUseInfo) {
IdxBizJgUseInfo equipUseInfoChangeDataDto = (IdxBizJgUseInfo) changeDataDto;
......@@ -1039,8 +1039,13 @@ public class CommonEquipDataProcessService {
}
// 检验信息
if (changeDataDto instanceof IdxBizJgInspectionDetectionInfo) {
IdxBizJgInspectionDetectionInfo equipUseInfoChangeDataDto = (IdxBizJgInspectionDetectionInfo) changeDataDto;
equipChangeDataUpdateServiceImpl.updateInspectInfoEs(record, equipUseInfoChangeDataDto);
IdxBizJgInspectionDetectionInfo equipInspectionInfoChangeDataDto = (IdxBizJgInspectionDetectionInfo) changeDataDto;
equipChangeDataUpdateServiceImpl.updateInspectInfoEs(record, equipInspectionInfoChangeDataDto);
}
// 监督管理信息
if (changeDataDto instanceof IdxBizJgSupervisionInfo) {
IdxBizJgSupervisionInfo equipSupervisionInfoChangeDataDto = (IdxBizJgSupervisionInfo) changeDataDto;
equipChangeDataUpdateServiceImpl.updateSupervisionInfoEs(record, equipSupervisionInfoChangeDataDto);
}
}
......
......@@ -371,6 +371,19 @@ public class EquipChangeDataUpdateServiceImpl {
}
}
public void updateSupervisionInfoEs(String record, IdxBizJgSupervisionInfo equipSupervisionInfoChangeDataDto) {
// es 数据更新
Optional<ESEquipmentCategoryDto> optional = esEquipmentCategory.findById(record);
if (optional.isPresent()) {
ESEquipmentCategoryDto esEquipmentCategoryDto = optional.get();
if(equipSupervisionInfoChangeDataDto.getOrgBranchCode() != null) {
esEquipmentCategoryDto.setORG_BRANCH_CODE(equipSupervisionInfoChangeDataDto.getOrgBranchCode());
esEquipmentCategoryDto.setORG_BRANCH_NAME(equipSupervisionInfoChangeDataDto.getOrgBranchName());
esEquipmentCategory.save(esEquipmentCategoryDto);
}
}
}
public void updateOtherInfoChangeData(String record, EquipOtherInfoChangeDataDto otherInfoChangeDataDto) {
LambdaUpdateWrapper<IdxBizJgOtherInfo> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.eq(IdxBizJgOtherInfo::getRecord, record);
......
......@@ -130,6 +130,7 @@ public class SingleEquipChangeProcess implements IEquipChangeDataProcessStrategy
commonEquipDataProcessService.updateEsDataOfEquip(record, designInfoNew);
commonEquipDataProcessService.updateEsDataOfEquip(record, otherInfoNew);
commonEquipDataProcessService.updateEsDataOfEquip(record, factoryInfoNew);
commonEquipDataProcessService.updateEsDataOfEquip(record, idxBizJgSupervisionInfoNew);
// 如果是气瓶则按照证更新其他同证下的气瓶字段
this.updateOtherEquipInSameCert(useInfoNew, registerInfoNew, registerInfoOld, allChangeColumns);
......
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