From cfe9304d21ccb1cdb5e74fb7b7d8fda0b322c9ce Mon Sep 17 00:00:00 2001 From: Guoqs <123@jsowell.com> Date: Thu, 9 Jan 2025 16:21:07 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=96=B0=E7=9A=84=E5=88=86=E8=B4=A6?= =?UTF-8?q?=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/jsowell/mq/OrderRabbitListener.java | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) 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分 取消了手动应答配置