Browse Source

1.延迟更新订单信息

dev
zhenghaoyu 2 weeks ago
parent
commit
4038c9e342
  1. 7
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java

7
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 key = RabbitConstant.ORDER_INFO_UPDATE_ROUTING
)) ))
public void updateOrderInfo(String msg, Channel channel) { public void updateOrderInfo(String msg, Channel channel) {
log.info("############updateOrderInfo: 当前处理的订单 msg={}",msg);
if(StringUtil.isNotBlank(msg)){ if(StringUtil.isNotBlank(msg)){
DistributionStockArticleEntity bean = JSONUtil.toBean(msg, DistributionStockArticleEntity.class); DistributionStockArticleEntity bean = JSONUtil.toBean(msg, DistributionStockArticleEntity.class);
distributionStockArticleService.updateOrderInfoByDistributionStockArticleEntity(bean); distributionStockArticleService.updateOrderInfoByDistributionStockArticleEntity(bean);
} }
log.info("############updateOrderInfo: 处理完成 ");
} }
} }

Loading…
Cancel
Save