from flask import Flask

# 接口文件
from api.common import common_api
from api.analysis import analysis_api
from api.instruction import instruction_api
from api.time_padding import time_padding_api
from api.fiber_analysis import fiber_analysis_api
from api.space_padding import space_padding_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(analysis_api)
app.register_blueprint(instruction_api)
app.register_blueprint(time_padding_api)
app.register_blueprint(fiber_analysis_api)
app.register_blueprint(space_padding_api)


class Config(object):
    """配置参数"""
    # 设置连接数据库的URL
    user = 'ai_underground'
    password = 'McXyS8CHZrLF8ExJ'
    database = 'ai_underground'
    app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://%s:%s@39.97.209.211: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()