提交 149721ce authored 作者: 刘海泉's avatar 刘海泉

Merge remote-tracking branch 'origin/v19.4_order_performance_progress_20240712' into dev

...@@ -25,7 +25,7 @@ public class SaveOrderGoodsAdjustmentPriceListener { ...@@ -25,7 +25,7 @@ public class SaveOrderGoodsAdjustmentPriceListener {
@RabbitListener(queues = RabbitKeyConstants.SAVE_ORDER_GOODS_ADJUSTMENT_PRICE_QUEUE) @RabbitListener(queues = RabbitKeyConstants.SAVE_ORDER_GOODS_ADJUSTMENT_PRICE_QUEUE)
public void onMessage(Message message) { public void onMessage(Message message) {
log.info("监听到保存货单挂单运费调整记录,消息内容{}", message); log.info("监听到保存货单挂单运费调整记录,消息内容{}", new String(message.getBody()));
OrderGoodsAdjustmentPrice data = JSON.parseObject(new String(message.getBody()), OrderGoodsAdjustmentPrice data = JSON.parseObject(new String(message.getBody()),
new TypeReference<MqWrapper<OrderGoodsAdjustmentPrice>>() { new TypeReference<MqWrapper<OrderGoodsAdjustmentPrice>>() {
}).getData(); }).getData();
......
...@@ -25,7 +25,7 @@ public class SyncPerformanceProgress4OrderChildListener { ...@@ -25,7 +25,7 @@ public class SyncPerformanceProgress4OrderChildListener {
@RabbitListener(queues = RabbitKeyConstants.SYNC_PERFORMANCE_PROGRESS_FOR_ORDER_CHILD_QUEUE) @RabbitListener(queues = RabbitKeyConstants.SYNC_PERFORMANCE_PROGRESS_FOR_ORDER_CHILD_QUEUE)
public void onMessage(Message message) { public void onMessage(Message message) {
log.info("监听到同步履约进度表---运单信息部分,消息内容{}", message); log.info("监听到同步履约进度表---运单信息部分,消息内容{}", new String(message.getBody()));
OrderChild data = JSON.parseObject(new String(message.getBody()), OrderChild data = JSON.parseObject(new String(message.getBody()),
new TypeReference<MqWrapper<OrderChild>>() { new TypeReference<MqWrapper<OrderChild>>() {
}).getData(); }).getData();
......
...@@ -25,7 +25,7 @@ public class SyncPerformanceProgress4OrderGoodsListener { ...@@ -25,7 +25,7 @@ public class SyncPerformanceProgress4OrderGoodsListener {
@RabbitListener(queues = RabbitKeyConstants.SYNC_PERFORMANCE_PROGRESS_FOR_ORDER_GOODS_QUEUE) @RabbitListener(queues = RabbitKeyConstants.SYNC_PERFORMANCE_PROGRESS_FOR_ORDER_GOODS_QUEUE)
public void onMessage(Message message) { public void onMessage(Message message) {
log.info("监听到同步履约进度表---货单信息部分,消息内容{}", message); log.info("监听到同步履约进度表---货单信息部分,消息内容{}", new String(message.getBody()));
OrderGoods data = JSON.parseObject(new String(message.getBody()), OrderGoods data = JSON.parseObject(new String(message.getBody()),
new TypeReference<MqWrapper<OrderGoods>>() { new TypeReference<MqWrapper<OrderGoods>>() {
}).getData(); }).getData();
......
...@@ -25,7 +25,7 @@ public class SyncPerformanceProgress4OrderInfoListener { ...@@ -25,7 +25,7 @@ public class SyncPerformanceProgress4OrderInfoListener {
@RabbitListener(queues = RabbitKeyConstants.SYNC_PERFORMANCE_PROGRESS_FOR_ORDER_INFO_QUEUE) @RabbitListener(queues = RabbitKeyConstants.SYNC_PERFORMANCE_PROGRESS_FOR_ORDER_INFO_QUEUE)
public void onMessage(Message message) { public void onMessage(Message message) {
log.info("监听到同步履约进度表---订单信息部分,消息内容{}", message); log.info("监听到同步履约进度表---订单信息部分,消息内容{}", new String(message.getBody()));
OrderInfoMessage data = JSON.parseObject(new String(message.getBody()), OrderInfoMessage data = JSON.parseObject(new String(message.getBody()),
new TypeReference<MqWrapper<OrderInfoMessage>>() { new TypeReference<MqWrapper<OrderInfoMessage>>() {
}).getData(); }).getData();
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论