产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
云
2 天以前 c3a981e80973ac52b5988aca62b87409976c6fb1 
 src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java


@@ -179,6 +179,34 @@


            homeBusinessDto.setMonthPurchaseMoney(receiveAmount.setScale(2, RoundingMode.HALF_UP).toString());


            homeBusinessDto.setMonthPurchaseHaveMoney(BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP).toString());


        }




        // 上月销售金额


        YearMonth lastMonth = currentMonth.minusMonths(1);


        LambdaQueryWrapper<SalesLedger> lastMonthSalesWrapper = new LambdaQueryWrapper<>();


        lastMonthSalesWrapper.ge(SalesLedger::getEntryDate, lastMonth.atDay(1).atStartOfDay())


                .lt(SalesLedger::getEntryDate, lastMonth.plusMonths(1).atDay(1).atStartOfDay());


        List<SalesLedger> lastMonthSalesLedgers = salesLedgerMapper.selectList(lastMonthSalesWrapper);


        if (!CollectionUtils.isEmpty(lastMonthSalesLedgers)) {


            BigDecimal lastMonthContractAmount = lastMonthSalesLedgers.stream()


                    .map(SalesLedger::getContractAmount)


                    .filter(Objects::nonNull)


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


            homeBusinessDto.setLastMonthSaleMoney(lastMonthContractAmount.setScale(2, RoundingMode.HALF_UP).toString());


        }




        // 上月采购金额


        LambdaQueryWrapper<PurchaseLedger> lastMonthPurchaseWrapper = new LambdaQueryWrapper<>();


        lastMonthPurchaseWrapper.ge(PurchaseLedger::getEntryDate, lastMonth.atDay(1).atStartOfDay())


                .lt(PurchaseLedger::getEntryDate, lastMonth.plusMonths(1).atDay(1).atStartOfDay());


        List<PurchaseLedger> lastMonthPurchaseLedgers = purchaseLedgerMapper.selectList(lastMonthPurchaseWrapper);


        if (!CollectionUtils.isEmpty(lastMonthPurchaseLedgers)) {


            BigDecimal lastMonthPurchaseAmount = lastMonthPurchaseLedgers.stream()


                    .map(PurchaseLedger::getContractAmount)


                    .filter(Objects::nonNull)


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


            homeBusinessDto.setLastMonthPurchaseMoney(lastMonthPurchaseAmount.setScale(2, RoundingMode.HALF_UP).toString());


        }




        // 统计库存


        BigDecimal stockQuantityTotal = stockInventoryMapper.selectTotal();


        homeBusinessDto.setInventoryNum(stockQuantityTotal.setScale(2, RoundingMode.HALF_UP).toString());


@@ -313,19 +341,35 @@


            queryWrapper.ge(QualityInspect::getCheckTime, monthStart.toString())


                    .le(QualityInspect::getCheckTime, monthEnd.toString());


            List<QualityInspect> monthInspects = qualityStatisticsMapper.selectList(queryWrapper);




            // 统计总数量（合格数量 + 不合格数量）


            BigDecimal reduce = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(0))


                    .map(QualityInspect::getQuantity)


                    .map(inspect -> {


                        BigDecimal qualified = inspect.getQualifiedQuantity() != null ? inspect.getQualifiedQuantity() : BigDecimal.ZERO;


                        BigDecimal unqualified = inspect.getUnqualifiedQuantity() != null ? inspect.getUnqualifiedQuantity() : BigDecimal.ZERO;


                        return qualified.add(unqualified);


                    })


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


            supplierNum = supplierNum.add(reduce);




            BigDecimal reduce1 = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(1))


                    .map(QualityInspect::getQuantity)


                    .map(inspect -> {


                        BigDecimal qualified = inspect.getQualifiedQuantity() != null ? inspect.getQualifiedQuantity() : BigDecimal.ZERO;


                        BigDecimal unqualified = inspect.getUnqualifiedQuantity() != null ? inspect.getUnqualifiedQuantity() : BigDecimal.ZERO;


                        return qualified.add(unqualified);


                    })


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


            processNum = processNum.add(reduce1);




            BigDecimal reduce2 = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(2))


                    .map(QualityInspect::getQuantity)


                    .map(inspect -> {


                        BigDecimal qualified = inspect.getQualifiedQuantity() != null ? inspect.getQualifiedQuantity() : BigDecimal.ZERO;


                        BigDecimal unqualified = inspect.getUnqualifiedQuantity() != null ? inspect.getUnqualifiedQuantity() : BigDecimal.ZERO;


                        return qualified.add(unqualified);


                    })


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


            factoryNum = factoryNum.add(reduce2);




