| | |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.error(f"可能没有获取到涨停价：{code}") |
|---|
| | | logger_debug.exception(e) |
|---|
| | | # logger_debug.exception(e) |
|---|
| | | deal_big_order_info = None |
|---|
| | | code_name = gpcode_manager.get_code_name(code) |
|---|
| | | fresults.append((code, code_name, deal_big_order_info, deal_big_order_detail_info)) |
|---|
| | |
|---|
| | | 累计成交大单阈值管理（人为设置） |
|---|
| | | """ |
|---|
| | | __db = 3 |
|---|
| | | __redis_manager = redis_manager.RedisManager(3) |
|---|
| | | __total_big_order_threshold = {} |
|---|
| | | |
|---|
| | | def __init__(self): |
|---|
| | | self.__load_data() |
|---|
| | | |
|---|
| | | def __get_redis(self): |
|---|
| | | return self.__redis_manager.getRedis() |
|---|
| | | |
|---|
| | | def __load_data(self): |
|---|
| | | keys = redis_manager.RedisUtils.keys(self.__get_redis(), "total_radical_big_order_threshold-*") |
|---|
| | | for k in keys: |
|---|
