该楼层疑似违规已被系统折叠 隐藏此楼查看此楼

#coding=utf-8

from flask import Flask

from flask import send_from_directory

from flask import request

import MySQLdb

import json

import os

import sys

import time

app = Flask(__name__, static_url_path='')

import applly.db.creat#返回首页

@app.route('/')

def index():

return app.send_static_file('index.html')#添加客户资源

@app.route('/kehuziyuan/add',methods=['post'])

def kehuadd(): # 创建数据库连接

conn = MySQLdb.connect(host='127.0.0.1', user='root', passwd='root', port=3306, charset='utf8')

conn.select_db('Server_DataBase');

cursor = conn.cursor(MySQLdb.cursors.DictCursor) # 查询当前最大ID并设置当前插入数据的ID

cursor.execute('SELECT MAX(ID) FROM `kehu`')

rwa = cursor.fetchall()

ID = rwa[0].get('MAX(ID)') if ID != None:

ID = str(ID + 1)

else:

ID = str(1001)

print("ID=", ID) uid = request.form['uid']#客户分类

name = request.form['name'] # 客户名字

head = request.form['head'] # 经营范围

phone = request.form['phone'] # 联系方式 s1 = "INSERT INTO `kehu` (`ID`,`uid`,`name`,`head` ,`phone`) VALUES ("

sql = s1 + "'" + ID + "','" + uid + "','"+name +"','"+ head + "','" + phone + "')" print sql

# 向数据库提交拼接好的插入数据的SQL

cursor.execute(sql)

conn.commit() # 关闭数据库连接

cursor.close()

conn.close() # 插入成功返回1

return '增加成功'#查询客户资源

@app.route('/kehuziyuan/find',methods=['post'])

def kehuFind(): #创建数据库连接并查询当前最大的ID

conn = MySQLdb.connect(host='127.0.0.1', user='root',passwd='root',port=3306,charset='utf8')

conn.select_db('Server_DataBase');

cursor = conn.cursor(MySQLdb.cursors.DictCursor) #拼接sql

sql="SELECT * FROM kehu"

print sql

#查询

cursor.execute(sql)

rwa=cursor.fetchall() #关闭数据库连接

cursor.close()

conn.close() return json.dumps({"msgid":100,'msg':rwa,"errormsg":''})#增加新闻

@app.route('/xinwen/add',methods=['post'])

def xinwenAdd(): # 创建数据库连接

conn = MySQLdb.connect(host='127.0.0.1', user='root', passwd='root', port=3306, charset='utf8')

conn.select_db('Server_DataBase');

cursor = conn.cursor(MySQLdb.cursors.DictCursor) # 查询当前最大ID并设置当前插入数据的ID

cursor.execute('SELECT MAX(ID) FROM `xinwen`')

rwa = cursor.fetchall()

ID = rwa[0].get('MAX(ID)')

print ID

if ID != None:

ID = str(ID + 1)

else:

ID = str(1001)

print("ID=", ID) name = request.form['name'] # 新闻标题

name2 = request.form['name2'] # 新闻副标题

art = request.form['art'] # 正文

times = time.strftime("%Y/%m/%d")

print str(times) s1 = "INSERT INTO `xinwen` (`ID`,`name`,`name2`,`art`,`time`) VALUES ("

sql = s1 + "'" + ID + "','" + name + "','"+name2+"','"+ art +"','"+str(times)+ "')" print sql

# 向数据库提交拼接好的插入数据的SQL

cursor.execute(sql)

conn.commit() # 关闭数据库连接

cursor.close()

conn.close() # 插入成功返回1

return '增加成功'#查询新闻

@app.route('/xinwen/find',methods=['post'])

def xinwenFind():

#创建数据库连接并查询当前最大的ID

conn = MySQLdb.connect(host='127.0.0.1', user='root',passwd='root',port=3306,charset='utf8')

conn.select_db('Server_DataBase');

cursor = conn.cursor(MySQLdb.cursors.DictCursor) #拼接sql

sql="SELECT * FROM xinwen"

#查询

cursor.execute(sql)

