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