Просмотр исходного кода

[券过期][修改]:退款错误catch

release_toaliyun_real
Stormeye Wu 7 лет назад
Родитель
Сommit
2bea3cf20e
2 измененных файлов: 24 добавлений и 4 удалений
  1. +19
    -4
      mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java
  2. +5
    -0
      mallinkService/src/main/java/com/iformall/service/impl/WxRefundOrderServiceImpl.java

+ 19
- 4
mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java Просмотреть файл

@@ -59,22 +59,37 @@ public class CouponOrderExpiringSchedule {
List<WxCouponOrder> list = wxCouponOrderMapper.findExpiredFreeCouponOrderByValidDate(); List<WxCouponOrder> list = wxCouponOrderMapper.findExpiredFreeCouponOrderByValidDate();
list.stream().forEach(co -> { list.stream().forEach(co -> {
// 券过期,更改状态及库存退回 // 券过期,更改状态及库存退回
couponOrderExpire(co);
try {
couponOrderExpire(co);
} catch (Exception e) {
logger.error(e.getMessage());
}

}); });


} }


@Scheduled(cron = "0 5 0 * * ?") // 每天凌晨00:05 @Scheduled(cron = "0 5 0 * * ?") // 每天凌晨00:05
//@Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次
// @Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次
public void couponOrderRefundSchedule() { public void couponOrderRefundSchedule() {


List<WxCouponOrder> list = wxCouponOrderMapper.findExpiredCouponOrderByValidDate(); List<WxCouponOrder> list = wxCouponOrderMapper.findExpiredCouponOrderByValidDate();


list.stream().forEach(co -> { list.stream().forEach(co -> {
// 券过期,更改状态及库存退回 // 券过期,更改状态及库存退回
couponOrderExpire(co);
try {
couponOrderExpire(co);
} catch (Exception e) {
logger.error(e.getMessage());
}

// 退款 // 退款
couponOrderExpireRefund(co);
try {
couponOrderExpireRefund(co);
} catch (Exception e) {
logger.error(e.getMessage());
}

}); });
} }




+ 5
- 0
mallinkService/src/main/java/com/iformall/service/impl/WxRefundOrderServiceImpl.java Просмотреть файл

@@ -271,6 +271,10 @@ public class WxRefundOrderServiceImpl implements WxRefundOrderService {
} }


WxOrder wxOrder = wxOrderMapper.selectByPrimaryKey(wxCouponOrder.getOrderId()); WxOrder wxOrder = wxOrderMapper.selectByPrimaryKey(wxCouponOrder.getOrderId());
if (wxOrder == null) {
logger.error("订单ID不存在:" + couponOrderId);
throw new MallinkException(ErrorCode.ORDER_IS_NOT_FIND);
}


if (payType == EnumPayType.PAY_B_REFUND) { if (payType == EnumPayType.PAY_B_REFUND) {
logger.info("B端发起退款: bUserId-" + bUserId); logger.info("B端发起退款: bUserId-" + bUserId);
@@ -295,6 +299,7 @@ public class WxRefundOrderServiceImpl implements WxRefundOrderService {
} else { } else {
logger.info("自己发起退款: cUserId-" + bUserId); logger.info("自己发起退款: cUserId-" + bUserId);
} }

if (wxOrder.getPayment() <= 0) { if (wxOrder.getPayment() <= 0) {
logger.error("订单支付金额小于等于0: " + wxOrder.toString()); logger.error("订单支付金额小于等于0: " + wxOrder.toString());
throw new MallinkException(ErrorCode.REFUND_PAY_ORDER_IS_ZERO); throw new MallinkException(ErrorCode.REFUND_PAY_ORDER_IS_ZERO);


Загрузка…
Отмена
Сохранить