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..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 @@ -27,15 +27,23 @@ 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) { + log.info("############updateOrderInfo: 当前处理的订单 msg={}",msg); + if(StringUtil.isNotBlank(msg)){ + + + DistributionStockArticleEntity bean = JSONUtil.toBean(msg, DistributionStockArticleEntity.class); distributionStockArticleService.updateOrderInfoByDistributionStockArticleEntity(bean); } + + log.info("############updateOrderInfo: 处理完成 "); } }