VPM (Все сообщения пользователя)

[QUOTE][USER=16131]VPM[/USER] написал:
-- Инициализация модулей в правильном порядке (с учётом зависимостей)

    -- 1. ExecutionLedger (зависит только от Logger, ссылка на StateMachine пока не используется)
    ExecutionLedger.init({ logger = Logger, stateMachine = StateMachine })

    -- 2. OrderManager (зависит от ExecutionLedger и Logger)
    OrderManager.init({
        ExecutionLedger = ExecutionLedger,
        Logger = Logger
    })

    -- 3. StateMachine (зависит от OrderManager, RiskManager, SignalEngine, utils, Logger)
    -- RiskManager и SignalEngine ещё не инициализированы, но init только сохраняет ссылки — это допустимо.
    StateMachine.init({
        utils = utils,
        OrderManager = OrderManager,
        RiskManager = RiskManager,
        SignalEngine = SignalEngine,
        Logger = Logger,
        ExecutionLedger = ExecutionLedger   -- <-- добавить
    })

    -- 4. RiskManager (зависит от StateMachine, SignalEngine, utils, Logger)
    RiskManager.init({
        utils = utils,
        StateMachine = StateMachine,
        SignalEngine = SignalEngine,
        Logger = Logger,
        config = {
            daily_loss_limit = daily_loss_limit,
            max_consecutive_losses = max_consecutive_losses,
            max_position_size = max_position_size,
            max_total_exposure = max_total_exposure,
            broker_comiss_stock = broker_comiss_stock,
            broker_comiss_fut = broker_comiss_fut,
            exchange_comiss_stock = exchange_comiss_stock
        }
    })

    -- 5. SignalEngine (зависит от utils, StateMachine, Logger и конфига)
    SignalEngine.init({
        utils = utils,
        StateMachine = StateMachine,
        Logger = Logger,
        config = {
            broker_comiss_stock = broker_comiss_stock,
            exchange_comiss_stock = exchange_comiss_stock,
            broker_comiss_fut = broker_comiss_fut,
            exchange_pay = exchange_pay,
            div = div,                     -- таблица дивидендов должна быть загружена ранее
            div_before_expiry = div_before_expiry,
            nalog = nalog,
            rate = rate,
            min_edge_abs = min_edge_abs
        }
    })

    -- 6. Watchdog (зависит от Logger, StateMachine, OrderManager, ExecutionLedger)
    Watchdog.init({
        Logger = Logger,
        StateMachine = StateMachine,
        OrderManager = OrderManager,
        ExecutionLedger = ExecutionLedger,
        config = {
            order_timeout = order_timeout,
            execution_timeout = 10
        }
    })

    -- 7. Recovery (если есть)
    Recovery.init({
        Logger = Logger,
        StateMachine = StateMachine
    })
    Recovery.recover()[/QUOTE]

Сборка в главном скрипте

-- main.lua
require("core.order_engine")
require("adapter.quik_exchange")
require("adapter.callbacks")
require("strategies.simple_strategy")

function main()
    -- 1. Инициализация адаптера
    local exchange = QuikExchange:new("SPBFUT12345", "SPBFUT", "SiH5")

    -- 2. Инициализация ядра
    local engine = OrderEngine:new(exchange)

    -- 3. Передаём ссылку в callbacks
    set_engine(engine)

    -- 4. Создаём стратегию
    local strategy = Strategy:new(engine)

    -- 5. Главный цикл
    while true do
        local price_param = getParamEx(exchange.class, exchange.sec, "LAST")
        local price = tonumber(price_param.param_value)

        if price then
            strategy:on_price(price)
            engine:process()
        end

        sleep(100)
    end
end

dofile(path .. '\\QL.lua')
dofile(path .. "\\ContanGO\\Проект\\config.lua")

local utils = dofile(path .. "\\ContanGO\\Проект\\core\\utils.lua")
local Logger = dofile(path .. "\\ContanGO\\Проект\\core\\logger.lua")
local OrderManager = dofile(path .. "\\ContanGO\\Проект\\core\\order_manager.lua")
local StateMachine = dofile(path .. "\\ContanGO\\Проект\\core\\state_machine.lua")
local Recovery = dofile(path .. "\\ContanGO\\Проект\\core\\recovery.lua")
local SignalEngine = dofile(path .. "\\ContanGO\\Проект\\core\\signal_engine.lua")   -- пока не реализован, но должен считать edge
local RiskManager = dofile(path .. "\\ContanGO\\Проект\\core\\risk_manager.lua")     -- проверка лимитов
local Watchdog = dofile(path .. "\\ContanGO\\Проект\\core\\watchdog.lua")
local ExecutionLedger = dofile(path .. "\\ContanGO\\Проект\\core\\execution_ledger.lua")

