From 5447abaae60e4d8d98c52c952a10d9c4ad6c06d6 Mon Sep 17 00:00:00 2001
From: Administrator <zhubaomin>
Date: 星期四, 27 六月 2024 09:19:20 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

---
 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java |  132 ++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 115 insertions(+), 17 deletions(-)

diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java
index 6def3c1..773046e 100644
--- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java
@@ -31,10 +31,6 @@
     @Autowired
     private RmAlarmStateHistoryMapper rmAlarmStateHistoryMapperDao ;//鎺у埗鍣ㄥ巻鍙叉姤璀﹀拰鐘舵�丏AO
     @Autowired
-    private RmAutoReportLastMapper rmAutoReportLastMapperDao ;//鎺у埗鍣ㄦ渶鏂颁笂鎶ユ暟鎹瓺AO
-    @Autowired
-    private RmAutoReportHistoryMapper rmAutoReportHistoryMapperDao ;//鎺у埗鍣ㄥ巻鍙蹭笂鎶ユ暟鎹瓺AO
-    @Autowired
     private RmOpenCloseValveLastMapper rmOpenCloseValveLastMapperDao ;//鎺у埗鍣ㄦ渶鏂板紑鍏抽榾涓婃姤鏁版嵁DAO
     @Autowired
     private RmOpenCloseValveHistoryMapper rmOpenCloseValveHistoryMapperDao ;//鎺у埗鍣ㄥ巻鍙插紑鍏抽榾涓婃姤鏁版嵁DAO
@@ -50,6 +46,21 @@
     private RmCommandHistoryMapper rmCommandHistoryDao ;//杩滅▼鍛戒护鏃ュ織鐩稿叧
     @Autowired
     private SeVirtualCardMapper seVirtualCardDao ;//铏氭嫙鍗$浉鍏�
+
+    @Autowired
+    private RmTimingReportHistoryMapper rmTimingReportHistoryDao; // 瀹氱偣涓婃姤鍘嗗彶鏁版嵁DAO
+    @Autowired
+    private RmTimingReportLastMapper rmTimingReportLastDao; // 瀹氱偣涓婃姤鏈�鏂版暟鎹瓺AO
+
+    @Autowired
+    private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 鏁寸偣涓婃姤鍘嗗彶鏁版嵁DAO
+    @Autowired
+    private RmOnHourReportLastMapper rmOnHourReportLastDao; // 鏁寸偣涓婃姤鏈�鏂版暟鎹瓺AO
+
+    @Autowired
+    private RmOpenCloseHistoryMapper rmOpenCloseHistoryDao;
+    @Autowired
+    private RmOpenCloseLastMapper rmOpenCloseLastDao;
 
     //@Autowired
     //@Lazy
@@ -156,48 +167,97 @@
 
     /////////////////////////////////////////////////
     //
-    // 涓诲姩涓婃姤鏁版嵁鍔熻兘
+    // 瀹氱偣鎶ユ暟鎹姛鑳�(鍙湪鐜嬫睙娴风殑鍗忚鏈夋鏁版嵁)
     //
     ////////////////////////////////////////////////
+
     /**
-     * 寰楀埌鎺у埗鍣ㄤ笂鎶ユ暟鎹渶鏂拌褰�
+     * 淇濆瓨鎺у埗鍣ㄥ畾鐐逛笂鎶ュ巻鍙叉暟鎹�
+     * @param po
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void saveRmTimingReportHistory(RmTimingReportHistory po){
+        this.rmTimingReportHistoryDao.insert(po);
+    }
+
+    /**
+     * 鏍规嵁闃�鎺у櫒鍦板潃鑾峰彇瀹氱偣涓婃姤鏈�鏂版暟鎹�
      * @param rtuAddr
      * @return
      */
