华鑫适配

Administrator

2023-07-17 a9681c7b03a6fde559bf77ef65917d6d4db5d84c

 l2/l2_data_manager_new.py

@@ -4,7 +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 l2.huaxin import l2_huaxin_util, huaxin_delegate_postion_manager
from utils import global_util, ths_industry_util, tool
import l2_data_util
from db import redis_manager
@@ -13,7 +13,7 @@
    trade_result_manager, first_code_score_manager
from l2 import safe_count_manager, l2_data_manager, l2_data_log, l2_log, l2_data_source_util, code_price_manager
from l2.cancel_buy_strategy import SecondCancelBigNumComputer, HourCancelBigNumComputer, L2LimitUpMoneyStatisticUtil, \
    L2LimitUpSellStatisticUtil
    L2LimitUpSellStatisticUtil, DCancelBigNumComputer
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
@@ -231,10 +231,13 @@
                _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)
            # 获取下单位置
            place_order_index = huaxin_delegate_postion_manager.get_l2_place_order_position(code, datas)
            if place_order_index:
                DCancelBigNumComputer.set_real_order_index(code, place_order_index)

            __start_time = round(t.time() * 1000)
            print("格式化L2数据成功", code)
            cls.process_add_datas(code, datas, 0, __start_time)
            print("huaxin L2数据处理成功", code)
        except Exception as e:
            print("huaxin L2数据处理异常", code, str(e))
            logging.exception(e)