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

local NaN = 0 / 0

local function getPointsToRublesMultiplier(classCode, secCode)
    if InfoSecurities.isFuturesClass(classCode) then
        local stepPrice = getParamEx(classCode, secCode, "STEPPRICE")
        local secPriceStep = getParamEx(classCode, secCode, "SEC_PRICE_STEP")
        if type(stepPrice) ~= "table" or type(secPriceStep) ~= "table" then
            return NaN
        end
        stepPrice = stepPrice.param_value
        secPriceStep = secPriceStep.param_value
        if stepPrice == nil or secPriceStep == nil then
            return NaN
        end
        local stepPriceInRub = tonumber(stepPrice)
        local priceStepInPts = tonumber(secPriceStep)
        if stepPriceInRub > 0 and priceStepInPts > 0 then
            return stepPriceInRub / priceStepInPts
        else
            return NaN
        end
    else
        return 1
    end
end

D:\QUIK_BROKER1
D:\QUIK_BROKER2
D:\QUIK_BROKER3

--
-- Подгонка размеров окна.
--

local interrupted = false

function OnStop()
    interrupted = true
end

function main()
    local tId = AllocTable()
    CreateWindow(tId)

    local topPrev, leftPrev, bottomPrev, rightPrev = 0, 0, 0, 0
    while not interrupted do
        if IsWindowClosed(tId) then
            break
        end
        local top, left, bottom, right = GetWindowRect(tId)
        if top == nil or left == nil or bottom == nil or right == nil then
            break
        end
        if topPrev ~= top or leftPrev ~= left or bottomPrev ~= bottom or rightPrev ~= right then
            SetWindowCaption(tId, "x=" .. tostring(left)
                    .. ",y=" .. tostring(top)
                    .. ",dx=" .. tostring(right - left)
                    .. ",dy=" .. tostring(bottom - top))
            topPrev = top
            leftPrev = left
            bottomPrev = bottom
            rightPrev = right
        else
            sleep(50)
        end
    end
end

local ds = CreateDataSource(classCode, secCode, INTERVAL_M5)

local size = ds:Size()

ExecuteCallback(function() 
  -- обращение к данным ds, которое будет произведено в потоке коллбэков
end)

SwingUtilities.invokeLater(Runnable doRun)

local function init(ds, timeout)
  local deadline = os.time() + timeout
  while os.time() < deadline do
    if ds:Size() > 0 then
      return true
    end
    sleep(100)
  end
  return false
end

del /F /Q acnt.dat
del /F /Q alerts.dat
del /F /Q alltrade.dat
del /F /Q banners.dat
del /F /Q classes.dat
del /F /Q firms.dat
del /F /Q limits.dat
del /F /Q locales.dat
del /F /Q orders.dat
del /F /Q par.dat
del /F /Q portfolio.dat
del /F /Q scripts.dat
del /F /Q search.dat
del /F /Q sec.dat
del /F /Q tmsg.dat
del /F /Q tradermsg.dat
del /F /Q trades.dat
del /F /Q trans.dat
del /F /Q transresult.dat

del /F /Q info.log
del /F /Q portfolio.log

info.exe -clear

value.tbl.bid[indexBid].price

local tbl = value.tbl
local bids = tbl.bid
local price = bids[indexBid].price

--
-- Реализация очереди из функций и их исполнения.
--

local Executor = {}

--- Конструктор.
-- @param self объект
local function new(self)
    local queue = {
        head = 1,
        tail = 0
    }
    setmetatable(queue, self)
    self.__index = self
    return queue
end

Executor.new = new

--- Поместить функцию в очередь на выполнение.
-- @param self объект
-- @param f функция
local function submit(self, f)
    if type(f) == "function" then
        self[self.tail + 1] = f
        self.tail = self.tail + 1
    end
end

Executor.submit = submit

--- Получить очередную функцию из очереди.
-- @param self объект
-- @return функция
local function get(self)
    if self.head > self.tail then
        return nil
    else
        local f = self[self.head]
        self[self.head] = nil
        self.head = self.head + 1
        return f
    end
end

Executor.get = get

--- Выполнять функции из очереди либо пока они там есть, либо пока не будет выполнено указанное количество функций.
-- @param self объект
-- @param max максимальное количество исполняемых за один раз функций
local function execute(self, max)
    max = max or 1000000
    while max > 0 do
        local f = self:get()
        if f == nil then
            return
        else
            f()
            max = max - 1
        end
    end
end

Executor.execute = execute

return Executor

local tradeCounters = {} -- таблица[secCode], содержащая количество обезличенных сделок по каждому инструменту

function OnAllTrade(t)
    executor:submit(function()
            tradeCounters[t.sec_code] = (tradeCounters[t.sec_code] or 0) + 1
    end)
end

while not interrupted do
    ....
    executor:execute()
    ....
end

local SELL_FLAG = 1
local BUY_FLAG = 2

function OnAllTrade(allTrade)
    ...
    local buySell = 0
    if bit.band(currTrade.flags, BUY_FLAG) == BUY_FLAG then
        buySell = 1
    elseif bit.band(currTrade.flags, SELL_FLAG) == SELL_FLAG then
        buySell = -1
    end
    ...
end