From 716a8e866af8df060ae2897a890f191174a08d37 Mon Sep 17 00:00:00 2001
From: guyue <1721849008@qq.com>
Date: 星期一, 14 七月 2025 14:43:17 +0800
Subject: [PATCH] 修改取消任务已有数据的提问词状态
---
src/main/java/com/linghu/controller/CollectController.java | 4 ++--
src/main/java/com/linghu/controller/OrderController.java | 2 +-
src/main/java/com/linghu/controller/QuestionController.java | 15 +++++++++++++--
3 files changed, 16 insertions(+), 5 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/OrderController.java b/src/main/java/com/linghu/controller/OrderController.java
index 9e8922c..1972832 100644
--- a/src/main/java/com/linghu/controller/OrderController.java
+++ b/src/main/java/com/linghu/controller/OrderController.java
@@ -179,7 +179,7 @@
// 添加查询条件
if (clientName != null && !clientName.trim().isEmpty()) {
- queryWrapper.like(Orders::getClient_name, clientName);
+ queryWrapper.eq(Orders::getClient_name, clientName);
}
if (status != null) {
queryWrapper.eq(Orders::getStatus, status);
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();
--
Gitblit v1.7.1