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

---
 server.py |    6 ++++++
 1 files changed, 6 insertions(+), 0 deletions(-)

diff --git a/server.py b/server.py
index e2d1173..d3dc3ce 100644
--- a/server.py
+++ b/server.py
@@ -9,6 +9,7 @@
 import threading
 import time
 
+import alert_util
 import code_volumn_manager
 import data_process
 import gpcode_manager
@@ -16,6 +17,7 @@
 import juejin
 import l2_data_manager
 import ths_industry_util
+import ths_util
 import tool
 import trade_manager
 import l2_code_operate
@@ -223,6 +225,10 @@
                     thsDead = data.get("thsDead")
                     logger_device.info("锛坽}锛夊鎴风淇℃伅锛歿}".format(client_id, json.dumps(data)))
                     data_process.saveClientActive(int(client_id), host, thsDead)
+                    if ths_util.is_ths_dead(client_id):
+                        # TODO 閲嶅惎鍚岃姳椤�
+                        # 鎶ヨ
+                        alert_util.alarm()
                     # print("蹇冭烦锛�", client_id)
                 sk.send(return_str.encode())
 

--
Gitblit v1.8.0