From 4202470a0702b313b150eff1797ec495ee1ca59a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 10 七月 2023 13:27:08 +0800
Subject: [PATCH] 华鑫适配
---
l2/l2_data_manager_new.py | 35 +++++++++++++++++++++++++++++++++--
1 files changed, 33 insertions(+), 2 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index bdc1cda..d9f4e51 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -4,6 +4,7 @@
from code_attribute import big_money_num_manager, code_volumn_manager, code_data_util, industry_codes_sort, \
limit_up_time_manager, global_data_loader, gpcode_manager
import constant
+from l2.huaxin import l2_huaxin_util
from utils import global_util, ths_industry_util, tool
import l2_data_util
from db import redis_manager
@@ -14,10 +15,11 @@
from l2.cancel_buy_strategy import SecondCancelBigNumComputer, HourCancelBigNumComputer, L2LimitUpMoneyStatisticUtil, \
L2LimitUpSellStatisticUtil
from l2.l2_data_manager import L2DataException, TradePointManager
-from l2.l2_data_util import local_today_datas, L2DataUtil, local_today_num_operate_map,local_today_buyno_map, local_latest_datas
+from l2.l2_data_util import local_today_datas, L2DataUtil, local_today_num_operate_map, local_today_buyno_map, \
+ local_latest_datas
import l2.l2_data_util
from logs_.log import logger_l2_trade_buy, logger_l2_process, \
- logger_place_order_score
+ logger_place_order_score, logger_l2_error
# TODO l2鏁版嵁绠＄悊
from trade.trade_data_manager import CodeActualPriceProcessor
@@ -210,6 +212,35 @@
if code in cls.unreal_buy_dict:
cls.unreal_buy_dict.pop(code)
+ # 澶勭悊鍗庨懌L2鏁版嵁
+ @classmethod
+ def process_huaxin(cls, code, datas):
+ origin_start_time = round(t.time() * 1000)
+ try:
+ # 鍔犺浇鍘嗗彶鐨凩2鏁版嵁
+ is_normal = l2.l2_data_util.load_l2_data(code,load_latest=False)
+ if not is_normal:
+ print("鍘嗗彶鏁版嵁寮傚父:", code)
+ # 鏁版嵁涓嶆甯搁渶瑕佺姝氦鏄�
+ l2_trade_util.forbidden_trade(code)
+ # 杞崲鏁版嵁鏍煎紡
+ _start_index = 0
+ if local_today_datas.get(code) is not None and len(
+ local_today_datas[code]) > 0:
+ _start_index = local_today_datas[code][-1]["index"] + 1
+ datas = l2_huaxin_util.get_format_l2_datas(code, datas,
+ gpcode_manager.get_limit_up_price(code), _start_index)
+ __start_time = round(t.time() * 1000)
+ cls.process_add_datas(code, datas, 0, __start_time)
+ except Exception as e:
+ logging.exception(e)
+ logger_l2_error.exception(e)
+ finally:
+ l2_data_log.l2_time(code, round(t.time() * 1000) - origin_start_time,
+ "l2鏁版嵁澶勭悊鎬昏�楁椂",
+ True)
+ l2.l2_data_util.save_l2_data(code, None, datas)
+
@classmethod
def process_add_datas(cls, code, add_datas, capture_timestamp, __start_time):
now_time_str = tool.get_now_time_str()
--
Gitblit v1.8.0