From 41eda4e79e6364178f9b14aeb13588f722d32322 Mon Sep 17 00:00:00 2001
From: sangelxiu1 <15781802@163.com>
Date: Tue, 21 Oct 2025 14:02:08 +0800
Subject: [PATCH] =?UTF-8?q?##=20Opt=20-=20=E8=A1=A5=E5=81=BF=E7=BB=93?=
 =?UTF-8?q?=E4=BD=99=E9=87=91=E9=A2=9D=E8=AE=A1=E7=AE=97=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../achieve/mapper/CuMemberAchieveMapper.java | 10 ++++++++++
 .../impl/CuMemberAchieveServiceImpl.java      |  1 +
 .../member/achieve/CuMemberAchieveMapper.xml  | 19 +++++++++++++++++++
 3 files changed, 30 insertions(+)

diff --git a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/mapper/CuMemberAchieveMapper.java b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/mapper/CuMemberAchieveMapper.java
index 7f992a8f..925561d6 100644
--- a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/mapper/CuMemberAchieveMapper.java
+++ b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/mapper/CuMemberAchieveMapper.java
@@ -156,6 +156,16 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
     void chargeBackSaOrder(@Param("targetTable") String targetTable, @Param("sourceTable") String sourceTable,
                            @Param("period") Integer period, @Param("achieve") MemberAchieveParam memberAchieveParam);
 
+    /**
+     * 补偿结余金额
+     * @param targetTable
+     * @param sourceTable
+     * @param period
+     * @param memberAchieveParam
+     */
+    void compensationBalanceAmount(@Param("targetTable") String targetTable, @Param("sourceTable") String sourceTable,
+                           @Param("period") Integer period, @Param("achieve") MemberAchieveParam memberAchieveParam);
+
     /**
      * 根据每日日业绩开始更新会员业绩 新增业绩、累计业绩、新増金额、累计金额
      *
diff --git a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/service/impl/CuMemberAchieveServiceImpl.java b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/service/impl/CuMemberAchieveServiceImpl.java
index 7594f7e9..55bbe23e 100644
--- a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/service/impl/CuMemberAchieveServiceImpl.java
+++ b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/service/impl/CuMemberAchieveServiceImpl.java
@@ -185,6 +185,7 @@ public class CuMemberAchieveServiceImpl extends ServiceImpl<CuMemberAchieveMappe
             int settlePeriod = cuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(settleDate).getPkId();
             String targetTable = TableNameConstants.CU_MEMBER_SETTLE + settlePeriod;
             baseMapper.chargeBackSaOrder(targetTable, sourceTable, period, cuMemberAchieve);
+            baseMapper.compensationBalanceAmount(targetTable, sourceTable, period, cuMemberAchieve);
         }
         return Boolean.TRUE;
     }
diff --git a/bd-business/bd-business-bonus/src/main/resources/mapper/member/achieve/CuMemberAchieveMapper.xml b/bd-business/bd-business-bonus/src/main/resources/mapper/member/achieve/CuMemberAchieveMapper.xml
index 4990c643..a3dccb76 100644
--- a/bd-business/bd-business-bonus/src/main/resources/mapper/member/achieve/CuMemberAchieveMapper.xml
+++ b/bd-business/bd-business-bonus/src/main/resources/mapper/member/achieve/CuMemberAchieveMapper.xml
@@ -1011,6 +1011,25 @@
                     a.a_balance = b.a_balance,a.b_balance = b.b_balance,
                     a.min_achieve = b.min_achieve,a.round = b.round,a.second = b.second
     </update>
+    <update id="compensationBalanceAmount">
+        UPDATE ${targetTable} t
+        SET A_BALANCE = CASE
+                            WHEN t.a_sum_pv > t.b_sum_pv THEN t.a_sum_pv - t.b_sum_pv
+                            ELSE 0
+            END,
+            B_BALANCE = CASE
+                            WHEN t.b_sum_pv > t.a_sum_pv THEN t.b_sum_pv - t.a_sum_pv
+                            ELSE 0
+                END
+        WHERE t.period = 14
+          AND t.pk_member IN (
+            SELECT pk_member
+                FROM ${targetTable}
+                WHERE period = #{period}
+            START WITH pk_member = 20768
+            CONNECT BY PRIOR pk_member = #{achieve.pkMember}
+        )
+    </update>
 
     <select id="queryCuMemberAchieveByPkMember" resultMap="CuMemberAchieve">
         SELECT PK_MEMBER,