From 9972c26c36c18a1ca5b636964a38ba1cf56a1208 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期一, 23 十月 2023 17:44:55 +0800 Subject: [PATCH] 调整下单金额/调整输出/调整股价过高判断 --- output/code_info_output.py | 32 ++++++++++++++++++++++++++++---- 1 files changed, 28 insertions(+), 4 deletions(-) diff --git a/output/code_info_output.py b/output/code_info_output.py index 804230e..0eb1555 100644 --- a/output/code_info_output.py +++ b/output/code_info_output.py @@ -155,9 +155,22 @@ 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( @@ -375,12 +388,23 @@ 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), [])) -- Gitblit v1.8.0