@@ -335,25 +379,22 @@




            // 1. 供应商检验（类型0）- 合格数量


            BigDecimal supplierQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(0)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


                    .filter(inspect -> inspect.getInspectType().equals(0))


                    .map(inspect -> inspect.getQualifiedQuantity() != null ? inspect.getQualifiedQuantity() : BigDecimal.ZERO)


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


            item.setSupplierNum(supplierQualified);




            // 2. 工序检验（类型1）- 合格数量


            BigDecimal processQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(1)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


                    .filter(inspect -> inspect.getInspectType().equals(1))


                    .map(inspect -> inspect.getQualifiedQuantity() != null ? inspect.getQualifiedQuantity() : BigDecimal.ZERO)


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


            item.setProcessNum(processQualified);




            // 3. 工厂检验（类型2）- 合格数量


            BigDecimal factoryQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(2)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


                    .filter(inspect -> inspect.getInspectType().equals(2))


                    .map(inspect -> inspect.getQualifiedQuantity() != null ? inspect.getQualifiedQuantity() : BigDecimal.ZERO)


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


            item.setFactoryNum(factoryQualified);




@@ -1680,14 +1721,15 @@


        LocalDate endDate = range[1];




        String startStr = startDate.toString();


        String endStr = endDate.toString();


        // 使用区间右开（< endDate + 1 天）保证检测时间含时分秒时也能覆盖到 endDate 当天


        String endExclusiveStr = endDate.plusDays(1).toString();




        List<QualityInspect> list = qualityInspectMapper.selectList(


                new LambdaQueryWrapper<QualityInspect>()


                        .eq(QualityInspect::getInspectType, inspectType)


                        .eq(QualityInspect::getInspectState, 1)


                        .ge(QualityInspect::getCheckTime, startStr)


                        .le(QualityInspect::getCheckTime, endStr));


                        .lt(QualityInspect::getCheckTime, endExclusiveStr));




        return buildQualifiedAnalysis(list);


    }


