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

---  Стек объектов финализации (автоматическая финализация) ---
--  В этот стек помещать для финализируемых объектов функции их очистки (сразу при создании объектов) в формате:
--    {<Функция финализации объекта>, {<Параметры финализации объекта через запятую>}};  таблица с параметрами может отсутствовать
local FINALIZATION_META
FINALIZATION_STEK = {}
--- Реализована возможность финализации "вручную":
-- 1) mess = true - финализация без выдачи сообщения;
-- 2) no_mess = 'string' - финализация c выдачи сообщения no_mess;
function FINALIZATION_STEK_FUNFIN(stek_fin, no_mess) -- ! Функция вызывается при любом варианте завершения скрипта -- 
   if type(stek_fin)  ~= 'table' then return end
   if not next(stek_fin) then return end 
   -------- Выдача сообщений различных вариантов финализации ---
   if not no_mess or type(no_mess) == 'string' then 
      -- message('FINALIZATION_STEK_FUNFIN - здесь выдать сообщение ADMIN: *** Завершение с не перехваченной ситуацией') 
      if B_Q_DLL and OPEN_CONTROL_BOT then
         local mess
         if type(no_mess) == 'string' then
            mess = no_mess
         else
            mess = '\n   *** Завершение с не перехваченной ситуацией в скрипте: ' .. (SCRIPT_NAME or '??') 
                   ..'\n  Дополнительные подробности смотрите в журнале скрипта и диагностике QUIK.'
         end
         message(mess, 3)   
         ---
      end
   end
   --------------------------------------------
   local ob_l
   for i = #stek_fin, 1, -1 do   -- обработка стека очистки объектов финализации --- 
      ob_l = stek_fin[i]   -- #### 15.12.24
      stek_fin[i] = nil    -- #### 15.12.24
      if type(ob_l)  == 'table' and type(ob_l[1]) == 'function' then    
         if ob_l[2] then
            ob_l[1](table.unpack(ob_l[2]))
         else
            ob_l[1]()
         end
      end
   end
   FINALIZATION_META.__gc= 0  -- отключение финализации ---
