From 1c74985186d67d3aba94ae3679bee573449b986d Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 20 Jul 2023 14:51:21 +0800
Subject: [PATCH] 支付返利,微信余额支付会有返利。发卷,赠送积分逻辑

---
 src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java |   10 ++++++++++
 1 files changed, 10 insertions(+), 0 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 9e68dfc..8cd6c24 100644
--- a/src/main/java/cc/mrbird/febs/pay/controller/XcxPayController.java
+++ b/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;
@@ -314,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());

--
Gitblit v1.9.1