| | |
|---|
| | | |
|---|
| | | // 将新的任务请求加入队列 |
|---|
| | | 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(); |
|---|
| | |
|---|
| | | KeywordTask keywordTask = new KeywordTask(); |
|---|
| | | keywordTask.setKeyword_id(keywordId); |
|---|
| | | keywordTask.setTask_id(null); // 任务ID为空 |
|---|
| | | keywordTask.setCreate_time(new Date()); |
|---|
| | | keywordTask.setCreate_time( LocalDateTime.now()); |
|---|
| | | |
|---|
| | | keywordTask.setNum(keyword.getNum()); |
|---|
| | | keywordTaskService.save(keywordTask); // 保存 KeywordTask |
|---|
| | |
|---|
| | | //更新关键词状态 |
|---|
| | | 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()) |
|---|
