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

[储值卡][新增]:储值卡购买未支付检查

release_toaliyun_real
Stormeye Wu 7 лет назад
Родитель
Сommit
d64f6bac0b
1 измененных файлов: 14 добавлений и 7 удалений
  1. +14
    -7
      mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java

+ 14
- 7
mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java Просмотреть файл

@@ -37,21 +37,28 @@ public class OrderExpiringSchedule {


Map dateMap = new HashMap(); Map dateMap = new HashMap();
Date curDate = new Date(); Date curDate = new Date();
Date expireDate = new Date(curDate.getTime() - TIME_OUT_VALUE );


// 只检查券相关订单
// 券相关订单
dateMap.put("type", EnumOrderType.COUPON.getCode()); dateMap.put("type", EnumOrderType.COUPON.getCode());
dateMap.put("endDate", new Date(curDate.getTime() - TIME_OUT_VALUE ));
List<WxOrder> wxOrderList = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap);
dateMap.put("endDate", expireDate);
List<WxOrder> orderCoupons = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap);
orderCoupons.parallelStream().forEach( o -> {
orderExpired(o);
});


for(WxOrder wxOrder: wxOrderList){
orderExpired(wxOrder);
}
// 卡相关订单
dateMap.put("type", EnumOrderType.PREPAIDCARD.getCode());
dateMap.put("endDate", new Date(curDate.getTime() - TIME_OUT_VALUE ));
List<WxOrder> orderCards = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap);
orderCards.parallelStream().forEach( o -> {
orderExpired(o);
});
} }


@Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class})
public void orderExpired(WxOrder order) { public void orderExpired(WxOrder order) {
order.setUpdateDate(new Date()); order.setUpdateDate(new Date());
order.setType(EnumOrderType.COUPON.getCode());
order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_OVERTIME_CANCEL.getCode()); order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_OVERTIME_CANCEL.getCode());
wxOrderMapper.updateByPrimaryKeySelective(order); wxOrderMapper.updateByPrimaryKeySelective(order);




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