From 8ffe22beae76001d360585fbe8b2bf515a534a34 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期五, 23 二月 2024 18:37:31 +0800
Subject: [PATCH] 优化报表查询慢问题
---
service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeSummaryCmd.java | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeSummaryCmd.java b/service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeSummaryCmd.java
index af1a0f7..fc6fcc6 100644
--- a/service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeSummaryCmd.java
+++ b/service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeSummaryCmd.java
@@ -80,7 +80,7 @@
Java110ThreadPoolFactory java110ThreadPoolFactory = null;
try {
- java110ThreadPoolFactory = Java110ThreadPoolFactory.getInstance().createThreadPool(7);
+ java110ThreadPoolFactory = Java110ThreadPoolFactory.getInstance().createThreadPool(5);
java110ThreadPoolFactory.submit(() -> {
//todo 鏌ヨ鍘嗗彶娆犺垂
double hisOweFee = feeStatisticsImpl.getHisMonthOweFee(queryStatisticsDto);
@@ -127,9 +127,15 @@
//todo 鎴垮眿鏁�
long roomCount = baseDataStatisticsImpl.getRoomCount(queryStatisticsDto);
data.put("roomCount", roomCount);
+ return roomCount;
+ });
+ java110ThreadPoolFactory.submit(() -> {
//todo 鏀惰垂鎴垮眿鏁�
long feeRoomCount = feeStatisticsImpl.getFeeRoomCount(queryStatisticsDto);
data.put("feeRoomCount", feeRoomCount);
+ return feeRoomCount;
+ });
+ java110ThreadPoolFactory.submit(() -> {
//todo 娆犺垂鎴锋暟
int oweRoomCount = feeStatisticsImpl.getOweRoomCount(queryStatisticsDto);
data.put("oweRoomCount", oweRoomCount);
--
Gitblit v1.8.0