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