| | |
| | | async_log_util.info(logger_debug, f"扫入处理时长:{code}-{use_time}") |
| | | |
| | | |
| | | |
| | | # 回调 |
| | | my_l2_data_callback = MyL2DataCallback() |
| | | my_l2_data_callbacks = [MyL2DataCallback() for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT)] |
| | | my_trade_response = MyTradeResponse() |
| | | |
| | | |
| | | # 预埋单 |
| | | def __test_pre_place_order(): |
| | | logger_debug.info("进入预埋单测试") |
| | | price = 18.16 |
| | | code = "002626" |
| | | shadow_price = tool.get_shadow_price(price) |
| | | if not constant.TRADE_ENABLE: |
| | | return |
| | | try: |
| | | result = huaxin_trade_api.order(1, code, 100, price, blocking=False, |
| | | shadow_price=shadow_price) |
| | | async_log_util.info(logger_trade, f"{code}下单结束") |
| | | except Exception as e: |
| | | pass |
| | | |
| | | |
| | | # 做一些初始化的操作 |
| | |
| | | # 持仓刷新 |
| | | 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("01:00:01").do(__test_pre_place_order) |
| | | 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) |