#!/usr/bin/env python3

from mymodules import ipnet
from mymodules import mylog
from mymodules import mysql_oper
import time

# 一天前的日期
data_time = time.strftime('%Y%m%d',time.localtime(time.time()-93600))
db_result = mysql_oper.operate('select * from portflow_day where DATE="%s"'%(data_time),None)
if not db_result:
    result_data = ipnet.download_portflow_d(data_time)
    if result_data:
        print('流量表，日，写入数据库%s'%data_time)
        mysql_oper.operate("insert into portflow_day (DATE,ipman_out_used,ipman_local_huiju_used,ipman_local_jieru_limitsum,iptv_out,iptv_server,cmnet_out_used,ar_out_used,psce_used,csce_used) value (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)",result_data)

db_result = mysql_oper.operate('select * from card_used_al where DATE="%s"'%(data_time+'21'),None)
if not db_result:
    result_data = ipnet.download_card_used_al(data_time+'21')
    if result_data:
        print('阿卡，日，写入数据库%s'%data_time)
        mysql_oper.operate("insert into card_used_al (DATE,device_name,slot,used) value (%s,%s,%s,%s)",result_data)

db_result = mysql_oper.operate('select * from card_used_hw where DATE="%s"'%(data_time),None)
if not db_result:
    result_data = ipnet.download_card_used_hw_d(data_time)
    if result_data:
        print('华为，日，写入数据库%s'%data_time)
        mysql_oper.operate("insert into card_used_hw (DATE,device_name,slot,maxuser,sn,used) value (%s,%s,%s,%s,%s,%s)",result_data)

data_time = time.strftime('%Y%m%d',time.localtime(time.time()-93600))
db_result = mysql_oper.operate('select * from monitor_port where DATE="%s"'%(data_time),None)
if not db_result:
    monitor_list = ipnet.get_port_limit(data_time)
    if monitor_list == False:
        ipnet.download_portflow_d(data_time)
        monitor_list = ipnet.get_port_limit(data_time)
        if monitor_list:
            for i in monitor_list:
                mysql_oper.operate("insert into monitor_port (date,device_type,device_name,port_name,port_describe,port_name2,used) value (%s,%s,%s,%s,%s,%s,%s)",i)
    elif monitor_list:
        for i in monitor_list:
            mysql_oper.operate("insert into monitor_port (date,device_type,device_name,port_name,port_describe,port_name2,used) value (%s,%s,%s,%s,%s,%s,%s)",i)

db_result = mysql_oper.operate('select * from monitor_card_al where DATE="%s"'%(data_time+'21'),None)
if not db_result:
    monitor_list = ipnet.get_card_al_limit(data_time)
    if monitor_list == False:
        ipnet.download_card_used_al(data_time+'21')
        monitor_list = ipnet.get_card_al_limit(data_time+'21')
        if monitor_list:
            for i in monitor_list:
                mysql_oper.operate("insert into monitor_card_al (date,device_name,slot,used) value (%s,%s,%s,%s)",i)
    elif monitor_list:
        for i in monitor_list:
            mysql_oper.operate("insert into monitor_card_al (date,device_name,slot,used) value (%s,%s,%s,%s)",i)

db_result = mysql_oper.operate('select * from monitor_card_hw where DATE="%s"'%(data_time),None)
if not db_result:
    monitor_list = ipnet.get_card_hw_limit(data_time)
    if monitor_list == False:
        ipnet.download_card_used_hw_d(data_time)
        monitor_list = ipnet.get_card_hw_limit(data_time)
        if monitor_list:
            for i in monitor_list:
                mysql_oper.operate("insert into monitor_card_hw (date,device_name,slot,maxuser,sn,used) value (%s,%s,%s,%s,%s,%s)",i)
    elif monitor_list:
        for i in monitor_list:
            mysql_oper.operate("insert into monitor_card_hw (date,device_name,slot,maxuser,sn,used) value (%s,%s,%s,%s,%s,%s)",i)