-    public RmAutoReportLast getRmAutoReportLast(String rtuAddr){
-        List<RmAutoReportLast> list = rmAutoReportLastMapperDao.selectByRtuAddr(rtuAddr) ;
+    @Transactional(rollbackFor = Exception.class)
+    public RmTimingReportLast getRmTimingReportLast(String rtuAddr) {
+        List<RmTimingReportLast> list = this.rmTimingReportLastDao.getRmTimingReportLast(rtuAddr) ;
         if(list != null && list.size() > 0){
             return list.get(0) ;
         }
         return null ;
     }
+
     /**
-     * 淇濆瓨鎺у埗鍣ㄤ笂鎶ユ暟鎹渶鏂拌褰�
+     * 淇濆瓨鎺у埗鍣ㄥ畾鐐逛笂鎶ユ渶鏂版暟鎹�
      * @param po
      */
     @Transactional(rollbackFor = Exception.class)
-    public void saveRmAutoReportLast(RmAutoReportLast po){
-        this.rmAutoReportLastMapperDao.insert(po) ;
+    public void saveRmTimingReportLast(RmTimingReportLast po) {
+        this.rmTimingReportLastDao.insert(po);
     }
+
     /**
-     * 淇濆瓨鎺у埗鍣ㄤ笂鎶ユ暟鎹渶鏂拌褰�
+     * 淇濆瓨鎺у埗鍣ㄥ畾鐐逛笂鎶ョ姜琛屾暟鎹�
      * @param po
      */
     @Transactional(rollbackFor = Exception.class)
-    public void updateRmAutoReportLast(RmAutoReportLast po){
-        this.rmAutoReportLastMapperDao.updateByPrimaryKeySelective(po) ;
+    public void updateRmTimingReportLast(RmTimingReportLast po) {
+        this.rmTimingReportLastDao.updateByPrimaryKeySelective(po);
     }
+
+    /////////////////////////////////////////////////
+    //
+    // 鏁寸偣涓婃姤瀹炴椂鏁版嵁鍔熻兘(鍙湪闈虫�荤殑鍗忚鏈夋鏁版嵁)
+    //
+    ////////////////////////////////////////////////
+
     /**
-     * 淇濆瓨鎺у埗鍣ㄤ笂鎶ユ暟鎹巻鍙茶褰�
+     * 淇濆瓨鎺у埗鍣ㄦ暣鐐逛笂鎶ュ巻鍙叉暟鎹�
      * @param po
      */
     @Transactional(rollbackFor = Exception.class)
-    public void saveRmAutoReportHistory(RmAutoReportHistory po){
-        this.rmAutoReportHistoryMapperDao.insert(po) ;
+    public void saveRmOnHourReportHistory(RmOnHourReportHistory po){
+        this.rmOnHourReportHistoryDao.insert(po);
     }
 
+    /**
+     * 鏍规嵁闃�鎺у櫒鍦板潃鑾峰彇鏁寸偣涓婃姤鏈�鏂版暟鎹�
+     * @param rtuAddr
+     * @return
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public RmOnHourReportLast getRmOnHourReportLast(String rtuAddr) {
+        List<RmOnHourReportLast> list = this.rmOnHourReportLastDao.getRmOnHourReportLast(rtuAddr) ;
+        if(list != null && list.size() > 0){
+            return list.get(0) ;
+        }
+        return null ;
+    }
 
+    /**
+     * 淇濆瓨鎺у埗鍣ㄦ暣鐐逛笂鎶ユ渶鏂版暟鎹�
+     * @param po
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void saveRmOnHourReportLast(RmOnHourReportLast po) {
+        this.rmOnHourReportLastDao.insert(po);
+    }
 
+    /**
+     * 淇濆瓨鎺у埗鍣ㄦ暣鐐逛笂鎶ョ姜琛屾暟鎹�
+     * @param po
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void updateRmOnHourReportLast(RmOnHourReportLast po) {
+        this.rmOnHourReportLastDao.updateByPrimaryKeySelective(po);
+    }
 
     /////////////////////////////////////////////////
     //
@@ -259,7 +319,45 @@
         this.rmOpenCloseValveHistoryMapperDao.updateByPrimaryKeySelective(po) ;
     }
 
+    /**
+     * 淇濆瓨鎺у埗鍣ㄥ紑鍏抽榾涓婃姤鏁版嵁鏈�鏂拌褰�(202404)
+     * @param po
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void saveRmOpenCloseLast(RmOpenCloseLast po){
+        this.rmOpenCloseLastDao.insert(po) ;
+    }
 
+    /**
+     * 淇濆瓨鎺у埗鍣ㄥ紑鍏抽榾涓婃姤鏁版嵁鍘嗗彶璁板綍(202404)
+     * @param po
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void saveRmOpenCloseHistory(RmOpenCloseHistory po){
+        this.rmOpenCloseHistoryDao.insert(po) ;
+    }
+
+    /**
+     * 寰楀埌鎺у埗鍣ㄥ紑鍏抽榾涓婃姤鏁版嵁鏈�鏂拌褰�(202404)
+     * @param rtuAddr
+     * @return
+     */
+    public RmOpenCloseLast getRmOpenCloseLast(String rtuAddr){
+        List<RmOpenCloseLast> list = rmOpenCloseLastDao.getRmOpenCloseReportLast(rtuAddr);
+        if(list != null && list.size() > 0){
+            return list.get(0) ;
+        }
+        return null ;
+    }
+
+    /**
+     * 淇濆瓨鎺у埗鍣ㄥ紑鍏抽榾涓婃姤鏁版嵁鏈�鏂拌褰�(202404)
+     * @param po
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void updateRmOpenCloseLast(RmOpenCloseLast po){
+        this.rmOpenCloseLastDao.updateByPrimaryKeySelective(po);
+    }
 
     /////////////////////////////////////////////////
     //

--
Gitblit v1.8.0