From 7eb970282c629c14a28d9f7af3777419bfb290fc Mon Sep 17 00:00:00 2001
From: zss <zss@example.com>
Date: 星期二, 20 一月 2026 11:11:45 +0800
Subject: [PATCH] 大屏生产统计调整

---
 src/main/java/com/ruoyi/production/mapper/ProductWorkOrderMapper.java |    1 
 src/main/resources/mapper/production/ProductWorkOrderMapper.xml       |    8 +-
 src/main/java/com/ruoyi/home/dto/ProductionTurnoverDto.java           |   27 +++++++++
 src/main/resources/mapper/production/ProductOrderMapper.xml           |    3 +
 src/main/java/com/ruoyi/home/controller/HomeController.java           |    4 
 src/main/java/com/ruoyi/home/dto/ProductionProgressDto.java           |   10 +-
 src/main/java/com/ruoyi/home/service/HomeService.java                 |    4 
 src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java        |   78 ++++++++++++++++---------
 8 files changed, 92 insertions(+), 43 deletions(-)

diff --git a/src/main/java/com/ruoyi/home/controller/HomeController.java b/src/main/java/com/ruoyi/home/controller/HomeController.java
index 62f6715..3224c0f 100644
--- a/src/main/java/com/ruoyi/home/controller/HomeController.java
+++ b/src/main/java/com/ruoyi/home/controller/HomeController.java
@@ -99,7 +99,7 @@
     @GetMapping("/workInProcessTurnover")
     @ApiOperation("鍦ㄥ埗鍝佸懆杞儏鍐�")
     public AjaxResult workInProcessTurnover(){
-        Map<Integer, List<ProductWorkOrderDto>> productWorkOrderDtoMap = homeService.workInProcessTurnover();
-        return AjaxResult.success(productWorkOrderDtoMap);
+        ProductionTurnoverDto productionTurnoverDto = homeService.workInProcessTurnover();
+        return AjaxResult.success(productionTurnoverDto);
     }
 }
diff --git a/src/main/java/com/ruoyi/home/dto/ProductionProgressDto.java b/src/main/java/com/ruoyi/home/dto/ProductionProgressDto.java
index 99d9e61..88fe4b6 100644
--- a/src/main/java/com/ruoyi/home/dto/ProductionProgressDto.java
+++ b/src/main/java/com/ruoyi/home/dto/ProductionProgressDto.java
@@ -12,14 +12,14 @@
 @ApiModel
 public class ProductionProgressDto {
     @ApiModelProperty("鎬昏鍗曟暟")
-    private Integer totalOrderCount;
+    private Long totalOrderCount;
 
     @ApiModelProperty("宸插畬鎴愯鍗曟暟")
-    private Integer completedOrderCount;
+    private Long completedOrderCount;
     @ApiModelProperty("鏈畬鎴愯鍗曟暟")
-    private Integer uncompletedOrderCount;
-    @ApiModelProperty("鎬讳綋瀹屾垚杩涘害")
-    private BigDecimal completedProgressCount;
+    private Long uncompletedOrderCount;
+    @ApiModelProperty("閮ㄥ垎瀹屾垚璁㈠崟鏁�")
+    private Long partialCompletedOrderCount;
     @ApiModelProperty("璁㈠崟璇︽儏")
     private List<ProductOrderDto> completedOrderDetails;
 }
