From fa6a3ab958ce9493833eef68ac62bd155be5d53e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 28 十月 2022 15:09:15 +0800
Subject: [PATCH] 驾驶舱监听，不再处理同花顺14:55以后的交易队列数据
---
trade_queue_manager.py | 22 +++++++++++++++++++---
1 files changed, 19 insertions(+), 3 deletions(-)
diff --git a/trade_queue_manager.py b/trade_queue_manager.py
index 37dec69..f16ffa6 100644
--- a/trade_queue_manager.py
+++ b/trade_queue_manager.py
@@ -46,11 +46,27 @@
val = json.loads(val)
return val[0], val[1]
+ # 娣诲姞璁板綍
+ def __add_recod(self, code):
+ key = "buy1_volumn_codes"
+ self.__get_redis().sadd(key, code)
+ self.__get_redis().expire(key, 10)
+
+ # 鑾峰彇褰撳墠姝ｅ湪鐩戝惉鐨勪唬鐮�
+ def get_current_codes(self):
+ key = "buy1_volumn_codes"
+ return self.__get_redis().smembers(key)
+
# 杩斿洖鏄惁闇�瑕佹洿鏂版暟鎹�
- def save(self, code, time_str, volumn,price):
+ def save(self, code, time_str, volumn, price):
# 瀹㈡埛绔暟鎹湭鍔犺浇鍑烘潵杩囨护
if volumn < 1:
return False
+ # 14:55:00涔嬪悗涓嶅湪澶勭悊
+ if int(time_str.replace(':', '')) >= int("145500"):
+ return False
+
+ self.__add_recod(code)
# 鍒ゆ柇鏄惁涓烘定鍋滀环
limit_up_price = gpcode_manager.get_limit_up_price(code)
if limit_up_price != tool.to_price(decimal.Decimal(price)):
@@ -133,6 +149,6 @@
time_str, volumn = self.__get_latest_record(code)
return time_str, volumn
-if __name__ == '__main__':
- JueJinBuy1VolumnManager().save("001203", "15:00:00", 40586553, 12.12)
\ No newline at end of file
+if __name__ == '__main__':
+ JueJinBuy1VolumnManager().save("001203", "15:00:00", 40586553, 12.12)
--
Gitblit v1.8.0