From 58928eb1e4cc73bb0d15015bb43a12dc6a33c29e Mon Sep 17 00:00:00 2001 From: zhenghaoyu Date: Thu, 6 Feb 2025 18:32:17 +0800 Subject: [PATCH 1/2] =?UTF-8?q?1.=E5=BB=B6=E8=BF=9F=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E8=AE=A2=E5=8D=95=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../logpm/distribution/receiver/OrderInfoUpdateHandler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java index bf4e07cdd..f7295e372 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java @@ -27,7 +27,8 @@ public class OrderInfoUpdateHandler { value = @Queue(name = RabbitConstant.ORDER_INFO_UPDATE_QUEUE, durable = "true"), exchange = @Exchange(name = RabbitConstant.ORDER_INFO_UPDATE_EXCHANGE, type = ExchangeTypes.DIRECT, - delayed = FactoryDataConstants.Mq.DELAYED) + delayed = FactoryDataConstants.Mq.DELAYED), + key = RabbitConstant.ORDER_INFO_UPDATE_ROUTING )) public void updateOrderInfo(String msg, Channel channel) { if(StringUtil.isNotBlank(msg)){ From 4038c9e342d243a8b2331824a1473cb25ac35878 Mon Sep 17 00:00:00 2001 From: zhenghaoyu Date: Thu, 6 Feb 2025 18:34:15 +0800 Subject: [PATCH 2/2] =?UTF-8?q?1.=E5=BB=B6=E8=BF=9F=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E8=AE=A2=E5=8D=95=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../distribution/receiver/OrderInfoUpdateHandler.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java index f7295e372..3d7127b27 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java @@ -31,12 +31,19 @@ public class OrderInfoUpdateHandler { key = RabbitConstant.ORDER_INFO_UPDATE_ROUTING )) public void updateOrderInfo(String msg, Channel channel) { + log.info("############updateOrderInfo: 当前处理的订单 msg={}",msg); + if(StringUtil.isNotBlank(msg)){ + + + DistributionStockArticleEntity bean = JSONUtil.toBean(msg, DistributionStockArticleEntity.class); distributionStockArticleService.updateOrderInfoByDistributionStockArticleEntity(bean); } + + log.info("############updateOrderInfo: 处理完成 "); } }