定时K线更新/L1目标代码更新

Administrator

9 天以前 bba825d6ddfaca81c18890a5c3d3a1f0a346fd42

定时K线更新/L1目标代码更新

 servers/huaxin_trade_server.py

@@ -19,7 +19,7 @@
from code_attribute.code_l1_data_manager import L1DataManager
from code_attribute.gpcode_manager import CodePrePriceManager, CodesNameManager, \
    WantBuyCodesManager
from huaxin_client import l2_data_transform_protocol
from huaxin_client import l2_data_transform_protocol, l1_subscript_codes_manager
from huaxin_client.trade_transform_protocol import TradeResponse
from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, transaction_progress, \
    l2_data_source_util, l2_data_log, data_callback
@@ -38,7 +38,8 @@
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_l2_radical_buy, logger_l2_trade
from third_data import block_info, kpl_data_manager, history_k_data_manager, huaxin_l1_data_manager, kpl_api, kpl_util
from third_data import block_info, kpl_data_manager, history_k_data_manager, huaxin_l1_data_manager, kpl_api, kpl_util, \
    third_blocks_manager
from third_data.code_plate_key_manager import KPLCodeJXBlockManager, RealTimeKplMarketData, \
    KPLPlateForbiddenManager
from third_data.history_k_data_manager import HistoryKDataManager
@@ -1092,6 +1093,20 @@
    logger_debug.info("更新昨日开盘啦实时涨停数据")


def __update_l1_target_codes():
    try:
        codes_sh, codes_sz = l1_subscript_codes_manager.request_l1_subscript_target_codes()
        if codes_sh and codes_sz:
            l1_subscript_codes_manager.save_codes(codes_sh, codes_sz)
        # 拉取三方板块
        codes = []
        codes.extend(codes_sh)
        codes.extend(codes_sz)
        third_blocks_manager.load_if_less(codes)
    except Exception as e:
        logger_debug.error(e)


# 做一些初始化的操作
def __init():
    def run_pending():
@@ -1110,6 +1125,10 @@
        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)
        # 更新代码
        schedule.every().day.at("15:58:00").do(__update_l1_target_codes)
        # 更新K线
        schedule.every().day.at("16:30:00").do(history_k_data_manager.update_history_k_bars)

        while True:
            try: