for i = 1, 5000000000 do   end

LUA_API void lua_pushboolean (lua_State *L, int b) {
  lua_lock(L);
  if (b)
    setbtvalue(s2v(L->top));
  else
    setbfvalue(s2v(L->top));
  api_incr_top(L);
  lua_unlock(L);
}

local path = _G.getScriptPath()
package.path = path.."/?.lua;"

local id = 'script1'
local logFile

function _G.OnInit(script_path)
   id = ((script_path:match("[^/\\]+$")):gsub('.lua', ''))
end

local function log_tostring(...)
  local args = table.pack(...)
  if args.n == 1 then
    return tostring(args[1])
  end
  for i = 1, args.n do
    args[i] = tostring(args[i])
  end
  return table.concat(args, " ", 1, args.n)
end

local function log(...)
    if logFile==nil then return end
    logFile:write(log_tostring(...).."\n");
    logFile:flush();
end

local sleep         = _G.sleep
local message       = _G.message
local isRun         = true

local last_rec, last_time, time_diff
local start_rec = tonumber(getInfoParam('LASTRECORD') or '') or 0

local q = 0
local t = os.time()
local start

function _G.OnParam(class_code,  sec_code)
   if q == 0 then t = os.time() end
   q = q + 1
   local last_price = tonumber((getParamEx(class_code,  sec_code, 'LAST') or {}).param_value)
   -- PrintDbgStr(log_tostring('OnParam', q, class_code,  sec_code, 'last_price', last_price))
end

local function log_stat()

   local end_rec   = tonumber(getInfoParam('LASTRECORD') or '') or 0
   local loaded   = end_rec - start_rec
   t = os.time() - t
   local str = log_tostring(id, ': done', ', processed callbacks: ', q, ', in: ', t, 'sec', ', avg: ', q == 0 and '---' or t/q)
   message(str)
   local str1 = log_tostring(id, ': start_rec: ', start_rec, ', end_rec: ', end_rec, ', loaded records: ', loaded, ', avg: ', loaded == 0 and '---' or t/loaded)
   message(str1)
   if io.type(logFile) == 'file' then
       log(str)
       log(str1)
      logFile:close()
   end
end


function _G.main()

    logFile = io.open(path.."\\"..id..".txt", "w")

    while isRun do
        sleep(10)
    end
end

function _G.OnDisconnected()
   message('OnDisconnected, current_rec: '..tostring(tonumber(getInfoParam('LASTRECORD') or '') or 0))
   q = 0
   t = os.time()
end

function _G.OnConnected(flag)
   if flag then
      start_rec   = tonumber(getInfoParam('LASTRECORD') or '') or 0
      message('OnConnected, start_rec: '..tostring(start_rec))
      q = 0
      t = os.time()
      start = true
   end
end

function _G.OnStop()
    isRun = false
   log_stat()
end

while c.is_run do
    local cur_size = _G.Robot.ds:Size()
    if cur_size > last_known_size then
        last_known_size = cur_size
        c.BAR_CACHE_IDX = cur_size
        _G.Robot:ExecuteQuantumClosure(
            _G.Robot.ds,
            cur_size
        )
    end
    if _G.Robot.ProcessLearningQueue then 
        _G.Robot:ProcessLearningQueue()
    end

    if _G.Robot.TriggerUIRender then 
        _G.Robot:TriggerUIRender()
    end

    local current_work_time = GetMilliseconds() - TT
    c.LAST_EXECUTION_LAG = current_work_time
    local calculated_sleep = 200 - current_work_time

    if calculated_sleep <= 0 then 
        calculated_sleep = 1 
    end

    sleep(calculated_sleep)
    TT = GetMilliseconds()
end

    if not Robot or not c.is_run or not c.IS_WARMED_UP or Robot.Is_Inside_HotPath then return end
    if Robot.ProcessParamEvent and type(Robot.ProcessParamEvent) == "function" then 
        Robot:ProcessParamEvent(class_code, sec_code) 
    end