diff --git a/src/main/java/com/ruoyi/home/dto/ProductionTurnoverDto.java b/src/main/java/com/ruoyi/home/dto/ProductionTurnoverDto.java
new file mode 100644
index 0000000..41ad82b
--- /dev/null
+++ b/src/main/java/com/ruoyi/home/dto/ProductionTurnoverDto.java
@@ -0,0 +1,27 @@
+package com.ruoyi.home.dto;
+
+import com.ruoyi.production.dto.ProductOrderDto;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+@Data
+@ApiModel
+public class ProductionTurnoverDto {
+    @ApiModelProperty("鎬诲湪鍒舵暟閲�")
+    private Long totalOrderCount;
+
+    @ApiModelProperty("骞冲潎鍛ㄨ浆澶╂暟")
+    private BigDecimal averageTurnoverDays;
+    @ApiModelProperty("鍛ㄨ浆鏁堢巼")
+    private BigDecimal turnoverEfficiency;
+
+    @ApiModelProperty("宸ュ簭璇︽儏")
+    private List<String> processDetails;
+
+    @ApiModelProperty("宸ュ簭瀵瑰簲鐨勬暟閲忚鎯�")
+    private List<Long> processQuantityDetails;
+}
diff --git a/src/main/java/com/ruoyi/home/service/HomeService.java b/src/main/java/com/ruoyi/home/service/HomeService.java
index 010e8c1..2dbab27 100644
--- a/src/main/java/com/ruoyi/home/service/HomeService.java
+++ b/src/main/java/com/ruoyi/home/service/HomeService.java
@@ -31,6 +31,6 @@
 
     Long noticesCount();
 
-     ProductionProgressDto productionProgress();
-     Map<Integer, List<ProductWorkOrderDto>> workInProcessTurnover();
+    ProductionProgressDto productionProgress();
+    ProductionTurnoverDto workInProcessTurnover();
 }
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 fecd4d1..85f9719 100644
--- a/src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java
+++ b/src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java
@@ -2,6 +2,7 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.ruoyi.approve.mapper.ApproveProcessMapper;
 import com.ruoyi.approve.pojo.ApproveProcess;
@@ -31,9 +32,11 @@
 import com.ruoyi.production.dto.ProductWorkOrderDto;
 import com.ruoyi.production.dto.ProductionProductMainDto;
 import com.ruoyi.production.mapper.ProductOrderMapper;
+import com.ruoyi.production.mapper.ProductProcessMapper;
 import com.ruoyi.production.mapper.ProductWorkOrderMapper;
 import com.ruoyi.production.mapper.ProductionProductMainMapper;
 import com.ruoyi.production.pojo.ProductOrder;
+import com.ruoyi.production.pojo.ProductProcess;
 import com.ruoyi.production.pojo.ProductWorkOrder;
 import com.ruoyi.project.system.domain.SysDept;
 import com.ruoyi.project.system.mapper.SysDeptMapper;
@@ -60,6 +63,7 @@
 import java.text.SimpleDateFormat;
 import java.time.*;
 import java.time.format.DateTimeFormatter;
+import java.time.temporal.ChronoUnit;
 import java.time.temporal.TemporalAdjusters;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -114,7 +118,7 @@
     @Autowired
     private ProductOrderMapper productOrderMapper;
     @Autowired
-    private ProductionProductMainMapper productionProductMainMapper;
+    private ProductProcessMapper productProcessMapper;
     @Autowired
     private ProductWorkOrderMapper productWorkOrderMapper;
     @Autowired
