From 324a5e115559d5432f04146b4e788d5bcb2237e0 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 11 九月 2023 11:30:32 +0800
Subject: [PATCH] 数据编号重复处理
---
l2/l2_data_manager_new.py | 18 +++++++++++-------
1 files changed, 11 insertions(+), 7 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index 20591e4..fd14007 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -312,13 +312,17 @@
_start_index = total_datas[-1]["index"] + 1
datas = l2_huaxin_util.get_format_l2_datas(code, origin_datas,
gpcode_manager.get_limit_up_price(code), _start_index)
- # 鑾峰彇涓嬪崟浣嶇疆
- place_order_index = huaxin_delegate_postion_manager.get_l2_place_order_position(code, datas)
- if place_order_index:
- buy_single_index, buy_exec_index, buy_compute_index, num, count, max_num_set, buy_volume_rate = cls.__get_order_begin_pos(
- code)
- cls.set_real_place_order_index(code, place_order_index, buy_single_index)
- async_log_util.info(logger_l2_process, "code:{} 鑾峰彇鍒颁笅鍗曠湡瀹炰綅缃細{}", code, place_order_index)
+ try:
+ # 鑾峰彇涓嬪崟浣嶇疆
+ place_order_index = huaxin_delegate_postion_manager.get_l2_place_order_position(code, datas)
+ if place_order_index:
+ buy_single_index, buy_exec_index, buy_compute_index, num, count, max_num_set, buy_volume_rate = cls.__get_order_begin_pos(
+ code)
+ cls.set_real_place_order_index(code, place_order_index, buy_single_index)
+ async_log_util.info(logger_l2_process, "code:{} 鑾峰彇鍒颁笅鍗曠湡瀹炰綅缃細{}", code, place_order_index)
+ except:
+ logger_l2_error.exception(f"{code} 澶勭悊鐪熷疄涓嬪崟浣嶇疆鍑洪敊")
+
__start_time = round(t.time() * 1000)
if len(datas) > 0:
cls.process_add_datas(code, datas, 0, __start_time)
--
Gitblit v1.8.0