From fe50c1d1951d93970c9c16e9260efa0d9d0e4f7a Mon Sep 17 00:00:00 2001
From: guyue <1721849008@qq.com>
Date: 星期一, 28 七月 2025 14:24:25 +0800
Subject: [PATCH] 账号信息错误增加error信息

---
 src/main/java/com/linghu/controller/CollectController.java |   11 +++++++++--
 1 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/linghu/controller/CollectController.java b/src/main/java/com/linghu/controller/CollectController.java
index d61cf93..da3fa1d 100644
--- a/src/main/java/com/linghu/controller/CollectController.java
+++ b/src/main/java/com/linghu/controller/CollectController.java
@@ -469,7 +469,9 @@
                 keywordService.updateById(keyword);
 
                 //更新提问词状态为取消
-                questionService.update(new LambdaUpdateWrapper<Question>().eq(Question::getKeyword_id, keywordId).isNull(Question::getResponse).set(Question::getStatus, "cancelled"));
+                questionService.update(new LambdaUpdateWrapper<Question>().eq(Question::getKeyword_id, keywordId).isNull(Question::getResponse).set(Question::getStatus, "cancelled").set(Question::getError, "任务已取消"));
+//        将所有提问词设置eroor为已取消
+//                questionService.update(new LambdaUpdateWrapper<Question>().eq(Question::getKeyword_id, keywordId).set(Question::getStatus, "failed").set(Question::getError, "任务已取消"));
 
                 // 更新订单状态
                 String orderId = keyword.getOrder_id();
@@ -1247,7 +1249,7 @@
             log.warn("引用核心字段为空,跳过映射:{}", ref);
             return;
         }
-        String key = ref.getTitle() + "|" + ref.getUrl() + "|" + ref.getDomain();
+        String key = ref.getQuestion_id() + "|" + ref.getTitle() + "|" + ref.getUrl() + "|" + ref.getDomain();
         map.computeIfAbsent(key, k -> new ArrayList<>()).add(ref);
     }
 
@@ -1315,6 +1317,11 @@
             } else if (userResult.getError().contains("信息错误")) {
                 userWrapper.set(User::getStatus, "信息错误");
                 userService.update(userWrapper);
+                // 批量更新问题状态为失败
+                questionService.update(new LambdaUpdateWrapper<Question>()
+                        .eq(Question::getKeyword_id, keyword.getKeyword_id())
+                        .set(Question::getStatus, "failed")
+                        .set(Question::getError, "账户信息错误"));
             }
         }
     }

--
Gitblit v1.7.1