From 0b3393b2485ef1905f44356e26f5cc1a48be9a83 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Sun, 21 May 2023 19:52:09 +0800
Subject: [PATCH] 正式环境

---
 src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java |   14 ++++++++------
 1 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java b/src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java
index c7f4cd6..9e68dfc 100644
--- a/src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java
+++ b/src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java
@@ -6,10 +6,7 @@
 import cc.mrbird.febs.common.utils.RedisUtils;
 import cc.mrbird.febs.common.utils.SpringContextHolder;
 import cc.mrbird.febs.mall.dto.RechargeWalletMessageSendDto;
-import cc.mrbird.febs.mall.entity.DataDictionaryCustom;
-import cc.mrbird.febs.mall.entity.MallMemberWallet;
-import cc.mrbird.febs.mall.entity.MallMoneyFlow;
-import cc.mrbird.febs.mall.entity.MallOrderInfo;
+import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.*;
 import cc.mrbird.febs.mall.service.IApiMallMemberService;
 import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
@@ -73,6 +70,8 @@
     private IApiMallMemberWalletService memberWalletService;
     @Autowired
     private IApiMallMemberService mallMemberService;
+    @Autowired
+    private MallAgentRecordMapper mallAgentRecordMapper;
 
     @Autowired
     private IXcxPayService iXcxPayService;
@@ -115,6 +114,7 @@
                 String rechargeNo = (String) jsonObject.get("rechargeNo");
                 Integer type = (Integer) jsonObject.get("type");
                 Long memberId = Long.parseLong(jsonObject.get("memberId").toString());
+                Long agentApplyId = Long.parseLong(jsonObject.get("agentApplyId").toString());
                 // 检验订单状态
                 MallMoneyFlow mallMoneyFlow = mallMoneyFlowMapper.selectOneByOrderNoAndMemberId(rechargeNo,memberId);
                 // 校验签名
@@ -139,7 +139,9 @@
                             log.debug("检查支付金额payMoney={},mallMoneyFlow.getPayMoney()={}", payMoney, mallMoneyFlow.getAmount());
                             //合伙人申请的充值,要更新会员状态为FIRST_LEVEL
                             if(2 == type){
-                                mallMemberService.updateMemberAgent(memberId);
+                                log.info("微信充值回调" + agentApplyId);
+                                MallAgentRecord mallAgentRecord = mallAgentRecordMapper.selectById(agentApplyId);
+                                mallMemberService.updateMemberAgent(agentApplyId,mallAgentRecord.getAgentLevel());
                             }
                             memberWalletService.addBalance(payMoney,memberId);
                             mallMoneyFlow.setStatus(2);
@@ -306,7 +308,7 @@
 
                             mallMoneyFlowService.addMoneyFlow(
                                     order.getMemberId(),
-                                    order.getAmount(),
+                                    order.getAmount().negate(),
                                     MoneyFlowTypeEnum.WECHAT_PAY.getValue(),
                                     order.getOrderNo(),
                                     FlowTypeEnum.WECHAT.getValue(),

--
Gitblit v1.9.1