end
----
-- При подключении финализирующей метатаблицы в ней обязательно должно быть поле __gc  
-- (! значения отличные от функции не будут обрабатываться, но функцию можно присвоить позже), 
-- иначе не будет пометки для финализации (список финализации формируется при подключении метатаблиц с полем __gc)
FINALIZATION_META = {__gc = FINALIZATION_STEK_FUNFIN}
setmetatable(FINALIZATION_STEK, FINALIZATION_META)
---  Запись в стек функции финализации ---
function FINALIZATION_STEK_PUSH(tbl_rez)    --  tbl_rez =  {<Функция финализации объекта>, {<Параметры финализации объекта>}}
   FINALIZATION_STEK[#FINALIZATION_STEK + 1] = tbl_rez
end 

while _RUN_ do
    < Тело основного цикла скрипта>
end
if  TBL_QUIK then  -- Если использовались таблицы
         -- Финализация (не допускать одновременного выполнения в пользовательском и основном потоке QUIK) ---
         FINALIZATION_STEK_FUNFIN(FINALIZATION_STEK, true)
         ----
         -- #### Задержка sleep нужна чтобы установить признак запуска скрипта при перезапуске QUIK. 
         -- Иначе при перезапуске QUIK не будет перезапущен скрипт.--
         -- При нормальном завершении QUIK, если есть таблицы QUIK, они удаляются (и вызываются коллбеки QTABLE_CLOSE)
         -- Если при этом нет задержки, то скрипт завершается и не выставляется признак необходимости его перезапуска
         -- при запуске QUIK. Признак TBL_QUIK  устанавливается в основной пользовательской таблице QUIK. 
         -- Длительность задержки выбрана экспериментально.
         sleep(sleep_TBL_QUIK_ or 1000) 
      end 

Settings = {
   Name = "*Kijun-sen",
   kijun_period = 26,  -- Период Kijun-sen (можно изменить)
   line = {{
       Name = "Kijun-sen",
       Color = RGB(0, 0, 200),
       Type = TYPE_LINE,
       Width = 2
   }}
}

local kijun_period = Settings.kijun_period

local QueueH, QueueL = {}, {}
local const_L = 999999999

function Init()
   QueueH, QueueL = {}, {}
   for i = 0, kijun_period - 1 do
      QueueH[i] = 0; QueueL[i] = const_L
   end
   return 1 
end

function OnChangeSettings()
   kijun_period = Settings.kijun_period 
   QueueH, QueueL = {}, {}
   for i = 0, kijun_period - 1 do
      QueueH[i] = 0; QueueL[i] = const_L
   end
end
---
local TT
local N_C = 500
local max_high, min_low
function OnCalculate(index)
-- -- Вычисление времени обработки свеч  (500 свечкй за ~4 млс. в 5 раз быстрее моего же *Kijun-sen_opt)--
-- if index == kijun_period + 1 then
   -- TT = os.clock()
-- end
-- if index == N_C + kijun_period then
   -- message('Kijun-sen. Время обработки ' .. N_C .. ' свечей (млс.) = ' .. (os.clock() - TT) * 1000)
-- end
-- -----------------------------------
   if index == 1 then
      max_high = H(1) or 0
      min_low = L(1) or const_L
      QueueH[1], QueueL[1] = max_high, min_low
   else
      current_high = H(index) or 0
      current_low = L(index) or const_L
      local ind = index % kijun_period  -- место в векторе --
      local QueueH_end 
      local QueueL_end
      if index > kijun_period then  -- сохранение уходящих значений --
         QueueH_end = QueueH[ind]   
         QueueL_end = QueueL[ind]
      end
      
      QueueH[ind], QueueL[ind] = current_high, current_low -- сохранение текущих в векторе --
      -- --------
      if current_high >= max_high then  -- Пришел максимальный --
         max_high = current_high
      else
         if index > kijun_period then  -- начальный период завершен --
            --  Максимум "ушел" из скользящего периода --
            if QueueH_end >= max_high then -- поиск максимального в векторе 
               max_high = current_high
               for j = 0, kijun_period - 1 do
                  current_high = QueueH[j]
                  if current_high > max_high then max_high = current_high end
               end
            end
         end
      end
      ---
      if current_low <= min_low then  -- Пришел минимальный
         min_low = current_low
      else
         if index > kijun_period then
            --  Ушел из скользящего периода минимальный --
            if QueueL_end <= min_low then -- поиск минимального
               min_low = current_low
               for j = 0, kijun_period - 1 do
                  current_low = QueueL[j]
                  if current_low < min_low then min_low = current_low end
               end
            end
         end
      end
   end
   return (max_high + min_low) / 2
end

Settings = {
   Name = "*Kijun-sen_opt",
   kijun_period = 26,  -- Период Kijun-sen (можно изменить)
   line = {{
       Name = "Kijun-sen_opt",
       Color = RGB(0, 0, 200),
       Type = TYPE_LINE,
       Width = 2
   }}
}

function Init()  return 1 end

local kijun_period = Settings.kijun_period

function OnChangeSettings()
   kijun_period = Settings.kijun_period 
end
---
local TT
local N_C = 500
function OnCalculate(index)
-- -- Вычисление времени обработки свеч --
-- if index == kijun_period + 1 then
   -- TT = os.clock()
-- end
-- if index == N_C + kijun_period then
   -- message('Kijun-sen. Время обработки ' .. N_C .. ' свечей (млс.) = ' .. (os.clock() - TT) * 1000)
-- end
   if index==1 then
      max_high = H(1)
      min_low = L(1)
   else
      current_high = H(index)
      current_low = L(index)
      --------
      if current_high > max_high then  -- Пришел максимальный
         max_high = current_high
      else
         if index > kijun_period then
            --  Ушел из скользящего периода максимальный --
            if H(index - kijun_period) >= max_high then -- поиск максимального
               max_high = current_high
               for j = index - kijun_period + 1, index - 1 do
                  current_high = H(j)
                  if current_high > max_high then max_high = current_high end
               end
            end
         end
      end
      ---
      if current_low < min_low then  -- Пришел минимальный
         min_low = current_low
      else
         if index > kijun_period then
            --  Ушел из скользящего периода минимальный --
            if L(index - kijun_period) <= min_low then -- поиск минимального
               min_low = current_low
               for j = index - kijun_period + 1, index - 1 do
                  current_low = L(j)
                  if current_low < min_low then min_low = current_low end
               end
            end
         end
      end
   end
   return (max_high + min_low) / 2
end

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