# 买1量管理
|
import decimal
|
import json
|
|
import gpcode_manager
|
import redis_manager
|
import tool
|
import trade_manager
|
|
|
class THSBuy1VolumnManager:
|
__redisManager = redis_manager.RedisManager(1)
|
__last_data = {}
|
__code_time_volumn_dict = {}
|
|
def __get_redis(self):
|
return self.__redisManager.getRedis()
|
|
def __save_recod(self, code, time_str, volumn):
|
|
# 保存每一次的
|
key = "buy1_volumn-{}-{}".format(code, time_str)
|
self.__get_redis().setex(key, tool.get_expire(), volumn)
|
# 保存最近的
|
key = "buy1_volumn_latest_info-{}".format(code)
|
self.__get_redis().setex(key, tool.get_expire(), json.dumps((time_str, volumn)))
|
|
# 保存上一次数据
|
def __save_last_recod(self, code, time_str, volumn):
|
# 保存最近的
|
key = "buy1_volumn_last_info-{}".format(code)
|
self.__get_redis().setex(key, tool.get_expire(), json.dumps((time_str, volumn)))
|
|
def __get_last_record(self, code):
|
key = "buy1_volumn_last_info-{}".format(code)
|
val = self.__get_redis().get(key)
|
if val is None:
|
return None, None
|
val = json.loads(val)
|
return val[0], val[1]
|
|
def __get_latest_record(self, code):
|
key = "buy1_volumn_latest_info-{}".format(code)
|
val = self.__get_redis().get(key)
|
if val is None:
|
return None, None
|
val = json.loads(val)
|
return val[0], val[1]
|
|
# 添加记录
|
def __add_recod(self, code):
|
key = "buy1_volumn_codes"
|
self.__get_redis().sadd(key, code)
|
self.__get_redis().expire(key, 10)
|
|
# 获取当前正在监听的代码
|
def get_current_codes(self):
|
key = "buy1_volumn_codes"
|
return self.__get_redis().smembers(key)
|
|
# 返回是否需要更新数据,是否需要撤单，撤单原因
|
def save(self, code, time_str, volumn, price):
|
# 客户端数据未加载出来过滤
|
if volumn < 1:
|
return False, False, None
|
# 14:55:00之后不在处理
|
if int(time_str.replace(':', '')) >= int("145500"):
|
return False, False, None
|
|
self.__add_recod(code)
|
# 判断是否为涨停价
|
limit_up_price = gpcode_manager.get_limit_up_price(code)
|
if limit_up_price != tool.to_price(decimal.Decimal(price)):
|
# 非涨停价
|
volumn = 0
|
last_volumn = self.__last_data.get(code)
|
# 不保存和上一次相同的数据
|
if code in self.__last_data and last_volumn == volumn:
|
return False, False, None
|
self.__last_data[code] = volumn
|
|
if code not in self.__code_time_volumn_dict:
|
self.__code_time_volumn_dict[code] = {}
|
self.__code_time_volumn_dict[code][time_str] = volumn
|
# 删除倒数第2个之前的数据
|
keys = []
|
for k in self.__code_time_volumn_dict[code].keys():
|
keys.append(k)
|
keys.sort(key=lambda val: int(val.replace(":", "")))
|
if len(keys) > 2:
|
for i in range(0, len(keys) - 2):
|
self.__code_time_volumn_dict[code].pop(keys[i])
|
keys = keys[len(keys) - 2:]
|
if len(keys) == 2:
|
self.__save_last_recod(code, keys[0], self.__code_time_volumn_dict[code][keys[0]])
|
|
self.__save_recod(code, time_str, volumn)
|
|
# 如果当前已挂单
|
state = trade_manager.get_trade_state(code)
|
if state == trade_manager.TRADE_STATE_BUY_DELEGATED or state == trade_manager.TRADE_STATE_BUY_PLACE_ORDER:
|
# 判断本次与上一次的封单额是否小于5000w
|
limit_up_price = gpcode_manager.get_limit_up_price(code)
|
threshold_num = 50000000 // (limit_up_price * 100)
|
|
if volumn < threshold_num and last_volumn < threshold_num:
|
# 下降趋势
|
if volumn < last_volumn:
|
if (last_volumn - volumn) / last_volumn > 0.5:
|
return True, True, "连续两次封单量降幅达50%以上，时间：{} 封单量：{}-{}".format(time_str, last_volumn, volumn)
|
# 当封单额小于1000万需要撤单
|
min_num = 10000000 // (limit_up_price * 100)
|
if volumn < min_num:
|
return True, True, "最新封单额小于1000万，时间：{} 封单量：{}".format(time_str, volumn)
|
|
return True, False, None
|
|
# 获取校验数据
|
# 返回上一次的数据，如果没有上一次的就返回本次的
|
def get_verify_data(self, code):
|
time_str, volumn = self.__get_last_record(code)
|
if time_str is not None:
|
return time_str, volumn
|
time_str, volumn = self.__get_latest_record(code)
|
return time_str, volumn
|
|
|
class JueJinBuy1VolumnManager:
|
__redisManager = redis_manager.RedisManager(1)
|
__last_data = {}
|
|
def __get_redis(self):
|
return self.__redisManager.getRedis()
|
|
def __save_recod(self, code, time_str, volumn):
|
# 保存每一次的
|
key = "buy1_volumn_juejin-{}-{}".format(code, time_str)
|
self.__get_redis().setex(key, tool.get_expire(), volumn)
|
key = "buy1_volumn_juejin_latest_info-{}".format(code)
|
self.__get_redis().setex(key, tool.get_expire(), volumn)
|
|
def __get_latest_record(self, code):
|
key = "buy1_volumn_juejin_latest_info-{}".format(code)
|
val = self.__get_redis().get(key)
|
if val is None:
|
return None, None
|
val = json.loads(val)
|
return val[0], val[1]
|
|
# 返回是否需要更新数据
|
def save(self, code, time_str, volumn, price):
|
|
# 判断是否为涨停价
|
limit_up_price = gpcode_manager.get_limit_up_price(code)
|
if limit_up_price != tool.to_price(decimal.Decimal(price)):
|
# 非涨停价
|
volumn = 0
|
# 不保存和上一次相同的数据
|
if code in self.__last_data and self.__last_data[code] == volumn:
|
return False
|
self.__last_data[code] = volumn
|
self.__save_recod(code, time_str, volumn)
|
return True
|
|
# 获取校验数据
|
# 返回上一次的数据，如果没有上一次的就返回本次的
|
def get_verify_data(self, code):
|
time_str, volumn = self.__get_latest_record(code)
|
return time_str, volumn
|
|
|
# 买1实时价格管理器
|
class Buy1PriceManager:
|
__redisManager = redis_manager.RedisManager(0)
|
|
def __init__(self):
|
self.latest_prices = {}
|
|
def __get_redis(self):
|
return self.__redisManager.getRedis()
|
|
def __save_recod(self, code, price):
|
# 保存每一次的
|
key = "buy1_price-{}".format(code)
|
self.__get_redis().setex(key, tool.get_expire(), price)
|
|
def __get_record(self, code):
|
key = "buy1_price-{}".format(code)
|
val = self.__get_redis().get(key)
|
return val
|
|
# 保存数据
|
def save(self, code, price):
|
if self.latest_prices.get(code) == price:
|
return
|
self.latest_prices[code] = price
|
self.__save_recod(code, price)
|
|
def get_price(self, code):
|
return self.__get_record(code)
|
|
|
if __name__ == '__main__':
|
print( Buy1PriceManager().get_price("002644"))
|
