From ffca46b39d25439a06a27cafda2ec523a3fb67cf Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期二, 27 十月 2026 17:53:02 +0800
Subject: [PATCH] feat(mes): 增加盘号字段支持和优化报工质检流程
---
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java | 46 +++++++++++++++++++++++++++++++++++++++-------
1 files changed, 39 insertions(+), 7 deletions(-)
diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java
index 0f21b7d..c0ce9a5 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/qc/oqc/MesQcOqcServiceImpl.java
@@ -3,9 +3,12 @@
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
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.iocoder.yudao.module.erp.api.sale.ErpSaleOrderApi;
import cn.iocoder.yudao.module.mes.controller.admin.qc.oqc.vo.MesQcOqcImportExcelVO;
import cn.iocoder.yudao.module.mes.controller.admin.qc.oqc.vo.MesQcOqcPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.qc.oqc.vo.MesQcOqcSaveReqVO;
@@ -34,6 +37,7 @@
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
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;
@@ -51,6 +55,7 @@
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 鍑鸿揣妫�楠屽崟锛圤QC锛� Service 瀹炵幇绫�
@@ -63,6 +68,9 @@
@Resource
private MesQcOqcMapper oqcMapper;
+
+ @Resource
+ private ErpSaleOrderApi saleOrderApi;
@Resource
private MesQcTemplateItemService templateItemService;
@@ -125,6 +133,10 @@
.setTemplateId(templateId)
.setSourceDocCode(sourceDocCode)
.setStatus(MesQcStatusEnum.DRAFT.getStatus());
+ if (createReqVO.getSourceLineId() != null) {
+ oqc.setReelNo(resolveSalesReelNo(productSalesLineService
+ .validateProductSalesLineExists(createReqVO.getSourceLineId())));
+ }
oqcMapper.insert(oqc);
// 3. 浠庢ā鏉挎寚鏍囪嚜鍔ㄧ敓鎴愭楠岃
@@ -135,7 +147,7 @@
@Override
public void updateOqc(MesQcOqcSaveReqVO updateReqVO) {
// 1.1 鏍￠獙瀛樺湪 + 鑽夌鐘舵��
- validateOqcStatusPrepare(updateReqVO.getId());
+ MesQcOqcDO existingOqc = validateOqcStatusPrepare(updateReqVO.getId());
// 1.2 鏍￠獙鏁版嵁
validateOqcSaveData(updateReqVO);
@@ -144,7 +156,12 @@
updateObj.setSourceDocType(null).setSourceDocId(null).setSourceLineId(null); // 涓嶅厑璁镐慨鏀规潵婧愬崟鎹�
updateObj.setTemplateId(null); // 涓嶅厑璁镐慨鏀规ā鏉�
updateObj.setItemId(null); // 涓嶅厑璁镐慨鏀圭墿鏂�
- oqcMapper.updateById(updateObj);
+ if (existingOqc.getSourceLineId() != null) updateObj.setReelNo(null); // 鏉ユ簮鐩樺彿淇濇寔蹇収
+ // 缂栬緫鏃跺厑璁告竻绌哄鎴凤紱瀹屾垚妫�楠岀瓑灞�閮ㄦ洿鏂颁粛淇濈暀鍘熷鎴枫��
+ updateObj.setClientId(null);
+ oqcMapper.update(updateObj, new LambdaUpdateWrapper<MesQcOqcDO>()
+ .eq(MesQcOqcDO::getId, updateReqVO.getId())
+ .set(MesQcOqcDO::getClientId, updateReqVO.getClientId()));
}
private void validateOqcSaveData(MesQcOqcSaveReqVO reqVO) {
@@ -304,9 +321,7 @@
@Override
public PageResult<MesQcOqcDO> getOqcPage(MesQcOqcPageReqVO pageReqVO) {
- // 鑾峰彇鐢ㄦ埛鏈夋潈闄愮殑瀹㈡埛 ID 鍒楄〃
- List<Long> permittedClientIds = customerApi.getPermittedCustomerIds();
- return oqcMapper.selectPage(pageReqVO, permittedClientIds);
+ return oqcMapper.selectPage(pageReqVO, (List<Long>) null);
}
@Override
@@ -379,11 +394,16 @@
oqc.setClientId(clientId);
oqc.setItemId(line.getItemId());
oqc.setBatchCode(line.getBatchCode());
+ oqc.setReelNo(resolveSalesReelNo(line));
oqc.setOutQuantity(line.getQuantity());
oqc.setCheckQuantity(BigDecimal.ZERO); // 寰呭～鍐�
oqc.setQualifiedQuantity(BigDecimal.ZERO); // 寰呭～鍐�
oqc.setUnqualifiedQuantity(BigDecimal.ZERO); // 寰呭～鍐�
- oqc.setOutDate(java.time.LocalDateTime.now());
+ MesWmProductSalesDO sales = productSalesService.getProductSales(salesId);
+ java.time.LocalDateTime businessDate = sales != null && sales.getSalesDate() != null
+ ? sales.getSalesDate() : java.time.LocalDateTime.now();
+ oqc.setOutDate(businessDate);
+ oqc.setInspectDate(businessDate);
oqc.setStatus(MesQcStatusEnum.DRAFT.getStatus());
oqcMapper.insert(oqc);
@@ -391,6 +411,12 @@
oqcLineService.createLinesFromTemplate(oqc.getId(), templateId);
return oqc.getId();
+ }
+
+ private String resolveSalesReelNo(MesWmProductSalesLineDO line) {
+ if (line == null || line.getSaleOrderItemId() == null) return null;
+ var item = saleOrderApi.getSaleOrderItem(line.getSaleOrderItemId()).getCheckedData();
+ return item == null ? null : item.getReelNo();
}
/**
@@ -413,10 +439,14 @@
@Override
@Transactional(rollbackFor = Exception.class)
+ @LogRecord(type = MES_QC_OQC_TYPE, subType = MES_QC_OQC_IMPORT_SUB_TYPE, bizNo = "0",
+ success = MES_QC_OQC_IMPORT_SUCCESS)
public MesQcImportRespVO importOqcList(List<MesQcOqcImportExcelVO> 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();
@@ -440,6 +470,8 @@
respVO.getFailureList().put(label, MesQcImportHelper.resolveImportErrorMessage(ex));
}
}
+ // 璁板綍瀵煎叆缁撴灉姹囨�伙紝渚� @LogRecord 鐨� success 鏂囨寮曠敤
+ OperateLogUtils.putImportSummary(respVO.getCreateList(), null, respVO.getFailureList());
return respVO;
}
@@ -476,7 +508,7 @@
reqVO.setName(row.getName().trim());
reqVO.setItemId(qcImportHelper.resolveItemId(row.getItemCode()));
Long clientId = qcImportHelper.resolveClientId(row.getClientName());
- qcImportHelper.validateClientPermission(clientId, row.getClientName().trim());
+ qcImportHelper.validateClientPermission(clientId, StrUtil.trimToEmpty(row.getClientName()));
reqVO.setClientId(clientId);
reqVO.setBatchCode(StrUtil.trimToNull(row.getBatchCode()));
reqVO.setTemplateId(qcImportHelper.resolveTemplateId(row.getTemplateName()));
--
Gitblit v1.9.3