对比采集，实时状态

guyue

2025-07-16 693f70da11701e777203e263d7da41abb648dd0f

 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);
        }
        keywordService.updateById(keyword);

        List<List<UserDto>> batches = new ArrayList<>();