From dbb4ac17ff70578662af99c6b1772b5c0641d005 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期三, 20 十一月 2024 18:48:23 +0800
Subject: [PATCH] 1、基于Timer实现定时执行的任务,并在满足条件下结束定时任务,为此实现抽象类TimerTaskJob类,并在UpgradeManager类中应用; 2、TreadJob类由TimerTaskJob替换,弃用TreadJob类。

---
 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowmeterSv.java |   21 +++++++++++++++++++--
 1 files changed, 19 insertions(+), 2 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 3dff9b3..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
@@ -60,16 +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<>() ;
         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