first commit

Author: yaoliang83

cmdb/README.md

@@ -0,0 +1,81 @@
+# Flask CMDB
+
+* [安装指南](#安装指南)
+* [结构与功能](#结构与功能)
+* [项目截图](#项目截图)
+
+
+## 安装指南:
+* 需要python2.7环境
+* 需要模块，查看requestment.txt
+* 初始化数据
+* 数据库sql/reboot10.sql
+
+### MYSQL数据库导入
+```
+mysql -uroot -p123456 -e 'create database reboot10'
+mysql -uroot -p123456 reboot10 < sql/reboot10.sql
+```
+### MYSQL数据库字符集设置
+```
+[client]
+default-character-set=utf8
+
+[mysqld]
+character-set-server=utf8
+collation-server=utf8_general_ci
+```
+
+### 登录用户名和密码
+* 用户: test
+* 密码: 123123
+
+## 结构与功能
+* 仪表盘 
+  * 欢迎界面
+* 用户管理
+  * 个人用户信息
+    * 显示当前登录用户的个人信息 
+  * 所有用户信息
+    * 显示所有用户信息(只管理员可见)
+* 资产管理
+  * 服务器管理
+    * 服务器信息
+  * 机柜管理
+    * 机柜信息
+  * 机房管理
+    * 机房信息  
+* 值班系统
+  * 当前值班人
+    * 当前值班人个人信息
+  * 值班列表
+    * 本周值班人信息列表
+* 工单管理
+  * 工单申请
+    * 显示申请界面
+  * 工单申请列表
+    * 已申请和待处理工单列表
+  * 工单历史列表
+    * 处理结束的历史工单列表 
+* 代码更新
+  * 更新信息
+    * 代码更新界面
+  * 更新历史
+    * 更新成功的历史信息列表
+* 设置
+* 访问官网
+
+## 项目截图
+![sec](https://ooo.0o0.ooo/2016/11/22/5834136d7e85b.png)
+![sec](https://ooo.0o0.ooo/2016/11/22/5834136dc8fce.png)
+![sec](https://ooo.0o0.ooo/2016/11/22/5834136f8b787.png)
+![sec](https://ooo.0o0.ooo/2016/11/22/5834136eda8be.png)
+![sec](https://ooo.0o0.ooo/2016/11/22/5834136ed0fe2.png)
+![sec](https://ooo.0o0.ooo/2016/11/22/5834137b087e9.png)
+![sec](https://ooo.0o0.ooo/2016/11/23/58357428e7523.png)
+![sec](https://ooo.0o0.ooo/2016/11/23/583574290c5cd.png)
+![sec](https://ooo.0o0.ooo/2016/11/22/5834137ab0be7.png)
+![sec](https://ooo.0o0.ooo/2016/11/22/5834137b54126.png)
+![sec](https://ooo.0o0.ooo/2016/11/22/5834137bb871b.png)
+![sec](https://ooo.0o0.ooo/2016/12/08/5848c98b75376.png)
+![sec](https://ooo.0o0.ooo/2016/12/08/5848c98b85e61.png)

cmdb/app/__init__.py

@@ -0,0 +1,10 @@
+#!/usr/bin/python
+#coding:utf-8
+
+from flask import Flask
+
+app = Flask(__name__)
+app.secret_key='\xd1\xfe\xfb\x7fH\xbf\xc8Q\x17-\xab\xc6\x80u2\xc2\xb6\n9\x00\x87\xa7\xa75'
+
+
+import user,idc,cabinet,server,job,code,duty

cmdb/app/cabinet.py

@@ -0,0 +1,71 @@
+#!/usr/bin/python
+#coding:utf-8
+
+from flask import render_template,request,redirect,session
+from . import app
+from config import *
+from utils import login_request
+import json
+import db
+
+app.config.from_object(Table)
+fields_idc=app.config.get('FIELDS_IDC')  
+fields_cabinet=app.config.get('FIELDS_CABINET')  
+
+@app.route('/cabinet/')
+@login_request.login_request
+def cabinet():
+    role = session.get('role')
+    cabinets = db.list('cabinet',fields_cabinet)
+    for i in cabinets:
+	idc = db.list('idc',fields_idc,i['idc_id'])
+	i['idc_id'] = idc['name']
+
+    return render_template("/cabinet/cabinetlist.html",cabinets = cabinets,role = role)
+
+@app.route('/cabinet_msg/')
+@login_request.login_request
+def cabinet_msg():
+    cabinets = db.list('cabinet',fields_cabinet)
+    return json.dumps({'result':cabinets}) 
+
+@app.route("/cabinetadd/",methods=['GET','POST'])
+@login_request.login_request
+def cabinetadd():
+    if request.method == 'GET':
+	return render_template('/cabinet/cabinetadd.html',info = session,role = session.get('role'))
+    if request.method == 'POST':
+	data = dict((k,v[0]) for k,v in dict(request.form).items())
+	l = []
+
+	for i in db.list('cabinet',fields_cabinet):
+	    l.append(i['name'])
+	if not data['name']:
+	    return json.dumps({'code':1,'errmsg':'name can not be null'})
+	elif data['name'] not in l:
+	    conditions = [ "%s='%s'" %  (k,v) for k,v in data.items()]
+	    db.add('cabinet',conditions)
+	    return json.dumps({'code':0,'result':'add cabinet success'})
+	return json.dumps({'code':1,'errmsg':'cabinet name is exist'})
+
+@app.route('/cabinet_update_msg/')
+@login_request.login_request
+def cabinet_update_msg():
+    id = request.args.get('id')
+    cabinet = db.list('cabinet',fields_cabinet,id)
+    return json.dumps({'code':0,'result':cabinet})
+
+@app.route('/cabinet_update/',methods=['GET','POST'])
+@login_request.login_request
+def cabinet_update():
+    data = dict((k,v[0]) for k,v in dict(request.form).items())
+    conditions = [ "%s='%s'" %  (k,v) for k,v in data.items()]
+    db.update('cabinet',conditions,data['id'])
+    return json.dumps({'code':0,'result':'update completed!'})
+
+@app.route('/cabinet_delete/',methods=['POST'])
+@login_request.login_request
+def cabinet_delete():
+    id = request.form.get('id')
+    db.delete('cabinet',id)
+    return json.dumps({'code':0,'result':'delete success!'})

cmdb/app/code.py

@@ -0,0 +1,131 @@
+#!/usr/bin/python
+#coding:utf-8
+
+from flask import render_template,request,redirect,session
+from . import app
+from config import *
+from utils import login_request
+from werkzeug import secure_filename
+import paramiko
+import json,os,sys,re,time
+import db
+import pysvn
+import zipfile
+
+reload(sys)
+sys.setdefaultencoding('utf-8')
+
+app.config.from_object(RemoteHost)
+app.config.from_object(Table)
+app.config.from_object(ProUrl)
+fields_code = app.config.get('FIELDS_CODE')
+url = app.config.get('URL') # 字典格式
+path = '/data/'
+hosts = []
+allfile = []
+
+for i in app.config:
+    if re.findall('HOST.',i):
+        hosts.append(app.config.get(i))
+    # hosts格式为[['192.168.1.100', 22, 'root', '123456'],['192.168.1.101', 22, 'root', '123456'],['192.168.1.102', 22, 'root', '123456']]
+
+def get_login(realm,username,may_save):
+    return True,'test','123456',True
+
+def svncheckout(url,where):
+    client = pysvn.Client()
+    client.callback_get_login = get_login
+    try:
+        client.checkout(url,where)
+    except Exception,e:
+        print 'Error: {}'.format(e)
+
+# 遍历目录中的所有文件
+#def dirlist(where):  
+#    filelist =  os.listdir(where)  
+#  
+#    for filename in filelist:  
+#        filepath = os.path.join(where, filename)  
+#        if os.path.isdir(filepath):  
+#            dirlist(filepath)  
+#        else:  
+#            allfile.append(filepath)  
+#    return allfile
+
+def trans(where,filename,host):
+    # 文件传输
+    tus = (host[0],host[1])
+    t = paramiko.Transport(tus)
+    t.connect(username=host[2],password=host[3])
+    sftp = paramiko.SFTPClient.from_transport(t)
+    sftp.put(where,filename)
+    t.close()
+	   
+def exec_comm(comm,host):
+    ssh = paramiko.SSHClient()
+    #comm = '/root/update.sh '+where
+
+    # 执行远程命令
+    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
+    ssh.connect(host[0],host[1],host[2],host[3],timeout=10)
+    stdin,stdout,stderr = ssh.exec_command(comm)
+    ssh.close()
+
+def zip_dir(dirname,zipfilename):
+    filelist = []
+    if os.path.isfile(dirname):
+        filelist.append(dirname)
+    else :
+        for root, dirs, files in os.walk(dirname):
+            for name in files:
+                filelist.append(os.path.join(root, name))
+         
+    zf = zipfile.ZipFile(zipfilename, "w", zipfile.zlib.DEFLATED)
+    for tar in filelist:
+        arcname = tar[len(dirname):]
+        #print arcname
+        zf.write(tar,arcname)
+    zf.close()
+
+@app.route('/code/',methods=['GET','POST'])
+@login_request.login_request
+def code():
+    role = session.get('role')
+    if request.method=='GET':
+	return render_template('/code/code.html',role=role)
+    else:
+	data = dict((k,v[0]) for k,v in dict(request.form).items()) # message, key, project
+	print data
+	key = data.pop('key')
+	project = data['project']
+	data['update_persion'] = session.get('name')
+	conditions = [ "%s='%s'" %  (k,v) for k,v in data.items()]
+	if key == 'mmnn88' and data['project']:
+	    try:
+		localtime = time.strftime('-%Y-%m-%d-%H:%M:%S')
+	        project_name = project+localtime # 例如: 'ecg-2016-12-07-10:00:37'
+		zip_name = project_name+'.zip'
+		print zip_name
+	        svncheckout(url[project],path+project_name) # co 到 '/data/ecg-2016-12-07-10:00:37'
+		os.chdir(path) # cd '/data'
+	  	zip_dir(project_name,zip_name)
+		for host in hosts:
+		    trans(zip_name,path+zip_name,host)
+		    exec_comm('/bin/bash /root/update.sh '+zip_name,host)
+    		db.add('code',conditions)
+    		return json.dumps({'code':0,'result':'更新成功'})
+	    except Exception, e:
+		errmsg = '失败信息 error: '+str(e)
+    		return json.dumps({'code':1,'errmsg':errmsg})
+	elif not data['project']:
+	    return json.dumps({'code':1,'errmsg':errmsg})
+	else:
+	    errmsg = '许可码无效!'
+	    return json.dumps({'code':1,'errmsg':errmsg})
+
+@app.route('/codelist/')
+@login_request.login_request
+def codelist():
+    role = session.get('role')
+    codes = db.list('code',fields_code)
+    return render_template("/code/codelist.html",codes = codes,role = role)

cmdb/app/duty.py

@@ -0,0 +1,68 @@
+#!/usr/bin/python
+#coding:utf-8
+
+from flask import render_template,request,redirect,session
+from . import app
+from hashlib import md5
+from config import * 
+from utils import login_request
+from datetime import date
+import json
+import db,time
+
+salt = '890iop*()'
+app.config.from_object(Table)
+fields_user = app.config.get('FIELDS_USER')
+
+def duty(day): # 查看星期几的值班人的编号
+    duty_dict = {}  # 带索引的值班人员字典
+    duty_week = {}  # k: 星期几 ,v: 为list 值班人 ,v[0][1] 表示第二周的星期一
+    duty_list = []  # 所有值班人员列表
+    users = db.list('users',fields_user)
+    for user in users:
+	if user['role'] == 'admin' and user['status'] == 0:
+	    duty_list.append(user['id'])
+    duty_list *= 5
+    duty_dict = { k:v for k,v in enumerate(duty_list)}
+    for k,v in duty_dict.items():
+	duty_week.setdefault(k,[])
+	duty_week[k%5].append(v)
+
+    week_num = (int(time.strftime('%W')))%(int(len(duty_list))/5) # 第几个星期 , 'int(len(duty_list))/5'周重置一次
+    return duty_week[day][week_num]
+
+@app.route("/dutyself/")
+@login_request.login_request
+def dutyself():
+    today = date.weekday(date.today()) # 今天是星期几
+    id = duty(today) 
+
+    user = db.list('users',fields_user,id)
+    role = session.get('role')
+    return render_template("/duty/dutyself.html",user = user,role = role)
+    
+@app.route('/dutylist/')
+@login_request.login_request
+def dutylist():
+    every_week = [] # 每周值班人汇总
+    role = session.get('role')
+    for i in range(5):
+        data = db.list('users',fields_user,duty(i))
+	if i == 0:
+	    data['week'] = '星期一'
+	    data['id'] = i
+	elif i == 1:
+	    data['week'] = '星期二'
+	    data['id'] = i
+	elif i == 2:
+	    data['week'] = '星期三'
+	    data['id'] = i
+	elif i == 3:
+	    data['week'] = '星期四'
+	    data['id'] = i
+	else:
+	    data['week'] = '星期五'
+	    data['id'] = i
+        every_week.append(data)
+         
+    return render_template("/duty/dutylist.html",users = every_week,role = role)