| | |
|---|
| | | # 调用所有以current信息为核心策略的函数 |
|---|
| | | def strategic_thread_manager(current_info): |
|---|
| | | if current_info is not None: |
|---|
| | | symbol_code = current_info[0] |
|---|
| | | data_cache.current_l1_dict[symbol_code] = current_info |
|---|
| | | # 调用交易策略模块中的涨幅视界策略 |
|---|
| | | # 买入策略调用 |
|---|
| | | buying_strategy.growth_view_strategy(current_info) |
|---|
| | |
|---|
| | | # print(f"i===={i}") |
|---|
| | | get_all_stocks_current_open(current_infos) |
|---|
| | | get_all_stocks_current_high_and_low(current_infos) |
|---|
| | | |
|---|
| | | # 保存现价 |
|---|
| | | for current_info in current_infos: |
|---|
| | | data_cache.current_l1_dict[current_info[0]] = current_info |
|---|
| | | |
|---|
| | | for current_info in current_infos: |
|---|
| | | try: |
|---|
| | | if current_info is not None: |
|---|
| | |
|---|
| | | get_all_stocks_current_open(current_infos) |
|---|
| | | get_all_stocks_current_high_and_low(current_infos) |
|---|
| | | if current_infos: |
|---|
| | | # 保存现价 |
|---|
| | | for current_info in current_infos: |
|---|
| | | data_cache.current_l1_dict[current_info[0]] = current_info |
|---|
| | | |
|---|
| | | # 分批处理数据 |
|---|
| | | ds = [] |
|---|
| | | total_count = len(current_infos) |
|---|