@@ -1726,8 +1768,8 @@


        QualityQualifiedAnalysisDto dto = new QualityQualifiedAnalysisDto();




        if (CollectionUtils.isEmpty(list)) {


            dto.setQualifiedCount(0);


            dto.setUnqualifiedCount(0);


            dto.setQualifiedCount(BigDecimal.valueOf(0));


            dto.setUnqualifiedCount(BigDecimal.valueOf(0));


            dto.setQualifiedRate(BigDecimal.ZERO.setScale(2));


            dto.setUnqualifiedRate(BigDecimal.ZERO.setScale(2));


            return dto;


@@ -1737,17 +1779,14 @@


        BigDecimal unqualifiedCount = BigDecimal.ZERO;




        for (QualityInspect item : list) {


            if ("合格".equals(item.getCheckResult())) {


                qualifiedCount = qualifiedCount.add(item.getQuantity());


            } else {


                unqualifiedCount = unqualifiedCount.add(item.getQuantity());


            }


            qualifiedCount = qualifiedCount.add(item.getQualifiedQuantity() != null ? item.getQualifiedQuantity() : BigDecimal.ZERO);


            unqualifiedCount = unqualifiedCount.add(item.getUnqualifiedQuantity() != null ? item.getUnqualifiedQuantity() : BigDecimal.ZERO);


        }




        BigDecimal totalCount = qualifiedCount.add(unqualifiedCount);




        dto.setQualifiedCount(qualifiedCount.intValue());


        dto.setUnqualifiedCount(unqualifiedCount.intValue());


        dto.setQualifiedCount(qualifiedCount);


        dto.setUnqualifiedCount(unqualifiedCount);




        if (totalCount.compareTo(BigDecimal.ZERO) == 0) {


            dto.setQualifiedRate(BigDecimal.ZERO.setScale(2));


@@ -1770,74 +1809,64 @@




    @Override


    public QualityInspectionCountDto qualityInspectionCount() {


        String todayStr = LocalDate.now().toString();


        String prevDayStr = LocalDate.now().minusDays(1).toString();


        // 查询出截止今日的总检验数


        List<QualityInspect> todayList = qualityInspectMapper.selectList(new LambdaQueryWrapper<QualityInspect>()


                .le(QualityInspect::getCheckTime, todayStr));


        // 查询出截止前一天的总检验数


        List<QualityInspect> prevList = qualityInspectMapper.selectList(new LambdaQueryWrapper<QualityInspect>()


                .le(QualityInspect::getCheckTime, prevDayStr));


        // 计算今日的总检验数


        BigDecimal todayCount = todayList.stream()


                .map(QualityInspect::getQuantity)


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


        // 计算前一天的总检验数


        BigDecimal prevCount = prevList.stream()


                .map(QualityInspect::getQuantity)


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


        LocalDate today = LocalDate.now();


        String todayStartStr = today.toString();


        String tomorrowStartStr = today.plusDays(1).toString();


        String yesterdayStartStr = today.minusDays(1).toString();




        // 计算今日相对昨天的一个总比增长


        BigDecimal growthRate = calcGrowthRate(todayCount, prevCount);


        // 累计总检验数（截止今日 24:00 之前的所有记录）


        BigDecimal totalCount = sumInspectQuantity(null, tomorrowStartStr, null);


        // 今日单日检验数


        BigDecimal todayCount = sumInspectQuantity(todayStartStr, tomorrowStartStr, null);


        // 昨日单日检验数


        BigDecimal yesterdayCount = sumInspectQuantity(yesterdayStartStr, todayStartStr, null);


        // 总检验数同比增长 = (今日单日 - 昨日单日) / 昨日单日 × 100%


        BigDecimal growthRate = calcGrowthRate(todayCount, yesterdayCount);




        // 计算今天的待完成数量


        List<QualityInspect> todayPendingList = qualityInspectMapper.selectList(new LambdaQueryWrapper<QualityInspect>()


                .eq(QualityInspect::getInspectState, 0)


                .eq(QualityInspect::getCheckTime, todayStr));


        // 今日待完成（inspectState=0）


        BigDecimal todayPendingCount = sumInspectQuantity(todayStartStr, tomorrowStartStr, 0);


        BigDecimal yesterdayPendingCount = sumInspectQuantity(yesterdayStartStr, todayStartStr, 0);


        BigDecimal todayPendingCountGrowthRate = calcGrowthRate(todayPendingCount, yesterdayPendingCount);




        // 计算前一天的待完成数量


        List<QualityInspect> prevPendingList = qualityInspectMapper.selectList(new LambdaQueryWrapper<QualityInspect>()


                .eq(QualityInspect::getInspectState, 0)


                .eq(QualityInspect::getCheckTime, prevDayStr));


        // 计算今天的待完成数量


        BigDecimal todayPendingCount = todayPendingList.stream()


                .map(QualityInspect::getQuantity)


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


        // 今日已完成（inspectState=1）


        BigDecimal todayCompletedCount = sumInspectQuantity(todayStartStr, tomorrowStartStr, 1);


        BigDecimal yesterdayCompletedCount = sumInspectQuantity(yesterdayStartStr, todayStartStr, 1);


        BigDecimal todayCompletedCountGrowthRate = calcGrowthRate(todayCompletedCount, yesterdayCompletedCount);




        // 计算前一天的待完成数量


        BigDecimal prevPendingCount = prevPendingList.stream()


                .map(QualityInspect::getQuantity)


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


        // 计算今天的待完成数量相对昨天的一个同比增长


        BigDecimal todayPendingCountGrowthRate = calcGrowthRate(todayPendingCount, prevPendingCount);


        // 计算今天的已完成数量


        List<QualityInspect> todayCompletedList = qualityInspectMapper


                .selectList(new LambdaQueryWrapper<QualityInspect>()


                        .eq(QualityInspect::getInspectState, 1)


                        .eq(QualityInspect::getCheckTime, todayStr));


        // 计算前一天的已完成数量


        List<QualityInspect> prevCompletedList = qualityInspectMapper


                .selectList(new LambdaQueryWrapper<QualityInspect>()


                        .eq(QualityInspect::getInspectState, 1)


                        .eq(QualityInspect::getCheckTime, prevDayStr));


        // 计算今天的已完成数量


        BigDecimal todayCompletedCount = todayCompletedList.stream()


                .map(QualityInspect::getQuantity)


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


        // 计算前一天的已完成数量


        BigDecimal prevCompletedCount = prevCompletedList.stream()


                .map(QualityInspect::getQuantity)


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


        // 计算今天的已完成数量相对昨天的一个同比增长


        BigDecimal todayCompletedCountGrowthRate = calcGrowthRate(todayCompletedCount, prevCompletedCount);


        QualityInspectionCountDto dto = new QualityInspectionCountDto();


        dto.setTotalCount(todayCount);


        dto.setTotalCount(totalCount);


        dto.setTotalCountGrowthRate(growthRate);


        dto.setTodayPendingCount(todayPendingCount);


        dto.setTodayPendingCountGrowthRate(todayPendingCountGrowthRate);


        dto.setTodayCompletedCount(todayCompletedCount);


        dto.setTodayCompletedCountGrowthRate(todayCompletedCountGrowthRate);


        return dto;


    }




    /**


     * 通过 SQL SUM 聚合 quality_inspect.quantity，避免把全表加载到内存


     */


    private BigDecimal sumInspectQuantity(String startInclusive, String endExclusive, Integer inspectState) {


        QueryWrapper<QualityInspect> wrapper = new QueryWrapper<>();


        wrapper.select("COALESCE(SUM(quantity), 0) AS total");


        if (startInclusive != null) {


            wrapper.ge("check_time", startInclusive);


        }


        if (endExclusive != null) {


            wrapper.lt("check_time", endExclusive);


        }


        if (inspectState != null) {


            wrapper.eq("inspect_state", inspectState);


        }


        List<Map<String, Object>> rows = qualityInspectMapper.selectMaps(wrapper);


        if (rows == null || rows.isEmpty()) {


            return BigDecimal.ZERO;


        }


        Object total = rows.get(0).get("total");


        if (total == null) {


            return BigDecimal.ZERO;


        }


        return total instanceof BigDecimal ? (BigDecimal) total : new BigDecimal(total.toString());


    }




    private BigDecimal calcGrowthRate(BigDecimal today, BigDecimal prev) {


@@ -1854,14 +1883,14 @@


    public NonComplianceWarningDto nonComplianceWarning() {


        String[] range = lastSevenDaysDateRange();


        String startStr = range[0];


        String endStr = range[1];


        String endExclusiveStr = range[1];




        // 查询近七天已处理不合格数据


        List<QualityUnqualified> list = qualityUnqualifiedMapper.selectList(


                new LambdaQueryWrapper<QualityUnqualified>()


                        .eq(QualityUnqualified::getInspectState, 1)


                        .ge(QualityUnqualified::getCheckTime, startStr)


                        .le(QualityUnqualified::getCheckTime, endStr));


                        .lt(QualityUnqualified::getCheckTime, endExclusiveStr));




        NonComplianceWarningDto dto = new NonComplianceWarningDto();




@@ -1960,24 +1989,24 @@


    }




    /**


     * 获取近七天的日期区间（仅含年月日）


     * 获取近七天的日期区间（仅含年月日）：返回 [start, endExclusive] —— endExclusive 是今天 + 1 天，便于使用 lt 包含今天全部


     */


    public static String[] lastSevenDaysDateRange() {


        LocalDate today = LocalDate.now();


        return new String[]{today.minusDays(6).toString(), today.toString()};


        return new String[]{today.minusDays(6).toString(), today.plusDays(1).toString()};


    }




    @Override


    public List<CompletedInspectionCountDto> completedInspectionCount() {


        String[] range = lastSevenDaysDateRange();


        String startStr = range[0];


        String endStr = range[1];


        String endExclusiveStr = range[1];




        // 查询近七天已完成的检验数据


        List<QualityInspect> list = qualityInspectMapper.selectList(new LambdaQueryWrapper<QualityInspect>()


                .eq(QualityInspect::getInspectState, 1)


                .ge(QualityInspect::getCheckTime, startStr)


                .le(QualityInspect::getCheckTime, endStr));


                .lt(QualityInspect::getCheckTime, endExclusiveStr));




        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("MM-dd");




@@ -2010,13 +2039,11 @@


                continue;


            }




            BigDecimal quantity = item.getQuantity();


            BigDecimal qualifiedQty = item.getQualifiedQuantity() != null ? item.getQualifiedQuantity() : BigDecimal.ZERO;


            BigDecimal unqualifiedQty = item.getUnqualifiedQuantity() != null ? item.getUnqualifiedQuantity() : BigDecimal.ZERO;




            if ("合格".equals(item.getCheckResult())) {


                dto.setQualifiedCount(dto.getQualifiedCount().add(quantity));


            } else {


                dto.setUnqualifiedCount(dto.getUnqualifiedCount().add(quantity));


            }


            dto.setQualifiedCount(dto.getQualifiedCount().add(qualifiedQty));


            dto.setUnqualifiedCount(dto.getUnqualifiedCount().add(unqualifiedQty));


        }




        // 计算合格率


