From 9f781d50d96e4193d61f4797b72cd79b5203a764 Mon Sep 17 00:00:00 2001 From: wuzeyu <1223318623@qq.com> Date: 星期四, 28 三月 2024 14:57:39 +0800 Subject: [PATCH] 增加 查询一个监测站接口 条件查询已绑定的流量计接口 查询全部流量计接口 --- pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterCtrl.java | 33 ++++++++++++++++++++++++++++----- 1 files changed, 28 insertions(+), 5 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterCtrl.java index 96513c4..2e3f6b5 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterCtrl.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterCtrl.java @@ -108,18 +108,41 @@ schema = @Schema(implementation = PrFlowmeter.class))} ) }) - @GetMapping(path = "getFlowMeters", consumes = MediaType.APPLICATION_JSON_VALUE) + @GetMapping(path = "getFlowMeters") @SsoAop() - public BaseResponse<QueryResultVo<List<VoFlowMeter>>> getFlowMeters(@RequestBody @Parameter(description = "鏌ヨform琛ㄥ崟json鏁版嵁", required = true) QueryVoFlowMeter vo) { + public BaseResponse<QueryResultVo<List<VoFlowMeter>>> getFlowMeters(QueryVoFlowMeter vo) { try { QueryResultVo<List<VoFlowMeter>> res = flowmeterSv.getFlowMeters(vo); - if (res == null) { - return BaseResponseUtils.buildFail(ProjectResultCode.NO_FLOWMETERS.getMessage()); + if (res.itemTotal != null && res.itemTotal > 0) { + return BaseResponseUtils.buildSuccess(res); } - return BaseResponseUtils.buildSuccess(res); + return BaseResponseUtils.buildFail(ProjectResultCode.NO_FLOWMETERS.getMessage()); } catch (Exception e) { log.error("鑾峰彇娴侀噺璁¤褰曞紓甯�", e); return BaseResponseUtils.buildException(e.getMessage()); } } + @Operation(summary = "鑾峰緱鍏ㄩ儴娴侀噺璁�", description = "杩斿洖鍏ㄩ儴娴侀噺璁�") + @ApiResponses(value = { + @ApiResponse( + responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, + description = "杩斿洖鍏ㄩ儴娴侀噺璁★紙BaseResponse.content:QueryResultVo[{}]锛�", + content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, + schema = @Schema(implementation = PrFlowmeter.class))} + ) + }) + @GetMapping(path = "all") + @SsoAop() + public BaseResponse<List<PrFlowmeter>> getFlowMeterAll() { + try { + List<PrFlowmeter> res = flowmeterSv.getFlowMeterAll(); + if (res != null && res.size() > 0) { + return BaseResponseUtils.buildSuccess(res); + } + return BaseResponseUtils.buildFail(ProjectResultCode.NO_DATA.getMessage()); + } catch (Exception e) { + log.error("鑾峰彇娴侀噺璁℃暟鎹紓甯�", e); + return BaseResponseUtils.buildException(e.getMessage()); + } + } } -- Gitblit v1.8.0