fix(backend): mysql定点构造新增query_backup_log_from_handler接口查询备份记录 TencentBlueKing#14188

# Reviewed, transaction id: 64147

Author: v_ycggyao

dbm-ui/backend/db_package/admin.py

@@ -15,6 +15,6 @@
 
 @admin.register(models.Package)
 class PackageAdmin(admin.ModelAdmin):
-    list_display = [field.name for field in models.Package._meta.get_fields()]
+    list_display = [field.name for field in models.Package._meta.concrete_fields]
     search_fields = ("name", "version", "path", "md5")
     list_filter = ("db_type", "pkg_type", "mode")

dbm-ui/backend/db_report/mysql_backup/handers.py

@@ -243,6 +243,19 @@ def get_tendb_priv_backup_info(self, latest_time: datetime = None) -> Dict[str,
             logger.info("{} only part of storage instance get privilege file".format(self.cluster.id))
         return backup_priv_info
 
+    def get_tendbha_rollback_backup_info(self, latest_time: datetime = None):
+        """
+        tendbha 获取指定集群的备份信息，根据备份时间排序
+        @param latest_time: 查询备份最迟时间
+        @param limit_one: 是否限制只返回一条备份记录
+        @return: 返回集群的各个数据节点的备份记录，且backup_id必须一致
+        """
+        if self.backup_source == MySQLBackupSource.LOCAL:
+            backup_infos = self.get_local_backup_infos(latest_time=latest_time)
+        else:
+            backup_infos = self.get_backup_infos(latest_time)
+        return backup_infos
+
     def get_spider_rollback_backup_info(self, latest_time: datetime = None, limit_one: bool = False) -> Dict[str, Any]:
         """
         tendbCluster 查询当前集群集群各个remote节点点的最新一份远程备份,且要求所有的分片backup_id是一致的。

dbm-ui/backend/db_services/mysql/fixpoint_rollback/views.py

@@ -50,7 +50,9 @@ class FixPointRollbackViewSet(viewsets.SystemViewSet):
     default_permission_class = [DBManagePermission()]
 
     @common_swagger_auto_schema(
-        operation_summary=_("通过日志平台获取集群备份记录"),
+        operation_summary=_(
+            "通过日志平台获取集群备份记录 # TODO: 当前api已废弃，替换为query_backup_log_from_handler接口(backup_source传remote)"
+        ),
         query_serializer=BackupLogSerializer(),
         responses={
             status.HTTP_200_OK: BackupLogTendbResponseSerializer(),
@@ -70,7 +72,7 @@ def query_backup_log_from_bklog(self, requests, *args, **kwargs):
         return Response(logs)
 
     @common_swagger_auto_schema(
-        operation_summary=_("查询集群的本地备份记录"),
+        operation_summary=_("查询集群的本地备份记录 # TODO: 当前api已废弃，替换为query_backup_log_from_handler接口(backup_source传local)"),
         query_serializer=BackupLogSerializer(),
         responses={status.HTTP_200_OK: BackupLocalLogMySQLResponseSerializer()},
         tags=[SWAGGER_TAG],
@@ -82,7 +84,7 @@ def query_backup_log_from_local(self, requests, *args, **kwargs):
         return Response(logs)
 
     @common_swagger_auto_schema(
-        operation_summary=_("查询小于回档时间点最近的备份记录"),
+        operation_summary=_("查询小于回档时间点最近的备份记录 # TODO: 部分接口还在使用， 新需求替换为latest_time_backup_log接口"),
         query_serializer=BackupLogRollbackTimeSerializer(),
         responses={
             status.HTTP_200_OK: BackupLogRollbackTimeTendbResponseSerializer(),
@@ -101,6 +103,33 @@ def query_latest_backup_log(self, requests, *args, **kwargs):
             )
         )
 
+    @common_swagger_auto_schema(
+        operation_summary=_("通过handler获取集群备份记录"),
+        query_serializer=FilterBackupLogSerializer(),
+        responses={
+            status.HTTP_200_OK: BackupLogTendbResponseSerializer(),
+            status.HTTP_202_ACCEPTED: BackupLogMySQLResponseSerializer(),
+        },
+        tags=[SWAGGER_TAG],
+    )
+    @action(methods=["GET"], detail=False, serializer_class=FilterBackupLogSerializer)
+    def query_backup_log_from_handler(self, requests, *args, **kwargs):
+        validated_data = self.params_validate(self.get_serializer_class())
+        cluster_id = validated_data["cluster_id"]
+        cluster = Cluster.objects.get(id=cluster_id)
+        db_type = ClusterType.cluster_type_to_db_type(cluster.cluster_type)
+        latest_time = validated_data.pop("latest_time", None)
+        # 初始化备份文件对象
+        handler = MySQLBackupHandler(**validated_data)
+
+        # 获取备份结果
+        result = {}
+        if db_type == DBType.MySQL.value:
+            result = handler.get_tendbha_rollback_backup_info(latest_time)
+        elif db_type == DBType.TenDBCluster.value:
+            result = handler.get_spider_rollback_backup_info(latest_time)
+        return Response(result)
+
     @common_swagger_auto_schema(
         operation_summary=_("通过获取集群最迟时间的最新一条备份记录"),
         query_serializer=FilterBackupLogSerializer(),

dbm-ui/backend/ticket/builders/mysql/mysql_fixpoint_rollback.py

@@ -47,8 +47,7 @@ class FixPointRollbackSerializer(serializers.Serializer):
         tables = serializers.ListField(help_text=_("目标table列表"), child=DBTableField())
         tables_ignore = serializers.ListField(help_text=_("忽略table列表"), child=DBTableField())
 
-        # display fields
-        affect_db = serializers.ListField(
+        affect_database_list = serializers.ListField(
             help_text=_("影响的DB"), child=serializers.CharField(), allow_null=True, required=False
         )