From 06df6025404f0aa1cae1bff229c00bb09db0a861 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 27 十一月 2023 16:42:56 +0800
Subject: [PATCH] 新版选票机制实行
---
test/l2_trade_test.py | 22 +++++++++++++---------
1 files changed, 13 insertions(+), 9 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index c74b22f..1d04262 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -10,7 +10,7 @@
from copy import deepcopy
from unittest import mock
-from code_attribute import big_money_num_manager, gpcode_manager
+from code_attribute import big_money_num_manager, gpcode_manager, code_nature_analyse
from db.redis_manager_delegate import RedisUtils
from l2.huaxin import huaxin_delegate_postion_manager
from l2.l2_sell_manager import L2MarketSellManager
@@ -85,7 +85,7 @@
except Exception as e:
pass
- # @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
+ @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_trade(self):
trade_manager.TradeStateManager().open_buy()
threading.Thread(target=async_log_util.run_sync, daemon=True).start()
@@ -185,7 +185,8 @@
time_str = time_str[:6]
time_str = f"{time_str[0:2]}:{time_str[2:4]}:{time_str[4:6]}"
L2MarketSellManager().set_current_total_sell_data(code, time_str,
- l2_m["totalAskVolume"] * l2_m["avgAskPrice"], l2_m["totalAskVolume"])
+ l2_m["totalAskVolume"] * l2_m["avgAskPrice"],
+ l2_m["totalAskVolume"])
break
for tp in trade_progress_list:
@@ -213,21 +214,24 @@
l2.l2_data_util.local_today_datas[code] = total_datas
l2.l2_data_util.load_num_operate_map(l2.l2_data_util.local_today_num_operate_map, code, total_datas, True)
- @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
+ # @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_block(self):
- code = "000628"
- KPLCodeJXBlockManager().load_jx_blocks(code, 17.96, 17.96)
+ code = "000903"
+ KPLCodeJXBlockManager().load_jx_blocks(code, 2.9, 2.9)
block_info.init_code(code)
kpl_data_manager.KPLLimitUpDataRecordManager.load_total_datas()
yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes()
- kpl_data_manager.KPLLimitUpDataRecordManager.latest_origin_datas = kpl_data_manager.KPLDataManager.get_data(
- kpl_util.KPLDataType.LIMIT_UP)
+ kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(),
+ kpl_data_manager.KPLDataManager.get_data(
+ kpl_util.KPLDataType.LIMIT_UP))
CodePlateKeyBuyManager.update_can_buy_blocks(code,
kpl_data_manager.KPLLimitUpDataRecordManager.latest_origin_datas,
kpl_data_manager.KPLLimitUpDataRecordManager.total_datas,
yesterday_codes,
- block_info.get_before_blocks_dict())
+ block_info.get_before_blocks_dict(),
+ kpl_data_manager.KPLLimitUpDataRecordManager.get_current_code_block_dict())
+ l2.l2_data_manager_new.L2TradeDataProcessor.can_buy_first(code, None)
@unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_transaction(self):
--
Gitblit v1.8.0