From 86e0061f9cf211b98252a9e6b71d6c9801e4a16b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期日, 18 十二月 2022 18:08:03 +0800
Subject: [PATCH] 撤单策略再次修改
---
trade_queue_manager.py | 46 +++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 45 insertions(+), 1 deletions(-)
diff --git a/trade_queue_manager.py b/trade_queue_manager.py
index 53722ec..2375c63 100644
--- a/trade_queue_manager.py
+++ b/trade_queue_manager.py
@@ -200,5 +200,49 @@
return self.__get_record(code)
+class thsl2tradequeuemanager:
+ __redisManager = redis_manager.RedisManager(0)
+ __filter_dict = {}
+
+ def __get_redis(self):
+ return self.__redisManager.getRedis()
+
+ def __save_latest_recod(self, code, info):
+ # 淇濆瓨姣忎竴娆＄殑
+ key = "ths_l2_latest_trade_info-{}".format(code)
+ self.__get_redis().setex(key, tool.get_expire(), json.dumps(info))
+
+ def __get_latest_record(self, code):
+ key = "ths_l2_latest_trade_info-{}".format(code)
+ val = self.__get_redis().get(key)
+ if val is None:
+ return None
+ return json.loads(val)
+
+ def save_recod(self, code, data):
+ _str = json.dumps(data)
+ if code in self.__filter_dict and self.__filter_dict[code] == _str:
+ return False
+ self.__filter_dict[code] = _str
+ self.__save_latest_recod(code, data)
+ buy_time = data["buyTime"]
+ buy_one_price = data["buyOnePrice"]
+ buy_one_volumn = data["buyOneVolumn"]
+ sell_time = data["sellTime"]
+ sell_one_price = data["sellOnePrice"]
+ sell_one_volumn = data["sellOneVolumn"]
+ return True
+
+ def get_sell1_info(self, code):
+ data = self.__get_latest_record(code)
+ if data is None:
+ return None, None, None
+ else:
+ sell_time = data["sellTime"]
+ sell_one_price = data["sellOnePrice"]
+ sell_one_volumn = data["sellOneVolumn"]
+ return sell_time, sell_one_price, int(sell_one_volumn)
+
+
if __name__ == '__main__':
- print( Buy1PriceManager().get_price("002644"))
+ thsl2tradequeuemanager().test()
--
Gitblit v1.8.0