#!//bin/env python
# coding:utf-8
from multiprocessing import Process
import _thread as thread
import include.functions as func
import os
import sys
import string
import time
import datetime
import logging
import logging.config
logging.config.fileConfig("etc/logger.ini")
logger = logging.getLogger("lepus")
path = './include'
sys.path.insert(0, path)

dbhost = func.get_config('monitor_server', 'host')
dbport = func.get_config('monitor_server', 'port')
dbuser = func.get_config('monitor_server', 'user')
dbpasswd = func.get_config('monitor_server', 'passwd')
dbname = func.get_config('monitor_server', 'dbname')


def check_os(ip, community, filter_os_disk, tags):
    func.mysql_exec(
        "insert into os_status_history select *, LEFT(REPLACE(REPLACE(REPLACE(create_time,'-',''),' ',''),':',''),12) from os_status where ip='%s';" % (ip), '')
    func.mysql_exec(
        "insert into os_disk_history select *, LEFT(REPLACE(REPLACE(REPLACE(create_time,'-',''),' ',''),':',''),12) from os_disk where ip='%s';" % (ip), '')
    func.mysql_exec(
        "insert into os_diskio_history select *, LEFT(REPLACE(REPLACE(REPLACE(create_time,'-',''),' ',''),':',''),12) from os_diskio where ip='%s';" % (ip), '')
    func.mysql_exec(
        "insert into os_net_history select *, LEFT(REPLACE(REPLACE(REPLACE(create_time,'-',''),' ',''),':',''),12) from os_net where ip='%s';" % (ip), '')
    func.mysql_exec("delete from os_status where ip='%s'" % (ip), '')
    func.mysql_exec("delete from os_disk where ip='%s'" % (ip), '')
    func.mysql_exec("delete from os_diskio where ip='%s'" % (ip), '')
    func.mysql_exec("delete from os_net where ip='%s'" % (ip), '')

    command = "sh check_os.sh"
    try:
        os.system("%s %s %s %s %s %s %s %s %s %s" % (command, ip, dbhost,
                                                     dbport, dbuser, dbpasswd, dbname, community, filter_os_disk, tags))
        logger.info("%s:%s statspack complete." % (dbhost, dbport))

    except Exception as e:
        print(e)
        logger.info("%s:%s statspack error: %s" % (dbhost, dbport, e))
        sys.exit(1)
    finally:
        sys.exit(1)


def main():
    # get os servers list
    servers = func.mysql_query(
        "select host,community,filter_os_disk,tags from db_servers_os where is_delete=0 and monitor=1;")

    logger.info("check os controller started.")
    if servers:
        for row in servers:
            host = row[0]
            community = row[1]
            filter_os_disk = row[2]
            tags = row[3]
            if host != '':
                thread.start_new_thread(
                    check_os, (host, community, filter_os_disk, tags))
                time.sleep(1)
    else:
        logger.warning("check os: not found any servers")
    logger.info("check os controller finished.")


if __name__ == '__main__':
    main()