mirror of
https://github.com/jumpserver/jumpserver.git
synced 2025-08-30 13:02:28 +00:00
905014d441
* feat: 改密计划支持数据库改密 * fix: 将数据库账户信息不保存在资产信息里，保存到自己的存储中 * perf: 早餐村 * perf: 修改account * perf: 修改app和系统用户 * perf: 优化系统用户和应用关系 * fix: 修复oracle不可连接问题 Co-authored-by: ibuler <ibuler@qq.com> Co-authored-by: feng626 <1304903146@qq.com> Co-authored-by: Michael Bai <baijiangjie@gmail.com>
41 lines
1.2 KiB
Python
41 lines
1.2 KiB
Python
# Generated by Django 3.1.12 on 2021-08-26 09:59
|
|
|
|
from django.db import migrations, transaction
|
|
from django.db.models import F
|
|
|
|
|
|
def migrate_app_account(apps, schema_editor):
|
|
db_alias = schema_editor.connection.alias
|
|
app_perm_model = apps.get_model("perms", "ApplicationPermission")
|
|
app_account_model = apps.get_model("applications", 'Account')
|
|
|
|
queryset = app_perm_model.objects \
|
|
.exclude(system_users__isnull=True) \
|
|
.exclude(applications__isnull=True) \
|
|
.annotate(systemuser=F('system_users')) \
|
|
.annotate(app=F('applications')) \
|
|
.values('app', 'systemuser', 'org_id')
|
|
|
|
accounts = []
|
|
for p in queryset:
|
|
if not p['app']:
|
|
continue
|
|
account = app_account_model(
|
|
app_id=p['app'], systemuser_id=p['systemuser'],
|
|
version=1, org_id=p['org_id']
|
|
)
|
|
accounts.append(account)
|
|
|
|
app_account_model.objects.using(db_alias).bulk_create(accounts, ignore_conflicts=True)
|
|
|
|
|
|
class Migration(migrations.Migration):
|
|
|
|
dependencies = [
|
|
('applications', '0010_appaccount_historicalappaccount'),
|
|
]
|
|
|
|
operations = [
|
|
migrations.RunPython(migrate_app_account)
|
|
]
|