From 2a1af722fe2e2575cfb82d4f108e89603dfc8096 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 08 四月 2025 14:43:06 +0800
Subject: [PATCH] 添加日志
---
servers/server.py | 22 ++++++++++++++--------
1 files changed, 14 insertions(+), 8 deletions(-)
diff --git a/servers/server.py b/servers/server.py
index d777744..d3a4faf 100644
--- a/servers/server.py
+++ b/servers/server.py
@@ -22,7 +22,7 @@
current_price_process_manager, trade_juejin, trade_constant
import l2.transaction_progress
-from log_module.log import logger_trade_delegate, logger_buy_1_volumn_record, \
+from log_module.log import logger_trade_delegate, logger_buy_1_volumn_record, \
logger_l2_trade_queue, logger_l2_trade_buy_queue, logger_debug
from trade.huaxin import huaxin_trade_record_manager
from trade.trade_manager import TradeTargetCodeModeManager
@@ -258,7 +258,8 @@
limit_up_price = gpcode_manager.get_limit_up_price(code)
if limit_up_price is not None:
- code_price_manager.Buy1PriceManager().process(code, buy_one_price, buy_one_volumn, buy_time, limit_up_price,
+ code_price_manager.Buy1PriceManager().process(code, buy_one_price, buy_one_volumn, buy_time,
+ limit_up_price,
sell_one_price, sell_one_volumn)
_start_time = time.time()
msg += "涔�1浠锋牸澶勭悊锛�" + f"{_start_time - __start_time} "
@@ -276,14 +277,16 @@
buy_one_price_ = decimal.Decimal(round(float(buy_one_price), 2)).quantize(
decimal.Decimal("0.00"))
# 鑾峰彇鎵ц浣嶆椂闂�
- order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code)
+ order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(
+ code)
if True:
# 鍙湁涓嬪崟杩囧悗鎵嶈幏鍙栦氦鏄撹繘搴�
exec_time = None
try:
if order_begin_pos.buy_exec_index and order_begin_pos.buy_exec_index > -1:
exec_time = \
- l2.l2_data_util.local_today_datas.get(code)[order_begin_pos.buy_exec_index]["val"]["time"]
+ l2.l2_data_util.local_today_datas.get(code)[
+ order_begin_pos.buy_exec_index]["val"]["time"]
except:
pass
buy_progress_index = self.tradeBuyQueue.compute_traded_index(code,
@@ -291,7 +294,9 @@
buy_queue_result_list,
exec_time)
if buy_progress_index is not None:
- LCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index, buy_progress_index,
+ LCancelBigNumComputer().set_trade_progress(code,
+ order_begin_pos.buy_single_index,
+ buy_progress_index,
l2.l2_data_util.local_today_datas.get(
code))
@@ -421,7 +426,8 @@
state = trade_manager.CodesTradeStateManager().get_trade_state(code)
if state == trade_constant.TRADE_STATE_BUY_PLACE_ORDER or state == trade_constant.TRADE_STATE_BUY_DELEGATED or state == trade_constant.TRADE_STATE_BUY_CANCEL_ING:
try:
- l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "鎵嬪姩鎾ら攢", cancel_type=trade_constant.CANCEL_TYPE_HUMAN)
+ l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "鎵嬪姩鎾ら攢",
+ cancel_type=trade_constant.CANCEL_TYPE_HUMAN)
return_str = json.dumps({"code": 0})
except Exception as e:
return_str = json.dumps({"code": 2, "msg": str(e)})
@@ -444,7 +450,7 @@
data = json.loads(_str)
codes = data["data"]["codes"]
for code in codes:
- l2_trade_util.forbidden_trade(code, msg="鎵嬪姩鍔犲叆",force= true)
+ l2_trade_util.forbidden_trade(code, msg="鎵嬪姩鍔犲叆", force=True)
name = gpcode_manager.get_code_name(code)
if not name:
results = HistoryKDatasUtils.get_gp_codes_names([code])
@@ -688,4 +694,4 @@
trade_manager.save_trade_success_data(fdatas)
except:
pass
- time.sleep(1.5)
\ No newline at end of file
+ time.sleep(1.5)
--
Gitblit v1.8.0