From 112d522999edce5c59515ec1de49785219d56fec Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期五, 12 十二月 2025 15:33:02 +0800
Subject: [PATCH] yys

---
 src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java |  163 ++++++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 127 insertions(+), 36 deletions(-)

diff --git a/src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java b/src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java
index ad6ca2f..ca2443b 100644
--- a/src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java
+++ b/src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java
@@ -38,6 +38,7 @@
 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;
@@ -261,50 +262,83 @@
 
     @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锛氬綋鍓嶆湀锛宨=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;
     }
 
@@ -404,4 +438,61 @@
 
         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;
+    }
 }

--
Gitblit v1.9.3