From 6e71fbcb119e7068ba35380edaa5cc66e7c71f1b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 27 十月 2022 16:21:05 +0800
Subject: [PATCH] 交易体系完善
---
gpcode_manager.py | 20 +++++++++-----------
1 files changed, 9 insertions(+), 11 deletions(-)
diff --git a/gpcode_manager.py b/gpcode_manager.py
index 9a0f239..3c6c24c 100644
--- a/gpcode_manager.py
+++ b/gpcode_manager.py
@@ -5,20 +5,15 @@
import random
import time
-import authority
-import global_util
+import client_manager
import redis_manager
import tool
-import juejin
-import data_process
import decimal
__redisManager = redis_manager.RedisManager(0)
-def set_gp_list(gpset):
- # 鑾峰彇鍩烘湰淇℃伅
- code_datas = juejin.JueJinManager.get_gp_latest_info(gpset)
+def set_gp_list(code_datas):
codes = []
name_codes = {}
for _data in code_datas:
@@ -63,8 +58,6 @@
def set_limit_up_list(gpset):
if gpset is None:
return
- # 淇濆瓨鍒板唴瀛樹腑
- global_util.add_limit_up_codes(gpset)
# 鑾峰彇鍩烘湰淇℃伅
redis_instance = __redisManager.getRedis()
# 鍒犻櫎涔嬪墠鐨�
@@ -134,6 +127,11 @@
return tool.to_price(decimal.Decimal(str(price)) * decimal.Decimal("1.1"))
+def get_limit_up_price_by_preprice(price):
+ if price is None:
+ return None
+ return tool.to_price(decimal.Decimal(str(price)) * decimal.Decimal("1.1"))
+
# 鑾峰彇璺屽仠浠�
def get_limit_down_price(code):
price = get_price_pre(code)
@@ -196,7 +194,7 @@
def get_can_listen_pos(client_id=0):
client_ids = []
if client_id <= 0:
- client_ids = data_process.getValidL2Clients()
+ client_ids = client_manager.getValidL2Clients()
else:
client_ids.append(client_id)
random.shuffle(client_ids)
@@ -245,7 +243,7 @@
# 鐩戝惉鏄惁婊′簡
def is_listen_full():
- clients = data_process.getValidL2Clients()
+ clients = client_manager.getValidL2Clients()
codes = get_listen_codes()
return len(codes) >= 8 * len(clients)
--
Gitblit v1.8.0