Przeglądaj źródła

fix schedule bug

release_toaliyun_real
xiaohanzi 5 lat temu
rodzic
commit
5d801378ae
2 zmienionych plików z 17 dodań i 1 usunięć
  1. +5
    -1
      mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java
  2. +12
    -0
      mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java

+ 5
- 1
mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java Wyświetl plik

@@ -73,7 +73,11 @@ public class CouponOrderExpiringSchedule {
List<WxCouponOrder> list = wxCouponOrderMapper.findExpiredCouponOrderByValidDate(); List<WxCouponOrder> list = wxCouponOrderMapper.findExpiredCouponOrderByValidDate();
CouponOrderExpiringSchedule proxy = (CouponOrderExpiringSchedule) AopContext.currentProxy(); CouponOrderExpiringSchedule proxy = (CouponOrderExpiringSchedule) AopContext.currentProxy();
list.stream().forEach(co -> { list.stream().forEach(co -> {
proxy.refund(co);
try {
proxy.refund(co);
}catch(Exception e) {
logger.error(e.getMessage());
}
}); });
} }




+ 12
- 0
mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java Wyświetl plik

@@ -158,6 +158,7 @@ public class OrderExpiringSchedule {
order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_COOPERATING_CANCEL.getCode()); order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_COOPERATING_CANCEL.getCode());
wxOrderMapper.selectList(new QueryWrapper(order)).stream().forEach(o -> { wxOrderMapper.selectList(new QueryWrapper(order)).stream().forEach(o -> {
try { try {
proxy.orderGroupBreak((WxOrder) o);
proxy.returnMoney((WxOrder) o); proxy.returnMoney((WxOrder) o);
} catch (Exception e) { } catch (Exception e) {
logger.error("拼团券下架退款失败" + e.getMessage()); logger.error("拼团券下架退款失败" + e.getMessage());
@@ -304,6 +305,17 @@ public class OrderExpiringSchedule {
wxOrderService.orderClose(updateOrder); wxOrderService.orderClose(updateOrder);
logger.info("拼团订单: " + order.getId() + " create at " + order.getCreateDate() + " expired at " + curDate); logger.info("拼团订单: " + order.getId() + " create at " + order.getCreateDate() + " expired at " + curDate);
} }
@Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class})
public void orderGroupBreak(WxOrder order) {
Date curDate = new Date();
WxOrder updateOrder = new WxOrder();
updateOrder.setId(order.getId());
updateOrder.updateTenantInfo(order);
updateOrder.setOrderStatus(EnumOrderStatus.ORDER_STATUS_COOPERATING_BREAK.getCode());
updateOrder.setUpdateDate(curDate);
wxOrderMapper.updateById(updateOrder);
}


/** /**
* 回调会再次扣减库存 * 回调会再次扣减库存


Ładowanie…
Anuluj
Zapisz