tmp

zhaoqingang

2025-02-20 6efaa41969ab89c1e1bd468b1b895f6689b7f70d

tmp

 app/service/v2/app_driver/chat_workflow.py

@@ -28,22 +28,19 @@
                print(e)

    @staticmethod
    async def request_data(query: str, conversation_id: str, user:str, chat_data: ChatData) -> dict:
        inputs = []
        files = []
        if hasattr(chat_data,  "inputs"):
    async def request_data(query: str, conversation_id: str, user: str, chat_data: ChatData) -> dict:
        data = {"response_mode": "streaming",
                "conversation_id": conversation_id,
                "user": user}
        inputs = {}
        # files = []
        if hasattr(chat_data, "inputs"):
            inputs = chat_data.inputs
        if hasattr(chat_data,  "files"):
        if hasattr(chat_data, "files"):
            files = chat_data.files

        return {
            "inputs":inputs,
            "query": query,
            "response_mode": "streaming",
            "conversation_id": conversation_id,
            "user": user,
            "files": files
        }
            data["files"] = files
        data["inputs"] = inputs
        return data


if __name__ == "__main__":
@@ -54,7 +51,7 @@
        url = f"{base_url}/v1/chat-messages"
        chat = ChatAgent()
        data = {
            "inputs":{},
            "inputs": {},
            "query": "你好，你能做什么？",
            "response_mode": "streaming",
            "conversation_id": "",

 app/service/v2/chat.py

@@ -142,7 +142,6 @@
    files = []
    node_list = []
    token = await get_chat_token(db, chat_id)

    chat, url = await get_chat_object(mode)
    if hasattr(chat_data, "query"):
        query = chat_data.query

 main.py

@@ -29,7 +29,7 @@
from app.task.fetch_agent import sync_agents, initialize_agents, sync_agents_v2, sync_knowledge, \
    sync_resources_from_json
from app.init_config.init_run_data import sync_default_data
from app.task.sync_account_token import sync_token, start_sync_token_task
from app.task.sync_account_token import start_sync_token_task

init_db()

@@ -47,7 +47,7 @@
    sync_agents_v2()
    sync_knowledge()
    sync_resources_from_json()
    start_sync_token_task()
    # start_sync_token_task()
    yield
    # 在应用关闭时执行清理操作（如果需要）
    pass