feat(backend): mysql/tendb的webconsole添加时区和字符集查询 #11233

Author: huangwentai-wendel

dbm-ui/backend/db_services/dbbase/serializers.py

@@ -20,7 +20,9 @@
 from backend.db_meta.models import Cluster
 from backend.db_services.dbbase.constants import ResourceType
 from backend.db_services.dbbase.resources.serializers import ListClusterEntriesSLZ, ListResourceSLZ
+from backend.db_services.dbbase.utils import get_local_charset
 from backend.db_services.ipchooser.query.resource import ResourceQueryHelper
+from backend.db_services.mysql.sql_import.constants import SQLCharset
 from backend.db_services.redis.resources.redis_cluster.query import RedisListRetrieveResource
 from backend.dbm_init.constants import CC_APP_ABBR_ATTR
 from backend.ticket.builders.common.field import DBTimezoneField
@@ -191,8 +193,10 @@ class Meta:
 
 class WebConsoleSerializer(serializers.Serializer):
     class OptionsSerializer(serializers.Serializer):
-        time_zone = serializers.CharField(help_text=_("时区"), default="utc+8")
-        character_set = serializers.CharField(help_text=_("字符集"), default="default")
+        timezone = serializers.ChoiceField(
+            help_text=_("时区"), choices=SQLCharset.get_choices(), default=SQLCharset.DEFAULT
+        )
+        charset = serializers.CharField(help_text=_("字符集"), default=get_local_charset())
 
     cluster_id = serializers.IntegerField(help_text=_("集群ID"))
     cmd = serializers.CharField(help_text=_("sql语句"))

dbm-ui/backend/db_services/dbbase/utils.py

@@ -0,0 +1,25 @@
+# -*- coding: utf-8 -*-Add commentMore actions
+"""
+TencentBlueKing is pleased to support the open source community by making 蓝鲸智云-DB管理系统(BlueKing-BK-DBM) available.
+Copyright (C) 2017-2023 THL A29 Limited, a Tencent company. All rights reserved.
+Licensed under the MIT License (the "License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at https://opensource.org/licenses/MIT
+Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+specific language governing permissions and limitations under the License.
+"""
+from datetime import datetime, timezone
+
+
+def get_local_charset():
+
+    now = datetime.now(timezone.utc).astimezone()
+    # 提取时区偏移并格式化
+    offset = now.utcoffset()
+    total_seconds = offset.total_seconds()
+    hours = int(total_seconds // 3600)
+    minutes = int(abs(total_seconds) % 3600 // 60)
+
+    # 格式化为"+HH:MM"（确保小时和分钟都是两位数）
+    formatted_offset = f"{'+' if hours >= 0 else '-'}{abs(hours):02d}:{minutes:02d}"
+    return formatted_offset

dbm-ui/backend/db_services/dbbase/views.py

@@ -61,9 +61,11 @@
     WebConsoleResponseSerializer,
     WebConsoleSerializer,
 )
+from backend.db_services.dbbase.utils import get_local_charset
 from backend.db_services.ipchooser.query.resource import ResourceQueryHelper
 from backend.db_services.mongodb.cluster.handlers import ClusterServiceHandler as MongoClusterServiceHandler
 from backend.db_services.mysql.remote_service.handlers import RemoteServiceHandler
+from backend.db_services.mysql.sql_import.constants import SQLCharset
 from backend.db_services.redis.toolbox.handlers import ToolboxHandler
 from backend.iam_app.handlers.drf_perm.base import DBManagePermission
 from backend.iam_app.handlers.drf_perm.cluster import (
@@ -332,10 +334,10 @@ def webconsole(self, request):
 
         # mysql / tendbcluster
         if db_type in [DBType.MySQL, DBType.TenDBCluster]:
-            if not data.get("options", {}).get("time_zone"):
-                data["options"]["time_zone"] = "+8:00"
-            if not data.get("options", {}).get("character_set"):
-                data["options"]["character_set"] = "default"
+            if not data.get("options", {}).get("timezone"):
+                data["options"]["timezone"] = get_local_charset()
+            if not data.get("options", {}).get("charset"):
+                data["options"]["charset"] = SQLCharset.DEFAULT.value
             data = RemoteServiceHandler(bk_biz_id=cluster.bk_biz_id).webconsole_rpc(**data)
         # redis
         elif db_type in ClusterType.redis_cluster_types():