From de34b0a96d71e6ab8eabe2e580c2b94de9065d08 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 31 八月 2023 17:00:14 +0800
Subject: [PATCH] 交易bug修改
---
test/l2_trade_test.py | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index ebf762f..0bafceb 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -4,6 +4,7 @@
import json
import multiprocessing
import random
+import threading
import time
import unittest
from copy import deepcopy
@@ -11,7 +12,7 @@
from code_attribute import big_money_num_manager, gpcode_manager
from db.redis_manager_delegate import RedisUtils
-from log_module import log, log_export
+from log_module import log, log_export, async_log_util
from trade.huaxin import huaxin_trade_api
from utils import tool
from db import redis_manager_delegate as redis_manager
@@ -92,7 +93,9 @@
# @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_trade(self):
- code = "002527"
+ threading.Thread(target=async_log_util.run_sync,daemon=True).start()
+
+ code = "000678"
clear_trade_data(code)
l2.l2_data_util.load_l2_data(code)
total_datas = deepcopy(l2.l2_data_util.local_today_datas[code])
@@ -147,7 +150,7 @@
current_price_process_manager.set_trade_price(code, round(float(gpcode_manager.get_limit_up_price(code)), 2))
pss_server, pss_strategy = multiprocessing.Pipe()
- huaxin_trade_api.run_pipe_trade(pss_server)
+ huaxin_trade_api.run_pipe_trade(pss_server, None)
for indexs in pos_list:
l2_log.threadIds[code] = mock.Mock(
--
Gitblit v1.8.0