| | |
| | | else: |
| | | if trade_progress < len(total_datas): |
| | | data = total_datas[trade_progress] |
| | | params["trade_data"]["trade_progress"] = {"time": data['val']['time'], |
| | | "num": data['val']['num'], "money": round( |
| | | data['val']['num'] * float(data['val']['price']) * 100 / 10000, 1)} |
| | | trade_progress_datas = [] |
| | | for min_money in [30000, 20000, 10000]: |
| | | for i in range(trade_progress - 1, -1, -1): |
| | | # 是否为涨停买 |
| | | 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'], |
| | | "num": data['val']['num'], "money": money_desc(round( |
| | | data['val']['num'] * float(data['val']['price']) * 100))}) |
| | | break |
| | | if trade_progress_datas: |
| | | break |
| | | |
| | | trade_progress_datas.append({"time": data['val']['time'], |
| | | "num": data['val']['num'], "money": money_desc(round( |
| | | data['val']['num'] * float(data['val']['price']) * 100))}) |
| | | |
| | | # 买入信号 |
| | | 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( |
| | |
| | | extra_datas)) |
| | | elif type == trade_record_log_util.TYPE_REAL_PLACE_ORDER_POSITION: |
| | | _datas = [] |
| | | MIN_MONEYS = [30000, 20000, 10000] |
| | | for min_money in MIN_MONEYS: |
| | | for i in range(data['index'], 0, -1): |
| | | if L2DataUtil.is_limit_up_price_buy(total_datas[i]['val']) and total_datas[i]['val'][ |
| | | 'num'] * float(total_datas[i]['val']['price']) >= min_money: |
| | | _datas.append(f"【{format_l2_data(total_datas[i])}】") |
| | | if len(_datas) >= 1: |
| | | break |
| | | if len(_datas) >= 1: |
| | | break |
| | | for i in range(data['index'], 0, -1): |
| | | if L2DataUtil.is_limit_up_price_buy(total_datas[i]['val']) and total_datas[i]['val'][ |
| | | 'num'] * float(total_datas[i]['val']['price']) >= 3000: |
| | | if len(_datas) >= 2: |
| | | if _datas and _datas[-1]["index"] == i: |
| | | break |
| | | _datas.append(f"【{format_l2_data(total_datas[i])}】") |
| | | break |
| | | records_new_data.append( |
| | | (time_, "实际挂单位", "".join(_datas), [])) |
| | | |