From 556942d1132123ef608c174d9bca91aa818f6ccb Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 19 八月 2025 16:57:32 +0800
Subject: [PATCH] bug修复/接口修改/续买bug修改
---
code_attribute/today_max_price_manager.py | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/code_attribute/today_max_price_manager.py b/code_attribute/today_max_price_manager.py
index 96b67fd..e07764b 100644
--- a/code_attribute/today_max_price_manager.py
+++ b/code_attribute/today_max_price_manager.py
@@ -50,31 +50,31 @@
return False
return True
- def set_price_info(self, code, price, time, sell1_info):
+ def set_price_info(self, code, price, time_str, sell1_info):
"""
璁剧疆浠锋牸淇℃伅
@param sell1_info: 鍗�1淇℃伅锛�(鍗�1浠�, 鍗�1閲�)
@param code:
@param price:
- @param time:
+ @param time_str:
@return:
"""
+ price_info = (price, time_str, sell1_info)
old_price_info = self.__max_price_info_cache.get(code)
- if old_price_info and old_price_info[0] >= price:
- return
- price_info = (price, time, sell1_info)
- tool.CodeDataCacheUtil.set_cache(self.__max_price_info_cache, code, price_info)
- RedisUtils.setex_async(
- self.__db, "max_price_info-{}".format(code), tool.get_expire(), json.dumps(price_info))
+ if not old_price_info or old_price_info[0] < price:
+ tool.CodeDataCacheUtil.set_cache(self.__max_price_info_cache, code, price_info)
+ RedisUtils.setex_async(
+ self.__db, "max_price_info-{}".format(code), tool.get_expire(), json.dumps(price_info))
# async_log_util.info(logger_debug, f"鏈�澶х幇浠�:{code}-{price_info}")
+ # 缁熻娑ㄥ仠鎸佺画鏃堕棿
if self.__is_limit_up(code, price, sell1_info):
if code not in self.__limit_up_latest_info_cache:
- self.__limit_up_latest_info_cache[code] = time
+ self.__limit_up_latest_info_cache[code] = time_str
else:
if code not in self.__limit_up_records_cache:
self.__limit_up_records_cache[code] = []
if code in self.__limit_up_latest_info_cache:
- limit_up_info = (self.__limit_up_latest_info_cache.get(code), time)
+ limit_up_info = (self.__limit_up_latest_info_cache.get(code), time_str)
self.__limit_up_records_cache[code].append(limit_up_info)
self.__limit_up_latest_info_cache.pop(code)
async_log_util.info(logger_limit_up_record, f"{code}-{limit_up_info}")
--
Gitblit v1.8.0