From 8821049f3faee04e03f5535c6259d07bfb8b6433 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 24 七月 2025 18:11:11 +0800
Subject: [PATCH] 订阅规则修改/增加新的外部接口/删除不必要的debug日志
---
l2/l2_data_util.py | 153 ++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 120 insertions(+), 33 deletions(-)
diff --git a/l2/l2_data_util.py b/l2/l2_data_util.py
index b5dbb57..e12f024 100644
--- a/l2/l2_data_util.py
+++ b/l2/l2_data_util.py
@@ -33,6 +33,12 @@
# 涔板叆璁㈠崟鍙锋槧灏�,鍙湁鍘熺敓鐨凩2鏁版嵁鎵嶆湁
local_today_buyno_map = {}
+# 鍗栧嚭璁㈠崟鍙锋槧灏勶紝鍙湁鍘熺敓鐨凩2鏁版嵁鎵嶆湁
+local_today_sellno_map = {}
+
+# 宸茬粡鎾ゅ崟鐨勮鍗曞彿
+local_today_canceled_buyno_map = {}
+
def load_l2_data(code, load_latest=True, force=False):
# 鍔犺浇鏈�杩戠殑l2鏁版嵁
@@ -71,8 +77,43 @@
# 鏍规嵁浠婃棩鏁版嵁鍔犺浇
load_num_operate_map(local_today_num_operate_map, code, local_today_datas.get(code), force)
load_buy_no_map(local_today_buyno_map, code, local_today_datas.get(code), force)
+ load_sell_no_map(local_today_sellno_map, code, local_today_datas.get(code), force)
+ load_canceled_buy_no_map(local_today_canceled_buyno_map, code, local_today_datas.get(code), force)
return data_normal
return True
+
+
+# L2鏁版嵁鏄惁姝ｅ父
+def l2_data_is_normal(code):
+ datas = local_today_datas.get(code)
+ if not datas:
+ # 鍒濆鍖�
+ local_today_datas[code] = []
+ load_num_operate_map(local_today_num_operate_map, code, local_today_datas.get(code))
+ load_buy_no_map(local_today_buyno_map, code, local_today_datas.get(code))
+ load_sell_no_map(local_today_sellno_map, code, local_today_datas.get(code))
+ load_canceled_buy_no_map(local_today_canceled_buyno_map, code, local_today_datas.get(code))
+
+ if datas and len(datas) != datas[-1]["index"] + 1:
+ return False
+ return True
+
+
+# 鍔犺浇鎵�鏈夌殑l2鏁版嵁
+def load_l2_data_all(force=False):
+ datas = log_export.load_l2_from_log()
+ for code in datas:
+ if force:
+ local_today_datas[code] = datas[code]
+ else:
+ if code not in local_today_datas:
+ local_today_datas[code] = datas[code]
+ load_num_operate_map(local_today_num_operate_map, code, local_today_datas.get(code), force)
+ load_buy_no_map(local_today_buyno_map, code, local_today_datas.get(code), force)
+ load_sell_no_map(local_today_sellno_map, code, local_today_datas.get(code), force)
+ load_canceled_buy_no_map(local_today_canceled_buyno_map, code, local_today_datas.get(code), force)
+
+ constant.L2_DATA_IS_LOADED = True
# 灏嗘暟鎹牴鎹畁um-operate鍒嗙被
@@ -106,6 +147,45 @@
key = "{}".format(data["val"]["orderNo"])
if local_today_buyno_map[code].get(key) is None:
local_today_buyno_map[code].setdefault(key, data)
+
+
+# 灏嗘暟鎹牴鎹畂rderNo鍒嗙被,鍘熺敓鏁版嵁鎵嶆湁
+def load_sell_no_map(local_today_sellno_map, code, source_datas, clear=False):
+ # 鍙湁鍘熺敓L2鏁版嵁鎵嶄細鏈夋鎿嶄綔
+ if constant.L2_SOURCE_TYPE != constant.L2_SOURCE_TYPE_HUAXIN:
+ return
+ if local_today_sellno_map.get(code) is None:
+ local_today_sellno_map[code] = {}
+ if clear:
+ local_today_sellno_map[code] = {}
+
+ for data in source_datas:
+ if data["val"]["operateType"] != 2:
+ continue
+ # 鍙～鍏呬拱鍏ユ暟鎹�
+ key = "{}".format(data["val"]["orderNo"])
+ if local_today_sellno_map[code].get(key) is None:
+ local_today_sellno_map[code].setdefault(key, data)
+
+
+# 灏嗘暟鎹牴鎹畂rderNo鍒嗙被宸叉挙璁㈠崟,鍘熺敓鏁版嵁鎵嶆湁
+def load_canceled_buy_no_map(local_today_canceled_buyno_map, code, source_datas, clear=False):
+ # 鍙湁鍘熺敓L2鏁版嵁鎵嶄細鏈夋鎿嶄綔
+ if constant.L2_SOURCE_TYPE != constant.L2_SOURCE_TYPE_HUAXIN:
+ return
+ if local_today_canceled_buyno_map.get(code) is None:
+ local_today_canceled_buyno_map[code] = {}
+ if clear:
+ local_today_canceled_buyno_map[code] = {}
+
+ for data in source_datas:
+ # 鍙暀涓嬩拱鎾�
+ if data["val"]["operateType"] != 1:
+ continue
+ # 鍙～鍏呬拱鍏ユ暟鎹�
+ key = "{}".format(data["val"]["orderNo"])
+ if local_today_canceled_buyno_map[code].get(key) is None:
+ local_today_canceled_buyno_map[code].setdefault(key, data)
@tool.async_call
@@ -215,33 +295,12 @@
return False
-# 鏄惁涓哄ぇ鍗�
-def is_big_money(val):
- price = float(val["price"])
- money = price * int(val["num"])
- if price > 3.0:
- if money >= 30000:
- return True
- else:
- return False
- else:
- max_money = price * 10000
- if money >= max_money * 0.95:
- return True
- else:
- return False
-
-
class L2DataUtil:
@classmethod
def is_same_time(cls, time1, time2):
if constant.TEST:
return True
- time1_s = time1.split(":")
- time1_second = int(time1_s[0]) * 3600 + int(time1_s[1]) * 60 + int(time1_s[2])
- time2_s = time2.split(":")
- time2_second = int(time2_s[0]) * 3600 + int(time2_s[1]) * 60 + int(time2_s[2])
- if abs(time2_second - time1_second) < 3:
+ if abs(tool.trade_time_sub(time1, time2)) < 3:
return True
else:
return False
@@ -384,11 +443,16 @@
if int(val["operateType"]) != 2:
return False
+ return True
- price = float(val["price"])
- num = int(val["num"])
- # if price * num * 100 < 50 * 10000:
- # return False
+ # 娑ㄥ仠鍗栨挙
+ @classmethod
+ def is_limit_up_price_sell_cancel(cls, val):
+ if int(val["limitPrice"]) != 1:
+ return False
+
+ if int(val["operateType"]) != 3:
+ return False
return True
# 鏄惁娑ㄥ仠涔版挙
@@ -400,10 +464,12 @@
if int(val["operateType"]) != 1:
return False
- price = float(val["price"])
- num = int(val["num"])
- # if price * num * 100 < 50 * 10000:
- # return False
+ return True
+
+ @classmethod
+ def is_buy_cancel(cls, val):
+ if int(val["operateType"]) != 1:
+ return False
return True
# 鏄惁鍗栨挙
@@ -420,6 +486,26 @@
return True
return False
+ # 鏄惁涓轰拱
+ @classmethod
+ def is_buy(cls, val):
+ if int(val["operateType"]) == 0:
+ return True
+ return False
+
+ # l2鏃堕棿宸��
+ @classmethod
+ def time_sub_as_ms(cls, val1, val2):
+ # 璁＄畻鏃堕棿宸��
+ sub_s = tool.trade_time_sub(val1["time"], val2["time"])
+ sub_ms = int(val1["tms"]) - int(val2["tms"])
+ fs = sub_s * 1000 + sub_ms
+ return fs
+
+ @classmethod
+ def get_time_with_ms(cls, val):
+ return val["time"] + "." + "{:0>3}".format(int(val["tms"]))
+
class L2TradeQueueUtils(object):
# 涔板叆鏁版嵁鏄惁宸叉挙
@@ -431,8 +517,9 @@
# 鏄惁鏈変拱鎾ゆ暟鎹�
if cancel_datas:
for cancel_data in cancel_datas:
- buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data(code, cancel_data,
- local_today_num_operate_map)
+ buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data_v2(cancel_data,
+ local_today_buyno_map.get(
+ code))
if buy_index == data["index"]:
return True
return False
@@ -533,4 +620,4 @@
if __name__ == "__main__":
- print(load_l2_data("002235"))
+ print(L2DataUtil.time_sub_as_ms({"time": "09:46:05", "tms": 480}, {"time": "09:46:04", "tms": 90}))
--
Gitblit v1.8.0