| | |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price(d[0]) |
|---|
| | | if limit_up_price: |
|---|
| | | # 默认设置涨停，量为0 |
|---|
| | | datas.append((code, float(limit_up_price), 10, 0, time.time())) |
|---|
| | | datas.append((code, 0, float(limit_up_price), tool.get_shadow_price(float(limit_up_price)))) |
|---|
| | | except Exception as e: |
|---|
| | | logger_l2_codes_subscript.exception(e) |
|---|
| | | if not datas: |
|---|
| | |
|---|
| | | # 如果在9:24-9:30 需要加载板块 |
|---|
| | | if int("092400") < int(tool.get_now_time_str().replace(":", "")) < int("093000"): |
|---|
| | | for d in datas: |
|---|
| | | KPLCodeJXBlockManager().load_jx_blocks(d[0], gpcode_manager.get_price(d[0]), float(d[2]), KPLLimitUpDataRecordManager.get_current_reasons()) |
|---|
| | | KPLCodeJXBlockManager().load_jx_blocks(d[0], gpcode_manager.get_price(d[0]), float(d[2]), |
|---|
| | | KPLLimitUpDataRecordManager.get_current_reasons()) |
|---|
| | | time.sleep(1) |
|---|
| | | logger_l2_codes_subscript.info("({})发送到华鑫L2代码处理队列：数量-{}", request_id, len(datas)) |
|---|
| | | except Exception as e: |
|---|
