From 307bc98d632594a5081d1bf21b392277df2b6893 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期五, 28 二月 2025 18:32:55 +0800
Subject: [PATCH] 运营加入 房屋和房屋明细功能

---
 service-user/src/main/java/com/java110/user/bmo/owner/impl/QueryOwnerStatisticsBMOImpl.java |   73 ++++++++++++++++++++++++++++++++++++
 1 files changed, 73 insertions(+), 0 deletions(-)

diff --git a/service-user/src/main/java/com/java110/user/bmo/owner/impl/QueryOwnerStatisticsBMOImpl.java b/service-user/src/main/java/com/java110/user/bmo/owner/impl/QueryOwnerStatisticsBMOImpl.java
index f767b11..74c79f9 100644
--- a/service-user/src/main/java/com/java110/user/bmo/owner/impl/QueryOwnerStatisticsBMOImpl.java
+++ b/service-user/src/main/java/com/java110/user/bmo/owner/impl/QueryOwnerStatisticsBMOImpl.java
@@ -1,6 +1,9 @@
 package com.java110.user.bmo.owner.impl;
 
+import com.java110.dto.community.CommunityDto;
 import com.java110.dto.owner.OwnerDto;
+import com.java110.dto.room.RoomDto;
+import com.java110.intf.community.ICommunityV1InnerServiceSMO;
 import com.java110.intf.store.IComplaintV1InnerServiceSMO;
 import com.java110.intf.community.IRepairPoolV1InnerServiceSMO;
 import com.java110.intf.report.IReportOweFeeInnerServiceSMO;
@@ -45,6 +48,9 @@
     @Autowired
     private IContractInnerServiceSMO contractInnerServiceSMOImpl;
 
+    @Autowired
+    private ICommunityV1InnerServiceSMO communityV1InnerServiceSMOImpl;
+
     @Override
     public List<OwnerDto> query(List<OwnerDto> ownerDtos) {
 
@@ -65,6 +71,53 @@
             memberIds.add(ownerDto.getMemberId());
         }
 
+
+        // 鏌ヨ 鎴垮眿鏁伴噺
+        queryRoomCount(ownerIds, ownerDtos);
+
+        // 鏌ヨ 瀹跺涵鎴愬憳鏁�
+        queryOwnerMemberCount(ownerIds, ownerDtos);
+
+        // 鏌ヨ 杞﹁締鏁�
+        queryCarCount(memberIds, ownerDtos);
+
+        // 鏌ヨ 鎶曡瘔鏁�
+        //queryComplaintCount(ownerTels,ownerDtos);
+
+        // 鏌ヨ 鎶ヤ慨鏁�
+        //queryRepairCount(ownerTels,ownerDtos);
+
+        // 鏌ヨ涓氫富娆犺垂
+        queryOwnerOweFee(ownerIds, ownerDtos);
+
+        // 鏌ヨ涓氫富鍚堝悓
+        //queryOwnerContractCount(ownerIds,ownerDtos);
+
+        return ownerDtos;
+    }
+
+    @Override
+    public List<OwnerDto> queryAdminData(List<OwnerDto> ownerDtos) {
+        if (ListUtil.isNull(ownerDtos)) {
+            return ownerDtos;
+        }
+
+        //杩欓噷闄愬埗琛屾暟锛屼互鍏嶅奖鍝嶇郴缁熸�ц兘
+        if (ownerDtos.size() > MAX_LINE_COUNT) {
+            return ownerDtos;
+        }
+        List<String> ownerIds = new ArrayList<>();
+        List<String> memberIds = new ArrayList<>();
+        List<String> ownerTels = new ArrayList<>();
+        List<String> communityIds = new ArrayList<>();
+        for (OwnerDto ownerDto : ownerDtos) {
+            ownerIds.add(ownerDto.getOwnerId());
+            ownerTels.add(ownerDto.getLink());
+            memberIds.add(ownerDto.getMemberId());
+            communityIds.add(ownerDto.getCommunityId());
+        }
+// 鏌ヨ灏忓尯鍚嶇О
+        queryCommunityName(communityIds,ownerDtos);
 
         // 鏌ヨ 鎴垮眿鏁伴噺
         queryRoomCount(ownerIds, ownerDtos);
@@ -240,4 +293,24 @@
             }
         }
     }
+
+    private void queryCommunityName(List<String> communityIds, List<OwnerDto> ownerDtos) {
+        if(ListUtil.isNull(communityIds)){
+            return ;
+        }
+        CommunityDto communityDto = new CommunityDto();
+        communityDto.setCommunityIds(communityIds.toArray(new String[communityIds.size()]));
+        List<CommunityDto> communityDtos = communityV1InnerServiceSMOImpl.queryCommunitys(communityDto);
+        if(ListUtil.isNull(communityDtos)){
+            return;
+        }
+        for (OwnerDto tmpOwnerDto : ownerDtos) {
+            for (CommunityDto tCommunityDto : communityDtos) {
+                if (!tmpOwnerDto.getCommunityId().equals(tCommunityDto.getCommunityId())) {
+                    continue;
+                }
+                tmpOwnerDto.setCommunityName(tCommunityDto.getName());
+            }
+        }
+    }
 }

--
Gitblit v1.8.0