feat(mes): 新增报工设备快照功能并优化状态校验

云

6 小时以前 3ff6604c75c887f4056ee03545d204bc9323286c

 yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/pro/feedback/MesProFeedbackServiceImplTest.java

@@ -63,6 +63,9 @@
    private MesProFeedbackMapper feedbackMapper;

    @MockitoBean
    private MesProFeedbackEquipmentService equipmentService;

    @MockitoBean
    private MesProWorkOrderService workOrderService;
    @MockitoBean
    private MesProRouteProcessService routeProcessService;
@@ -94,6 +97,15 @@
    private MdmItemBatchConfigApi itemBatchConfigApi;
    @MockitoBean
    private BpmProcessInstanceApi processInstanceApi;

    @Test
    public void testEquipmentSnapshotSurvivesStatusUpdates() {
        MesProFeedbackDO feedback = randomPojo(MesProFeedbackDO.class, f -> f.setMachineryIds("10,20"));
        feedbackMapper.insert(feedback);
        feedbackMapper.updateById(new MesProFeedbackDO().setId(feedback.getId())
                .setStatus(MesProFeedbackStatusEnum.APPROVING.getStatus()));
        assertEquals("10,20", feedbackMapper.selectById(feedback.getId()).getMachineryIds());
    }

    @Test
    public void testUpdateProFeedbackWhenIpqcFinish_success_withUnqualified() {
@@ -146,12 +158,9 @@
        assertEquals(0, materialScrapQty.compareTo(updatedFeedback.getMaterialScrapQuantity()));
        assertEquals(0, otherScrapQty.compareTo(updatedFeedback.getOtherScrapQuantity()));

        // 断言 4：更新了任务和工单的已生产数量
        // 注意：数量经过 DB 存取后 scale 可能变化，用 any() 匹配
        verify(taskService).updateProducedQuantity(eq(taskId),
                any(BigDecimal.class), any(BigDecimal.class), any(BigDecimal.class));
        verify(workOrderService).updateProducedQuantity(eq(workOrderId),
                any(BigDecimal.class));
        // 产量已经在报工审批时累计，质检回调不能重复累计。
        verify(taskService, never()).updateProducedQuantity(anyLong(), any(), any(), any());
        verify(workOrderService, never()).updateProducedQuantity(anyLong(), any());
    }

    @Test
@@ -263,6 +272,8 @@
        when(productProduceService.generateProductProduce(any(), eq(false), any())).thenReturn(produce);

        // mock: 产出行（用于 updateTaskAndWorkOrderByFeedback）
        when(workOrderProcessService.getLastWorkOrderProcessByWorkOrderId(feedback.getWorkOrderId()))
                .thenReturn(new MesProWorkOrderProcessDO().setProcessId(processId));
        MesWmProductProduceLineDO qualifiedLine = MesWmProductProduceLineDO.builder()
                .quantity(BigDecimal.valueOf(80))
                .qualityStatus(MesWmQualityStatusEnum.PASS.getStatus()).build();
@@ -328,8 +339,8 @@
        verify(productProduceService).generateProductProduce(any(), eq(true), any());
        verify(productProduceService, never()).finishProductProduce(anyLong());

        // 断言 4：没有更新任务/工单数量（等 IPQC 回调）
        verify(taskService, never()).updateProducedQuantity(anyLong(), any(), any(), any());
        // 产量在审批时累计，产出仍保持待检；非末道不更新工单总产量。
        verify(taskService).updateProducedQuantity(eq(feedback.getTaskId()), any(), any(), any());
        verify(workOrderService, never()).updateProducedQuantity(anyLong(), any());
    }

@@ -353,6 +364,8 @@
                .keyFlag(false).checkFlag(false).build();
        when(routeProcessService.getRouteProcessByRouteIdAndProcessId(routeId, processId))
                .thenReturn(routeProcess);
        MesWmProductProduceDO produce = randomPojo(MesWmProductProduceDO.class);
        when(productProduceService.generateProductProduce(any(), eq(false), any())).thenReturn(produce);

        // 调用
        MesProFeedbackApproveReqVO reqVO = new MesProFeedbackApproveReqVO();
@@ -366,9 +379,11 @@
        MesProFeedbackDO updated = feedbackMapper.selectById(feedback.getId());
        assertEquals(MesProFeedbackStatusEnum.FINISHED.getStatus(), updated.getStatus());

        // 断言 3：不生成产出单，不更新任务/工单
        verify(productProduceService, never()).generateProductProduce(any(), anyBoolean(), any());
        verify(taskService, never()).updateProducedQuantity(anyLong(), any(), any(), any());
        // 非关键工序也生成产出并累计任务进度，但不累计工单总产量。
        verify(productProduceService).generateProductProduce(any(), eq(false), any());
        verify(productProduceService).finishProductProduce(produce.getId());
        verify(taskService).updateProducedQuantity(eq(feedback.getTaskId()), any(), any(), any());
        verify(workOrderService, never()).updateProducedQuantity(anyLong(), any());
    }

    @Test
@@ -404,9 +419,9 @@
    }

    @Test
    public void testApproveFeedback_nonKeyCheck_directFinishAndCleanUncheck() {
    public void testApproveFeedback_nonKeyCheck_enterUncheckAndCleanQuantity() {
        // 准备数据：非关键 + 质检工序（!key+check），uncheckQuantity > 0
        // 应放行（checkFlag=true 不拦截 uncheckQuantity），直接完结并清零 uncheckQuantity
        // 应放行并进入待检验，审批阶段只累计一次任务产量。
        Long routeId = randomLongId();
        Long processId = randomLongId();
        MesProFeedbackDO feedback = randomPojo(MesProFeedbackDO.class, o -> {
@@ -430,16 +445,17 @@
        reqVO.setId(feedback.getId());
        boolean result = feedbackService.approveFeedback(reqVO);

        // 断言 1：返回 true（直接完成，不走 UNCHECK）
        assertTrue(result);
        assertFalse(result);

        // 断言 2：状态为已完成，uncheckQuantity 被清零
        // 质检工序无论是否关键工序，都进入待检验。
        MesProFeedbackDO updated = feedbackMapper.selectById(feedback.getId());
        assertEquals(MesProFeedbackStatusEnum.FINISHED.getStatus(), updated.getStatus());
        assertEquals(MesProFeedbackStatusEnum.UNCHECK.getStatus(), updated.getStatus());
        assertEquals(0, BigDecimal.ZERO.compareTo(updated.getUncheckQuantity()));

        // 断言 3：非关键工序不生成产出单
        verify(productProduceService, never()).generateProductProduce(any(), anyBoolean(), any());
        verify(productProduceService).generateProductProduce(any(), eq(true), any());
        verify(productProduceService, never()).finishProductProduce(anyLong());
        verify(taskService).updateProducedQuantity(eq(feedback.getTaskId()), any(), any(), any());
        verify(workOrderService, never()).updateProducedQuantity(anyLong(), any());
    }

    // ==================== 顺序报工（上一道工序完成后才能报下一道）测试 ====================