From 18f9dc6d0f15cad4a74e68fcf87b1a9aa83b5e66 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期四, 18 七月 2024 14:28:28 +0800
Subject: [PATCH] 实现协议中各种命令结果日志数据库永久更新保存功能

---
 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealClientAmountDay.java |   26 ++++++++++++++++++++------
 1 files changed, 20 insertions(+), 6 deletions(-)

diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealClientAmountDay.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealClientAmountDay.java
index 5c1abe9..1752409 100644
--- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealClientAmountDay.java
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealClientAmountDay.java
@@ -108,12 +108,10 @@
                         poHistory = this.updateRmClientAmountBySameDateNewData(clientVo, poHistory, poLast, dV1_0_1, cdData);
                         sv.updateRmClientAmountDay(poHistory);
                     }
-                    sv.saveRmClientAmountLast(poLast);
                 }else if(upYmd.after(poLast.dt)){
                     //鏂扮殑鏃ユ湡
                     poLast = this.updateRmClientAmountLastByNewDateNewData(clientVo, dV1_0_1, cdData, poLast);
                     this.newAndSaveHistoryDataDeal(sv, clientVo, dV1_0_1, cdData, poLast);
-                    sv.saveRmClientAmountLast(poLast);
                 }else{
                     //杩欑鎯呭喌涓嶅瓨鍦�
                 }
@@ -170,8 +168,16 @@
         RmClientAmountDay poHistory = new RmClientAmountDay() ;
         poHistory.clientId = clientVo.getId();
         if(lastPo != null){
-            poHistory.amount += lastPo.amount ;
-            poHistory.money += lastPo.money ;
+            if(poHistory.amount != null){
+                poHistory.amount += lastPo.amount ;
+            }else{
+                poHistory.amount = lastPo.amount ;
+            }
+            if(poHistory.money != null){
+                poHistory.money += lastPo.money ;
+            }else{
+                poHistory.money = lastPo.money ;
+            }
             poHistory.dt = lastPo.dt ;
             poHistory.openDtLast = lastPo.openDtLast ;
             poHistory.closeDtLast = lastPo.closeDtLast ;
@@ -278,8 +284,16 @@
      */
     private RmClientAmountDay updateRmClientAmountBySameDateNewData(SeClient clientVo, RmClientAmountDay poHistory, RmClientAmountDayLast lastPo, DataV1_0_1 dV1_0_1, DataCd83CloseVo cdData)throws Exception {
         poHistory.clientId = clientVo.getId();
-        poHistory.amount += lastPo.amount ;
-        poHistory.money += lastPo.money ;
+        if(poHistory.amount != null){
+            poHistory.amount += cdData.thisAmount ;
+        }else{
+            poHistory.amount = cdData.thisAmount ;
+        }
+        if(poHistory.money != null){
+            poHistory.money += cdData.thisMoney ;
+        }else{
+            poHistory.money = cdData.thisMoney ;
+        }
         poHistory.dt = lastPo.dt ;
         poHistory.openDtLast = lastPo.openDtLast ;
         poHistory.closeDtLast = lastPo.closeDtLast ;

--
Gitblit v1.8.0