'完善'

Administrator

2022-09-08 e7f8c6013d777dd5ba10b8d548d2d3db6158d37a

 gpcode_manager.py

@@ -1,13 +1,16 @@
import json
import random
import time

import authority
import global_util
import redis_manager
import tool
import juejin
import data_process
import decimal

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


def set_gp_list(gpset):
@@ -30,6 +33,8 @@

# 涨停犁碑坳
def set_limit_up_list(gpset):
    # 保存到内存中
    global_util.add_limit_up_codes(gpset)
    # 获取基本信息
    redis_instance = __redisManager.getRedis()
    # 删除之前的
@@ -84,7 +89,7 @@

# 设置收盘价
def set_price_pre(code, price):
    codes= get_listen_codes()
    codes= get_gp_list()
    if code not in codes:
        return
    redis_instance = __redisManager.getRedis()
@@ -162,14 +167,15 @@
def get_can_listen_pos(client_id=0):
    client_ids = []
    if client_id <= 0:
        client_ids = data_process.getValidClients()
        client_ids = data_process.getValidL2Clients()
    else:
        client_ids.append(client_id)

    random.shuffle(client_ids)
    for client_id in client_ids:
        redis_instance = __redisManager.getRedis()
        k = "listen_code-{}-*".format(client_id)
        keys = redis_instance.keys(k)
        random.shuffle(keys)
        codes = []
        for key in keys:
            result = redis_instance.get(key)
@@ -210,8 +216,9 @@

# 监听是否满了
def is_listen_full():
    clients = data_process.getValidL2Clients()
    codes = get_listen_codes()
    return len(codes) >= 8
    return len(codes) >= 8*len(clients)


# 是否正在操作