定时强制更新K线

Administrator

2 天以前 d73df3ed85355d7877d9d4ff96af105d7a329b99

定时强制更新K线

 servers/huaxin_trade_server.py

@@ -1102,10 +1102,9 @@
        # 更新K线
        schedule.every().day.at("08:00:01").do(history_k_data_manager.update_history_k_bars)
        schedule.every().day.at("08:30:01").do(history_k_data_manager.update_history_k_bars)
        schedule.every().day.at("09:00:01").do(history_k_data_manager.update_history_k_bars)
        schedule.every().day.at("09:02:01").do(lambda: history_k_data_manager.update_history_k_bars(force=True))
        # 更新账户信息
        schedule.every().day.at("09:00:01").do(huaxin_trade_data_update.add_money_list)
        schedule.every().day.at("09:15:20").do(huaxin_trade_data_update.add_money_list)
        schedule.every().day.at("09:15:20").do(huaxin_trade_data_update.add_money_list)
        # 更新昨日实时涨停数据
        schedule.every().day.at("07:58:00").do(__update_yesterday_kpl_limit_up_datas)

 third_data/history_k_data_manager.py

@@ -15,7 +15,7 @@
from utils import tool, init_data_util


def update_history_k_bars():
def update_history_k_bars(force=False):
    """
    更新历史K线
    @return: 此次更新的数量
@@ -26,7 +26,8 @@
            try:
                datas = init_data_util.get_volumns_by_code(code, 150)
                if datas:
                    HistoryKDataManager().save_history_bars(code, datas[0]['bob'].strftime("%Y-%m-%d"), datas)
                    HistoryKDataManager().save_history_bars(code, datas[0]['bob'].strftime("%Y-%m-%d"), datas,
                                                            force=force)
            except Exception as e:
                logger_debug.exception(e)

@@ -40,6 +41,7 @@
        for code_byte in codes_sz:
            codes.add(code_byte.decode())
    # 获取已经更新的数据
    if not force:
    codes_record = HistoryKDataManager().get_history_bars_codes(latest_trading_date)
    codes = codes - codes_record
    threading.Thread(target=lambda: update(codes), daemon=True).start()