function OnInit()
    -- Логирование (ваш код)
    Logger.init(log_file)
    Logger.log("INIT", "", "Starting robot")

    -- Дополнительное логирование (опционально)
    do
        local log = _G.getScriptPath()..'\\arbitrage.log'
        toLog(log, "Start INIT robot arbitrage")
    end

    -- Объявление глобальных таблиц для хранения данных по инструментам
    exchange_pay = {}
    div_date = {}
    div_before_expiry = {}

    -- Инициализация контекстов для каждой акции из списка
    for stock in string.gmatch(ticker_list, "%a+") do
        local fut_code = futures_map[stock] or utils.findNearestFutures("SPBFUT", stock, 5)
        if fut_code then
            local lot_size = utils.safeParam("SPBFUT", fut_code, "LOTSIZE") or 1
            StateMachine.initContext(stock, fut_code, lot_size)

            -- Комиссия биржи
            exchange_pay[stock] = utils.safeParam("SPBFUT", fut_code, "EXCH_PAY") or 0

            -- Дата дивидендов (нужна реализация функции getDividendDate)
            div_date[stock] = getDividendDate(stock)

            -- Дивиденд до экспирации?
            if div_date[stock] then
                local exp_date = utils.safeParam("SPBFUT", fut_code, "MAT_DATE")
                div_before_expiry[stock] = exp_date and (tonumber(div_date[stock]) < tonumber(exp_date))
            else
                div_before_expiry[stock] = false
            end

            Logger.log("INIT", stock, string.format("Fut=%s lot=%d", fut_code, lot_size))
        else
            Logger.log("ERROR", stock, "No futures found")
        end
    end

    -- Инициализация модулей в правильном порядке (с учётом зависимостей)

    -- 1. ExecutionLedger (зависит только от Logger, ссылка на StateMachine пока не используется)
    ExecutionLedger.init({ logger = Logger, stateMachine = StateMachine })

    -- 2. OrderManager (зависит от ExecutionLedger и Logger)
    OrderManager.init({
        ExecutionLedger = ExecutionLedger,
        Logger = Logger
    })

    -- 3. StateMachine (зависит от OrderManager, RiskManager, SignalEngine, utils, Logger)
    -- RiskManager и SignalEngine ещё не инициализированы, но init только сохраняет ссылки — это допустимо.
    StateMachine.init({
        utils = utils,
        OrderManager = OrderManager,
        RiskManager = RiskManager,
        SignalEngine = SignalEngine,
        Logger = Logger,
        ExecutionLedger = ExecutionLedger   -- <-- добавить
    })

    -- 4. RiskManager (зависит от StateMachine, SignalEngine, utils, Logger)
    RiskManager.init({
        utils = utils,
        StateMachine = StateMachine,
        SignalEngine = SignalEngine,
        Logger = Logger,
        config = {
            daily_loss_limit = daily_loss_limit,
            max_consecutive_losses = max_consecutive_losses,
            max_position_size = max_position_size,
            max_total_exposure = max_total_exposure,
            broker_comiss_stock = broker_comiss_stock,
            broker_comiss_fut = broker_comiss_fut,
            exchange_comiss_stock = exchange_comiss_stock
        }
    })

    -- 5. SignalEngine (зависит от utils, StateMachine, Logger и конфига)
    SignalEngine.init({
        utils = utils,
        StateMachine = StateMachine,
        Logger = Logger,
        config = {
            broker_comiss_stock = broker_comiss_stock,
            exchange_comiss_stock = exchange_comiss_stock,
            broker_comiss_fut = broker_comiss_fut,
            exchange_pay = exchange_pay,
            div = div,                     -- таблица дивидендов должна быть загружена ранее
            div_before_expiry = div_before_expiry,
            nalog = nalog,
            rate = rate,
            min_edge_abs = min_edge_abs
        }
    })

    -- 6. Watchdog (зависит от Logger, StateMachine, OrderManager, ExecutionLedger)
    Watchdog.init({
        Logger = Logger,
        StateMachine = StateMachine,
        OrderManager = OrderManager,
        ExecutionLedger = ExecutionLedger,
        config = {
            order_timeout = order_timeout,
            execution_timeout = 10
        }
    })

    -- 7. Recovery (если есть)
    Recovery.init({
        Logger = Logger,
        StateMachine = StateMachine
    })
    Recovery.recover()

    Logger.log("INIT", "", "All modules initialized")
end