From 286cc1963d6d5a26f26c78d542974691b80a86f7 Mon Sep 17 00:00:00 2001
From: guyue <1721849008@qq.com>
Date: 星期六, 12 七月 2025 15:28:38 +0800
Subject: [PATCH] 登录失败修改状态

---
 src/main/java/com/linghu/controller/CollectController.java |   19 ++++++++++++++++---
 1 files changed, 16 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/linghu/controller/CollectController.java b/src/main/java/com/linghu/controller/CollectController.java
index 6bc388f..cfeab53 100644
--- a/src/main/java/com/linghu/controller/CollectController.java
+++ b/src/main/java/com/linghu/controller/CollectController.java
@@ -496,9 +496,6 @@
                 })
                 .onErrorResume(e -> {
                     System.out.println("获取任务结果失败");
-                    if (e.getMessage().contains("登陆失败")){
-
-                    }
                         TaskResultResponse result = new TaskResultResponse();
                     result.setDetail("获取任务结果失败: " + e.getMessage());
                     return Mono.just(result);
@@ -838,6 +835,22 @@
                             System.out.println("处理问题结果失败: " + e.getMessage());
                         }
                     }
+                    //更新账号状态
+                    if ( "failed".equals(userResult.getStatus())){
+                        if (userResult.getError().contains("登录失败")){
+                            LambdaUpdateWrapper<User> userWrapper =  new LambdaUpdateWrapper<>();
+                            userWrapper.eq(User::getUser_email, userResult.getUser_email());
+                            userWrapper.set(User::getStatus, "无法登录");
+                            userService.update(userWrapper);
+
+                        }else if (userResult.getError().contains("信息错误")){
+                            LambdaUpdateWrapper<User> userWrapper =  new LambdaUpdateWrapper<>();
+                            userWrapper.eq(User::getUser_email, userResult.getUser_email());
+                            userWrapper.set(User::getStatus, "信息错误");
+                            userService.update(userWrapper);
+                        }
+                    }
+
                 }
 
                 // 4. 批量更新问题

--
Gitblit v1.7.1