@@ -528,37 +532,55 @@
     @Override
     public ProductionProgressDto productionProgress() {
         ProductionProgressDto productionProgressDto = new ProductionProgressDto();
-        List<ProductOrder> productOrderList = productOrderMapper.selectList(new LambdaQueryWrapper<ProductOrder>());
-        List<ProductOrderDto> productOrderDtoList = new ArrayList<>();
-        productOrderList.forEach(productOrder -> {
-            ProductOrderDto productOrderDto = productOrderMapper.productMainByOrderId(productOrder);
-//            if (productOrderDto != null && productOrderDto.getPlanQuantity() != null && productOrderDto.getQuantity() != null) {
-//                productOrderDto.setCompletionStatus((productOrderDto.getPlanQuantity().subtract(productOrderDto.getQuantity())).divide(productOrderDto.getPlanQuantity(), 2, RoundingMode.HALF_UP));
-//            }
-            productOrderDtoList.add(productOrderDto);
-        });
-        productionProgressDto.setCompletedOrderDetails(productOrderDtoList);
-        // 1. 鏌ヨ鎵�鏈夌敓浜ц鍗曪紙鍙牴鎹渶姹傛坊鍔犺繃婊ゆ潯浠讹紝濡傛帓闄ゅ凡鍒犻櫎銆佸凡鍙栨秷鐨勮鍗曪級
-        IPage<ProductOrderDto> productOrderDtoIPage = productOrderMapper.pageProductOrder(new Page<>(1, -1), new ProductOrderDto());
-
-        // 2. 鍒濆鍖栨眹鎬绘暟鎹�
-        int totalCount = productOrderDtoIPage.getRecords().size();
-        int completedCount = (int) productOrderDtoIPage.getRecords().stream().map(productOrderDto -> productOrderMapper.productMainByOrderId(productOrderDto)).filter(productOrderDto1 -> productOrderDto1.getQuantity() != null && productOrderDto1.getQuantity().compareTo(BigDecimal.ZERO) == 0).count();
-
-        // 6. 璧嬪�兼眹鎬绘暟鎹�
+        ProductOrderDto orderDto = new ProductOrderDto();
+        orderDto.setStartTime(LocalDateTime.now().minusMonths(1));
+        orderDto.setEndTime(LocalDateTime.now());
+        List<ProductOrderDto> productOrderDtos = productOrderMapper.pageProductOrder(new Page<>(1, -1), orderDto).getRecords();
+        productionProgressDto.setCompletedOrderDetails(productOrderDtos);
+        long totalCount = productOrderDtos.size();
+        long count = productOrderDtos.stream().filter(productOrderDto -> productOrderDto.getCompleteQuantity().compareTo(productOrderDto.getQuantity()) >= 0).count();
+        long count2 = productOrderDtos.stream().filter(productOrderDto -> productOrderDto.getCompleteQuantity().compareTo(BigDecimal.ZERO) == 0).count();
         productionProgressDto.setTotalOrderCount(totalCount);
-        productionProgressDto.setCompletedOrderCount(completedCount);
-        productionProgressDto.setUncompletedOrderCount(totalCount - completedCount);
-        productionProgressDto.setCompletedProgressCount(BigDecimal.valueOf(completedCount).divide(BigDecimal.valueOf(totalCount), 2, RoundingMode.HALF_UP));
+        productionProgressDto.setCompletedOrderCount(count);
+        productionProgressDto.setUncompletedOrderCount(count2);
+        productionProgressDto.setPartialCompletedOrderCount(totalCount-count-count2);
         return productionProgressDto;
     }
     @Override
-    public Map<Integer, List<ProductWorkOrderDto>> workInProcessTurnover() {
-        List<ProductWorkOrderDto> productWorkOrderDtoList = productWorkOrderMapper.selectProductWorkOrderDtoList();
-       //鏍规嵁鐘舵�佸尯鍒嗗伐鍗曠殑鍚勪釜鐘舵��
-        Map<Integer, List<ProductWorkOrderDto>> productWorkOrderDtoMap = productWorkOrderDtoList.stream().collect(Collectors.groupingBy(ProductWorkOrderDto::getStatus));
-
-        return productWorkOrderDtoMap;
+    public ProductionTurnoverDto workInProcessTurnover() {
+        ProductionTurnoverDto productionTurnoverDto = new ProductionTurnoverDto();
+        ProductWorkOrderDto workOrder = new ProductWorkOrderDto();
+        workOrder.setPlanStartTime(LocalDate.now().minusMonths(1));
+        workOrder.setPlanEndTime(LocalDate.now());
+        List<ProductWorkOrderDto> productWorkOrders = productWorkOrderMapper.pageProductWorkOrder(new Page<>(1, -1), workOrder).getRecords();
+        long sum = productWorkOrders.stream()
+                .filter(productWorkOrder -> productWorkOrder.getPlanQuantity().compareTo(productWorkOrder.getCompleteQuantity()) > 0)
+                .map(ProductWorkOrder::getPlanQuantity)
+                .mapToLong(BigDecimal::longValue)
+                .sum();
+        if (sum == 0)return null;
+        productionTurnoverDto.setTotalOrderCount(sum);//鎬诲湪鍒跺搧鏁伴噺
+        productionTurnoverDto.setAverageTurnoverDays(BigDecimal.valueOf(sum).divide(BigDecimal.valueOf(ChronoUnit.DAYS.between(LocalDateTime.now().minusMonths(1), LocalDateTime.now())),2,RoundingMode.HALF_UP));
+        long completeQuantity = productWorkOrders.stream()
+                .filter(productWorkOrder -> productWorkOrder.getCompleteQuantity().compareTo(productWorkOrder.getPlanQuantity()) >= 0)
+                .map(ProductWorkOrder::getCompleteQuantity)
+                .mapToLong(BigDecimal::longValue)
+                .sum();
+        productionTurnoverDto.setTurnoverEfficiency(BigDecimal.valueOf(completeQuantity).divide(BigDecimal.valueOf(sum),2,RoundingMode.HALF_UP));
+        Map<String, List<ProductWorkOrderDto>> map = productWorkOrders.stream()
+                .filter(productWorkOrder -> productWorkOrder.getPlanQuantity().compareTo(productWorkOrder.getCompleteQuantity()) > 0)
+                .collect(Collectors.groupingBy(ProductWorkOrderDto::getProcessName));
+        List<String> strings = new ArrayList<>();
+        List<Long> processQuantityDetails = new ArrayList<>();
+        map.entrySet().stream().forEach(entry -> {
+            String key = entry.getKey();
+            long completeSum = entry.getValue().stream().map(ProductWorkOrderDto::getCompleteQuantity).mapToLong(BigDecimal::longValue).sum();
+            strings.add(key);
+            processQuantityDetails.add(completeSum);
+        });
+        productionTurnoverDto.setProcessDetails(strings);
+        productionTurnoverDto.setProcessQuantityDetails(processQuantityDetails);
+        return productionTurnoverDto;
 
     }
 }
