| | |
|---|
| | | if tool.trade_time_sub(tool.get_now_time_str(), "09:30:00") > 0: |
|---|
| | | break |
|---|
| | | |
|---|
| | | # 持仓刷新 |
|---|
| | | huaxin_trade_data_update.add_position_list() |
|---|
| | | # 请求持仓 |
|---|
| | | def request_position(): |
|---|
| | | for i in range(3): |
|---|
| | | time.sleep(10) |
|---|
| | | huaxin_trade_data_update.add_position_list() |
|---|
| | | |
|---|
| | | # 定时持仓刷新 |
|---|
| | | 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("09:15:00").do(huaxin_trade_data_update.add_position_list) |
|---|
| | | threading.Thread(target=run_pending, daemon=True).start() |
|---|
| | | threading.Thread(target=request_position, daemon=True).start() |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w, queue_strategy_r_trade_w, queue_strategy_w_trade_r): |
|---|
