From 12e9ce64c364deb7ea08ba82f8d72abf6e561fc2 Mon Sep 17 00:00:00 2001 From: wuzeyu <1223318623@qq.com> Date: 星期一, 27 五月 2024 16:53:50 +0800 Subject: [PATCH] 田间灌溉项目管理 灌溉制度模块 修改查询流浪灌溉单元和已绑定灌溉单元接口返回id类型 作物分页查询增加返回备注字段 --- pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateGroup/IrrigateGroupCtrl.java | 62 ++++++++++++++++++++++-------- 1 files changed, 45 insertions(+), 17 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateGroup/IrrigateGroupCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateGroup/IrrigateGroupCtrl.java index fd7145e..7694fbb 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateGroup/IrrigateGroupCtrl.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateGroup/IrrigateGroupCtrl.java @@ -31,10 +31,7 @@ import org.springframework.validation.BindingResult; import org.springframework.web.bind.annotation.*; -import java.util.List; -import java.util.Map; -import java.util.Objects; -import java.util.Optional; +import java.util.*; /** * @author :WuZeYu @@ -250,14 +247,24 @@ @PostMapping(path = "add_unit", consumes = MediaType.APPLICATION_JSON_VALUE) @Transactional(rollbackFor = Exception.class) @SsoAop() - public BaseResponse<Boolean> addGroupUnit(@RequestBody @Valid IrGroupUnit po, BindingResult bindingResult) { + public BaseResponse<Boolean> addGroupUnit(@RequestBody @Valid Map<String,Object> po, BindingResult bindingResult) { if (bindingResult != null && bindingResult.hasErrors()) { return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); } + Long groupId = Long.parseLong(po.get("groupId").toString()); + Long operator = Long.parseLong(po.get("operator").toString()); + List<Long> unitIds = (List<Long>) po.get("unitIds"); try { - Integer rec = Optional.ofNullable(irrigateGroupSv.addGroupUnit(po)).orElse(0); - if (rec == 0) { - return BaseResponseUtils.buildFail(IrrigateResultCode.ADD_PROJECT_FAIL.getMessage()); + for (int i = 0; i < unitIds.size(); i++) { + Long unitId = unitIds.get(i); + IrGroupUnit irGroupUnit = new IrGroupUnit(); + irGroupUnit.setGroupId(groupId); + irGroupUnit.setUnitId(unitId); + irGroupUnit.setOperator(operator); + Integer rec = Optional.ofNullable(irrigateGroupSv.addGroupUnit(irGroupUnit)).orElse(0); + if (rec == 0) { + return BaseResponseUtils.buildFail(IrrigateResultCode.ADD_PROJECT_FAIL.getMessage()); + } } } catch (Exception e) { log.error("杞亴缁勬坊鍔犵亴婧夊崟鍏冨紓甯�", e); @@ -267,7 +274,7 @@ } /** - * 閫昏緫鍒犻櫎 杞亴缁勭Щ闄ょ亴婧夊崟鍏� + * 杞亴缁勭Щ闄ょ亴婧夊崟鍏� * @param * @return */ @@ -283,15 +290,26 @@ @PostMapping(path = "remove_unit") @Transactional(rollbackFor = Exception.class) @SsoAop() - public BaseResponse<Boolean> deleteGroupUnit(@RequestBody @Valid IrGroupUnit po, BindingResult bindingResult) { + public BaseResponse<Boolean> deleteGroupUnit(@RequestBody @Valid Map<String,Object> po, BindingResult bindingResult) { if (bindingResult != null && bindingResult.hasErrors()) { return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); } + Long groupId = Long.parseLong(po.get("groupId").toString()); + Long operator = Long.parseLong(po.get("operator").toString()); + List<Long> unitIds = (List<Long>) po.get("unitIds"); try { - Integer rec = Optional.ofNullable(irrigateGroupSv.deleteGroupUnit(po)).orElse(0); - if (rec == 0) { - return BaseResponseUtils.buildFail(IrrigateResultCode.DELETE_PROJECT_FAIL.getMessage()); + for (int i = 0; i < unitIds.size(); i++) { + Long unitId = unitIds.get(i); + IrGroupUnit irGroupUnit = new IrGroupUnit(); + irGroupUnit.setGroupId(groupId); + irGroupUnit.setUnitId(unitId); + irGroupUnit.setOperator(operator); + Integer rec = Optional.ofNullable(irrigateGroupSv.deleteGroupUnit(irGroupUnit)).orElse(0); + if (rec == 0) { + return BaseResponseUtils.buildFail(IrrigateResultCode.DELETE_PROJECT_FAIL.getMessage()); + } } + } catch (Exception e) { log.error("杞亴缁勭Щ闄ょ亴婧夊崟鍏冨紓甯�", e); return BaseResponseUtils.buildException(e.getMessage()); @@ -301,10 +319,15 @@ @GetMapping(path = "bind_units") @SsoAop() - public BaseResponse<List<Long>> getGroupBindUnits(Long id) { + public BaseResponse<List<String>> getGroupBindUnits(Long id) { try { List<Long> res = irrigateGroupSv.getGroupBindUnits(id); - return BaseResponseUtils.buildSuccess(res); + ArrayList<Object> list = new ArrayList<>(); + for (int i = 0; i < res.size(); i++) { + String aLong = res.get(i).toString(); + list.add(aLong); + } + return BaseResponseUtils.buildSuccess(list); } catch (Exception e) { log.error("鑾峰彇涓�涓疆鐏岀粍缁戝畾鐏屾簤鍗曞厓璁板綍寮傚父", e); return BaseResponseUtils.buildException(e.getMessage()); @@ -313,10 +336,15 @@ @GetMapping(path = "notBind_units") @SsoAop() - public BaseResponse<List<Long>> getNotBindUnits() { + public BaseResponse<List<String>> getNotBindUnits() { try { List<Long> res = irrigateGroupSv.getNotBindUnits(); - return BaseResponseUtils.buildSuccess(res); + ArrayList<Object> list = new ArrayList<>(); + for (int i = 0; i < res.size(); i++) { + String aLong = res.get(i).toString(); + list.add(aLong); + } + return BaseResponseUtils.buildSuccess(list); } catch (Exception e) { log.error("鑾峰彇鏈粦瀹氳疆鐏岀粍鐨勭亴婧夊崟鍏僫d璁板綍寮傚父", e); return BaseResponseUtils.buildException(e.getMessage()); -- Gitblit v1.8.0