rwa=cursor.fetchall() #关闭数据库连接

cursor.close()

conn.close()

print rwa[0]['time']

return json.dumps({"msgid":100,'msg':rwa,"errormsg":''})#查询新闻详情

@app.route('/xinwen/finds',methods=['post'])

def xinwenFinds():

id = request.form['id']

#创建数据库连接并查询当前最大的ID

conn = MySQLdb.connect(host='127.0.0.1', user='root',passwd='root',port=3306,charset='utf8')

conn.select_db('Server_DataBase');

cursor = conn.cursor(MySQLdb.cursors.DictCursor) #拼接sql

sql="SELECT * FROM xinwen WHERE id="+id #查询

cursor.execute(sql)

rwa=cursor.fetchall() #关闭数据库连接

cursor.close()

conn.close() return json.dumps({"msgid":100,'msg':rwa,"errormsg":''})#文件上传

@app.route('/wendang/up',methods=['post'])

def backimgup():

file_path = os.path.dirname(sys.argv[0])+"/static/stm"

files = request.files.getlist("files")#接收文件 filename = ""

for fil in files:

finame = fil.filename if not files:

return json.dumps({"msgid":400,'msg':'',"errormsg":'no'})

#检查路径

check = os.path.exists(file_path)

if not check:

os.makedirs(file_path) s1 = "file_"

count = 0

for root, dirs, files in os.walk(file_path):

for each in files:

count += 1

name = s1 + str(count) + "." + finame.split(".")[1]

fil.save(os.path.join(file_path, name)) # 创建数据库连接

conn = MySQLdb.connect(host='127.0.0.1', user='root', passwd='root', port=3306, charset='utf8')

conn.select_db('Server_DataBase');

cursor = conn.cursor(MySQLdb.cursors.DictCursor) # 查询当前最大ID并设置当前插入数据的ID

cursor.execute('SELECT MAX(ID) FROM `wendang`')

rwa = cursor.fetchall()

ID = rwa[0].get('MAX(ID)')

if ID != None:

ID = str(ID + 1)

else:

ID = str(1001)

s1 = "INSERT INTO `wendang` (`ID`,`fileName`,`name`) VALUES ("

sql = s1 + "'" + ID + "','" + name + "','"+finame+"')" print sql

# 向数据库提交拼接好的插入数据的SQL

cursor.execute(sql)

conn.commit() # 关闭数据库连接

cursor.close()

conn.close() # 插入成功返回1

return '增加成功'#查询文件列表

@app.route('/wendang/find',methods=['post'])

def wendangFind():

#创建数据库连接并查询当前最大的ID

conn = MySQLdb.connect(host='127.0.0.1', user='root',passwd='root',port=3306,charset='utf8')

conn.select_db('Server_DataBase');

cursor = conn.cursor(MySQLdb.cursors.DictCursor) #拼接sql

sql="SELECT * FROM wendang"

print sql

#查询

cursor.execute(sql)

rwa=cursor.fetchall() #关闭数据库连接

cursor.close()

conn.close() return json.dumps({"msgid":100,'msg':rwa,"errormsg":''})#文件下载

@app.route('/downLoad')

def download():

id = request.args.get('id') #创建数据库连接并查询当前最大的ID

conn = MySQLdb.connect(host='127.0.0.1', user='root',passwd='root',port=3306,charset='utf8')

conn.select_db('Server_DataBase');

cursor = conn.cursor(MySQLdb.cursors.DictCursor) #拼接sql

sql="SELECT * FROM wendang WHERE id="+str(id)

print sql

#查询

cursor.execute(sql)

rwa=cursor.fetchall()

print rwa

if not rwa:

return '文件不存在，请联系管理员'

#关闭数据库连接

cursor.close()

conn.close() filename = rwa[0]['fileName']

if os.path.isfile(os.path.join(os.path.dirname(sys.argv[0])+"/static/stm", filename)):

return send_from_directory(os.path.dirname(sys.argv[0])+"/static/stm", filename, as_attachment=True)

return '404'

if __name__ == '__main__':

app.run(host='0.0.0.0',port=80,debug=False)