Browse Source

添加线程池

yq 3 years ago
parent
commit
0d3aece92a
1 changed files with 4 additions and 4 deletions
  1. 4 4
      src/main/java/com/usky/dxtop/service/impl/OrderServiceImpl.java

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

@@ -300,7 +300,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
         this.updateById(order);
     }
 
-    @Transactional(rollbackFor = Exception.class)
+
     @Override
     public String exportDetail(OrderRequest orderRequest) {
         LoginUser loginUser = SecurityUtils.getLoginUser();
@@ -314,7 +314,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
 
     }
 
-    @Async
+    @Async("threadPoolTaskExecutor")
     public void syncOrder(Long taskId,OrderRequest orderRequest){
         Workbook workbook = null;
         try {
@@ -419,7 +419,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
         List<OrderReport> orderReports = JSON.parseArray(jsonStr, OrderReport.class);
         return new CommonPage<>(orderReports,page.getTotal(),page.getCurrent(),page.getSize());
     }
-    @Transactional(rollbackFor = Exception.class)
+
     @Override
     public String reportExport(Date startTime, Date endTime, Integer type) {
         LoginUser loginUser = SecurityUtils.getLoginUser();
@@ -431,7 +431,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
         ((OrderServiceImpl) AopContext.currentProxy()).syncOrderBusiness(taskId,startTime,endTime,type);
         return String.valueOf(taskId);
     }
-    @Async
+    @Async("threadPoolTaskExecutor")
     public void syncOrderBusiness(Long taskId,Date startTime, Date endTime, Integer type){
         Workbook workbook = null;
         try {