From 23ac3e4f8fb16db0759ba5c91c4d06d622c67009 Mon Sep 17 00:00:00 2001
From: huliguo <2023611923@qq.com>
Date: 星期一, 14 七月 2025 14:49:34 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 src/main/java/com/linghu/controller/CollectController.java  |    4 ++--
 src/main/java/com/linghu/controller/UserController.java     |    4 ++--
 src/main/java/com/linghu/controller/QuestionController.java |   15 +++++++++++++--
 3 files changed, 17 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/linghu/controller/CollectController.java b/src/main/java/com/linghu/controller/CollectController.java
index f435bea..1ad4f89 100644
--- a/src/main/java/com/linghu/controller/CollectController.java
+++ b/src/main/java/com/linghu/controller/CollectController.java
@@ -642,13 +642,13 @@
 //                if (keywordTasks.stream().allMatch(task ->
 //                        "completed".equals(task.getStatus()) || "false".equals(task.getStatus()) || "canceled".equals(task.getStatus())
 //                )) {
-                    keyword.setStatus("canceled");
+//                    keyword.setStatus("canceled");
                     keywordService.updateById(keyword);
 //                    log.info("关键词 {} 所有任务已完成,更新状态为 completed", keywordId);
 //                }
                 //更新提问词状态为取消
 
-                questionService.update(new LambdaUpdateWrapper<Question>().eq(Question::getKeyword_id, keywordId).set(Question::getStatus, "canceled"));
+                questionService.update(new LambdaUpdateWrapper<Question>().eq(Question::getKeyword_id, keywordId).isNull(Question::getResponse).set(Question::getStatus, "canceled"));
 
                 // 更新订单状态
                 String orderId = keyword.getOrder_id();
diff --git a/src/main/java/com/linghu/controller/QuestionController.java b/src/main/java/com/linghu/controller/QuestionController.java
index 0d90313..97f50e0 100644
--- a/src/main/java/com/linghu/controller/QuestionController.java
+++ b/src/main/java/com/linghu/controller/QuestionController.java
@@ -80,8 +80,8 @@
         //查询question的状态
        //遍历
         for (Question q : keywordDto.getQuestionList()) {
-            if ("success".equals(q.getStatus())) {
-                return ResponseResult.error("该提问词已采集");
+            if ("pending".equals(q.getStatus()) || "processing".equals(q.getStatus())) {
+                return ResponseResult.error("有提问词在采集中");
             }
         }
          questionService.updateBatchById(keywordDto.getQuestionList());
@@ -114,6 +114,11 @@
     @PutMapping("/update")
     @ApiOperation(value = "修改单个提问词")
     public ResponseResult<Void> update(@RequestBody Question questions) {
+
+            if ("pending".equals(questions.getStatus()) || "processing".equals(questions.getStatus())) {
+                return ResponseResult.error("该提问词在采集中");
+            }
+
         boolean success = questionService.updateById(questions);
         if (success) {
             return ResponseResult.success();
@@ -125,6 +130,12 @@
      @Transactional
      @ApiOperation(value = "批量删除提问词")
      public ResponseResult<Void> batchDelete(@RequestBody List<Integer> questionIds) {
+        List<Question> questions = questionService.listByIds(questionIds);
+         for (Question q : questions) {
+             if ("pending".equals(q.getStatus()) || "processing".equals(q.getStatus())) {
+                 return ResponseResult.error("有提问词在采集中");
+             }
+         }
          System.out.println(questionIds.toString());
         questionService.removeByIds(questionIds);
         return ResponseResult.success();
diff --git a/src/main/java/com/linghu/controller/UserController.java b/src/main/java/com/linghu/controller/UserController.java
index fc4f197..8b086b9 100644
--- a/src/main/java/com/linghu/controller/UserController.java
+++ b/src/main/java/com/linghu/controller/UserController.java
@@ -57,7 +57,7 @@
     public ResponseResult add(@RequestBody User user) {
         List<User> list = userService.list(new LambdaQueryWrapper<User>().eq(User::getUser_email, user.getUser_email()));
         if (list != null && list.size() > 0) {
-            return ResponseResult.success("该邮箱已存在");
+            return ResponseResult.error("该邮箱已存在");
         }
         user.setStatus("正常");
         userService.save(user);
@@ -80,7 +80,7 @@
                         .ne(User::getUser_id, user.getUser_id())
                 .eq(User::getUser_email, user.getUser_email()));
         if (list != null && list.size() > 0) {
-            return ResponseResult.success("该邮箱已存在");
+            return ResponseResult.error("该邮箱已存在");
         }
         if (!user1.getUser_email().equals(user.getUser_email())||!user1.getPassword().equals(user.getPassword())) {
             user.setStatus("正常");

--
Gitblit v1.7.1