| | |
| | | import com.dy.pipIrrGlobal.pojoPr.PrIntake; |
| | | import com.dy.pipIrrGlobal.voPr.VoIntake; |
| | | import com.dy.pipIrrGlobal.voSe.VoActiveCard; |
| | | import com.dy.pipIrrProject.result.ProjectResultCode; |
| | | import io.swagger.v3.oas.annotations.Operation; |
| | | import io.swagger.v3.oas.annotations.Parameter; |
| | | import io.swagger.v3.oas.annotations.media.Content; |
| | |
| | | public BaseResponse<QueryResultVo<List<PrIntake>>> all(){ |
| | | try { |
| | | QueryResultVo<List<PrIntake>> res = this.intakeSv.selectAll(); |
| | | return BaseResponseUtils.buildSuccess(res); |
| | | if(res == null) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | }else { |
| | | return BaseResponseUtils.buildSuccess(res); |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("查询取水口异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | |
| | | @GetMapping(path = "one/{id}") |
| | | @SsoAop() |
| | | public BaseResponse<PrIntake> one(@PathVariable("id") Long id){ |
| | | return BaseResponseUtils.buildSuccess(this.intakeSv.selectById(id)); |
| | | if(this.intakeSv.selectById(id) == null) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | }else { |
| | | return BaseResponseUtils.buildSuccess(this.intakeSv.selectById(id)); |
| | | } |
| | | } |
| | | |
| | | @Operation(summary = "获得一页取水口记录", description = "返回一页取水口数据") |
| | |
| | | try { |
| | | QueryResultVo<List<VoIntake>> res = intakeSv.getIntakes(vo); |
| | | if(res == null) { |
| | | return BaseResponseUtils.buildFail("查询失败"); |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.NO_INTAKES.getMessage()); |
| | | } |
| | | return BaseResponseUtils.buildSuccess(res); |
| | | } catch (Exception e) { |
| | |
| | | po.setOperateDt(operateTime); |
| | | Integer rec = Optional.ofNullable(intakeSv.addIntake(po)).orElse(0); |
| | | if(rec == 0) { |
| | | return BaseResponseUtils.buildFail("数据库存储失败"); |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.ADD_INTAKE_FAIL.getMessage()); |
| | | } |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |
| | |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | if(count <= 0){ |
| | | return BaseResponseUtils.buildFail("数据库存储失败") ; |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.UPDATE_INTAKE.getMessage()) ; |
| | | }else{ |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |
| | |
| | | @GetMapping(path = "delete/{id}") |
| | | @SsoAop() |
| | | public BaseResponse<Boolean> delete(@PathVariable("id") Long id){ |
| | | if(id == null){ |
| | | return BaseResponseUtils.buildFail("id不能为空") ; |
| | | if(id == null ){ |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.PLEASE_INPUT_INTAKE_ID.getMessage()) ; |
| | | } |
| | | int count; |
| | | try { |
| | |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | if(count <= 0){ |
| | | return BaseResponseUtils.buildFail("数据库存储失败") ; |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.DELETE_INTAKE_FAIL.getMessage()) ; |
| | | }else{ |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |