From 76016f2bffe70ac5b7871b3e32a5d0079f9a6e52 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 29 三月 2024 18:44:57 +0800
Subject: [PATCH] 添加B撤
---
test/l2_trade_test.py | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index 7be7e91..ca64687 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -19,7 +19,8 @@
from trade.huaxin import huaxin_trade_api
from utils import tool
from db import redis_manager_delegate as redis_manager
-from l2 import l2_log, l2_data_manager, transaction_progress, l2_data_manager_new, l2_transaction_data_processor
+from l2 import l2_log, l2_data_manager, transaction_progress, l2_data_manager_new, l2_transaction_data_processor, \
+ cancel_buy_strategy
from l2.transaction_progress import TradeBuyQueue
from third_data import kpl_util, kpl_data_manager, block_info
from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager, CodePlateKeyBuyManager
@@ -203,6 +204,7 @@
l2.l2_data_manager_new.L2TradeDataProcessor.process_add_datas(code, total_datas[indexs[0]:indexs[1] + 1], 0,
0)
+ @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_s_cancel(self):
code = "603363"
l2.l2_data_util.load_l2_data(code)
@@ -251,6 +253,7 @@
kpl_data_manager.KPLLimitUpDataRecordManager.get_current_reason_codes_dict())
# l2.l2_data_manager_new.L2TradeDataProcessor.can_buy_first(code, None)
+ @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_add_transaction_orders(self):
code = "603359"
date = "2024-03-14"
@@ -260,6 +263,16 @@
for d in datas:
big_sell_order_info = HuaXinSellOrderStatisticManager.add_transaction_datas(code, d)
+ def test_b_cancel(self):
+ code = "603032"
+ l2.l2_data_util.load_l2_data(code)
+ total_datas = l2.l2_data_util.local_today_datas.get(code)
+ TradeBuyQueue.get_traded_index = mock.Mock(return_value=(1000, False))
+ cancel_buy_strategy.GCancelBigNumComputer().set_real_place_order_index(code, 1015, 10000, False)
+ cancel_buy_strategy.GCancelBigNumComputer().set_trade_progress(code, 1000, 1000)
+ result = cancel_buy_strategy.GCancelBigNumComputer().need_cancel_for_b(code, 1020, 1077)
+ print(result)
+
@unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_transaction(self):
threading.Thread(target=async_log_util.run_sync, daemon=True).start()
--
Gitblit v1.8.0