# 小时的数据
def get_hour(data_time):
    db_result = mysql_oper.operate('select * from portflow_hour where DATE="%s"'%(data_time),None)
    if not db_result:
        result_data = ipnet.download_portflow_h(data_time)
        if result_data:
            print('流量表，小时，写入数据库%s'%data_time)
            mysql_oper.operate("insert into portflow_hour (DATE,ipman_out_used,ipman_local_huiju_used,ipman_local_jieru_limitsum,iptv_out,iptv_server,cmnet_out_used,ar_out_used,psce_used,csce_used) value (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)",result_data)

    db_result = mysql_oper.operate('select * from card_used_al where DATE="%s"'%(data_time),None)
    if not db_result:
        result_data = ipnet.download_card_used_al(data_time)
        if result_data:
            print('阿卡，小时，写入数据库%s'%data_time)
            mysql_oper.operate("insert into card_used_al (DATE,device_name,slot,used) value (%s,%s,%s,%s)",result_data)
    
    db_result = mysql_oper.operate('select * from card_used_hw where DATE="%s"'%(data_time),None)
    if not db_result:
        result_data = ipnet.download_card_used_hw_h(data_time)
        if result_data:
            print('华为，小时，写入数据库%s'%data_time)
            mysql_oper.operate("insert into card_used_hw (DATE,device_name,slot,maxuser,sn,used) value (%s,%s,%s,%s,%s,%s)",result_data)

def get_monitor_hour(data_time):
    db_result = mysql_oper.operate('select * from monitor_port where DATE="%s"'%(data_time),None)
    if not db_result:
        monitor_list = ipnet.get_port_limit(data_time)
        if monitor_list == False:
            ipnet.download_portflow_h(data_time)
            monitor_list = ipnet.get_port_limit(data_time)
            if monitor_list:
                for i in monitor_list:
                    mysql_oper.operate("insert into monitor_port (date,device_type,device_name,port_name,port_describe,port_name2,used) value (%s,%s,%s,%s,%s,%s,%s)",i)
        elif monitor_list:
            for i in monitor_list:
                mysql_oper.operate("insert into monitor_port (date,device_type,device_name,port_name,port_describe,port_name2,used) value (%s,%s,%s,%s,%s,%s,%s)",i)
    
    db_result = mysql_oper.operate('select * from monitor_card_al where DATE="%s"'%(data_time),None)
    if not db_result:
        monitor_list = ipnet.get_card_al_limit(data_time)
        if monitor_list == False:
            ipnet.download_card_used_al(data_time)
            monitor_list = ipnet.get_card_al_limit(data_time)
            if monitor_list:
                for i in monitor_list:
                    mysql_oper.operate("insert into monitor_card_al (date,device_name,slot,used) value (%s,%s,%s,%s)",i)
        elif  monitor_list:
            for i in monitor_list:
                mysql_oper.operate("insert into monitor_card_al (date,device_name,slot,used) value (%s,%s,%s,%s)",i)
    
    db_result = mysql_oper.operate('select * from monitor_card_hw where DATE="%s"'%(data_time),None)
    if not db_result:
        monitor_list = ipnet.get_card_hw_limit(data_time)
        if monitor_list == False:
            ipnet.download_card_used_hw_h(data_time)
            monitor_list = ipnet.get_card_hw_limit(data_time)
            if monitor_list:
                for i in monitor_list:
                    mysql_oper.operate("insert into monitor_card_hw (date,device_name,slot,maxuser,sn,used) value (%s,%s,%s,%s,%s,%s)",i)
        elif monitor_list:
            for i in monitor_list:
                mysql_oper.operate("insert into monitor_card_hw (date,device_name,slot,maxuser,sn,used) value (%s,%s,%s,%s,%s,%s)",i)

#need_hour = ['17','20','11']
need_hour = ["00","01","02","03","04","05","06","07","08","09","10","11","12","13","14","15","16","17","18","19","20","21","22","23"]
data_hour=time.strftime('%H',time.localtime(time.time()-7200))
data_time = time.strftime('%Y%m%d',time.localtime(time.time()-7200))
for i in need_hour:
    if int(i) <= int(data_hour):
        get_hour(data_time+i)
        get_monitor_hour(data_time+i)
    else:
        pass