From 6bfd9e219ef6e51cd89f77a4cb6e5fb37779e9fe Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期四, 03 四月 2025 10:27:58 +0800 Subject: [PATCH] bug修改 --- ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/ScreenController.java | 213 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 212 insertions(+), 1 deletions(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/ScreenController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/ScreenController.java index 354a246..d188bfe 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/ScreenController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/ScreenController.java @@ -1,10 +1,40 @@ 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 @@ -13,7 +43,188 @@ @Api(tags = {"大屏相关接口"}) @RestController @RequestMapping("/screen") -@RequiredArgsConstructor +@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() { + + String businessDeptId = SecurityUtils.getBusinessDeptId(); + Date currentDate = new Date(); + Date targetDate = DateUtils.addMonths(currentDate, -3 * 6); + Map<String, Date> startQuarterDate = DateUtils.getQuarterDate(targetDate); + + + Date targetDate2 = DateUtils.addMonths(currentDate, 0); + Map<String, Date> endQuarterDate = DateUtils.getQuarterDate(targetDate2); + + List<TContract> contracts = contractService.list(new LambdaQueryWrapper<TContract>() + .eq(!"0".equals(businessDeptId),TContract::getBusinessDeptId, businessDeptId) + .isNotNull(TContract::getSignTime) + .between(TContract::getSignTime, startQuarterDate.get("first"), endQuarterDate.get("last")) + .orderByAsc(TContract::getSignTime)); + + DateTimeFormatter quarterFormatter = DateTimeFormatter.ofPattern("yyyy-MM"); + + List<TenantCountTrendVO> trendData = contracts.stream() + .collect(Collectors.groupingBy(contract -> { + LocalDate date = contract.getSignTime().toLocalDate(); + int quarter = (date.getMonthValue() - 1) / 3 + 1; + return YearQuarter.from(date.withMonth(quarter * 3 - 2)); + }, TreeMap::new, Collectors.counting())) + .entrySet().stream() + .map(entry -> new TenantCountTrendVO( + entry.getKey().format(quarterFormatter), + entry.getValue())) + .collect(Collectors.toList()); + + return R.ok(trendData); + } + + + /** + * 实时租赁数据 + */ + @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); + } + + /** + * 获取房屋地图分布 + */ + @GetMapping("/getHouseMapDistribution") + @ApiOperation("获取房屋地图分布") + public R<List<HouseMapDistributionVO>> getHouseMapDistribution() { + + String businessDeptId = SecurityUtils.getBusinessDeptId(); + // 获取所有房屋信息 + List<THouse> houses = houseService.list(new LambdaQueryWrapper<THouse>() + .eq(!"0".equals(businessDeptId),THouse::getBusinessDeptId, businessDeptId)); + 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 = contractService.getOne(new LambdaQueryWrapper<TContract>() + .eq(!"0".equals(businessDeptId),TContract::getBusinessDeptId, businessDeptId) + .gt(TContract::getEndTime, LocalDate.now()) + .eq(TContract::getHouseId, house.getId()) + .eq(TContract::getStatus, 4) + .last("limit 1")); + + if (contract != null){ + List<TBill> tBills = billService.list(new LambdaQueryWrapper<TBill>() + .eq(!"0".equals(businessDeptId),TBill::getBusinessDeptId, businessDeptId) + .eq(TBill::getContractId, contract.getId()) + .eq(TBill::getBillType, 1)); + houseMapDistributionVO.setTenant(contract.getPartyTwoName()); + LocalDateTime startTime = contract.getStartTime(); + LocalDateTime endTime = contract.getEndTime(); + BigDecimal monthRent = contract.getMonthRent(); + // 计算相差月份 + long monthsBetween = ChronoUnit.MONTHS.between(startTime, endTime); + BigDecimal payableFeesMoney = monthRent.multiply(new BigDecimal(monthsBetween)); + + BigDecimal paidAlready = tBills.stream() + .map(TBill::getPayableFeesMoney) + .reduce(BigDecimal::add) + .orElse(BigDecimal.ZERO); + String rentStatus = String.format("%.2f/%.2f", paidAlready, payableFeesMoney); + houseMapDistributionVO.setRentStatus(rentStatus); + + +// TBill one = billService.getOne(new LambdaQueryWrapper<TBill>() +// .le(TBill::getStartTime, LocalDate.now()) +// .ge(TBill::getEndTime, LocalDate.now()) +// .eq(TBill::getBillType, 1) +// .eq(TBill::getContractId, contract.getId())); + + List<TBill> ones = billService.list(new LambdaQueryWrapper<TBill>() + .eq(!"0".equals(businessDeptId),TBill::getBusinessDeptId, businessDeptId) + .le(TBill::getStartTime, LocalDate.now()) + .ge(TBill::getEndTime, LocalDate.now()) + .eq(TBill::getBillType, 1) + .eq(TBill::getContractId, contract.getId())); + TBill one = null; + if (!ones.isEmpty()){ + one = ones.get(0); + } + + if (one != null){ + if ("4".equals(one.getPayFeesStatus())){ + houseMapDistributionVO.setHouseStatus("4"); + } + BigDecimal payFeesMoney = one.getPayFeesMoney(); + BigDecimal payableFeesMoney1 = one.getPayableFeesMoney(); + String rent = String.format("%.2f/%.2f", payFeesMoney, payableFeesMoney1); + houseMapDistributionVO.setRent(rent); + }else { + houseMapDistributionVO.setRent("暂无"); + } + }else { + houseMapDistributionVO.setTenant("暂无"); + houseMapDistributionVO.setRentStatus("暂无"); + houseMapDistributionVO.setRent("暂无"); + } + result.add(houseMapDistributionVO); + } + return R.ok(result); + } } -- Gitblit v1.7.1