异步执行过期机具扣款

kxs-product/kxs-product-biz/src/main/java/com/kxs/product/biz/task/KxsProductTask.java

@@ -44,6 +44,7 @@ import java.util.List;
 @Slf4j
 @RestController
 @RequestMapping("product-job")
+@EnableAsync
 public class KxsProductTask {
 
 
@@ -58,10 +59,11 @@ public class KxsProductTask {
     /**
      * 循环过期机具添加预扣款
      * 一个小时执行一次
-     *
+     * 异步执行
      */
     @Inner
     @GetMapping("/recycleMachineSchedule")
+    @Async("getAsyncExecutor")
     public void recycleMachineSchedule(@RequestParam("param") String para)  {
         LocalDateTime endDay = LocalDate.now().minusDays(30).atStartOfDay();
         List<KxsMachine> machines = kxsMachineMapper.selectExpireDeductList(endDay);