Commit 58cb48ed authored by suhuiguang's avatar suhuiguang

1.编辑数据增加冗余设备类别名称到es

parent 32525d12
...@@ -118,12 +118,22 @@ public class EquipChangeDataUpdateService { ...@@ -118,12 +118,22 @@ public class EquipChangeDataUpdateService {
esEquipmentCategoryDto.setPRODUCT_NAME(registerChangeDataDto.getProductName()); esEquipmentCategoryDto.setPRODUCT_NAME(registerChangeDataDto.getProductName());
esEquipmentCategoryDto.setEQU_CODE(registerChangeDataDto.getEquCode()); esEquipmentCategoryDto.setEQU_CODE(registerChangeDataDto.getEquCode());
esEquipmentCategoryDto.setEQU_TYPE(registerChangeDataDto.getEquType()); esEquipmentCategoryDto.setEQU_TYPE(registerChangeDataDto.getEquType());
esEquipmentCategoryDto.setEQU_DEFINE_CODE(registerChangeDataDto.getEquDefine());
esEquipmentCategoryDto.setEQU_CATEGORY_CODE(registerChangeDataDto.getEquCategory()); esEquipmentCategoryDto.setEQU_CATEGORY_CODE(registerChangeDataDto.getEquCategory());
esEquipmentCategoryDto.setEQU_DEFINE_CODE(registerChangeDataDto.getEquDefine());
// 冗余设备类别名称
if (StringUtils.isEmpty(registerChangeDataDto.getEquCategory())) {
esEquipmentCategoryDto.setEQU_CATEGORY(null);
} else {
EquipmentCategory category = getEquipmentCategory(registerChangeDataDto.getEquCategory());
if (category != null) {
esEquipmentCategoryDto.setEQU_CATEGORY(category.getName());
}
}
// 冗余设备品种名称
if (StringUtils.isEmpty(registerChangeDataDto.getEquDefine())) { if (StringUtils.isEmpty(registerChangeDataDto.getEquDefine())) {
esEquipmentCategoryDto.setEQU_DEFINE(null); esEquipmentCategoryDto.setEQU_DEFINE(null);
} else { } else {
EquipmentCategory category = getEquipmentCategory(registerChangeDataDto); EquipmentCategory category = getEquipmentCategory(registerChangeDataDto.getEquDefine());
if (category != null) { if (category != null) {
esEquipmentCategoryDto.setEQU_DEFINE(category.getName()); esEquipmentCategoryDto.setEQU_DEFINE(category.getName());
} }
...@@ -143,10 +153,11 @@ public class EquipChangeDataUpdateService { ...@@ -143,10 +153,11 @@ public class EquipChangeDataUpdateService {
} }
} }
private EquipmentCategory getEquipmentCategory(EquipRegisterChangeDataDto registerChangeDataDto) { private EquipmentCategory getEquipmentCategory(String categoryCode) {
return equipmentCategoryMapper.selectOne(new LambdaQueryWrapper<EquipmentCategory>().eq(EquipmentCategory::getCode, registerChangeDataDto.getEquDefine())); return equipmentCategoryMapper.selectOne(new LambdaQueryWrapper<EquipmentCategory>().eq(EquipmentCategory::getCode, categoryCode));
} }
public void updateTechParamByRecord(String tableName, String record, List<ChangeDataDto> changeDataDtos) { public void updateTechParamByRecord(String tableName, String record, List<ChangeDataDto> changeDataDtos) {
List<DynamicColumnDto> columns = changeDataDtos.stream().map(c -> { List<DynamicColumnDto> columns = changeDataDtos.stream().map(c -> {
DynamicColumnDto columnDto = new DynamicColumnDto(); DynamicColumnDto columnDto = new DynamicColumnDto();
......
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