定时任务

order-application-service/src/main/java/cn/freemud/controller/OrderController.java

@@ -29,6 +29,7 @@ import cn.freemud.service.impl.MallOrderServiceImpl;
 import cn.freemud.service.impl.OrderAdapterServiceImpl;
 import cn.freemud.utils.AppLogUtil;
 import cn.freemud.utils.ResponseUtil;
+import cn.freemud.handler.CouponOrderAutoRefundHandler;
 import cn.freemud.xxljob.OrderCountJobHandler;
 import com.freemud.application.sdk.api.log.ApiAnnotation;
 import com.freemud.application.sdk.api.log.LogParams;
@@ -60,6 +61,8 @@ public class OrderController {
     @Autowired
     private OrderCountJobHandler orderCountJobHandler;
     @Autowired
+    private CouponOrderAutoRefundHandler couponOrderAutoRefundHandler;
+    @Autowired
     private PointsMallOrderService pointsMallOrderService;
 
     /**
@@ -520,5 +523,18 @@ public class OrderController {
         return orderservice.couponOrderRefundRetry(orderRefundRetryVo);
     }
 
+    /**
+     *  卖券订单券过期自动退款
+     * @param
+     * @return
+     */
+    @ApiAnnotation(logMessage = "reportSendOrderCount")
+    @GetMapping("/reportSendOrderCount")
+    public BaseResponse couponOrderAutoRefund() throws Exception {
+        AppLogUtil.infoLog("卖券订单券过期自动退款 ",null,null);
+        couponOrderAutoRefundHandler.execute(null);
+        return ResponseUtil.success();
+    }
+
 }
 

order-application-service/src/main/java/cn/freemud/xxljob/CouponOrderRefundRetryHandler.java → order-application-service/src/main/java/cn/freemud/handler/CouponOrderAutoRefundHandler.java

-package cn.freemud.xxljob;
+package cn.freemud.handler;
 
 import cn.freemud.base.entity.BaseResponse;
 import cn.freemud.base.util.DateUtil;
@@ -45,7 +45,7 @@ import java.util.stream.Collectors;
  * @description :
  */
 @Component
-public class CouponOrderRefundRetryHandler extends IJobHandler {
+public class CouponOrderAutoRefundHandler {
 
     @Autowired
     private Orderservice orderservice;
@@ -55,7 +55,6 @@ public class CouponOrderRefundRetryHandler extends IJobHandler {
 
     private ExecutorService executor = Executors.newFixedThreadPool(5);
 
-    @Override
     public ReturnT<String> execute(String param) throws Exception {
 
         long now = System.currentTimeMillis();