From 4bb98ab3b49687265fb60754d07610d50b3b8431 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 28 六月 2024 10:55:44 +0800
Subject: [PATCH] 水下捞相关数据删除/优化目标代码处理
---
trade/trade_data_manager.py | 112 --------------------------------------------------------
1 files changed, 0 insertions(+), 112 deletions(-)
diff --git a/trade/trade_data_manager.py b/trade/trade_data_manager.py
index 9b7bca5..1189b48 100644
--- a/trade/trade_data_manager.py
+++ b/trade/trade_data_manager.py
@@ -191,7 +191,6 @@
# 浠ｇ爜瀹炴椂浠锋牸绠＄悊鍣�
class CodeActualPriceProcessor:
- __under_water_last_time_cache = {}
__code_current_rate_cache = {}
__code_current_rate_latest = {}
__db = 0
@@ -212,12 +211,6 @@
def __load_datas(cls):
__redis = cls.__get_redis()
try:
- keys = RedisUtils.keys(__redis, "under_water_last_time-*")
- for k in keys:
- code = k.split("-")[-1]
- val = RedisUtils.get(__redis, k)
- tool.CodeDataCacheUtil.set_cache(cls.__under_water_last_time_cache, code, val)
-
keys = RedisUtils.keys(__redis, "code_current_rate-*")
for k in keys:
code = k.split("-")[-1]
@@ -227,49 +220,6 @@
pass
finally:
RedisUtils.realse(__redis)
-
- # 淇濆瓨璺屼环鐨勬椂闂�
- def __save_down_price_time(self, code, time_str):
- key = "under_water_last_time-{}".format(code)
- tool.CodeDataCacheUtil.set_cache(self.__under_water_last_time_cache, code, time_str)
- RedisUtils.setex(self.__get_redis(), key, tool.get_expire(), time_str)
-
- def __remove_down_price_time(self, code):
- key = "under_water_last_time-{}".format(code)
- tool.CodeDataCacheUtil.clear_cache(self.__under_water_last_time_cache, code)
- RedisUtils.delete(self.__get_redis(), key)
-
- def __get_last_down_price_time(self, code):
- key = "under_water_last_time-{}".format(code)
- return RedisUtils.get(self.__get_redis(), key)
-
- def __get_last_down_price_time_cache(self, code):
- cache_result = tool.CodeDataCacheUtil.get_cache(self.__under_water_last_time_cache, code)
- if cache_result[0]:
- return cache_result[1]
- return None
-
- def __increment_down_price_time(self, code, seconds):
- key = "under_water_seconds-{}".format(code)
- RedisUtils.incrby(
- self.__get_redis(), key, seconds)
- # 璁剧疆涓け鏁堟椂闂�
- RedisUtils.expire(self.__get_redis(), key, tool.get_expire())
-
- def __get_down_price_time_as_seconds(self, code):
- key = "under_water_seconds-{}".format(code)
- val = RedisUtils.get(self.__get_redis(), key)
- if val is None:
- return None
- else:
- return int(val)
-
- # 娓呴櫎鎵�鏈夌殑姘翠笅鎹炴暟鎹�
- def clear_under_water_data(self):
- key = "under_water_*"
- keys = RedisUtils.keys(self.__get_redis(), key)
- for k in keys:
- RedisUtils.delete(self.__get_redis(), k)
def __save_current_price_codes_count(self, count):
key = "current_price_codes_count"
@@ -315,54 +265,6 @@
return cache_result[1]
return None
- def process_rate(self, code, rate, time_str):
- # 淇濆瓨鐩墠鐨勪唬鐮佹定骞�
- self.__save_current_rate(code, rate)
- # 9鐐瑰崐涔嬪墠鐨勬暟鎹笉澶勭悊
- if int(time_str.replace(":", "")) < int("093000"):
- return
- # now_str = tool.get_now_time_str()
- if rate >= 0:
- down_start_time = self.__get_last_down_price_time_cache(code)
- if down_start_time is None:
- return
- else:
- # 绱澧炲姞鏃堕棿
- time_second = tool.trade_time_sub(time_str, down_start_time)
- self.__increment_down_price_time(code, time_second)
- # 鍒犻櫎璧峰鏃堕棿
- self.__remove_down_price_time(code)
- else:
- # 璁板綍寮�濮嬪��
- if self.__get_last_down_price_time_cache(code) is None:
- self.__save_down_price_time(code, time_str)
-
- # datas:[(浠ｇ爜,姣斾緥)]
- def process_rates(self, datas, time_str):
- # 9鐐瑰崐涔嬪墠鐨勬暟鎹笉澶勭悊
- if int(time_str.replace(":", "")) < int("093000"):
- return
- # 淇濆瓨鐩墠鐨勪唬鐮佹定骞�
- self.__save_current_rates(datas)
-
- # now_str = tool.get_now_time_str()
- for d in datas:
- code, rate = d[0], d[1]
- if rate >= 0:
- down_start_time = self.__get_last_down_price_time_cache(code)
- if down_start_time is None:
- continue
- else:
- # 绱澧炲姞鏃堕棿
- time_second = tool.trade_time_sub(time_str, down_start_time)
- self.__increment_down_price_time(code, time_second)
- # 鍒犻櫎璧峰鏃堕棿
- self.__remove_down_price_time(code)
- else:
- # 璁板綍寮�濮嬪��
- if self.__get_last_down_price_time_cache(code) is None:
- self.__save_down_price_time(code, time_str)
-
# 淇濆瓨鐜颁环
def save_current_price(self, code, price, is_limit_up):
global_util.cuurent_prices[code] = (price, is_limit_up, round(time.time()))
@@ -378,20 +280,6 @@
def get_current_price_codes_count(self):
return self.__get_current_price_codes_count()
-
- # 鏄惁涓烘按涓嬫崬
- def is_under_water(self, code, now_time=None):
- time_seconds = self.__get_down_price_time_as_seconds(code)
- if time_seconds is None:
- return False
- else:
- if time_seconds >= constant.UNDER_WATER_PRICE_TIME_AS_SECONDS:
- if now_time is None:
- now_time = tool.get_now_time_str()
- space = tool.trade_time_sub(now_time, "09:30:00")
- if space > 0 and time_seconds / space >= 0.2:
- return True
- return False
# 褰撳墠浠ｇ爜鏄惁娑ㄥ仠
def current_is_limit_up(self, code):
--
Gitblit v1.8.0