From 8218790ab15e752d982ee9c0df156ceea849c9a9 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 05 十二月 2022 22:02:47 +0800
Subject: [PATCH] 策略优化，增加买1价格的影响
---
trade_queue_manager.py | 33 ++++++++++++++++++++++++++++++++-
1 files changed, 32 insertions(+), 1 deletions(-)
diff --git a/trade_queue_manager.py b/trade_queue_manager.py
index bf9ea0c..53722ec 100644
--- a/trade_queue_manager.py
+++ b/trade_queue_manager.py
@@ -169,5 +169,36 @@
return time_str, volumn
+# 涔�1瀹炴椂浠锋牸绠＄悊鍣�
+class Buy1PriceManager:
+ __redisManager = redis_manager.RedisManager(0)
+
+ def __init__(self):
+ self.latest_prices = {}
+
+ def __get_redis(self):
+ return self.__redisManager.getRedis()
+
+ def __save_recod(self, code, price):
+ # 淇濆瓨姣忎竴娆＄殑
+ key = "buy1_price-{}".format(code)
+ self.__get_redis().setex(key, tool.get_expire(), price)
+
+ def __get_record(self, code):
+ key = "buy1_price-{}".format(code)
+ val = self.__get_redis().get(key)
+ return val
+
+ # 淇濆瓨鏁版嵁
+ def save(self, code, price):
+ if self.latest_prices.get(code) == price:
+ return
+ self.latest_prices[code] = price
+ self.__save_recod(code, price)
+
+ def get_price(self, code):
+ return self.__get_record(code)
+
+
if __name__ == '__main__':
- JueJinBuy1VolumnManager().save("001203", "15:00:00", 40586553, 12.12)
+ print( Buy1PriceManager().get_price("002644"))
--
Gitblit v1.8.0