|
|
|
@ -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: 处理完成 "); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|