From 6160ddb8f5fff8e0452082ff099456e0bc51e9bd Mon Sep 17 00:00:00 2001
From: liukang <644012909@qq.com>
Date: Mon, 24 Feb 2025 09:01:16 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8A=A2=E7=A5=A8=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/ruoyi/web/task/MyReq.java     | 13 ++++++++++++-
 .../src/main/java/com/ruoyi/web/task/RyTask.java    |  3 ++-
 2 files changed, 14 insertions(+), 2 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java b/ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java
index 8222c66..1013f58 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java
@@ -7,6 +7,8 @@ public class MyReq {
     private HttpClient client;
     private HttpRequest request;
 
+    private String user;
+
     public HttpClient getClient() {
         return client;
     }
@@ -23,8 +25,17 @@ public class MyReq {
         this.request = request;
     }
 
-    public MyReq(HttpClient client, HttpRequest request) {
+    public String getUser() {
+        return user;
+    }
+
+    public void setUser(String user) {
+        this.user = user;
+    }
+
+    public MyReq(HttpClient client, HttpRequest request, String user) {
         this.client = client;
         this.request = request;
+        this.user = user;
     }
 }
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java b/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java
index 21ee645..f30ad61 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java
@@ -104,7 +104,7 @@ public class RyTask {
                     .header("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36")
                     .POST(HttpRequest.BodyPublishers.ofString(jsonPayload))
                     .build();
-            req.add(new MyReq(client, request));
+            req.add(new MyReq(client, request, a.getName()));
         }
 
         Calendar calendar = Calendar.getInstance();
@@ -115,6 +115,7 @@ public class RyTask {
         Thread.sleep(start - now);
         log.info("抢票开始了");
         for (MyReq r : req) {
+            log.info(r.getUser());
             // 发起异步请求，但不等待结果
             CompletableFuture<HttpResponse<String>> future2 = r.getClient().sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString());
             future2.thenAccept(response -> {