fix(backend): 全站搜索优化 TencentBlueKing#8587

# Reviewed, transaction id: 26691

dbm-ui/backend/db_services/quick_search/constants.py

@@ -14,8 +14,8 @@
 
 
 class ResourceType(str, StructuredEnum):
-    CLUSTER_NAME = EnumField("cluster_name", _("集群名"))
-    CLUSTER_DOMAIN = EnumField("cluster_domain", _("集群域名"))
+    # CLUSTER_NAME = EnumField("cluster_name", _("集群名"))
+    entry = EnumField("entry", _("访问入口"))
     INSTANCE = EnumField("instance", _("实例"))
     TICKET = EnumField("ticket", _("单号"))
     TASK = EnumField("task", _("任务"))

dbm-ui/backend/db_services/quick_search/handlers.py

@@ -12,8 +12,9 @@
 from django.db.models.functions import Concat
 from django.forms import model_to_dict
 
+from backend.configuration.models import DBAdministrator
 from backend.db_meta.enums import ClusterType
-from backend.db_meta.models import Cluster, Machine, ProxyInstance, StorageInstance
+from backend.db_meta.models import Cluster, ClusterEntry, Machine, ProxyInstance, StorageInstance
 from backend.db_services.dbresource.handlers import ResourceHandler
 from backend.db_services.quick_search import constants
 from backend.db_services.quick_search.constants import FilterType, ResourceType
@@ -134,17 +135,50 @@ def common_filter(self, objs, return_type="list", fields=None, limit=None):
         limit = limit or self.limit
         return list(objs[:limit].values(*fields))
 
+    def supplementary_fields(self, objects_list: list):
+        """补充 主dba和db类型字段"""
+        for object in objects_list:
+            # 将 db_type 补充到对象中
+            object["db_type"] = ClusterType.cluster_type_to_db_type(object["cluster_type"])
+
+            # 获取dba人员  # DBA 人员获取优先级： 业务 > 平台 > 默认空值
+            dba_list = DBAdministrator.list_biz_admins(bk_biz_id=object["bk_biz_id"])
+            dba_content = next((dba for dba in dba_list if dba["db_type"] == object["db_type"]))
+            object["dba"] = dba_content["users"][0] if dba_content["users"] else None
+            object["is_show_dba"] = dba_content["is_show"]
+        return objects_list
+
     def filter_cluster_name(self, keyword_list: list):
         """过滤集群名"""
         qs = self.generate_filter_for_str("name", keyword_list)
         objs = Cluster.objects.filter(qs)
         return self.common_filter(objs)
 
-    def filter_cluster_domain(self, keyword_list: list):
-        """过滤集群域名"""
-        qs = self.generate_filter_for_domain("immute_domain", keyword_list)
-        objs = Cluster.objects.filter(qs)
-        return self.common_filter(objs)
+    def filter_entry(self, keyword_list: list):
+        """过滤集群访问入口"""
+        qs = self.generate_filter_for_domain("entry", keyword_list)
+
+        if self.bk_biz_ids:
+            qs = Q(bk_biz_id__in=self.bk_biz_ids) & qs
+
+        if self.db_types:
+            qs = Q(cluster_type__in=self.cluster_types) & qs
+
+        common_fields = {
+            "cluster_type": F("cluster__cluster_type"),
+            "immute_domain": F("cluster__immute_domain"),
+            "bk_biz_id": F("cluster__bk_biz_id"),
+        }
+        fields = [
+            "id",
+            "cluster_entry_type",
+            "entry",
+            "cluster_id",
+            "role",
+            *common_fields.keys(),
+        ]
+        objs = ClusterEntry.objects.filter(qs).select_related("cluster").annotate(**common_fields)
+        return self.supplementary_fields(list(objs[: self.limit].values(*fields)))
 
     def filter_instance(self, keyword_list: list):
         """过滤实例"""
@@ -192,7 +226,9 @@ def filter_instance(self, keyword_list: list):
             "phase",
             *common_fields.keys(),
         ]
-        return list(storage_objs[: self.limit].values(*fields)) + list(proxy_objs[: self.limit].values(*fields))
+        return self.supplementary_fields(list(storage_objs[: self.limit].values(*fields))) + self.supplementary_fields(
+            list(proxy_objs[: self.limit].values(*fields))
+        )
 
     def filter_task(self, keyword_list: list):
         """过滤任务"""

dbm-ui/backend/tests/db_services/quick_search/test_quick_search.py

@@ -52,30 +52,30 @@ def _request_quick_search(self, resource_list_mock, query):
         response = quick_search_viewset(request)
         return response
 
-    @pytest.mark.parametrize("query", [QUICK_SEARCH_CONTAINS_PARAMS, QUICK_SEARCH_EXACT_PARAMS])
-    @patch.object(DBResourceApi, "resource_list")
-    def test_quick_search_for_cluster_name(self, resource_list_mock, query, init_cluster):
-        """
-        测试搜索集群名称
-        """
-        target_value = init_cluster.name
-        query["keyword"] = self._get_keyword(query, target_value)
-        response = self._request_quick_search(resource_list_mock, query)
-        assert response.status_code == 200
-        result = [cluster.get("id") for cluster in response.data.get("cluster_name")]
-        assert init_cluster.id in result
+    # @pytest.mark.parametrize("query", [QUICK_SEARCH_CONTAINS_PARAMS, QUICK_SEARCH_EXACT_PARAMS])
+    # @patch.object(DBResourceApi, "resource_list")
+    # def test_quick_search_for_cluster_name(self, resource_list_mock, query, init_cluster):
+    #     """
+    #     测试搜索集群名称
+    #     """
+    #     target_value = init_cluster.name
+    #     query["keyword"] = self._get_keyword(query, target_value)
+    #     response = self._request_quick_search(resource_list_mock, query)
+    #     assert response.status_code == 200
+    #     result = [cluster.get("id") for cluster in response.data.get("cluster_name")]
+    #     assert init_cluster.id in result
 
     @pytest.mark.parametrize("query", [QUICK_SEARCH_CONTAINS_PARAMS, QUICK_SEARCH_EXACT_PARAMS])
     @patch.object(DBResourceApi, "resource_list")
-    def test_quick_search_for_cluster_domain(self, resource_list_mock, query, init_cluster):
+    def test_quick_search_for_entry(self, resource_list_mock, query, init_cluster):
         """
-        测试搜索集群域名
+        测试搜索访问入口
         """
         target_value = init_cluster.immute_domain
         query["keyword"] = self._get_keyword(query, target_value)
         response = self._request_quick_search(resource_list_mock, query)
         assert response.status_code == 200
-        result = [cluster.get("id") for cluster in response.data.get("cluster_domain")]
+        result = [cluster.get("id") for cluster in response.data.get("entry")]
         assert init_cluster.id in result
 
     @pytest.mark.parametrize("query", [QUICK_SEARCH_CONTAINS_PARAMS, QUICK_SEARCH_EXACT_PARAMS])