浏览代码

开启异步任务成功

yq 3 年之前
父节点
当前提交
0552df6c69

+ 2 - 0
src/main/java/com/usky/dxtop/DxtopApplication.java

@@ -3,11 +3,13 @@ package com.usky.dxtop;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 @MapperScan(basePackages = {"com.usky.dxtop.mapper","com.usky.dxtop.quartz.mapper"})
 @SpringBootApplication
 @EnableScheduling
+@EnableAsync
 public class DxtopApplication {
 
     public static void main(String[] args) {

+ 3 - 4
src/main/java/com/usky/dxtop/service/impl/OrderServiceImpl.java

@@ -314,11 +314,10 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
 
     }
 
-    @Async("threadPoolTaskExecutor")
+    @Async
     public void syncOrder(Long taskId,OrderRequest orderRequest){
         Workbook workbook = null;
         try {
-            Thread.sleep(1000);
             ExportParams params = new ExportParams(null, "订单详情");
             workbook = ExcelExportUtil.exportBigExcel(params, OrderExport.class,
                     (o, i) -> {
@@ -334,6 +333,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
             } else {
                 sysAsyncTaskService.sendResult(taskId, false, "订单表格数据为空", AsyncResultType.TEXT);
             }
+            log.info("订单详情导出完成");
         } catch (Exception e) {
             log.error("导出文件失败", e);
             sysAsyncTaskService.sendResult(taskId, false, "导出订单文件失败", AsyncResultType.TEXT);
@@ -432,11 +432,10 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
         ((OrderServiceImpl) AopContext.currentProxy()).syncOrderBusiness(taskId,startTime,endTime,type);
         return String.valueOf(taskId);
     }
-    @Async("threadPoolTaskExecutor")
+    @Async
     public void syncOrderBusiness(Long taskId,Date startTime, Date endTime, Integer type){
         Workbook workbook = null;
         try {
-            Thread.sleep(1000);
             ExportParams params = new ExportParams(null, "订单报表");
             workbook = ExcelExportUtil.exportBigExcel(params, OrderReport.class,
                     (o, i) -> {