| | |
| | | import ths_util |
| | | import tool |
| | | from output import code_info_output |
| | | from third_data import hot_block_data_process |
| | | from third_data import hot_block_data_process, block_info |
| | | from ths import l2_listen_pos_health_manager |
| | | from trade import trade_gui, trade_data_manager, trade_manager, l2_trade_util, deal_big_money_manager, \ |
| | | first_code_score_manager, current_price_process_manager |
| | |
| | | # 根据代码获取选股宝热门概念 |
| | | day = tool.get_now_date_str() |
| | | code = data_process.parse(_str)["data"]["code"] |
| | | todays = hot_block_data_process.XGBHotBlockDataManager.list_by_code(code, day) |
| | | todays =block_info.KPLLimitUpDataRecordManager.list_by_code(code, day) |
| | | today_datas = [] |
| | | if todays: |
| | | for data in todays: |
| | | block = data[2] |
| | | block_datas = hot_block_data_process.XGBHotBlockDataManager.list_by_block(block, day) |
| | | block_datas = block_info.KPLLimitUpDataRecordManager.list_by_block(block, day) |
| | | block_datas = list(block_datas) |
| | | # 根据涨停时间排序 |
| | | block_datas.sort(key=lambda d: (d[4] if len(d[4]) > 6 else '15:00:00')) |
| | |
| | | break |
| | | # 获取前一个交易日 |
| | | last_day = juejin.JueJinManager.get_previous_trading_date(day) |
| | | lasts = hot_block_data_process.XGBHotBlockDataManager.list_by_code(code, last_day) |
| | | lasts = block_info.KPLLimitUpDataRecordManager.list_by_code(code, last_day) |
| | | last_datas = [] |
| | | if todays: |
| | | for data in lasts: |
| | | block = data[2] |
| | | block_datas = hot_block_data_process.XGBHotBlockDataManager.list_by_block(block, last_day) |
| | | block_datas = block_info.KPLLimitUpDataRecordManager.list_by_block(block, last_day) |
| | | block_datas = list(block_datas) |
| | | # 根据涨停时间排序 |
| | | block_datas.sort(key=lambda d: (d[4] if len(d[4]) > 6 else '15:00:00')) |
| | |
| | | data_dict = {} |
| | | for i in range(0, 2): |
| | | day = juejin.JueJinManager.get_previous_trading_date(day) |
| | | data_list = list(hot_block_data_process.XGBHotBlockDataManager.list_all(day)) |
| | | data_list = list(block_info.KPLLimitUpDataRecordManager.list_all(day)) |
| | | codes_set = set() |
| | | if data_list: |
| | | for d in data_list: |