| | |
|---|
| | | |
|---|
| | | from code_attribute import target_codes_manager, gpcode_manager, code_market_manager, history_k_data_util |
|---|
| | | from db.redis_manager_delegate import RedisUtils |
|---|
| | | from huaxin_client import l2_client_for_cb, trade_client_for_cb |
|---|
| | | from huaxin_client import l2_client_for_cb |
|---|
| | | from huaxin_client.client_network import SendResponseSkManager |
|---|
| | | from log_module import async_log_util, log_export |
|---|
| | | from records import huaxin_trade_record_manager |
|---|
| | |
|---|
| | | # 正股需要加载板块 |
|---|
| | | if code.find("11") != 0 and code.find("12") != 0: |
|---|
| | | limit_up_price = tool.get_limit_up_price(code, result[8]) |
|---|
| | | |
|---|
| | | KPLCodeJXBlockManager().load_jx_blocks(result[0], result[3], |
|---|
| | | float(limit_up_price), |
|---|
| | | KPLLimitUpDataRecordManager.get_current_reasons()) |
|---|
| | | # 涨幅大于5%才开始获取板块 |
|---|
| | | if result[2] > 0.05: |
|---|
| | | KPLCodeJXBlockManager().load_jx_blocks(result[0], result[3], |
|---|
| | | float(limit_up_price), |
|---|
| | | KPLLimitUpDataRecordManager.get_current_reasons()) |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | time.sleep(1) |
|---|
