From e6de7ac4b7b16a38f3c371f0f3577241f8a5d5b7 Mon Sep 17 00:00:00 2001 From: hupeng Date: Tue, 4 Sep 2018 11:02:44 +0800 Subject: [PATCH] =?UTF-8?q?[=E7=B3=BB=E7=BB=9F][=E6=96=B0=E5=A2=9E]:?= =?UTF-8?q?=E5=8D=A1=E5=88=B8=E5=AE=9A=E6=97=B6=E9=80=80=E6=AC=BE=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../schedule/CouponOrderExpiringSchedule.java | 41 +++++++++++++++---- 1 file changed, 32 insertions(+), 9 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/simple/schedule/CouponOrderExpiringSchedule.java b/mallinkAdmin/src/main/java/com/simple/schedule/CouponOrderExpiringSchedule.java index 8e5582231..c4a2b8602 100644 --- a/mallinkAdmin/src/main/java/com/simple/schedule/CouponOrderExpiringSchedule.java +++ b/mallinkAdmin/src/main/java/com/simple/schedule/CouponOrderExpiringSchedule.java @@ -3,16 +3,17 @@ package com.simple.schedule; import com.simple.common.ErrorCode; import com.simple.common.ResultData; import com.simple.config.PayProperty; -import com.simple.domain.po.WxAppinfo; -import com.simple.domain.po.WxCouponOrder; -import com.simple.domain.po.WxMerchantBUser; +import com.simple.domain.po.*; import com.simple.domain.vo.WxCouponOrderCVo; +import com.simple.enums.EnumAppType; +import com.simple.enums.EnumPayStatus; import com.simple.enums.EnumPayWay; +import com.simple.enums.EnumRefundWay; import com.simple.exception.MallinkException; -import com.simple.mapper.WxCouponChannelMapper; -import com.simple.mapper.WxCouponMapper; -import com.simple.mapper.WxCouponOrderMapper; -import com.simple.mapper.WxMallMapper; +import com.simple.mapper.*; +import com.simple.service.WxAppinfoService; +import com.simple.service.WxPayOrderService; +import com.simple.service.WxRefundOrderService; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; @@ -34,6 +35,15 @@ public class CouponOrderExpiringSchedule { @Autowired private PayProperty payProperty; + @Autowired + private WxRefundOrderService wxRefundOrderService; + + @Autowired + private WxPayOrderService wxPayOrderService; + + @Autowired + private WxAppinfoMapper wxAppinfoMapper; + @Scheduled(cron = "0 5 0 * * ?") // 每天凌晨00:05 //@Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次 @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) @@ -43,11 +53,24 @@ public class CouponOrderExpiringSchedule { @Scheduled(cron = "0 5 0 * * ?") // 每天凌晨00:05 //@Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次 - @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) public void couponOrderRefundSchedule() { List list = wxCouponOrderMapper.findExpiredCouponOrderByValidDate(); - } + for(WxCouponOrder co:list) { + + WxAppinfo appinfo = new WxAppinfo(); + appinfo.setTenantId(co.getOrderId().toString()); + appinfo.setType(EnumAppType.B.getCode()); + appinfo = wxAppinfoMapper.findList(appinfo).get(0); + + try { + wxRefundOrderService.createRefundOrder(payProperty.isReal(), appinfo, co.getId(), EnumRefundWay.AUTO, null); + } catch (Exception e) { + logger.error("退款失败:"+e.getMessage()+"couponOrderId="+co.getId()); + continue; + } + } + } } \ No newline at end of file