function OnParam(class_code, sec_code)
    if not Robot or not c.is_run or not c.IS_WARMED_UP or Robot.Is_Inside_HotPath then return end
    if Robot.ProcessParamEvent and type(Robot.ProcessParamEvent) == "function" then 
        Robot:ProcessParamEvent(class_code, sec_code) 
    end
end

function _G.OnParam(class_code,  sec_code)
    local last_price = tonumber((getParamEx(class_code,  sec_code, 'LAST') or {}).param_value) or nil

   -- if rev_lis[sec_code] then
      -- GetPrice(class_code,  sec_code)
   -- end
end

local path = _G.getScriptPath()
package.path = path.."/?.lua;"

local bl1 = require('big_lib')
local bl2 = require('big_lib2')
local bl3 = require('big_lib3')
local bl4 = require('big_lib4')

local id = 'script3'
local logFile

local function log_tostring(...)
  local args = table.pack(...)
  if args.n == 1 then
    return tostring(args[1])
  end
  for i = 1, args.n do
    args[i] = tostring(args[i])
  end
  return table.concat(args, " ", 1, args.n)
end

local function log(...)
    if logFile==nil then return end
    logFile:write(log_tostring(...).."\n");
    logFile:flush();
end


local sec_list      = {
    {'SPBFUT', 'MMU6'},
    {'SPBFUT', 'SiU6'},
    {'SPBFUT', 'RIU6'},
    {'SPBFUT', 'USDRUBF'},
    {'SPBFUT', 'CNYRUBF'},
    {'TQBR', 'SBER'},
    {'TQBR', 'GAZP'}
}

local last_data = {}


local rev_lis = {}
for i = 1, #sec_list do
    rev_lis[sec_list[i][2]] = i
    last_data[sec_list[i][2]] = {}
end

local sleep         = _G.sleep
local isRun         = true

local t_id          = nil

-- local SeaGreen      = 12713921  --  RGB(193, 255, 193) нежно-зеленый
-- local RosyBrown     = 12698111  --  RGB(255, 193, 193) нежно-розовый
-- local GetCell       = _G.GetCell
-- local Highlight     = _G.Highlight
local SetCell           = _G.SetCell
local getParamEx        = _G.getParamEx
local getInfoParam      = _G.getInfoParam
local IsWindowClosed    = _G.IsWindowClosed

local Queue = {}
Queue.__index = Queue

function Queue.new()
   return setmetatable({first = 1, last = 0 }, Queue)
end
---  Записать в очередь --
function Queue:push(v)
   if v == nil then error('!!! Ошибка. Параметр v функции QueuePush nil') end
   local last = self.last + 1
   self[last] = v
   self.last = last
   return last - self.first + 1    -- количество элементов в очереди ---
end
---  Читать очередь  --
function Queue:pop()
   local  first =  self.first
   if  first > self.last then return nil   end
   local v, v1  =  self[first], self[first + 1]
   self.first = first + 1
   self[first] =  nil
   v1 = type (v1) == 'string' and #v1 or 0
   return  v, v1   -- v1 -длина следующего элемента (если строка) ---
end

-- Текущий размер очереди ---
function Queue:size()
   return self.last - self.first + 1
end

local queue = Queue.new()

local function process_queue()
    local n = 0
    local res = queue:pop()
    while res do
        n = n + 1
        local last_price = res[3]
        -- local lp = GetCell(t_id, 1, 0).value or last_price
        -- if lp < last_price then
        --     Highlight(t_id, 1, 0, SeaGreen, 0, 500)
        -- elseif lp > last_price then
        --     Highlight(t_id, 1, 0, RosyBrown, 0, 500)
        -- end
        SetCell(t_id, rev_lis[res[2]], 1, tostring(last_price), last_price)
        -- log(id, ' --- set pop value',  n, rev_lis[res[2]], last_price)
        res = queue:pop()
    end
    return n
