From 14bb69110fc779feb53c0f2fe4623a24467d4422 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 23 Sep 2022 14:54:12 +0800
Subject: [PATCH] 20220902

---
 src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java |   38 +++++++++++++++++++++++++-------------
 1 files changed, 25 insertions(+), 13 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 88351ab..dcc08f2 100644
--- a/src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java
+++ b/src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java
@@ -109,7 +109,7 @@
                 attrStr = data.getAttach();
                 JSONObject jsonObject = JSONUtil.parseObj(attrStr);
                 String rechargeNo = (String) jsonObject.get("rechargeNo");
-                Long memberId = (Long) jsonObject.get("memberId");
+                Long memberId = Long.parseLong(jsonObject.get("memberId").toString());
                 // 检验订单状态
                 MallMoneyFlow mallMoneyFlow = mallMoneyFlowMapper.selectOneByOrderNoAndMemberId(rechargeNo,memberId);
                 // 校验签名
@@ -131,19 +131,22 @@
                                 RoundingMode.HALF_UP);
 
                         if (ObjectUtil.isNotEmpty(mallMoneyFlow)) {
-                                log.debug("检查支付金额payMoney={},mallMoneyFlow.getPayMoney()={}", payMoney, mallMoneyFlow.getAmount());
-                                memberWalletService.addBalance(payMoney,memberId);
-                                RechargeWalletMessageSendDto rechargeWalletMessageSendDto = new RechargeWalletMessageSendDto();
-                                rechargeWalletMessageSendDto.setRechargeNo(rechargeNo);
-                                rechargeWalletMessageSendDto.setRechargeAmount(payMoney.toString());
+                            log.debug("检查支付金额payMoney={},mallMoneyFlow.getPayMoney()={}", payMoney, mallMoneyFlow.getAmount());
+                            memberWalletService.addBalance(payMoney,memberId);
+                            mallMoneyFlow.setStatus(2);
+                            mallMoneyFlowMapper.updateById(mallMoneyFlow);
 
-                                MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
-                                rechargeWalletMessageSendDto.setBalance(mallMemberWallet.getBalance().toString());
-                                rechargeWalletMessageSendDto.setCreateTime(DateUtil.now());
-                                rechargeWalletMessageSendDto.setOpenId(mallMemberMapper.selectById(memberId).getOpenId());
-                                DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WX_TEMPLATE_ID_TWO.getType(), DataDictionaryEnum.WX_TEMPLATE_ID_TWO.getCode());
-                                rechargeWalletMessageSendDto.setTemplateId(dataDictionaryCustom.getValue());
-                                iXcxPayService.rechargeWalletMessageSend(rechargeWalletMessageSendDto);
+                            RechargeWalletMessageSendDto rechargeWalletMessageSendDto = new RechargeWalletMessageSendDto();
+                            rechargeWalletMessageSendDto.setRechargeNo(rechargeNo);
+                            rechargeWalletMessageSendDto.setRechargeAmount(payMoney.toString());
+
+                            MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
+                            rechargeWalletMessageSendDto.setBalance(mallMemberWallet.getBalance().toString());
+                            rechargeWalletMessageSendDto.setCreateTime(DateUtil.now());
+                            rechargeWalletMessageSendDto.setOpenId(mallMemberMapper.selectById(memberId).getOpenId());
+                            DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WX_TEMPLATE_ID_TWO.getType(), DataDictionaryEnum.WX_TEMPLATE_ID_TWO.getCode());
+                            rechargeWalletMessageSendDto.setTemplateId(dataDictionaryCustom.getValue());
+                            iXcxPayService.rechargeWalletMessageSend(rechargeWalletMessageSendDto);
                             threadResult.success().message("充值成功");
                         } else {
                             log.info("充值失败", attrStr);
@@ -175,6 +178,15 @@
         return;
 
     }
+
+//    public static void main(String[] args) {
+//        String attach="{'rechargeNo':CZ_2022083117160259880,'memberId':47}";
+//        JSONObject jsonObject = JSONUtil.parseObj(attach);
+//        String rechargeNo = (String) jsonObject.get("rechargeNo");
+//        Long memberId = Long.parseLong(jsonObject.get("memberId").toString());
+//        System.out.println(memberId);
+//        System.out.println(rechargeNo);
+//    }
     /**
      * 微信支付回调接口
      */

--
Gitblit v1.9.1