From 51527a6e817a6ba73b29b07e94a7e879a86f8eaf Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期三, 06 三月 2024 16:29:08 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ruoyi-modules/ruoyi-file/src/main/java/com/ruoyi/file/controller/SysFileController.java | 54 ++++++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 50 insertions(+), 4 deletions(-)
diff --git a/ruoyi-modules/ruoyi-file/src/main/java/com/ruoyi/file/controller/SysFileController.java b/ruoyi-modules/ruoyi-file/src/main/java/com/ruoyi/file/controller/SysFileController.java
index 345b2ad..1008e47 100644
--- a/ruoyi-modules/ruoyi-file/src/main/java/com/ruoyi/file/controller/SysFileController.java
+++ b/ruoyi-modules/ruoyi-file/src/main/java/com/ruoyi/file/controller/SysFileController.java
@@ -4,7 +4,9 @@
import com.ruoyi.common.core.utils.file.FileUtils;
import com.ruoyi.file.service.ISysFileService;
import com.ruoyi.file.utils.OBSUploadUtils;
+import com.ruoyi.system.api.domain.poji.config.FileRecord;
import com.ruoyi.system.api.domain.poji.sys.SysFile;
+import com.ruoyi.system.api.service.RemoteConfigService;
import com.wechat.pay.contrib.apache.httpclient.WechatPayHttpClientBuilder;
import com.wechat.pay.contrib.apache.httpclient.WechatPayUploadHttpPost;
import com.wechat.pay.contrib.apache.httpclient.auth.AutoUpdateCertificatesVerifier;
@@ -20,17 +22,18 @@
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestPart;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
+import javax.annotation.Resource;
import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.net.URI;
import java.security.PrivateKey;
import java.util.ArrayList;
+import java.util.Date;
import java.util.List;
/**
@@ -45,15 +48,18 @@
private final static String PRIVATE_KEY = "";
- private final static String MCH_ID = "";
+ private final static String MCH_ID = "1631381314";
private final static String MCH_SERIAL_NO = "";
- private final static String API_V3_KEY = "";
+ private final static String API_V3_KEY = "J8v9JDHKJYDHW9bdk30o2bdjy6z9mn1A";
- @Autowired
+ @Resource
private ISysFileService sysFileService;
+
+ @Resource
+ private RemoteConfigService remoteConfigService;
/**
* 文件上传请求
@@ -64,10 +70,22 @@
try
{
// 上传并返回访问地址
+ String fileName = file.getOriginalFilename();
+ String prefix = fileName.substring(fileName.lastIndexOf("."));
+ long fileSize = file.getSize();
String url = sysFileService.uploadFile(file);
SysFile sysFile = new SysFile();
sysFile.setName(FileUtils.getName(url));
sysFile.setUrl(url);
+ //创建上传记录
+ FileRecord fileRecord = new FileRecord();
+ fileRecord.setFileName(fileName);
+ fileRecord.setFilePath(url);
+ fileRecord.setUploadType(2);
+ fileRecord.setUploadTime(new Date());
+ fileRecord.setFileSize(fileSize);
+ fileRecord.setFileType(prefix);
+ remoteConfigService.createFileRecord(fileRecord);
return R.ok(sysFile);
}
catch (Exception e)
@@ -86,7 +104,19 @@
try
{
// 上传并返回访问地址
+ String fileName = file.getOriginalFilename();
+ String prefix = fileName.substring(fileName.lastIndexOf("."));
+ long fileSize = file.getSize();
String url = OBSUploadUtils.uploadFile(file);
+ //创建上传记录
+ FileRecord fileRecord = new FileRecord();
+ fileRecord.setFileName(fileName);
+ fileRecord.setFilePath(url);
+ fileRecord.setUploadType(2);
+ fileRecord.setUploadTime(new Date());
+ fileRecord.setFileSize(fileSize);
+ fileRecord.setFileType(prefix);
+ remoteConfigService.createFileRecord(fileRecord);
return R.ok(url);
}
catch (Exception e)
@@ -99,11 +129,27 @@
@PostMapping("batchUploadOSS")
public R<List<String>> batchUploadOSS(@RequestPart("file") MultipartFile[] files) {
List<String> urls = new ArrayList<>();
+ String fileName;
+ String prefix;
+ long fileSize;
+ FileRecord fileRecord;
for (MultipartFile file : files) {
try {
+ fileName = file.getOriginalFilename();
+ prefix = fileName.substring(fileName.lastIndexOf("."));
+ fileSize = file.getSize();
// 上传并返回访问地址
String url = OBSUploadUtils.uploadFile(file);
urls.add(url);
+ //创建上传记录
+ fileRecord = new FileRecord();
+ fileRecord.setFileName(fileName);
+ fileRecord.setFilePath(url);
+ fileRecord.setUploadType(2);
+ fileRecord.setUploadTime(new Date());
+ fileRecord.setFileSize(fileSize);
+ fileRecord.setFileType(prefix);
+ remoteConfigService.createFileRecord(fileRecord);
} catch (Exception e) {
log.error("上传文件失败", e);
return R.fail(e.getMessage());
--
Gitblit v1.7.1