revert(collect): 撤销 collect 数采模块（新高设备管理已有自己的采集方式）

xiaoyi

6 天以前 9075785a9e14f6220783d052d231f915c6930b87

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkOrderServiceImpl.java

@@ -2,11 +2,16 @@

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.MesProWorkOrderImportExcelVO;
import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.MesProWorkOrderImportRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.MesProWorkOrderPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.MesProWorkOrderSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemBatchConfigDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderDO;
import cn.iocoder.yudao.module.mes.dal.mysql.pro.workorder.MesProWorkOrderMapper;
import cn.iocoder.yudao.module.mes.enums.pro.MesProWorkOrderStatusEnum;
@@ -24,6 +29,7 @@
import cn.iocoder.yudao.module.mes.service.pro.task.MesProTaskService;
import cn.iocoder.yudao.module.mes.service.wm.barcode.MesWmBarcodeService;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.crm.api.customer.dto.CrmCustomerRespDTO;
import cn.iocoder.yudao.module.erp.api.sale.ErpSaleOrderApi;
import cn.iocoder.yudao.module.erp.api.sale.dto.ErpSaleOrderRespDTO;
import jakarta.annotation.Resource;
@@ -36,6 +42,7 @@
import java.math.RoundingMode;
import java.time.LocalDateTime;
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
@@ -173,6 +180,75 @@
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public MesProWorkOrderImportRespVO importWorkOrderList(List<MesProWorkOrderImportExcelVO> importList,
                                                           boolean updateSupport) {
        // 1. 校验非空
        if (CollUtil.isEmpty(importList)) {
            throw exception(MES_PRO_WORK_ORDER_IMPORT_LIST_IS_EMPTY);
        }

        // 2. 逐行处理
        MesProWorkOrderImportRespVO respVO = MesProWorkOrderImportRespVO.builder()
                .createCodes(new ArrayList<>()).updateCodes(new ArrayList<>())
                .failureCodes(new LinkedHashMap<>()).build();
        AtomicInteger index = new AtomicInteger(1);
        importList.forEach(importItem -> {
            int currentIndex = index.getAndIncrement();
            String key = StrUtil.blankToDefault(importItem.getCode(), "第 " + currentIndex + " 行");
            if (StrUtil.isBlank(importItem.getCode())) {
                respVO.getFailureCodes().put(key, "工单编码不能为空");
                return;
            }
            if (StrUtil.isBlank(importItem.getName())) {
                respVO.getFailureCodes().put(key, "工单名称不能为空");
                return;
            }
            // 2.1 解析产品
            Long productId = null;
            if (StrUtil.isNotBlank(importItem.getProductCode())) {
                MesMdItemDO item = itemService.getItemByCode(importItem.getProductCode().trim());
                if (item == null) {
                    respVO.getFailureCodes().put(key, "产品编码[" + importItem.getProductCode() + "]不存在");
                    return;
                }
                productId = item.getId();
            }
            // 2.2 解析客户
            Long clientId = null;
            if (StrUtil.isNotBlank(importItem.getClientName())) {
                CrmCustomerRespDTO customer = customerApi.getCustomerByName(importItem.getClientName().trim());
                if (customer == null) {
                    respVO.getFailureCodes().put(key, "客户名称[" + importItem.getClientName() + "]不存在");
                    return;
                }
                clientId = customer.getId();
            }
            // 2.3 构建请求并创建/更新（复用现有 create/update 服务，保留 BOM 与条码生成逻辑）
            MesProWorkOrderSaveReqVO reqVO = BeanUtils.toBean(importItem, MesProWorkOrderSaveReqVO.class);
            reqVO.setProductId(productId);
            reqVO.setClientId(clientId);
            MesProWorkOrderDO existWorkOrder = workOrderMapper.selectByCode(importItem.getCode());
            try {
                if (existWorkOrder == null) {
                    reqVO.setId(null);
                    createWorkOrder(reqVO);
                    respVO.getCreateCodes().add(importItem.getCode());
                } else if (updateSupport) {
                    reqVO.setId(existWorkOrder.getId());
                    updateWorkOrder(reqVO);
                    respVO.getUpdateCodes().add(importItem.getCode());
                } else {
                    respVO.getFailureCodes().put(key, "工单编码已存在");
                }
            } catch (ServiceException e) {
                respVO.getFailureCodes().put(key, e.getMessage());
            }
        });
        return respVO;
    }

    @Override
    public PageResult<MesProWorkOrderDO> getWorkOrderPage(MesProWorkOrderPageReqVO pageReqVO) {
        // 获取用户有权限的客户 ID 列表
        List<Long> permittedClientIds = customerApi.getPermittedCustomerIds();
@@ -225,6 +301,20 @@
        if (ObjUtil.notEqual(workOrder.getStatus(), MesProWorkOrderStatusEnum.CONFIRMED.getStatus())) {
            throw exception(PRO_WORK_ORDER_NOT_CONFIRMED);
        }
        if (workOrder.getQuantityProduced() == null
                || workOrder.getQuantity() == null
                || workOrder.getQuantityProduced().compareTo(workOrder.getQuantity()) < 0) {
            throw exception(PRO_WORK_ORDER_PRODUCTION_NOT_COMPLETE);
        }
        // 校验每个任务的实际产出是否已达成计划数量（任务状态只有在工单完成时由级联方法置为已完成，不能在此校验状态）
        List<MesProTaskDO> tasks = taskService.getTaskListByWorkOrderIds(Collections.singletonList(id));
        boolean hasUnfinishedTask = CollUtil.isEmpty(tasks) || tasks.stream().anyMatch(task ->
                task.getProducedQuantity() == null
                        || task.getQuantity() == null
                        || task.getProducedQuantity().compareTo(task.getQuantity()) < 0);
        if (hasUnfinishedTask) {
            throw exception(PRO_WORK_ORDER_PRODUCTION_NOT_COMPLETE);
        }

        // 2. 级联完成所有关联任务
        taskService.finishTaskByOrderId(id);