| | |
|---|
| | | dif2 = add_code_set - latest_add_codes |
|---|
| | | if dif2: |
|---|
| | | # 新增加的订阅需要拉取之前的大单 |
|---|
| | | for c in dif2: |
|---|
| | | __pre_big_order_deal_thread_pool.submit(radical_buy_data_manager.pull_pre_deal_big_orders, c) |
|---|
| | | __pre_big_order_deal_thread_pool.submit(radical_buy_data_manager.pull_pre_deal_big_orders_by_codes, dif2) |
|---|
| | | if True: |
|---|
| | | async_log_util.info(logger_l2_codes_subscript, |
|---|
| | | f"({request_id})预处理新增订阅代码：{dif2}") |
|---|
| | |
|---|
| | | tool.get_buy_volume(limit_up_price), list(special_volumes))) |
|---|
| | | huaxin_target_codes_manager.HuaXinL2SubscriptCodesManager.push(add_datas, request_id) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | logger_debug.exception(e) |
|---|
| | | else: |
|---|
| | | pass |
|---|
| | | |
|---|
