From e702269b1154c68aa357a3c63e2ed9b1d568b64c Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期一, 22 九月 2025 14:25:32 +0800
Subject: [PATCH] 文件下发，放入OSS备查
---
blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/MdmProgramImportService.java | 15 +++++++++------
1 files changed, 9 insertions(+), 6 deletions(-)
diff --git a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/MdmProgramImportService.java b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/MdmProgramImportService.java
index 25e96d7..4fc6fa8 100644
--- a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/MdmProgramImportService.java
+++ b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/MdmProgramImportService.java
@@ -7,6 +7,8 @@
import org.apache.commons.lang3.StringUtils;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.mp.base.BizServiceImpl;
+import org.springblade.core.oss.OssTemplate;
+import org.springblade.core.oss.model.BladeFile;
import org.springblade.core.redis.cache.BladeRedis;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.utils.Func;
@@ -40,19 +42,16 @@
@Slf4j
@Service
public class MdmProgramImportService extends BizServiceImpl<NcProgramExchangeMapper, NcProgramExchange> {
-
@Autowired
private BladeRedis bladeRedis;
-
@Autowired
private ProgramAnnotationService programAnnotationService;
-
@Autowired
private MachineService machineService;
-
@Autowired
private FileSendRecordService fileSendRecordService;
-
+ @Autowired
+ private OssTemplate ossTemplate;
private String getFileKey(){
return "mdmgkwimpfile-"+ AuthUtil.getUserId();
}
@@ -292,7 +291,6 @@
/**
* 鍏ュ簱mdm娑夊瘑缃戞枃浠�
* @param ids id鍒楄〃閫楀彿鍒嗛殧
- * @return
*/
public void mdmFileAccept(String ids) throws IOException {
@@ -320,6 +318,11 @@
Path destPath = Paths.get(destFileFull);
record.setMachineCode(vo.getMachineCode());
record.setFileSize(Files.size(destPath));
+
+ try(InputStream inputStream = new FileInputStream(destFile)){
+ BladeFile bFile = ossTemplate.putFile(record.getName(), inputStream);
+ record.setOssName(bFile.getName());
+ }
fileSendRecordService.save(record);
break;
}
--
Gitblit v1.9.3