From ad1f5d2df29463efca1dfa0c0fa8b2c8d6de6b40 Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Fri, 6 Dec 2024 15:35:01 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E6=89=A7=E8=A1=8C=E6=97=B6?=
 =?UTF-8?q?=E9=97=B4=20=E9=A2=86=E5=8F=96=E8=BF=87=E6=85=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../sqx/common/aspect/AppApiMethodAspect.java  |  9 +++++----
 .../controller/DiscSpinningController.java     | 18 ++++++++++++++----
 2 files changed, 19 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/sqx/common/aspect/AppApiMethodAspect.java b/src/main/java/com/sqx/common/aspect/AppApiMethodAspect.java
index 5849a5fb..8857336e 100644
--- a/src/main/java/com/sqx/common/aspect/AppApiMethodAspect.java
+++ b/src/main/java/com/sqx/common/aspect/AppApiMethodAspect.java
@@ -31,7 +31,7 @@ public class AppApiMethodAspect {
     @Around("pkg()")
 //    @SuppressWarnings("unchecked")
     public Object around(ProceedingJoinPoint pjp) throws Throwable {
-        String start = DateUtils.format(new Date());
+        long start = System.currentTimeMillis();
         // 执行被拦截的方法
         Object result = pjp.proceed();
         //请求的参数
@@ -40,9 +40,10 @@ public class AppApiMethodAspect {
         String resultJson = new Gson().toJson(result);
         //获取request
         HttpServletRequest request = HttpContextUtils.getHttpServletRequest();
-        String end = DateUtils.format(new Date());
-        log.info("\n>>>>>> 开始时间：{} 结束时间：{} \n>>>>>> {} {}\n>>>>>> {}\n>>>>>> Request: {}\n>>>>>> Response: {}",
-                start,end,request.getMethod(), request.getRequestURL(), IPUtils.getIpAddr(request),
+        long end = System.currentTimeMillis();
+
+        log.info("\n>>>>>> {} {}\n>>>>>> IP: {} \n>>>>>> execute time:{}\n>>>>>> Request: {}\n>>>>>> Response: {}",
+                request.getMethod(), request.getRequestURL(), IPUtils.getIpAddr(request),end-start,
                 params,
                 resultJson
         );
diff --git a/src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java b/src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java
index ddedbfda..8802af9c 100644
--- a/src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java
+++ b/src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java
@@ -28,6 +28,7 @@ import io.swagger.annotations.*;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 
@@ -160,8 +161,14 @@ public class DiscSpinningController {
 
     @PostMapping("/app/discSpinning/receive")
     @ApiOperation("大转盘奖项领取")
-    @Transactional
     public Result receive(@RequestBody DiscSpinningRecord receive) {
+        receiveAsync(receive);
+        return Result.success();
+    }
+
+    @Async
+    @Transactional
+    public void receiveAsync(DiscSpinningRecord receive) {
         UserEntity userInfo = userService.queryByUserId(receive.getUserId());
         if (StringUtils.isNotBlank(userInfo.getZhiFuBao()) && StringUtils.isNotBlank(userInfo.getZhiFuBaoName())) {
             receive.setTarget("1");
@@ -170,11 +177,13 @@ public class DiscSpinningController {
             recordService.updateById(receive);
 
             if (StringUtils.isBlank(result)) {
-                return Result.success();
+//                return Result.success();
+                return;
             }
 
             if ("提现成功，将在三个工作日内到账，请耐心等待！".equals(result)) {
-                return Result.success(result);
+//                return Result.success(result);
+                return;
             }
         }
 
@@ -195,9 +204,10 @@ public class DiscSpinningController {
         receive.setTargetId(userMoneyDetails.getId());
 
         recordService.updateById(receive);
-        return Result.success();
     }
 
+
+    @Transactional
     public String withdraw(DiscSpinningRecord record, Long userId, Double money) {
         UserEntity userInfo = userService.queryByUserId(userId);
         //最高提现金额