| | |
| | | try: |
| | | # 在data_cache中获取到推送过来的实时指数行情数据 |
| | | stock_index_dict = data_cache.stock_index_dict |
| | | now_time = datetime.datetime.now().strftime("%H:%M:%S") |
| | | now_time = data_cache.now_time |
| | | if len(stock_index_dict) == 0 and data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
| | | print(f"9:15--15:00 实时指数数据为空===={stock_index_dict}") |
| | | index_judge_thread_manager(stock_index_dict) |
| | |
| | | def get_all_stocks_current_open(current_infos): |
| | | pass |
| | | # 获取当前时间 |
| | | now_time = datetime.datetime.now().strftime("%H:%M:%S") |
| | | now_time = data_cache.now_time |
| | | # 如果当前时间大于09:25:06才运行最高价和最低价的运算 |
| | | if data_cache.LATER_OPEN_BIDDING_TIME < now_time: |
| | | # if data_cache.AFTER_CLOSING_TIME < now_time: |
| | |
| | | # 生成所有个股的最高价、最低价 字典 |
| | | def get_all_stocks_current_high_and_low(current_infos): |
| | | # 获取当前时间 |
| | | now_time = datetime.datetime.now().strftime("%H:%M:%S") |
| | | now_time = data_cache.now_time |
| | | # 如果当前时间大于09:25:06才运行最高价和最低价的运算 |
| | | if data_cache.LATER_OPEN_BIDDING_TIME < now_time: |
| | | # if data_cache.AFTER_CLOSING_TIME < now_time: |
| | |
| | | try: |
| | | now_start = time.time() |
| | | current_infos = l1_data_api.get_current_info() |
| | | now_time = datetime.datetime.now().strftime("%H:%M:%S") |
| | | now_time = data_cache.now_time |
| | | if len(current_infos) == 0 and now_time > data_cache.L1_DATA_START_TIME: |
| | | print(f"9:15后 l1数据为空=l1_data_current_infos===={current_infos}") |
| | | # for i in current_infos: |
| | |
| | | logging.info(f"set_current_info进入") |
| | | try: |
| | | now_start = time.time() |
| | | now_time = datetime.datetime.now().strftime("%H:%M:%S") |
| | | now_time = data_cache.now_time |
| | | if len(current_infos) == 0 and now_time > data_cache.L1_DATA_START_TIME: |
| | | print(f"9:15后 l1数据为空=l1_data_current_infos===={current_infos}") |
| | | # for i in current_infos: |