From be73e2b78857adaf006063275726b69c4c60f0d7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 12 十月 2022 11:54:25 +0800
Subject: [PATCH] 买撤策略修改；加入报警功能

---
 data_process.py |    8 ++++++--
 1 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/data_process.py b/data_process.py
index 2806ab7..2dafd7d 100644
--- a/data_process.py
+++ b/data_process.py
@@ -11,6 +11,7 @@
 
 # 缁熻浠婃棩鍗栧嚭
 # 缁熻浠婃棩涔板叆
+import ths_util
 import tool
 from code_data_util import ZYLTGBUtil
 
@@ -161,7 +162,7 @@
         if float(data["zyltgb"]) > 0:
             _list.append(_dict)
             # 淇濆瓨10澶�
-            ZYLTGBUtil.save(data["code"],data["zyltgb"],data["zyltgb_unit"])
+            ZYLTGBUtil.save(data["code"], data["zyltgb"], data["zyltgb_unit"])
     mongo_data.save("ths-zylt", _list)
 
 
@@ -170,6 +171,7 @@
         return
     redis = __redisManager.getRedis();
     redis.setex("client-active-{}".format(client_id), 10, json.dumps((host, thsDead)))
+    ths_util.set_ths_dead_state(client_id, thsDead)
 
 
 def getValidL2Clients():
@@ -178,7 +180,9 @@
     client_ids = []
     for k in keys:
         _id = k.split("client-active-")[1]
-        client_ids.append(_id)
+        # 瀹㈡埛绔悓鑺遍『娌″崱姝绘墠鑳藉姞鍏�
+        if not ths_util.is_ths_dead(_id):
+            client_ids.append(_id)
     l2_clients = authority.get_l2_clients()
 
     return list(set(client_ids).intersection(set(l2_clients)))

--
Gitblit v1.8.0