From 4051d7fc8dc5c1b4081dfe076217d3de978eff1e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 01 八月 2023 11:13:20 +0800
Subject: [PATCH] 获取环境接口
---
l2/l2_data_manager_new.py | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index 7a20f5b..d0ef479 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -220,9 +220,10 @@
# 澶勭悊鍗庨懌L2鏁版嵁
@classmethod
- def process_huaxin(cls, code, datas):
- print("process_huaxin", code, len(datas))
+ def process_huaxin(cls, code, origin_datas):
+ print("process_huaxin", code, len(origin_datas))
origin_start_time = round(t.time() * 1000)
+ datas = None
try:
# 鍔犺浇鍘嗗彶鐨凩2鏁版嵁
is_normal = l2.l2_data_util.load_l2_data(code, load_latest=False)
@@ -235,7 +236,7 @@
if local_today_datas.get(code) is not None and len(
local_today_datas[code]) > 0:
_start_index = local_today_datas[code][-1]["index"] + 1
- datas = l2_huaxin_util.get_format_l2_datas(code, datas,
+ 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)
@@ -265,7 +266,8 @@
l2_data_log.l2_time(code, round(t.time() * 1000) - origin_start_time,
"l2鏁版嵁澶勭悊鎬昏�楁椂",
True)
- l2.l2_data_util.save_l2_data(code, None, datas)
+ if datas:
+ l2.l2_data_util.save_l2_data(code, None, datas)
@classmethod
def process_add_datas(cls, code, add_datas, capture_timestamp, __start_time):
--
Gitblit v1.8.0