From af6bafbb985e1972f938aef9bfedbe6549f749ad Mon Sep 17 00:00:00 2001
From: liu <2021943741@qq.com>
Date: 星期一, 07 九月 2026 16:46:48 +0800
Subject: [PATCH] feat(mes): 生产报工按工单工序顺序控制，上一道报满后才能报下一道
---
yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/pro/feedback/MesProFeedbackServiceImplTest.java | 307 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 307 insertions(+), 0 deletions(-)
diff --git a/yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/pro/feedback/MesProFeedbackServiceImplTest.java b/yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/pro/feedback/MesProFeedbackServiceImplTest.java
index 4cefcbd..a086275 100644
--- a/yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/pro/feedback/MesProFeedbackServiceImplTest.java
+++ b/yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/pro/feedback/MesProFeedbackServiceImplTest.java
@@ -1,18 +1,35 @@
package cn.iocoder.yudao.module.mes.service.pro.feedback;
import cn.hutool.core.collection.ListUtil;
+import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
+import cn.iocoder.yudao.module.bpm.api.task.BpmProcessInstanceApi;
+import cn.iocoder.yudao.module.mdm.api.item.MdmItemBatchConfigApi;
+import cn.iocoder.yudao.module.mes.api.mps.MesProMpsApi;
import cn.iocoder.yudao.module.mes.controller.admin.pro.feedback.vo.MesProFeedbackApproveReqVO;
+import cn.iocoder.yudao.module.mes.controller.admin.pro.feedback.vo.MesProFeedbackQuickCreateReqVO;
+import cn.iocoder.yudao.module.mes.controller.admin.pro.feedback.vo.MesProFeedbackQuickCreateRespVO;
+import cn.iocoder.yudao.module.mes.controller.admin.pro.feedback.vo.MesProFeedbackSubmitReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.feedback.MesProFeedbackDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.pro.process.MesProProcessDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteProcessDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.pro.task.MesProTaskDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderProcessDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productproduce.MesWmProductProduceDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productproduce.MesWmProductProduceLineDO;
import cn.iocoder.yudao.module.mes.dal.mysql.pro.feedback.MesProFeedbackMapper;
import cn.iocoder.yudao.module.mes.enums.pro.MesProFeedbackStatusEnum;
+import cn.iocoder.yudao.module.mes.enums.pro.MesProTaskStatusEnum;
import cn.iocoder.yudao.module.mes.enums.wm.MesWmQualityStatusEnum;
+import cn.iocoder.yudao.module.mes.service.md.autocode.MesMdAutoCodeRecordService;
import cn.iocoder.yudao.module.mes.service.md.workstation.MesMdWorkstationService;
+import cn.iocoder.yudao.module.mes.service.mdm.MesMdmItemService;
+import cn.iocoder.yudao.module.mes.service.pro.process.MesProProcessService;
import cn.iocoder.yudao.module.mes.service.pro.route.MesProRouteProcessService;
import cn.iocoder.yudao.module.mes.service.pro.task.MesProTaskService;
+import cn.iocoder.yudao.module.mes.service.pro.workorder.MesProWorkOrderBomService;
+import cn.iocoder.yudao.module.mes.service.pro.workorder.MesProWorkOrderParamRecordService;
+import cn.iocoder.yudao.module.mes.service.pro.workorder.MesProWorkOrderProcessService;
import cn.iocoder.yudao.module.mes.service.pro.workorder.MesProWorkOrderService;
import cn.iocoder.yudao.module.mes.service.wm.itemconsume.MesWmItemConsumeService;
import cn.iocoder.yudao.module.mes.service.wm.productproduce.MesWmProductProduceLineService;
@@ -23,6 +40,8 @@
import org.springframework.test.context.bean.override.mockito.MockitoBean;
import java.math.BigDecimal;
+import java.util.Collections;
+import java.util.List;
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.randomLongId;
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.randomPojo;
@@ -57,6 +76,24 @@
private MesWmProductProduceService productProduceService;
@MockitoBean
private MesWmProductProduceLineService produceLineService;
+ @MockitoBean
+ private MesProWorkOrderParamRecordService paramRecordService;
+ @MockitoBean
+ private MesProWorkOrderBomService workOrderBomService;
+ @MockitoBean
+ private MesProWorkOrderProcessService workOrderProcessService;
+ @MockitoBean
+ private MesProProcessService processService;
+ @MockitoBean
+ private MesProMpsApi mpsApi;
+ @MockitoBean
+ private MesMdAutoCodeRecordService autoCodeRecordService;
+ @MockitoBean
+ private MesMdmItemService mdmItemService;
+ @MockitoBean
+ private MdmItemBatchConfigApi itemBatchConfigApi;
+ @MockitoBean
+ private BpmProcessInstanceApi processInstanceApi;
@Test
public void testUpdateProFeedbackWhenIpqcFinish_success_withUnqualified() {
@@ -405,4 +442,274 @@
verify(productProduceService, never()).generateProductProduce(any(), anyBoolean(), any());
}
+ // ==================== 椤哄簭鎶ュ伐锛堜笂涓�閬撳伐搴忓畬鎴愬悗鎵嶈兘鎶ヤ笅涓�閬擄級娴嬭瘯 ====================
+
+ /**
+ * 鏋勯��"涓婇亾宸ュ簭锛坧rev锛�+ 褰撳墠宸ュ簭锛坈ur锛�"鐨勫伐鍗曞伐搴忛摼锛堟晠鎰忎贡搴忎紶鍏ワ紝楠岃瘉鎸� sort 鎺掑簭鍚庡彇鍓嶉┍锛�
+ */
+ private List<MesProWorkOrderProcessDO> buildTwoProcessChain(Long workOrderId, Long prevProcessId,
+ Long curProcessId) {
+ return ListUtil.of(
+ MesProWorkOrderProcessDO.builder().workOrderId(workOrderId).processId(curProcessId).sort(2).build(),
+ MesProWorkOrderProcessDO.builder().workOrderId(workOrderId).processId(prevProcessId).sort(1).build());
+ }
+
+ @Test
+ public void testQuickCreateFeedback_blockedWhenPreviousProcessNotFinished() {
+ // 鍑嗗锛氬綋鍓嶄换鍔″湪绗� 2 閬撳伐搴忥紝涓婇亾宸ュ簭浠诲姟鍙仛浜� 60/100
+ Long workOrderId = randomLongId();
+ Long routeId = randomLongId();
+ Long prevProcessId = randomLongId();
+ Long curProcessId = randomLongId();
+ Long curTaskId = randomLongId();
+
+ MesProTaskDO curTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setId(curTaskId);
+ o.setWorkOrderId(workOrderId);
+ o.setRouteId(routeId);
+ o.setProcessId(curProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.ZERO);
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.validateTaskNotFinished(curTaskId)).thenReturn(curTask);
+ when(workOrderProcessService.getWorkOrderProcessListByWorkOrderId(workOrderId))
+ .thenReturn(buildTwoProcessChain(workOrderId, prevProcessId, curProcessId));
+ MesProTaskDO prevTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setWorkOrderId(workOrderId);
+ o.setProcessId(prevProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.valueOf(60));
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.getTaskListByWorkOrderIds(Collections.singletonList(workOrderId)))
+ .thenReturn(List.of(prevTask));
+ when(processService.getProcess(prevProcessId)).thenReturn(
+ randomPojo(MesProProcessDO.class, o -> o.setName("CNC鍔犲伐")));
+
+ // 璋冪敤锛氬簲琚嫤鎴�
+ MesProFeedbackQuickCreateReqVO req = new MesProFeedbackQuickCreateReqVO();
+ req.setTaskId(curTaskId);
+ req.setFeedbackQuantity(BigDecimal.TEN);
+ ServiceException ex = assertThrows(ServiceException.class, () -> feedbackService.quickCreateFeedback(req));
+ assertTrue(ex.getMessage().contains("灏氭湭鎶ュ伐瀹屾垚"));
+ assertTrue(ex.getMessage().contains("CNC鍔犲伐"));
+ // 鏈湡姝ｇ敓鎴愭姤宸ュ崟
+ verify(autoCodeRecordService, never()).generateAutoCode(anyString());
+ }
+
+ @Test
+ public void testQuickCreateFeedback_blockedWhenPreviousMultiTaskAnyNotFinished() {
+ // 鍑嗗锛氫笂閬撳伐搴忔湁 2 涓换鍔★紝涓�涓仛婊°�佷竴涓湭鍋氭弧锛屼粛搴旀嫤鎴�
+ Long workOrderId = randomLongId();
+ Long routeId = randomLongId();
+ Long prevProcessId = randomLongId();
+ Long curProcessId = randomLongId();
+ Long curTaskId = randomLongId();
+
+ MesProTaskDO curTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setId(curTaskId);
+ o.setWorkOrderId(workOrderId);
+ o.setRouteId(routeId);
+ o.setProcessId(curProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.ZERO);
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.validateTaskNotFinished(curTaskId)).thenReturn(curTask);
+ when(workOrderProcessService.getWorkOrderProcessListByWorkOrderId(workOrderId))
+ .thenReturn(buildTwoProcessChain(workOrderId, prevProcessId, curProcessId));
+
+ MesProTaskDO finishedTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setWorkOrderId(workOrderId);
+ o.setProcessId(prevProcessId);
+ o.setQuantity(BigDecimal.valueOf(50));
+ o.setProducedQuantity(BigDecimal.valueOf(50)); // 宸插仛婊�
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ MesProTaskDO partialTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setWorkOrderId(workOrderId);
+ o.setProcessId(prevProcessId);
+ o.setQuantity(BigDecimal.valueOf(50));
+ o.setProducedQuantity(BigDecimal.valueOf(20)); // 鏈仛婊�
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.getTaskListByWorkOrderIds(Collections.singletonList(workOrderId)))
+ .thenReturn(ListUtil.of(finishedTask, partialTask));
+
+ MesProFeedbackQuickCreateReqVO req = new MesProFeedbackQuickCreateReqVO();
+ req.setTaskId(curTaskId);
+ req.setFeedbackQuantity(BigDecimal.TEN);
+ ServiceException ex = assertThrows(ServiceException.class, () -> feedbackService.quickCreateFeedback(req));
+ assertTrue(ex.getMessage().contains("灏氭湭鎶ュ伐瀹屾垚"));
+ }
+
+ @Test
+ public void testQuickCreateFeedback_allowedWhenPreviousProcessFinished() {
+ // 鍑嗗锛氫笂閬撳伐搴忎换鍔″凡鍋氭弧锛�100/100锛夛紝褰撳墠涓虹 2 閬撳伐搴忥紝搴旀斁琛�
+ Long workOrderId = randomLongId();
+ Long routeId = randomLongId();
+ Long prevProcessId = randomLongId();
+ Long curProcessId = randomLongId();
+ Long curTaskId = randomLongId();
+
+ MesProTaskDO curTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setId(curTaskId);
+ o.setWorkOrderId(workOrderId);
+ o.setRouteId(routeId);
+ o.setProcessId(curProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.ZERO);
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.validateTaskNotFinished(curTaskId)).thenReturn(curTask);
+ when(workOrderProcessService.getWorkOrderProcessListByWorkOrderId(workOrderId))
+ .thenReturn(buildTwoProcessChain(workOrderId, prevProcessId, curProcessId));
+ MesProTaskDO prevTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setWorkOrderId(workOrderId);
+ o.setProcessId(prevProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.valueOf(100)); // 宸插仛婊�
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.getTaskListByWorkOrderIds(Collections.singletonList(workOrderId)))
+ .thenReturn(List.of(prevTask));
+
+ // 璧伴�氬悗缁�昏緫鐨勬々
+ when(routeProcessService.getRouteProcessByRouteIdAndProcessId(routeId, curProcessId))
+ .thenReturn(MesProRouteProcessDO.builder().routeId(routeId).processId(curProcessId)
+ .keyFlag(false).checkFlag(false).build());
+ when(autoCodeRecordService.generateAutoCode(anyString())).thenReturn("FB-ORDER-1");
+
+ // 璋冪敤锛氬簲鎴愬姛鐢熸垚鎶ュ伐鍗�
+ MesProFeedbackQuickCreateReqVO req = new MesProFeedbackQuickCreateReqVO();
+ req.setTaskId(curTaskId);
+ req.setFeedbackQuantity(BigDecimal.TEN);
+ MesProFeedbackQuickCreateRespVO resp = feedbackService.quickCreateFeedback(req);
+ assertNotNull(resp);
+ assertNotNull(resp.getFeedbackId());
+ verify(autoCodeRecordService).generateAutoCode(anyString());
+ }
+
+ @Test
+ public void testQuickCreateFeedback_allowedWhenPreviousProcessAllCancelled() {
+ // 鍑嗗锛氫笂閬撳伐搴忎换鍔″叏閮ㄥ彇娑堬紝瑙嗕负鏃犲墠缃姹傦紝褰撳墠绗� 2 閬撳伐搴忓簲鏀捐
+ Long workOrderId = randomLongId();
+ Long routeId = randomLongId();
+ Long prevProcessId = randomLongId();
+ Long curProcessId = randomLongId();
+ Long curTaskId = randomLongId();
+
+ MesProTaskDO curTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setId(curTaskId);
+ o.setWorkOrderId(workOrderId);
+ o.setRouteId(routeId);
+ o.setProcessId(curProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.ZERO);
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.validateTaskNotFinished(curTaskId)).thenReturn(curTask);
+ when(workOrderProcessService.getWorkOrderProcessListByWorkOrderId(workOrderId))
+ .thenReturn(buildTwoProcessChain(workOrderId, prevProcessId, curProcessId));
+ MesProTaskDO cancelledTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setWorkOrderId(workOrderId);
+ o.setProcessId(prevProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.ZERO);
+ o.setStatus(MesProTaskStatusEnum.CANCELED.getStatus());
+ });
+ when(taskService.getTaskListByWorkOrderIds(Collections.singletonList(workOrderId)))
+ .thenReturn(List.of(cancelledTask));
+ when(routeProcessService.getRouteProcessByRouteIdAndProcessId(routeId, curProcessId))
+ .thenReturn(MesProRouteProcessDO.builder().routeId(routeId).processId(curProcessId)
+ .keyFlag(false).checkFlag(false).build());
+ when(autoCodeRecordService.generateAutoCode(anyString())).thenReturn("FB-ORDER-2");
+
+ MesProFeedbackQuickCreateReqVO req = new MesProFeedbackQuickCreateReqVO();
+ req.setTaskId(curTaskId);
+ req.setFeedbackQuantity(BigDecimal.TEN);
+ MesProFeedbackQuickCreateRespVO resp = feedbackService.quickCreateFeedback(req);
+ assertNotNull(resp);
+ assertNotNull(resp.getFeedbackId());
+ }
+
+ @Test
+ public void testQuickCreateFeedback_allowedWhenCurrentIsFirstProcess() {
+ // 鍑嗗锛氬綋鍓嶄换鍔″氨鏄 1 閬撳伐搴忥紙閾句腑鍙湁涓�閬撳伐搴忥級锛屾棤鍓嶇疆锛屽簲鏀捐
+ Long workOrderId = randomLongId();
+ Long routeId = randomLongId();
+ Long curProcessId = randomLongId();
+ Long curTaskId = randomLongId();
+
+ MesProTaskDO curTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setId(curTaskId);
+ o.setWorkOrderId(workOrderId);
+ o.setRouteId(routeId);
+ o.setProcessId(curProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.ZERO);
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.validateTaskNotFinished(curTaskId)).thenReturn(curTask);
+ when(workOrderProcessService.getWorkOrderProcessListByWorkOrderId(workOrderId))
+ .thenReturn(ListUtil.of(MesProWorkOrderProcessDO.builder()
+ .workOrderId(workOrderId).processId(curProcessId).sort(1).build()));
+ when(routeProcessService.getRouteProcessByRouteIdAndProcessId(routeId, curProcessId))
+ .thenReturn(MesProRouteProcessDO.builder().routeId(routeId).processId(curProcessId)
+ .keyFlag(false).checkFlag(false).build());
+ when(autoCodeRecordService.generateAutoCode(anyString())).thenReturn("FB-ORDER-3");
+
+ MesProFeedbackQuickCreateReqVO req = new MesProFeedbackQuickCreateReqVO();
+ req.setTaskId(curTaskId);
+ req.setFeedbackQuantity(BigDecimal.TEN);
+ MesProFeedbackQuickCreateRespVO resp = feedbackService.quickCreateFeedback(req);
+ assertNotNull(resp);
+ assertNotNull(resp.getFeedbackId());
+ }
+
+ @Test
+ public void testSubmitFeedback_blockedWhenPreviousProcessNotFinished() {
+ // 鍑嗗锛氬凡瀛樺湪鑽夌鎶ュ伐鍗曪紙绗� 2 閬撳伐搴忥級锛屼笂閬撳伐搴忔湭鍋氭弧锛屾彁浜ゅ簲琚嫤鎴�
+ Long workOrderId = randomLongId();
+ Long routeId = randomLongId();
+ Long prevProcessId = randomLongId();
+ Long curProcessId = randomLongId();
+ Long curTaskId = randomLongId();
+
+ MesProFeedbackDO feedback = randomPojo(MesProFeedbackDO.class, o -> {
+ o.setStatus(MesProFeedbackStatusEnum.PREPARE.getStatus());
+ o.setTaskId(curTaskId);
+ o.setWorkOrderId(workOrderId);
+ o.setRouteId(routeId);
+ o.setProcessId(curProcessId);
+ });
+ feedbackMapper.insert(feedback);
+
+ MesProTaskDO curTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setId(curTaskId);
+ o.setWorkOrderId(workOrderId);
+ o.setRouteId(routeId);
+ o.setProcessId(curProcessId);
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.getTask(curTaskId)).thenReturn(curTask);
+ when(workOrderProcessService.getWorkOrderProcessListByWorkOrderId(workOrderId))
+ .thenReturn(buildTwoProcessChain(workOrderId, prevProcessId, curProcessId));
+ MesProTaskDO prevTask = randomPojo(MesProTaskDO.class, o -> {
+ o.setWorkOrderId(workOrderId);
+ o.setProcessId(prevProcessId);
+ o.setQuantity(BigDecimal.valueOf(100));
+ o.setProducedQuantity(BigDecimal.valueOf(30));
+ o.setStatus(MesProTaskStatusEnum.PREPARE.getStatus());
+ });
+ when(taskService.getTaskListByWorkOrderIds(Collections.singletonList(workOrderId)))
+ .thenReturn(List.of(prevTask));
+
+ MesProFeedbackSubmitReqVO req = new MesProFeedbackSubmitReqVO();
+ req.setId(feedback.getId());
+ ServiceException ex = assertThrows(ServiceException.class, () -> feedbackService.submitFeedback(req));
+ assertTrue(ex.getMessage().contains("灏氭湭鎶ュ伐瀹屾垚"));
+ }
+
}
--
Gitblit v1.9.3