feat: 完成固废消纳量看板接口

gongchunyi

3 天以前 7e9f46c8cb12e4c59a8bf529a9280067d217fe12

feat: 完成固废消纳量看板接口

 src/main/java/com/ruoyi/home/controller/HomeController.java

@@ -397,5 +397,23 @@
        return AjaxResult.success(homeService.energy(dto));
    }

    @GetMapping("/solidWaste/coreIndicators")
    @ApiOperation("固废消纳量-核心指标")
    public AjaxResult coreIndicators(productionStatisticsDto dto){
        return AjaxResult.success(homeService.coreIndicators(dto));
    }

    @GetMapping("/solidWaste/trends")
    @ApiOperation("固废消纳量-固废消纳趋势")
    public AjaxResult trends(productionStatisticsDto dto){
        return AjaxResult.success(homeService.trends(dto));
    }

    @GetMapping("/solidWaste/typeDistribution")
    @ApiOperation("固废消纳量-固废类型分布")
    public AjaxResult typeDistribution(productionStatisticsDto dto){
        return AjaxResult.success(homeService.typeDistribution(dto));
    }


}

 src/main/java/com/ruoyi/home/dto/SolidWasteCoreIndicatorsDto.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,26 @@
package com.ruoyi.home.dto;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.math.BigDecimal;

/**
 * å›ºåºŸæ¶ˆçº³é‡æ ¸å¿ƒæŒ‡æ ‡Dto
 *
 * @author deslrey
 * @version 1.0
 * @since 2026/04/02
 */
@Data
@ApiModel(value = "SolidWasteCoreIndicatorsDto", description = "固废消纳量核心指标Dto")
public class SolidWasteCoreIndicatorsDto {

    @ApiModelProperty("合计量")
    private BigDecimal totalAmount = BigDecimal.ZERO;

    @ApiModelProperty("累计消纳量 (自2022å¹´èµ·)")
    private BigDecimal cumulativeAmount = BigDecimal.ZERO;

}

 src/main/java/com/ruoyi/home/service/HomeService.java

@@ -119,4 +119,10 @@
    List<SolidWasteStatisticsDto> solidWaste(productionStatisticsDto dto);

    List<HomeEnergyStatisticsDto> energy(productionStatisticsDto dto);

    SolidWasteCoreIndicatorsDto coreIndicators(productionStatisticsDto dto);

    List<SolidWasteStatisticsDto> trends(productionStatisticsDto dto);

    List<MapDto> typeDistribution(productionStatisticsDto dto);
}

 src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java

