diff --git a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalExtController.java b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalExtController.java index a5b3c03..ec8804a 100644 --- a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalExtController.java +++ b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalExtController.java @@ -62,6 +62,20 @@ public class TerminalExtController extends BaseController { CameraScheduleService cameraScheduleService; + @PostMapping("batchUpdate") + @ApiOperation("批量修改装置") + @Log(title = "批量修改装置", type = "修改") + public ResponseReult batchUpdate(@RequestBody BatchUpdateModel model) throws Exception { + if (model.getNewLineId() == null) { + throw new ApiException("newLineId不能为空"); + } + if (CollectionUtils.isEmpty(model.getTermIds())) { + throw new ApiException("termIds不能为空"); + } + terminalExtService.batchUpdate(model); + return ResponseReult.success("OK"); + } + @PostMapping("importTerminal") @ApiOperation("导入装置") @Log(title = "导入装置", type = "导入") diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/BatchUpdateModel.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/BatchUpdateModel.java new file mode 100644 index 0000000..1369291 --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/BatchUpdateModel.java @@ -0,0 +1,11 @@ +package com.shxy.xymanager_common.model; + +import lombok.Data; + +import java.util.List; + +@Data +public class BatchUpdateModel { + List termIds; + Integer newLineId; +} diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalExtServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalExtServiceImpl.java index c0b5717..1e8cc3d 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalExtServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalExtServiceImpl.java @@ -361,4 +361,23 @@ public class TerminalExtServiceImpl implements TerminalExtService { } return stat; } + + @Override + @CacheEvict(cacheNames = {"permissionfull", "permissionover", "fulltree", "cacheTerminalMap", "cacheTower"}, allEntries = true) + public void batchUpdate(BatchUpdateModel model) throws Exception { + for (Integer termId : model.getTermIds()) { + Terminals terminal = terminalsDao.selectByPrimaryKey(termId); + if (terminal == null) { + throw new ApiException("没有找到该装置termId=" + termId); + } + Towers tower = towerDao.selectByPrimaryKey(terminal.getTowerId()); + if (tower == null) { + throw new ApiException("该装置termId=" + termId + "的杆塔towerId=" + terminal.getTowerId() + "不存在"); + } + terminal.setLineId(model.getNewLineId()); + tower.setLineid(model.getNewLineId()); + towerDao.updateByPrimaryKey(tower); + terminalsDao.updateByPrimaryKey(terminal); + } + } } diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/service/TerminalExtService.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/service/TerminalExtService.java index 94beb3c..681b573 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/service/TerminalExtService.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/service/TerminalExtService.java @@ -2,6 +2,7 @@ package com.shxy.xymanager_service.service; import com.github.pagehelper.PageInfo; import com.shxy.xymanager_common.entity.*; +import com.shxy.xymanager_common.model.BatchUpdateModel; import com.shxy.xymanager_common.model.StatMaintain; import com.shxy.xymanager_common.model.StatModel; import com.shxy.xymanager_common.model.UploadModel; @@ -30,4 +31,6 @@ public interface TerminalExtService { void importTerminal(UploadModel model); List statMaintain(StatModel model) throws Exception; + + void batchUpdate(BatchUpdateModel model) throws Exception; }