diff --git a/src/main/java/com/ruoyi/production/mapper/ProductWorkOrderMapper.java b/src/main/java/com/ruoyi/production/mapper/ProductWorkOrderMapper.java
index 46f988f..8a8a52f 100644
--- a/src/main/java/com/ruoyi/production/mapper/ProductWorkOrderMapper.java
+++ b/src/main/java/com/ruoyi/production/mapper/ProductWorkOrderMapper.java
@@ -17,5 +17,4 @@
 
     IPage<ProductWorkOrderDto> pageProductWorkOrder(Page<ProductWorkOrderDto> page, @Param("c") ProductWorkOrderDto productWorkOrder);
 
-    List<ProductWorkOrderDto> selectProductWorkOrderDtoList();
 }
diff --git a/src/main/resources/mapper/production/ProductOrderMapper.xml b/src/main/resources/mapper/production/ProductOrderMapper.xml
index b47d5cf..28e03b5 100644
--- a/src/main/resources/mapper/production/ProductOrderMapper.xml
+++ b/src/main/resources/mapper/production/ProductOrderMapper.xml
@@ -43,6 +43,9 @@
             <if test="c.specificationModel != null and c.specificationModel != ''">
                 and slp.specification_model like concat('%',#{c.specificationModel},'%')
             </if>
+            <if test="c.startTime != null and c.endTime != null">
+                and po.create_time between #{c.startTime} and #{c.endTime}
+            </if>
         </where>
     </select>
     <select id="productMainByOrderId" resultType="com.ruoyi.production.dto.ProductOrderDto">
diff --git a/src/main/resources/mapper/production/ProductWorkOrderMapper.xml b/src/main/resources/mapper/production/ProductWorkOrderMapper.xml
index 9a03b30..06f79e1 100644
--- a/src/main/resources/mapper/production/ProductWorkOrderMapper.xml
+++ b/src/main/resources/mapper/production/ProductWorkOrderMapper.xml
@@ -38,11 +38,9 @@
             <if test="c.workOrderNo != null and c.workOrderNo != ''">
                 pwo.work_order_no like concat('%',#{c.workOrderNo},'%')
             </if>
+            <if test="c.planStartTime != null and c.planEndTime != null">
+                and DATE(pwo.create_time) between #{c.planStartTime} and #{c.planEndTime}
+            </if>
         </where>
-    </select>
-    <select id="selectProductWorkOrderDtoList" resultType="com.ruoyi.production.dto.ProductWorkOrderDto">
-        select *
-        from product_work_order pwo
-        left join product_order po on po.id = pwo.product_order_id
     </select>
 </mapper>

--
Gitblit v1.9.3