| | |
| | | import cn.iocoder.yudao.module.mes.dal.dataobject.qc.defectrecord.MesQcDefectRecordDO; |
| | | import cn.iocoder.yudao.module.mes.dal.dataobject.qc.iqc.MesQcIqcDO; |
| | | import cn.iocoder.yudao.module.mes.dal.dataobject.qc.template.MesQcTemplateItemDO; |
| | | import cn.iocoder.yudao.module.mes.dal.dataobject.wm.arrivalnotice.MesWmArrivalNoticeLineDO; |
| | | import cn.iocoder.yudao.module.mes.dal.mysql.qc.iqc.MesQcIqcMapper; |
| | | import cn.iocoder.yudao.module.mes.enums.MesBizTypeConstants; |
| | | import cn.iocoder.yudao.module.mes.enums.qc.MesQcDefectLevelEnum; |
| | |
| | | import cn.iocoder.yudao.module.mes.service.qc.template.MesQcTemplateItemService; |
| | | import cn.iocoder.yudao.module.mes.service.wm.arrivalnotice.MesWmArrivalNoticeService; |
| | | import cn.iocoder.yudao.module.mes.service.wm.outsourcereceipt.MesWmOutsourceReceiptService; |
| | | import cn.iocoder.yudao.module.erp.api.purchase.ErpSupplierApi; |
| | | import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi; |
| | | import cn.iocoder.yudao.module.system.api.user.AdminUserApi; |
| | | import jakarta.annotation.Resource; |
| | | import org.springframework.context.annotation.Lazy; |
| | |
| | | @Resource |
| | | private AdminUserApi adminUserApi; |
| | | |
| | | @Resource |
| | | private MdmItemApi mdmItemApi; |
| | | |
| | | @Resource |
| | | @Lazy |
| | | private ErpSupplierApi supplierApi; |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Long createIqc(MesQcIqcSaveReqVO createReqVO) { |
| | |
| | | private void validateIqcSaveData(MesQcIqcSaveReqVO reqVO) { |
| | | // 校验编号唯一 |
| | | validateIqcCodeUnique(reqVO.getId(), reqVO.getCode()); |
| | | // 校验供应商、物料、检测人员存在 |
| | | // 校验供应商存在(优先校验 ERP 供应商,失败则校验 MDM 供应商) |
| | | if (reqVO.getVendorId() != null) { |
| | | try { |
| | | supplierApi.validateSupplier(reqVO.getVendorId()); |
| | | } catch (Exception e) { |
| | | // ERP 供应商校验失败,尝试 MDM 供应商 |
| | | vendorService.validateVendorExists(reqVO.getVendorId()); |
| | | itemService.validateItemExists(reqVO.getItemId()); |
| | | } |
| | | } |
| | | // 校验物料存在(使用 MDM 物料) |
| | | if (reqVO.getItemId() != null) { |
| | | mdmItemApi.getItem(reqVO.getItemId()).getCheckedData(); |
| | | } |
| | | // 校验检测人员存在 |
| | | adminUserApi.validateUser(reqVO.getInspectorUserId()); |
| | | } |
| | | |
| | |
| | | // 根据不同的来源单据类型,回写不同的单据 |
| | | if (Objects.equals(iqc.getSourceDocType(), MesBizTypeConstants.WM_ARRIVAL_NOTICE)) { |
| | | arrivalNoticeService.updateArrivalNoticeWhenIqcFinish(iqc.getSourceDocId(), iqc.getSourceLineId(), |
| | | iqc.getId(), iqc.getQualifiedQuantity()); |
| | | iqc.getId(), iqc.getCheckResult(), iqc.getQualifiedQuantity()); |
| | | } else if (Objects.equals(iqc.getSourceDocType(), MesBizTypeConstants.WM_OUTSOURCE_RECPT)) { |
| | | outsourceReceiptService.updateOutsourceReceiptWhenIqcFinish(iqc.getSourceDocId(), iqc.getSourceLineId(), |
| | | iqc.getId(), iqc.getQualifiedQuantity(), iqc.getUnqualifiedQuantity()); |
| | |
| | | return iqcMapper.selectCountByVendorId(vendorId); |
| | | } |
| | | |
| | | @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(); |
| | | |
| | | // 3. 创建 IQC 主表(待检验状态,初始合格数量为 0) |
| | | 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); |
| | | iqc.setItemId(line.getItemId()); |
| | | iqc.setReceivedQuantity(line.getArrivalQuantity()); |
| | | iqc.setCheckQuantity(BigDecimal.ZERO); // 待填写 |
| | | iqc.setQualifiedQuantity(BigDecimal.ZERO); // 待填写 |
| | | iqc.setUnqualifiedQuantity(BigDecimal.ZERO); // 待填写 |
| | | iqc.setReceiveDate(java.time.LocalDateTime.now()); |
| | | iqc.setStatus(MesQcStatusEnum.DRAFT.getStatus()); |
| | | iqcMapper.insert(iqc); |
| | | |
| | | // 4. 从模板指标自动生成检验行 |
| | | iqcLineService.createLinesFromTemplate(iqc.getId(), templateId); |
| | | |
| | | return iqc.getId(); |
| | | } |
| | | |
| | | /** |
| | | * 获取物料信息(编码+名称) |
| | | */ |
| | | private String getItemInfo(Long itemId) { |
| | | if (itemId == null) { |
| | | return "未知物料"; |
| | | } |
| | | try { |
| | | cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemRespDTO item = mdmItemApi.getItem(itemId).getCheckedData(); |
| | | if (item != null) { |
| | | return item.getCode() + "-" + item.getName(); |
| | | } |
| | | } catch (Exception e) { |
| | | // 忽略异常 |
| | | } |
| | | return "物料ID:" + itemId; |
| | | } |
| | | |
| | | } |