import threading
from runtime import StockRuntime
from data_center import DataCenter
import datetime


def thread_Timer(data_center):

    runtime = StockRuntime()
    now_time = datetime.date.today()
    all_stock = data_center.query_all_stock(now_time.strftime('%Y-%m-%d'))
    #all_stock = bs.get_all_stock('2022-06-27')
    predict = data_center.get_predict_date()
    update_stock = []
    for i in range(len(all_stock)):
        item = all_stock[i]
        if item in predict.keys() :
            predict_time = predict[item]
            if predict_time < now_time :
                update_stock.append(item)
        else:
            update_stock.append(item)
        
    if runtime.update(update_stock):
        
        timer = threading.Timer(72000, thread_Timer,data_center)
    else:
        timer = threading.Timer(600, thread_Timer,data_center)
    timer.start()

if __name__ == "__main__":
    data_center = DataCenter()
    timer = threading.Timer(1, thread_Timer,data_center)
    timer.start()