排1添加日志

Administrator

2024-12-03 40832ae4adf4c50d16d19e83b5d7ba4964fab503

排1添加日志

 servers/huaxin_trade_server.py

@@ -881,14 +881,15 @@

# 预埋单
def __test_pre_place_order():
    logger_debug.info("进入预埋单测试")
    codes = gpcode_manager.BuyOpenLimitUpCodeManager().get_codes()
    logger_debug.info(f"进入预埋单测试:{codes}")
    try:
    if codes:
        for code in codes:
            # 获取昨日收盘价格
            limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)
            if not limit_up_price:
                init_data_util.re_set_price_pre(code)
                    init_data_util.re_set_price_pre(code, force=True)
                limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)
            if not limit_up_price:
                logger_debug.info(f"没有获取到涨停价:{code}")
@@ -905,7 +906,9 @@
                buy_open_limit_up_strategy.BuyOpenLimitupDataManager().set_place_order_info(code, volume, volume,
                                                                                            result.get("order_ref"))
            except Exception as e:
                pass
                    logger_debug.exception(e)
    except Exception as e:
        logger_debug.exception(e)


def __subscript_fixed_codes_l2():
@@ -934,7 +937,7 @@
def __init():
    def run_pending():
        schedule.every().day.at("15:10:00").do(zyltgb_util.update_all_zylt_volumes)
        schedule.every().day.at("01:05:00").do(__test_pre_place_order)
        schedule.every().day.at("01:02:00").do(__test_pre_place_order)
        schedule.every().day.at("09:10:00").do(__subscript_fixed_codes_l2)
        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)
@@ -942,7 +945,11 @@
        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)
        while True:
            try:
            schedule.run_pending()
            except:
                pass
            finally:
            time.sleep(1)
            # 9点半后终止运行
            # if tool.trade_time_sub(tool.get_now_time_str(), "09:30:00") > 0: