# coding: utf8
from __future__ import absolute_import
from apps import app
from utils.io import scan_apps
from utils.db import execute, executemany
import subprocess
from utils.log import Log

HOST = "localhost"
PORT = 5000


@app.route('/')
def hello_world():
    app.logger.error("aaa")
    return 'Hello World!'


@app.route("/refresh")
def refresh():
    """更新指令"""
    _apps, _commands = scan_apps()
    execute("DELETE FROM apps")
    execute("DELETE FROM commands")

    insert_sql_apps = "INSERT INTO apps(appid, appname) VALUES(?,?)"
    executemany(insert_sql_apps, _apps)

    insert_sql_commands = "INSERT INTO commands(name, commands, action, appid) " + \
                          "VALUES(?,?,?,?)"
    executemany(insert_sql_commands, _commands)

    return "刷新成功！"


@app.route("/reboot")
def reboot():
    """重启web"""

    def _exec(script):
        """执行shell脚本"""
        subprocess.call(script,
                        shell=True,
                        stdout=subprocess.PIPE,
                        stderr=subprocess.PIPE)

    try:
        # 参考1，https://blog.csdn.net/weixin_42840933/article/details/85780125
        # 参考2，https://www.jianshu.com/p/bdfddc6ed505
        _exec("nohup sh ./reboot.sh > ./logs/nohup.log 2>&1 &")
        app.logger.info("重启成功")
    except Exception as error:
        app.logger.error(f"重启失败，报错：{error}")
        # 以下内容可能不会被display
        return "重启失败"
    return "重启成功"


if __name__ == '__main__':
    refresh()
    app.logger.addHandler(Log().handler)
    app.run(host=HOST, port=PORT)