package com.ruoyi.web.controller.api;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.system.model.TBill;
|
import com.ruoyi.system.model.TContract;
|
import com.ruoyi.system.model.THouse;
|
import com.ruoyi.system.model.TStreet;
|
import com.ruoyi.system.service.ITStreetService;
|
import com.ruoyi.system.service.TBillService;
|
import com.ruoyi.system.service.TContractService;
|
import com.ruoyi.system.service.THouseService;
|
import com.ruoyi.system.service.impl.ScreenService;
|
import com.ruoyi.system.vo.*;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.math.BigDecimal;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.YearMonth;
|
import java.time.format.DateTimeFormatter;
|
import java.time.temporal.ChronoUnit;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
import static org.checkerframework.checker.units.qual.Prefix.one;
|
|
/**
|
* @author mitao
|
* @date 2025/3/19
|
*/
|
@Api(tags = {"大屏相关接口"})
|
@RestController
|
@RequestMapping("/screen")
|
@RequiredArgsConstructor(onConstructor_ = {@Lazy})
|
public class ScreenController {
|
private final ScreenService screenService;
|
private final TContractService contractService;
|
private final THouseService houseService;
|
private final ITStreetService streetService;
|
private final TBillService billService;
|
|
@GetMapping("/statics-data")
|
@ApiOperation(value = "获取顶部统计数据")
|
public R<ScreenTopStaticsDataVO> getTopStaticsData() {
|
return R.ok(screenService.getTopStaticsData());
|
}
|
|
@GetMapping("/rent-rank")
|
@ApiOperation("区域租金排名")
|
public R<List<ScreenRentRankVO>> rentRank() {
|
return R.ok(screenService.streetRentRank());
|
}
|
|
@GetMapping("/rent-income-trend")
|
@ApiOperation("租金收入趋势")
|
public R<ScreenRentIncomeTrendVO> rentIncomeTrend() {
|
return R.ok(screenService.rentIncomeTrend());
|
}
|
|
|
@GetMapping("/getTenantCountTrend")
|
@ApiOperation(value = "租户数量趋势统计")
|
public R<List<TenantCountTrendVO>> getTenantCountTrend() {
|
return screenService.getTenantCountTrend();
|
}
|
|
|
/**
|
* 实时租赁数据
|
*/
|
@GetMapping("/getRealTimeRentData")
|
@ApiOperation("获取实时租赁数据")
|
public R<List<RealTimeRentDataVO>> getRealTimeRentData() {
|
// 随机获取十条房源
|
String businessDeptId = SecurityUtils.getBusinessDeptId();
|
List<THouse> houses = houseService.list(new LambdaQueryWrapper<THouse>()
|
.eq(!"0".equals(businessDeptId),THouse::getBusinessDeptId, businessDeptId)
|
.last("ORDER BY RAND() LIMIT 10"));
|
|
if (CollectionUtil.isEmpty(houses)){
|
return R.ok(new ArrayList<>());
|
}
|
|
// 提取streetIds
|
List<String> streetIds = houses.stream()
|
.map(THouse::getStreetId)
|
.collect(Collectors.toList());
|
|
// 获取街道信息
|
Map<String, String> streetMap = streetService.listByIds(streetIds).stream()
|
.collect(Collectors.toMap(TStreet::getId, TStreet::getStreetName));
|
|
// 转换为返回格式
|
List<RealTimeRentDataVO> result = houses.stream().map(house -> {
|
RealTimeRentDataVO vo = new RealTimeRentDataVO();
|
vo.setStreetName(streetMap.getOrDefault(house.getStreetId(), "未知"));
|
vo.setRoomName(house.getHouseName());
|
vo.setLeaseStatus(house.getLeaseStatus());
|
return vo;
|
}).collect(Collectors.toList());
|
|
return R.ok(result);
|
}
|
|
|
public static void main(String[] args) {
|
// 获取当前季度的开始和结束时间
|
// 获取当前季度的开始和结束时间的实现示例：
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
LocalDate now = LocalDate.now();
|
int month = now.getMonthValue();
|
int year = now.getYear();
|
|
// 计算季度起始月份（1,4,7,10）
|
int quarterStartMonth = ((month - 1) / 3) * 3 + 1;
|
int quarterEndMonth = quarterStartMonth + 2;
|
// 构建季度起止日期
|
LocalDate quarterStart = YearMonth.of(year, quarterStartMonth).atDay(1);
|
LocalDate quarterEnd = YearMonth.of(year, quarterEndMonth).atEndOfMonth();
|
|
System.out.println("季度开始：" + quarterStart.format(formatter));
|
System.out.println("季度结束：" + quarterEnd.format(formatter));
|
}
|
|
/**
|
* 获取房屋地图分布
|
*/
|
@GetMapping("/getHouseMapDistribution")
|
@ApiOperation("获取房屋地图分布")
|
public R<List<HouseMapDistributionVO>> getHouseMapDistribution() {
|
|
String businessDeptId = SecurityUtils.getBusinessDeptId();
|
|
List<TContract> tContracts = contractService.list(new LambdaQueryWrapper<TContract>()
|
.eq(!"0".equals(businessDeptId), TContract::getBusinessDeptId, businessDeptId)
|
.eq(TContract::getPayType, 2));
|
List<String> houseIds1 = tContracts.stream().map(TContract::getHouseId).collect(Collectors.toList());
|
|
|
// 获取所有房屋信息
|
List<THouse> houses = houseService.list(new LambdaQueryWrapper<THouse>()
|
.and(wrapper -> wrapper.in(!houseIds1.isEmpty(),THouse::getId, houseIds1)
|
.or(!houseIds1.isEmpty())
|
.eq(THouse::getLeaseStatus, "1")
|
)
|
.eq(!"0".equals(businessDeptId),THouse::getBusinessDeptId, businessDeptId)
|
);
|
|
// 建议在循环外批量查询以下数据：
|
// 1. 提前获取所有房屋对应的最新有效合同（按房屋ID分组）
|
Set<String> houseIds = houses.stream().map(THouse::getId).collect(Collectors.toSet());
|
Map<String, TContract> contractMap = contractService.list(new LambdaQueryWrapper<TContract>()
|
.eq(!"0".equals(businessDeptId), TContract::getBusinessDeptId, businessDeptId)
|
.eq(TContract::getPayType, 2)
|
.gt(TContract::getEndTime, LocalDate.now())
|
.in(TContract::getHouseId, houseIds) // 批量查询
|
.eq(TContract::getStatus, 4)
|
.orderByDesc(TContract::getEndTime))
|
.stream()
|
.collect(Collectors.toMap(
|
TContract::getHouseId,
|
c -> c,
|
(existing, replacement) -> existing // 保留最新合同
|
));
|
|
// 2. 提前批量查询所有合同对应的账单（按contractId分组）
|
Set<String> contractIds = contractMap.values().stream()
|
.map(TContract::getId)
|
.collect(Collectors.toSet());
|
Map<String, List<TBill>> billsMap = billService.list(new LambdaQueryWrapper<TBill>()
|
.eq(!"0".equals(businessDeptId), TBill::getBusinessDeptId, businessDeptId)
|
.in(!contractIds.isEmpty(), TBill::getContractId, contractIds)
|
.eq(TBill::getBillType, 1))
|
.stream()
|
.collect(Collectors.groupingBy(TBill::getContractId));
|
|
|
// 3. 季度时间计算提到循环外（所有房屋共用）
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
LocalDate now = LocalDate.now();
|
int month = now.getMonthValue();
|
int quarterStartMonth = ((month - 1) / 3) * 3 + 1;
|
LocalDate quarterStart = YearMonth.of(now.getYear(), quarterStartMonth).atDay(1);
|
LocalDate quarterEnd = YearMonth.of(now.getYear(), quarterStartMonth + 2).atEndOfMonth();
|
|
List<HouseMapDistributionVO> result = new ArrayList<>();
|
for (THouse house : houses) {
|
HouseMapDistributionVO houseMapDistributionVO = new HouseMapDistributionVO();
|
houseMapDistributionVO.setHouseName(house.getHouseName());
|
houseMapDistributionVO.setHouseAddress(house.getHouseAddress());
|
houseMapDistributionVO.setHouseStatus(house.getLeaseStatus());
|
houseMapDistributionVO.setLongitude(house.getLongitude());
|
houseMapDistributionVO.setLatitude(house.getLatitude());
|
|
|
|
TContract contract = contractMap.get(house.getId());
|
|
|
if (contract != null){
|
|
|
List<TBill> tBills = billsMap.getOrDefault(contract.getId(), Collections.emptyList());
|
|
|
houseMapDistributionVO.setTenant(contract.getPartyTwoName());
|
|
BigDecimal payFeesMoney = tBills.stream()
|
.map(TBill::getPayFeesMoney)
|
.reduce(BigDecimal::add)
|
.orElse(BigDecimal.ZERO);
|
|
BigDecimal payableFeesMoney = tBills.stream()
|
.map(TBill::getPayableFeesMoney)
|
.reduce(BigDecimal::add)
|
.orElse(BigDecimal.ZERO);
|
String rentStatus = String.format("%.2f/%.2f", payFeesMoney, payableFeesMoney);
|
houseMapDistributionVO.setRentStatus(rentStatus);
|
|
// 季度账单筛选
|
List<TBill> ones = tBills.stream()
|
.filter(b -> {
|
LocalDate billDate = b.getStartTime().toLocalDate();
|
return !billDate.isBefore(quarterStart) && !billDate.isAfter(quarterEnd);
|
})
|
.collect(Collectors.toList());
|
if (!ones.isEmpty()){
|
|
long count = ones.stream().filter(tBill -> "4".equals(tBill.getPayFeesStatus())).count();
|
if (count > 0){
|
houseMapDistributionVO.setHouseStatus("4");
|
}
|
|
BigDecimal payFeesMoney1 = ones.stream()
|
.map(TBill::getPayFeesMoney)
|
.reduce(BigDecimal::add)
|
.orElse(BigDecimal.ZERO);
|
|
BigDecimal payableFeesMoney1 = ones.stream()
|
.map(TBill::getPayableFeesMoney)
|
.reduce(BigDecimal::add)
|
.orElse(BigDecimal.ZERO);
|
|
String rent = String.format("%.2f/%.2f", payFeesMoney1, payableFeesMoney1);
|
houseMapDistributionVO.setRent(rent);
|
}else {
|
houseMapDistributionVO.setRent("欠费");
|
}
|
|
}else {
|
houseMapDistributionVO.setTenant("暂无");
|
houseMapDistributionVO.setRentStatus("待出租");
|
houseMapDistributionVO.setRent("暂无");
|
}
|
result.add(houseMapDistributionVO);
|
}
|
return R.ok(result);
|
}
|
|
|
}
|
