| @@ -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<WxOrder> 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()); | |||
| } | |||
| } | |||