| | |
| | | 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.framework.operatelog.core.util.OperateLogUtils; |
| | | import cn.hutool.core.util.ObjectUtil; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.qc.iqc.vo.MesQcIqcImportExcelVO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.qc.iqc.vo.MesQcIqcPageReqVO; |
| | |
| | | import cn.iocoder.yudao.module.srm.api.supplier.SrmSupplierApi; |
| | | import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi; |
| | | import cn.iocoder.yudao.module.system.api.user.AdminUserApi; |
| | | import com.mzt.logapi.starter.annotation.LogRecord; |
| | | import jakarta.annotation.Resource; |
| | | import org.springframework.context.annotation.Lazy; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | |
| | | import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; |
| | | import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*; |
| | | import static cn.iocoder.yudao.module.mes.enums.LogRecordConstants.*; |
| | | |
| | | /** |
| | | * MES 来料检验单(IQC) Service 实现类 |
| | |
| | | @Service |
| | | @Validated |
| | | public class MesQcIqcServiceImpl implements MesQcIqcService { |
| | | |
| | | @Resource |
| | | private cn.iocoder.yudao.module.mes.service.qc.MesQcCompletionHelper completionHelper; |
| | | |
| | | @Resource |
| | | private MesQcIqcMapper iqcMapper; |
| | |
| | | // 1.2 校验来源单据参数,并验证数据存在 |
| | | String sourceDocCode = validateAndGetSourceDocCode( |
| | | createReqVO.getSourceDocType(), createReqVO.getSourceDocId(), createReqVO.getSourceLineId()); |
| | | // 1.3 根据产品 + IQC 类型查找可用质检方案(支持前端显式指定) |
| | | List<MesQcTemplateItemDO> templateItems = templateItemService.getTemplateItemList( |
| | | createReqVO.getItemId(), MesQcTypeEnum.IQC.getType(), null, null); |
| | | if (CollUtil.isEmpty(templateItems)) { |
| | | throw exception(QC_NO_TEMPLATE); |
| | | } |
| | | MesQcTemplateItemDO templateItem = templateItems.get(0); |
| | | if (createReqVO.getTemplateId() != null) { |
| | | templateItem = templateItems.stream() |
| | | .filter(item -> Objects.equals(item.getTemplateId(), createReqVO.getTemplateId())) |
| | | .findFirst().orElse(null); |
| | | if (templateItem == null) { |
| | | throw exception(QC_NO_TEMPLATE); // 指定了方案但不在匹配列表中,拒绝 |
| | | } |
| | | } |
| | | Long templateId = templateItem.getTemplateId(); |
| | | // 新建质检单不依赖质检方案。 |
| | | |
| | | // 2. 插入主表 |
| | | MesQcIqcDO iqc = BeanUtils.toBean(createReqVO, MesQcIqcDO.class) |
| | | .setTemplateId(templateId) |
| | | .setTemplateId(null) |
| | | .setCheckQuantity(createReqVO.getQualifiedQuantity().add(createReqVO.getUnqualifiedQuantity())) |
| | | .setSourceDocCode(sourceDocCode) |
| | | .setStatus(MesQcStatusEnum.DRAFT.getStatus()); |
| | | iqcMapper.insert(iqc); |
| | | |
| | | // 3. 从模板指标自动生成检验行 |
| | | iqcLineService.createLinesFromTemplate(iqc.getId(), templateId); |
| | | return iqc.getId(); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | private void validateIqcSaveData(MesQcIqcSaveReqVO reqVO) { |
| | | // 空字符串也需要写入,以支持编辑时清空手填名称。 |
| | | if (reqVO.getVendorName() != null) { |
| | | reqVO.setVendorName(reqVO.getVendorName().trim()); |
| | | } |
| | | // 校验编号唯一 |
| | | validateIqcCodeUnique(reqVO.getId(), reqVO.getCode()); |
| | | // 校验供应商存在 |
| | | if (reqVO.getVendorId() != null) { |
| | | srmSupplierApi.getSupplier(reqVO.getVendorId()); |
| | | var supplier = srmSupplierApi.getSupplier(reqVO.getVendorId()).getCheckedData(); |
| | | if (reqVO.getVendorName() == null && supplier != null) { |
| | | reqVO.setVendorName(supplier.getName()); |
| | | } |
| | | } |
| | | // 校验物料存在(使用 MDM 物料) |
| | | if (reqVO.getItemId() != null) { |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void finishIqc(Long id) { |
| | | completionHelper.lockDocument("iqc", id); |
| | | // 1.1 校验存在 + 草稿状态 |
| | | MesQcIqcDO iqc = validateIqcStatusPrepare(id); |
| | | if (iqc.getCheckResult() == null) { |
| | | throw exception(QC_IQC_CHECK_RESULT_EMPTY); |
| | | } |
| | | // 1.2 校验至少存在一条检测结果 |
| | | indicatorResultService.validateIndicatorResultExistsByQcIdAndType(id, MesQcTypeEnum.IQC.getType()); |
| | | int result = completionHelper.validateAndGetResult("iqc", id, iqc.getQualifiedQuantity(), iqc.getUnqualifiedQuantity(), iqc.getCheckQuantity()); |
| | | iqc.setCheckResult(result); |
| | | |
| | | |
| | | // 2. 更新状态为已完成 |
| | | MesQcIqcDO updateObj = new MesQcIqcDO() |
| | | .setId(id).setStatus(MesQcStatusEnum.FINISHED.getStatus()); |
| | | .setId(id).setStatus(MesQcStatusEnum.FINISHED.getStatus()).setCheckResult(result); |
| | | iqcMapper.updateById(updateObj); |
| | | |
| | | // 3. 不合格时自动创建 NCR |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Long createIqcFromArrivalNotice(Long noticeId, MesWmArrivalNoticeLineDO line, String noticeCode, Long vendorId) { |
| | | // 1. 校验物料是否配置了 IQC 检验模板 |
| | | MesQcTemplateItemDO templateItem; |
| | | try { |
| | | templateItem = templateItemService.getRequiredTemplateByItemIdAndType( |
| | | line.getItemId(), MesQcTypeEnum.IQC.getType()); |
| | | } catch (Exception e) { |
| | | // 获取物料信息,提供更明确的错误提示 |
| | | String itemInfo = getItemInfo(line.getItemId()); |
| | | throw exception(QC_NO_TEMPLATE_FOR_ITEM, itemInfo); |
| | | } |
| | | Long templateId = templateItem.getTemplateId(); |
| | | |
| | | // 2. 生成检验单编码 |
| | | String code = "IQC" + System.currentTimeMillis(); |
| | |
| | | MesQcIqcDO iqc = new MesQcIqcDO(); |
| | | iqc.setCode(code); |
| | | iqc.setName(noticeCode + "-物料检验"); |
| | | iqc.setTemplateId(templateId); |
| | | |
| | | iqc.setSourceDocType(MesBizTypeConstants.WM_ARRIVAL_NOTICE); |
| | | iqc.setSourceDocId(noticeId); |
| | | iqc.setSourceLineId(line.getId()); |
| | | iqc.setSourceDocCode(noticeCode); |
| | | iqc.setVendorId(vendorId); |
| | | if (vendorId != null) { |
| | | var supplier = srmSupplierApi.getSupplier(vendorId).getCheckedData(); |
| | | if (supplier != null) { |
| | | iqc.setVendorName(supplier.getName()); |
| | | } |
| | | } |
| | | iqc.setItemId(line.getItemId()); |
| | | iqc.setReceivedQuantity(line.getArrivalQuantity()); |
| | | iqc.setCheckQuantity(BigDecimal.ZERO); // 待填写 |
| | |
| | | iqc.setStatus(MesQcStatusEnum.DRAFT.getStatus()); |
| | | iqcMapper.insert(iqc); |
| | | |
| | | // 4. 从模板指标自动生成检验行 |
| | | iqcLineService.createLinesFromTemplate(iqc.getId(), templateId); |
| | | |
| | | return iqc.getId(); |
| | | } |
| | |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | @LogRecord(type = MES_QC_IQC_TYPE, subType = MES_QC_IQC_IMPORT_SUB_TYPE, bizNo = "0", |
| | | success = MES_QC_IQC_IMPORT_SUCCESS) |
| | | public MesQcImportRespVO importIqcList(List<MesQcIqcImportExcelVO> importList) { |
| | | MesQcImportRespVO respVO = MesQcImportRespVO.builder() |
| | | .createList(new ArrayList<>()).failureList(new LinkedHashMap<>()).build(); |
| | | if (CollUtil.isEmpty(importList)) { |
| | | // 空文件也要给日志文案兜底,避免 {{#importSummary}} 取不到值 |
| | | OperateLogUtils.putImportSummary(respVO.getCreateList(), null, respVO.getFailureList()); |
| | | return respVO; |
| | | } |
| | | qcImportHelper.startImport(); |
| | |
| | | respVO.getFailureList().put(label, MesQcImportHelper.resolveImportErrorMessage(ex)); |
| | | } |
| | | } |
| | | // 记录导入结果汇总,供 @LogRecord 的 success 文案引用 |
| | | OperateLogUtils.putImportSummary(respVO.getCreateList(), null, respVO.getFailureList()); |
| | | return respVO; |
| | | } |
| | | |
| | |
| | | } |
| | | reqVO.setName(row.getName().trim()); |
| | | reqVO.setItemId(qcImportHelper.resolveItemId(row.getItemCode())); |
| | | reqVO.setVendorId(qcImportHelper.resolveVendorId(row.getVendorName())); |
| | | reqVO.setVendorName(StrUtil.trimToEmpty(row.getVendorName())); |
| | | reqVO.setVendorBatch(StrUtil.trimToNull(row.getVendorBatch())); |
| | | reqVO.setTemplateId(qcImportHelper.resolveTemplateId(row.getTemplateName())); |
| | | // 3. 数量:合格品 + 不合格品 必须等于本次接收数量(接收数量留空则自动合计) |
| | |
| | | reqVO.setReceiveDate(qcImportHelper.parseRequiredDateTime(row.getReceiveDate(), "来料日期")); |
| | | reqVO.setRemark(StrUtil.trimToNull(row.getRemark())); |
| | | // 5. 去重:同一 物料 + 供应商 + 供应商批次 + 来料日期 的来料检验单不可重复导入 |
| | | MesQcIqcDO duplicate = CollUtil.getFirst(iqcMapper.selectListByImportKey(reqVO.getItemId(), reqVO.getVendorId(), |
| | | MesQcIqcDO duplicate = CollUtil.getFirst(iqcMapper.selectListByImportKey(reqVO.getItemId(), reqVO.getVendorName(), |
| | | reqVO.getVendorBatch(), reqVO.getReceiveDate())); |
| | | if (duplicate != null) { |
| | | throw MesQcImportHelper.duplicateExistingException(buildImportKeyDesc(row), "来料检验单", |