异步领取 奖项

src/main/java/com/sqx/SqxApplication.java

@@ -12,7 +12,6 @@ import java.util.Map;
 /**
  * @author GYJ
  */
-@EnableAsync
 @EnableScheduling
 @SpringBootApplication
 public class SqxApplication {
@@ -35,12 +34,12 @@ public class SqxApplication {
 			}
 		});
 		System.out.println("(♥◠‿◠)ﾉﾞ  短剧系统启动成功   ლ(´ڡ`ლ)ﾞ  \n"+
-							"       _    \n" +
-							"      | |   \n" +
-							"  ___ | | __\n" +
-							" / _ \\| |/ /\n" +
-							"| (_) |   < \n" +
-							" \\___/|_|\\_\\");
+				"       _    \n" +
+				"      | |   \n" +
+				"  ___ | | __\n" +
+				" / _ \\| |/ /\n" +
+				"| (_) |   < \n" +
+				" \\___/|_|\\_\\");
 
 	}
 

src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java

@@ -36,6 +36,7 @@ import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
 
 @Slf4j
 @RestController
@@ -132,14 +133,14 @@ public class DiscSpinningController {
     public Result drawCount(@RequestAttribute("userId") Long userId) {
         Map<String, Object> map = new HashMap<>();
         int drawCount = Integer.parseInt(commonRepository.findOne(901).getValue());
-        map.put("sum",drawCount);
+        map.put("sum", drawCount);
         int i = recordService.countDraw(userId);
         if (drawCount - i > 0) {
-            map.put("count",ordersService.selectOrdersCountStatisticsByDay(userId, drawCount - i));
+            map.put("count", ordersService.selectOrdersCountStatisticsByDay(userId, drawCount - i));
             return Result.success(map);
         } else {
-            map.put("count",0);
-            return  Result.success(map);
+            map.put("count", 0);
+            return Result.success(map);
         }
     }
 
@@ -162,11 +163,12 @@ public class DiscSpinningController {
     @PostMapping("/app/discSpinning/receive")
     @ApiOperation("大转盘奖项领取")
     public Result receive(@RequestBody DiscSpinningRecord receive) {
-        receiveAsync(receive);
+        CompletableFuture.runAsync(() -> {
+            receiveAsync(receive);
+        });
         return Result.success();
     }
 
-    @Async
     @Transactional
     public void receiveAsync(DiscSpinningRecord receive) {
         UserEntity userInfo = userService.queryByUserId(receive.getUserId());