| | |
|---|
| | | else: |
|---|
| | | logger_l2_error.exception(e) |
|---|
| | | |
|---|
| | | elif type == 1: |
|---|
| | | # 设置股票代码 |
|---|
| | | data_list, is_add = data_process.parseGPCode(_str) |
|---|
| | | ZYLTGBUtil.save_list(data_list) |
|---|
| | | code_list = [] |
|---|
| | | for data in data_list: |
|---|
| | | code_list.append(data["code"]) |
|---|
| | | # 获取基本信息 |
|---|
| | | code_datas = HistoryKDatasUtils.get_gp_latest_info(code_list) |
|---|
| | | # if is_add: |
|---|
| | | # gpcode_manager.add_gp_list(code_datas) |
|---|
| | | # else: |
|---|
| | | # gpcode_manager.set_gp_list(code_datas) |
|---|
| | | |
|---|
| | | if not is_add: |
|---|
| | | # 同步同花顺目标代码 |
|---|
| | | t1 = threading.Thread(target=lambda: sync_target_codes_to_ths()) |
|---|
| | | t1.setDaemon(True) |
|---|
| | | t1.start() |
|---|
| | | elif type == 2: |
|---|
| | | # 涨停代码 |
|---|
| | | dataList, is_add = data_process.parseGPCode(_str) |
|---|
