From 9683aeeafa2f1067ef061b34124a1c362df07e5e Mon Sep 17 00:00:00 2001
From: zhaoqingang <zhaoqg0118@163.com>
Date: 星期四, 03 四月 2025 14:10:13 +0800
Subject: [PATCH] rg配置修改

---
 app/api/files.py |   27 +++++++++++++++++++++++++--
 1 files changed, 25 insertions(+), 2 deletions(-)

diff --git a/app/api/files.py b/app/api/files.py
index 0592b4b..c6c05c5 100644
--- a/app/api/files.py
+++ b/app/api/files.py
@@ -1,4 +1,5 @@
 import io
+import time
 from typing import Optional, List
 
 import requests
@@ -19,7 +20,7 @@
 from app.models.user_model import UserModel
 from app.service.basic import BasicService
 from app.service.bisheng import BishengService
-from app.service.files import read_file
+from app.service.files import read_file, service_chat_message, generate_word_document
 from app.service.v2.api_token import DfTokenDao
 from app.service.difyService import DifyService
 from app.service.ragflow import RagflowService
@@ -137,6 +138,8 @@
                     return Response(code=400, msg=str(e))
                 try:
                     file_upload = await dify_service.upload(token, f.filename, file_content, current_user.id)
+                    if not file_upload:
+                        raise HTTPException(status_code=500, detail="涓婁紶鏂囦欢鍑洪敊")
                     try:
                         tokens = await read_file(file_content, f.filename, f.content_type)
                         file_upload["tokens"] = tokens
@@ -242,4 +245,24 @@
                     break
                 yield data
 
-    return StreamingResponse(generate(), media_type="application/octet-stream")
\ No newline at end of file
+    return StreamingResponse(generate(), media_type="application/octet-stream")
+
+
+@router.get("/message/{message_id}/download", response_model=Response)
+async def chat_message_generate_docx(message_id: str, db=Depends(get_db)):
+    title, content = await service_chat_message(db, message_id)
+    if title:
+        print(title)
+        # 鍒涘缓 Word 鏂囨。
+        doc = await generate_word_document(title, content)
+
+        # 淇濆瓨鍒板唴瀛樼紦鍐插尯
+        buffer = io.BytesIO()
+        doc.save(buffer)
+        buffer.seek(0)
+        # print(2323232)
+        # 杩斿洖鏂囦欢娴�
+        return StreamingResponse(buffer,
+                                 media_type="application/vnd.openxmlformats-officedocument.wordprocessingml.document",
+                                 headers={"Content-Disposition": f"attachment; filename={int(time.time()*1000)}.docx"})
+    raise HTTPException(status_code=400, detail="Failed to generate Word document")

--
Gitblit v1.8.0