f

zhaoqingang

2024-12-31 181aa6b29c7bba447107941051eebfaac9e7d7ea

 app/service/v2/initialize_data.py

@@ -2,7 +2,7 @@
import time
import os
from Log import logger
from app.config.const import DIFY
from app.config.const import DIFY, ENV_CONF_PATH
from app.models import MenuCapacityModel, WebMenuModel, GroupModel, RoleModel, DialogModel, UserModel, UserAppModel, \
    cipher_suite
from app.service.auth import UserAppDao
@@ -17,7 +17,7 @@

async def dialog_menu_sync(db):
    menu_list = []
    with open("env_conf/menu_conf.json", 'r', encoding='utf-8') as file:
    with open(os.path.join(ENV_CONF_PATH, "menu_conf.json") , 'r', encoding='utf-8') as file:
        # 加载JSON数据
        data = json.load(file)
        menu_list = data.get("data", [])
@@ -40,29 +40,35 @@


async def create_menu_sync(db):
    json_file_path = "env_conf/menu_conf.json"
    # json_file_path = "env_conf/menu_conf.json.template"
    json_file_path = os.path.join(ENV_CONF_PATH, "menu_conf.json.template")
    with open(json_file_path, 'r', encoding='utf-8') as file:
        json_data = json.load(file).get("data", [])
        for menu in json_data:
            menu['dialog'].clear()
        # for menu in json_data:
        #     menu['dialog'].clear()
    dialogs = db.query(DialogModel).all()

    dialog_dict = {}
    for dialog in dialogs:
        if dialog.name not in dialog_dict:
            dialog_dict[dialog.name] = []
        dialog_dict[dialog.name].append(dialog)

    for menu in json_data:
        if menu['title'] in dialog_dict:
            for dialog in dialog_dict[menu['title']]:
                new_dialog_item = {
        dialog_dict[dialog.name].append({
                    'id': dialog.id,
                    'chat_id': dialog.id,
                    'chat_type': '',
                    'agentType': dialog.dialog_type
                }
                menu['dialog'].append(new_dialog_item)
                })

    for menu in json_data:
        # if menu['title'] in dialog_dict:
        #     for dialog in dialog_dict[menu['title']]:
        #         new_dialog_item = {
        #             'id': dialog.id,
        #             'chat_id': dialog.id,
        #             'chat_type': '',
        #             'agentType': dialog.dialog_type
        #         }
        menu['dialog']= dialog_dict.get(menu['title'], [])
    json_data = {"data": json_data}
    new_file_name = f"menu_conf.json.template"
    new_file_path = os.path.join(os.path.dirname(json_file_path), new_file_name)
@@ -102,7 +108,7 @@

async def app_register_sync(db):
    app_dict = {}
    with open("env_conf/app_register_conf.json", 'r', encoding='utf-8') as file:
    with open(os.path.join(ENV_CONF_PATH, "app_register_conf.json"), 'r', encoding='utf-8') as file:
        # 加载JSON数据
        app_dict = json.load(file)
        try:
@@ -114,7 +120,7 @@

async def basic_agent_sync(db):
    agent_list = []
    with open("env_conf/default_agent_conf.json", 'r', encoding='utf-8') as file:
    with open(os.path.join(ENV_CONF_PATH, "default_agent_conf.json"), 'r', encoding='utf-8') as file:
        # 加载JSON数据
        agent_dict = json.load(file)
        agent_list = agent_dict.get("basic", [])