Merge branch 'main' of https://github.com/dataease/SQLBot

dataeaseShu · dataeaseShu · commit 262cf222a166 · 2025-07-31T16:10:20.000+08:00
diff --git a/backend/apps/datasource/api/datasource.py b/backend/apps/datasource/api/datasource.py
@@ -1,3 +1,4 @@
+import asyncio
 import hashlib
 import os
 import uuid
@@ -38,22 +39,34 @@ async def get_datasource(session: SessionDep, id: int):
 
 @router.post("/check")
 async def check(session: SessionDep, ds: CoreDatasource):
-    return check_status(session, ds, True)
+    def inner():
+        return check_status(session, ds, True)
+
+    return await asyncio.to_thread(inner)
 
 
 @router.post("/add", response_model=CoreDatasource)
 async def add(session: SessionDep, trans: Trans, user: CurrentUser, ds: CreateDatasource):
-    return create_ds(session, trans, user, ds)
+    def inner():
+        return create_ds(session, trans, user, ds)
+
+    return await asyncio.to_thread(inner)
 
 
 @router.post("/chooseTables/{id}")
 async def choose_tables(session: SessionDep, id: int, tables: List[CoreTable]):
-    chooseTables(session, id, tables)
+    def inner():
+        chooseTables(session, id, tables)
+
+    await asyncio.to_thread(inner)
 
 
 @router.post("/update", response_model=CoreDatasource)
 async def update(session: SessionDep, trans: Trans, user: CurrentUser, ds: CoreDatasource):
-    return update_ds(session, trans, user, ds)
+    def inner():
+        return update_ds(session, trans, user, ds)
+
+    return await asyncio.to_thread(inner)
 
 
 @router.post("/delete/{id}", response_model=CoreDatasource)
@@ -82,7 +95,10 @@ async def get_fields(session: SessionDep, id: int, table_name: str):
 
 @router.post("/execSql/{id}/{sql}")
 async def exec_sql(session: SessionDep, id: int, sql: str):
-    return execSql(session, id, sql)
+    def inner():
+        return execSql(session, id, sql)
+
+    return await asyncio.to_thread(inner)
 
 
 @router.post("/tableList/{id}")
@@ -111,17 +127,23 @@ async def edit_field(session: SessionDep, field: CoreField):
 
 
 @router.post("/previewData/{id}")
-async def edit_local(session: SessionDep, current_user: CurrentUser, id: int, data: TableObj):
-    try:
-        return preview(session, current_user, id, data)
-    except Exception as e:
-        SQLBotLogUtil.error(f"Preview failed: {e}")
-        raise HTTPException(status_code=500, detail=f'Preview Failed: {e.args}')
+async def preview_data(session: SessionDep, current_user: CurrentUser, id: int, data: TableObj):
+    def inner():
+        try:
+            return preview(session, current_user, id, data)
+        except Exception as e:
+            SQLBotLogUtil.error(f"Preview failed: {e}")
+            raise HTTPException(status_code=500, detail=f'Preview Failed: {e.args}')
+
+    return await asyncio.to_thread(inner)
 
 
 @router.post("/fieldEnum/{id}")
 async def field_enum(session: SessionDep, id: int):
-    return fieldEnum(session, id)
+    def inner():
+        return fieldEnum(session, id)
+
+    return await asyncio.to_thread(inner)
 
 
 @router.post("/uploadExcel")
@@ -136,32 +158,12 @@ async def upload_excel(session: SessionDep, file: UploadFile = File(...)):
     with open(save_path, "wb") as f:
         f.write(await file.read())
 
-    sheets = []
-    with get_data_engine() as conn:
-        if filename.endswith(".csv"):
-            df = pd.read_csv(save_path)
-            tableName = f"sheet1_{hashlib.sha256(uuid.uuid4().bytes).hexdigest()[:10]}"
-            sheets.append({"tableName": tableName, "tableComment": ""})
-            column_len = len(df.dtypes)
-            fields = []
-            for i in range(column_len):
-                # build fields
-                fields.append({"name": df.columns[i], "type": str(df.dtypes[i]), "relType": ""})
-            # create table
-            create_table(conn, tableName, fields)
-
-            data = [
-                {df.columns[i]: None if pd.isna(row[i]) else (int(row[i]) if "int" in str(df.dtypes[i]) else row[i])
-                 for i in range(len(row))}
-                for row in df.values
-            ]
-            # insert data
-            insert_data(conn, tableName, fields, data)
-        else:
-            df_sheets = pd.read_excel(save_path, sheet_name=None)
-            # build columns and data to insert db
-            for sheet_name, df in df_sheets.items():
-                tableName = f"{sheet_name}_{hashlib.sha256(uuid.uuid4().bytes).hexdigest()[:10]}"
+    def inner():
+        sheets = []
+        with get_data_engine() as conn:
+            if filename.endswith(".csv"):
+                df = pd.read_csv(save_path)
+                tableName = f"sheet1_{hashlib.sha256(uuid.uuid4().bytes).hexdigest()[:10]}"
                 sheets.append({"tableName": tableName, "tableComment": ""})
                 column_len = len(df.dtypes)
                 fields = []
