| | |
|---|
| | | datas = data["data"] |
|---|
| | | cls.__save_l1_current_price(datas) |
|---|
| | | cls.__process_buy_open_limit_up_datas(datas) |
|---|
| | | # 根据高标的实时涨幅计算拉黑板块 |
|---|
| | | rate_dict = {d[0]: d[2] for d in datas} |
|---|
| | | cls.__process_l1_data_thread_pool.submit( |
|---|
| | | lambda: KPLPlateForbiddenManager().compute(rate_dict)) |
|---|
| | | # 9:30之前采用非线程 |
|---|
| | | if int(tool.get_now_time_str().replace(":", "")) < int("093000") or True: |
|---|
| | | HuaXinL1TargetCodesManager.set_level_1_codes_datas(datas, request_id=request_id) |
|---|
| | |
|---|
| | | # 加载自由流通量 |
|---|
| | | global_data_loader.load_zyltgb_volume_from_db() |
|---|
| | | # 获取最近7天涨停数最多的板块 |
|---|
| | | try: |
|---|
| | | if not KPLPlateForbiddenManager().list_all_cache() and tool.get_now_time_as_int() > int("070000"): |
|---|
| | | # 没有添加过的时候需要重新添加 |
|---|
| | | datas_ = LatestLimitUpBlockManager().statistics_limit_up_block_infos() |
|---|
| | | if datas_: |
|---|
| | | for data_ in datas_: |
|---|
| | | # 连续2天的板块就不买 |
|---|
| | | if data_[2] >= 2: |
|---|
| | | KPLPlateForbiddenManager().save_plate(data_[0]) |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | # try: |
|---|
| | | # if not KPLPlateForbiddenManager().list_all_cache() and tool.get_now_time_as_int() > int("070000"): |
|---|
| | | # # 没有添加过的时候需要重新添加 |
|---|
| | | # datas_ = LatestLimitUpBlockManager().statistics_limit_up_block_infos() |
|---|
| | | # if datas_: |
|---|
| | | # for data_ in datas_: |
|---|
| | | # # 连续2天的板块就不买 |
|---|
| | | # if data_[2] >= 2: |
|---|
| | | # KPLPlateForbiddenManager().save_plate(data_[0]) |
|---|
| | | # except: |
|---|
| | | # pass |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_read, trade_ipc_addr): |
|---|
