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 { 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 + + 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} + ) +