From 32e5068c79612bd132af689fc36c0cf81f067bc6 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 10 七月 2023 10:56:32 +0800
Subject: [PATCH] 华鑫适配
---
trade/current_price_process_manager.py | 21 ++++++++++++++-------
1 files changed, 14 insertions(+), 7 deletions(-)
diff --git a/trade/current_price_process_manager.py b/trade/current_price_process_manager.py
index f02f0dc..0894761 100644
--- a/trade/current_price_process_manager.py
+++ b/trade/current_price_process_manager.py
@@ -9,7 +9,6 @@
from ths import client_manager
import constant
from code_attribute import gpcode_manager
-from trade.huaxin import huaxin_trade_api
from utils import tool, import_util
from ths.l2_code_operate import L2CodeOperate
from trade import trade_manager, l2_trade_util
@@ -18,6 +17,8 @@
trade_gui = import_util.import_lib("trade.trade_gui")
__actualPriceProcessor = CodeActualPriceProcessor()
+
+latest_add_codes = set()
def accept_prices(prices):
@@ -116,12 +117,18 @@
if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_HUAXIN:
# 鍗庨懌L2,鑾峰彇鍔犲叆浠ｇ爜鐨勬定鍋滀环
- add_datas = []
- for d in add_code_list:
- limit_up_price = gpcode_manager.get_limit_up_price(d)
- limit_up_price = round(float(limit_up_price), 2)
- min_volume = int(round(50 * 10000 / limit_up_price))
- add_datas.append((d, min_volume, limit_up_price))
+
+ # 鏄惁鍜屼笂娆′竴鏍�
+ add_code_set = set(add_code_list)
+ global latest_add_codes
+ if tuple(latest_add_codes) != tuple(add_code_set):
+ latest_add_codes = add_code_set
+ add_datas = []
+ for d in add_code_list:
+ limit_up_price = gpcode_manager.get_limit_up_price(d)
+ limit_up_price = round(float(limit_up_price), 2)
+ min_volume = int(round(50 * 10000 / limit_up_price))
+ add_datas.append((d, min_volume, limit_up_price))
try:
huaxin_target_codes_manager.push(add_datas)
except Exception as e:
--
Gitblit v1.8.0