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

RUN = true
function main()
   -- Функции для асинхронного запроса свечей ---
-- 1. Массовый запрос свечей BulkRequestCandles.
-- Параметр: таблица {{class_code, sec_code, interval}}
-- Результат: {{class_code, sec_code, interval, ds}}
   local BulkRequestCandles = function(par)
      for i = 1, #par do
         par[i].ds = CreateDataSource(par[i].class_code, par[i].sec_code, par[i].interval)
      end
   end
----------------------------------------

   -- 2. Проверка запроса свечей CheckingCandleRequest.
   -- Параметр: таблица {{class_code, sec_code, interval, ds}}
   -- Результат в таблице парамктров : {{class_code, sec_code, interval, ds, ok}}
   -- Значения ok: true - данные начали поступать; nil данные еще не поступили; 
   --              false - ошибка в параметрах запроса
   -- Знвчение функции: количеситво источников еще ожидающих данные --
   local CheckingCandleRequest = function(par)
      local N = #par
      local ds
      for i = 1, #par do
         ds = par[i].ds
         if type(ds) == 'string' then -- обнаруженная ранее ошибка в параметрах запроса
             N = N - 1
         else
            if par[i].ok == nil then  -- еще не дождались данных
               if ds == nil then      -- обнаружена ошибка
                  par[i].ds = '  *** Ошибка в параметрах запроса'
                  par[i].ok = false
               else
                  -- проверка поступления данных
                  if ds:Size() > 0 then -- есть данные 
                     par[i].ok = true
                     N = N - 1 
                  end
               end
            else 
               N = N - 1 
            end
         end
      end
      return N
   end
   -------------------------------------------------
   local  sec_list = {}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 1}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 2}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 10}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 20}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 10}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 2}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'LKOH', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'FEES', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'SiZ5', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'RIZ5', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'RIZ5', interval = 15}
   sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'SRZ5', interval = 30}

   BulkRequestCandles(sec_list)
   --------------
   local DS = false
   while RUN do
      -- Проверка поступления свечей (без блокирования цикла обработки)
      
      if CheckingCandleRequest(sec_list) == 0 and not DS then
         DS = true
         -- Отладочная печать --
         for i = 1, #sec_list do
            if sec_list[i].ok == true then 
               message(sec_list[i].sec_code ..'  ds:size() = ' .. sec_list[i].ds:Size()
                        ..'  interval = ' .. sec_list[i].interval)
            else  -- Ошибка задания параметров
               message(sec_list[i].sec_code..'  interval = ' .. sec_list[i].interval
                        .. sec_list[i].ds )
            end
         end
      end
      
      --  Выполнение заданий скрипта --
      
      sleep (100)
   end 
end

function OnStop(signal)
   RUN = false
   return 5000
end

   function main()
   local N =100000
   local function foo () 
      local yield = coroutine.yield
      while 1 do
           yield() 
      end
   end   
   local function foo1 () return  end
   -----
   local out = 'Результат теста: количество вызовов = ' .. N .. ', время вызова сопрограммы '
               
   local resume = coroutine.resume
   local co = coroutine.create(foo)
   local TT1 = os.clock()
      for i =1, N do  resume(co) end
   TT1 = (os.clock() - TT1) * 1000
   out = out .. TT1 .. ' млс.'
   -- message('coroutine = ' .. (os.clock() - TT) * 1000)
   local TT2 = os.clock()
      for i =1, N do  foo1(10) end
   TT2 = (os.clock() - TT2) * 1000   
   -- message('function = '.. (os.clock() - TT) * 1000) 
   out = out .. ', функции ' .. TT2 .. ' млс. T1/T2 = ' .. TT1/TT2 
   message(out)
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

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