From 6184ec366a86d7c9c6884ce868be5e706a57b0e9 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Sat, 08 Apr 2023 15:30:59 +0800
Subject: [PATCH] 设置内转开关

---
 src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java |   18 +++++++++++++-----
 1 files changed, 13 insertions(+), 5 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
index 7817f85..a356f36 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
@@ -189,6 +189,7 @@
                 amountTC,
                 "score",
                 MoneyFlowTypeEnum.BUY_SET_MEAL_PERK.getValue(),
+                memberId,
                 FlowTypeEnum.SCORE.getValue(),
                 orderNo);
 
@@ -206,6 +207,7 @@
                     amountTC,
                     "balance",
                     MoneyFlowTypeEnum.DIRECT_CASH_PERK.getValue(),
+                    memberId,
                     FlowTypeEnum.BALANCE.getValue(),
                     orderNo);
 
@@ -214,6 +216,7 @@
                     amountTC,
                     "score",
                     MoneyFlowTypeEnum.DIRECT_SCORE_PERK.getValue(),
+                    memberId,
                     FlowTypeEnum.SCORE.getValue(),
                     orderNo);
         }
@@ -228,6 +231,7 @@
                     amountTC,
                     "balance",
                     MoneyFlowTypeEnum.DIRECTOR_CASH_PERK.getValue(),
+                    memberId,
                     FlowTypeEnum.BALANCE.getValue(),
                     orderNo);
         }
@@ -242,6 +246,7 @@
                     amountTC,
                     "balance",
                     MoneyFlowTypeEnum.PARTNER_CASH_PERK.getValue(),
+                    memberId,
                     FlowTypeEnum.BALANCE.getValue(),
                     orderNo);
         }
@@ -310,6 +315,7 @@
                                     teamPerkMemberId,
                                     "balance",
                                     MoneyFlowTypeEnum.AGENT_CASH_PERK.getValue(),
+                                    memberId,
                                     FlowTypeEnum.BALANCE.getValue(),
                                     orderNo);
                         }
@@ -318,6 +324,7 @@
                                     teamPerkMemberId,
                                     "score",
                                     MoneyFlowTypeEnum.AGENT_SCORE_PERK.getValue(),
+                                    memberId,
                                     FlowTypeEnum.SCORE.getValue(),
                                     orderNo);
                         }
@@ -397,7 +404,7 @@
      * @param flowType 流水分类
      * @param orderNo 订单编号
      */
-    private void perkMember(Long memberId,PerkEnum perkEnum,BigDecimal amountTC,String walletField,int type,int flowType,String orderNo){
+    private void perkMember(Long memberId,PerkEnum perkEnum,BigDecimal amountTC,String walletField,int type,Long rtMemberId,int flowType,String orderNo){
         DataDictionaryCustom perkEnumDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                 perkEnum.getType(),
                 perkEnum.getCode());
@@ -414,7 +421,7 @@
                 perkEnumDicPercentPerk = perkEnumDicPercentPerk.divide(poolScorePrice, 2 ,BigDecimal.ROUND_DOWN);
             }
             if(perkEnumDicPercentPerk.compareTo(BigDecimal.ZERO) > 0){
-                addWalletInfoAndMoneyFlow(perkEnumDicPercentPerk,memberId,walletField,type,flowType,orderNo);
+                addWalletInfoAndMoneyFlow(perkEnumDicPercentPerk,memberId,walletField,type,rtMemberId,flowType,orderNo);
             }
         }
     }
@@ -428,7 +435,7 @@
      * @param flowType
      * @param orderNo
      */
-    private void addWalletInfoAndMoneyFlow(BigDecimal amount,Long memberId,String walletField,int type,int flowType,String orderNo){
+    private void addWalletInfoAndMoneyFlow(BigDecimal amount,Long memberId,String walletField,int type,Long rtMemberId,int flowType,String orderNo){
         //增加
         iApiMallMemberWalletService.add(amount,memberId,walletField);
         //增加一个流水记录
@@ -437,6 +444,7 @@
                 amount,
                 type,
                 orderNo,
+                rtMemberId,
                 flowType,
                 AppContants.IS_RETURN_YES);
     }
@@ -451,7 +459,7 @@
      * @param flowType  流水分类
      * @param orderNo   订单编号
      */
-    private void perkMembersLevel(List<MallMember> mallMembers,PerkEnum perkEnum,BigDecimal amountTC,String walletField,int type,int flowType,String orderNo){
+    private void perkMembersLevel(List<MallMember> mallMembers,PerkEnum perkEnum,BigDecimal amountTC,String walletField,int type,Long rtMemberId,int flowType,String orderNo){
         DataDictionaryCustom perkEnumDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                 perkEnum.getType(),
                 perkEnum.getCode());
@@ -464,7 +472,7 @@
             if(perkEnumDicPercentPerk.compareTo(BigDecimal.ZERO) > 0){
                 for(MallMember mallMember : mallMembers){
                     Long memberId = mallMember.getId();
-                    addWalletInfoAndMoneyFlow(perkEnumDicPercentPerk,memberId,walletField,type,flowType,orderNo);
+                    addWalletInfoAndMoneyFlow(perkEnumDicPercentPerk,memberId,walletField,type,rtMemberId,flowType,orderNo);
                 }
             }
         }

--
Gitblit v1.9.1