| | |
| | | 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; |
| | |
| | | private IApiMallMemberService mallMemberService; |
| | | @Autowired |
| | | private MallAgentRecordMapper mallAgentRecordMapper; |
| | | @Autowired |
| | | private AgentProducer agentProducer; |
| | | |
| | | @Autowired |
| | | private IXcxPayService iXcxPayService; |
| | |
| | | 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); |
| | |
| | | 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()); |