From 8e0decd25b9ec86b02d58de53dee1451f83d1566 Mon Sep 17 00:00:00 2001
From: huliguo <2023611923@qq.com>
Date: 星期四, 10 七月 2025 23:48:35 +0800
Subject: [PATCH] 新增

---
 src/main/java/com/linghu/controller/QuestionController.java |   84 ++++++++++++++++++++++--------------------
 1 files changed, 44 insertions(+), 40 deletions(-)

diff --git a/src/main/java/com/linghu/controller/QuestionController.java b/src/main/java/com/linghu/controller/QuestionController.java
index 5b6732f..be640e1 100644
--- a/src/main/java/com/linghu/controller/QuestionController.java
+++ b/src/main/java/com/linghu/controller/QuestionController.java
@@ -2,6 +2,7 @@
 
 import com.alibaba.excel.EasyExcel;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.linghu.listener.QuestionExcelListener;
 import com.linghu.model.common.ResponseResult;
@@ -27,6 +28,8 @@
 import java.util.List;
 import java.util.Objects;
 import java.util.stream.Collectors;
+
+import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;
 
 @RestController
 @RequestMapping("/question")
@@ -74,57 +77,58 @@
     @ApiOperation(value = "修改提问词")
     @Transactional
     public ResponseResult<List<Question>> update(@RequestBody KeywordDto keywordDto) {
-        if (!"notSubmitted".equals(keywordDto.getStatus() )){
-            return ResponseResult.error("该关键词已提交或者已采集完成不允许修改提问词!");
+        //查询question的状态
+       //遍历
+        for (Question q : keywordDto.getQuestionList()) {
+            if ("success".equals(q.getStatus())) {
+                return ResponseResult.error("该提问词已采集");
+            }
         }
-        LambdaQueryWrapper<Question> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.eq(Question::getKeyword_id, keywordDto.getKeyword_id());
-        questionService.remove(queryWrapper);
+         questionService.updateBatchById(keywordDto.getQuestionList());
 
-        List<Question> questionList = Arrays.stream(keywordDto.getQuestions().split("\\n"))
-                .filter(q -> !q.trim().isEmpty())
-                .map(q -> {
-                    Question question = new Question();
-                    question.setKeyword_id(keywordDto.getKeyword_id());
-                    question.setQuestion(q.trim());
-                    question.setStatus("pending");
+//        if (!"notSubmitted".equals(keywordDto.getStatus() )){
+//            return ResponseResult.error("该关键词已提交或者已采集完成不允许修改提问词!");
+//        }
+//        LambdaQueryWrapper<Question> queryWrapper = new LambdaQueryWrapper<>();
+//        queryWrapper.eq(Question::getKeyword_id, keywordDto.getKeyword_id());
+//        questionService.remove(queryWrapper);
 
-                    return question;
-                }).collect(Collectors.toList());
+//        List<Question> questionList = Arrays.stream(keywordDto.getQuestions().split("\\n"))
+//                .filter(q -> !q.trim().isEmpty())
+//                .map(q -> {
+//                    Question question = new Question();
+//                    question.setKeyword_id(keywordDto.getKeyword_id());
+//                    question.setQuestion(q.trim());
+//                    question.setStatus("pending");
+//
+//                    return question;
+//                }).collect(Collectors.toList());
 
-         questionService.saveBatch(questionList);
+//         questionService.saveBatch(questionList);
 
          return ResponseResult.success();
 
 
     }
 
-//    @PutMapping
-//    @ApiOperation(value = "修改提问词")
-//    public ResponseResult<Void> update(@RequestBody Question questions) {
-//        boolean success = questionService.updateById(questions);
-//        if (success) {
-//            return ResponseResult.success();
-//        }
-//        return ResponseResult.error("更新提问词失败");
-//    }
+    @PutMapping("/update")
+    @ApiOperation(value = "修改单个提问词")
+    public ResponseResult<Void> update(@RequestBody Question questions) {
+        boolean success = questionService.updateById(questions);
+        if (success) {
+            return ResponseResult.success();
+        }
+        return ResponseResult.error("更新提问词失败");
+    }
 
-    // @DeleteMapping("/batch")
-    // @Transactional
-    // public ResponseResult<Void> batchDelete(@RequestBody List<Integer>
-    // questionIds) {
-    // List<Question> questions = questionIds.stream().map(id -> {
-    // Question question = new Question();
-    // question.setQuestion_id(id);
-    // return question;
-    // }).collect(Collectors.toList());
-
-    // boolean success = questionService.updateBatchById(questions);
-    // if (success) {
-    // return ResponseResult.success();
-    // }
-    // return ResponseResult.error("批量删除提问词失败");
-    // }
+     @DeleteMapping("/batch")
+     @Transactional
+     @ApiOperation(value = "批量删除提问词")
+     public ResponseResult<Void> batchDelete(@RequestBody List<Integer> questionIds) {
+         System.out.println(questionIds.toString());
+        questionService.removeByIds(questionIds);
+        return ResponseResult.success();
+     }
 
     @GetMapping("/list")
     @ApiOperation("根据关键词查询提问词列表")

--
Gitblit v1.7.1