From 403f53e86f04ce0efb285d5d60c8519ab8ce1e15 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 15 九月 2023 10:56:00 +0800 Subject: [PATCH] 注释下单阻止 --- code_attribute/gpcode_manager.py | 8 ++++---- 1 files changed, 4 insertions(+), 4 deletions(-) diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py index 3a8cc06..425d809 100644 --- a/code_attribute/gpcode_manager.py +++ b/code_attribute/gpcode_manager.py @@ -13,6 +13,7 @@ from ths import l2_listen_pos_health_manager, client_manager __redisManager = redis_manager.RedisManager(0) +__db = 0 class CodesNameManager: @@ -510,7 +511,8 @@ def is_in_gp_pool(code): - return RedisUtils.sismember(__redisManager.getRedis(), "gp_list", code) or FirstGPCodesManager().is_in_first_gp_codes_cache(code) + return RedisUtils.sismember(__redisManager.getRedis(), "gp_list", + code) or FirstGPCodesManager().is_in_first_gp_codes_cache(code) def get_gp_list(): @@ -620,14 +622,12 @@ # datas:[(code,price)] def set_prices(datas): - pipe = __redisManager.getRedis().pipeline() for d in datas: code, price = d[0], d[1] if code in __current_price_cache and __current_price_cache[code] == price: continue __current_price_cache[code] = price - RedisUtils.setex(pipe, "price-{}".format(code), tool.get_expire(), price) - pipe.execute() + RedisUtils.setex_async(__db, "price-{}".format(code), tool.get_expire(), price) # 鑾峰彇姝e湪鐩戝惉鐨勪唬鐮� -- Gitblit v1.8.0