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;
|
import com.java110.intf.store.IContractInnerServiceSMO;
|
import com.java110.intf.user.IOwnerCarV1InnerServiceSMO;
|
import com.java110.intf.user.IOwnerRoomRelV1InnerServiceSMO;
|
import com.java110.intf.user.IOwnerV1InnerServiceSMO;
|
import com.java110.user.bmo.owner.IQueryOwnerStatisticsBMO;
|
import com.java110.utils.util.ListUtil;
|
import com.java110.utils.util.StringUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class QueryOwnerStatisticsBMOImpl implements IQueryOwnerStatisticsBMO {
|
|
public static final int MAX_LINE_COUNT = 15;
|
|
@Autowired
|
private IOwnerRoomRelV1InnerServiceSMO ownerRoomRelV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerCarV1InnerServiceSMO ownerCarV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IComplaintV1InnerServiceSMO complaintV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IRepairPoolV1InnerServiceSMO repairPoolV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IReportOweFeeInnerServiceSMO reportOweFeeInnerServiceSMOImpl;
|
|
@Autowired
|
private IContractInnerServiceSMO contractInnerServiceSMOImpl;
|
|
@Autowired
|
private ICommunityV1InnerServiceSMO communityV1InnerServiceSMOImpl;
|
|
@Override
|
public List<OwnerDto> query(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<>();
|
for (OwnerDto ownerDto : ownerDtos) {
|
ownerIds.add(ownerDto.getOwnerId());
|
ownerTels.add(ownerDto.getLink());
|
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);
|
|
// 查询 家庭成员数
|
queryOwnerMemberCount(ownerIds, ownerDtos);
|
|
// 查询 车辆数
|
queryCarCount(memberIds, ownerDtos);
|
|
// 查询 投诉数
|
//queryComplaintCount(ownerTels,ownerDtos);
|
|
// 查询 报修数
|
//queryRepairCount(ownerTels,ownerDtos);
|
|
// 查询业主欠费
|
queryOwnerOweFee(ownerIds, ownerDtos);
|
|
// 查询业主合同
|
//queryOwnerContractCount(ownerIds,ownerDtos);
|
|
return ownerDtos;
|
}
|
|
private void queryOwnerContractCount(List<String> ownerIds, List<OwnerDto> ownerDtos) {
|
Map info = new HashMap();
|
info.put("communityId", ownerDtos.get(0).getCommunityId());
|
info.put("ownerIds", ownerIds.toArray(new String[ownerIds.size()]));
|
List<Map> contractsCount = contractInnerServiceSMOImpl.queryContractsByOwnerIds(info);
|
|
for (OwnerDto ownerDto : ownerDtos) {
|
for (Map count : contractsCount) {
|
if (ownerDto.getOwnerId().equals(count.get("ownerId"))) {
|
ownerDto.setContractCount(count.get("contractCount").toString());
|
}
|
}
|
}
|
}
|
|
/**
|
* 查询业主欠费
|
*
|
* @param ownerIds
|
* @param ownerDtos
|
*/
|
private void queryOwnerOweFee(List<String> ownerIds, List<OwnerDto> ownerDtos) {
|
Map info = new HashMap();
|
info.put("communityId", ownerDtos.get(0).getCommunityId());
|
info.put("ownerIds", ownerIds.toArray(new String[ownerIds.size()]));
|
List<Map> repairCounts = reportOweFeeInnerServiceSMOImpl.queryOweFeesByOwnerIds(info);
|
|
for (OwnerDto ownerDto : ownerDtos) {
|
for (Map count : repairCounts) {
|
if (ownerDto.getOwnerId().equals(count.get("ownerId"))) {
|
ownerDto.setOweFee(count.get("oweFee").toString());
|
}
|
}
|
}
|
}
|
|
|
/**
|
* 查询业主投诉数
|
*
|
* @param ownerTels
|
* @param ownerDtos
|
*/
|
private void queryRepairCount(List<String> ownerTels, List<OwnerDto> ownerDtos) {
|
|
|
Map info = new HashMap();
|
info.put("communityId", ownerDtos.get(0).getCommunityId());
|
info.put("ownerTels", ownerTels.toArray(new String[ownerTels.size()]));
|
List<Map> repairCounts = repairPoolV1InnerServiceSMOImpl.queryRepairCountByOwnerTels(info);
|
|
for (OwnerDto ownerDto : ownerDtos) {
|
for (Map count : repairCounts) {
|
if (ownerDto.getLink().equals(count.get("ownerTel"))) {
|
ownerDto.setRepairCount(count.get("repairCount").toString());
|
}
|
}
|
}
|
}
|
|
/**
|
* 查询业主投诉数
|
*
|
* @param ownerTels
|
* @param ownerDtos
|
*/
|
private void queryComplaintCount(List<String> ownerTels, List<OwnerDto> ownerDtos) {
|
|
|
Map info = new HashMap();
|
info.put("communityId", ownerDtos.get(0).getCommunityId());
|
info.put("ownerTels", ownerTels.toArray(new String[ownerTels.size()]));
|
List<Map> complaintCounts = complaintV1InnerServiceSMOImpl.queryComplaintCountByOwnerTels(info);
|
|
for (OwnerDto ownerDto : ownerDtos) {
|
for (Map count : complaintCounts) {
|
if (ownerDto.getLink().equals(count.get("ownerTel"))) {
|
ownerDto.setComplaintCount(count.get("complaintCount").toString());
|
}
|
}
|
}
|
}
|
|
/**
|
* 查询业主车辆数
|
*
|
* @param memberIds
|
* @param ownerDtos
|
*/
|
private void queryCarCount(List<String> memberIds, List<OwnerDto> ownerDtos) {
|
|
List<Map> memberCounts = ownerCarV1InnerServiceSMOImpl.queryOwnerCarCountByOwnerIds(memberIds);
|
|
for (OwnerDto ownerDto : ownerDtos) {
|
for (Map count : memberCounts) {
|
if (ownerDto.getMemberId().equals(count.get("ownerId"))) {
|
ownerDto.setCarCount(count.get("carCount").toString());
|
}
|
}
|
}
|
}
|
|
/**
|
* 查询 业主成员数
|
*
|
* @param ownerIds
|
* @param ownerDtos
|
*/
|
private void queryOwnerMemberCount(List<String> ownerIds, List<OwnerDto> ownerDtos) {
|
|
List<Map> memberCounts = ownerV1InnerServiceSMOImpl.queryOwnerMembersCount(ownerIds);
|
|
for (OwnerDto ownerDto : ownerDtos) {
|
if (OwnerDto.OWNER_TYPE_CD_MEMBER.equals(ownerDto.getOwnerTypeCd())) {
|
ownerDto.setMemberCount("0");
|
continue;
|
}
|
for (Map count : memberCounts) {
|
if (ownerDto.getOwnerId().equals(count.get("ownerId"))) {
|
ownerDto.setMemberCount(count.get("memberCount").toString());
|
}
|
}
|
}
|
}
|
|
/**
|
* 查询 房屋数量
|
*
|
* @param ownerIds
|
* @param ownerDtos
|
*/
|
private void queryRoomCount(List<String> ownerIds, List<OwnerDto> ownerDtos) {
|
|
//查询业主房屋数
|
List<Map> ownerRoomCounts = ownerRoomRelV1InnerServiceSMOImpl.queryRoomCountByOwnerIds(ownerIds);
|
|
for (OwnerDto ownerDto : ownerDtos) {
|
for (Map count : ownerRoomCounts) {
|
if (StringUtil.isEmpty(ownerDto.getOwnerId())) {
|
continue;
|
}
|
if (StringUtil.isEmpty(count.get("ownerId").toString())) {
|
continue;
|
}
|
if (ownerDto.getOwnerId().equals(count.get("ownerId").toString())) {
|
ownerDto.setRoomCount(count.get("roomCount").toString());
|
}
|
}
|
}
|
}
|
|
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());
|
}
|
}
|
}
|
}
|
