| | |
| | | try { |
| | | QueryResultVo<List<PrIntake>> res = this.intakeSv.selectAll(); |
| | | if (res == null) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | } else { |
| | | return BaseResponseUtils.buildSuccess(res); |
| | | } |
| | |
| | | @SsoAop() |
| | | public BaseResponse<PrIntake> one(@PathVariable("id") Long id) { |
| | | if (this.intakeSv.selectById(id) == null) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | } else { |
| | | return BaseResponseUtils.buildSuccess(this.intakeSv.selectById(id)); |
| | | } |
| | |
| | | try { |
| | | QueryResultVo<List<VoIntake>> res = intakeSv.getIntakes(vo); |
| | | if (res == null) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | } |
| | | return BaseResponseUtils.buildSuccess(res); |
| | | } catch (Exception e) { |
| | |
| | | public BaseResponse<Boolean> add(@RequestBody @Valid PrIntake po, @Parameter(hidden = true) BindingResult bindingResult) { |
| | | DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); |
| | | if (bindingResult != null && bindingResult.hasErrors()) { |
| | | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); |
| | | } |
| | | List<Long> ids = intakeSv.getIntakeIdsByName(po.getName()); |
| | | if (ids.size() > 0) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.INTAKE_NAME_EXIST.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.INTAKE_NAME_EXIST.getMessage()); |
| | | } |
| | | po.setOperateDt(new Date()); |
| | | po.setDeleted((byte) 0); |
| | | Integer rec = Optional.ofNullable(intakeSv.addIntake(po)).orElse(0); |
| | | if (rec == 0) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.ADD_INTAKE_FAIL.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.ADD_INTAKE_FAIL.getMessage()); |
| | | } |
| | | return BaseResponseUtils.buildSuccess(true); |
| | | } |
| | |
| | | @SsoAop() |
| | | public BaseResponse<Boolean> update(@RequestBody @Parameter(description = "form表单json数据", required = true) @Valid PrIntake po, @Parameter(hidden = true) BindingResult bindingResult) { |
| | | if (bindingResult != null && bindingResult.hasErrors()) { |
| | | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); |
| | | } |
| | | List<Long> ids = intakeSv.getIntakeIdByNameExcludeId(po.getId(), po.getName()); |
| | | if (ids.size() > 0) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.INTAKE_NAME_EXIST.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.INTAKE_NAME_EXIST.getMessage()); |
| | | } |
| | | int count; |
| | | po.setOperateDt(new Date()); |
| | |
| | | return BaseResponseUtils.buildException(e.getMessage()); |
| | | } |
| | | if (count <= 0) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.UPDATE_INTAKE.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.UPDATE_INTAKE.getMessage()); |
| | | } else { |
| | | return BaseResponseUtils.buildSuccess(true); |
| | | } |
| | |
| | | @SsoAop() |
| | | public BaseResponse<Boolean> delete(@RequestBody Map map) { |
| | | if (map == null || map.size() <= 0) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.PLEASE_INPUT_INTAKE_ID.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.PLEASE_INPUT_INTAKE_ID.getMessage()); |
| | | } |
| | | Long id = Long.parseLong(map.get("id").toString()); |
| | | try { |
| | | //取水口ID |
| | | Integer recordCount = Optional.ofNullable(intakeSv.delete(id)).orElse(0); |
| | | if (recordCount == 0) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.DELETE_INTAKE_FAIL.getMessage()); |
| | | return BaseResponseUtils.buildErrorMsg(ProjectResultCode.DELETE_INTAKE_FAIL.getMessage()); |
| | | } else { |
| | | return BaseResponseUtils.buildSuccess(true); |
| | | } |