From 9f793729979a08e4c7e45b030ef85cfcbf9fc4d1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=9C=E9=9D=99?= Date: Fri, 13 Aug 2021 10:58:52 +0800 Subject: [PATCH] =?UTF-8?q?release-3.1.3(20210813,=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E4=BA=86=20=E6=96=B0=E5=A2=9E=E7=AB=99=E7=82=B9=20linkedin=20?= =?UTF-8?q?=E5=92=8C=20ins=20=E6=9F=A5=E8=AF=A2=E8=AF=A6=E6=83=85=E7=9A=84?= =?UTF-8?q?=E6=97=B6=E5=80=99=20=E6=A0=87=E9=A2=98=E4=B8=8D=E5=B1=95?= =?UTF-8?q?=E7=A4=BA=20author=20=E7=9A=84=E9=97=AE=E9=A2=98=E3=80=82?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=BA=86=20=E7=A6=BB=E7=BA=BF=E7=BB=9F?= =?UTF-8?q?=E8=AE=A1=20=E7=BB=9F=E8=AE=A1=E7=9A=84=E6=97=B6=E5=80=99?= =?UTF-8?q?=E4=BC=9A=E5=B0=86=E7=B2=89=E4=B8=9D=E6=95=B0=E4=B9=9F=E4=B8=80?= =?UTF-8?q?=E8=B5=B7=E7=BB=9F=E8=AE=A1=EF=BC=8C=E4=BB=8E=E8=80=8C=E5=AF=BC?= =?UTF-8?q?=E8=87=B4task=20=E7=9A=84=E7=BB=9F=E8=AE=A1=E7=BB=93=E6=9E=9C?= =?UTF-8?q?=E8=B7=9F=E6=9F=A5=E8=AF=A2=E7=BB=93=E6=9E=9C=E4=B8=8D=E7=9B=B8?= =?UTF-8?q?=E7=AC=A6)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/service/statistics/StatisticsService.java | 28 +++++++++++----------- 1 file changed, 14 insertions(+), 14 deletions(-) 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));