l2数据计算优化

Administrator

2022-09-16 b7000cbf5e67e90abe53e96a4ea931afbf906e24

 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


# 代码对应的价格是否正确
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)))


# 获取客户端IP
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]


# 保存量能