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";
     }