From 954e42723fab626b33f6dbff9246bd235981fe7a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 09 十二月 2022 19:22:38 +0800
Subject: [PATCH] 撤单策略初步修改
---
trade_data_manager.py | 17 ++++++++++++++---
1 files changed, 14 insertions(+), 3 deletions(-)
diff --git a/trade_data_manager.py b/trade_data_manager.py
index bc6c1f9..a6e40ba 100644
--- a/trade_data_manager.py
+++ b/trade_data_manager.py
@@ -183,6 +183,8 @@
def __increment_down_price_time(self, code, seconds):
key = "under_water_seconds-{}".format(code)
self.__get_redis().incrby(key, seconds)
+ # 璁剧疆涓け鏁堟椂闂�
+ self.__get_redis().expire(key, tool.get_expire())
def __get_down_price_time_as_seconds(self, code):
key = "under_water_seconds-{}".format(code)
@@ -192,14 +194,24 @@
else:
return int(val)
- def __save_current_price_codes_count(self,count):
+ # 娓呴櫎鎵�鏈夌殑姘翠笅鎹炴暟鎹�
+ def clear_under_water_data(self):
+ key = "under_water_*"
+ keys = self.__get_redis().keys(key)
+ for k in keys:
+ self.__get_redis().delete(k)
+
+ def __save_current_price_codes_count(self, count):
key = "current_price_codes_count"
- self.__get_redis().setex(key,10,count)
+ self.__get_redis().setex(key, 10, count)
def __get_current_price_codes_count(self):
key = "current_price_codes_count"
count = self.__get_redis().get(key)
return 0 if count is None else count
+
+
+
def process_rate(self, code, rate, time_str):
# 9鐐瑰崐涔嬪墠鐨勬暟鎹笉澶勭悊
@@ -232,7 +244,6 @@
def get_current_price_codes_count(self):
return self.__get_current_price_codes_count()
-
# 鏄惁涓烘按涓嬫崬
def is_under_water(self, code):
--
Gitblit v1.8.0