diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/service/statistics/StatisticsService.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/service/statistics/StatisticsService.java index b76d537..fcc9cb6 100644 --- a/cl_query_data_job/src/main/java/com/bfd/mf/job/service/statistics/StatisticsService.java +++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/service/statistics/StatisticsService.java @@ -62,20 +62,20 @@ public class StatisticsService { LOGGER.info("Statistics Task, took:{} ms.",(end - start)); //-------统计每个专题的量------------------------------------------------------------------------------------ -// start = System.currentTimeMillis(); -// // 如果是正常任务的,用这种方式统计 -// List subjectIds = subjectRepository.findAllSubjectIds(); -// for (BigInteger subjectId: subjectIds) { -// statisticsSubjectBySumTask(subjectId); -// } -// end = System.currentTimeMillis(); -// LOGGER.info("Statistics Subject Normal, took:{} ms.",(end - start)); -// // 如果是【欧莱雅】任务的,得用这个方式统计呀 -// start = System.currentTimeMillis(); -// List subjectIds1 = subjectRepository.findAllOlySubjectIds(); -// for (BigInteger subjectId: subjectIds1) { -// statisticsSubject(subjectId,clusterName); -// } + start = System.currentTimeMillis(); + // 如果是正常任务的,用这种方式统计 + List subjectIds = subjectRepository.findAllSubjectIds(); + for (BigInteger subjectId: subjectIds) { + statisticsSubjectBySumTask(subjectId); + } + end = System.currentTimeMillis(); + LOGGER.info("Statistics Subject Normal, took:{} ms.",(end - start)); + // 如果是【欧莱雅】任务的,得用这个方式统计呀 + start = System.currentTimeMillis(); + List subjectIds1 = subjectRepository.findAllOlySubjectIds(); + for (BigInteger subjectId: subjectIds1) { + statisticsSubject(subjectId,clusterName); + } end = System.currentTimeMillis(); LOGGER.info("Statistics Subject OLY, took:{} ms.",(end - start));