From a59377e20d2a61a9eb19487a21818872cf28a704 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=9F=A9=E9=B9=8F=E8=BE=89?= <18322780655@163.com>
Date: Thu, 30 May 2024 09:17:04 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=AE=A2=E5=8D=95=E4=BB=98?=
 =?UTF-8?q?=E6=AC=BE=E6=95=B0=E6=8D=AE=E7=BB=9F=E8=AE=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../system/cashierservice/service/PayService.java | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java b/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java
index ec61c9d..0024091 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java
@@ -1060,6 +1060,13 @@ public class PayService {
             flow.setCreateTime(new Date());
             tbShopUserFlowMapper.insert(flow);
 
+
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("shopId", memberIn.getShopId());
+            jsonObject.put("type", "wxMemberIn");
+            jsonObject.put("amount",memberIn.getAmount());
+            producer.putOrderCollect(jsonObject.toJSONString());
+
         }
         return "success";
     }
@@ -1130,8 +1137,14 @@ public class PayService {
             flow.setBalance(tbShopUser.getAmount());
             flow.setCreateTime(new Date());
             tbShopUserFlowMapper.insert(flow);
-
         }
+
+
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("shopId", memberIn.getShopId());
+        jsonObject.put("type", "wxMemberIn");
+        jsonObject.put("amount",memberIn.getAmount());
+        producer.putOrderCollect(jsonObject.toJSONString());
         return "SUCCESS";
     }