Changes

Administrator

2022-08-25 34491829675033e41715648b1e92f339bf2f35d1

 data_process.py

@@ -14,7 +14,7 @@
# 统计今日买入
import tool

redisManager = redis_manager.RedisManager()
__redisManager = redis_manager.RedisManager(0)


def _mysql_insert_data(day, code, item, conn):
@@ -94,7 +94,7 @@

# 保存L2交易队列
def saveL2TradeQueueData(code, data):
    redis = redisManager.getRedis()
    redis = __redisManager.getRedis()
    data_str = json.dumps(data)
    key = "trade-queue-{}".format(code)
    # 保存5s的数据
@@ -103,7 +103,7 @@

# 获取L2交易队列
def getL2TradeQueueData(code):
    redis = redisManager.getRedis()
    redis = __redisManager.getRedis()
    key = "trade-queue-{}".format(code)
    data_str = redis.get(key)
    if data_str is None or len(data_str) <= 0:
@@ -160,12 +160,12 @@
def saveClientActive(client_id, host):
    if client_id <= 0:
        return
    redis = redisManager.getRedis();
    redis = __redisManager.getRedis();
    redis.setex("client-active-{}".format(client_id), 10, host)


def getValidClients():
    redis = redisManager.getRedis();
    redis = __redisManager.getRedis();
    keys = redis.keys("client-active-*")
    client_ids = []
    for k in keys:
@@ -175,13 +175,13 @@


def getActiveClientIP(client_id):
    redis = redisManager.getRedis();
    redis = __redisManager.getRedis();
    return redis.get("client-active-{}".format(client_id))


# 保存量能
def saveCodeVolumn(datas):
    redis = redisManager.getRedis()
    redis = __redisManager.getRedis()
    for key in datas:
        k = "volumn-max-{}".format(key)
        redis.setex(k, tool.get_expire(), datas[key]["max_volumn"])