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 ea0fd46aa..13e800ea3 100644 --- a/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java +++ b/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java @@ -1,6 +1,5 @@ package com.jsowell.mq; -import com.huifu.adapay.core.exception.BaseAdaPayException; import com.jsowell.common.constant.RabbitConstants; import com.jsowell.pile.dto.AfterSettleOrderDTO; import com.jsowell.pile.service.OrderBasicInfoService; @@ -30,11 +29,11 @@ public class OrderRabbitListener { public void receiveChargeOrderData(AfterSettleOrderDTO afterSettleOrderDTO, Channel channel, Message message) throws IOException { log.info("接收到订单结算数据:{}", afterSettleOrderDTO); - try { - orderBasicInfoService.realTimeOrderSplit(afterSettleOrderDTO); - } catch (BaseAdaPayException e) { - throw new RuntimeException(e); - } + // try { + // orderBasicInfoService.realTimeOrderSplit(afterSettleOrderDTO); + // } catch (BaseAdaPayException e) { + // throw new RuntimeException(e); + // } //由于配置设置了手动应答,所以这里要进行一个手动应答。注意:如果设置了自动应答,这里又进行手动应答,会出现double ack,那么程序会报错。 channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/programlogic/DelayMerchantProgramLogic.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/programlogic/DelayMerchantProgramLogic.java index 288a0a859..bd3fc16d8 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/programlogic/DelayMerchantProgramLogic.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/programlogic/DelayMerchantProgramLogic.java @@ -479,7 +479,7 @@ public class DelayMerchantProgramLogic extends AbstractProgramLogic { transactionService.doUpdateOrder(dto); // 订单退款 - refundOrder(orderBasicInfo); + // refundOrder(orderBasicInfo); // 组装after参数 AfterSettleOrderDTO afterSettleOrderDTO = AfterSettleOrderDTO.builder()