From 693f70da11701e777203e263d7da41abb648dd0f Mon Sep 17 00:00:00 2001
From: guyue <1721849008@qq.com>
Date: 星期三, 16 七月 2025 20:16:29 +0800
Subject: [PATCH] 对比采集，实时状态
---
src/main/java/com/linghu/controller/CollectController.java | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/linghu/controller/CollectController.java b/src/main/java/com/linghu/controller/CollectController.java
index f1ae783..629e9c0 100644
--- a/src/main/java/com/linghu/controller/CollectController.java
+++ b/src/main/java/com/linghu/controller/CollectController.java
@@ -141,7 +141,7 @@
// ... 原有逻辑 ...
int maxConcurrentUsers = searchTaskRequest.getConfig() != null ?
searchTaskRequest.getConfig().getMax_concurrent_users() : 3;
- List<List<UserDto>> userBatches = splitUsersIntoBatches(searchTaskRequest.getUsers(), maxConcurrentUsers, keywordId);
+ List<List<UserDto>> userBatches = splitUsersIntoBatches(searchTaskRequest.getUsers(), maxConcurrentUsers, keywordId,searchTaskRequest.getIs_first());
// 创建批次队列并存入全局映射
@@ -368,13 +368,14 @@
// .then();
// }
- private List<List<UserDto>> splitUsersIntoBatches(List<UserDto> users, int batchSize,Integer keywordId) {
+ private List<List<UserDto>> splitUsersIntoBatches(List<UserDto> users, int batchSize,Integer keywordId,Boolean isFirst) {
Keyword keyword = keywordService.getById(keywordId);
- if (null==keyword.getNum()){
- keyword.setNum(0);
+ if (isFirst){
+ keyword.setNum(1);
+ }else {
+ keyword.setNum(keyword.getNum()+1);
}
- keyword.setNum(keyword.getNum()+1);
keywordService.updateById(keyword);
List<List<UserDto>> batches = new ArrayList<>();
--
Gitblit v1.7.1