From cab2f4605d16dee36270138a8f7dfdd79dc6d663 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 11 十月 2023 12:46:44 +0800
Subject: [PATCH] 交易记录日志优化

---
 output/code_info_output.py |   21 ++++++++++++++-------
 1 files changed, 14 insertions(+), 7 deletions(-)

diff --git a/output/code_info_output.py b/output/code_info_output.py
index c47e614..2262594 100644
--- a/output/code_info_output.py
+++ b/output/code_info_output.py
@@ -6,6 +6,7 @@
 # 涓嬪崟鍙傛暟淇℃伅
 # 閫夎偂瀹�
 # 甯傚満鐑害
+import logging
 import sys
 import time
 import code_attribute
@@ -352,7 +353,7 @@
                 data = record[2]
                 if type == trade_record_log_util.TYPE_PLACE_ORDER:
                     records_new_data.append((time_, "寮�鐩樺暒鎺ㄨ崘鍘熷洜",
-                                             f"{'銆�'.join(data['kpl_blocks'])}",
+                                             f"{'銆�'.join([k[1] for k in data['kpl_blocks']])}",
                                              None))
                     extra_datas = []
                     if data['big_num_indexes']:
@@ -367,7 +368,12 @@
                                              f"銆恵format_l2_data(total_datas[data['buy_single_index']])}銆�-銆恵format_l2_data(total_datas[data['buy_exec_index']])}銆�",
                                              data))
                 elif type == trade_record_log_util.TYPE_REAL_PLACE_ORDER_POSITION:
-                    records_new_data.append((time_, "瀹為檯鎸傚崟浣�", f"銆恵format_l2_data(data['index'])}銆�", None))
+                    for i in range(data['index'], 0, -1):
+                        if total_datas[i]['val']['num'] * float(total_datas[i]['val']['price']) >= 3000:
+                            records_new_data.append(
+                                (time_, "瀹為檯鎸傚崟浣�", f"銆恵format_l2_data(total_datas[i])}銆�", None))
+                            break
+
                 elif type == trade_record_log_util.TYPE_CANCEL_WATCH_INDEXES:
                     indexes = data['watch_indexes']
                     if indexes:
@@ -395,13 +401,14 @@
                     records_new_data.append((time_, "鎾ゅ崟", f"鍘熷洜锛歿data['msg']}", None))
             if records_new_data:
                 for d in records_new_data:
-                    records_new.append(f"銆恵d[0]}銆�"+"{:<10}".format(d[1])+d[2])
-        except:
-            pass
+                    records_new.append(f"銆恵d[0]}銆�" + "{:<10}".format(f'銆恵d[1]}銆�') + d[2])
+        except Exception as e:
+            logging.exception(e)
 
     return break_time, records_new, records_new_data
 
 
 if __name__ == '__main__':
-    ts = ("0", "1", "2", "3")
-    print(','.join(ts[:-1]))
+    code = '603131'
+    l2_data_util.load_l2_data(code)
+    __load_trade_record(code, l2_data_util.local_today_datas.get(code))

--
Gitblit v1.8.0