From c9ab412c787f478d7689bb5c0aaad7478887a1b7 Mon Sep 17 00:00:00 2001
From: guyue <1721849008@qq.com>
Date: 星期五, 05 九月 2025 14:05:33 +0800
Subject: [PATCH] 平台筛选2
---
src/main/java/com/linghu/service/impl/CollectionServiceImpl.java | 9 +++++++--
1 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/linghu/service/impl/CollectionServiceImpl.java b/src/main/java/com/linghu/service/impl/CollectionServiceImpl.java
index 325a4c1..772a0c1 100644
--- a/src/main/java/com/linghu/service/impl/CollectionServiceImpl.java
+++ b/src/main/java/com/linghu/service/impl/CollectionServiceImpl.java
@@ -84,7 +84,12 @@
// 将新的任务请求加入队列
taskQueue.add(searchTaskRequest);
+ //更新状态为采集中
+ LambdaUpdateWrapper<Keyword> updateWrapper = new LambdaUpdateWrapper<>();
+ updateWrapper.eq(Keyword::getKeyword_id, searchTaskRequest.getKeyword_id());
+ updateWrapper.set(Keyword::getStatus, FinalStatus.SUBMITTED.getValue());
+ keywordService.update(updateWrapper);
// 如果当前没有任务在处理中，则启动任务队列的处理
if (!isProcessing) {
processNextTaskInQueue();
@@ -396,6 +401,7 @@
KeywordTask keywordTask = new KeywordTask();
keywordTask.setKeyword_id(keywordId);
keywordTask.setTask_id(null); // 任务ID为空
+ keywordTask.setCreate_time( LocalDateTime.now());
keywordTask.setNum(keyword.getNum());
keywordTaskService.save(keywordTask); // 保存 KeywordTask
@@ -438,13 +444,12 @@
//更新关键词状态
LambdaUpdateWrapper<Keyword> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.eq(Keyword::getKeyword_id, batchRequest.getKeyword_id());
- updateWrapper.set(Keyword::getStatus, FinalStatus.COMPLETED.getValue());
updateWrapper.set(Keyword::getTask_id, taskResponse.getTask_id());
keywordService.update(updateWrapper);
//设置轮数
Keyword keyword = keywordService.getById(batchRequest.getKeyword_id());
// 更新关键词任务与任务ID的关联
- // 获取与关键词相关的任务，task_id 为 null，确保只取一个任务
+ // 获取与关键词相关的任务
List<KeywordTask> keywordTasks = keywordTaskService.list(new LambdaQueryWrapper<KeywordTask>()
.eq(KeywordTask::getKeyword_id, keyword.getKeyword_id())
.eq(KeywordTask::getNum, keyword.getNum())
--
Gitblit v1.7.1