diff --git a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/controller/ProdReportController.java b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/controller/ProdReportController.java
index 831efd34..437a37c6 100644
--- a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/controller/ProdReportController.java
+++ b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/controller/ProdReportController.java
@@ -192,4 +192,22 @@ public class ProdReportController extends BaseController {
         return R.ok(vos);
     }
 
+    /**
+     * 工序工单统计（按工序聚合）：完成数量、未完成数量与完成率
+     */
+    @GetMapping("/processWorkOrderStats")
+    public R<List<HashMap<String, Object>>> processWorkOrderStats(@RequestParam(required = false) Map hashMap) {
+        List<HashMap<String, Object>> vos = prodReportService.processWorkOrderStats(hashMap);
+        return R.ok(vos);
+    }
+
+    /**
+     * 工序下的计划子节点查询：按 plan_code + process_id 过滤，关联明细表
+     */
+    @GetMapping("/planProcessChildren")
+    public R<List<HashMap<String, Object>>> planProcessChildren(@RequestParam(required = false) Map hashMap) {
+        List<HashMap<String, Object>> vos = prodReportService.planProcessDetailChildren(hashMap);
+        return R.ok(vos);
+    }
+
 }
diff --git a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/domain/vo/ProcessProgressVo.java b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/domain/vo/ProcessProgressVo.java
index 832e24b5..601d850a 100644
--- a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/domain/vo/ProcessProgressVo.java
+++ b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/domain/vo/ProcessProgressVo.java
@@ -23,6 +23,7 @@ public class ProcessProgressVo implements Serializable {
      * 产品订单ID（用于批量查询结果分组）
      */
     private Long productOrderId;
+    private String planCode;
 
     /**
      * 工序ID
@@ -98,4 +99,22 @@ public class ProcessProgressVo implements Serializable {
      * 实际结束时间
      */
     private LocalDateTime realEndTime;
+
+    /**
+     * 物料名称（来自计划表关联的物料）
+     */
+    private String materialName;
+
+    /**
+     * 物料编码（来自计划表关联的物料）
+     */
+    private String materialCode;
+
+    // public String getPlanCode() {
+    //     return planCode;
+    // }
+
+    // public void setPlanCode(String planCode) {
+    //     this.planCode = planCode;
+    // }
 }
\ No newline at end of file
diff --git a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/mapper/ProdReportMapper.java b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/mapper/ProdReportMapper.java
index 24cb9413..88376a8a 100644
--- a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/mapper/ProdReportMapper.java
+++ b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/mapper/ProdReportMapper.java
@@ -124,22 +124,40 @@ public interface ProdReportMapper {
     Long wipTrackingReportCount(@Param("map") Map hashMap);
 
     /**
-     * 获取订单的工序进度详情（单订单）
+     * 工序下的计划子节点查询：按 plan_code + process_id 过滤，关联明细表
      */
-    List<ProcessProgressVo> getOrderProcessProgress(@Param("productOrderId") Long productOrderId, @Param("planTableName") String planTableName);
+    List<HashMap<String, Object>> getPlanProcessDetailChildren(@Param("planCode") String planCode,
+                                                               @Param("processId") Long processId,
+                                                               @Param("detailTableName") String detailTableName,
+                                                               @Param("planTableName") String planTableName,
+                                                               @Param("tenantId") String tenantId);
 
     /**
-     * 批量获取订单的工序进度详情（避免N+1，一次查询一个工序表）
-     * @param productOrderIds 订单ID列表
+     * 获取计划的工序进度详情（单计划，按planCode）
+     */
+    List<ProcessProgressVo> getPlanProcessProgress(@Param("planCode") String planCode,
+                                                   @Param("planTableName") String planTableName);
+
+    /**
+     * 批量获取计划的工序进度详情（按planCode批量）
+     * @param planCodes 计划编码列表
      * @param planTableName 工序表名（prod_plan_info_2/_3/_4）
+     * @param tenantId 租户ID（可选）
      * @return 工序进度明细
      */
-    List<ProcessProgressVo> getOrdersProcessProgressBatch(@Param("productOrderIds") List<Long> productOrderIds,
-                                                          @Param("planTableName") String planTableName,
-                                                          @Param("tenantId") String tenantId);
+    List<ProcessProgressVo> getPlansProcessProgressBatch(@Param("planCodes") List<String> planCodes,
+                                                         @Param("planTableName") String planTableName,
+                                                         @Param("tenantId") String tenantId);
 
     // 新增：小时产量统计（按结束时间小时分桶）
     List<HashMap<String, Object>> hourlyOutputByHour(@Param("map") Map hashMap,
                                                      @Param("detailTableName") String detailTableName,
                                                      @Param("planTableName") String planTableName);
+
+    /**
+     * 工序工单统计（按工序聚合）
+     * 返回各工序的未开工、在制未完成、延期未完成、完成率等指标
+     */
+    List<HashMap<String, Object>> processWorkOrderStats(@Param("map") Map hashMap,
+                                                        @Param("planTableName") String planTableName);
 }
diff --git a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/IProdReportService.java b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/IProdReportService.java
index 133f0e54..4f03c98f 100644
--- a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/IProdReportService.java
+++ b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/IProdReportService.java
@@ -136,4 +136,18 @@ public interface IProdReportService {
      */
     List<HashMap<String, Object>> hourlyOutputByHour(Map hashMap);
 
+    /**
+     * 工序工单统计（按工序聚合）：完成数量、未完成数量与完成率
+     * @param hashMap 查询条件：beginDate/endDate、processId、machineId、shiftId、classTeamId、materialName
+     * @return 各工序聚合统计列表
+     */
+    List<HashMap<String, Object>> processWorkOrderStats(Map hashMap);
+
+    /**
+     * 工序下的计划子节点查询：按 plan_code + process_id 过滤，关联明细表
+     * @param hashMap 查询条件：planCode、processId
+     * @return 计划明细子节点列表
+     */
+    List<HashMap<String, Object>> planProcessDetailChildren(Map hashMap);
+
 }
