From 34491829675033e41715648b1e92f339bf2f35d1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 25 八月 2022 17:51:10 +0800
Subject: [PATCH] Changes
---
l2_data_manager.py | 21 +++++++++++++++++----
1 files changed, 17 insertions(+), 4 deletions(-)
diff --git a/l2_data_manager.py b/l2_data_manager.py
index 9df3066..ffa57c1 100644
--- a/l2_data_manager.py
+++ b/l2_data_manager.py
@@ -203,9 +203,15 @@
# 鑾峰彇娑ㄥ仠浠�
limit_up_price = gpcode_manager.get_limit_up_price(code)
+ same_time_num = {}
for item in data:
# 瑙ｆ瀽鏁版嵁
time = item["time"]
+ if time in same_time_num:
+ same_time_num[time] = same_time_num[time] + 1
+ else:
+ same_time_num[time] = 1
+
price = float(item["price"])
num = item["num"]
limitPrice = item["limitPrice"]
@@ -225,6 +231,11 @@
# 鏁版嵁閲嶅娆℃暟榛樿涓�1
datas.append({"key": key, "val": item, "re": 1})
dataIndexs.setdefault(key, len(datas) - 1)
+ for key in same_time_num:
+ if same_time_num[key] > 50:
+ # TODO 淇濆瓨鏁版嵁
+ redis = _redisManager.getRedis()
+ redis.set("big_data-{}-{}".format(code, int(round(t.time() * 1000))), str)
return day, client, channel, code, datas
@@ -423,7 +434,7 @@
if limit_up_price is not None:
if latest_num * limit_up_price * 100 > 1000 * 10000:
# 澶т簬1000w灏变拱
- #print("鎵ц鎾ら攢")
+ # print("鎵ц鎾ら攢")
logger_l2_trade.info(
"鎵ц鎾ら攢锛歿} - {}".format(code, json.dumps(add_datas[-1])))
try:
@@ -526,7 +537,7 @@
# if datas[j]["val"]["limitPrice"] == 1 and datas[j]["val"]["operateType"] == 0:
# index_3 = j
if index_1 - index_0 == 1 and index_2 - index_1 == 1: # and index_3 - index_2 == 1
- logger_l2_trade.info("鎵惧埌鐗╃悊杩炵画娑ㄥ仠涔� {},{},{}".format(code, i,datas[i]))
+ logger_l2_trade.info("鎵惧埌鐗╃悊杩炵画娑ㄥ仠涔� {},{},{}".format(code, i, datas[i]))
return i
# 鍚�1s鍐呮湁涓嶈繛缁殑4涓定鍋滀拱锛堝鏋滈亣涔版挙灏遍噸鏂拌绠楋紝涓棿鍙棿闅斾笉娑ㄥ仠涔帮級鏍囪璁＄畻璧峰鐐�
if __is_limit_up_price_buy(_val):
@@ -548,7 +559,7 @@
_limit_up_count_1s_start_index = -1
if _limit_up_count_1s >= 4 and _limit_up_count_1s_start_index > -1:
- logger_l2_trade.info("鎵惧埌鍚屼竴绉掕繛缁定鍋滀拱 {},{},{}".format(code, _limit_up_count_1s_start_index,datas[i]))
+ logger_l2_trade.info("鎵惧埌鍚屼竴绉掕繛缁定鍋滀拱 {},{},{}".format(code, _limit_up_count_1s_start_index, datas[i]))
return _limit_up_count_1s_start_index
return None
@@ -590,7 +601,7 @@
index_2 = j
break
if index_1 - index_0 == 1 and index_2 - index_1 == 1:
- logger_l2_trade.info("杩炵画3涓定鍋滀拱鎾� {},{},{}".format(code, i,json.dumps(datas[i])))
+ logger_l2_trade.info("杩炵画3涓定鍋滀拱鎾� {},{},{}".format(code, i, json.dumps(datas[i])))
return i
return None
@@ -675,6 +686,7 @@
key = "l2-fixed-codes"
redis = _redisManager.getRedis()
redis.sadd(key, code)
+ redis.expire(key, tool.get_expire())
# 鏄惁鍦╨2鍥哄畾鐩戞帶浠ｇ爜涓�
@@ -685,6 +697,7 @@
if __name__ == "__main__":
+ print("big_data-{}-{}".format("123", int(round(t.time() * 1000))))
pass
# __set_buy_compute_start_data("000000", 100, 1)
# __set_buy_compute_start_data("000000", 100)
--
Gitblit v1.8.0