批量修改地址

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/controller/admin/equipboiler/EquipBoilerController.java

@@ -62,6 +62,13 @@ public class EquipBoilerController {
         return success(true);
     }
 
+    @PutMapping("/batch-update-district")
+    @Operation(summary = "批量修改锅炉设备行政区和街道")
+    public CommonResult<Boolean> batchUpdateDistrict(@Valid @RequestBody EquipBoilerBatchUpdateDistrictVO batchUpdateVO) {
+        equipBoilerService.batchUpdateEquipDistrict(batchUpdateVO);
+        return success(true);
+    }
+
     @DeleteMapping("/delete")
     @Operation(summary = "删除锅炉设备")
     @Parameter(name = "id", description = "编号", required = true)

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/controller/admin/equipboiler/vo/EquipBoilerBatchUpdateDistrictVO.java

@@ -0,0 +1,26 @@
+package cn.start.tz.module.pressure2.controller.admin.equipboiler.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotEmpty;
+import lombok.Data;
+
+import java.util.List;
+
+@Schema(description = "管理后台 - 锅炉设备批量修改行政区街道 Request VO")
+@Data
+public class EquipBoilerBatchUpdateDistrictVO {
+
+    @Schema(description = "设备ID列表", requiredMode = Schema.RequiredMode.REQUIRED, example = "[\"id1\", \"id2\"]")
+    @NotEmpty(message = "设备ID列表不能为空")
+    private List<String> ids;
+
+    @Schema(description = "设备所在行政区", example = "440305")
+    private Integer equipDistrict;
+
+    @Schema(description = "设备所在街道", example = "440305001")
+    private Integer equipStreet;
+
+    @Schema(description = "区域类型", example = "all")
+    private String areaType;
+
+}

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/controller/admin/equippipe/EquipPipeController.java

@@ -75,6 +75,13 @@ public class EquipPipeController {
         return success(true);
     }
 
+    @PutMapping("/batch-update-district")
+    @Operation(summary = "批量修改管道设备行政区和街道")
+    public CommonResult<Boolean> batchUpdateDistrict(@Valid @RequestBody EquipPipeBatchUpdateDistrictVO batchUpdateVO) {
+        equipPipeService.batchUpdateEquipDistrict(batchUpdateVO);
+        return success(true);
+    }
+
     @DeleteMapping("/delete")
     @Operation(summary = "删除管道设备")
     @Parameter(name = "id", description = "编号", required = true)

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/controller/admin/equippipe/vo/EquipPipeBatchUpdateDistrictVO.java

@@ -0,0 +1,26 @@
+package cn.start.tz.module.pressure2.controller.admin.equippipe.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotEmpty;
+import lombok.Data;
+
+import java.util.List;
+
+@Schema(description = "管理后台 - 管道设备批量修改行政区街道 Request VO")
+@Data
+public class EquipPipeBatchUpdateDistrictVO {
+
+    @Schema(description = "设备ID列表", requiredMode = Schema.RequiredMode.REQUIRED, example = "[\"id1\", \"id2\"]")
+    @NotEmpty(message = "设备ID列表不能为空")
+    private List<String> ids;
+
+    @Schema(description = "设备所在行政区", example = "440305")
+    private Integer equipDistrict;
+
+    @Schema(description = "设备所在街道", example = "440305001")
+    private Integer equipStreet;
+
+    @Schema(description = "区域类型", example = "all")
+    private String areaType;
+
+}

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/service/equipboiler/EquipBoilerService.java

@@ -107,4 +107,11 @@ public interface EquipBoilerService extends IService<EquipBoilerDO>  {
     List<EquipBoilerPressurePartDO> getPressureParts(String boilerId);
 
     void updateSafetyManager(@Valid EquipBoilerSafetyManagerReqVO updateReqVO);
+
+    /**
+     * 批量修改锅炉设备行政区和街道
+     *
+     * @param batchUpdateVO 批量修改信息
+     */
+    void batchUpdateEquipDistrict(EquipBoilerBatchUpdateDistrictVO batchUpdateVO);
 }

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/service/equipboiler/EquipBoilerServiceImpl.java

@@ -464,4 +464,42 @@ public class EquipBoilerServiceImpl extends ServiceImpl<EquipBoilerMapper, Equip
         equipBoilerMapper.updateById(equipBoilerDO);
     }
 
