From fdacd6f57d9ace487ee017c0a58de0a66075c9ca Mon Sep 17 00:00:00 2001 From: wuzeyu <1223318623@qq.com> Date: 星期三, 19 六月 2024 15:45:18 +0800 Subject: [PATCH] 修改 测控阀查询接口 返回实际在线情、增加返回通讯协议、备注 --- pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterSv.java | 37 +++++++++++++++++++++---------------- 1 files changed, 21 insertions(+), 16 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterSv.java index 92cab8d..a1803ac 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterSv.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterSv.java @@ -4,7 +4,6 @@ import com.dy.pipIrrGlobal.daoPr.PrFlowmeterMapper; import com.dy.pipIrrGlobal.pojoPr.PrFlowmeter; import com.dy.pipIrrGlobal.voPr.VoFlowMeter; -import com.dy.pipIrrGlobal.voPr.VoFlowMonitoring; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.common.utils.PojoUtils; import org.springframework.beans.factory.annotation.Autowired; @@ -61,27 +60,33 @@ */ public QueryResultVo<List<VoFlowMeter>> getFlowMeters(QueryVoFlowMeter queryVo){ Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo) ; - + Integer itemTotal = prFlowmeterMapper.getRecordCountOfFlowMeterByOthers(params); QueryResultVo<List<VoFlowMeter>> rsVo = new QueryResultVo<>() ; - - Integer pageCurr = 0; - Integer pageSize = 10000; - rsVo.pageCurr = 1; - rsVo.pageSize = 10000; - if(queryVo.pageSize != null && queryVo.pageCurr != null) { - rsVo.pageSize = queryVo.pageSize ; - rsVo.pageCurr = queryVo.pageCurr; - pageSize = queryVo.pageSize ; - pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString()); - } - params.put("pageCurr", pageCurr); - params.put("pageSize", pageSize); + rsVo.pageSize = queryVo.pageSize ; + rsVo.pageCurr = queryVo.pageCurr ; // 璁$畻绗﹀悎鏉′欢鐨勮褰曟暟 - Integer itemTotal = prFlowmeterMapper.getRecordCountOfFlowMeterByOthers(params); rsVo.calculateAndSet(itemTotal.longValue(), params); rsVo.obj = prFlowmeterMapper.getFlowMeters(params); return rsVo ; } + + /** + * 寰楀埌鍏ㄩ儴娴侀噺璁� + * @return + */ + public List<PrFlowmeter> getFlowMeterAll(){ + List<PrFlowmeter> all = prFlowmeterMapper.selectAll(); + return all; + } + + /** + * 缁欐祦閲忚琛ㄥ姞鐩戞祴绔橧D澶栭敭 + * @param + * @return + */ + public Integer flowmeterAddMonId(PrFlowmeter record){ + return prFlowmeterMapper.flowmeterAddMonId(record); + } } -- Gitblit v1.8.0