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

local function getItem_wait(tbl_quik, ind)
   local ob = getItem(tbl_quik, ind)
   local N = 500
   while not ob do
      sleep(10)
      ob = getItem(tbl_quik, ind)
      N = N - 1
      if N <= 0 then error ('Не дождались результата чтения таблицы ' .. tbl_quik .. ' по индексу ' .. tostring(ind)) end
   end
   return ob
end

stopped = false

function main()
   -------------------------------------------------------
   -- Создание параметризированной функции-замыкания коллбека (с дополнительными (кроме index)  
   -- параметрами ds и par, задаваемыми в момент создания). 
   --    Использование  ds:SetUpdateCallback(CreateUpdateCallbackDS(func, ds, par))
   --        параметр par необязателен, но если он fаlse, то тело функции не выполняется.
   --  ! Исключения в функции коллбека перехватываются. Коллбек при этом отключается с выдачей сообщения об исключении.
   --  Параметры: 
   --     func(index, ds, par) - функция  обработки коллбеков (вызываемых по изменениям свечи) --
   --     ds - открытый источник;
   --     par - параметр  (может отсутствовать) --
   --     index - индекс свечи при выполнении коллбека; 
   --  Результат: параметризированная функция-замыкание - параметр для функции ds:SetUpdateCallback ---
   local CreateUpdateCallbackDS = function(func, ds, par)
      return
         function(index)           -- Обертка для func  --
            if par ~= false then
               local kod, mes = pcall(func, index, ds, par) -- в защищенном режиме --
               if mes then
                  message('Исключение в коллбеке (он отключен, его 3-й параметр : '.. tostring(par) .. '). Текст исключения: ' .. mes, 3)
                  par = false
               end
            end
         end
   end
   --------------------------------------------------
   ---  Cl - класс, Sec - код бумаги, Int - таймфрейм.
   ---  T - ожидание поступления данных источника в сек. (по умолчанию 15 сек.)
   local CreateDS = function(Cl, Sec, Int, T)
      T = (T or 15) * 10
      local ds, Error = CreateDataSource(Cl, Sec, Int)
      for i = 1, T do
         if not ((Error == "" or Error == nil) and ds:Size() == 0) then break end 
         if i == T then error('Не дождались DS: ' .. Sec .. '. Ошибка: ' .. tostring(Error)) end
         sleep(100)
      end
      return ds
   end
   ---------------------------------------------------
   -- Вариант многократно используемой параметризированной заготовки для создания коллбеков в CreateUpdateCallbackDS --
   local function cb_p(index, ds, sec_code)
      local t = ds:T(index)
      local _str = string.format("#%d of %d\t%.4f\t%.4f\t%.4f\t%.4f\t%.4f %02d.%02d.%04d %02d:%02d:%02d.%04d\n",
      index, ds:Size(),ds:O(index), ds:H(index), ds:L(index), 
      ds:C(index), ds:V(index),
      t.day, t.month, t.year, t.hour, t.min, t.sec, t.ms)
      message(sec_code .. ': ' .. _str)
   end
   ---------
   local ds
   local function cb(index)  -- одноразовая функция коллбека -
      local t = ds:T(index)
      local _str = string.format("#%d of %d\t%.4f\t%.4f\t%.4f\t%.4f\t%.4f %02d.%02d.%04d %02d:%02d:%02d.%04d\n",
      index, ds:Size(),ds:O(index), ds:H(index), ds:L(index), 
      ds:C(index), ds:V(index),
      t.day, t.month, t.year, t.hour, t.min, t.sec, t.ms)
      message(_str)
   end
   ds = CreateDS("QJSIM", "GAZP", INTERVAL_M1)
message('Size = ' .. ds:Size())
   -- Вариант с созданием функции-замыкания, выдающей сообщение об исключениях во время ее выполнения ---
   ds:SetUpdateCallback(CreateUpdateCallbackDS(cb)) 
   
   -- ds:SetUpdateCallback()                                -- 1. #### это не помогает
   -- ds:SetUpdateCallback(function() end)                  -- 2. #### и это не помогает
   ds:Close() -- ?? После Close повторно установленные один раз коллбеки не срабатывают (
              -- хотя источник открывается)

   ds = CreateDS("QJSIM", "GAZP", INTERVAL_M1)
 
   -- ds:SetUpdateCallback(function() end) -- 3. #### это тоже помогает вместо последующего ds:SetUpdateCallback(cb)
   ds:SetUpdateCallback(cb) -- Обычный вариант (если в функции коллбека cb возникает исключение, 
                            -- то коллбек перестает выполняться, но сообщения об этом нет)
   ds:SetUpdateCallback(
                  CreateUpdateCallbackDS(cb_p, ds, "GAZP")) -- 4. #### Повторная установка параметризированного 
                                             --  коллбека. Если это закомментировать, то коллбек не запускается
   -- ds:SetUpdateCallback(cb)      -- 5. #### Это , вместо пункта 4, тоже проходит
    
   
   while not stopped do 
      sleep(3000)
-- message('while Size = ' .. ds:Size())
   end 
end  

function OnStop(row)
    stopped = true
end
---
--  Резюме (смотрите комментарии, выделенные строкой ####).
--- После ds:Close(), ds = CreateDataSource(...) повторно установленный коллбек cb не срабатывает 
--  (хотя источник открывается и свечи приходят).
--  Но если устанавливать два раза: ds:SetUpdateCallback(cb)   ds:SetUpdateCallback(cb),то cb срабатывает --

     --- Перед выполнением коллбека  ---
     local isrunning = collectgarbage('isrunning')
     if isrunning then collectgarbage('stop') end

         --- Выполнить  коллбек  ---

      --- После выполнения коллбека  ---
     if isrunning then collectgarbage('restart') end

local OK = false
function OnParam()
   OK = true
end

function main()
   _RUN_ = true
   collectgarbage('stop')     --   Сборка мусора отключена --
   while _RUN_ do
      if not collectgarbage('isrunning') then
         if OnParam and OK then
            message(' Ошибка обработки коллбеков устранена. '
               .. 'В скрипте где то был остановлен сбор мусора. '
               .. 'Вызов коллбека OnParam не меняет состояние сборки мусора', 3)
         end
      end

      sleep(3000)
   end

end

function OnStop()
   _RUN_ = false
   return 10000  
end

  local str, x, account
  local  class_code = getClassInfo('QJSIM') and 'QJSIM' or 'TQBR'   -- в песочнице 'QJSIM', а в продуктиве 'TQBR' 
  str="trade_accounts";
  for i=0, getNumberOf(str)-1 do 
     x=getItem(str,i) 
     if string.find(x.class_codes, class_code) then account=x.trdaccid; break; end 
  end