xiaoyong931011
2023-07-20 db0196ae6db238f8e387d24c9bbd4203ba834611
src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java
@@ -21,6 +21,7 @@
import cc.mrbird.febs.pay.util.Signature;
import cc.mrbird.febs.pay.util.Util;
import cc.mrbird.febs.pay.util.WechatConfigure;
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSONObject;
@@ -72,6 +73,8 @@
    private IApiMallMemberService mallMemberService;
    @Autowired
    private MallAgentRecordMapper mallAgentRecordMapper;
    @Autowired
    private AgentProducer agentProducer;
    @Autowired
    private IXcxPayService iXcxPayService;
@@ -139,8 +142,9 @@
                            log.debug("检查支付金额payMoney={},mallMoneyFlow.getPayMoney()={}", payMoney, mallMoneyFlow.getAmount());
                            //合伙人申请的充值,要更新会员状态为FIRST_LEVEL
                            if(2 == type){
                                log.info("微信充值回调" + agentApplyId);
                                MallAgentRecord mallAgentRecord = mallAgentRecordMapper.selectById(agentApplyId);
                                mallMemberService.updateMemberAgent(memberId,mallAgentRecord.getAgentLevel());
                                mallMemberService.updateMemberAgent(agentApplyId,mallAgentRecord.getAgentLevel());
                            }
                            memberWalletService.addBalance(payMoney,memberId);
                            mallMoneyFlow.setStatus(2);
@@ -313,6 +317,13 @@
                                    FlowTypeEnum.WECHAT.getValue(),
                                    "微信支付",
                                    2);
                            StringBuffer stringBuffer = new StringBuffer();
                            stringBuffer.append(order.getId().toString());
                            stringBuffer.append("@");
                            stringBuffer.append(order.getAmount().toString());
                            agentProducer.sendOrderGetMsg(stringBuffer.toString());
                            threadResult.success().message("支付成功");
                        } else {
                            log.info("订单状态不为待付款,order status=", order.getStatus());