@@ -2031,8 +2058,15 @@


    @Override


    public List<UnqualifiedProductRankDto> unqualifiedProductRanking() {




        // 限定近 30 天，避免全表加载


        LocalDate today = LocalDate.now();


        String startStr = today.minusDays(29).toString();


        String endExclusiveStr = today.plusDays(1).toString();




        List<QualityInspect> list = qualityInspectMapper.selectList(new LambdaQueryWrapper<QualityInspect>()


                .eq(QualityInspect::getInspectState, 1));


                .eq(QualityInspect::getInspectState, 1)


                .ge(QualityInspect::getCheckTime, startStr)


                .lt(QualityInspect::getCheckTime, endExclusiveStr));




        if (CollectionUtils.isEmpty(list)) {


            return new ArrayList<>();


@@ -2057,14 +2091,12 @@


            BigDecimal unqualifiedCount = BigDecimal.ZERO;




            for (QualityInspect item : items) {


                BigDecimal qty = item.getQuantity();


                totalCount = totalCount.add(qty);


                BigDecimal qualifiedQty = item.getQualifiedQuantity() != null ? item.getQualifiedQuantity() : BigDecimal.ZERO;


                BigDecimal unqualifiedQty = item.getUnqualifiedQuantity() != null ? item.getUnqualifiedQuantity() : BigDecimal.ZERO;




                if ("合格".equals(item.getCheckResult())) {


                    qualifiedCount = qualifiedCount.add(qty);


                } else {


                    unqualifiedCount = unqualifiedCount.add(qty);


                }


                totalCount = totalCount.add(qualifiedQty.add(unqualifiedQty));


                qualifiedCount = qualifiedCount.add(qualifiedQty);


                unqualifiedCount = unqualifiedCount.add(unqualifiedQty);


            }




            if (totalCount.compareTo(BigDecimal.ZERO) == 0) {


@@ -2185,7 +2217,7 @@


        List<QualityInspect> qualityInspectList = qualityInspectMapper


                .selectList(new LambdaQueryWrapper<QualityInspect>()


                        .ge(QualityInspect::getCheckTime, startDate.toString())


                        .le(QualityInspect::getCheckTime, endDate.toString())


                        .lt(QualityInspect::getCheckTime, endDate.plusDays(1).toString())


                        .eq(QualityInspect::getInspectState, 1));




        QualityStatisticsDto dto = new QualityStatisticsDto();


@@ -2193,13 +2225,17 @@


        dto.setProcessNum(sumQuantity(qualityInspectList, 1)); // 过程


        dto.setFactoryNum(sumQuantity(qualityInspectList, 2)); // 出厂




        // 假设 qualityInspectList 是一个 List<QualityInspect> 类型的集合


        Map<String, List<QualityInspect>> groupedByCheckResult = qualityInspectList.stream()


                .collect(Collectors.groupingBy(QualityInspect::getCheckResult));


        List<QualityInspect> qualityInspects = groupedByCheckResult.get("不合格");


        if (ObjectUtils.isNull(qualityInspects) || qualityInspects.size() == 0) {


            return null;


        // 根据 unqualifiedQuantity > 0 筛选不合格记录


        List<QualityInspect> qualityInspects = qualityInspectList.stream()


                .filter(i -> i.getUnqualifiedQuantity() != null && i.getUnqualifiedQuantity().compareTo(BigDecimal.ZERO) > 0)


                .collect(Collectors.toList());




        if (ObjectUtils.isEmpty(qualityInspects)) {


            // 即使没有不合格记录，也应该返回统计数据，只是图表项为空


            dto.setItem(new ArrayList<>());


            return dto;


        }




        // 4. 处理图表项 (Item)


        List<QualityStatisticsItem> itemList = new ArrayList<>();




@@ -2242,8 +2278,11 @@


    private BigDecimal sumQuantity(List<QualityInspect> list, Integer type) {


        return list.stream()


                .filter(i -> i.getInspectType().equals(type))


                .map(QualityInspect::getQuantity)


                .filter(Objects::nonNull)


                .map(i -> {


                    BigDecimal qualified = i.getQualifiedQuantity() != null ? i.getQualifiedQuantity() : BigDecimal.ZERO;


                    BigDecimal unqualified = i.getUnqualifiedQuantity() != null ? i.getUnqualifiedQuantity() : BigDecimal.ZERO;


                    return qualified.add(unqualified);


                })


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


    }




@@ -2251,11 +2290,18 @@


        QualityStatisticsItem item = new QualityStatisticsItem();


        item.setDate(dateLabel);




        item.setSupplierNum(list.stream().filter(i -> i.getInspectType() == 0).map(QualityInspect::getQuantity)


        // 统计每种检验类型的不合格数量


        item.setSupplierNum(list.stream()


                .filter(i -> Objects.equals(i.getInspectType(), 0))


                .map(i -> i.getUnqualifiedQuantity() != null ? i.getUnqualifiedQuantity() : BigDecimal.ZERO)


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


        item.setProcessNum(list.stream().filter(i -> i.getInspectType() == 1).map(QualityInspect::getQuantity)


        item.setProcessNum(list.stream()


                .filter(i -> Objects.equals(i.getInspectType(), 1))


                .map(i -> i.getUnqualifiedQuantity() != null ? i.getUnqualifiedQuantity() : BigDecimal.ZERO)


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


        item.setFactoryNum(list.stream().filter(i -> i.getInspectType() == 2).map(QualityInspect::getQuantity)


        item.setFactoryNum(list.stream()


                .filter(i -> Objects.equals(i.getInspectType(), 2))


                .map(i -> i.getUnqualifiedQuantity() != null ? i.getUnqualifiedQuantity() : BigDecimal.ZERO)


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




        return item;