autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-04-21 11:35:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
Guoqs
2025-01-06 13:27:06 +08:00
parent bb02068115
commit de0b4aa6e4
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java
View File

@@ -1,5 +1,6 @@
package com.jsowell.mq;
import com.alibaba.fastjson2.JSON;
import com.huifu.adapay.core.exception.BaseAdaPayException;
import com.jsowell.common.constant.RabbitConstants;
import com.jsowell.common.util.YKCUtils;
@@ -30,10 +31,10 @@ public class OrderRabbitListener {
*/
@RabbitListener(queues = RabbitConstants.QUEUE_CHARGE_ORDER_DATA)
public void receiveChargeOrderData(AfterSettleOrderDTO afterSettleOrderDTO, Channel channel, Message message) throws IOException {
log.info("接收到订单结算数据：{}", afterSettleOrderDTO);
log.info("接收到订单结算数据:{}", JSON.toJSONString(afterSettleOrderDTO));
List<String> newLogicStationIdList = YKCUtils.getNewLogicStationIdList();
if (newLogicStationIdList.contains(afterSettleOrderDTO.getStationId())) {
log.info("接收到订单结算数据：{}", afterSettleOrderDTO);
log.info("realTimeOrderSplit-订单{}开始执行新分账方法", afterSettleOrderDTO.getOrderCode());
try {
orderBasicInfoService.realTimeOrderSplit(afterSettleOrderDTO);
} catch (BaseAdaPayException e) {