L撤修改/已成交统计修改

Administrator

2023-11-17 061204832c6eb71d5583fa8ebdd41479100b6b54

 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()