| | |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | |
|---|
| | | previous_trading_date = history_k_data_util.HistoryKDatasUtils.get_previous_trading_date(tool.get_now_date_str()) |
|---|
| | | if previous_trading_date is None: |
|---|
| | | raise Exception("上一个交易日获取失败") |
|---|
| | | latest_trading_date = history_k_data_util.get_k_bar_dead_date() |
|---|
| | | # 刷新目标代码的自由流通量 |
|---|
| | | codes_sh, codes_sz = l1_subscript_codes_manager.get_codes(False) |
|---|
| | | codes = set() |
|---|
| | |
|---|
| | | for code_byte in codes_sz: |
|---|
| | | codes.add(code_byte.decode()) |
|---|
| | | # 获取已经更新的数据 |
|---|
| | | codes_record = HistoryKDataManager().get_history_bars_codes(previous_trading_date) |
|---|
| | | codes_record = HistoryKDataManager().get_history_bars_codes(latest_trading_date) |
|---|
| | | codes = codes - codes_record |
|---|
| | | threading.Thread(target=lambda: update(codes), daemon=True).start() |
|---|
| | | |
|---|
