日志

leo.li

2024-09-06 99359ca7265f9872d5b91686bd38a11df7cd723e

日志

 src/main/java/com/jw/ai/service/impl/TaskServiceImpl.java

@@ -336,6 +336,7 @@
                    } else {
                        if (task.getPyScript().contains(Constant.profile_prefix)) {
                            execPyTask(task, secId);
                            break;
                        }
                    }
                }
@@ -546,8 +547,10 @@
            // 4.如果任务执行完成后待完善粉丝数量 > 0 需要重复执行完善脚本
            if (!CollectionUtil.isEmpty(demandUserProfile)) {
                Set<Map.Entry<Long, String>> entrySet = demandUserProfile.entrySet();
                log.info("当前执行的需求数 {}",entrySet.size());
                for (Map.Entry<Long, String> obj : entrySet) {
                    Long demandId = obj.getKey();
                    log.info("当前执行的需求 {}",demandId);
                    String script = obj.getValue();
                    int count = baseMapper.countUpdateProfile(demandId);
                    String key = String.format(Constant.DEMAND_UPDATE_USER_PROFILE, demandId, script);