feat: 删除用户组时，向redis队列里插入被删除的用户组id

src/backend/bisheng/api/services/role_group_service.py

@@ -1,10 +1,12 @@
+import json
 from datetime import datetime
 from typing import List, Any, Dict
 from uuid import UUID
 
 from fastapi.encoders import jsonable_encoder
 from fastapi import Request, HTTPException
 
+from bisheng.cache.redis import redis_client
 from bisheng.api.services.assistant import AssistantService
 from bisheng.api.services.audit_log import AuditLogService
 from bisheng.api.services.user_service import UserPayload
@@ -125,6 +127,8 @@ def delete_group_hook(self, request: Request, login_user: UserPayload, group_inf
         GroupResourceDao.delete_group_resource_by_group_id(group_info.id)
         # 删除用户组下的角色列表
         RoleDao.delete_role_by_group_id(group_info.id)
+        # 将删除事件发到redis队列中
+        redis_client.rpush('delete_group', json.dumps({"id": group_info.id}))
 
     def get_group_user_list(self, group_id: int, page_size: int, page_num: int) -> List[User]:
         """获取全量的group列表"""

src/backend/bisheng/api/v1/usergroup.py

@@ -202,69 +202,3 @@ async def get_group_roles(*,
         "data": role_list,
         "total": total
     })
-
-
-@router.get("/assistant", response_model=UnifiedResponseModel[List[AssistantSimpleInfo]])
-async def get_group_assistant(*,
-                              group_id: int = Query(..., description="用户组ID"),
-                              keyword: str = Query(None, description="搜索关键字"),
-                              page: int = 1,
-                              limit: int = 10,
-                              user: UserPayload = Depends(get_login_user)):
-    """
-    获取用户组可见的助手列表
-    """
-    # 判断是否是用户组的管理员
-    if not user.check_group_admin(group_id):
-        return UnAuthorizedError.return_resp()
-
-    # 查询用户组下的助手ID列表
-    resource_list = GroupResourceDao.get_group_resource(group_id, ResourceTypeEnum.ASSISTANT)
-    res = []
-    total = 0
-    if resource_list:
-        assistant_ids = [UUID(resource.third_id) for resource in resource_list]  # 查询助手
-        data, total = AssistantDao.filter_assistant_by_id(assistant_ids, keyword, page, limit)
-        for one in data:
-            simple_one = AssistantService.return_simple_assistant_info(one)
-            res.append(simple_one)
-    return resp_200(data={
-        "data": res,
-        "total": total
-    })
-
-
-@router.get("/knowledge", response_model=UnifiedResponseModel[GroupRead])
-async def get_group_knowledge(*,
-                              group_id: int = Query(..., description="用户组ID"),
-                              keyword: str = Query(None, description="搜索关键字"),
-                              page: int = 1,
-                              limit: int = 10,
-                              user: UserPayload = Depends(get_login_user)):
-    """
-    获取用户组可见的知识库列表
-    """
-
-    # 判断是否是用户组的管理员
-    if not user.check_group_admin(group_id):
-        return UnAuthorizedError.return_resp()
-
-    # 查询用户组下的知识库ID列表
-    resource_list = GroupResourceDao.get_group_resource(group_id, ResourceTypeEnum.KNOWLEDGE)
-    res = []
-    total = 0
-    if resource_list:
-        knowledge_ids = [int(resource.third_id) for resource in resource_list]
-        # 查询知识库
-        data, total = KnowledgeDao.filter_knowledge_by_ids(knowledge_ids, keyword, page, limit)
-        db_user_ids = {one.user_id for one in data}
-        user_list = UserDao.get_user_by_ids(list(db_user_ids))
-        user_map = {user.user_id: user.user_name for user in user_list}
-        for one in data:
-            one_dict = one.model_dump()
-            one_dict["user_name"] = user_map.get(one.user_id, one.user_id)
-            res.append(one_dict)
-    return resp_200(data={
-        "data": res,
-        "total": total
-    })

src/backend/bisheng/cache/redis.py

@@ -131,6 +131,13 @@ def delete(self, key):
         finally:
             self.close()
 
+    def rpush(self, key, value):
+        try:
+            self.cluster_nodes(key)
+            return self.connection.rpush(key, value)
+        finally:
+            self.close()
+
     def exists(self, key):
         try:
             self.cluster_nodes(key)