update 新的分账方法

This commit is contained in:
Guoqs
2025-01-09 16:21:07 +08:00
parent b19bc49093
commit cfe9304d21

View File

@@ -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<String> 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分 取消了手动应答配置