@@ -178,6 +180,29 @@ async def upload_excel(session: SessionDep, file: UploadFile = File(...)):
                 ]
                 # insert data
                 insert_data(conn, tableName, fields, data)
-
-    os.remove(save_path)
-    return {"filename": filename, "sheets": sheets}
+            else:
+                df_sheets = pd.read_excel(save_path, sheet_name=None)
+                # build columns and data to insert db
+                for sheet_name, df in df_sheets.items():
+                    tableName = f"{sheet_name}_{hashlib.sha256(uuid.uuid4().bytes).hexdigest()[:10]}"
+                    sheets.append({"tableName": tableName, "tableComment": ""})
+                    column_len = len(df.dtypes)
+                    fields = []
+                    for i in range(column_len):
+                        # build fields
+                        fields.append({"name": df.columns[i], "type": str(df.dtypes[i]), "relType": ""})
+                    # create table
+                    create_table(conn, tableName, fields)
+
+                    data = [
+                        {df.columns[i]: None if pd.isna(row[i]) else (int(row[i]) if "int" in str(df.dtypes[i]) else row[i])
+                         for i in range(len(row))}
+                        for row in df.values
+                    ]
+                    # insert data
+                    insert_data(conn, tableName, fields, data)
+
+        os.remove(save_path)
+        return {"filename": filename, "sheets": sheets}
+
+    return await asyncio.to_thread(inner)
diff --git a/frontend/src/i18n/en.json b/frontend/src/i18n/en.json
@@ -146,7 +146,7 @@
     "local_excelcsv": "Local Excel/CSV",
     "pieces_in_total": "Showing {ms} records",
     "test_connection": "Test Connection",
-    "check": "check",
+    "check": "Check",
     "connection_success": "Connection Successful",
     "connection_failed": "Connection Failed, Please Check Configuration",
     "Search Datasource": "Search Datasource",
@@ -378,7 +378,7 @@
     "2_dashboards": "{msg} dashboards",
     "smart_data_centers": "{msg} smart data centers",
     "confirm_to_delete": "After the data source is deleted, the related questions can no longer be asked and the charts in the dashboard cannot be displayed normally. Please operate with caution!",
-    "id_account_to_add": "Search user ID/account to add",
+    "id_account_to_add": "Search name/account",
     "find_user": "Find user",
     "add_successfully": "Add successfully",
     "member_management": "Member management",
@@ -389,10 +389,10 @@
   "permission": {
     "search_rule_group": "Search rule group",
     "add_rule_group": "Add rule group",
-    "permission_rule": "Permission rule",
+    "permission_rule": "Permission rules",
     "restricted_user": "Restricted user",
-    "set_rule": "Set rule",
-    "set_user": "Set user",
+    "set_rule": "Setup rule",
+    "set_user": "Setup user",
     "2": "{msg}",
     "238_people": "{msg} people",
     "no_permission_rule": "No permission rule",
@@ -406,8 +406,8 @@
     "select_restricted_user": "Select restricted user",
     "rule_group_1": "Delete rule group: {msg}?",
     "no_rule": "No rule",
-    "row_permission": "Row permission",
-    "column_permission": "Column permission",
+    "row_permission": "Row perm",
+    "column_permission": "Column perm",
     "rule_rule_1": "Delete rule: {msg}?",
     "no_content": "No content",
     "edit_column_permission": "Edit column permission",
@@ -457,14 +457,14 @@
     "support_is_required": "Applicable to scenarios where data verification is not required, just embed the embedded code into the third party code, no additional support is required",
     "data_permissions_etc": "Applicable to scenarios where data verification is required, requiring the third party system to provide data source interface, user interface data permissions, etc.",
     "create_basic_application": "Create basic application",
-    "set_data_source": "Set data source",
+    "set_data_source": "Data source settings",
     "basic_information": "Basic information",
     "application_name": "Application name",
     "application_description": "Application description",
     "cross_domain_settings": "Cross-domain settings",
     "third_party_address": "Please enter the embedded third party address",
-    "set_to_private": "Set to private",
-    "set_to_public": "Set to public",
+    "set_to_private": "Set as private",
+    "set_to_public": "Set as public",
     "public": "Public",
     "private": "Private",
     "creating_advanced_applications": "Creating Advanced Applications",
@@ -508,10 +508,10 @@
     "type": "Chart Type",
     "chart_type": {
       "table": "Detail Table",
-      "bar": "Bar Chart",
-      "column": "Column Chart",
-      "line": "Line Chart",
-      "pie": "Pie Chart"
+      "bar": "Bar",
+      "column": "Column",
+      "line": "Line",
+      "pie": "Pie"
     },
     "show_sql": "View SQL",
     "export_to": "Export As",
