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

if isConnected()==1 then
  message("IsConnected "..tostring(Isconnected()))
  csi,error_desc=CreateDataSource("INDX", "IMOEX", INTERVAL_D1)
...
...

function main()
   message("Script's start local time: "..os.date("%d-%b-%Y %X"))
   SessionDate=getTradeDate().date
   message("Session date "..SessionDate)
   ParamRequest(p_classcode,ticker,"TRADINGSTATUS")
   --
   while is_run==true do
      t_status=tonumber(getParamEx2("TQBR",ticker, "TRADINGSTATUS").param_value) -- текущий статус
      if status~=t_status then -- изменение статуса сессии
         status=t_status
         if status==3 or status==1 then
            if not ds or type(ds)~="table" then
               ds,error_desc=CreateDataSource("TQBR", ticker, INTERVAL_TICK)
               if error_desc~=nil and error_desc~="" then message(" Source error==>" .. error_desc) end
               local nn=0
               while ds:Size()<5 and nn<100 do
               sleep(100) nn=nn+1
               end
               ds:SetEmptyCallback()
               message(os.date(" %X").." Ready. Session status:"..tostring(status).." Data size:"..tostring(ds:Size()))
            end
            while n<10 and status==1 do
               local size=ds:Size()
               if size~=old_size then
                  message(tostring(n)..os.date(" %X").." Get data. Session status:"..tostring(status).." Data size:"..tostring(ds:Size()))
                  old_size=size
                  n=n+1
               end
               sleep(50)
            end
         end
      end
      sleep(100)
   end
end

-- Скрипт проверки корректности получения данных обезличенных сделок.
-- Терминал запускается вместе со скриптом ДО начала сессии.
-- Таблица обезличенных сделок не открыта
-- Тикера нет в Таблице текущих торгов.
--
ticker="MAGN"
status,t_status=0,0
old_size=0
n=0
is_run=true
SessionDate=""
function main()
   message("Script's start local time: "..os.date("%d-%b-%Y %X"))
   SessionDate=getTradeDate().date
   message("Session date "..SessionDate)
   ParamRequest(p_classcode,ticker,"TRADINGSTATUS")
   --
   while is_run==true do
      if SessionDate~=getTradeDate().date and status==1 then -- новая сессия
         SessionDate=getTradeDate().date
         message("New session date "..SessionDate)
         n=0
      end
      t_status=tonumber(getParamEx2("TQBR",ticker, "TRADINGSTATUS").param_value) -- текущий статус
      if status~=t_status then -- изменение статуса сессии
         status=t_status
         if status==3 or status==1 then
            if not ds or type(ds)~="table" then
               ds,error_desc=CreateDataSource("TQBR", ticker, INTERVAL_TICK)
               if error_desc~=nil and error_desc~="" then message(" Source error==>" .. error_desc) end
               local nn=0
               while ds:Size()<5 and nn<100 do
               sleep(100) nn=nn+1
               end
               ds:SetEmptyCallback()
               message(os.date(" %X").." Ready. Session status:"..tostring(status).." Data size:"..tostring(ds:Size()))
               while n<10 and status==1 do
                  local size=ds:Size()
                  if size~=old_size then
                     message(tostring(n)..os.date(" %X").." Get data. Session status:"..tostring(status).." Data size:"..tostring(ds:Size()))
                     old_size=size
                     n=n+1
                  end
                  sleep(50)
               end
            end
         end
      end
      sleep(100)
   end
end

function OnStop(stop_flag)
   message("Script's stop local time(MSK-1): "..os.date("%d-%b-%Y %X"))
   if ds then ds:Close() end
   is_run=false
end

is_run=true
function main()
   ds,error_desc=CreateDataSource("TQBR", "GAZP", INTERVAL_TICK)
   if error_desc~=nil and error_desc~="" then message(" Source error==>" .. error_desc) end
   local nn=0
   while ds:Size()<5 and nn<100 do
      sleep(100) nn=nn+1
   end
   message("Data "..tostring(ds:Size()))
   ds:SetEmptyCallback()

   while is_run do   
      sleep(100)
   end
end

function OnStop(stop_flag)
   ds:Close()
   is_run=false
end

function OnTrade(trade) -- обработчик события сделки
   if trade.client_code~=p_clientcode or trade.sec_code~=trw.p_seccode then return end -- чужая заявка
   local tnord=trade.trade_num --номер сделки
   local on ord=trade.order_num --номер заявки
   local price=trade.price --цена сделки
   local dir="" if bit.test(trade.flags,2)==true then dir="S" else dir="B" end -- направление сделки   
   if tnord>last_trade then --в обработку
          last_trade=tnord
...
...
...
  end
end