| | |
|---|
| | | from cancel_strategy.s_l_h_cancel_strategy import SCancelBigNumComputer |
|---|
| | | from code_attribute import gpcode_manager, code_volumn_manager, global_data_loader, zyltgb_util, code_nature_analyse |
|---|
| | | from code_attribute.code_l1_data_manager import L1DataManager |
|---|
| | | from code_attribute.gpcode_manager import CodePrePriceManager |
|---|
| | | from code_attribute.gpcode_manager import CodePrePriceManager, CodesNameManager |
|---|
| | | from huaxin_client import l2_data_transform_protocol |
|---|
| | | 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, \ |
|---|
| | |
|---|
| | | # 获取level1的代码 |
|---|
| | | list_ = JueJinApi.get_exchanges_codes(["SHSE", "SZSE"]) |
|---|
| | | fdatas = [] |
|---|
| | | code_name_map = {} |
|---|
| | | for d in list_: |
|---|
| | | if not tool.is_target_code(d["sec_id"]): |
|---|
| | | continue |
|---|
| | |
|---|
| | | days=100)).timestamp() > datetime.datetime.now().timestamp(): |
|---|
| | | continue |
|---|
| | | fdatas.append(d["sec_id"]) |
|---|
| | | code_name_map[d["sec_id"]] = d["sec_name"] |
|---|
| | | # 保存代码名称 |
|---|
| | | for k in code_name_map: |
|---|
| | | CodesNameManager.add_code_name(k, code_name_map[k]) |
|---|
| | | |
|---|
| | | sk.sendall( |
|---|
| | | socket_util.load_header(json.dumps({"code": 0, "data": fdatas}).encode(encoding='utf-8'))) |
|---|
| | | |
|---|
