| | |
| | | pass |
| | | else: |
| | | if trade_progress < len(total_datas): |
| | | data = total_datas[trade_progress] |
| | | |
| | | trade_progress_datas = [] |
| | | for min_money in [30000, 20000, 10000]: |
| | | for i in range(trade_progress - 1, -1, -1): |
| | | # 是否为涨停买 |
| | | data = total_datas[i] |
| | | if L2DataUtil.is_limit_up_price_buy(total_datas[i]['val']): |
| | | if data['val']['num'] * float(data['val']['price']) > min_money: |
| | | trade_progress_datas.append({"time": data['val']['time'], |
| | |
| | | break |
| | | if trade_progress_datas: |
| | | break |
| | | |
| | | data = total_datas[trade_progress] |
| | | trade_progress_datas.append({"time": data['val']['time'], |
| | | "num": data['val']['num'], "money": money_desc(round( |
| | | data['val']['num'] * float(data['val']['price']) * 100))}) |
| | | params["trade_data"]["trade_progress"] = trade_progress_datas |
| | | |
| | | # 买入信号 |
| | | buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache( |