diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/TtOrderQueryCpsSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/TtOrderQueryCpsSchedule.java index 2f1027e8a..0ae544ba9 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/TtOrderQueryCpsSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/TtOrderQueryCpsSchedule.java @@ -3,10 +3,7 @@ package com.iformall.schedule; import com.iformall.domain.po.*; import com.iformall.douyin.pay.TtPayService; import com.iformall.douyin.payv2.result.TtPayCpsOrderQueryV2Result; -import com.iformall.enums.EnumAppType; -import com.iformall.enums.EnumOrderCpsStatus; -import com.iformall.enums.EnumOrderStatus; -import com.iformall.enums.EnumPayWay; +import com.iformall.enums.*; import com.iformall.mapper.OrderCpsMapper; import com.iformall.mapper.TtOrderPushErrorMapper; import com.iformall.mapper.WxBatchOrderMapper; @@ -22,6 +19,7 @@ import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; +import java.util.Date; import java.util.List; @Component @@ -59,12 +57,18 @@ public class TtOrderQueryCpsSchedule { WxOrder orderQ = new WxOrder(); orderQ.updateTenantInfo(appinfo); + orderQ.setType(EnumOrderType.COUPON.getCode()); + orderQ.setPayVendor(EnumPayWay.PAY_WAY_TT.getCode()); orderQ.setOrderStatus(EnumOrderStatus.ORDER_STATUS_PAYMENT_SUCCESS.getCode()); orderQ.setCpsStatus(EnumOrderCpsStatus.ORDER_DEF_CPS.getCode()); List orderList = wxOrderService.findList(orderQ); for (WxOrder order:orderList) { try { + if(order.getPayment().intValue() <= 0){ + order.setCpsStatus(EnumOrderCpsStatus.ORDER_NO_CPS.getCode()); + wxOrderService.updateCpsStatus(order); + } TtPayCpsOrderQueryV2Result ttPayCpsOrderQueryV2Result = ttPayService.queryCpsOrderV2(null, order.getComposeOrderId().toString()); if(ttPayCpsOrderQueryV2Result != null){ OrderCps cps = new OrderCps(); @@ -86,6 +90,9 @@ public class TtOrderQueryCpsSchedule { } } if(StringUtils.isNotBlank(cps.getItemOrderId())){ + Date now = new Date(); + cps.setCreateDate(now); + cps.setCreateDate(now); int insert = orderCpsMapper.insert(cps); if(insert == 1){ order.setCpsStatus(EnumOrderCpsStatus.ORDER_IS_CPS.getCode()); @@ -97,11 +104,13 @@ public class TtOrderQueryCpsSchedule { wxOrderService.updateCpsStatus(order); } }catch(Exception e){ - + e.printStackTrace(); + logger.error("查询cps订单异常"+e.getMessage()); } } }catch(Exception e){ - + e.printStackTrace(); + logger.error("查询cps订单异常"+e.getMessage()); } }