From 6039d4e3ce4f9520420b8dbcab5dc70ccdb9ccdf Mon Sep 17 00:00:00 2001
From: wuxicheng <1441859745@qq.com>
Date: Mon, 22 May 2023 22:35:10 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E8=A1=A8=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?=E8=BF=94=E5=9B=9E=E4=B8=BB=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java    | 1 +
 .../order/service/impl/OrderMqMessageRecordServiceImpl.java      | 1 +
 .../bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java    | 1 +
 3 files changed, 3 insertions(+)

diff --git a/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java b/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java
index bc90114..cfe36ad 100644
--- a/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java
+++ b/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java
@@ -184,6 +184,7 @@ public class ImgMqMessageRecordServiceImpl implements ImgMqMessageRecordService
         imgMqMessageRecord.setCreateTime(new Date());
         imgMqMessageRecord.setMessageKey(message.getMessageKey());
         imgMqMessageRecord.setContent(JSON.toJSONString(message));
+        imgMqMessageRecord.setReturnTopic(message.getReturnTopic());
         imgMqMessageRecordMapper.insert(imgMqMessageRecord);
         return imgMqMessageRecord;
     }
diff --git a/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java b/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
index 159e628..0a30a4d 100644
--- a/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
+++ b/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
@@ -182,6 +182,7 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ
         orderMqMessageRecord.setCreateTime(new Date());
         orderMqMessageRecord.setMessageKey(message.getMessageKey());
         orderMqMessageRecord.setContent(JSON.toJSONString(message));
+        orderMqMessageRecord.setReturnTopic(message.getReturnTopic());
         orderMqMessageRecordMapper.insert(orderMqMessageRecord);
         return orderMqMessageRecord;
     }
diff --git a/bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java b/bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java
index 331a8cb..9f5e108 100644
--- a/bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java
+++ b/bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java
@@ -183,6 +183,7 @@ public class PayMqMessageRecordServiceImpl implements PayMqMessageRecordService
         payMqMessageRecord.setCreateTime(new Date());
         payMqMessageRecord.setMessageKey(message.getMessageKey());
         payMqMessageRecord.setContent(JSON.toJSONString(message));
+        payMqMessageRecord.setReturnTopic(message.getReturnTopic());
         payMqMessageRecordMapper.insert(payMqMessageRecord);
         return payMqMessageRecord;
     }