From d424997fce8151bb020ed7d33a0fa6fb74e5be9c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 09 一月 2025 14:47:46 +0800
Subject: [PATCH] BUG修复
---
third_data/code_plate_key_manager.py | 45 +++++++++++++++++++++++++++++++++------------
1 files changed, 33 insertions(+), 12 deletions(-)
diff --git a/third_data/code_plate_key_manager.py b/third_data/code_plate_key_manager.py
index 3e2f5d2..c02582c 100644
--- a/third_data/code_plate_key_manager.py
+++ b/third_data/code_plate_key_manager.py
@@ -222,7 +222,10 @@
# 寮�鐩樺暒绂佹浜ゆ槗鏉垮潡绠＄悊
class KPLPlateForbiddenManager:
- __redisManager = redis_manager.RedisManager(3)
+ """
+ 涓嶈兘涔扮殑鏉垮潡绠＄悊
+ """
+ __redis_manager = redis_manager.RedisManager(3)
__kpl_forbidden_plates_cache = set()
__instance = None
@@ -237,17 +240,22 @@
def __load_datas(cls):
__redis = cls.__get_redis()
try:
- __kpl_forbidden_plates_cache = RedisUtils.smembers(__redis, "kpl_forbidden_plates")
+ cls.__kpl_forbidden_plates_cache = RedisUtils.smembers(__redis, "kpl_forbidden_plates")
finally:
RedisUtils.realse(__redis)
@classmethod
def __get_redis(cls):
- return cls.__redisManager.getRedis()
+ return cls.__redis_manager.getRedis()
def save_plate(self, plate):
self.__kpl_forbidden_plates_cache.add(plate)
RedisUtils.sadd(self.__get_redis(), "kpl_forbidden_plates", plate)
+ RedisUtils.expire(self.__get_redis(), "kpl_forbidden_plates", tool.get_expire())
+
+ def delete_plate(self, plate):
+ self.__kpl_forbidden_plates_cache.discard(plate)
+ RedisUtils.srem(self.__get_redis(), "kpl_forbidden_plates", plate)
RedisUtils.expire(self.__get_redis(), "kpl_forbidden_plates", tool.get_expire())
def list_all(self):
@@ -255,6 +263,11 @@
def list_all_cache(self):
return self.__kpl_forbidden_plates_cache
+
+ def is_in_cache(self, plate):
+ if self.__kpl_forbidden_plates_cache and plate in self.__kpl_forbidden_plates_cache:
+ return True
+ return False
class LimitUpCodesPlateKeyManager:
@@ -377,13 +390,13 @@
@return:
"""
# 娴佸叆闃堝��
- THRESHOLD_MONEY = 100 * (tool.trade_time_sub(tool.get_now_time_str(), "09:30:00") // 60) + 1000
- THRESHOLD_MONEY = min(THRESHOLD_MONEY, 10000)
- THRESHOLD_MONEY = max(THRESHOLD_MONEY, 1000)
- THRESHOLD_MONEY = THRESHOLD_MONEY * 10000
- # THRESHOLD_MONEY = 0
+ # THRESHOLD_MONEY = 50 * (tool.trade_time_sub(tool.get_now_time_str(), "09:30:00") // 60) + 1000
+ # THRESHOLD_MONEY = min(THRESHOLD_MONEY, 10000)
+ # THRESHOLD_MONEY = max(THRESHOLD_MONEY, 1000)
+ # THRESHOLD_MONEY = THRESHOLD_MONEY * 10000
+ THRESHOLD_MONEY = 0
# 鏈�澶ф暟閲�
- MAX_COUNT = cls.get_jingxuan_in_block_threshold_count()
+ # MAX_COUNT = cls.get_jingxuan_in_block_threshold_count()
cls.top_in_list_cache = datas
blocks = set()
@@ -412,9 +425,17 @@
break
if has_code:
count += 1
-
- if count >= MAX_COUNT:
- break
+ if count == 10:
+ strong = cls.get_market_strong()
+ if strong is None:
+ strong = 60
+ if data[3] > 3e7:
+ # 澶т簬3鍗冧竾
+ THRESHOLD_MONEY = int((1 - strong / 200) * data[3])
+ else:
+ THRESHOLD_MONEY = data[3]
+ # if count >= MAX_COUNT:
+ # break
# 璁板綍绮鹃�夋祦鍑烘棩蹇�
async_log_util.info(logger_kpl_jx_in, f"鍘熸暟鎹細{datas[:50]} 鏉垮潡锛歿blocks}")
blocks = list(blocks)
--
Gitblit v1.8.0