From 45965105a35516eff2f89bbd95c5ed4e50d8e75e Mon Sep 17 00:00:00 2001 From: Penny <2500338766@qq.com> Date: Mon, 22 May 2023 22:24:07 +0800 Subject: [PATCH] =?UTF-8?q?feature:=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../img/service/impl/ImgMqMessageRecordServiceImpl.java | 5 ++++- .../order/service/impl/OrderMqMessageRecordServiceImpl.java | 5 ++++- .../pay/service/impl/PayMqMessageRecordServiceImpl.java | 5 ++++- 3 files changed, 12 insertions(+), 3 deletions(-) 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 b58e97d..bc90114 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 @@ -215,8 +215,11 @@ public class ImgMqMessageRecordServiceImpl implements ImgMqMessageRecordService String content = imgMqMessageRecord.getContent(); JSONObject jsonObject = JSON.parseObject(content); String msg = jsonObject.getString("content"); + MqRecordMessage message = new MqRecordMessage(); + message.setId(imgMqMessageRecord.getId()); + message.setContent(msg); //少于30分钟，发送消息 - sendAsyncMsg(imgMqMessageRecord.getTopic(),null,msg); + sendAsyncMsg(imgMqMessageRecord.getTopic(),null,message); }else{ //超过30分钟，修改状态为废弃 imgMqMessageRecord.setStatus(EnumMessageStatus.INVALID); 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 13141ef..159e628 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 @@ -213,8 +213,11 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ String content = orderMqMessageRecord.getContent(); JSONObject jsonObject = JSON.parseObject(content); String msg = jsonObject.getString("content"); + MqRecordMessage message = new MqRecordMessage(); + message.setId(orderMqMessageRecord.getId()); + message.setContent(msg); //少于30分钟，发送消息 - sendAsyncMsg(orderMqMessageRecord.getTopic(),null,msg); + sendAsyncMsg(orderMqMessageRecord.getTopic(),null,message); }else{ //超过30分钟，修改状态为废弃 orderMqMessageRecord.setStatus(EnumMessageStatus.INVALID); 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 2ee2890..331a8cb 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 @@ -214,8 +214,11 @@ public class PayMqMessageRecordServiceImpl implements PayMqMessageRecordService String content = payMqMessageRecord.getContent(); JSONObject jsonObject = JSON.parseObject(content); String msg = jsonObject.getString("content"); + MqRecordMessage message = new MqRecordMessage(); + message.setId(payMqMessageRecord.getId()); + message.setContent(msg); //少于30分钟，发送消息 - sendAsyncMsg(payMqMessageRecord.getTopic(),null,msg); + sendAsyncMsg(payMqMessageRecord.getTopic(),null,message); }else{ //超过30分钟，修改状态为废弃 payMqMessageRecord.setStatus(EnumMessageStatus.INVALID);