From c2053d7017625f270577bc0f6c523d04f52db6ea Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期五, 24 七月 2026 14:20:29 +0800
Subject: [PATCH] refactor(crm): 重构文件上传功能，替换原有的fileUrls字段为统一的StorageAttachmentApi
---
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/document/MesPdDocumentServiceImpl.java | 16 ++++++++++++++++
1 files changed, 16 insertions(+), 0 deletions(-)
diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/document/MesPdDocumentServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/document/MesPdDocumentServiceImpl.java
index c733e24..d1d8172 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/document/MesPdDocumentServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/document/MesPdDocumentServiceImpl.java
@@ -7,6 +7,7 @@
import cn.iocoder.yudao.module.mes.dal.dataobject.pd.document.MesPdDocumentDO;
import cn.iocoder.yudao.module.mes.dal.mysql.pd.document.MesPdDocumentMapper;
import cn.iocoder.yudao.module.mes.service.pd.project.MesPdProjectService;
+import cn.iocoder.yudao.module.system.api.storage.StorageAttachmentApi;
import jakarta.annotation.Resource;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
@@ -32,6 +33,8 @@
@Resource
@Lazy
private MesPdProjectService projectService;
+ @Resource
+ private StorageAttachmentApi storageAttachmentApi;
@Override
public Long createDocument(MesPdDocumentSaveReqVO createReqVO) {
@@ -40,6 +43,8 @@
// 鎻掑叆
MesPdDocumentDO document = BeanUtils.toBean(createReqVO, MesPdDocumentDO.class);
documentMapper.insert(document);
+ storageAttachmentApi.bindAttachments("file", "mes_pd_document",
+ document.getId(), createReqVO.getBlobIds());
return document.getId();
}
@@ -50,12 +55,19 @@
// 鏇存柊
MesPdDocumentDO updateObj = BeanUtils.toBean(updateReqVO, MesPdDocumentDO.class);
documentMapper.updateById(updateObj);
+ if (updateReqVO.getBlobIds() != null) {
+ storageAttachmentApi.deleteAttachmentsByRecord("mes_pd_document", updateReqVO.getId());
+ storageAttachmentApi.bindAttachments("file", "mes_pd_document",
+ updateReqVO.getId(), updateReqVO.getBlobIds());
+ }
}
@Override
public void deleteDocument(Long id) {
// 鏍￠獙瀛樺湪
validateDocumentExists(id);
+ // 鍒犻櫎闄勪欢
+ storageAttachmentApi.deleteAttachmentsByRecord("mes_pd_document", id);
// 鍒犻櫎
documentMapper.deleteById(id);
}
@@ -77,6 +89,10 @@
@Override
public void deleteByProjectId(Long projectId) {
+ List<MesPdDocumentDO> documents = documentMapper.selectListByProjectId(projectId);
+ for (MesPdDocumentDO document : documents) {
+ storageAttachmentApi.deleteAttachmentsByRecord("mes_pd_document", document.getId());
+ }
documentMapper.deleteByProjectId(projectId);
}
--
Gitblit v1.9.3