from flask import Flask

from api.common import common_api
from api.create import create_api
from api.entry import entry_api
from api.execute import execute_api
from api.code import code_api
from api.demo import demo_api

from flask_cors import CORS
from flask_apscheduler import APScheduler
from apscheduler.schedulers.background import BackgroundScheduler

from flask_sqlalchemy import SQLAlchemy
from db_model.exts import db
from jobs import delete_job
import pymysql

pymysql.install_as_MySQLdb()

app = Flask(__name__)
CORS(app, supports_credentials=True)

app.register_blueprint(common_api)
app.register_blueprint(entry_api)
app.register_blueprint(create_api)
app.register_blueprint(execute_api)
app.register_blueprint(demo_api)
app.register_blueprint(code_api)


class Config(object):
    """配置参数"""
    # 设置连接数据库的URL
    user = 'ai_guangxi'
    password = '83DphxmHNcXpZrAN'
    database = 'ai_guangxi'
    app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://%s:%s@182.92.122.168:3306/%s' % (user, password, database)
    # app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://%s:%s@localhost:3306/%s' % (user, password, database)

    # 设置sqlalchemy自动更跟踪数据库
    SQLALCHEMY_TRACK_MODIFICATIONS = True
    # 防止超时
    SQLALCHEMY_POOL_RECYCLE = 1
    SQLALCHEMY_POOL_SIZE = 1000

    # 查询时会显示原始SQL语句
    app.config['SQLALCHEMY_ECHO'] = False

    # 禁止自动提交数据处理
    app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = False

    # 定时任务，定时删除文件
    JOBS = [
        {
            'id': 'delete_job',  # 任务id
            'func': '__main__:delete_job',  # 删除任务程序
            'args': None,  # 执行程序参数
            'trigger': 'interval',  # 任务执行类型，定时器
            # 'seconds': 5,  # 任务执行时间，单位秒，10小时清除一次
            'seconds': 36000,  # 任务执行时间，单位秒，10小时清除一次
        }
    ]
    SCHEDULER_API_ENABLED = True
    SCHEDULER_TIMEZONE = "Asia/Shanghai"


# 读取配置
app.config.from_object(Config)

db.init_app(app)

if __name__ == '__main__':
    scheduler = APScheduler()  # 实例化APScheduler
    scheduler.init_app(app)  # 把任务列表载入实例flask
    scheduler.start()  # 启动任务计划
    app.run(host='0.0.0.0', debug=False, port=10492)
    # app.run()