From b7000cbf5e67e90abe53e96a4ea931afbf906e24 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 16 九月 2022 18:51:47 +0800
Subject: [PATCH] l2数据计算优化

---
 data_process.py |   23 +++++++++++++++++++----
 1 files changed, 19 insertions(+), 4 deletions(-)

diff --git a/data_process.py b/data_process.py
index 967df73..dbf1df5 100644
--- a/data_process.py
+++ b/data_process.py
@@ -12,7 +12,6 @@
 import gpcode_manager
 import mongo_data
 
-
 # 缁熻浠婃棩鍗栧嚭
 # 缁熻浠婃棩涔板叆
 import tool
@@ -87,6 +86,7 @@
     code = data["code"]
     trade_data = data["data"]
     return code, trade_data
+
 
 # 浠g爜瀵瑰簲鐨勪环鏍兼槸鍚︽纭�
 def is_same_code_with_price(code, price):
@@ -164,11 +164,11 @@
     mongo_data.save("ths-zylt", _list)
 
 
-def saveClientActive(client_id, host):
+def saveClientActive(client_id, host, thsDead):
     if client_id <= 0:
         return
     redis = __redisManager.getRedis();
-    redis.setex("client-active-{}".format(client_id), 10, host)
+    redis.setex("client-active-{}".format(client_id), 10, json.dumps((host, thsDead)))
 
 
 def getValidL2Clients():
@@ -183,9 +183,24 @@
     return list(set(client_ids).intersection(set(l2_clients)))
 
 
+# 鑾峰彇瀹㈡埛绔疘P
 def getActiveClientIP(client_id):
     redis = __redisManager.getRedis();
-    return redis.get("client-active-{}".format(client_id))
+    val = redis.get("client-active-{}".format(client_id))
+    if val is None:
+        return None
+    val=json.loads(val)
+    return val[0]
+
+
+# 鑾峰彇瀹㈡埛绔悓鑺遍『鐘舵��
+def getTHSState(client_id):
+    redis = __redisManager.getRedis();
+    val = redis.get("client-active-{}".format(client_id))
+    if val is None:
+        return None
+    val = json.loads(val)
+    return val[1]
 
 
 # 淇濆瓨閲忚兘

--
Gitblit v1.8.0