feat: 增加批量修改传感器的主设备id

src/main/java/com/xydl/cac/controller/ModevController.java

@@ -18,7 +18,7 @@ import javax.validation.constraints.NotNull;
 import java.util.List;
 
 @RestController
-@Api(tags = {"监测设备相关接口"})
+@Api(tags = {"旧监测设备相关接口"})
 @RequestMapping("modev")
 @Slf4j
 public class ModevController extends BasicController {

src/main/java/com/xydl/cac/controller/NSensorController.java

@@ -6,6 +6,7 @@ import com.xydl.cac.exception.BusinessException;
 import com.xydl.cac.model.ConditionModel;
 import com.xydl.cac.model.Response;
 import com.xydl.cac.model.SensorDetail;
+import com.xydl.cac.model.SensorUpdateModel;
 import com.xydl.cac.service.NSensorService;
 import com.xydl.cac.service.ParamBindService;
 import com.xydl.cac.service.ReportService;
@@ -75,6 +76,13 @@ public class NSensorController extends BasicController {
         return Response.success("OK");
     }
 
+    @PostMapping("batchUpdate")
+    @ApiOperation("批量更新")
+    public Response<String> batchUpdate(@Validated @RequestBody SensorUpdateModel model) throws Exception {
+        service.batchUpdate(model);
+        return Response.success("OK");
+    }
+
     @PostMapping("delete")
     @ApiOperation("删除")
     public Response<String> delete(@Validated @NotNull(message = "ID不能为空!") @Param("id") Integer id) {

src/main/java/com/xydl/cac/entity/NSensor.java

@@ -58,7 +58,7 @@ public class NSensor {
     private Integer status;
 
     @Column(name = "zsb_id")
-    @ApiModelProperty("主设备编号")
+    @ApiModelProperty("主设备Id")
     private Integer zsbId;
 
     @Column(name = "icd_id")

src/main/java/com/xydl/cac/model/SensorUpdateModel.java

@@ -0,0 +1,14 @@
+package com.xydl.cac.model;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+import java.util.List;
+
+@Data
+public class SensorUpdateModel {
+    @NotNull(message = "id列表不能为空")
+    private List<Integer> idList;
+    @NotNull(message = "主设备Id不能为空")
+    private Integer zsbId;
+}

src/main/java/com/xydl/cac/service/NSensorService.java

@@ -3,6 +3,7 @@ package com.xydl.cac.service;
 import com.xydl.cac.entity.NSensor;
 import com.xydl.cac.model.ConditionModel;
 import com.xydl.cac.model.SensorDetail;
+import com.xydl.cac.model.SensorUpdateModel;
 import org.springframework.data.domain.Page;
 
 import java.util.Collection;
@@ -18,6 +19,8 @@ public interface NSensorService {
 
     void update(NSensor item) throws Exception;
 
+    void batchUpdate(SensorUpdateModel model) throws Exception;
+
     void delete(Integer id);
 
     SensorDetail<Map<String, Object>> getDetail(ConditionModel model) throws Exception;

src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java

@@ -111,7 +111,6 @@ public class DataServiceImpl implements DataService {
 
         String sqlCount = "SELECT count(*)" + sqlFrom + sqlWhere;
         String sql = sqlSelect + sqlFrom + sqlWhere + sqlOrder + sqlLimit;
-        log.info(sql);
 
         Long count = jdbcTemplate.queryForObject(sqlCount, Long.class);
         List<Map<String, Object>> content = jdbcTemplate.queryForList(sql);
@@ -152,7 +151,6 @@ public class DataServiceImpl implements DataService {
 
         String sqlCount = "SELECT count(*)" + sqlFrom + sqlWhere;
         String sql = sqlSelect + sqlFrom + sqlWhere + sqlOrder + sqlLimit;
-        log.info(sql);
 
         Long count = jdbcTemplate.queryForObject(sqlCount, Long.class);
         List<Map<String, Object>> content = jdbcTemplate.queryForList(sql);

src/main/java/com/xydl/cac/service/impl/NSensorServiceImpl.java

@@ -5,6 +5,7 @@ import com.xydl.cac.exception.BusinessException;
 import com.xydl.cac.model.ConditionModel;
 import com.xydl.cac.model.OnePage;
 import com.xydl.cac.model.SensorDetail;
+import com.xydl.cac.model.SensorUpdateModel;
 import com.xydl.cac.repository.NPointRepository;
 import com.xydl.cac.repository.NSensorRepository;
 import com.xydl.cac.service.DataService;
@@ -62,6 +63,18 @@ public class NSensorServiceImpl implements NSensorService {
         repository.save(item);
     }
 
+    @Override
+    public void batchUpdate(SensorUpdateModel model) throws Exception {
+        for (Integer id : model.getIdList()) {
+            Optional<NSensor> optional = repository.findById(id);
+            if (!optional.isPresent()) {
+                throw new BusinessException("未找到该装置" + id);
+            }
+            NSensor sensor = optional.get();
+            sensor.setZsbId(model.getZsbId());
+        }
+    }
+
     @Override
     public void delete(Integer id) {
         repository.deleteById(id);