bug修复

Administrator

2024-07-03 c02285dc28ac273e38cf80e1ee01d818b32e1355

bug修复

 third_data/history_k_data_manager.py

@@ -17,13 +17,15 @@
    更新历史K线
    @return: 此次更新的数量
    """

    def update(codes_):
        for code in codes_:
            try:
                datas = init_data_util.get_volumns_by_code(code)
                datas = init_data_util.get_volumns_by_code(code, 150)
                HistoryKDataManager().save_history_bars(code, datas[0]['bob'].strftime("%Y-%m-%d"), datas)
            except Exception as e:
                logger_debug.exception(e)

    previous_trading_date = history_k_data_util.JueJinApi.get_previous_trading_date(tool.get_now_date_str())
    if previous_trading_date is None:
        raise Exception("上一个交易日获取失败")
@@ -41,7 +43,6 @@
    threading.Thread(target=lambda: update(codes), daemon=True).start()

    return len(codes)



class HistoryKDataManager:

 trade/huaxin/huaxin_trade_server.py

@@ -37,7 +37,7 @@
from log_module.log import hx_logger_contact_debug, hx_logger_trade_callback, \
    hx_logger_l2_orderdetail, hx_logger_l2_market_data, logger_l2_g_cancel, logger_debug, \
    logger_system, logger_trade, logger_local_huaxin_l1_trade_info, logger_l2_codes_subscript
from third_data import block_info, kpl_data_manager
from third_data import block_info, kpl_data_manager, history_k_data_manager
from third_data.code_plate_key_manager import KPLCodeJXBlockManager, CodePlateKeyBuyManager
from third_data.history_k_data_util import JueJinApi
from trade import trade_manager, l2_trade_util, \
@@ -780,6 +780,9 @@
    schedule.every().day.at("09:00:00").do(huaxin_trade_data_update.add_position_list)
    schedule.every().day.at("09:10:00").do(huaxin_trade_data_update.add_position_list)
    schedule.every().day.at("15:10:00").do(zyltgb_util.update_all_zylt_volumes)
    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)
    threading.Thread(target=run_pending, daemon=True).start()
    l2_data_util.load_l2_data_all(True)
    L2TradeSingleDataManager.set_callback(MyL2TradeSingleCallback())