end

local function GetPrice(class_code,  sec_code)
    local last_price = tonumber((getParamEx(class_code,  sec_code, 'LAST') or {}).param_value) or nil
    if last_data[sec_code][1] == last_price then return end
    local res = {}
    res.last_time  = tonumber((getParamEx(class_code,  sec_code, 'TIME') or {}).param_value) or 0
    if res.last_time == 0 then return end
    res.last_price = last_price
    if not res.last_price then return end
    local bid_depth  = tonumber((getParamEx(class_code,  sec_code, 'BIDDEPTHT') or {}).param_value) or 0
    res.best_bid   = bid_depth > 0 and tonumber((getParamEx(class_code,  sec_code, 'BID') or {}).param_value) or nil
    local ask_depth  = tonumber((getParamEx(class_code,  sec_code, 'OFFERDEPTHT') or {}).param_value) or 0
    res.best_ask   = ask_depth > 0 and tonumber((getParamEx(class_code,  sec_code, 'OFFER') or {}).param_value) or nil
    -- res.last_rec   = tonumber((tostring(getInfoParam('LASTRECORDTIME') or ''):gsub(':', ''))) or 0
    -- res.local_time = (tonumber((tostring(getInfoParam('LOCALTIME') or ''):gsub(':', ''))) or 0)
    -- res.time_diff  = math.abs(res.local_time - res.last_rec) + 10
    last_data[sec_code][1] = last_price
    queue:push{class_code,  sec_code, last_price}
end

local function event_callback(_, msg, par1, par2)
    if (msg == _G.QTABLE_CLOSE) then
        isRun = false
    end
    if msg == _G.QTABLE_CHAR then
        SetCell(t_id, par1, 2, tostring(par2), par2)
    end
end

local function CreateTable()

    t_id = _G.AllocTable()

    _G.AddColumn(t_id, 0, "sec", true, _G.QTABLE_STRING_TYPE, 15)
    _G.AddColumn(t_id, 1, "price", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.AddColumn(t_id, 2, "edit", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.CreateWindow(t_id)
    _G.SetWindowPos(t_id, 90, 120, 470, 300)
    for i = 1, #sec_list do
        _G.InsertRow(t_id, i)
        SetCell(t_id, i, 0, sec_list[i][2])
    end
    _G.SetTableNotificationCallback(t_id, event_callback)
end

function _G.OnParam(class_code,  sec_code)
    local last_price = tonumber((getParamEx(class_code,  sec_code, 'LAST') or {}).param_value) or nil

   -- if rev_lis[sec_code] then
      -- GetPrice(class_code,  sec_code)
   -- end
end

local last_rec, last_time, time_diff


function _G.main()

    CreateTable()

    logFile = io.open(path.."\\load_"..id..".txt", "w")

    local lt = 0
    local req_int = 1

    while isRun do

        local cwt = os.time()
        if cwt - lt > req_int then
            lt = cwt
            for i = 1, #sec_list do
                GetPrice(sec_list[i][1], sec_list[i][2])
            end
        end

   last_rec   = tonumber((tostring(getInfoParam('LASTRECORDTIME') or ''):gsub(':', ''))) or 0
   local_time = (tonumber((tostring(getInfoParam('LOCALTIME') or ''):gsub(':', ''))) or 0)
   time_diff  = math.abs(local_time - last_rec) + 10

        -- log(id, 'Enter main loop')
   IsWindowClosed(t_id)
        local n = process_queue()
        bl1.func1()
        bl2.func100()
        bl3.func200()
        bl4.func300()
        -- log(id, 'Exit main loop', 'in queue', n)
        -- log('---------------------------------------------------------------------------')
        sleep(60)
    end
end

function _G.OnStop()
    isRun = false
    if t_id and not IsWindowClosed(t_id) then
        _G.DestroyTable(t_id)
    end
end