DIALECT = 'mysql'
DRIVER = 'pymysql'
USERNAME = 'root'
PASSWORD = '123456'
HOST = '127.0.0.1'
PORT = '3306'
DATABASE = 'tgcrm'
# mysql 不會認(rèn)識utf-8,而需要直接寫成utf8
SQLALCHEMY_DATABASE_URI = "{}+{}://{}:{}@{}:{}/{}?charset=utf8".format(DIALECT, DRIVER, USERNAME, PASSWORD, HOST, PORT,
                                                                       DATABASE)
SQLALCHEMY_TRACK_MODIFICATIONS = False
SQLALCHEMY_ECHO = True
# 加載密鑰
key_access = '&^_^&protect*py_&^_^&'

from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()

from flask import Flask
# 引用數(shù)據(jù)庫啟動文件
from mapper.exts import db
# 引用數(shù)據(jù)庫配置文件
import config
# 引用數(shù)據(jù)庫
from controller.user_controller import *
app = Flask(__name__)
app.config.from_object(config)
db.init_app(app)
app.register_blueprint(user, url_prefix="/user")
# 全局?jǐn)r截器校驗(yàn)token
@app.before_request
def before():
    key = str(request.headers.get('TOKEN'))
    if key != format(config.key_access):
        return 'Password error'
    else:
        pass
if __name__ == '__main__':
    app.run(host='0.0.0.0', port=8060)

# 添加 http://127.0.0.1:5000/user/add/2/1
@user.route('/add/<username>/<pwd>')
def add_user(username, pwd):
    print(username, pwd)
    userinfo = User(username=username, pwd=pwd)
    db.session.add(userinfo)
    db.session.commit()
    # # 接受前端發(fā)來的數(shù)據(jù)
    # data = json.loads(request.form.get('data'))
    #
    # # lesson: "Operation System"
    # # score: 100
    # lesson = data["lesson"]
    # score = data["score"]
    #
    # # 自己在本地組裝成Json格式,用到了flask的jsonify方法
    # info = dict()
    # info['name'] = "pengshuang"
    # info['lesson'] = lesson
    # info['score'] = score
    # return jsonify(info)
    return jsonify("ADD_SUCCESS")

@user.route('/delete/<int:id>')
def delete_user(id):
    print(id)
    # 第一種
    user1 = User.query.filter().first()
    print(user1.id)
    db.session.delete(user1)
    db.session.commit()
    # 第二種
    user2 = User.query.filter(User.id == 2).delete()
    db.session.commit()
    return jsonify("DELETE_SUCCESS")

@user.route('/update/<int:id>')
def update_user(id):
    user1 = User.query.filter(User.id == id).first()
    user1.username = "我是修改后的"
    db.session.merge(user1)
    db.session.commit()
    return jsonify("UPDATE_SUCCESS")

@user.route('/list')
def list_users():
    users = User.query.all()
    print(users)
    users_output = []
    for user in users:
        users_output.append(user.to_json())
    return jsonify(users_output)

@user.route('/loadUserPage/<int:page>/<int:per_page>')
def list_user(page, per_page):
    """ 用戶分頁 """
    # 每一頁的數(shù)據(jù)大小-per_page 頁碼-page
    # 1. 查詢用戶信息
    user = User.query
    # 2. 準(zhǔn)備分頁的數(shù)據(jù)
    print(page, per_page)
    user_page_data = user.paginate(page, per_page=per_page)
    users_output = []
    for user in user_page_data.items:
        users_output.append(user.to_json())
    print("當(dāng)前頁的數(shù)據(jù)列表", users_output)
    print("是否有上一頁", user_page_data.has_prev)
    print("是否下一頁", user_page_data.has_next)
    print("上一頁的頁碼", user_page_data.prev_num)
    print("下一頁的頁碼", user_page_data.next_num)
    print("總記錄數(shù)", user_page_data.total)
    print("總頁數(shù)", user_page_data.pages)
    return jsonify(users_output)
""" 輸出
當(dāng)前頁的數(shù)據(jù)列表 [{'pwd': '2', 'id': 2, 'username': '2', 'nick': '2'}]
是否有上一頁 True
是否下一頁 True
上一頁的頁碼 1
下一頁的頁碼 3
總記錄數(shù) 7
總頁數(shù) 7
"""

from controller.user_controller import user
app = Flask(__name__)
app.config.from_object(config)
db.init_app(app)
app.register_blueprint(user, url_prefix="/user")

from flask import Blueprint, jsonify, request, json
user = Blueprint('user', __name__)
# 查詢?nèi)?http://127.0.0.1:5000/user/list
@user.route('/list')
def list_users():
    users = User.query.all()
    print(users)
    users_output = []
    for user in users:
        users_output.append(user.to_json())
    return jsonify(users_output)

# 引用配置文件
import config
# 全局?jǐn)r截器校驗(yàn)token
@app.before_request
def before():
    key = str(request.headers.get('TOKEN'))
    if key != format(config.key_access):
        return 'Password error'
    else:
        pass

# 加載密鑰
key_access = '&^_^&protect*py_&^_^&'