From e1788016750ad6ec1dfc28a4e6948ecaf5b326e4 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 22 二月 2024 16:03:30 +0800
Subject: [PATCH] 影子单价格修改/消息日志添加/成交太快撤单
---
msg/buy_order_msg_manager.py | 15 +++++++++++++++
1 files changed, 15 insertions(+), 0 deletions(-)
diff --git a/msg/buy_order_msg_manager.py b/msg/buy_order_msg_manager.py
index 993b854..319e288 100644
--- a/msg/buy_order_msg_manager.py
+++ b/msg/buy_order_msg_manager.py
@@ -2,12 +2,16 @@
from code_attribute import gpcode_manager
from l2 import l2_data_source_util, l2_data_util
from l2.l2_data_util import L2DataUtil
+from log_module import async_log_util
+from log_module.log import logger_kp_msg
from msg import push_msg_manager
from utils import output_util, tool
# 鍗冲皢鎴愪氦
def almost_deal(code, real_order_index, trade_index, total_datas):
+ if trade_index > real_order_index:
+ return
# 涓嬪崟3s杩囧悗鍐嶆彁閱�
if tool.trade_time_sub(total_datas[-1]["val"]["time"], total_datas[real_order_index]["val"]["time"]) <= 3:
return
@@ -32,13 +36,19 @@
if total_left_count <= 10:
push_msg_manager.push_order_almost_deal(code, code_name, real_order_index, f"鍓╀綑锛歿total_left_count}绗�",
ctype="count")
+ async_log_util.info(logger_kp_msg, f"{code}鍗冲皢鎴愪氦锛歵rade_index-{trade_index}锛宺eal_order_index-{real_order_index}锛屽墿浣欙細{total_left_count}绗�")
+
elif total_left_money < 1500 * 10000:
push_msg_manager.push_order_almost_deal(code, code_name, real_order_index,
f"鍓╀綑锛歿output_util.money_desc(total_left_money)}", ctype="money")
+ async_log_util.info(logger_kp_msg,
+ f"{code}鍗冲皢鎴愪氦锛歵rade_index-{trade_index}锛宺eal_order_index-{real_order_index}锛屽墿浣欙細{total_left_money}鍏�")
# 鐪熷疄涓嬪崟浣嶅悗闈㈣窡鍗曚笉瓒�
def follow_not_enough(code, buy_exec_index, real_order_index, total_datas):
+ if buy_exec_index > real_order_index:
+ return
# 涓嬪崟3s杩囧悗鍐嶆彁閱�
if tool.trade_time_sub(total_datas[-1]["val"]["time"], total_datas[buy_exec_index]["val"]["time"]) <= 3:
return
@@ -69,7 +79,12 @@
push_msg_manager.push_delegate_order_danger(code, code_name, buy_exec_index,
f"鍓╀綑锛歿real_place_order_after_count}绗�",
ctype="count")
+ async_log_util.info(logger_kp_msg,
+ f"{code}灏佸崟涓嶈冻锛歜uy_exec_index-{buy_exec_index}锛宺eal_order_index-{real_order_index}锛屽墿浣欙細{real_place_order_after_count}鍏�")
+
if real_place_order_after_money <= 1500 * 10000:
push_msg_manager.push_delegate_order_danger(code, code_name, buy_exec_index,
f"鍓╀綑锛歿output_util.money_desc(real_place_order_after_money)}",
ctype="money")
+ async_log_util.info(logger_kp_msg,
+ f"{code}灏佸崟涓嶈冻锛歜uy_exec_index-{buy_exec_index}锛宺eal_order_index-{real_order_index}锛屽墿浣欙細{real_place_order_after_money}鍏�")
--
Gitblit v1.8.0