From 1bd4e57aada5b4d3decf0d4088fc949c819d7864 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 05 十一月 2024 15:03:31 +0800
Subject: [PATCH] 刪除同花顺时代的代码
---
code_attribute/gpcode_manager.py | 141 -----------------------------------------------
1 files changed, 0 insertions(+), 141 deletions(-)
diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py
index 48ab178..501d851 100644
--- a/code_attribute/gpcode_manager.py
+++ b/code_attribute/gpcode_manager.py
@@ -5,7 +5,6 @@
import json
import time
-import constant
from db import redis_manager_delegate as redis_manager
from db.mysql_data_delegate import Mysqldb
from db.redis_manager_delegate import RedisUtils
@@ -13,8 +12,6 @@
from log_module.log import logger_pre_close_price
from utils import tool
import decimal
-
-from ths import l2_listen_pos_health_manager, client_manager
__redisManager = redis_manager.RedisManager(0)
__db = 0
@@ -873,141 +870,3 @@
finally:
RedisUtils.realse(redis_instance)
-
-# 鑾峰彇鍙互鎿嶄綔鐨勪綅缃�
-def get_can_listen_pos(client_id=0):
- client_ids = []
- if client_id <= 0:
- client_ids = client_manager.getValidL2Clients()
- else:
- client_ids.append(client_id)
- # random.shuffle(client_ids)
- available_positions = []
- for client_id in client_ids:
- redis_instance = __redisManager.getRedis()
- k = "listen_code-{}-*".format(client_id)
- keys = RedisUtils.keys(redis_instance, k, auto_free=False)
- # random.shuffle(keys)
- codes = []
- for key in keys:
- index = key.split("-")[-1]
- if int(index) + 1 > constant.L2_CODE_COUNT_PER_DEVICE:
- continue
- result = RedisUtils.get(redis_instance, key, auto_free=False)
- if result is None or len(result) == 0:
- available_positions.append((client_id, int(key.replace("listen_code-{}-".format(client_id), ""))))
- else:
- codes.append((key, result))
- RedisUtils.realse(redis_instance)
- # 鏌ヨ鏄惁鏈夐噸澶嶇殑浠ｇ爜
- codes_set = set()
- count = 0
- for code in codes:
- count = count + 1
- codes_set.add(code[1])
- if len(codes_set) < count:
- return client_id, int(code[0].replace("listen_code-{}-".format(client_id), ""))
-
- if available_positions:
- # 鑾峰彇鍋ュ悍鐘舵��
- available_positions_health_states = l2_listen_pos_health_manager.list_health_state(available_positions)
- # 灏介噺涓嶅垎閰嶇涓�涓綅缃�
- available_positions_new = sorted(available_positions,
- key=lambda x: (available_positions_health_states[x], 0 if x[1] == 0 else 1),
- reverse=True)
- # available_positions.sort(key=lambda x: available_positions_health_states[x], reverse=True)
- # 鍙栫1涓暟鎹�
- return available_positions_new[0][0], available_positions_new[0][1]
-
- return None, None
-
-
-# 鑾峰彇鍙互鎿嶄綔鐨勪綅缃�
-def get_free_listen_pos_count():
- client_ids = client_manager.getValidL2Clients()
- free_count = 0
- for client_id in client_ids:
- redis_instance = __redisManager.getRedis()
- try:
- k = "listen_code-{}-*".format(client_id)
- keys = RedisUtils.keys(redis_instance, k, auto_free=False)
- for key in keys:
- code = RedisUtils.get(redis_instance, key, auto_free=False)
- if not code:
- free_count += 1
- finally:
- RedisUtils.realse(redis_instance)
- return free_count
-
-
-# 鑾峰彇姝ｅ湪鐩戝惉鐨勪唬鐮佺殑浣嶇疆
-def get_listen_code_pos(code):
- val = RedisUtils.get(__redisManager.getRedis(), "code_listen_pos-{}".format(code))
- if val is None:
- return None, None
- val = json.loads(val)
- cid, pid = val[0], val[1]
- code_ = get_listen_code_by_pos(cid, pid)
- # 鏍￠獙浠ｇ爜
- if code_ == code:
- return cid, pid
- else:
- return None, None
-
-
-# 鏄惁姝ｅ湪鐩戝惉
-def is_listen(code):
- val = RedisUtils.get(__redisManager.getRedis(), "code_listen_pos-{}".format(code))
- if val is None:
- return False
- else:
- return True
- # codes = get_listen_codes()
- # return codes.__contains__(code)
-
-
-def is_listen_old(code):
- codes = get_listen_codes()
- return codes.__contains__(code)
-
-
-# 鐩戝惉鏄惁婊′簡
-def is_listen_full():
- clients = client_manager.getValidL2Clients()
- codes = get_listen_codes()
- return len(codes) >= constant.L2_CODE_COUNT_PER_DEVICE * len(clients)
-
-
-# 鏄惁姝ｅ湪鎿嶄綔
-def is_operate(code):
- return RedisUtils.get(__redisManager.getRedis(), "gp_operate-{}".format(code)) is not None
-
-
-# 璁剧疆姝ｅ湪鎿嶄綔鐨勪唬鐮�
-def set_operate(code):
- RedisUtils.setex(__redisManager.getRedis(), "gp_operate-{}".format(code), 30, "1")
-
-
-# 鎵归噺璁剧疆姝ｅ湪鎿嶄綔鐨勪唬鐮�
-def set_operates(codes):
- for code in codes:
- RedisUtils.setex(__redisManager.getRedis(), "gp_operate-{}".format(code), 30, "1")
-
-
-# 绉婚櫎姝ｅ湪鎿嶄綔鐨勪唬鐮�
-def rm_operate(code):
- RedisUtils.delete(__redisManager.getRedis(), "gp_operate-{}".format(code))
-
-
-# 鎵归噺绉婚櫎姝ｅ湪鎿嶄綔鐨勪唬鐮�
-def rm_operates(codes):
- redis_instance = __redisManager.getRedis()
- try:
- for code in codes:
- RedisUtils.delete(redis_instance, "gp_operate-{}".format(code), auto_free=False)
- finally:
- RedisUtils.realse(redis_instance)
-
-
-if __name__ == '__main__':
- get_can_listen_pos()
--
Gitblit v1.8.0