diff --git a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/impl/ProdReportServiceImpl.java b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/impl/ProdReportServiceImpl.java
index 4378a870..5586c5b3 100644
--- a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/impl/ProdReportServiceImpl.java
+++ b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/impl/ProdReportServiceImpl.java
@@ -172,7 +172,7 @@ public class ProdReportServiceImpl implements IProdReportService {
     // 新增辅助方法用于安全解析 processId
     private Long parseProcessId(Object processIdObj) {
         if (processIdObj == null) {
-            return null; // 或者根据业务需要返回默认值如 16L
+            return null;
         }
 
         try {
@@ -208,6 +208,14 @@ public class ProdReportServiceImpl implements IProdReportService {
      */
     @Override
     public TableDataInfo<WipTrackingReportVo> wipTrackingReportList(Map hashMap, PageQuery pageQuery) {
+        // 注入租户范围，确保仅查询当前租户数据
+        try {
+            String tenantId = LoginHelper.getTenantId();
+            if (tenantId != null && !tenantId.isEmpty()) {
+                hashMap.put("tenantId", tenantId);
+            }
+        } catch (Exception ignore) {
+        }
         // 使用优化后的SQL查询，大部分计算已在数据库层完成
         // 关闭自动 count，避免对复杂 CTE SQL 的解析失败
         Page<WipTrackingReportVo> mpPage = pageQuery.build();
@@ -237,6 +245,15 @@ public class ProdReportServiceImpl implements IProdReportService {
      */
     @Override
     public List<WipTrackingReportVo> wipTrackingReportList(Map hashMap) {
+        // 注入租户范围，确保仅查询当前租户数据
+        try {
+            String tenantId = LoginHelper.getTenantId();
+            if (tenantId != null && !tenantId.isEmpty()) {
+                hashMap.put("tenantId", tenantId);
+            }
+        } catch (Exception ignore) {
+        }
+
         // 使用优化后的SQL查询，大部分计算已在数据库层完成
         List<WipTrackingReportVo> list = prodReportMapper.wipTrackingReportList(hashMap);
 
@@ -255,28 +272,28 @@ public class ProdReportServiceImpl implements IProdReportService {
             return;
         }
 
-        // 批量获取所有订单的工序进度信息
-        Map<Long, List<ProcessProgressVo>> orderProcessMap = new HashMap<>();
+        // 批量获取所有计划的工序进度信息（按planCode维度）
+        Map<String, List<ProcessProgressVo>> planProcessMap = new HashMap<>();
 
         try {
-            // 收集所有需要查询的订单ID
-            List<Long> orderIds = reportList.stream()
-                    .map(WipTrackingReportVo::getProductOrderId)
-                    .filter(Objects::nonNull)
+            // 收集所有需要查询的计划编码
+            List<String> planCodes = reportList.stream()
+                    .map(WipTrackingReportVo::getPlanCode)
+                    .filter(code -> code != null && !code.isEmpty())
                     .distinct()
                     .collect(Collectors.toList());
 
-            if (orderIds.isEmpty()) {
+            if (planCodes.isEmpty()) {
                 return;
             }
 
-            // 批量查询各个工序表的进度信息
-            batchQueryProcessProgress(orderIds, orderProcessMap);
+            // 批量查询各个工序表的进度信息（按计划编码）
+            batchQueryProcessProgress(planCodes, planProcessMap);
 
             // 为每个报表项设置工序进度信息
             for (WipTrackingReportVo vo : reportList) {
-                if (vo.getProductOrderId() != null) {
-                    List<ProcessProgressVo> processProgress = orderProcessMap.get(vo.getProductOrderId());
+                if (vo.getPlanCode() != null && !vo.getPlanCode().isEmpty()) {
+                    List<ProcessProgressVo> processProgress = planProcessMap.get(vo.getPlanCode());
                     if (processProgress != null && !processProgress.isEmpty()) {
                         vo.setProcessProgressList(processProgress);
                         // 基于实际工序进度微调计算结果
@@ -288,7 +305,7 @@ public class ProdReportServiceImpl implements IProdReportService {
             }
 
         } catch (Exception e) {
-            System.out.println("批量获取工序进度信息失败: " + e.getMessage());
+            System.out.println("批量获取工序进度信息失败(按planCode): " + e.getMessage());
             // 降级处理：为每个订单单独查询
             fallbackToIndividualQuery(reportList);
         }
@@ -299,18 +316,18 @@ public class ProdReportServiceImpl implements IProdReportService {
      * @param orderIds 订单ID列表
      * @param orderProcessMap 结果映射
      */
-    private void batchQueryProcessProgress(List<Long> orderIds, Map<Long, List<ProcessProgressVo>> orderProcessMap) {
+    private void batchQueryProcessProgress(List<String> planCodes, Map<String, List<ProcessProgressVo>> planProcessMap) {
         // 查询半制品工序进度（prod_plan_info_2）
-        queryProcessProgressByTable(orderIds, "prod_plan_info_2", orderProcessMap);
+        queryProcessProgressByTable(planCodes, "prod_plan_info_2", planProcessMap);
 
         // 查询成型工序进度（prod_plan_info_3）
-        queryProcessProgressByTable(orderIds, "prod_plan_info_3", orderProcessMap);
+        queryProcessProgressByTable(planCodes, "prod_plan_info_3", planProcessMap);
 
         // 查询硫化工序进度（prod_plan_info_4）
-        queryProcessProgressByTable(orderIds, "prod_plan_info_4", orderProcessMap);
+        queryProcessProgressByTable(planCodes, "prod_plan_info_4", planProcessMap);
 
-        // 对每个订单的工序进度进行排序
-        orderProcessMap.values().forEach(processList ->
+        // 对每个计划的工序进度进行排序
+        planProcessMap.values().forEach(processList ->
             processList.sort((a, b) -> {
                 if (a.getProcessOrder() == null) return 1;
                 if (b.getProcessOrder() == null) return -1;
@@ -325,23 +342,23 @@ public class ProdReportServiceImpl implements IProdReportService {
      * @param tableName 表名
      * @param orderProcessMap 结果映射
      */
-    private void queryProcessProgressByTable(List<Long> orderIds, String tableName, Map<Long, List<ProcessProgressVo>> orderProcessMap) {
+    private void queryProcessProgressByTable(List<String> planCodes, String tableName, Map<String, List<ProcessProgressVo>> planProcessMap) {
         try {
-            // 使用批量查询避免 N+1：一次性查询该工序表下所有订单的工序进度
-            // 返回结果中包含 productOrderId 字段，便于在此处进行分组
+            // 使用批量查询避免 N+1：一次性查询该工序表下所有计划的工序进度
+            // 返回结果中包含 planCode 字段，便于在此处进行分组
             String tenantId = LoginHelper.getTenantId();
-            List<ProcessProgressVo> batchResults = prodReportMapper.getOrdersProcessProgressBatch(orderIds, tableName, tenantId);
+            List<ProcessProgressVo> batchResults = prodReportMapper.getPlansProcessProgressBatch(planCodes, tableName, tenantId);
             if (batchResults != null && !batchResults.isEmpty()) {
                 for (ProcessProgressVo progress : batchResults) {
-                    Long orderId = progress.getProductOrderId();
-                    if (orderId != null) {
-                        orderProcessMap.computeIfAbsent(orderId, k -> new ArrayList<>()).add(progress);
+                    String planCode = progress.getPlanCode();
+                    if (planCode != null && !planCode.isEmpty()) {
+                        planProcessMap.computeIfAbsent(planCode, k -> new ArrayList<>()).add(progress);
                     }
                 }
             }
         } catch (Exception e) {
             // 记录失败但不中断整体处理，后续会有降级策略
-            System.out.println("批量查询表 " + tableName + " 的工序进度失败: " + e.getMessage());
+            System.out.println("批量查询表 " + tableName + " 的工序进度失败(按planCode): " + e.getMessage());
         }
     }
 
@@ -388,7 +405,7 @@ public class ProdReportServiceImpl implements IProdReportService {
              vo.setRemainingProcesses(remainingProcesses);
 
         } catch (Exception e) {
-            System.out.println("微调进度计算失败，订单ID: " + vo.getProductOrderId() + ", 错误: " + e.getMessage());
+            System.out.println("微调进度计算失败，计划编码: " + vo.getPlanCode() + ", 错误: " + e.getMessage());
         }
     }
 
@@ -398,13 +415,13 @@ public class ProdReportServiceImpl implements IProdReportService {
      */
     private void fallbackToIndividualQuery(List<WipTrackingReportVo> reportList) {
         for (WipTrackingReportVo vo : reportList) {
-            if (vo.getProductOrderId() != null) {
+            if (vo.getPlanCode() != null && !vo.getPlanCode().isEmpty()) {
                 try {
-                    List<ProcessProgressVo> processProgress = getAllOrderProcessProgressOptimized(vo.getProductOrderId());
+                    List<ProcessProgressVo> processProgress = getAllPlanProcessProgressOptimized(vo.getPlanCode());
                     vo.setProcessProgressList(processProgress);
                     adjustProgressCalculation(vo, processProgress);
                 } catch (Exception e) {
-                    System.out.println("单独查询订单工序进度失败，订单ID: " + vo.getProductOrderId());
+                    System.out.println("单独查询计划工序进度失败，计划编码: " + vo.getPlanCode());
                     vo.setProcessProgressList(new ArrayList<>());
                 }
             }
@@ -412,40 +429,47 @@ public class ProdReportServiceImpl implements IProdReportService {
     }
 
     /**
-     * 获取订单的所有工序进度详情（优化版本）
-     * @param productOrderId 产品订单ID
+     * 工序下的计划子节点查询：按 plan_code + process_id 过滤，关联明细表
+     */
+    @Override
+    public List<HashMap<String, Object>> planProcessDetailChildren(Map hashMap) {
+        Long processId = parseProcessId(hashMap.get("processId"));
+        String detailTable = getPlanDetailTableNameByProcessId(processId);
+        String planTable = getPlanInfoTableNameByProcessId(processId);
+        String planCode = String.valueOf(hashMap.get("planCode"));
+        String tenantId = LoginHelper.getTenantId();
+        return prodReportMapper.getPlanProcessDetailChildren(planCode, processId, detailTable, planTable, tenantId);
+    }
+
+    /**
+     * 获取计划的所有工序进度详情（优化版本，按planCode）
+     * @param planCode 计划编码
      * @return 工序进度列表
      */
-    private List<ProcessProgressVo> getAllOrderProcessProgressOptimized(Long productOrderId) {
+    private List<ProcessProgressVo> getAllPlanProcessProgressOptimized(String planCode) {
         List<ProcessProgressVo> allProcessProgress = new java.util.ArrayList<>();
 
         try {
-            // 1. 获取订单信息
-            var orderInfo = prodOrderInfoMapper.selectById(productOrderId);
-            if (orderInfo == null) {
-                return allProcessProgress;
-            }
+            // 不依赖 prod_order_info，直接查询三个计划表
+            String[] planTables = {
+                DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_2",
+                DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_3",
+                DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_4"
+            };
 
-            // 2. 根据派工类型确定需要查询的工序表
-            List<Long> processIds = determineProcessIds(orderInfo);
-
-            // 3. 并行查询各工序表以提高性能
-            for (Long processId : processIds) {
+            for (String planTableName : planTables) {
                 try {
-                    String planTableName = getPlanInfoTableNameByProcessId(processId);
-                    if (planTableName != null) {
-                        List<ProcessProgressVo> processProgress = prodReportMapper.getOrderProcessProgress(productOrderId, planTableName);
-                        if (processProgress != null && !processProgress.isEmpty()) {
-                            allProcessProgress.addAll(processProgress);
-                        }
+                    List<ProcessProgressVo> processProgress = prodReportMapper.getPlanProcessProgress(planCode, planTableName);
+                    if (processProgress != null && !processProgress.isEmpty()) {
+                        allProcessProgress.addAll(processProgress);
                     }
                 } catch (Exception e) {
                     // 记录日志但不中断处理
-                    System.out.println("查询工序进度失败，订单ID: " + productOrderId + ", 工序ID: " + processId + ", 错误: " + e.getMessage());
+                    System.out.println("查询工序进度失败，计划编码: " + planCode + ", 表: " + planTableName + ", 错误: " + e.getMessage());
                 }
             }
 
-            // 4. 按工序顺序排序
+            // 按工序顺序排序
             allProcessProgress.sort((a, b) -> {
                 if (a.getProcessOrder() == null) return 1;
                 if (b.getProcessOrder() == null) return -1;
@@ -453,7 +477,7 @@ public class ProdReportServiceImpl implements IProdReportService {
             });
 
         } catch (Exception e) {
-            System.out.println("获取订单工序进度失败，订单ID: " + productOrderId + ", 错误: " + e.getMessage());
+            System.out.println("获取计划工序进度失败，计划编码: " + planCode + ", 错误: " + e.getMessage());
         }
 
         return allProcessProgress;
@@ -595,4 +619,15 @@ public class ProdReportServiceImpl implements IProdReportService {
     }
 
 
+    /**
+     * 工序工单统计（按工序聚合）：完成数量、未完成数量与完成率
+     * 兼容传入的 processId，用于选择对应的计划表
+     */
+    @Override
+    public List<HashMap<String, Object>> processWorkOrderStats(Map hashMap) {
+        Long processId = parseProcessId(hashMap.get("processId"));
+        String planTable = getPlanInfoTableNameByProcessId(processId);
+        return prodReportMapper.processWorkOrderStats(hashMap, planTable);
+    }
+
 }
diff --git a/ruoyi-modules/hwmom-mes/src/main/resources/mapper/mes/ProdReportMapper.xml b/ruoyi-modules/hwmom-mes/src/main/resources/mapper/mes/ProdReportMapper.xml
index 4d251a72..b7e77067 100644
--- a/ruoyi-modules/hwmom-mes/src/main/resources/mapper/mes/ProdReportMapper.xml
+++ b/ruoyi-modules/hwmom-mes/src/main/resources/mapper/mes/ProdReportMapper.xml
@@ -1,4 +1,4 @@
-<?xml version="1.0" encoding="UTF-8" ?>
+<?xml version="1.0" encoding="UTF-8" ?>
 <!DOCTYPE mapper
     PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
@@ -295,21 +295,28 @@
         ORDER BY ppd.real_begin_time DESC, ppi.plan_id DESC
     </select>
 
-    <!-- 在制品跟踪报表 - 高性能优化版本（进一步优化：限制工序统计范围到已过滤订单，避免全表扫描；使用索引友好时间过滤） -->
+    <!-- 在制品跟踪报表 - 高性能优化版本（进一步优化：限制工序统计范围到已过滤订单，避免全表扫描） -->
     <select id="wipTrackingReportList" resultType="org.dromara.mes.domain.vo.WipTrackingReportVo">
-        WITH Orders AS (
-            -- 先根据筛选条件提取订单范围，避免后续工序统计对全库扫描（索引友好）
-            SELECT o.product_order_id, o.tenant_id
-            FROM prod_order_info o
-            INNER JOIN base_material_info m ON m.material_id = o.material_id
+        WITH Plans AS (
+            SELECT p.plan_code, p.tenant_id
+            FROM (
+                SELECT product_order_id, tenant_id, material_id, plan_begin_time, plan_code FROM prod_plan_info_2
+                UNION ALL
+                SELECT product_order_id, tenant_id, material_id, plan_begin_time, plan_code FROM prod_plan_info_3
+                UNION ALL
+                SELECT product_order_id, tenant_id, material_id, plan_begin_time, plan_code FROM prod_plan_info_4
+            ) p
+            INNER JOIN base_material_info m ON m.material_id = p.material_id
             WHERE m.del_flag = '0'
-            <if test="map.beginDate != null and map.beginDate != '' and map.endDate != null and map.endDate != ''">
-                -- 时间范围过滤：避免对列使用函数，保持索引可用
-                AND o.plan_begin_time &gt;= CAST(#{map.beginDate} AS DATETIME)
-                AND o.plan_begin_time &lt; DATEADD(day, 1, CAST(#{map.endDate} AS DATETIME))
+            <if test="map.tenantId != null and map.tenantId != ''">
+                AND p.tenant_id = #{map.tenantId}
             </if>
-            <if test="map.orderCode != null and map.orderCode != ''">
-                AND o.order_code LIKE CONCAT('%', #{map.orderCode}, '%')
+            <if test="map.beginDate != null and map.beginDate != '' and map.endDate != null and map.endDate != ''">
+                AND p.plan_begin_time &gt;= CAST(#{map.beginDate} AS DATETIME)
+                AND p.plan_begin_time &lt; DATEADD(day, 1, CAST(#{map.endDate} AS DATETIME))
+            </if>
+            <if test="map.planCode != null and map.planCode != ''">
+                AND p.plan_code LIKE CONCAT('%', #{map.planCode}, '%')
             </if>
             <if test="map.materialName != null and map.materialName != ''">
                 AND m.material_name LIKE CONCAT('%', #{map.materialName}, '%')
@@ -317,86 +324,99 @@
             <if test="map.materialCode != null and map.materialCode != ''">
                 AND m.material_code LIKE CONCAT('%', #{map.materialCode}, '%')
             </if>
+            GROUP BY p.plan_code, p.tenant_id
+        ),
+        ProcessRows AS (
+            -- 订单范围内的所有工序计划行（UNION ALL 提升性能）
+            SELECT p2.plan_code, p2.tenant_id, p2.process_id, p2.process_order, p2.plan_status,
+                   p2.plan_amount, p2.complete_amount, pr2.process_name
+            FROM prod_plan_info_2 p2
+            LEFT JOIN prod_base_process_info pr2 ON pr2.process_id = p2.process_id
+            INNER JOIN Plans pl ON pl.plan_code = p2.plan_code AND pl.tenant_id = p2.tenant_id
+
+            UNION ALL
+
+            SELECT p3.plan_code, p3.tenant_id, p3.process_id, p3.process_order, p3.plan_status,
+                   p3.plan_amount, p3.complete_amount, pr3.process_name
+            FROM prod_plan_info_3 p3
+            LEFT JOIN prod_base_process_info pr3 ON pr3.process_id = p3.process_id
+            INNER JOIN Plans pl ON pl.plan_code = p3.plan_code AND pl.tenant_id = p3.tenant_id
+
+            UNION ALL
+
+            SELECT p4.plan_code, p4.tenant_id, p4.process_id, p4.process_order, p4.plan_status,
+                   p4.plan_amount, p4.complete_amount, pr4.process_name
+            FROM prod_plan_info_4 p4
+            LEFT JOIN prod_base_process_info pr4 ON pr4.process_id = p4.process_id
+            INNER JOIN Plans pl ON pl.plan_code = p4.plan_code AND pl.tenant_id = p4.tenant_id
+        ),
+        DistinctProcess AS (
+            -- 按计划+工序聚合为唯一工序，避免同一工序多行导致工序数偏大
+            SELECT
+                plan_code,
+                tenant_id,
+                process_id,
+                MAX(ISNULL(process_order,0)) AS process_order,
+                MAX(CASE WHEN plan_status = '3' THEN 1 ELSE 0 END) AS isCompleted,
+                MAX(CASE WHEN plan_status = '2' THEN 1 ELSE 0 END) AS isInProgress,
+                SUM(ISNULL(plan_amount,0)) AS plan_amount,
+                SUM(ISNULL(complete_amount,0)) AS complete_amount,
+                MAX(process_name) AS process_name
+            FROM ProcessRows
+            GROUP BY plan_code, tenant_id, process_id
         ),
         ProcessStats AS (
-            -- 统计每个订单的工序进度信息，仅统计已过滤的订单范围（UNION ALL 提升性能）
+            -- 统计每个订单的工序进度（以唯一工序为单位）
             SELECT
-                ap.product_order_id,
-                ap.tenant_id,
+                dp.plan_code,
+                dp.tenant_id,
                 COUNT(*) AS totalProcessCount,
-                SUM(CASE WHEN ap.plan_status = '3' THEN 1 ELSE 0 END) AS completedProcessCount,
-                SUM(CASE WHEN ap.plan_status = '2' THEN 1 ELSE 0 END) AS wipProcessCount,
-                MAX(CASE WHEN ap.plan_status = '3' THEN ap.process_order ELSE 0 END) AS maxCompletedOrder,
-                -- 在制工序名称（进行中的工序）
-                STRING_AGG(CASE WHEN ap.plan_status = '2' THEN ap.process_name END, ',') AS wipProcessNames,
-                -- 剩余工序名称（未派工和已派工但未开始的工序）
-                STRING_AGG(CASE WHEN ap.plan_status IN ('0','1') THEN ap.process_name END, ',') AS remainingProcessNames,
-                -- 在制品数量加权计算
-                SUM(CASE WHEN ap.plan_status = '2' THEN ISNULL(ap.plan_amount - ap.complete_amount, 0) * ap.process_order ELSE 0 END) AS wipWeightedSum
+                SUM(dp.isCompleted) AS completedProcessCount,
+                SUM(dp.isInProgress) AS wipProcessCount,
+                MAX(CASE WHEN dp.isCompleted = 1 THEN dp.process_order ELSE 0 END) AS maxCompletedOrder,
+                STRING_AGG(CASE WHEN dp.isInProgress = 1 THEN dp.process_name END, ',') AS wipProcessNames,
+                STRING_AGG(CASE WHEN dp.isCompleted = 0 AND dp.isInProgress = 0 THEN dp.process_name END, ',') AS remainingProcessNames,
+                SUM(CASE WHEN dp.isInProgress = 1 THEN ISNULL(dp.plan_amount - dp.complete_amount, 0) * dp.process_order ELSE 0 END) AS wipWeightedSum
+            FROM DistinctProcess dp
+            GROUP BY dp.plan_code, dp.tenant_id
+        ),
+        PlanAgg AS (
+            -- 按计划聚合计划信息（按 plan_code 维度）
+            SELECT
+                p.plan_code,
+                p.tenant_id,
+                MIN(p.plan_begin_time) AS plan_begin_time,
+                MIN(p.real_begin_time) AS real_begin_time,
+                MAX(p.plan_end_time) AS plan_end_time,
+                SUM(ISNULL(p.plan_amount,0)) AS plan_amount,
+                SUM(ISNULL(p.complete_amount,0)) AS complete_amount,
+                MAX(p.material_id) AS material_id
             FROM (
-                -- 半制品工序（prod_plan_info_2）
-                SELECT
-                    p2.product_order_id,
-                    p2.tenant_id,
-                    p2.process_id,
-                    p2.process_order,
-                    p2.plan_status,
-                    p2.plan_amount,
-                    p2.complete_amount,
-                    pr2.process_name
-                FROM prod_plan_info_2 p2
-                LEFT JOIN prod_base_process_info pr2 ON pr2.process_id = p2.process_id
-                INNER JOIN Orders ord ON ord.product_order_id = p2.product_order_id AND ord.tenant_id = p2.tenant_id
-                WHERE p2.product_order_id IS NOT NULL
-
+                SELECT plan_code, tenant_id, plan_begin_time, real_begin_time, plan_end_time, plan_amount, complete_amount, material_id
+                FROM prod_plan_info_2
                 UNION ALL
-
-                -- 成型工序（prod_plan_info_3）
-                SELECT
-                    p3.product_order_id,
-                    p3.tenant_id,
-                    p3.process_id,
-                    p3.process_order,
-                    p3.plan_status,
-                    p3.plan_amount,
-                    p3.complete_amount,
-                    pr3.process_name
-                FROM prod_plan_info_3 p3
-                LEFT JOIN prod_base_process_info pr3 ON pr3.process_id = p3.process_id
-                INNER JOIN Orders ord ON ord.product_order_id = p3.product_order_id AND ord.tenant_id = p3.tenant_id
-                WHERE p3.product_order_id IS NOT NULL
-
+                SELECT plan_code, tenant_id, plan_begin_time, real_begin_time, plan_end_time, plan_amount, complete_amount, material_id
+                FROM prod_plan_info_3
                 UNION ALL
-
-                -- 硫化工序（prod_plan_info_4）
-                SELECT
-                    p4.product_order_id,
-                    p4.tenant_id,
-                    p4.process_id,
-                    p4.process_order,
-                    p4.plan_status,
-                    p4.plan_amount,
-                    p4.complete_amount,
-                    pr4.process_name
-                FROM prod_plan_info_4 p4
-                LEFT JOIN prod_base_process_info pr4 ON pr4.process_id = p4.process_id
-                INNER JOIN Orders ord ON ord.product_order_id = p4.product_order_id AND ord.tenant_id = p4.tenant_id
-                WHERE p4.product_order_id IS NOT NULL
-            ) AS ap
-            GROUP BY ap.product_order_id, ap.tenant_id
+                SELECT plan_code, tenant_id, plan_begin_time, real_begin_time, plan_end_time, plan_amount, complete_amount, material_id
+                FROM prod_plan_info_4
+            ) p
+            INNER JOIN Plans pl ON pl.plan_code = p.plan_code AND pl.tenant_id = p.tenant_id
+            GROUP BY p.plan_code, p.tenant_id
         )
         SELECT
-            o.product_order_id AS productOrderId,
-            o.order_code AS orderCode,
+            NULL AS productOrderId,
+            '' AS orderCode,
+            oa.plan_code AS planCode,
             m.material_code AS materialCode,
             m.material_name AS materialName,
             ISNULL(m.material_spec, '') AS materialSpec,
-            CAST(o.plan_amount AS DECIMAL(18,2)) AS planAmount,
-            CAST(ISNULL(o.plan_amount,0) - ISNULL(o.complete_amount,0) AS DECIMAL(18,2)) AS wipAmount,
-            CAST(ISNULL(o.complete_amount,0) AS DECIMAL(18,2)) AS completeAmount,
-            o.plan_begin_time AS planBeginTime,
-            o.real_begin_time AS realBeginTime,
-            o.plan_end_time AS planEndTime,
+            CAST(oa.plan_amount AS DECIMAL(18,2)) AS planAmount,
+            CAST(ISNULL(oa.plan_amount,0) - ISNULL(oa.complete_amount,0) AS DECIMAL(18,2)) AS wipAmount,
+            CAST(ISNULL(oa.complete_amount,0) AS DECIMAL(18,2)) AS completeAmount,
+            oa.plan_begin_time AS planBeginTime,
+            oa.real_begin_time AS realBeginTime,
+            oa.plan_end_time AS planEndTime,
             GETDATE() AS currentTime,
             CAST(ISNULL(ps.totalProcessCount, 0) AS VARCHAR(10)) + '道' AS totalProcessCount,
 
@@ -406,15 +426,15 @@
             CONCAT(
                 CAST(
                     CASE
-                        WHEN o.plan_amount > 0
-                        THEN (CAST(ISNULL(o.complete_amount,0) AS DECIMAL(18,6)) / CAST(o.plan_amount AS DECIMAL(18,6))) * 100
+                        WHEN oa.plan_amount > 0
+                        THEN (CAST(ISNULL(oa.complete_amount,0) AS DECIMAL(18,6)) / CAST(oa.plan_amount AS DECIMAL(18,6))) * 100
                         ELSE 0
                     END
                 AS DECIMAL(10,2)), '%'
             ) AS overallProgress,
             -- 进度状态判断：延期或正常
             CASE
-                WHEN o.plan_end_time IS NOT NULL AND GETDATE() > o.plan_end_time AND ISNULL(o.complete_amount,0) &lt; o.plan_amount
+                WHEN oa.plan_end_time IS NOT NULL AND GETDATE() > oa.plan_end_time AND ISNULL(oa.complete_amount,0) &lt; oa.plan_amount
                 THEN '延期'
                 ELSE '正常'
             END AS progressStatus,
@@ -423,58 +443,123 @@
             -- 数值型整体进度（不带百分号）
             CAST(
                 CASE
-                    WHEN o.plan_amount > 0
-                    THEN (CAST(ISNULL(o.complete_amount,0) AS DECIMAL(18,6)) / CAST(o.plan_amount AS DECIMAL(18,6))) * 100
+                    WHEN oa.plan_amount > 0
+                    THEN (CAST(ISNULL(oa.complete_amount,0) AS DECIMAL(18,6)) / CAST(oa.plan_amount AS DECIMAL(18,6))) * 100
                     ELSE 0
                 END
             AS DECIMAL(10,2)) AS overallProgressNum
-        FROM prod_order_info o
-        INNER JOIN base_material_info m ON m.material_id = o.material_id
-        INNER JOIN Orders ord ON ord.product_order_id = o.product_order_id AND ord.tenant_id = o.tenant_id
-        LEFT JOIN ProcessStats ps ON ps.product_order_id = o.product_order_id AND ps.tenant_id = o.tenant_id
+        FROM PlanAgg oa
+        INNER JOIN base_material_info m ON m.material_id = oa.material_id
+        LEFT JOIN ProcessStats ps ON ps.plan_code = oa.plan_code AND ps.tenant_id = oa.tenant_id
         <where>
             <!-- 进度状态过滤单独保留在最终结果上 -->
             <if test="map.progressStatus != null and map.progressStatus != ''">
                 AND CASE
-                    WHEN o.plan_end_time IS NOT NULL AND GETDATE() > o.plan_end_time AND ISNULL(o.complete_amount,0) &lt; o.plan_amount
+                    WHEN oa.plan_end_time IS NOT NULL AND GETDATE() > oa.plan_end_time AND ISNULL(oa.complete_amount,0) &lt; oa.plan_amount
                     THEN '延期'
                     ELSE '正常'
                 END = #{map.progressStatus}
             </if>
         </where>
-        ORDER BY o.order_code DESC
+        -- 为避免首屏仅出现以 'PLAN' 开头的计划编号（字符串排序导致），
+        -- 改为按时间优先降序，其次按计划编号升序，确保不同编码规则的计划均能出现在第一页
+        ORDER BY oa.plan_begin_time DESC, oa.real_begin_time DESC, oa.plan_code ASC
     </select>
 
-    <!-- 在制品跟踪报表总数（简化版 count）：避免复杂 CTE/聚合，保持与筛选条件一致 -->
+    <!-- 在制品跟踪报表总数（按工序维度计数）：统计筛选范围内存在数据的工序数量 -->
     <select id="wipTrackingReportCount" resultType="java.lang.Long">
-        SELECT COUNT(*)
-        FROM prod_order_info o
-        INNER JOIN base_material_info m ON m.material_id = o.material_id
-        WHERE m.del_flag = '0'
-        <if test="map.beginDate != null and map.beginDate != '' and map.endDate != null and map.endDate != ''">
-            AND o.plan_begin_time <![CDATA[>=]]> CAST(#{map.beginDate} AS DATETIME)
-            AND o.plan_begin_time <![CDATA[<]]> DATEADD(day, 1, CAST(#{map.endDate} AS DATETIME))
-        </if>
-        <if test="map.orderCode != null and map.orderCode != ''">
-            AND o.order_code LIKE CONCAT('%', #{map.orderCode}, '%')
-        </if>
-        <if test="map.materialName != null and map.materialName != ''">
-            AND m.material_name LIKE CONCAT('%', #{map.materialName}, '%')
-        </if>
-        <if test="map.materialCode != null and map.materialCode != ''">
-            AND m.material_code LIKE CONCAT('%', #{map.materialCode}, '%')
-        </if>
-        <if test="map.progressStatus != null and map.progressStatus != ''">
-            AND CASE
-                WHEN o.plan_end_time IS NOT NULL AND GETDATE() > o.plan_end_time AND ISNULL(o.complete_amount,0) <![CDATA[<]]> o.plan_amount THEN '延期'
-                ELSE '正常'
-            END = #{map.progressStatus}
-        </if>
+        WITH Plans AS (
+            SELECT p.plan_code, p.tenant_id
+            FROM (
+                SELECT product_order_id, tenant_id, material_id, plan_begin_time, plan_code FROM prod_plan_info_2
+                UNION ALL
+                SELECT product_order_id, tenant_id, material_id, plan_begin_time, plan_code FROM prod_plan_info_3
+                UNION ALL
+                SELECT product_order_id, tenant_id, material_id, plan_begin_time, plan_code FROM prod_plan_info_4
+            ) p
+            INNER JOIN base_material_info m ON m.material_id = p.material_id
+            WHERE m.del_flag = '0'
+            <if test="map.tenantId != null and map.tenantId != ''">
+                AND p.tenant_id = #{map.tenantId}
+            </if>
+            <if test="map.beginDate != null and map.beginDate != '' and map.endDate != null and map.endDate != ''">
+                AND p.plan_begin_time <![CDATA[>=]]> CAST(#{map.beginDate} AS DATETIME)
+                AND p.plan_begin_time <![CDATA[<]]> DATEADD(day, 1, CAST(#{map.endDate} AS DATETIME))
+            </if>
+            <if test="map.planCode != null and map.planCode != ''">
+                AND p.plan_code LIKE CONCAT('%', #{map.planCode}, '%')
+            </if>
+            <if test="map.materialName != null and map.materialName != ''">
+                AND m.material_name LIKE CONCAT('%', #{map.materialName}, '%')
+            </if>
+            <if test="map.materialCode != null and map.materialCode != ''">
+                AND m.material_code LIKE CONCAT('%', #{map.materialCode}, '%')
+            </if>
+            GROUP BY p.plan_code, p.tenant_id
+        ),
+        PlanAgg AS (
+            -- 计划级聚合（用于进度状态筛选）
+            SELECT
+                p.plan_code,
+                p.tenant_id,
+                MAX(p.material_id) AS material_id,
+                MAX(p.plan_end_time) AS plan_end_time,
+                SUM(ISNULL(p.plan_amount,0)) AS plan_amount,
+                SUM(ISNULL(p.complete_amount,0)) AS complete_amount
+            FROM (
+                SELECT plan_code, tenant_id, plan_end_time, plan_amount, complete_amount, material_id FROM prod_plan_info_2
+                UNION ALL
+                SELECT plan_code, tenant_id, plan_end_time, plan_amount, complete_amount, material_id FROM prod_plan_info_3
+                UNION ALL
+                SELECT plan_code, tenant_id, plan_end_time, plan_amount, complete_amount, material_id FROM prod_plan_info_4
+            ) p
+            INNER JOIN Plans pl ON pl.plan_code = p.plan_code AND pl.tenant_id = p.tenant_id
+            GROUP BY p.plan_code, p.tenant_id
+        ),
+        EligiblePlans AS (
+            -- 应用进度状态筛选（如有），得到符合条件的计划集合
+            SELECT oa.plan_code, oa.tenant_id
+            FROM PlanAgg oa
+            INNER JOIN base_material_info m ON m.material_id = oa.material_id
+            WHERE m.del_flag = '0'
+            <if test="map.progressStatus != null and map.progressStatus != ''">
+                AND CASE
+                    WHEN oa.plan_end_time IS NOT NULL AND GETDATE() > oa.plan_end_time AND ISNULL(oa.complete_amount,0) <![CDATA[<]]> oa.plan_amount THEN '延期'
+                    ELSE '正常'
+                END = #{map.progressStatus}
+            </if>
+        ),
+        ProcessRows AS (
+            -- 订单范围内且符合状态筛选的所有工序行
+            SELECT p2.plan_code, p2.tenant_id, p2.process_id, ISNULL(pr2.process_name, N'未知工序') AS process_name
+            FROM prod_plan_info_2 p2
+            LEFT JOIN prod_base_process_info pr2 ON pr2.process_id = p2.process_id
+            INNER JOIN EligiblePlans ep ON ep.plan_code = p2.plan_code AND ep.tenant_id = p2.tenant_id
+
+            UNION ALL
+
+            SELECT p3.plan_code, p3.tenant_id, p3.process_id, ISNULL(pr3.process_name, N'未知工序') AS process_name
+            FROM prod_plan_info_3 p3
+            LEFT JOIN prod_base_process_info pr3 ON pr3.process_id = p3.process_id
+            INNER JOIN EligiblePlans ep ON ep.plan_code = p3.plan_code AND ep.tenant_id = p3.tenant_id
+
+            UNION ALL
+
+            SELECT p4.plan_code, p4.tenant_id, p4.process_id, ISNULL(pr4.process_name, N'未知工序') AS process_name
+            FROM prod_plan_info_4 p4
+            LEFT JOIN prod_base_process_info pr4 ON pr4.process_id = p4.process_id
+            INNER JOIN EligiblePlans ep ON ep.plan_code = p4.plan_code AND ep.tenant_id = p4.tenant_id
+        )
+        SELECT COUNT(DISTINCT process_name)
+        FROM ProcessRows
     </select>
 
-    <!-- 获取订单的工序进度详情 - 高性能优化版本（保留单订单查询，不返回productOrderId以兼容旧用法） -->
-    <select id="getOrderProcessProgress" resultType="org.dromara.mes.domain.vo.ProcessProgressVo">
+    <!-- （已清理）订单维度的工序进度查询已移除，统一按 plan_code 维度处理 -->
+
+    <!-- 获取计划的工序进度详情（按planCode单条） -->
+    <select id="getPlanProcessProgress" resultType="org.dromara.mes.domain.vo.ProcessProgressVo">
         SELECT
+            p.plan_code AS planCode,
             p.process_id AS processId,
             ISNULL(pr.process_name, '未知工序') AS processName,
             ISNULL(p.process_order, 0) AS processOrder,
@@ -491,34 +576,29 @@
             CAST(ISNULL(p.plan_amount, 0) AS DECIMAL(18,2)) AS planAmount,
             CAST(ISNULL(p.complete_amount, 0) AS DECIMAL(18,2)) AS completeAmount,
             CAST(ISNULL(p.plan_amount, 0) - ISNULL(p.complete_amount, 0) AS DECIMAL(18,2)) AS remainingAmount,
-            -- 工序进度百分比
             CAST(
-                CASE
-                    WHEN ISNULL(p.plan_amount, 0) > 0
-                    THEN (CAST(ISNULL(p.complete_amount, 0) AS DECIMAL(18,6)) / CAST(p.plan_amount AS DECIMAL(18,6))) * 100
-                    ELSE 0
+                CASE WHEN ISNULL(p.plan_amount, 0) > 0
+                     THEN (CAST(ISNULL(p.complete_amount, 0) AS DECIMAL(18,6)) / CAST(p.plan_amount AS DECIMAL(18,6))) * 100
+                     ELSE 0
                 END
             AS DECIMAL(10,2)) AS processProgress,
-            -- 计划开始时间和结束时间
             p.plan_begin_time AS planBeginTime,
             p.plan_end_time AS planEndTime,
             p.real_begin_time AS realBeginTime,
-            p.real_end_time AS realEndTime
+            p.real_end_time AS realEndTime,
+            bmi.material_name AS materialName,
+            bmi.material_code AS materialCode
         FROM ${planTableName} p
         LEFT JOIN prod_base_process_info pr ON pr.process_id = p.process_id
-        WHERE p.product_order_id = #{productOrderId}
+        LEFT JOIN base_material_info bmi ON bmi.material_id = p.material_id
+        WHERE p.plan_code = #{planCode}
         ORDER BY p.process_order
     </select>
 
-    <!-- 批量获取订单的工序进度详情（避免N+1，一次查询一个工序表） -->
-    <!-- 说明：
-         1. 通过 IN 子句一次性查询多个订单的工序进度，显著减少数据库往返，提高性能；
-         2. 返回 product_order_id 字段用于在服务层进行分组映射；
-         3. 该SQL按订单ID与工序顺序排序，便于后续按工序顺序展示；
-    -->
-    <select id="getOrdersProcessProgressBatch" resultType="org.dromara.mes.domain.vo.ProcessProgressVo">
+    <!-- 批量获取计划的工序进度详情（按planCode批量） -->
+    <select id="getPlansProcessProgressBatch" resultType="org.dromara.mes.domain.vo.ProcessProgressVo">
         SELECT
-            p.product_order_id AS productOrderId,
+            p.plan_code AS planCode,
             p.process_id AS processId,
             ISNULL(pr.process_name, '未知工序') AS processName,
             ISNULL(p.process_order, 0) AS processOrder,
@@ -536,24 +616,49 @@
             CAST(ISNULL(p.complete_amount, 0) AS DECIMAL(18,2)) AS completeAmount,
             CAST(ISNULL(p.plan_amount, 0) - ISNULL(p.complete_amount, 0) AS DECIMAL(18,2)) AS remainingAmount,
             CAST(
-                CASE
-                    WHEN ISNULL(p.plan_amount, 0) > 0
-                    THEN (CAST(ISNULL(p.complete_amount, 0) AS DECIMAL(18,6)) / CAST(p.plan_amount AS DECIMAL(18,6))) * 100
-                    ELSE 0
+                CASE WHEN ISNULL(p.plan_amount, 0) > 0
+                     THEN (CAST(ISNULL(p.complete_amount, 0) AS DECIMAL(18,6)) / CAST(p.plan_amount AS DECIMAL(18,6))) * 100
+                     ELSE 0
                 END
             AS DECIMAL(10,2)) AS processProgress,
             p.plan_begin_time AS planBeginTime,
             p.plan_end_time AS planEndTime,
             p.real_begin_time AS realBeginTime,
-            p.real_end_time AS realEndTime
+            p.real_end_time AS realEndTime,
+            bmi.material_name AS materialName,
+            bmi.material_code AS materialCode
         FROM ${planTableName} p
         LEFT JOIN prod_base_process_info pr ON pr.process_id = p.process_id
-        WHERE p.product_order_id IN
-        <foreach collection="productOrderIds" item="id" open="(" separator="," close=")">
-            #{id}
+        LEFT JOIN base_material_info bmi ON bmi.material_id = p.material_id
+        WHERE p.plan_code IN
+        <foreach collection="planCodes" item="code" open="(" separator="," close=")">
+            #{code}
         </foreach>
         <if test="tenantId != null"> AND p.tenant_id = #{tenantId} </if>
-        ORDER BY p.product_order_id, p.process_order
+        ORDER BY p.plan_code, p.process_order
+    </select>
+
+    <!-- 工序下的计划子节点查询：按 plan_code + process_id 过滤，计划级视图（不关联明细表） -->
+    <select id="getPlanProcessDetailChildren" resultType="java.util.HashMap">
+        SELECT
+            ppi.plan_id          AS planId,
+            ppi.plan_code        AS planCode,
+            ppi.process_id       AS processId,
+            ppi.process_order    AS processOrder,
+            ISNULL(ppi.plan_amount, 0)    AS planAmount,
+            ISNULL(ppi.complete_amount, 0) AS completeAmount,
+            ppi.real_begin_time  AS realBeginTime,
+            ppi.real_end_time    AS realEndTime,
+            ISNULL(bct.team_name, '')     AS teamName,
+            ISNULL(pbsi.station_name, '') AS stationName,
+            ISNULL(ppi.plan_status, '0')  AS planStatus
+        FROM ${planTableName} ppi
+        LEFT JOIN base_class_team_info bct ON bct.class_team_id = ppi.class_team_id
+        LEFT JOIN prod_base_station_info pbsi ON pbsi.station_id = bct.station_id
+        WHERE ppi.plan_code = #{planCode}
+        <if test="processId != null"> AND ppi.process_id = #{processId} </if>
+        <if test="tenantId != null"> AND ppi.tenant_id = #{tenantId} </if>
+        ORDER BY ppi.real_begin_time, ppi.plan_id
     </select>
 
 
@@ -597,4 +702,59 @@
         ORDER BY productionDate, DATEPART(HOUR, t.create_time)
     </select>
 
+    <!-- 工序生产统计（按工序聚合）：完成数量、未完成数量与完成率 -->
+    <select id="processWorkOrderStats" resultType="java.util.HashMap">
+        <![CDATA[
+        SELECT
+            ISNULL(pproc.process_name, N'未知工序') AS processName,
+            -- 汇总计划与完成数量
+            CAST(SUM(ISNULL(p.plan_amount, 0)) AS DECIMAL(18,4)) AS planQty,
+            CAST(SUM(ISNULL(p.complete_amount, 0)) AS DECIMAL(18,4)) AS completedQty,
+            CAST(SUM(ISNULL(p.plan_amount, 0) - ISNULL(p.complete_amount, 0)) AS DECIMAL(18,4)) AS uncompletedQty,
+            -- 完成率（数值 & 展示）
+            CAST(
+                CASE WHEN SUM(ISNULL(p.plan_amount, 0)) > 0
+                     THEN (CAST(SUM(ISNULL(p.complete_amount, 0)) AS DECIMAL(18,6)) / CAST(SUM(ISNULL(p.plan_amount, 0)) AS DECIMAL(18,6))) * 100
+                     ELSE 0 END
+            AS DECIMAL(10,2)) AS completionRateNum,
+            CONCAT(
+                CAST(
+                    CASE WHEN SUM(ISNULL(p.plan_amount, 0)) > 0
+                         THEN (CAST(SUM(ISNULL(p.complete_amount, 0)) AS DECIMAL(18,6)) / CAST(SUM(ISNULL(p.plan_amount, 0)) AS DECIMAL(18,6))) * 100
+                         ELSE 0 END
+                AS DECIMAL(10,2)
+            ), '%') AS completionRate
+        FROM ${planTableName} AS p
+        LEFT JOIN prod_base_process_info AS pproc ON pproc.process_id = p.process_id
+        LEFT JOIN base_material_info AS bmi ON bmi.material_id = p.material_id
+        ]]>
+        <where>
+            <if test="map.beginDate != null  and map.beginDate != '' and map.endDate != null  and map.endDate != ''">
+                AND FORMAT(p.plan_begin_time, 'yyyy-MM-dd') BETWEEN #{map.beginDate} AND #{map.endDate}
+            </if>
+            <if test="map.processId != null and map.processId != ''">
+                AND p.process_id = #{map.processId}
+            </if>
+            <if test="map.machineId != null and map.machineId != ''">
+                AND p.release_id = #{map.machineId}
+            </if>
+            <if test="map.shiftId != null and map.shiftId != ''">
+                AND p.shift_id = #{map.shiftId}
+            </if>
+            <if test="map.classTeamId != null and map.classTeamId != ''">
+                AND p.class_team_id = #{map.classTeamId}
+            </if>
+            <if test="map.planCode != null and map.planCode != ''">
+                AND p.plan_code LIKE CONCAT('%', #{map.planCode}, '%')
+            </if>
+            <if test="map.materialName != null and map.materialName != ''">
+                AND bmi.material_name LIKE CONCAT('%', #{map.materialName}, '%')
+            </if>
+        </where>
+        <![CDATA[
+        GROUP BY ISNULL(pproc.process_name, N'未知工序')
+        ORDER BY completionRateNum DESC, processName
+        ]]>
+    </select>
+
 </mapper>