|
@ -62,20 +62,20 @@ public class StatisticsService { |
|
|
LOGGER.info("Statistics Task, took:{} ms.",(end - start)); |
|
|
LOGGER.info("Statistics Task, took:{} ms.",(end - start)); |
|
|
|
|
|
|
|
|
//-------统计每个专题的量------------------------------------------------------------------------------------ |
|
|
//-------统计每个专题的量------------------------------------------------------------------------------------ |
|
|
// start = System.currentTimeMillis(); |
|
|
|
|
|
// // 如果是正常任务的,用这种方式统计 |
|
|
|
|
|
// List<BigInteger> 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<BigInteger> subjectIds1 = subjectRepository.findAllOlySubjectIds(); |
|
|
|
|
|
// for (BigInteger subjectId: subjectIds1) { |
|
|
|
|
|
// statisticsSubject(subjectId,clusterName); |
|
|
|
|
|
// } |
|
|
|
|
|
|
|
|
start = System.currentTimeMillis(); |
|
|
|
|
|
// 如果是正常任务的,用这种方式统计 |
|
|
|
|
|
List<BigInteger> 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<BigInteger> subjectIds1 = subjectRepository.findAllOlySubjectIds(); |
|
|
|
|
|
for (BigInteger subjectId: subjectIds1) { |
|
|
|
|
|
statisticsSubject(subjectId,clusterName); |
|
|
|
|
|
} |
|
|
end = System.currentTimeMillis(); |
|
|
end = System.currentTimeMillis(); |
|
|
LOGGER.info("Statistics Subject OLY, took:{} ms.",(end - start)); |
|
|
LOGGER.info("Statistics Subject OLY, took:{} ms.",(end - start)); |
|
|
|
|
|
|
|
|