diff --git a/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java b/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java index cba7f1cde..f5866871e 100644 --- a/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java +++ b/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java @@ -32,14 +32,17 @@ public class OrderRabbitListener { @RabbitListener(queues = RabbitConstants.QUEUE_CHARGE_ORDER_DATA) public void receiveChargeOrderData(AfterSettleOrderDTO afterSettleOrderDTO, Channel channel, Message message) throws IOException { log.info("接收到订单结算数据:{}", JSON.toJSONString(afterSettleOrderDTO)); + List newLogicStationIdList = YKCUtils.getNewLogicStationIdList(); - if (newLogicStationIdList.contains(afterSettleOrderDTO.getStationId())) { - log.info("realTimeOrderSplit-订单{}开始执行新分账方法", afterSettleOrderDTO.getOrderCode()); - try { - orderBasicInfoService.realTimeOrderSplit(afterSettleOrderDTO); - } catch (BaseAdaPayException e) { - throw new RuntimeException(e); - } + if (!newLogicStationIdList.contains(afterSettleOrderDTO.getStationId())) { + return; + } + + log.info("realTimeOrderSplit-订单{}开始执行新分账方法", afterSettleOrderDTO.getOrderCode()); + try { + orderBasicInfoService.realTimeOrderSplit(afterSettleOrderDTO); + } catch (BaseAdaPayException e) { + throw new RuntimeException(e); } // 2024年12月26日16点27分 取消了手动应答配置