提交 721ba393 authored 作者: huyufan's avatar huyufan

修改BUG

上级 204d7c90
...@@ -156,6 +156,7 @@ public class OneGoodsOrderStrategy implements GoodsOrderStrategy, InitializingBe ...@@ -156,6 +156,7 @@ public class OneGoodsOrderStrategy implements GoodsOrderStrategy, InitializingBe
public void sendMq(Map<String, LocalDateTime> mqMap, LocalDateTime now) { public void sendMq(Map<String, LocalDateTime> mqMap, LocalDateTime now) {
for (Map.Entry<String, LocalDateTime> entry : mqMap.entrySet()) { for (Map.Entry<String, LocalDateTime> entry : mqMap.entrySet()) {
log.info("发送货单更改挂单中延迟消息,时间:{},orderGoodsNo:{}", entry.getKey(), entry.getValue());
Message message = MessageBuilder.withBody(entry.getKey().getBytes()).build(); Message message = MessageBuilder.withBody(entry.getKey().getBytes()).build();
long epochMilli = 0L; long epochMilli = 0L;
if (entry.getValue().isAfter(now)) { if (entry.getValue().isAfter(now)) {
...@@ -166,11 +167,13 @@ public class OneGoodsOrderStrategy implements GoodsOrderStrategy, InitializingBe ...@@ -166,11 +167,13 @@ public class OneGoodsOrderStrategy implements GoodsOrderStrategy, InitializingBe
} }
if (epochMilli == 0L) { if (epochMilli == 0L) {
log.info("epochMilli时间为0,时间为:{}", epochMilli); log.info("epochMilli时间为0,时间为:{}", epochMilli);
log.info("货单更改挂单中直接发延迟队列,因为时间早于当前时间");
rabbitTemplate.send( rabbitTemplate.send(
RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE, RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY, message RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE, RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY, message
); );
} else { } else {
log.info("epochMilli时间不为0,时间为:{}", epochMilli); log.info("epochMilli时间不为0,时间为:{}", epochMilli);
log.info("货单更改挂单中发送延迟消息,因为挂单时间大于当前时间{}", epochMilli);
message.getMessageProperties().setExpiration(String.valueOf(epochMilli)); message.getMessageProperties().setExpiration(String.valueOf(epochMilli));
rabbitTemplate.send( rabbitTemplate.send(
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论