@@ -30,7 +28,6 @@
|
- ## |
@@ -43,62 +40,13 @@
-
+
- ##
- ## 资产
- ##
- ## - 主机信息创建/编辑
- ## - 删除主机信息
- ## - 主机禁用/解禁
- ## - 主机分组管理
- ## - 主机账号管理
- ## - 主机账号分组管理
- ##
- ##
- ##
- ## 用户
- ##
- ## - 登录WEB系统
- ## - 用户创建/编辑
- ## - 删除用户
- ## - 用户禁用/解禁
- ## - 用户分组管理
- ##
- ##
- ##
- ## 运维
- ##
- ## - 远程主机运维
- ## - 运维授权管理
- ## - 查看在线会话
- ## - 阻断在线会话
- ##
- ##
- ##
- ## 审计
- ##
- ## - 审计（查看历史会话）
- ## - 审计授权管理
- ## ## - 查看系统日志
- ##
- ##
- ##
- ## 系统
- ##
- ## ## - 部门管理
- ##
- ## - 角色管理
- ## - 系统配置与维护
- ## - 历史会话管理
- ## - 系统日志管理
- ##
-
@@ -137,6 +85,6 @@
历史会话管理
系统日志管理
- 特别注意：teleport系统使用最小权限判定规则，也即，在检查权限时，会按用户所具有的最小权限进行判断。例如：如用户无远程主机运维权限，那么即使其所在用户组被授权访问某远程主机，此用户也无法连接到该远程主机。
+## 特别注意：teleport系统使用最小权限判定规则，也即，在检查权限时，会按用户所具有的最小权限进行判断。例如：如用户无远程主机运维权限，那么即使其所在用户组被授权访问某远程主机，此用户也无法连接到该远程主机。
diff --git a/server/www/teleport/webroot/app/controller/__init__.py b/server/www/teleport/webroot/app/controller/__init__.py
index 51f39c9..b1b6945 100644
--- a/server/www/teleport/webroot/app/controller/__init__.py
+++ b/server/www/teleport/webroot/app/controller/__init__.py
@@ -207,6 +207,10 @@ controllers = [
# 系统管理设置相关
# - 角色管理页面
(r'/system/role', system.RoleHandler),
+ # - [json] 创建/更新 角色
+ (r'/system/role-update', system.DoRoleUpdateHandler),
+ # - [json] 删除 角色
+ (r'/system/role-remove', system.DoRoleRemoveHandler),
# - 系统日志页面
(r'/system/syslog', system.SysLogHandler),
# - [json] 获取系统日志列表
diff --git a/server/www/teleport/webroot/app/controller/account.py b/server/www/teleport/webroot/app/controller/account.py
index 6e5bd1e..b54b4f0 100644
--- a/server/www/teleport/webroot/app/controller/account.py
+++ b/server/www/teleport/webroot/app/controller/account.py
@@ -1,22 +1,16 @@
# -*- coding: utf-8 -*-
-import time
-import csv
-import os
import json
import threading
+
import tornado.gen
import tornado.httpclient
-
-from app.base.configs import get_cfg
+from app.base.controller import TPBaseHandler, TPBaseJsonHandler
+from app.base.core_server import core_service_async_enc
+from app.base.logger import *
from app.const import *
-# from app.base.utils import *
from app.model import account
from app.model import group
-from app.base.logger import *
-from app.base.core_server import core_service_async_enc
-from app.base.session import session_manager
-from app.base.controller import TPBaseHandler, TPBaseJsonHandler
# cfg = get_cfg()
diff --git a/server/www/teleport/webroot/app/controller/system.py b/server/www/teleport/webroot/app/controller/system.py
index b1ec5b3..3143fc5 100644
--- a/server/www/teleport/webroot/app/controller/system.py
+++ b/server/www/teleport/webroot/app/controller/system.py
@@ -1,15 +1,15 @@
# -*- coding: utf-8 -*-
-import json
import datetime
+import json
import shutil
-import copy
import app.model.system as system_model
import tornado.gen
from app.base import mail
from app.base.configs import get_cfg
from app.base.controller import TPBaseHandler, TPBaseJsonHandler
+from app.base.logger import *
from app.const import *
from app.model import syslog
@@ -52,6 +52,67 @@ class RoleHandler(TPBaseHandler):
self.render('system/role.mako')
+class DoRoleUpdateHandler(TPBaseJsonHandler):
+ @tornado.gen.coroutine
+ def post(self):
+ ret = self.check_privilege(TP_PRIVILEGE_SYS_ROLE)
+ if ret != TPE_OK:
+ return
+
+ args = self.get_argument('args', None)
+ if args is None:
+ return self.write_json(TPE_PARAM)
+ try:
+ args = json.loads(args)
+ except:
+ return self.write_json(TPE_JSON_FORMAT)
+
+ try:
+ role_id = int(args['role_id'])
+ role_name = args['role_name']
+ privilege = int(args['privilege'])
+ except:
+ log.e('\n')
+ return self.write_json(TPE_PARAM)
+
+ if role_id == 0:
+ err, role_id = system_model.add_role(self, role_id, role_name, privilege)
+ else:
+ if role_id == 1:
+ return self.write_json(TPE_FAILED, '禁止修改系统管理员角色！')
+ err = system_model.update_role(self, role_id, role_name, privilege)
+
+ return self.write_json(err, data=role_id)
+
+
+class DoRoleRemoveHandler(TPBaseJsonHandler):
+ @tornado.gen.coroutine
+ def post(self):
+ ret = self.check_privilege(TP_PRIVILEGE_SYS_ROLE)
+ if ret != TPE_OK:
+ return
+
+ args = self.get_argument('args', None)
+ if args is None:
+ return self.write_json(TPE_PARAM)
+ try:
+ args = json.loads(args)
+ except:
+ return self.write_json(TPE_JSON_FORMAT)
+
+ try:
+ role_id = int(args['role_id'])
+ except:
+ log.e('\n')
+ return self.write_json(TPE_PARAM)
+
+ if role_id == 1:
+ return self.write_json(TPE_FAILED, '禁止删除系统管理员角色！')
+ err = system_model.remove_role(self, role_id)
+
+ return self.write_json(err)
+
+
class SysLogHandler(TPBaseHandler):
def get(self):
ret = self.check_privilege(TP_PRIVILEGE_SYS_LOG)
diff --git a/server/www/teleport/webroot/app/model/account.py b/server/www/teleport/webroot/app/model/account.py
index a96d855..145c56c 100644
--- a/server/www/teleport/webroot/app/model/account.py
+++ b/server/www/teleport/webroot/app/model/account.py
@@ -291,7 +291,6 @@ def remove_accounts(handler, host_id, acc_ids):
"""
db = get_db()
acc_count = len(acc_ids)
- print(acc_count)
acc_ids = ','.join([str(uid) for uid in acc_ids])
s = SQL(db)
@@ -303,9 +302,6 @@ def remove_accounts(handler, host_id, acc_ids):
return err
if len(s.recorder) == 0:
return TPE_NOT_EXISTS
- print(s.recorder)
-
-
s.reset().select_from('acc', ['host_ip', 'router_ip', 'router_port', 'username'], alt_name='a')
s.where('a.host_id={h_id} AND a.id IN ({ids}) '.format(h_id=host_id, ids=acc_ids))
@@ -350,7 +346,6 @@ def remove_accounts(handler, host_id, acc_ids):
return err
if len(s.recorder) == 0:
return TPE_NOT_EXISTS
- print(s.recorder)
syslog.sys_log(handler.get_current_user(), handler.request.remote_ip, TPE_OK, "删除账号：{}".format('，'.join(acc_names)))
diff --git a/server/www/teleport/webroot/app/model/system.py b/server/www/teleport/webroot/app/model/system.py
index 4c7482e..87f9fd7 100644
--- a/server/www/teleport/webroot/app/model/system.py
+++ b/server/www/teleport/webroot/app/model/system.py
@@ -3,6 +3,8 @@
from app.const import *
from app.base.db import get_db, SQL
from app.base.logger import log
+from app.base.utils import tp_timestamp_utc_now
+from . import syslog
def save_mail_config(_server, _port, _ssl, _sender, _password):
@@ -23,6 +25,87 @@ def save_mail_config(_server, _port, _ssl, _sender, _password):
return TPE_FAILED, '数据库操作失败'
+
+def add_role(handler, role_id, role_name, privilege):
+ db = get_db()
+ _time_now = tp_timestamp_utc_now()
+ operator = handler.get_current_user()
+
+ # 1. 判断是否已经存在了
+ sql = 'SELECT id FROM {}role WHERE name="{name}";'.format(db.table_prefix, name=role_name)
+ db_ret = db.query(sql)
+ if db_ret is not None and len(db_ret) > 0:
+ return TPE_EXISTS, 0
+
+ sql = 'INSERT INTO `{}role` (name, privilege, creator_id, create_time) VALUES ' \
+ '("{name}", {privilege}, {creator_id}, {create_time});' \
+ ''.format(db.table_prefix,
+ name=role_name, privilege=privilege, creator_id=operator['id'], create_time=_time_now)
+ db_ret = db.exec(sql)
+ if not db_ret:
+ return TPE_DATABASE, 0
+
+ _id = db.last_insert_id()
+
+ syslog.sys_log(operator, handler.request.remote_ip, TPE_OK, "创建角色：{}".format(role_name))
+
+ return TPE_OK, _id
+
+
+def update_role(handler, role_id, role_name, privilege):
+ """
+ 更新一个远程账号
+ """
+ db = get_db()
+
+ # 1. 判断是否存在
+ sql = 'SELECT id FROM {}role WHERE id={rid};'.format(db.table_prefix, rid=role_id)
+ db_ret = db.query(sql)
+ if db_ret is None or len(db_ret) == 0:
+ return TPE_NOT_EXISTS
+
+ sql = 'UPDATE `{}role` SET name="{name}", privilege={p} WHERE id={rid};' \
+ ''.format(db.table_prefix, name=role_name, p=privilege, rid=role_id)
+
+ db_ret = db.exec(sql)
+ if not db_ret:
+ return TPE_DATABASE
+
+ return TPE_OK
+
+
+def remove_role(handler, role_id):
+ db = get_db()
+
+ s = SQL(db)
+ # 1. 判断是否存在
+ s.select_from('role', ['name'], alt_name='r')
+ s.where('r.id={rid}'.format(rid=role_id))
+ err = s.query()
+ if err != TPE_OK:
+ return err
+ if len(s.recorder) == 0:
+ return TPE_NOT_EXISTS
+
+ role_name = s.recorder[0].name
+
+ sql_list = []
+
+ sql = 'DELETE FROM `{}role` WHERE id={};'.format(db.table_prefix, role_id)
+ sql_list.append(sql)
+
+ # 更新此角色相关的用户信息
+ sql = 'UPDATE `{}user` SET role_id=0 WHERE role_id={rid};'.format(db.table_prefix, rid=role_id)
+ sql_list.append(sql)
+
+ if not db.transaction(sql_list):
+ return TPE_DATABASE
+
+ syslog.sys_log(handler.get_current_user(), handler.request.remote_ip, TPE_OK, "删除角色：{}".format('，'.join(role_name)))
+
+ return TPE_OK
+
+
# def get_config_list():
# try:
# from eom_app.module.common import get_db_con
|