From 061204832c6eb71d5583fa8ebdd41479100b6b54 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 17 十一月 2023 19:03:41 +0800
Subject: [PATCH] L撤修改/已成交统计修改
---
test/l2_trade_test.py | 13 ++++++++++++-
1 files changed, 12 insertions(+), 1 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index fedc498..591a364 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -18,7 +18,7 @@
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
+from l2 import l2_log, l2_data_manager, transaction_progress, l2_data_manager_new, l2_transaction_data_manager
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, KPLCodeJXBlockManager
@@ -85,6 +85,7 @@
except Exception as e:
pass
+ @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_trade(self):
threading.Thread(target=async_log_util.run_sync, daemon=True).start()
code = "000026"
@@ -227,6 +228,16 @@
yesterday_codes,
block_info.get_before_blocks_dict())
+ def test_transaction(self):
+ threading.Thread(target=async_log_util.run_sync, daemon=True).start()
+ code = "003019"
+ l2.l2_data_util.load_l2_data(code)
+ # 璇诲彇鎴愪氦鏁版嵁
+ transaction_map = log_export.load_huaxin_transaction_map()
+ fdatas = transaction_map.get(code)
+ for d in fdatas:
+ l2_transaction_data_manager.HuaXinTransactionDatasProcessor().process_huaxin_transaction_datas(code, d)
+
# class TestTrade(unittest.TestCase):
# processor = L2TradeDataProcessor()
--
Gitblit v1.8.0