| @@ -53,7 +53,11 @@ public class OrderExpiringSchedule { | |||||
| dateMap.put("endDate", expireDate); | dateMap.put("endDate", expireDate); | ||||
| List<WxOrder> orderCoupons = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap); | List<WxOrder> orderCoupons = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap); | ||||
| orderCoupons.parallelStream().forEach( o -> { | orderCoupons.parallelStream().forEach( o -> { | ||||
| orderExpired(o); | |||||
| try { | |||||
| orderExpired(o); | |||||
| } catch (Exception e) { | |||||
| logger.error(e.getMessage()); | |||||
| } | |||||
| }); | }); | ||||
| // 砍价相关订单, 已超过砍价结束时间, 订单过期 | // 砍价相关订单, 已超过砍价结束时间, 订单过期 | ||||
| @@ -61,13 +65,21 @@ public class OrderExpiringSchedule { | |||||
| dateMap.put("endDate", curDate); | dateMap.put("endDate", curDate); | ||||
| List<WxOrder> orderPresss = wxOrderMapper.findListOfUnpaidPressOrderByDate(dateMap); | List<WxOrder> orderPresss = wxOrderMapper.findListOfUnpaidPressOrderByDate(dateMap); | ||||
| orderPresss.parallelStream().forEach( o -> { | orderPresss.parallelStream().forEach( o -> { | ||||
| orderPressExpired(o); | |||||
| try { | |||||
| orderPressExpired(o); | |||||
| } catch (Exception e) { | |||||
| logger.error(e.getMessage()); | |||||
| } | |||||
| }); | }); | ||||
| //拼团 | //拼团 | ||||
| List<WxOrderGroup> orderGroups = wxOrderGroupService.findList(null); | List<WxOrderGroup> orderGroups = wxOrderGroupService.findList(null); | ||||
| orderGroups.parallelStream().forEach(g -> { | orderGroups.parallelStream().forEach(g -> { | ||||
| wxOrderGroupService.updateGroupStatus(g); | |||||
| try { | |||||
| wxOrderGroupService.updateGroupStatus(g); | |||||
| } catch (Exception e) { | |||||
| logger.error(e.getMessage()); | |||||
| } | |||||
| }); | }); | ||||
| } | } | ||||