From 3ff6604c75c887f4056ee03545d204bc9323286c Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期四, 15 十月 2026 17:47:19 +0800
Subject: [PATCH] feat(mes): 新增报工设备快照功能并优化状态校验
---
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/task/MesProTaskMapper.java | 38 +++++++++++++++++++++++++++++++++++++-
1 files changed, 37 insertions(+), 1 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 21b9f44..9f089fe 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
@@ -6,7 +6,9 @@
import cn.iocoder.yudao.framework.mybatis.core.query.MPJLambdaWrapperX;
import cn.iocoder.yudao.module.mes.controller.admin.pro.task.vo.MesProTaskPageReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteProcessDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.pro.task.MesProTaskAssigneeDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.task.MesProTaskDO;
+import cn.iocoder.yudao.module.mes.enums.pro.MesProTaskStatusEnum;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import org.apache.ibatis.annotations.Mapper;
@@ -16,10 +18,21 @@
/**
* MES 鐢熶骇浠诲姟 Mapper
*
- * @author 鑺嬮亾婧愮爜
+ * @author 瓒呯骇绠＄悊鍛�
*/
@Mapper
public interface MesProTaskMapper extends BaseMapperX<MesProTaskDO> {
+
+ /** 鎵�鏈夋帓浜у啓鍏ュ彛浠ョ浉鍚岄『搴忛攣瀹氬伐浣滅珯锛涗簨鍔℃彁浜ゅ悗閲婃斁锛岃法杩涚▼闃叉璧勬簮绔炴�併�� */
+ @org.apache.ibatis.annotations.Select("SELECT id FROM mes_md_workstation WHERE deleted = 0 ORDER BY id FOR UPDATE")
+ List<Long> lockSchedulingResources();
+
+ default List<MesProTaskDO> selectSchedulingTasks() {
+ return selectList(new LambdaQueryWrapperX<MesProTaskDO>()
+ .and(query -> query.isNull(MesProTaskDO::getStatus).or()
+ .notIn(MesProTaskDO::getStatus, MesProTaskStatusEnum.CANCELED.getStatus(), MesProTaskStatusEnum.FINISHED.getStatus()))
+ .orderByAsc(MesProTaskDO::getId));
+ }
default PageResult<MesProTaskDO> selectPage(MesProTaskPageReqVO reqVO) {
MPJLambdaWrapperX<MesProTaskDO> query = new MPJLambdaWrapperX<>();
@@ -44,6 +57,29 @@
return selectPage(reqVO, query);
}
+ default PageResult<MesProTaskDO> selectPendingFeedbackPage(MesProTaskPageReqVO reqVO) {
+ MPJLambdaWrapperX<MesProTaskDO> query = new MPJLambdaWrapperX<>();
+ query.selectAll(MesProTaskDO.class);
+ // 褰撻渶瑕佹寜 assigneeUserId 杩囨护鏃讹紝INNER JOIN mes_pro_task_assignee
+ if (reqVO.getAssigneeUserId() != null) {
+ query.innerJoin(MesProTaskAssigneeDO.class, on -> on
+ .eq(MesProTaskAssigneeDO::getTaskId, MesProTaskDO::getId));
+ query.eq(MesProTaskAssigneeDO::getUserId, reqVO.getAssigneeUserId());
+ }
+ // 寰呮姤宸ュ彴璐︼細杩涜涓殑浠诲姟锛堟帓闄ゅ凡瀹屾垚/宸插彇娑堬級锛屼笖浠嶆湁寰呮姤宸ラ噺
+ query.in(MesProTaskDO::getStatus, MesProTaskStatusEnum.PREPARE.getStatus(),MesProTaskStatusEnum.PAUSED.getStatus());
+ query.apply("(quantity - IFNULL(produced_quantity, 0)) > 0");
+ query.likeIfPresent(MesProTaskDO::getCode, reqVO.getCode())
+ .likeIfPresent(MesProTaskDO::getName, reqVO.getName())
+ .eqIfPresent(MesProTaskDO::getWorkOrderId, reqVO.getWorkOrderId())
+ .eqIfPresent(MesProTaskDO::getRouteId, reqVO.getRouteId())
+ .eqIfPresent(MesProTaskDO::getProcessId, reqVO.getProcessId())
+ .eqIfPresent(MesProTaskDO::getWorkstationId, reqVO.getWorkstationId())
+ .betweenIfPresent(MesProTaskDO::getCreateTime, reqVO.getCreateTime())
+ .orderByDesc(MesProTaskDO::getId);
+ return selectPage(reqVO, query);
+ }
+
default List<MesProTaskDO> selectListByWorkOrderId(Long workOrderId) {
return selectList(new LambdaQueryWrapperX<MesProTaskDO>()
.eqIfPresent(MesProTaskDO::getWorkOrderId, workOrderId)
--
Gitblit v1.9.3