feat: System operate log

Author: zhanweizhang7

apps/application/views/application.py

@@ -6,6 +6,7 @@
     @date：2025/5/26 16:51
     @desc:
 """
+from django.db.models import QuerySet
 from django.utils.translation import gettext_lazy as _
 from drf_spectacular.utils import extend_schema
 from rest_framework.parsers import MultiPartParser
@@ -14,11 +15,22 @@
 
 from application.api.application_api import ApplicationCreateAPI, ApplicationQueryAPI, ApplicationImportAPI, \
     ApplicationExportAPI, ApplicationOperateAPI, ApplicationEditAPI
+from application.models import Application
 from application.serializers.application import ApplicationSerializer, Query, ApplicationOperateSerializer
 from common import result
 from common.auth import TokenAuth
 from common.auth.authentication import has_permissions
 from common.constants.permission_constants import PermissionConstants
+from common.log.log import log
+
+
+def get_application_operation_object(application_id):
+    application_model = QuerySet(model=Application).filter(id=application_id).first()
+    if application_model is not None:
+        return{
+            'name': application_model.name
+        }
+    return {}
 
 
 class Application(APIView):
@@ -35,6 +47,8 @@ class Application(APIView):
         tags=[_('Application')]  # type: ignore
     )
     @has_permissions(PermissionConstants.APPLICATION_READ.get_workspace_permission())
+    @log(menu='Application', operate='Create an application',
+         get_operation_object=lambda r,k: {'name': r.data.get('name')})
     def post(self, request: Request, workspace_id: str):
         return result.success(
             ApplicationSerializer(data={'workspace_id': workspace_id, 'user_id': request.user.id}).insert(request.data))
@@ -85,11 +99,14 @@ class Import(APIView):
             tags=[_('Application')]  # type: ignore
         )
         @has_permissions(PermissionConstants.APPLICATION_READ)
+        @log(menu='Application', operate="Import Application")
         def post(self, request: Request, workspace_id: str):
             return result.success(ApplicationSerializer(
                 data={'user_id': request.user.id, 'workspace_id': workspace_id,
                       }).import_({'file': request.FILES.get('file')}))
 
+
+
     class Export(APIView):
         authentication_classes = [TokenAuth]
 
@@ -103,6 +120,8 @@ class Export(APIView):
             tags=[_('Application')]  # type: ignore
         )
         @has_permissions(PermissionConstants.APPLICATION_EXPORT.get_workspace_application_permission())
+        @log(menu='Application', operate="Export Application",
+             get_operation_object=lambda r, k: get_application_operation_object(k.get('application_id')))
         def post(self, request: Request, workspace_id: str, application_id: str):
             return ApplicationOperateSerializer(
                 data={'application_id': application_id,
@@ -121,6 +140,9 @@ class Operate(APIView):
             tags=[_('Application')]  # type: ignore
         )
         @has_permissions(PermissionConstants.APPLICATION_DELETE.get_workspace_application_permission())
+        @log(menu='Application', operate='Deleting application',
+             get_operation_object=lambda r, k: get_application_operation_object(k.get('application_id'))
+             )
         def delete(self, request: Request, workspace_id: str, application_id: str):
             return result.success(ApplicationOperateSerializer(
                 data={'application_id': application_id, 'user_id': request.user.id}).delete(
@@ -137,6 +159,8 @@ def delete(self, request: Request, workspace_id: str, application_id: str):
             tags=[_('Application')]  # type: ignore
         )
         @has_permissions(PermissionConstants.APPLICATION_EDIT.get_workspace_application_permission())
+        @log(menu='Application', operate="Modify the application",
+             get_operation_object=lambda r, k: get_application_operation_object(k.get('application_id')))
         def put(self, request: Request, workspace_id: str, application_id: str):
             return result.success(
                 ApplicationOperateSerializer(
@@ -171,6 +195,9 @@ class Publish(APIView):
             responses=result.DefaultResultSerializer,
             tags=[_('Application')]  # type: ignore
         )
+        @log(menu='Application', operate='Publishing an application',
+             get_operation_object=lambda r,k: get_application_operation_object(k.get('application_id'))
+             )
         def put(self, request: Request, application_id: str):
             return result.success(
                 ApplicationOperateSerializer(

apps/application/views/application_api_key.py

@@ -1,14 +1,26 @@
+from django.db.models import QuerySet
 from drf_spectacular.utils import extend_schema
 from rest_framework.request import Request
 from rest_framework.views import APIView
 from django.utils.translation import gettext_lazy as _
 
 from application.api.application_api_key import ApplicationKeyCreateAPI
+from application.models import ApplicationApiKey
 from application.serializers.application_api_key import ApplicationKeySerializer
 from common.auth import TokenAuth
+from common.log.log import log
 from common.result import result, success
 
 
+def get_application_operation_object(application_api_key_id):
+    application_api_key_model = QuerySet(model=ApplicationApiKey).filter(id=application_api_key_id).first()
+    if application_api_key_model is not None:
+        return {
+            "name": application_api_key_model.name
+        }
+    return {}
+
+
 class ApplicationKey(APIView):
     authentication_classes = [TokenAuth]
 
@@ -20,6 +32,8 @@ class ApplicationKey(APIView):
         parameters=ApplicationKeyCreateAPI.get_parameters(),
         tags=[_('Application Api Key')]  # type: ignore
     )
+    @log(menu='Application', operate="Add ApiKey",
+         get_operation_object=lambda r, k: get_application_operation_object(k.get('application_api_key_id')))
     def post(self,request: Request, application_id: str, workspace_id: str):
         return result.success(ApplicationKeySerializer(
                 data={'application_id': application_id, 'user_id': request.user.id,

apps/application/views/application_version.py

@@ -12,10 +12,12 @@
 from rest_framework.views import APIView
 
 from application.serializers.application_version import ApplicationVersionSerializer
+from application.views import get_application_operation_object
 from common import result
 from common.auth import TokenAuth
 from common.auth.authentication import has_permissions
 from common.constants.permission_constants import PermissionConstants
+from common.log.log import log
 
 
 class ApplicationVersionView(APIView):
@@ -90,6 +92,9 @@ def get(self, request: Request, application_id: str, work_flow_version_id: str):
             # responses=ApplicationCreateAPI.get_response(),
             tags=[_('Application/Version')]  # type: ignore
         )
+        @log(menu='Application', operate="Modify application version information",
+             get_operation_object=lambda r, k: get_application_operation_object(k.get('application_id')))
+
         def put(self, request: Request, application_id: str, work_flow_version_id: str):
             return result.success(
                 ApplicationVersionSerializer.Operate(

apps/folders/views/folder.py

@@ -1,3 +1,4 @@
+from django.db.models import QuerySet
 from django.utils.translation import gettext_lazy as _
 from drf_spectacular.utils import extend_schema
 from rest_framework.request import Request
@@ -6,11 +7,29 @@
 from common.auth import TokenAuth
 from common.auth.authentication import has_permissions
 from common.constants.permission_constants import Permission, Group, Operate
+from common.log.log import log
 from common.result import result
 from folders.api.folder import FolderCreateAPI, FolderEditAPI, FolderReadAPI, FolderTreeReadAPI, FolderDeleteAPI
+from folders.models.folder import FolderCreateRequest, FolderEditRequest
 from folders.serializers.folder import FolderSerializer, FolderTreeSerializer
 
 
+def get_folder_create_operation_object(folder_name):
+    folder_model = QuerySet(model=FolderCreateRequest).filter(name=folder_name).first()
+    if folder_model is not None:
+        return {
+            'name': folder_model.name
+        }
+    return {}
+
+def get_folder_edit_operation_object(folder_name):
+    folder_model = QuerySet(model=FolderEditRequest).filter(name=folder_name).first()
+    if folder_model is not None:
+        return {
+            'name': folder_model.name
+        }
+    return {}
+
 class FolderView(APIView):
     authentication_classes = [TokenAuth]
 
@@ -26,6 +45,9 @@ class FolderView(APIView):
     )
     @has_permissions(lambda r, kwargs: Permission(group=Group(kwargs.get('source')), operate=Operate.CREATE,
                                                   resource_path=f"/WORKSPACE/{kwargs.get('workspace_id')}"))
+    @log(menu='folder', operate='Create folder',
+         get_operation_object=lambda r,k: get_folder_create_operation_object(k.get('folder_name'))
+         )
     def post(self, request: Request, workspace_id: str, source: str):
         return result.success(FolderSerializer.Create(
             data={'user_id': request.user.id,
@@ -64,6 +86,9 @@ class Operate(APIView):
         )
         @has_permissions(lambda r, kwargs: Permission(group=Group(kwargs.get('source')), operate=Operate.EDIT,
                                                       resource_path=f"/WORKSPACE/{kwargs.get('workspace_id')}"))
+        @log(menu='folder', operate='Edit folder',
+             get_operation_object=lambda r, k: get_folder_edit_operation_object(k.get('folder_name'))
+             )
         def put(self, request: Request, workspace_id: str, source: str, folder_id: str):
             return result.success(FolderSerializer.Operate(
                 data={'id': folder_id, 'workspace_id': workspace_id, 'source': source}
@@ -96,6 +121,7 @@ def get(self, request: Request, workspace_id: str, source: str, folder_id: str):
         )
         @has_permissions(lambda r, kwargs: Permission(group=Group(kwargs.get('source')), operate=Operate.DELETE,
                                                       resource_path=f"/WORKSPACE/{kwargs.get('workspace_id')}"))
+        @log(menu='folder', operate='Delete folder')
         def delete(self, request: Request, workspace_id: str, source: str, folder_id: str):
             return result.success(FolderSerializer.Operate(
                 data={'id': folder_id, 'workspace_id': workspace_id, 'source': source}

apps/knowledge/serializers/common.py

@@ -221,3 +221,17 @@ def or_get(exists_problem_list, content, knowledge_id, document_id, paragraph_id
         problem = Problem(id=uuid.uuid7(), content=content, knowledge_id=knowledge_id)
         problem_content_dict[content] = problem, True
         return problem, document_id, paragraph_id
+
+
+
+def get_knowledge_operation_object(knowledge_id: str):
+    knowledge_model = QuerySet(model=Knowledge).filter(id=knowledge_id).first()
+    if knowledge_model is not None:
+        return {
+            "name": knowledge_model.name,
+            "desc": knowledge_model.desc,
+            "type": knowledge_model.type,
+            "create_time": knowledge_model.create_time,
+            "update_time": knowledge_model.update_time
+        }
+    return {}

apps/knowledge/views/common.py

@@ -0,0 +1,35 @@
+from django.db.models import QuerySet
+
+from knowledge.models import Document
+
+
+
+def get_document_operation_object(document_id: str):
+    document_model = QuerySet(model=Document).filter(id=document_id).first()
+    if document_model is not None:
+        return {
+            "name": document_model.name,
+            "type": document_model.type,
+        }
+    return {}
+
+def get_document_operation_object_batch(document_id_list: str):
+    document_model_list = QuerySet(model=Document).filter(id__in=document_id_list)
+    if document_model_list is not None:
+        return {
+            "name": f'[{",".join([document_model.name for document_model in document_model_list])}]',
+            'document_list': [{'name': document_model.name, 'type': document_model.type} for document_model in
+                              document_model_list]
+        }
+    return {}
+
+
+def get_knowledge_document_operation_object(knowledge_dict: dict, document_dict: dict):
+    return {
+        'name': f'{knowledge_dict.get("name", "")}/{document_dict.get("name", "")}',
+        'dataset_name': knowledge_dict.get("name", ""),
+        'dataset_desc': knowledge_dict.get("desc", ""),
+        'dataset_type': knowledge_dict.get("type", ""),
+        'document_name': document_dict.get("name", ""),
+        'document_type': document_dict.get("type", ""),
+    }