| | |
|---|
| | | package com.ruoyi.home.service.impl; |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|---|
| | | import com.ruoyi.account.pojo.AccountExpense; |
|---|
| | | import com.ruoyi.account.pojo.AccountIncome; |
|---|
| | | import com.ruoyi.approve.mapper.ApproveProcessMapper; |
|---|
| | | import com.ruoyi.approve.pojo.ApproveProcess; |
|---|
| | | import com.ruoyi.common.utils.SecurityUtils; |
|---|
| | |
|---|
| | | import com.ruoyi.framework.security.LoginUser; |
|---|
| | | import com.ruoyi.home.dto.*; |
|---|
| | | import com.ruoyi.home.service.HomeService; |
|---|
| | | import com.ruoyi.lavorissue.mapper.LavorIssueMapper; |
|---|
| | | import com.ruoyi.lavorissue.pojo.LaborIssue; |
|---|
| | | import com.ruoyi.procurementrecord.mapper.ProcurementRecordMapper; |
|---|
| | | import com.ruoyi.procurementrecord.mapper.ProcurementRecordOutMapper; |
|---|
| | | import com.ruoyi.procurementrecord.pojo.ProcurementRecordOut; |
|---|
| | | import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage; |
|---|
| | | import com.ruoyi.production.mapper.SalesLedgerWorkMapper; |
|---|
| | | import com.ruoyi.production.pojo.SalesLedgerWork; |
|---|
| | | import com.ruoyi.project.system.domain.SysDept; |
|---|
| | | import com.ruoyi.project.system.mapper.SysDeptMapper; |
|---|
| | | import com.ruoyi.purchase.mapper.PaymentRegistrationMapper; |
|---|
| | |
|---|
| | | |
|---|
| | | import java.math.BigDecimal; |
|---|
| | | import java.math.RoundingMode; |
|---|
| | | 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; |
|---|
| | |
|---|
| | | private PaymentRegistrationMapper paymentRegistrationMapper; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private LavorIssueMapper lavorIssueMapper; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private SysDeptMapper sysDeptMapper; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private SalesLedgerWorkMapper salesLedgerWorkMapper;; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public HomeBusinessDto business() { |
|---|
| | |
|---|
| | | |
|---|
| | | @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); |
|---|
| | | factoryNum= factoryNum.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); |
|---|
| | | processNum = processNum.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; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<ApproveProcess> todos() { |
|---|
| | | public List<ApproveProcess> todos() throws ParseException { |
|---|
| | | LoginUser loginUser = SecurityUtils.getLoginUser(); |
|---|
| | | LambdaQueryWrapper<ApproveProcess> approveProcessLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
|---|
| | | approveProcessLambdaQueryWrapper.eq(ApproveProcess::getApproveDelete, 0) |
|---|
| | | .eq(ApproveProcess::getApproveUserCurrentId, loginUser.getUserId()) |
|---|
| | | .ne(ApproveProcess::getApproveStatus, 2) |
|---|
| | | .eq(ApproveProcess::getTenantId, loginUser.getTenantId()); |
|---|
| | | return approveProcessMapper.selectList(approveProcessLambdaQueryWrapper); |
|---|
| | | List<ApproveProcess> approveProcesses = approveProcessMapper.selectList(approveProcessLambdaQueryWrapper); |
|---|
| | | if(CollectionUtils.isEmpty(approveProcesses)){ |
|---|
| | | approveProcesses = new ArrayList<>(); |
|---|
| | | } |
|---|
| | | // 查询未领用劳保记录 |
|---|
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
|---|
| | | |
|---|
| | | LaborIssue laborIssue1 = new LaborIssue(); |
|---|
| | | laborIssue1.setAdoptedDate(new Date()); |
|---|
| | | laborIssue1.setIssueDate(sdf.parse(sdf.format(new Date()))); |
|---|
| | | List<LaborIssue> laborIssues = lavorIssueMapper.list(laborIssue1); |
|---|
| | | if(!CollectionUtils.isEmpty(laborIssues)){ |
|---|
| | | for (LaborIssue laborIssue : laborIssues) { |
|---|
| | | ApproveProcess approveProcess = new ApproveProcess(); |
|---|
| | | approveProcess.setApproveId(laborIssue.getOrderNo()); |
|---|
| | | approveProcess.setApproveDeptName(sysDeptMapper.selectDeptById(loginUser.getTenantId()).getDeptName()); |
|---|
| | | approveProcess.setApproveTime(laborIssue.getIssueDate()); |
|---|
| | | approveProcess.setApproveReason(laborIssue.getDictTypeName() + "-" + laborIssue.getDictName() + "超时未领取"); |
|---|
| | | approveProcesses.add(approveProcess); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return approveProcesses; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | } |
|---|
| | | // 应收 |
|---|
| | | 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)){ |
|---|
| | | // 原材料合格率 |
|---|
| | | long rawwMaterialCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 0).count(); |
|---|
| | | long count = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 0).count(); |
|---|
| | | if(count > 0){ |
|---|
| | | qualityProductQualifiedRateDto.setRawMaterialQualifiedRate(new BigDecimal(rawwMaterialCount) |
|---|
| | | .divide(new BigDecimal( count), 4, RoundingMode.HALF_UP) |
|---|
| | | .multiply(BigDecimal.valueOf(100.0))); |
|---|
| | | } |
|---|
| | | // 过程合格率 |
|---|
| | | long processCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 1).count(); |
|---|
| | | long countOne = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 1).count(); |
|---|
| | | if(countOne > 0){ |
|---|
| | | qualityProductQualifiedRateDto.setProcessQualifiedRate(new BigDecimal(processCount) |
|---|
| | | .divide(new BigDecimal( countOne), 4, RoundingMode.HALF_UP) |
|---|
| | | .multiply(BigDecimal.valueOf(100.0))); |
|---|
| | | } |
|---|
| | | // 出厂合格率 |
|---|
| | | long factoryCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 2).count(); |
|---|
| | | long countTwo = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 2).count(); |
|---|
| | | if(countTwo > 0){ |
|---|
| | | qualityProductQualifiedRateDto.setFactoryQualifiedRate(new BigDecimal(factoryCount) |
|---|
| | | .divide(new BigDecimal( 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; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public QualityStatisticsDto inventoryStatistics() { |
|---|
| | | // 获取近四个月数据（往前推三个月，共4个完整月份） |
|---|
| | | LocalDate today = LocalDate.now(); |
|---|
| | | // 定义日期格式化器（用于显示“年月”格式） |
|---|
| | | DateTimeFormatter monthFormatter = DateTimeFormatter.ofPattern("yyyy-MM"); |
|---|
| | | |
|---|
| | | QualityStatisticsDto qualityStatisticsDto = new QualityStatisticsDto(); |
|---|
| | | List<QualityStatisticsItem> qualityStatisticsItems = new ArrayList<>(); |
|---|
| | | |
|---|
| | | BigDecimal supplierNum = new BigDecimal(0); //入库数量 |
|---|
| | | BigDecimal factoryNum = 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<ProcurementRecordStorage> queryWrapper = new LambdaQueryWrapper<>(); |
|---|
| | | queryWrapper.ge(ProcurementRecordStorage::getCreateTime, monthStart) |
|---|
| | | .le(ProcurementRecordStorage::getCreateTime, monthEnd); // 筛选当月数据 |
|---|
| | | List<ProcurementRecordStorage> monthInspects = procurementRecordStorageMapper.selectList(queryWrapper); |
|---|
| | | // 出库数量 |
|---|
| | | LambdaQueryWrapper<ProcurementRecordOut> queryWrapper1 = new LambdaQueryWrapper<>(); |
|---|
| | | queryWrapper1.ge(ProcurementRecordOut::getCreateTime, monthStart) |
|---|
| | | .le(ProcurementRecordOut::getCreateTime, monthEnd); |
|---|
| | | List<ProcurementRecordOut> monthInspects1 = procurementRecordOutMapper.selectList(queryWrapper1); |
|---|
| | | BigDecimal reduce = monthInspects.stream() |
|---|
| | | .map(ProcurementRecordStorage::getInboundNum) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | supplierNum = supplierNum.add(reduce); |
|---|
| | | BigDecimal reduce1 = monthInspects1.stream() |
|---|
| | | .map(ProcurementRecordOut::getInboundNum) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | factoryNum= factoryNum.add(reduce1); |
|---|
| | | |
|---|
| | | // 构建当月统计项 |
|---|
| | | QualityStatisticsItem item = new QualityStatisticsItem(); |
|---|
| | | item.setDate(monthStart.format(monthFormatter)); // 日期显示为“年月”（如 2025-10） |
|---|
| | | |
|---|
| | | // 1. 供应商检验（类型0）- 合格数量 |
|---|
| | | BigDecimal supplierQualified = monthInspects.stream() |
|---|
| | | .map(ProcurementRecordStorage::getInboundNum) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | item.setSupplierNum(supplierQualified); |
|---|
| | | |
|---|
| | | // 3. 工厂检验（类型2）- 合格数量 |
|---|
| | | BigDecimal factoryQualified = monthInspects1.stream() |
|---|
| | | .map(ProcurementRecordOut::getInboundNum) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | item.setFactoryNum(factoryQualified); |
|---|
| | | |
|---|
| | | qualityStatisticsItems.add(item); |
|---|
| | | } |
|---|
| | | // 统计近4个月总数据（所有月份汇总） |
|---|
| | | qualityStatisticsDto.setSupplierNum(supplierNum); |
|---|
| | | qualityStatisticsDto.setFactoryNum(factoryNum); |
|---|
| | | qualityStatisticsDto.setItem(qualityStatisticsItems); |
|---|
| | | |
|---|
| | | return qualityStatisticsDto; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Map<String, List<String>> productionStatistics() { |
|---|
| | | // 获取最近四个月（当前月 + 前3个月）的时间范围 |
|---|
| | | LocalDate today = LocalDate.now(); |
|---|
| | | DateTimeFormatter monthFormatter = DateTimeFormatter.ofPattern("yyyy-MM"); // 年月格式化器 |
|---|
| | | Map<String, List<String>> result = new HashMap<>(); |
|---|
| | | List<String> months = new ArrayList<>(); // 存储年月（如 2025-12、2025-11） |
|---|
| | | List<String> totalIncomeList = new ArrayList<>(); // 每月总收入 |
|---|
| | | List<String> totalExpenseList = new ArrayList<>(); // 每月总支出 |
|---|
| | | List<String> netIncomeList = new ArrayList<>(); // 每月净收入（收入-支出） |
|---|
| | | |
|---|
| | | // 步骤1：计算近4个月的年月列表（当前月、前1月、前2月、前3月） |
|---|
| | | List<String> targetMonths = new ArrayList<>(); |
|---|
| | | for (int i = 0; i < 4; i++) { |
|---|
| | | LocalDate currentMonth = today.minusMonths(i); |
|---|
| | | String monthStr = currentMonth.format(monthFormatter); |
|---|
| | | targetMonths.add(monthStr); |
|---|
| | | } |
|---|
| | | // 反转列表，确保顺序为「前3月 → 当前月」（可选，按需求调整顺序） |
|---|
| | | Collections.reverse(targetMonths); |
|---|
| | | |
|---|
| | | // 步骤2：一次性查询近4个月所有收入数据，按“年月”分组汇总 |
|---|
| | | LocalDate fourMonthsAgo = today.minusMonths(3).withDayOfMonth(1); // 近4个月起始日（前3月1号） |
|---|
| | | LocalDate currentMonthEnd = today.withDayOfMonth(today.lengthOfMonth()); // 当前月结束日 |
|---|
| | | ZoneId zoneId = ZoneId.of("Asia/Shanghai"); |
|---|
| | | // 查询近4个月所有收入 |
|---|
| | | List<SalesLedgerWork> allIncomes = salesLedgerWorkMapper.selectList( |
|---|
| | | Wrappers.<SalesLedgerWork>lambdaQuery() |
|---|
| | | .ge(SalesLedgerWork::getSchedulingDate, fourMonthsAgo.toString()) // 大于等于起始日 |
|---|
| | | .le(SalesLedgerWork::getSchedulingDate, currentMonthEnd.toString()) // 小于等于结束日 |
|---|
| | | ); |
|---|
| | | |
|---|
| | | // 待生产 |
|---|
| | | Map<String, BigDecimal> monthlyIncomeMap = allIncomes.stream() |
|---|
| | | .filter(income -> income.getSchedulingNum() != null && income.getStatus().equals(1)) // 过滤空金额 |
|---|
| | | .collect(Collectors.groupingBy( |
|---|
| | | income -> { |
|---|
| | | // 将输入时间（字符串）转换为LocalDate，再格式化为年月 |
|---|
| | | return income.getSchedulingDate().format(monthFormatter); |
|---|
| | | }, |
|---|
| | | Collectors.reducing(BigDecimal.ZERO, SalesLedgerWork::getSchedulingNum, BigDecimal::add) |
|---|
| | | )); |
|---|
| | | |
|---|
| | | // 生产中 |
|---|
| | | Map<String, BigDecimal> monthlyExpenseMap = allIncomes.stream() |
|---|
| | | .filter(income -> income.getSchedulingNum() != null && income.getStatus().equals(2)) // 过滤空金额 |
|---|
| | | .collect(Collectors.groupingBy( |
|---|
| | | income -> { |
|---|
| | | // 将输入时间（字符串）转换为LocalDate，再格式化为年月 |
|---|
| | | return income.getSchedulingDate().format(monthFormatter); |
|---|
| | | }, |
|---|
| | | Collectors.reducing(BigDecimal.ZERO, SalesLedgerWork::getSchedulingNum, BigDecimal::add) |
|---|
| | | )); |
|---|
| | | |
|---|
| | | // 已报工 |
|---|
| | | Map<String, BigDecimal> successIncomeMap = allIncomes.stream() |
|---|
| | | .filter(income -> income.getSchedulingNum() != null && income.getStatus().equals(3)) // 过滤空金额 |
|---|
| | | .collect(Collectors.groupingBy( |
|---|
| | | income -> { |
|---|
| | | // 将输入时间（字符串）转换为LocalDate，再格式化为年月 |
|---|
| | | return income.getSchedulingDate().format(monthFormatter); |
|---|
| | | }, |
|---|
| | | Collectors.reducing(BigDecimal.ZERO, SalesLedgerWork::getSchedulingNum, BigDecimal::add) |
|---|
| | | )); |
|---|
| | | |
|---|
| | | // 步骤4：循环4个目标月份，填充统计数据（无数据时默认为0） |
|---|
| | | for (String month : targetMonths) { |
|---|
| | | // 待生产 |
|---|
| | | BigDecimal totalIncome = monthlyIncomeMap.getOrDefault(month, BigDecimal.ZERO); |
|---|
| | | // 生产中 |
|---|
| | | BigDecimal totalExpense = monthlyExpenseMap.getOrDefault(month, BigDecimal.ZERO); |
|---|
| | | // 已报工 |
|---|
| | | BigDecimal netIncome = successIncomeMap.getOrDefault(month, BigDecimal.ZERO); |
|---|
| | | |
|---|
| | | // 填充列表 |
|---|
| | | months.add(month); |
|---|
| | | totalIncomeList.add(totalIncome.toString()); |
|---|
| | | totalExpenseList.add(totalExpense.toString()); |
|---|
| | | netIncomeList.add(netIncome.toString()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 组装结果 |
|---|
| | | result.put("days", months); // 年月（如 ["2025-09", "2025-10", "2025-11", "2025-12"]） |
|---|
| | | result.put("totalIncome", totalIncomeList); // 待生产 |
|---|
| | | result.put("totalExpense", totalExpenseList); // 生产中 |
|---|
| | | result.put("netIncome", netIncomeList); // 已报工 |
|---|
| | | |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | } |
|---|
