买撤策略修改；加入报警功能

Administrator

2022-10-12 be73e2b78857adaf006063275726b69c4c60f0d7

 data_process.py

@@ -11,6 +11,7 @@

# 统计今日卖出
# 统计今日买入
import ths_util
import tool
from code_data_util import ZYLTGBUtil

@@ -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,6 +180,8 @@
    client_ids = []
    for k in keys:
        _id = k.split("client-active-")[1]
        # 客户端同花顺没卡死才能加入
        if not ths_util.is_ths_dead(_id):
        client_ids.append(_id)
    l2_clients = authority.get_l2_clients()