diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java index 6e643fa65..e51dca272 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java @@ -140,14 +140,26 @@ public class OrderExpiringSchedule { // 拼团取消 WxOrder order = new WxOrder(); - order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_COOPERATING_UNPAID.getCode()); - wxOrderMapper.selectList(new QueryWrapper(order)).stream().forEach(o -> { +// order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_COOPERATING_UNPAID.getCode()); +// wxOrderMapper.selectList(new QueryWrapper(order)).stream().forEach(o -> { +// try { +// proxy.orderGroupExpired((WxOrder) o,true,true,payWay); +// } catch (Exception e) { +// logger.error("拼团取消失败" + e.getMessage()); +// } +// }); + Date groupExpireDate = new Date(curDate.getTime() - NORMAL_TIME_OUT ); + dateMap.put("type", EnumOrderType.COUPON.getCode()); + dateMap.put("endDate", groupExpireDate); + List orderGroups = wxOrderMapper.findListOfUnpaidGroupOrderByDate(dateMap); + orderGroups.stream().forEach( o -> { try { - proxy.orderGroupExpired((WxOrder) o,true,true,payWay); + proxy.orderGroupExpired(o,true,true,payWay); } catch (Exception e) { - logger.error("拼团取消失败" + e.getMessage()); + logger.error("砍价券支付过期失败" + e.getMessage()); } }); + //更新拼团过期状态 wxOrderMapper.updateOrderStatusForGroup(); diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxOrderMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxOrderMapper.java index 4dbc72579..224151a8f 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxOrderMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxOrderMapper.java @@ -21,6 +21,8 @@ public interface WxOrderMapper extends CommonMapper { List findListOfUnpaidPressOrderByDate(Map dateMap); List findListOfCompleteUnPaidPressOrderByDate(Map dateMap); + List findListOfUnpaidGroupOrderByDate(Map dateMap); + List findListOfCUser(WxOrder wxOrder); List selectDetailOfCUser(WxOrder wxOrder); diff --git a/mallinkService/src/main/resources/mapper/WxOrderMapper.xml b/mallinkService/src/main/resources/mapper/WxOrderMapper.xml index d4ad86213..0507938de 100644 --- a/mallinkService/src/main/resources/mapper/WxOrderMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxOrderMapper.xml @@ -218,6 +218,22 @@ AND unix_timestamp(`update_date`) < unix_timestamp(#{endDate,jdbcType=TIMESTAMP}) + +