From 02bdd456f4739d46a8c6c9a6c470613695e3ecd0 Mon Sep 17 00:00:00 2001
From: yuance <182865460@qq.com>
Date: Tue, 6 Jan 2026 17:15:59 +0800
Subject: [PATCH] =?UTF-8?q?=E7=9F=A5=E8=AF=86=E5=BA=93=E6=96=87=E6=A1=A3?=
 =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E5=90=8C=E6=97=B6=E5=A4=87=E4=BB=BD=E8=87=B3?=
 =?UTF-8?q?OSS=E6=9C=8D=E5=8A=A1=E5=99=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/AiCloudFileServiceImpl.java  |  8 +++++++
 .../system/controller/FileController.java     | 22 +++++++++++++++++++
 2 files changed, 30 insertions(+)

diff --git a/src/main/java/com/gxwebsoft/ai/service/impl/AiCloudFileServiceImpl.java b/src/main/java/com/gxwebsoft/ai/service/impl/AiCloudFileServiceImpl.java
index 0ae1881..ded695f 100644
--- a/src/main/java/com/gxwebsoft/ai/service/impl/AiCloudFileServiceImpl.java
+++ b/src/main/java/com/gxwebsoft/ai/service/impl/AiCloudFileServiceImpl.java
@@ -6,6 +6,8 @@ import com.gxwebsoft.ai.config.KnowledgeBaseConfig;
 import com.gxwebsoft.ai.factory.KnowledgeBaseClientFactory;
 import com.gxwebsoft.ai.util.AiCloudDataCenterUtil;
 import com.gxwebsoft.ai.util.AiCloudKnowledgeBaseUtil;
+import com.gxwebsoft.common.system.controller.FileController;
+import com.gxwebsoft.common.system.entity.FileRecord;
 import com.gxwebsoft.common.system.entity.User;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
@@ -56,6 +58,9 @@ public class AiCloudFileServiceImpl extends ServiceImpl<AiCloudFileMapper, AiClo
     @Resource
     private KnowledgeBaseService knowledgeBaseService;
 
+    @Resource
+    private FileController fileController;
+    
     @Override
     public PageResult<AiCloudFile> pageRel(AiCloudFileParam param) {
         PageParam<AiCloudFile, AiCloudFileParam> page = new PageParam<>(param);
@@ -92,6 +97,8 @@ public class AiCloudFileServiceImpl extends ServiceImpl<AiCloudFileMapper, AiClo
                 AddFileResponse addFileResponse = AiCloudDataCenterUtil.uploadFile(client, workspaceId, categoryId, file);
                 String fileId = addFileResponse.getBody().getData().getFileId();
                 
+                FileRecord fileRecord = fileController.upload(file, loginUser.getTenantId());
+                
                 // 保存文件信息到数据库
                 AiCloudFile aiCloudFile = new AiCloudFile();
                 aiCloudFile.setDocId(docId);
@@ -100,6 +107,7 @@ public class AiCloudFileServiceImpl extends ServiceImpl<AiCloudFileMapper, AiClo
                 aiCloudFile.setFileType(getFileExtension(file.getOriginalFilename()));
                 aiCloudFile.setFileExt(getFileExtension(file.getOriginalFilename()));
                 aiCloudFile.setFileId(fileId);
+                aiCloudFile.setFileUrl(fileRecord.getDownloadUrl());
                 aiCloudFile.setUploadTime(LocalDateTime.now());
                 aiCloudFile.setWorkspaceId(workspaceId);
                 
diff --git a/src/main/java/com/gxwebsoft/common/system/controller/FileController.java b/src/main/java/com/gxwebsoft/common/system/controller/FileController.java
index 5d800b5..a6dc268 100644
--- a/src/main/java/com/gxwebsoft/common/system/controller/FileController.java
+++ b/src/main/java/com/gxwebsoft/common/system/controller/FileController.java
@@ -1,6 +1,9 @@
 package com.gxwebsoft.common.system.controller;
 
+import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.hutool.http.HttpRequest;
+
 import com.alibaba.fastjson.JSONObject;
 import com.gxwebsoft.common.core.annotation.OperationLog;
 import com.gxwebsoft.common.core.config.ConfigProperties;
@@ -316,4 +319,23 @@ public class FileController extends BaseController {
       return fail("修改失败");
     }
 
+    public FileRecord upload(MultipartFile file, Integer tenantId) {
+    	FileRecord fileRecord = new FileRecord();
+    	if (file == null || file.isEmpty()) {
+    		return fileRecord;
+    	}
+        try {
+        	String requestURL = config.getServerUrl() + "/oss/upload";
+        	String response = HttpRequest.post(requestURL)
+        			.header("Tenantid", tenantId != null ? tenantId.toString() : getTenantId().toString())
+        			.form("file", file.getBytes(), file.getOriginalFilename())
+        			.execute()
+        			.body();
+        	JSONObject data = JSONObject.parseObject(response).getJSONObject("data");
+        	fileRecord = data != null ? BeanUtil.copyProperties(data, FileRecord.class) : fileRecord;
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+        return fileRecord;
+    }
 }