From 9bb60335b6f7b48e2da54d78212b582d2ecc0b82 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=89=9B=E5=8F=89=E9=97=AA=E9=97=AA?= <18322780655@163.com>
Date: Wed, 28 Aug 2024 17:07:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=BC=9A=E5=91=98=E4=BD=99?=
 =?UTF-8?q?=E9=A2=9D=E5=8F=98=E5=8A=A8=E9=80=9A=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../rabbit/RabbitConstants.java               |  6 ++++
 .../cashierservice/rabbit/RabbitProducer.java |  9 ++++++
 .../cashierservice/service/PayService.java    | 28 +++++++++++++++++++
 3 files changed, 43 insertions(+)

diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConstants.java b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConstants.java
index 01a8b62..433333a 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConstants.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConstants.java
@@ -62,4 +62,10 @@ public interface RabbitConstants {
 	// 库存记录交换机
     String EXCHANGE_STOCK_RECORD = "exchange.stock.record";
 	String ROUTING_STOCK_RECORD_SALE = "routing.stock.record.sale";
+
+
+	public static final String BALANCE_PUT="balance_put";
+	public static final String BALANCE_QUEUE_PUT="balance_queue_put";
+
+	public static final String BALANCE_ROUTINGKEY_PUT="balance_routingkey_put";
 }
diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitProducer.java b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitProducer.java
index f0d67ac..2155fcd 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitProducer.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitProducer.java
@@ -58,6 +58,15 @@ public class RabbitProducer implements RabbitTemplate.ConfirmCallback  {
         rabbitTemplate.convertAndSend(RabbitConstants.CONS_MSG_COLLECT_PUT, RabbitConstants.CONS_MSG_COLLECT_ROUTINGKEY_PUT, content, correlationId);
     }
 
+
+
+    public void balance(String content){
+        CorrelationData correlationId = new CorrelationData(UUID.randomUUID().toString());
+        rabbitTemplate.convertAndSend(RabbitConstants.BALANCE_PUT, RabbitConstants.BALANCE_ROUTINGKEY_PUT, content, correlationId);
+    }
+
+
+
     @Override
     public void confirm(CorrelationData correlationData, boolean ack, String cause) {
     	logger.info(" 回调id:" + correlationData);
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 721c520..df8ee78 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java
@@ -420,6 +420,22 @@ public class PayService {
         data.put("orderId", orderInfo.getId());
         data.put("plat", "miniApp");
         mQUtils.sendStockSaleMsg(data);
+
+
+        JSONObject baObj=new JSONObject();
+        baObj.put("userId",userInfo.getId());
+        baObj.put("shopId",user.getShopId());
+        baObj.put("amount",orderInfo.getOrderAmount());
+        baObj.put("balance",user.getAmount());
+        baObj.put("type","消费");
+        baObj.put("time",flow.getCreateTime());
+        producer.balance(baObj.toString());
+
+
+
+
+
+
         return Result.success(CodeEnum.SUCCESS, "1");
     }
 
@@ -1193,6 +1209,18 @@ public class PayService {
         jsonObject.put("type", "wxMemberIn");
         jsonObject.put("amount", memberIn.getAmount());
         producer.putOrderCollect(jsonObject.toJSONString());
+
+
+
+        JSONObject baObj=new JSONObject();
+        baObj.put("userId", tbShopUser.getUserId());
+        baObj.put("shopId",tbShopUser.getShopId());
+        baObj.put("amount",memberIn.getAmount());
+        baObj.put("balance",tbShopUser.getAmount());
+        baObj.put("type","充值");
+        baObj.put("time",flow.getCreateTime());
+        producer.balance(baObj.toString());
+
         return "SUCCESS";
     }