@@ -3433,4 +3433,155 @@

        return new ArrayList<>(resultData.values());
    }

    @Override
    public SolidWasteCoreIndicatorsDto coreIndicators(productionStatisticsDto dto) {
        if (dto == null) {
            dto = new productionStatisticsDto();
            dto.setDateType(1);
        }

        LocalDate now = LocalDate.now();
        LocalDate startDate = null;
        if (dto.getDateType() != null && dto.getDateType() == 1) { // æœ¬æœˆè‡³ä»Š
            startDate = now.withDayOfMonth(1);
        } else { // æœ¬å¹´è‡³ä»Š
            startDate = now.withDayOfYear(1);
        }

        // ç´¯è®¡æ¶ˆçº³é‡ä»Ž2022-01-01开始
        LocalDate cumulativeStartDate = LocalDate.of(2022, 1, 1);
        // æŸ¥è¯¢ä»Ž2022-01-01至今的所有报工数据
        List<ProductionProductMain> mainList = productionProductMainService.list(Wrappers.<ProductionProductMain>lambdaQuery()
                .ge(ProductionProductMain::getReportingTime, cumulativeStartDate.atStartOfDay()));
        if (CollectionUtils.isEmpty(mainList)) return new SolidWasteCoreIndicatorsDto();

        List<Long> mainIds = mainList.stream().map(ProductionProductMain::getId).collect(Collectors.toList());
        Map<Long, ProductionProductMain> mainMap = mainList.stream().collect(Collectors.toMap(ProductionProductMain::getId, m -> m));

        // èŽ·å–投入明细
        List<ProductionProductInput> allInputs = productionProductInputService.list(Wrappers.<ProductionProductInput>lambdaQuery()
                .in(ProductionProductInput::getProductMainId, mainIds));
        if (CollectionUtils.isEmpty(allInputs)) return new SolidWasteCoreIndicatorsDto();

        // èŽ·å–规格和物料名称
        Set<Long> skuIds = allInputs.stream().map(ProductionProductInput::getProductId).filter(Objects::nonNull).collect(Collectors.toSet());
        Map<Long, String> skuToMaterialNameMap = new HashMap<>();
        if (!skuIds.isEmpty()) {
            List<ProductMaterialSku> skus = productMaterialSkuService.listByIds(skuIds);
            Set<Long> productIds = skus.stream().map(ProductMaterialSku::getProductId).filter(Objects::nonNull).collect(Collectors.toSet());
            Map<Long, String> materialNameMap = productMaterialService.listByIds(productIds).stream()
                    .collect(Collectors.toMap(ProductMaterial::getId, ProductMaterial::getProductName));
            skuToMaterialNameMap = skus.stream()
                    .filter(s -> s.getProductId() != null && materialNameMap.containsKey(s.getProductId()))
                    .collect(Collectors.toMap(ProductMaterialSku::getId, s -> materialNameMap.get(s.getProductId())));
        }

        BigDecimal totalAmount = BigDecimal.ZERO;
        BigDecimal cumulativeAmount = BigDecimal.ZERO;

        Set<String> targetMaterials = new HashSet<>(Arrays.asList("粉煤灰", "石膏", "石灰"));

        for (ProductionProductInput input : allInputs) {
            String materialName = skuToMaterialNameMap.get(input.getProductId());
            if (materialName == null || !targetMaterials.contains(materialName)) continue;

            ProductionProductMain main = mainMap.get(input.getProductMainId());
            if (main == null || main.getReportingTime() == null) continue;

            BigDecimal qty = UnitUtils.convertValueToTon(input.getQuantity(), input.getUnit());
            // ç´¯åŠ ç´¯è®¡æ¶ˆçº³é‡
            cumulativeAmount = cumulativeAmount.add(qty);

            if (!main.getReportingTime().toLocalDate().isBefore(startDate)) {
                totalAmount = totalAmount.add(qty);
            }
        }

        SolidWasteCoreIndicatorsDto result = new SolidWasteCoreIndicatorsDto();
        result.setTotalAmount(totalAmount.setScale(2, RoundingMode.HALF_UP));
        result.setCumulativeAmount(cumulativeAmount.setScale(2, RoundingMode.HALF_UP));
        return result;
    }

    @Override
    public List<SolidWasteStatisticsDto> trends(productionStatisticsDto dto) {
        return solidWaste(dto);
    }

    @Override
    public List<MapDto> typeDistribution(productionStatisticsDto dto) {
        if (dto == null) {
            dto = new productionStatisticsDto();
            dto.setDateType(1);
        }

        LocalDate now = LocalDate.now();
        LocalDate startDate = null;
        if (dto.getDateType() != null && dto.getDateType() == 1) { // æœ¬æœˆè‡³ä»Š
            startDate = now.withDayOfMonth(1);
        } else { // æœ¬å¹´è‡³ä»Š
            startDate = now.withDayOfYear(1);
        }

        // æŸ¥è¯¢æŠ¥å·¥ä¸»è¡¨
        List<ProductionProductMain> mainList = productionProductMainService.list(Wrappers.<ProductionProductMain>lambdaQuery()
                .ge(ProductionProductMain::getReportingTime, startDate.atStartOfDay()));
        if (CollectionUtils.isEmpty(mainList)) return new ArrayList<>();

        List<Long> mainIds = mainList.stream().map(ProductionProductMain::getId).collect(Collectors.toList());
        
        // èŽ·å–投入明细
        List<ProductionProductInput> allInputs = productionProductInputService.list(Wrappers.<ProductionProductInput>lambdaQuery()
                .in(ProductionProductInput::getProductMainId, mainIds));
        if (CollectionUtils.isEmpty(allInputs)) return new ArrayList<>();

        // èŽ·å–规格和物料名称
        Set<Long> skuIds = allInputs.stream().map(ProductionProductInput::getProductId).filter(Objects::nonNull).collect(Collectors.toSet());
        Map<Long, String> skuToMaterialNameMap = new HashMap<>();
        if (!skuIds.isEmpty()) {
            List<ProductMaterialSku> skus = productMaterialSkuService.listByIds(skuIds);
            Set<Long> productIds = skus.stream().map(ProductMaterialSku::getProductId).filter(Objects::nonNull).collect(Collectors.toSet());
            Map<Long, String> materialNameMap = productMaterialService.listByIds(productIds).stream()
                    .collect(Collectors.toMap(ProductMaterial::getId, ProductMaterial::getProductName));
            skuToMaterialNameMap = skus.stream()
                    .filter(s -> s.getProductId() != null && materialNameMap.containsKey(s.getProductId()))
                    .collect(Collectors.toMap(ProductMaterialSku::getId, s -> materialNameMap.get(s.getProductId())));
        }

        Map<String, BigDecimal> countMap = new HashMap<>();
        countMap.put("粉煤灰", BigDecimal.ZERO);
        countMap.put("石膏", BigDecimal.ZERO);
        countMap.put("石灰", BigDecimal.ZERO);

        BigDecimal total = BigDecimal.ZERO;

        for (ProductionProductInput input : allInputs) {
            String materialName = skuToMaterialNameMap.get(input.getProductId());
            if (materialName == null || !countMap.containsKey(materialName)) continue;

            BigDecimal qty = UnitUtils.convertValueToTon(input.getQuantity(), input.getUnit());
            countMap.put(materialName, countMap.get(materialName).add(qty));
            total = total.add(qty);
        }

        List<MapDto> result = new ArrayList<>();
        for (Map.Entry<String, BigDecimal> entry : countMap.entrySet()) {
            MapDto mapDto = new MapDto();
            mapDto.setName(entry.getKey());
            BigDecimal value = entry.getValue().setScale(2, RoundingMode.HALF_UP);
            mapDto.setValue(value.toString());

            if (total.compareTo(BigDecimal.ZERO) > 0) {
                BigDecimal rate = entry.getValue().divide(total, 4, RoundingMode.HALF_UP)
                        .multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP);
                mapDto.setRate(rate.toString());
            } else {
                mapDto.setRate("0.00");
            }
            result.add(mapDto);
        }

        return result;
    }
}