From ad3cc1a24c4b413bae3069cc6d1c2a1923540ce3 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 25 七月 2025 15:51:48 +0800 Subject: [PATCH] 开盘啦TCP请求/委托数据持久化异步处理 --- code_attribute/big_money_num_manager.py | 11 ++++++----- 1 files changed, 6 insertions(+), 5 deletions(-) diff --git a/code_attribute/big_money_num_manager.py b/code_attribute/big_money_num_manager.py index fb481a1..14d86d8 100644 --- a/code_attribute/big_money_num_manager.py +++ b/code_attribute/big_money_num_manager.py @@ -3,16 +3,17 @@ """ # 澶у崟绠$悊 -from db import redis_manager -from db.redis_manager import RedisUtils +from db import redis_manager_delegate as redis_manager +from db.redis_manager_delegate import RedisUtils from utils import tool -__redisManager = redis_manager.RedisManager(0) +__db = 0 +__redisManager = redis_manager.RedisManager(__db) # 鏄惁涓哄ぇ鍗� def is_big_num(val): - if int(val["num"]) >= 8000 or int(val["num"]) * float(val["price"]) >= 30000: + if int(val["num"]) >= 8999 or int(val["num"]) * float(val["price"]) >= 29900: return True else: return False @@ -25,7 +26,7 @@ if code not in __big_money_cache: __big_money_cache[code] = 0 __big_money_cache[code] += num - RedisUtils.incrby_async(__redisManager.getRedis(), "big_money-{}".format(code), num) + RedisUtils.incrby_async(__db, "big_money-{}".format(code), num) # 璁剧疆杩囨湡鏃堕棿 -- Gitblit v1.8.0