mirror of https://github.com/jumpserver/jumpserver
Merge branch 'dev' of git.coding.net:jumpserver/jumpserver into dev
commit
18da6f69a2
|
@ -1,6 +1,7 @@
|
||||||
# -*- coding: utf-8 -*-
|
# -*- coding: utf-8 -*-
|
||||||
|
|
||||||
from django.db.models import Q
|
from django.db.models import Q
|
||||||
|
from django.http import HttpResponseBadRequest, HttpResponseNotAllowed
|
||||||
from paramiko import SSHException
|
from paramiko import SSHException
|
||||||
from jperm.perm_api import *
|
from jperm.perm_api import *
|
||||||
|
|
||||||
|
@ -317,9 +318,13 @@ def perm_role_delete(request):
|
||||||
delete role page
|
delete role page
|
||||||
"""
|
"""
|
||||||
if request.method == "POST":
|
if request.method == "POST":
|
||||||
|
try:
|
||||||
# 获取参数删除的role对象
|
# 获取参数删除的role对象
|
||||||
role_id = request.POST.get("id")
|
role_id = request.POST.get("id")
|
||||||
role = get_object(PermRole, id=role_id)
|
role = get_object(PermRole, id=role_id)
|
||||||
|
if not role:
|
||||||
|
logger.warning(u"Delete Role: %s not exist" % role.name)
|
||||||
|
raise ServerError(u"%s 无数据记录" % role.name)
|
||||||
role_key = role.key_path
|
role_key = role.key_path
|
||||||
# 删除推送到主机上的role
|
# 删除推送到主机上的role
|
||||||
recycle_assets = [push.asset for push in role.perm_push.all() if push.success]
|
recycle_assets = [push.asset for push in role.perm_push.all() if push.success]
|
||||||
|
@ -327,20 +332,29 @@ def perm_role_delete(request):
|
||||||
if recycle_assets:
|
if recycle_assets:
|
||||||
recycle_resource = gen_resource(recycle_assets)
|
recycle_resource = gen_resource(recycle_assets)
|
||||||
task = MyTask(recycle_resource)
|
task = MyTask(recycle_resource)
|
||||||
|
try:
|
||||||
msg = task.del_user(get_object(PermRole, id=role_id).name)
|
msg = task.del_user(get_object(PermRole, id=role_id).name)
|
||||||
|
except Exception, e:
|
||||||
|
logger.warning(u"Recycle Role failed: %s" % e)
|
||||||
|
raise ServerError(u"回收已推送的系统用户失败: %s" % e)
|
||||||
logger.info(u"delete role %s - execute delete user: %s" % (role.name, msg))
|
logger.info(u"delete role %s - execute delete user: %s" % (role.name, msg))
|
||||||
# TODO: 判断返回结果,处理异常
|
# TODO: 判断返回结果,处理异常
|
||||||
# 删除存储的秘钥,以及目录
|
# 删除存储的秘钥,以及目录
|
||||||
|
try:
|
||||||
key_files = os.listdir(role_key)
|
key_files = os.listdir(role_key)
|
||||||
for key_file in key_files:
|
for key_file in key_files:
|
||||||
os.remove(os.path.join(role_key, key_file))
|
os.remove(os.path.join(role_key, key_file))
|
||||||
os.rmdir(role_key)
|
os.rmdir(role_key)
|
||||||
|
except OSError, e:
|
||||||
|
logger.warning(u"Delete Role: delete key error, %s" % e)
|
||||||
|
raise ServerError(u"删除系统用户key失败: %s" % e)
|
||||||
logger.info(u"delete role %s - delete role key directory: %s" % (role.name, role_key))
|
logger.info(u"delete role %s - delete role key directory: %s" % (role.name, role_key))
|
||||||
# 数据库里删除记录 TODO: 判断返回结果,处理异常
|
# 数据库里删除记录
|
||||||
role.delete()
|
role.delete()
|
||||||
return HttpResponse(u"删除系统用户: %s" % role.name)
|
return HttpResponse(u"删除系统用户: %s" % role.name)
|
||||||
else:
|
except ServerError, e:
|
||||||
return HttpResponse(u"不支持该操作")
|
return HttpResponseBadRequest(u"删除失败, 原因: %s" % e)
|
||||||
|
return HttpResponseNotAllowed(u"仅支持POST")
|
||||||
|
|
||||||
|
|
||||||
@require_role('admin')
|
@require_role('admin')
|
||||||
|
|
|
@ -96,7 +96,7 @@ function remove_role(role_id){
|
||||||
},
|
},
|
||||||
error: function (msg) {
|
error: function (msg) {
|
||||||
console.log(msg);
|
console.log(msg);
|
||||||
alert("失败: " + msg)
|
alert("失败: " + msg.responseText)
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue