From 481100011ee1f6e324b2ac2d0f3ee056b1d31d2e Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期四, 14 一月 2021 22:44:53 +0800
Subject: [PATCH] 优化代码

---
 service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java |   28 +++++++++++++++-------------
 1 files changed, 15 insertions(+), 13 deletions(-)

diff --git a/service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java b/service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java
index a8247c7..a583271 100644
--- a/service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java
+++ b/service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java
@@ -183,18 +183,20 @@
         }
         //鏌ヨ璐圭敤淇℃伅arrearsEndTime
         List<RoomDto> tmpRoomDtos = new ArrayList<>();
-        List<RoomDto> tempRooms = new ArrayList<>();
+        //List<RoomDto> tempRooms = new ArrayList<>();
         int threadNum = Java110ThreadPoolFactory.JAVA110_DEFAULT_THREAD_NUM;
-        for (int roomIndex = 0; roomIndex < roomDtos.size(); roomIndex++) {
-            tempRooms.add(roomDtos.get(roomIndex));
-            if (roomIndex % threadNum == 0 && roomIndex != 0) {
-                tmpRoomDtos.addAll(doGetTmpRoomDto(tempRooms, feeDto, threadNum));
-                tempRooms = new ArrayList();
-            }
-        }
-        if (tempRooms.size() > 0) {
-            tmpRoomDtos.addAll(doGetTmpRoomDto(tempRooms, feeDto, tempRooms.size()));
-        }
+        //for (int roomIndex = 0; roomIndex < roomDtos.size(); roomIndex++) {
+        // tempRooms.add(roomDtos.get(roomIndex));
+        //if (roomIndex % threadNum == 0 && roomIndex != 0) {
+        //    tmpRoomDtos.addAll(doGetTmpRoomDto(tempRooms, feeDto, threadNum));
+        //   tempRooms = new ArrayList();
+        // }
+        // }
+//        if (tempRooms.size() > 0) {
+//            tmpRoomDtos.addAll(doGetTmpRoomDto(tempRooms, feeDto, tempRooms.size()));
+//        }
+
+        tmpRoomDtos.addAll(doGetTmpRoomDto(roomDtos, feeDto, threadNum));
 
         return ResultVo.createResponseEntity(tmpRoomDtos);
     }
@@ -209,8 +211,8 @@
                 });
             }
             return java110ThreadPoolFactory.get();
-        }finally {
-            if(java110ThreadPoolFactory != null){
+        } finally {
+            if (java110ThreadPoolFactory != null) {
                 java110ThreadPoolFactory.stop();
             }
         }

--
Gitblit v1.8.0