| | |
|---|
| | | import java.text.ParseException; |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.time.*; |
|---|
| | | import java.time.format.DateTimeFormatter; |
|---|
| | | import java.time.temporal.TemporalAdjusters; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.atomic.AtomicInteger; |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public QualityStatisticsDto qualityStatistics() { |
|---|
| | | // 获取一周数据 |
|---|
| | | // 获取当前时间 |
|---|
| | | // 获取近四个月数据（往前推三个月，共4个完整月份） |
|---|
| | | LocalDate today = LocalDate.now(); |
|---|
| | | // 获取本周周一 |
|---|
| | | LocalDate startOfWeek = today.with(DayOfWeek.MONDAY); |
|---|
| | | // 获取本周周日 |
|---|
| | | LocalDate endOfWeek = today.with(DayOfWeek.SUNDAY); |
|---|
| | | LambdaQueryWrapper<QualityInspect> qualityInspectLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
|---|
| | | qualityInspectLambdaQueryWrapper.ge(QualityInspect::getCheckTime, startOfWeek) |
|---|
| | | .gt(QualityInspect::getCheckTime, endOfWeek); |
|---|
| | | List<QualityInspect> qualityInspects = qualityStatisticsMapper.selectList(qualityInspectLambdaQueryWrapper); |
|---|
| | | // 定义日期格式化器（用于显示“年月”格式） |
|---|
| | | DateTimeFormatter monthFormatter = DateTimeFormatter.ofPattern("yyyy-MM"); |
|---|
| | | |
|---|
| | | QualityStatisticsDto qualityStatisticsDto = new QualityStatisticsDto(); |
|---|
| | | qualityStatisticsDto.setSupplierNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(0)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add)); |
|---|
| | | qualityStatisticsDto.setProcessNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(1)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add)); |
|---|
| | | qualityStatisticsDto.setFactoryNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(2)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add)); |
|---|
| | | List<QualityStatisticsItem> qualityStatisticsItems = new ArrayList<>(); |
|---|
| | | for (int j = 1; j < 8; j++) { |
|---|
| | | LocalDate endTime = startOfWeek.plusDays(j); |
|---|
| | | LocalDate startTime = endTime.minusDays(1); |
|---|
| | | QualityStatisticsItem qualityStatisticsItem = new QualityStatisticsItem(); |
|---|
| | | qualityStatisticsItem.setDate(startTime.toString()); |
|---|
| | | qualityStatisticsItem.setSupplierNum(qualityInspects.stream() |
|---|
| | | .filter(item -> item.getInspectType().equals(0) && "不合格".equals(item.getCheckResult()) |
|---|
| | | && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate())) |
|---|
| | | && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate())) |
|---|
| | | |
|---|
| | | BigDecimal supplierNum = new BigDecimal(0); |
|---|
| | | BigDecimal factoryNum = new BigDecimal(0); |
|---|
| | | BigDecimal processNum = new BigDecimal(0); |
|---|
| | | // 循环4次，分别统计近4个月的数据（当前月、前1个月、前2个月、前3个月） |
|---|
| | | for (int i = 3; i >= 0; i--) { |
|---|
| | | // 计算当前循环对应的月份（i=0：当前月，i=1：前1个月，以此类推） |
|---|
| | | LocalDate currentMonth = today.minusMonths(i); |
|---|
| | | // 当月的开始日期（每月1号） |
|---|
| | | LocalDate monthStart = currentMonth.withDayOfMonth(1); |
|---|
| | | // 当月的结束日期（每月最后一天） |
|---|
| | | LocalDate monthEnd = currentMonth.withDayOfMonth(currentMonth.lengthOfMonth()); |
|---|
| | | |
|---|
| | | // 构建当月的查询条件（如果想一次性查全4个月数据再内存筛选，可优化为先查全再循环筛选） |
|---|
| | | LambdaQueryWrapper<QualityInspect> queryWrapper = new LambdaQueryWrapper<>(); |
|---|
| | | queryWrapper.ge(QualityInspect::getCheckTime, monthStart) |
|---|
| | | .le(QualityInspect::getCheckTime, monthEnd); // 筛选当月数据 |
|---|
| | | List<QualityInspect> monthInspects = qualityStatisticsMapper.selectList(queryWrapper); |
|---|
| | | BigDecimal reduce = monthInspects.stream() |
|---|
| | | .filter(inspect -> inspect.getInspectType().equals(0)) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add) |
|---|
| | | ); |
|---|
| | | qualityStatisticsItem.setFactoryNum(qualityInspects.stream() |
|---|
| | | .filter(item -> item.getInspectType().equals(1) && "不合格".equals(item.getCheckResult()) |
|---|
| | | && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate())) |
|---|
| | | && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate())) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | supplierNum = supplierNum.add(reduce); |
|---|
| | | BigDecimal reduce1 = monthInspects.stream() |
|---|
| | | .filter(inspect -> inspect.getInspectType().equals(1)) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add) |
|---|
| | | ); |
|---|
| | | qualityStatisticsItem.setProcessNum(qualityInspects.stream() |
|---|
| | | .filter(item -> item.getInspectType().equals(2) && "不合格".equals(item.getCheckResult()) |
|---|
| | | && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate())) |
|---|
| | | && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate())) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | processNum= processNum.add(reduce1); |
|---|
| | | BigDecimal reduce2 = monthInspects.stream() |
|---|
| | | .filter(inspect -> inspect.getInspectType().equals(2)) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add)); |
|---|
| | | qualityStatisticsItems.add(qualityStatisticsItem); |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | factoryNum = factoryNum.add(reduce2); |
|---|
| | | |
|---|
| | | // 构建当月统计项 |
|---|
| | | QualityStatisticsItem item = new QualityStatisticsItem(); |
|---|
| | | item.setDate(monthStart.format(monthFormatter)); // 日期显示为“年月”（如 2025-10） |
|---|
| | | |
|---|
| | | // 1. 供应商检验（类型0）- 合格数量 |
|---|
| | | BigDecimal supplierQualified = monthInspects.stream() |
|---|
| | | .filter(inspect -> inspect.getInspectType().equals(0) |
|---|
| | | && "合格".equals(inspect.getCheckResult())) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .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) |
|---|
| | | .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) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | item.setFactoryNum(factoryQualified); |
|---|
| | | |
|---|
| | | qualityStatisticsItems.add(item); |
|---|
| | | } |
|---|
| | | // 统计近4个月总数据（所有月份汇总） |
|---|
| | | qualityStatisticsDto.setProcessNum(processNum); |
|---|
| | | qualityStatisticsDto.setSupplierNum(supplierNum); |
|---|
| | | qualityStatisticsDto.setFactoryNum(factoryNum); |
|---|
| | | qualityStatisticsDto.setItem(qualityStatisticsItems); |
|---|
| | | |
|---|
| | | return qualityStatisticsDto; |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | } |
|---|
| | | // 应收 |
|---|
| | | List<SalesLedger> salesLedgers = salesLedgerMapper.selectList(new LambdaQueryWrapper<SalesLedger>() |
|---|
| | | .ge(SalesLedger::getEntryDate, startDate) |
|---|
| | | .lt(SalesLedger::getEntryDate, endDate) |
|---|
| | | // .ge(SalesLedger::getEntryDate, startDate) |
|---|
| | | // .lt(SalesLedger::getEntryDate, endDate) |
|---|
| | | ); |
|---|
| | | BigDecimal receivableMoney = salesLedgers.stream().map(SalesLedger::getContractAmount).reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | // 应付 |
|---|
| | | List<PurchaseLedger> procurementRecords = purchaseLedgerMapper.selectList(new LambdaQueryWrapper<PurchaseLedger>() |
|---|
| | | .ge(PurchaseLedger::getEntryDate, startDate) |
|---|
| | | .lt(PurchaseLedger::getEntryDate, endDate) |
|---|
| | | // .ge(PurchaseLedger::getEntryDate, startDate) |
|---|
| | | // .lt(PurchaseLedger::getEntryDate, endDate) |
|---|
| | | ); |
|---|
| | | BigDecimal payableMoney = procurementRecords.stream().map(PurchaseLedger::getContractAmount).reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | // 预收 |
|---|
| | | List<ReceiptPayment> receiptPayments = receiptPaymentMapper.selectList(new LambdaQueryWrapper<ReceiptPayment>() |
|---|
| | | .ge(ReceiptPayment::getReceiptPaymentDate, startDate) |
|---|
| | | .lt(ReceiptPayment::getReceiptPaymentDate, endDate)); |
|---|
| | | // .ge(ReceiptPayment::getReceiptPaymentDate, startDate) |
|---|
| | | // .lt(ReceiptPayment::getReceiptPaymentDate, endDate) |
|---|
| | | ); |
|---|
| | | BigDecimal advanceMoney = receiptPayments.stream().map(ReceiptPayment::getReceiptPaymentAmount).reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | // 预付 |
|---|
| | | List<PaymentRegistration> paymentRegistrations = paymentRegistrationMapper.selectList(new LambdaQueryWrapper<PaymentRegistration>() |
|---|
| | | .ge(PaymentRegistration::getPaymentDate, startDate) |
|---|
| | | .lt(PaymentRegistration::getPaymentDate, endDate)); |
|---|
| | | // .ge(PaymentRegistration::getPaymentDate, startDate) |
|---|
| | | // .lt(PaymentRegistration::getPaymentDate, endDate) |
|---|
| | | ); |
|---|
| | | BigDecimal prepayMoney = paymentRegistrations.stream().map(PaymentRegistration::getCurrentPaymentAmount).reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | StatisticsReceivablePayableDto statisticsReceivablePayableDto = new StatisticsReceivablePayableDto(); |
|---|
| | | statisticsReceivablePayableDto.setPayableMoney(payableMoney); |
|---|
| | | statisticsReceivablePayableDto.setReceivableMoney(receivableMoney); |
|---|
| | | statisticsReceivablePayableDto.setPayableMoney(payableMoney.subtract(prepayMoney)); |
|---|
| | | statisticsReceivablePayableDto.setReceivableMoney(receivableMoney.subtract(advanceMoney)); |
|---|
| | | statisticsReceivablePayableDto.setAdvanceMoney(advanceMoney); |
|---|
| | | statisticsReceivablePayableDto.setPrepayMoney(prepayMoney); |
|---|
| | | |
|---|
| | | return statisticsReceivablePayableDto; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public QualityProductQualifiedRateDto qualityProductQualifiedRate() { |
|---|
| | | QualityProductQualifiedRateDto qualityProductQualifiedRateDto = new QualityProductQualifiedRateDto(); |
|---|
| | | List<QualityInspect> qualityInspects = qualityStatisticsMapper.selectList(null); |
|---|
| | | if(!CollectionUtils.isEmpty(qualityInspects)){ |
|---|
| | | // 原材料合格率 |
|---|
| | | BigDecimal rawwMaterialCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 0) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | BigDecimal count = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 0) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | if(count.compareTo(BigDecimal.ZERO) != 0){ |
|---|
| | | qualityProductQualifiedRateDto.setRawMaterialQualifiedRate(rawwMaterialCount |
|---|
| | | .divide(count, 4, RoundingMode.HALF_UP) |
|---|
| | | .multiply(BigDecimal.valueOf(100.0))); |
|---|
| | | } |
|---|
| | | // 过程合格率 |
|---|
| | | BigDecimal processCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 1) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | BigDecimal countOne = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 1) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | if(countOne.compareTo(BigDecimal.ZERO) != 0){ |
|---|
| | | qualityProductQualifiedRateDto.setProcessQualifiedRate(processCount |
|---|
| | | .divide(countOne, 4, RoundingMode.HALF_UP) |
|---|
| | | .multiply(BigDecimal.valueOf(100.0))); |
|---|
| | | } |
|---|
| | | // 出厂合格率 |
|---|
| | | BigDecimal factoryCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 2) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | BigDecimal countTwo = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 2) |
|---|
| | | .map(QualityInspect::getQuantity) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | if(countTwo.compareTo(BigDecimal.ZERO) != 0){ |
|---|
| | | qualityProductQualifiedRateDto.setFactoryQualifiedRate(factoryCount |
|---|
| | | .divide(countTwo, 4, RoundingMode.HALF_UP) |
|---|
| | | .multiply(BigDecimal.valueOf(100.0))); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // 库存周转率统计当月出库（使用）的物料总数量÷平均的库存物料总数量×100%。） |
|---|
| | | // 获取当前月 |
|---|
| | | LocalDate today = LocalDate.now(); |
|---|
| | | LocalDate startDate = today.with(TemporalAdjusters.firstDayOfMonth()); |
|---|
| | | LocalDate endDate = today.with(TemporalAdjusters.lastDayOfMonth()); |
|---|
| | | // 获取当前月出库（使用）的物料总数量 |
|---|
| | | List<ProcurementRecordOut> procurementRecordOuts = procurementRecordOutMapper.selectList(new LambdaQueryWrapper<ProcurementRecordOut>() |
|---|
| | | .ge(ProcurementRecordOut::getCreateTime, startDate) |
|---|
| | | .lt(ProcurementRecordOut::getCreateTime, endDate)); |
|---|
| | | // 获取当前月入库的物料总数量 |
|---|
| | | List<ProcurementRecordStorage> procurementRecordStorages = procurementRecordStorageMapper.selectList(new LambdaQueryWrapper<ProcurementRecordStorage>() |
|---|
| | | .ge(ProcurementRecordStorage::getCreateTime, startDate) |
|---|
| | | .lt(ProcurementRecordStorage::getCreateTime, endDate)); |
|---|
| | | BigDecimal reduce = procurementRecordOuts.stream() |
|---|
| | | .map(ProcurementRecordOut::getInboundNum) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | BigDecimal reduceOne = procurementRecordStorages.stream() |
|---|
| | | .map(ProcurementRecordStorage::getInboundNum) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | if(reduce.compareTo(BigDecimal.ZERO) > 0){ |
|---|
| | | qualityProductQualifiedRateDto.setInventoryTurnoverRate(reduceOne.divide(reduce, 4, RoundingMode.HALF_UP) |
|---|
| | | .multiply(BigDecimal.valueOf(100.0))); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return qualityProductQualifiedRateDto; |
|---|
| | | } |
|---|
| | | } |
|---|
