From baff68fa55ed3212f618330e18cc5735b1caf57f Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期六, 12 十月 2024 10:06:37 +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/p206V1_0_0/TkDealIntakeAmountDay.java |   22 ++++++++++++----------
 1 files changed, 12 insertions(+), 10 deletions(-)

diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealIntakeAmountDay.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealIntakeAmountDay.java
index 0f1af39..290a31e 100644
--- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealIntakeAmountDay.java
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealIntakeAmountDay.java
@@ -107,7 +107,6 @@
                         poLast = this.updateRmIntakeAmountLastByControllerChange(poLast, controller, rtuAddr, dV1_0_1, dataVo);
                         this.newAndSaveHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataVo, poLast);
                     }
-                    sv.saveRmIntakeAmountLast(poLast);
                 }else{
                     //鏈洿鎹㈡帶鍒跺櫒
                     if(DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt).equals(poLast.dt)){
@@ -123,12 +122,10 @@
                             poHistory = this.updateRmIntakeAmountBySameDateNewData(poHistory, poLast, controller, rtuAddr, dV1_0_1, dataVo);
                             sv.updateRmIntakeAmountDay(poHistory);
                         }
-                        sv.saveRmIntakeAmountLast(poLast);
                     }else if(DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt).after(poLast.dt)){
                         //鏂扮殑鏃ユ湡
                         poLast = this.updateRmIntakeAmountLastByNewDateNewData(poLast, controller, rtuAddr, dV1_0_1, dataVo);
                         this.newAndSaveHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataVo, poLast);
-                        sv.saveRmIntakeAmountLast(poLast);
                     }else{
                         //杩欑鎯呭喌涓嶅瓨鍦�
                     }
@@ -245,9 +242,13 @@
         //lastPo.dt = DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt);//鏃ユ湡娌″彉
         lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt);
         lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt);
-        Double difference = cdData.totalAmount - lastPo.totalAmountLast ;
-        if(difference > 0){
-            lastPo.amount = difference;
+        Double added = cdData.totalAmount - lastPo.totalAmountLast ;
+        if(added > 0){
+            if(lastPo.amount == null){
+                lastPo.amount = added ;
+            }else{
+                lastPo.amount += added ;
+            }
         }else{
             //po.amount = po.amount ; //鏃ョ疮璁″彇姘撮噺涓嶅彉
         }
@@ -271,9 +272,10 @@
         lastPo.dt = DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt);//鏃ユ湡鍙樹簡
         lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt);
         lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt);
-        Double difference = cdData.totalAmount - lastPo.totalAmountLast ;
-        if(difference > 0){
-            lastPo.amount = difference;
+        Double added = cdData.totalAmount - lastPo.totalAmountLast ;
+        if(added > 0){
+            //鏂扮殑涓�澶╃殑澶勭悊鏂瑰紡涓庡悓涓�澶╃殑澶勭悊鏂瑰紡涓嶄竴鏍�
+            lastPo.amount = added;
         }else{
             lastPo.amount = 0.0D; //鏃ョ疮璁℃按閲忓綊0
         }
@@ -321,7 +323,7 @@
         po.dtLast = lastPo.dtLast;
         po.rtuDtLast = lastPo.rtuDtLast;
 
-        po.amount = lastPo.amount ;
+        po.amount = lastPo.amount ;//姝ゆ椂lastPo.amount宸茬粡澧炲姞涓婁簡澧為噺
         po.totalAmountLast = lastPo.totalAmountLast ;
 
         return po ;

--
Gitblit v1.8.0