1.压力管道编辑保存时同步更新装置下的搜索管道es的装置名称

amos-boot-system-tzs/amos-boot-module-common/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/dao/ESEquipmentCategory.java

@@ -9,5 +9,5 @@ import java.util.List;
 
 @Repository
 public interface ESEquipmentCategory extends PagingAndSortingRepository<ESEquipmentCategoryDto, String> {
-    List<ESEquipmentCategoryDto> findAllByPROJECT_CONTRAPTION_ID(String PROJECT_CONTRAPTION_ID);
+    List<ESEquipmentCategoryDto> findAllByProjectContraptionId(String PROJECT_CONTRAPTION_ID);
 }

amos-boot-system-tzs/amos-boot-module-common/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/dto/ESEquipmentCategoryDto.java

@@ -177,6 +177,6 @@ public class ESEquipmentCategoryDto {
     /**
      * 工程装置id（工业管道使用）
      */
-    @Field(type = FieldType.Keyword)
-    private String PROJECT_CONTRAPTION_ID;
+    @Field(type = FieldType.Keyword, name = "PROJECT_CONTRAPTION_ID")
+    private String projectContraptionId;
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/EquipChangeDataUpdateService.java

@@ -139,7 +139,7 @@ public class EquipChangeDataUpdateService {
 
     public void updateRegisterEsDataPieLine(ProjectContraptionChangeDataDto registerChangeDataDto) {
         // es 数据更新
-        List<ESEquipmentCategoryDto> pieLines = esEquipmentCategory.findAllByPROJECT_CONTRAPTION_ID(registerChangeDataDto.getProjectContraptionId());
+        List<ESEquipmentCategoryDto> pieLines = esEquipmentCategory.findAllByProjectContraptionId(registerChangeDataDto.getProjectContraptionId());
         for(ESEquipmentCategoryDto esEquipmentCategoryDto: pieLines) {
             esEquipmentCategoryDto.setPROJECT_CONTRAPTION(registerChangeDataDto.getProjectContraption());
         }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/IdxBizJgRegisterInfoServiceImpl.java

@@ -673,7 +673,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
             esEquipmentDto.setUSC_UNIT_NAME(projectContraption.getUscUnitName());
             esEquipmentDto.setPROJECT_CONTRAPTION(projectContraption.getProjectContraption());
             esEquipmentDto.setPRODUCT_NAME(pipelineInfo.getPipeName());
-            esEquipmentDto.setPROJECT_CONTRAPTION_ID(String.valueOf(sequenceNbr));
+            esEquipmentDto.setProjectContraptionId(String.valueOf(sequenceNbr));
             if (inspectionDetectionInfo.getNextInspectDate() != null) {
                 esEquipmentDto.setNEXT_INSPECT_DATE(inspectionDetectionInfo.getNextInspectDate().getTime());
             }