+    @Override
+    public void batchUpdateEquipDistrict(EquipBoilerBatchUpdateDistrictVO batchUpdateVO) {
+        List<String> ids = batchUpdateVO.getIds();
+        if (ids == null || ids.isEmpty()) {
+            throw new IllegalArgumentException("设备ID列表不能为空");
+        }
+
+        Integer equipDistrict = batchUpdateVO.getEquipDistrict();
+        Integer equipStreet = batchUpdateVO.getEquipStreet();
+        String areaType = batchUpdateVO.getAreaType();
+
+        if (equipDistrict == null && equipStreet == null && StringUtils.isBlank(areaType)) {
+            throw new IllegalArgumentException("行政区、街道和区域类型至少需要填写一个");
+        }
+
+        for (String id : ids) {
+            EquipBoilerDO equipBoiler = equipBoilerMapper.selectById(id);
+            if (equipBoiler == null) {
+                continue;
+            }
+
+            EquipBoilerDO updateObj = new EquipBoilerDO();
+            updateObj.setId(id);
+
+            if (equipDistrict != null) {
+                updateObj.setEquipDistrict(equipDistrict);
+            }
+            if (equipStreet != null) {
+                updateObj.setEquipStreet(equipStreet);
+            }
+            if (StringUtils.isNotBlank(areaType)) {
+                updateObj.setAreaType(areaType);
+            }
+
+            equipBoilerMapper.updateById(updateObj);
+        }
+    }
+
 }

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/service/equippipe/EquipPipeService.java

@@ -89,5 +89,12 @@ public interface EquipPipeService extends IService<EquipPipeDO>  {
 
     void updateSafetyManager(@Valid EquipPipeSafetyManagerReqVO updateReqVO);
 
+    /**
+     * 批量修改管道设备行政区和街道
+     *
+     * @param batchUpdateVO 批量修改信息
+     */
+    void batchUpdateEquipDistrict(EquipPipeBatchUpdateDistrictVO batchUpdateVO);
+
     List<EquipPipeRespVO> getEquipPipeListByTaskOrderId(String taskOrderId) throws JsonProcessingException;
 }

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/service/equippipe/EquipPipeServiceImpl.java

@@ -5,6 +5,7 @@ import cn.start.tz.framework.common.exception.ErrorCode;
 import cn.start.tz.framework.common.pojo.CommonResult;
 import cn.start.tz.framework.common.pojo.PageResult;
 import cn.start.tz.framework.common.util.object.BeanUtils;
+import cn.start.tz.module.pressure2.controller.admin.equippipe.vo.EquipPipeBatchUpdateDistrictVO;
 import cn.start.tz.module.pressure2.controller.admin.equippipe.vo.EquipPipePageReqVO;
 import cn.start.tz.module.pressure2.controller.admin.equippipe.vo.EquipPipeRespVO;
 import cn.start.tz.module.pressure2.controller.admin.equippipe.vo.EquipPipeSaveReqVO;
@@ -287,6 +288,40 @@ public class EquipPipeServiceImpl extends ServiceImpl<EquipPipeMapper, EquipPipe
         equipPipeMapper.updateById(equipPipeDO);
     }
 
+    @Override
+    public void batchUpdateEquipDistrict(EquipPipeBatchUpdateDistrictVO batchUpdateVO) {
+        List<String> ids = batchUpdateVO.getIds();
+        if (ids == null || ids.isEmpty()) {
+            throw new IllegalArgumentException("设备ID列表不能为空");
+        }
+
+        Integer equipDistrict = batchUpdateVO.getEquipDistrict();
+        Integer equipStreet = batchUpdateVO.getEquipStreet();
+
+        if (equipDistrict == null && equipStreet == null) {
+            throw new IllegalArgumentException("行政区和街道至少需要填写一个");
+        }
+
+        for (String id : ids) {
+            EquipPipeDO equipPipe = equipPipeMapper.selectById(id);
+            if (equipPipe == null) {
+                continue;
+            }
+
+            EquipPipeDO updateObj = new EquipPipeDO();
+            updateObj.setId(id);
+
+            if (equipDistrict != null) {
+                updateObj.setEquipDistrict(equipDistrict);
+            }
+            if (equipStreet != null) {
+                updateObj.setEquipStreet(equipStreet);
+            }
+
+            equipPipeMapper.updateById(updateObj);
+        }
+    }
+
     @Override
     public List<EquipPipeRespVO> getEquipPipeListByTaskOrderId(String taskOrderId) throws JsonProcessingException {
         List<EquipPipeDO> equipPipeDOS = equipPipeMapper.selectEquipPipeListByTaskOrderId(taskOrderId);