diff --git a/apps/audits/signal_handlers/activity_log.py b/apps/audits/signal_handlers/activity_log.py
index a85324005..430b25002 100644
--- a/apps/audits/signal_handlers/activity_log.py
+++ b/apps/audits/signal_handlers/activity_log.py
@@ -10,7 +10,7 @@ from common.utils import i18n_fmt, get_logger
 from jumpserver.utils import current_request
 from ops.celery import app
 from orgs.models import Organization
-from orgs.utils import current_org
+from orgs.utils import current_org, tmp_to_org
 from terminal.models import Session
 from users.models import User
 from ..const import ActivityChoices
@@ -77,7 +77,8 @@ def create_activities(resource_ids, detail, detail_id, action, org_id):
         )
         for resource_id in resource_ids
     ]
-    ActivityLog.objects.bulk_create(activities)
+    with tmp_to_org(org_id):
+        ActivityLog.objects.bulk_create(activities)
     return activities
 
 
diff --git a/apps/orgs/mixins/models.py b/apps/orgs/mixins/models.py
index d01a30ca5..d9eef1e2f 100644
--- a/apps/orgs/mixins/models.py
+++ b/apps/orgs/mixins/models.py
@@ -47,8 +47,7 @@ class OrgManager(models.Manager):
                 if not obj.org_id:
                     raise ValidationError('Please save in a org')
             else:
-                if not getattr(obj, 'org_id', None):
-                    obj.org_id = org.id
+                obj.org_id = org.id
         return super().bulk_create(objs, batch_size, ignore_conflicts)