mirror of
https://github.com/jumpserver/jumpserver.git
synced 2026-01-29 21:51:31 +00:00
* [Update] 暂存,优化解决不了问题 * [Update] 待续(小白) * [Update] 修改asset user * [Update] 计划再次更改 * [Update] 修改asset user * [Update] 暂存与喜爱 * [Update] Add id in * [Update] 阶段性完成ops task该做 * [Update] 修改asset user api * [Update] 修改asset user 任务,查看认证等 * [Update] 基本完成asset user改造 * [Update] dynamic user only allow 1 * [Update] 修改asset user task * [Update] 修改node admin user task api * [Update] remove file header license * [Update] 添加sftp root * [Update] 暂存 * [Update] 暂存 * [Update] 修改翻译 * [Update] 修改系统用户改为同名后,用户名改为空 * [Update] 基本完成CAS调研 * [Update] 支持cas server * [Update] 支持cas server * [Update] 添加requirements * [Update] 为方便调试添加mysql ipython到包中 * [Update] 添加huaweiyun翻译 * [Update] 增加下载session 录像 * [Update] 只有第一次通知replay离线的使用方法 * [Update] 暂存一下 * [Bugfix] 获取系统用户信息报错 * [Bugfix] 修改system user info * [Update] 改成清理10天git status * [Update] 修改celery日志保留时间 * [Update]修复部分pip包依赖的版本不兼容问题 (#3672) * [Update] 修复用户更新页面会清空用户public_key的问题 * Fix broken dependencies Co-authored-by: BaiJiangJie <32935519+BaiJiangJie@users.noreply.github.com> * [Update] 修改获取系统用户auth info * [Update] Remove log * [Bugfix] 修复sftp home设置的bug * [Update] 授权的系统用户添加sftp root * [Update] 修改系统用户关联的用户 * [Update] 修改placeholder * [Update] 优化获取授权的系统用户 * [Update] 修改tasks * [Update] tree service update * [Update] 暂存 * [Update] 基本完成用户授权树和资产树改造 * [Update] Dashbaord perf * [update] Add huawei cloud sdk requirements * [Updte] 优化dashboard页面 * [Update] system user auth info 添加id * [Update] 修改系统用户serializer * [Update] 优化api * [Update] LDAP Test Util (#3720) * [Update] LDAPTestUtil 1 * [Update] LDAPTestUtil 2 * [Update] LDAPTestUtil 3 * [Update] LDAPTestUtil 4 * [Update] LDAPTestUtil 5 * [Update] LDAPTestUtil 6 * [Update] LDAPTestUtil 7 * [Update] session 已添加is success,并且添加display serializer * [Bugfix] 修复无法删除空节点的bug * [Update] 命令记录分组织显示 * [Update] Session is_success 添加迁移文件 * [Update] 批量命令添加org_id * [Update] 修复一些文案,修改不绑定MFA,不能ssh登录 * [Update] 修改replay api, 返回session信息 * [Update] 解决无效es导致访问命令记录页面失败的问题 * [Update] 拆分profile view * [Update] 修改一个翻译 * [Update] 修改aysnc api框架 * [Update] 命令列表添加risk level * [Update] 完成录像打包下载 * [Update] 更改登陆otp页面 * [Update] 修改command 存储redis_level * [Update] 修改翻译 * [Update] 修改系统用户的用户列表字段 * [Update] 使用新logo和统一Jumpserver为JumpServer * [Update] 优化cloud task * [Update] 统一period task * [Update] 统一period form serializer字段 * [Update] 修改period task * [Update] 修改资产网关信息 * [Update] 用户授权资产树资产信息添加domain * [Update] 修改翻译 * [Update] 测试可连接性 * 1.5.7 bai (#3764) * [Update] 修复index页面Bug;修复测试资产用户可连接性问题; * [Update] 修改测试资产用户可连接 * [Bugfix] 修复backends问题 * [Update] 修改marksafe依赖版本 * [Update] 修改测试资产用户可连接性 * [Update] 修改检测服务器性能时获取percent值 * [Update] 更新依赖boto3=1.12.14 Co-authored-by: Yanzhe Lee <lee.yanzhe@yanzhe.org> Co-authored-by: BaiJiangJie <32935519+BaiJiangJie@users.noreply.github.com> Co-authored-by: Bai <bugatti_it@163.com>
218 lines
6.6 KiB
Python
218 lines
6.6 KiB
Python
import uuid
|
|
from django.conf import settings
|
|
|
|
from django.db import models
|
|
from django.utils.translation import ugettext_lazy as _
|
|
|
|
from common.utils import is_uuid, lazyproperty
|
|
|
|
|
|
class Organization(models.Model):
|
|
id = models.UUIDField(default=uuid.uuid4, primary_key=True)
|
|
name = models.CharField(max_length=128, unique=True, verbose_name=_("Name"))
|
|
users = models.ManyToManyField('users.User', related_name='related_user_orgs', blank=True)
|
|
admins = models.ManyToManyField('users.User', related_name='related_admin_orgs', blank=True)
|
|
auditors = models.ManyToManyField('users.User', related_name='related_audit_orgs', blank=True)
|
|
created_by = models.CharField(max_length=32, null=True, blank=True, verbose_name=_('Created by'))
|
|
date_created = models.DateTimeField(auto_now_add=True, null=True, blank=True, verbose_name=_('Date created'))
|
|
comment = models.TextField(max_length=128, default='', blank=True, verbose_name=_('Comment'))
|
|
|
|
orgs = None
|
|
CACHE_PREFIX = 'JMS_ORG_{}'
|
|
ROOT_ID = '00000000-0000-0000-0000-000000000000'
|
|
ROOT_NAME = 'ROOT'
|
|
DEFAULT_ID = 'DEFAULT'
|
|
DEFAULT_NAME = 'DEFAULT'
|
|
SYSTEM_ID = '00000000-0000-0000-0000-000000000002'
|
|
SYSTEM_NAME = 'SYSTEM'
|
|
_user_admin_orgs = None
|
|
|
|
class Meta:
|
|
verbose_name = _("Organization")
|
|
|
|
def __str__(self):
|
|
return self.name
|
|
|
|
def set_to_cache(self):
|
|
if self.__class__.orgs is None:
|
|
self.__class__.orgs = {}
|
|
self.__class__.orgs[str(self.id)] = self
|
|
|
|
def expire_cache(self):
|
|
self.__class__.orgs.pop(str(self.id), None)
|
|
|
|
@classmethod
|
|
def get_instance_from_cache(cls, oid):
|
|
if not cls.orgs or not isinstance(cls.orgs, dict):
|
|
return None
|
|
return cls.orgs.get(str(oid))
|
|
|
|
@classmethod
|
|
def get_instance(cls, id_or_name, default=False):
|
|
cached = cls.get_instance_from_cache(id_or_name)
|
|
if cached:
|
|
return cached
|
|
|
|
if id_or_name is None:
|
|
return cls.default() if default else None
|
|
elif id_or_name in [cls.DEFAULT_ID, cls.DEFAULT_NAME, '']:
|
|
return cls.default()
|
|
elif id_or_name in [cls.ROOT_ID, cls.ROOT_NAME]:
|
|
return cls.root()
|
|
elif id_or_name in [cls.SYSTEM_ID, cls.SYSTEM_NAME]:
|
|
return cls.system()
|
|
|
|
try:
|
|
if is_uuid(id_or_name):
|
|
org = cls.objects.get(id=id_or_name)
|
|
else:
|
|
org = cls.objects.get(name=id_or_name)
|
|
org.set_to_cache()
|
|
except cls.DoesNotExist:
|
|
org = cls.default() if default else None
|
|
return org
|
|
|
|
@lazyproperty
|
|
def org_users(self):
|
|
from users.models import User
|
|
if self.is_real():
|
|
return self.users.all()
|
|
users = User.objects.filter(role=User.ROLE_USER)
|
|
if self.is_default() and not settings.DEFAULT_ORG_SHOW_ALL_USERS:
|
|
users = users.filter(related_user_orgs__isnull=True)
|
|
return users
|
|
|
|
def get_org_users(self):
|
|
return self.org_users
|
|
|
|
@lazyproperty
|
|
def org_admins(self):
|
|
from users.models import User
|
|
if self.is_real():
|
|
return self.admins.all()
|
|
return User.objects.filter(role=User.ROLE_ADMIN)
|
|
|
|
def get_org_admins(self):
|
|
return self.org_admins
|
|
|
|
def org_id(self):
|
|
if self.is_real():
|
|
return self.id
|
|
elif self.is_root():
|
|
return self.ROOT_ID
|
|
else:
|
|
return ''
|
|
|
|
@lazyproperty
|
|
def org_auditors(self):
|
|
from users.models import User
|
|
if self.is_real():
|
|
return self.auditors.all()
|
|
return User.objects.filter(role=User.ROLE_AUDITOR)
|
|
|
|
def get_org_auditors(self):
|
|
return self.org_auditors
|
|
|
|
def get_org_members(self, exclude=()):
|
|
from users.models import User
|
|
members = User.objects.none()
|
|
if 'Admin' not in exclude:
|
|
members |= self.get_org_admins()
|
|
if 'User' not in exclude:
|
|
members |= self.get_org_users()
|
|
if 'Auditor' not in exclude:
|
|
members |= self.get_org_auditors()
|
|
return members.exclude(role=User.ROLE_APP).distinct()
|
|
|
|
def can_admin_by(self, user):
|
|
if user.is_superuser:
|
|
return True
|
|
if self.get_org_admins().filter(id=user.id):
|
|
return True
|
|
return False
|
|
|
|
def can_audit_by(self, user):
|
|
if user.is_super_auditor:
|
|
return True
|
|
if self.get_org_auditors().filter(id=user.id):
|
|
return True
|
|
return False
|
|
|
|
def can_user_by(self, user):
|
|
if self.get_org_users().filter(id=user.id):
|
|
return True
|
|
return False
|
|
|
|
def is_real(self):
|
|
return self.id not in (self.DEFAULT_NAME, self.ROOT_ID, self.SYSTEM_ID)
|
|
|
|
@classmethod
|
|
def get_user_admin_orgs(cls, user):
|
|
admin_orgs = []
|
|
if user.is_anonymous:
|
|
return admin_orgs
|
|
elif user.is_superuser:
|
|
admin_orgs = list(cls.objects.all())
|
|
admin_orgs.append(cls.default())
|
|
elif user.is_org_admin:
|
|
admin_orgs = user.related_admin_orgs.all()
|
|
return admin_orgs
|
|
|
|
@classmethod
|
|
def get_user_user_orgs(cls, user):
|
|
user_orgs = []
|
|
if user.is_anonymous:
|
|
return user_orgs
|
|
user_orgs = user.related_user_orgs.all()
|
|
return user_orgs
|
|
|
|
@classmethod
|
|
def get_user_audit_orgs(cls, user):
|
|
audit_orgs = []
|
|
if user.is_anonymous:
|
|
return audit_orgs
|
|
elif user.is_super_auditor:
|
|
audit_orgs = list(cls.objects.all())
|
|
audit_orgs.append(cls.default())
|
|
elif user.is_org_auditor:
|
|
audit_orgs = user.related_audit_orgs.all()
|
|
return audit_orgs
|
|
|
|
@classmethod
|
|
def get_user_admin_or_audit_orgs(self, user):
|
|
admin_orgs = self.get_user_admin_orgs(user)
|
|
audit_orgs = self.get_user_audit_orgs(user)
|
|
orgs = set(admin_orgs) | set(audit_orgs)
|
|
return orgs
|
|
|
|
@classmethod
|
|
def default(cls):
|
|
return cls(id=cls.DEFAULT_ID, name=cls.DEFAULT_NAME)
|
|
|
|
@classmethod
|
|
def root(cls):
|
|
return cls(id=cls.ROOT_ID, name=cls.ROOT_NAME)
|
|
|
|
@classmethod
|
|
def system(cls):
|
|
return cls(id=cls.SYSTEM_ID, name=cls.SYSTEM_NAME)
|
|
|
|
def is_root(self):
|
|
return self.id is self.ROOT_ID
|
|
|
|
def is_default(self):
|
|
return self.id is self.DEFAULT_ID
|
|
|
|
def is_system(self):
|
|
return self.id is self.SYSTEM_ID
|
|
|
|
def change_to(self):
|
|
from .utils import set_current_org
|
|
set_current_org(self)
|
|
|
|
@classmethod
|
|
def all_orgs(cls):
|
|
orgs = list(cls.objects.all())
|
|
orgs.append(cls.default())
|
|
return orgs
|