From 48dcb788e821d40be37fa05c9789b751a6e2a69b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 13 一月 2023 16:38:45 +0800
Subject: [PATCH] H撤大单修改
---
trade_queue_manager.py | 26 ++++++++++++++++++++++++++
1 files changed, 26 insertions(+), 0 deletions(-)
diff --git a/trade_queue_manager.py b/trade_queue_manager.py
index 44af7cd..3fd20f6 100644
--- a/trade_queue_manager.py
+++ b/trade_queue_manager.py
@@ -16,6 +16,18 @@
def __get_redis(self):
return self.__redisManager.getRedis()
+ # 淇濆瓨鏈�澶ч噺
+ def __save_max_buy1_volume(self, code, volume):
+ key = "max_buy1_volumn-{}".format(code)
+ self.__get_redis().setex(key, tool.get_expire(), volume)
+
+ def __get_max_buy1_volume(self, code):
+ key = "max_buy1_volumn-{}".format(code)
+ val = self.__get_redis().get(key)
+ if val is not None:
+ return int(val)
+ return None
+
def __save_recod(self, code, time_str, volumn):
# 淇濆瓨姣忎竴娆＄殑
@@ -83,6 +95,14 @@
return False, False, None
self.__last_data[code] = volumn
+ if int(time_str.replace(':', '')) >= int("093000"):
+ # 淇濆瓨鏈�澶ч噺(9:30杩囧悗鐨勯噺)
+ max_volume = self.__get_max_buy1_volume(code)
+ if max_volume is None:
+ max_volume = 0
+ if volumn > max_volume:
+ self.__save_max_buy1_volume(code, volumn)
+
if code not in self.__code_time_volumn_dict:
self.__code_time_volumn_dict[code] = {}
self.__code_time_volumn_dict[code][time_str] = volumn
@@ -129,6 +149,12 @@
time_str, volumn = self.__get_latest_record(code)
return time_str, volumn
+ def get_max_buy1_volume(self, code):
+ val = self.__get_max_buy1_volume(code)
+ if val is None:
+ return -1
+ return val
+
class JueJinBuy1VolumnManager:
__redisManager = redis_manager.RedisManager(1)
--
Gitblit v1.8.0