| | |
|---|
| | | |
|---|
| | | PrFlowmeter prFlowmeter = DtoToFlowmeterPojo.INSTANCT.po2vo(po); |
|---|
| | | Date operateTime = new Date(); |
|---|
| | | prFlowmeter.setOperatedt(operateTime); |
|---|
| | | prFlowmeter.setOperateDt(operateTime); |
|---|
| | | prFlowmeter.setDeleted((byte) 0); |
|---|
| | | prFlowmeter.setReporttime(operateTime); |
|---|
| | | prFlowmeter.setReportTime(operateTime); |
|---|
| | | Integer rec = Optional.ofNullable(flowmeterSv.addFlowmeter(prFlowmeter)).orElse(0); |
|---|
| | | if (rec == 0) { |
|---|
| | | return BaseResponseUtils.buildFail(ProjectResultCode.ADD_FLOWMETER_FAIL.getMessage()); |
|---|
| | |
|---|
| | | 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()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
