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

KW 08.10.25 16:50:36:220             ## Остановлен QUIK (16:50:36:220)
    --- @  Остановлен по стоп бот D:\0 D\0 TGB\B_Q\Bots\B1  @ ---
                                     ## Через ~ 1 сек. QUIK запущен
 ==================================
KW 08.10.25 16:51:02:693             ## Начало работы скрипта (длительность от начала запуска 26 сек.)
        Begin_Require: 08.10.25 16:51:02:693.  End_Require: 08.10.25 16:51:02:696   ## Загружены все пакеты скрипта (длительность загрузки 3 млс.)
KW 08.10.25 16:51:02:717 ACCOUNT, CLASS_CODES,  CLIENT_CODES, FIRM_ID:              ## Получены реквизиты и скрипт готов продолжать работать
KW 08.10.25 16:51:02:717 #572:TRADER_lib Нет подключения к серверу
KW 08.10.25 16:51:02:717 #575:TRADER_lib С сервера не поступают необходимые данные
KW 08.10.25 16:51:02:717 #578:TRADER_lib Ждет возобновления связи
KW 08.10.25 16:51:25:197 #590:TRADER_lib Соединение с сервером восстановлено, ждет 10 сек. подгрузки данных
KW 08.10.25 16:51:35:201 #608:TRADER_lib Возобновил работу                         ##  (16:51:35:201)  Итого: длительность перезапуска ~ 1 мин.

--- Использование графического пакета IUP (Lua 5.4...) в QUIKе (! ограничение IUP: 
-- только в одном из запущенном скрипте экземпляра QUIK).
-- Доступны все возможности пакета IUP (подключаемой версии).
-- Вариант 1: запуск IUP в потоке main (надо подключать только IUP, но цикл обработки скрипта программировать 
-- в таймере IUP: помечено #### ).
-- Вариант 2: запуск IUP в отдельном потоке отличном от main(кроме IUP, обязательно подключать пакет QluaUser).
--    Вариант 1 более безопасный, чем 2. Так как однопоточный, и не требующий синхронизации диалога с 
-- основной работой скрипта.
-- Ссылка для скачивания пакетов iup.dll, iuplua54.dll, QluaUser.dll (мой):
--    https://cloud.mail.ru/public/7xAm/jaCgULqGo    Перед использованием пакетов, надо их разблокировать.
-- Пакеты переслать в папку экземпляра QUIK, хранящую файл info.exe.
_RUN_ = true

function main()
   -- Пример формы IUP со двумя вкладками ---
   local Pause = 1000
   local thread = false  -- false - выполнение диалога в потоке main; true - запуск IUP в отдельном потоке --
   local cpath = (getWorkingFolder() .. '\\?54.dll;' .. getWorkingFolder() .. '\\?_5_4.dll;'.. getWorkingFolder() .. '\\?.dll;' .. package.cpath)
    ---
   package.cpath = cpath
   require("iuplua")
   local QluaUser = require('QluaUser')  -- Это для запуска диалога IUP в отдельном потоке ---
   if thread then
      QluaUser = require('QluaUser')
   end
   local function iup_form()
      local timer = iup.timer { time = Pause }   ---- Вместо sleep таймер формы  ( млсек.)  ---
      timer.run = "NO"
      function timer:action_cb()
         if not _RUN_ then
            timer.run = "NO"
            iup:ExitLoop()   --  Завершает текущий диалог      
         end
         if not thread then -- Основной цикл обработки скрипта в таймере IUP ---
            -- Тело основного цикла скрипта --  ####
            message('iup выполняется в потоке main. Тело основного цикла скрипта должно выполняеться здесь (в таймере iup)')
            -------------------
         end
      end
      -- Creates boxes
      local vboxA = iup.vbox{iup.fill{}, iup.label{title="TABS AAA", expand="HORIZONTAL"}, iup.button{title="AAA"}}
      local vboxB = iup.vbox{iup.label{title="TABS BBB"}, iup.button{title="BBB"}}
      -- Sets titles of the vboxes
      vboxA.tabtitle = "AAAAAA"
      vboxB.tabtitle = "BBBBBB"
      -- Creates tabs 
      local tabs = iup.tabs{vboxA, vboxB}
      -- Creates dialog
      local dlg = iup.dialog{iup.vbox{tabs; margin="10x10"}; title="Test IupTabs", size="150x80"}
      -- Shows dialog in the center of the screen
      dlg:showxy(iup.CENTER, iup.CENTER)
      timer.run = "YES"
      if (iup.MainLoopLevel()==0) then
        iup.MainLoop()
      end
      timer.run = "NO"
   end
   if thread then
      QluaUser.ThreadNew(iup_form)
   else
      iup_form()
      iup.Close()
      iup = nil
   end
   
   while _RUN_ do    -- Основной цикл обработки скрипта в main ---
      -----------------------
      if thread then
         message('iup был запущен в отдельном потоке. Тело основного цикла скрипта выполняется в потоке main.')
      else
         message('После завершения потока iup, продолжается выполняется поток main.')
      end
      sleep(Pause)
      -----------------------
   end
end 
---
function OnStop(flag)
   _RUN_ = false
   sleep(2000)
   if iup then iup.Close() end
   return 3000 
end

---  Стек объектов финализации (автоматическая финализация) ---
--  В этот стек помещать для финализируемых объектов функции их очистки (сразу при создании объектов) в формате:
--    {<Функция финализации объекта>, {<Параметры финализации объекта через запятую>}};  таблица с параметрами может отсутствовать
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