From dc36d72459ea92e4c78e2a2eefb5655e82a3d459 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期二, 04 六月 2024 23:52:26 +0800 Subject: [PATCH] 9:25之前的开1订阅 --- code_attribute/code_data_util.py | 13 +++++++++++-- 1 files changed, 11 insertions(+), 2 deletions(-) diff --git a/code_attribute/code_data_util.py b/code_attribute/code_data_util.py index 931f0fd..8a6bd99 100644 --- a/code_attribute/code_data_util.py +++ b/code_attribute/code_data_util.py @@ -7,10 +7,11 @@ import time from code_attribute import gpcode_manager -from db import mysql_data, redis_manager -from db.redis_manager import RedisUtils +from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager +from db.redis_manager_delegate import RedisUtils from utils import tool +__db = 0 _redisManager = redis_manager.RedisManager(0) @@ -29,6 +30,8 @@ # 鑷敱娴侀�氳偂鏈伐鍏风被 class ZYLTGBUtil: + __db = 0 + @classmethod def save(cls, code, val, unit): RedisUtils.setex(_redisManager.getRedis(), "zyltgb-{}".format(code), tool.get_expire(), @@ -36,6 +39,12 @@ float(val) * 10000)) @classmethod + def save_async(cls, code, val, unit): + RedisUtils.setex_async(cls.__db, "zyltgb-{}".format(code), tool.get_expire(), + round(float(val) * 100000000) if int(unit) == 0 else round( + float(val) * 10000)) + + @classmethod def get(cls, code): val = RedisUtils.get(_redisManager.getRedis(), "zyltgb-{}".format(code)) if val is not None: -- Gitblit v1.8.0