-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.py
135 lines (112 loc) · 4.25 KB
/
server.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
# _*_ coding:utf-8 _*_
import sys
from twisted.internet import reactor
from twisted.web.resource import Resource
from twisted.web.server import Site
try:
from database.conn import PsyBase
except:
pass
import json
import config
import logging
import re
from serch.serch import Serch, StaticFile, Logo
from util.common import arg_named
from api.api import Api
from api.weixin.auth import AuthWeiXin
back_data = "你好"
with open('honglou.txt') as f:
data = f.read()
data = data.split(' ')
back_data = list(set(data))
back_data.remove('')
print("-----------服务器启动")
class Root(Resource):
def __init__(self):
Resource.__init__(self)
self.putChild("ajax", App())
self.putChild("api", Api())
self.putChild("", AuthWeiXin(back_data))
self.putChild("search", Serch())
self.putChild("static", StaticFile())
self.putChild("logo", Logo())
class App(Resource):
def __init__(self):
Resource.__init__(self)
self.putChild("third", third())
self.putChild("userinfo", UserInfo())
self.putChild("auth", Auth())
self.putChild("register", Register())
def render_GET(self, request):
return "huangkaijie"
class Auth(Resource):
isLeaf = True
def render_POST(self, request):
phone_number = arg_named(request, 'phone_number', 0)
if phone_number == 0:
return json.dumps({"code": 20002, "msg": "参数错误"})
print(phone_number)
try:
user = PsyBase.find_user(phone_number)
if not user:
return json.dumps({"code": 20003, "msg": "用户未找到"})
return json.dumps({"phone_number": phone_number, "name": user['name'],
'intro': user['intro'],
"age": user['age'], "id": user['id'], "password": "123456","code": 10000})
except Exception as e:
print(e)
return json.dumps({"code":2004,"msg": "服务器错误"})
class Register(Resource):
isLeaf = True
def render_POST(self, request):
phone_number = arg_named(request, 'phone_number', 0)
password = arg_named(request, "password", None)
name = arg_named(request, "name", None)
if phone_number == 0 or password is None or name is None:
return json.dumps({"code": 20002, "msg": "参数错误"})
if len(str(phone_number)) != 11:
return json.dumps({"code": 20008,"msg": "手机号码不符合格式"})
try:
#return json.dumps({"phone_number": phone_number,"name": name, "age": 25, "id": 1, "password": password,"code": 10000})
code = PsyBase.insert_user(phone_number=phone_number,name=name,password=password)
print(code)
return str(code)
except Exception as e:
print(e)
return json.dumps({"code":2006,"msg": "注册失败"})
class UserInfo(Resource):
isLeaf = True
def render_GET(self, request):
phone_number = arg_named(request, 'phone_number', 0)
try:
user = PsyBase.find_user(phone_number)
if not user:
return json.dumps({"code": 20003, "msg": "用户未找到"})
return json.dumps({"phone_number": phone_number, "name": user['name'],
'intro': user['intro'],
"age": user['age'], "id": user['id'], "password": "123456","code": 10000})
except Exception as e:
print(e)
return json.dumps({"code": 2004, "msg": "服务器错误"})
class third(Resource):
isLeaf = True
def render_GET(self,request):
request.write({'name': '黄开杰'})
if __name__ == '__main__':
logfile = 'log'
# try:
# from processhtml.process_document import ProcessDocument
# ProcessDocument.create_index()
# except:
# pass
try:
import platform
if 'linux' in platform.system().lower():
logfile = '/home/log/twistserverlog/log'
except:
pass
formats = '[%(asctime)s] [%(filename)s L%(lineno)d] [%(levelname)s] %(message)s'
logging.basicConfig(level=logging.INFO, format=formats, filename=logfile)
reactor.listenTCP(8888, Site(third()))
reactor.run()