毕业设计，课程设计-基于Tornado做的有登录注册、新闻发布、评论、权限管理、分享、OA信息发布、实时聊天等功能的管理系统

#-*- coding: UTF-8 -*- # Copyright (c) 2014 The CCP project authors. All Rights Reserved. # # Use of this source code is governed by a Beijing Speedtong Information Technology Co.,Ltd license # that can be found in the LICENSE file in the root of the web site. # # http://www.yuntongxun.com # # An additional intellectual property rights grant can be found # in the file PATENTS. All contributing project authors may # be found in the AUTHORS file in the root of the source tree. import md5 import base64 import datetime import urllib2 import json from xmltojson import xmltojson from xml.dom import minidom class REST: AccountSid='' AccountToken='' AppId='' SubAccountSid='' SubAccountToken='' ServerIP='' ServerPort='' SoftVersion='' Iflog=True #是否打印日志 Batch='' #时间戳 BodyType = 'xml'#包体格式，可填值：json 、xml # 初始化 # @param serverIP 必选参数 服务器地址 # @param serverPort 必选参数 服务器端口 # @param softVersion 必选参数 REST版本号 def __init__(self,ServerIP,ServerPort,SoftVersion): self.ServerIP = ServerIP; self.ServerPort = ServerPort; self.SoftVersion = SoftVersion; # 设置主帐号 # @param AccountSid 必选参数 主帐号 # @param AccountToken 必选参数 主帐号Token def setAccount(self,AccountSid,AccountToken): self.AccountSid = AccountSid; self.AccountToken = AccountToken; # 设置子帐号 # # @param SubAccountSid 必选参数 子帐号 # @param SubAccountToken 必选参数 子帐号Token def setSubAccount(self,SubAccountSid,SubAccountToken): self.SubAccountSid = SubAccountSid; self.SubAccountToken = SubAccountToken; # 设置应用ID # # @param AppId 必选参数 应用ID def setAppId(self,AppId): self.AppId = AppId; def log(self,url,body,data): print('这是请求的URL：') print (url); print('这是请求包体:') print (body); print('这是响应包体:') print (data); print('********************************') # 创建子账号 # @param friendlyName 必选参数 子帐号名称 def CreateSubAccount(self, friendlyName): self.accAuth() nowdate = datetime.datetime.now() self.Batch = nowdate.strftime("%Y%m%d%H%M%S") #生成sig signature = self.AccountSid + self.AccountToken + self.Batch; sig = md5.new(signature).hexdigest().upper() #拼接URL url = "https://"+self.ServerIP + ":" + self.ServerPort + "/" + self.SoftVersion + "/Accounts/" + self.AccountSid + "/SubAccounts?sig=" + sig #生成auth src = self.AccountSid + ":" + self.Batch; auth = base64.encodestring(src).strip() req = urllib2.Request(url) self.setHttpHeader(req) req.add_header("Authorization", auth) #xml格式 body ='''<?xml version="1.0" encoding="utf-8"?><SubAccount><appId>%s</appId>\ <friendlyName>%s</friendlyName>\ </SubAccount>\ '''%(self.AppId, friendlyName) if self.BodyType == 'json': #json格式 body = '''{"friendlyName": "%s", "appId": "%s"}'''%(friendlyName,self.AppId) data='' req.add_data(body) try: res = urllib2.urlopen(req); data = res.read() res.close() if self.BodyType=='json': #json格式 locations = json.loads(data) else: #xml格式 xtj=xmltojson() locations=xtj.main(data) if self.Iflog: self.log(url,body,data) return locations except Exception, error: if self.Iflog: self.log(url,body,data) return {'172001':'网络错误'} # 获取子帐号 # @param startNo 可选参数 开始的序号，默认从0开始 # @param offset 可选参数 一次查询的最大条数，最小是1条，最大是100条 def getSubAccounts(self, startNo,offset): self.accAuth() nowdate = datetime.datetime.now() self.Batch = nowdate.strftime("%Y%m%d%H%M%S") #生成sig signature = self.AccountSid + self.AccountToken + self.Batch; sig = md5.new(signature).hexdigest().upper() #拼接URL url = "https://"+self.ServerIP + ":" + self.ServerPort + "/" + self.SoftVersion + "/Accounts/" + self.AccountSid + "/GetSubAccounts?sig=" + sig #生成auth src = self.AccountSid + ":" + self.Batch; auth = base64.encodestring(src).strip() req = urllib2.Request(url) self.setHttpHeader(req) req.add_header("Authorization", auth) #xml格式 body ='''<?xml version="1.0" encoding="utf-8"?><SubAccount><appId>%s</appId>\ <startNo>%s</startNo><offset>%s</offset>\ </SubAccount>\ '''%(self.AppId, startNo, offset) if self.BodyType == 'json': #json格式 body = '''{"appId": "%s", "startNo": "%s", "offset": "%s"}'''%(self.AppId,startNo,offset) data='' req.add_data(body) try: res = urllib2.urlopen(req); data = res.read() res.close() if self.BodyType=='json': #json格式 locations = json.loads(data) else: #xml格式 xtj=xmltojson() locations=xtj.main(data) if self.Iflog: self.log(url,body,data) return locations except Exception, error: if self.Iflog: self.log(url,body,data) return {'172001':'网络错误'} # 子帐号信息查询 # @param friendlyName 必选参数 子帐号名称 def querySubAccount(self, friendlyName): self.accAuth() nowdate = datetime.datetime.now() self.Batch = nowdate.strftime("%Y%m%d%H%M%S") #生成sig signature = self.AccountSid + self.AccountToken + self.Batch; sig = md5.new(signature).hexdigest().upper() #拼接URL url = "https://"+self.ServerIP + ":" + self.ServerPort + "/" + self.SoftVersion + "/Accounts/" + self.AccountSid + "/QuerySubAccountByName?sig=" + sig #生成auth src = self.AccountSid + ":" + self.Batch; auth = base64.encodestring(src).strip() req = urllib2.Request(url) self.setHttpHeader(req) req.add_header("Authorization", auth) #创建包体 body ='''<?xml version="1.0" encoding="utf-8"?><SubAccount><appId>%s</appId>\ <friendlyName>%s</friendlyName>\ </SubAccount>\ '''%(self.AppId, friendlyName) if self.BodyType == 'json': body = '''{"friendlyName": "%s", "appId": "%s"}'''%(friendlyName,self.AppId) data='' req.add_data(body) try: res = urllib2.urlopen(req); data = res.read() res.close() if self.BodyType=='json': #json格式 locations = json.loads(data) else: #xml格式 xtj=xmltojson() locations=xtj.main(data) if self.Iflog: self.log(url,body,data) return locations except Exception, error: if s