产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
buhuazhen
8 天以前 47768d890fbfc1a5f3e93ca26137847361415e9e 
 src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java


@@ -4,7 +4,6 @@


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.common.utils.DateUtils;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.common.utils.poi.ExcelUtil;


import com.ruoyi.framework.security.LoginUser;


@@ -25,9 +24,10 @@




import javax.servlet.http.HttpServletResponse;


import java.math.BigDecimal;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.format.DateTimeFormatter;


import java.util.List;


import java.util.*;


import java.util.stream.Collectors;




/**


@@ -129,12 +129,16 @@


        // 查询采购记录已入库数量


        List<Integer> collect = list.stream().map(ProcurementPageDto::getId).collect(Collectors.toList());


        if(CollectionUtils.isEmpty( collect)){


            ExcelUtil<ProcurementPageDto> util = new ExcelUtil<ProcurementPageDto>(ProcurementPageDto.class);


            util.exportExcel(response, list, "入库台账");


            return;


        }


        LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();


        procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);


        List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);


        if(CollectionUtils.isEmpty( procurementRecords)){


            ExcelUtil<ProcurementPageDto> util = new ExcelUtil<ProcurementPageDto>(ProcurementPageDto.class);


            util.exportExcel(response, list, "入库台账");


            return;


        }


        for (ProcurementPageDto dto : list) {


@@ -173,6 +177,12 @@


        DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");


        String entryDateStr = procurementDto.getEntryDate() + " 00:00:00";


        String createTimeStr = procurementDto.getCreateTime() + " 00:00:00";


        SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectById(procurementDto.getSalesLedgerProductId());


        if(salesLedgerProduct == null){


            throw new RuntimeException("销售台账产品不存在");


        }


        salesLedgerProduct.setMinStock(procurementDto.getMinStock());


        salesLedgerProductMapper.updateById(salesLedgerProduct);


        ProcurementRecordStorage procurementRecordStorageById = getProcurementRecordById(procurementDto.getId());


        procurementRecordStorageById.setCreateBy(sysUser.getNickName());


        procurementRecordStorageById.setCreateUser(sysUser.getUserId());


@@ -227,6 +237,104 @@


    }




    @Override


    public Map<String, Object> getReportList(Page page, ProcurementPageDto procurementDto) {


        // 构建报表数据结构


        Map<String, Object> reportData = new HashMap<>();


        // 2. 构建图表数据


        Map<String, Object> chartData = new HashMap<>();




        IPage<ProcurementPageDtoCopy> procurementPageDtoCopyIPage = procurementRecordMapper.listPageCopy(page, procurementDto);


        List<ProcurementPageDtoCopy> procurementPageDtoCopyList = procurementPageDtoCopyIPage.getRecords();


        // 计算待入库数量


        reportData.put("tableData", procurementPageDtoCopyList);


        // 查询采购记录已入库数量


        List<Integer> collect = procurementPageDtoCopyList.stream().map(ProcurementPageDtoCopy::getId).collect(Collectors.toList());


        if(CollectionUtils.isEmpty(collect)){


             return reportData;


        }


        LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();


        procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);


        List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);


        if(CollectionUtils.isEmpty( procurementRecords)){


             return reportData;


        }


        int totalIn =0;


        int totalOut =0;


        int currentStock =0;


        int turnoverRate =0;


        List<String> dates = new ArrayList<>();


        List<Integer> values = new ArrayList<>();


        List<String> comparisonDates = new ArrayList<>();


        List<Integer> inValues = new ArrayList<>();


        List<Integer> outValues = new ArrayList<>();


        // 定义日期格式化器，指定为yyyy-MM-dd格式


        DateTimeFormatter dateFormatter = DateTimeFormatter.ISO_LOCAL_DATE;


        for (ProcurementPageDtoCopy dto : procurementPageDtoCopyList) {


            dates.add(dto.getCreateTime().format(dateFormatter));


            comparisonDates.add(dto.getCreateTime().format(dateFormatter));




            // 根据采购台账ID筛选对应的出库记录


            List<ProcurementRecordOut> collect1 = procurementRecords.stream()


                    .filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))


                    .collect(Collectors.toList());




            // 如果没有相关的出库记录，跳过该条数据


            if(CollectionUtils.isEmpty(collect1)){


                dto.setInboundNum0(dto.getInboundNum());


                continue;


            }




            // 计算已出库数量总和，并设置待出库数量


            BigDecimal totalInboundNum = collect1.stream()


                    .map(ProcurementRecordOut::getInboundNum)


                    .reduce(BigDecimal.ZERO, BigDecimal::add);




            // 待出库数量 = 总数量 - 已出库数量


            dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum));




            // 计算总入库数量


            totalIn += dto.getInboundNum().intValue();


            inValues.add(totalIn);


            // 计算总出库数量


            totalOut += totalInboundNum.intValue();


            outValues.add(totalOut);


            // 计算当前库存


            currentStock += dto.getInboundNum().intValue() - totalInboundNum.intValue();


            values.add(currentStock);


            // 计算周转率


            if(totalIn > 0){


                turnoverRate = totalOut * 100 / totalIn;


            }


        }






        // 1. 构建汇总数据


        Map<String, Object> summary = new HashMap<>();


        summary.put("totalIn", totalIn);          // 总入库量，实际应从数据计算


        summary.put("totalOut", totalOut);         // 总出库量，实际应从数据计算


        summary.put("currentStock", currentStock);     // 当前库存量，实际应从数据计算


        summary.put("turnoverRate", turnoverRate);      // 周转率，实际应从数据计算


        reportData.put("summary", summary);




        // 2. 构建图表数据


//        Map<String, Object> chartData = new HashMap<>();


//        List<String> dates = Arrays.asList("2025-09-15", "2025-09-16", "2025-09-17", "2025-09-18", "2025-09-19");


//        List<Integer> values = Arrays.asList(300, 350, 400, 380, 420);




        chartData.put("dates", dates);


        chartData.put("values", values);


        chartData.put("comparisonDates", comparisonDates);  // 实际应从数据计算


        chartData.put("inValues", inValues);         // 实际应从数据计算


        chartData.put("outValues", outValues);        // 实际应从数据计算


        reportData.put("chartData", chartData);




        // 3. 设置表格数据


        reportData.put("tableData", procurementPageDtoCopyList);




        return reportData;


    }




    @Override


    public int add(ProcurementAddDto procurementDto) {


        LoginUser loginUser = SecurityUtils.getLoginUser();


        // 批量新增


@@ -244,7 +352,6 @@


                    .createUser(loginUser.getUserId())


                    .updateTime(LocalDateTime.now())


                    .updateUser(loginUser.getUserId())


                    .tenantId(loginUser.getTenantId())


                    .createBy(procurementDto.getNickName());


            this.save(procurementRecordBuilder.build());


            // 入库成功减掉采购数量


@@ -331,7 +438,8 @@


            BigDecimal totalInboundNum = collect1.stream()


                    .map(ProcurementRecordOut::getInboundNum)


                    .reduce(BigDecimal.ZERO, BigDecimal::add);




            // 出库数量 = 总数量 - 待出库数量


            dto.setTotalInboundNum(totalInboundNum);


            // 待出库数量 = 总数量 - 已出库数量


            dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum));


        }