From 0857cf1830039d60ce73005f386f284cf575e511 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期一, 26 十月 2026 14:00:19 +0800
Subject: [PATCH] feat(mes): 新增ERP销售订单生产状态枚举及MES工艺路线优化

---
 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/task/MesProTaskMapper.java |   16 ++++++++++++++++
 1 files changed, 16 insertions(+), 0 deletions(-)

diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/task/MesProTaskMapper.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/task/MesProTaskMapper.java
index 586c92b..1cf3bf0 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/task/MesProTaskMapper.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/task/MesProTaskMapper.java
@@ -67,6 +67,22 @@
         return selectPage(reqVO, query);
     }
 
+    /**
+     * 鎸夊伐浣滅珯缁熻寰呮姤宸ヤ换鍔℃暟锛屽彛寰勪笌 {@link #selectPendingFeedbackPage} 涓�鑷�
+     *
+     * @return 姣忚鍖呭惈 workstation_id銆乸ending_count
+     */
+    default List<Map<String, Object>> selectPendingFeedbackCountByWorkstation() {
+        return selectMaps(new QueryWrapper<MesProTaskDO>()
+                .select("workstation_id", "COUNT(*) AS pending_count")
+                .in("status", MesProTaskStatusEnum.PREPARE.getStatus(),
+                        MesProTaskStatusEnum.PRODUCING.getStatus(), MesProTaskStatusEnum.PARTIAL_FINISHED.getStatus(),
+                        MesProTaskStatusEnum.PAUSED.getStatus())
+                .apply("(quantity - IFNULL(produced_quantity, 0)) > 0")
+                .isNotNull("workstation_id")
+                .groupBy("workstation_id"));
+    }
+
     default List<MesProTaskDO> selectListByWorkOrderId(Long workOrderId) {
         return selectList(new LambdaQueryWrapperX<MesProTaskDO>()
                 .eqIfPresent(MesProTaskDO::getWorkOrderId, workOrderId)

--
Gitblit v1.9.3