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

table: 0000027F53E0C620
table: 0000027F53E0C2A0
table: 0000027F53E0C3A0
table: 0000027F53E0C820
table: 0000027F53E0C460

--  Скрипт для КВИК: Получение цены и запись в лог-файл
-- =======================================================
minfo=debug.getinfo(1, "S").source:sub(2);  p=minfo:match("(.*[/\\])") or "."
log_file_path =p.."/lua_log.txt"
class = "QJSIM"
sec = "SBER"    -- КОД ИНСТРУМЕНТА
param = "LAST"  -- Параметр: Цена последней сделки
local value = getParamEx (class, sec,param).param_image
if value then
   log_message = " Цена " .. sec .. " = " .. tostring(value)
else
   -- Ошибка
   log_message = "ОШИБКА: Не удалось получить параметр " .. param .. " для " .. sec .. ". Проверьте коды класса/инструмента и активность торгов."
end
 message( log_message,1) 
local file = io.open(log_file_path, "a")
if file then
   file:write(os.date("[%Y-%m-%d %H:%M:%S] ") .. log_message .. "\n")
   io.close(file)
   print("Лог записан в файл: " .. log_file_path) -- В системный лог QUIK
else
   local err = "Невозможно открыть/записать файл лога по пути: " .. log_file_path
   message(err, true) -- Всплывающее окно в QUIK
   print(error)
end

--  Скрипт для КВИК: Получение цены BRF6 и запись в лог-файл
-- =======================================================
minfo=debug.getinfo(1, "S").source:sub(2);  p=minfo:match("(.*[/\\])") or "."
log_file_path =p.."/lua_log.txt"
class = "QJSIM"
sec = "SBER"    -- КОД ИНСТРУМЕНТА
param = "LAST"  -- Параметр: Цена последней сделки
-- Используем функцию QUIK API для получения данных
local value = getParamEx (class, sec,param).param_image
  message(tostring(value),1) -- Всплывающее окно в QUIK
if value then
   log_message = " Цена " .. sec .. " = " .. tostring(value)
else
   -- Ошибка
   log_message = "ОШИБКА: Не удалось получить параметр " .. param .. " для " .. sec .. ". Проверьте коды класса/инструмента и активность торгов."
end
-- Запись сообщения в файл лога
 message( log_message,1) 
local file = io.open(log_file_path, "a")
if file then
   file:write(os.date("[%Y-%m-%d %H:%M:%S] ") .. log_message .. "\n")
   io.close(file)
   print("Лог записан в файл: " .. log_file_path) -- В системный лог QUIK
else
   local err = "Невозможно открыть/записать файл лога по пути: " .. log_file_path
   message(err, true) -- Всплывающее окно в QUIK
   print(error)
end

Ts={SBER={int={1,2,5,10,20},q=true},
GAZP={int={2,5},q=true}, LKOH={int={5},q=true}} 
--инструменты, которыми торгует робот , интервалы свечей и флаг
получения стакана

list_task="task1,task2"  -- задачи, которые
быдет исполнять робот  

nkLog=true;  -- -включить вывод в лог файл

----------------не трогать---------------

minfo =
debug.getinfo(1, "S").source:sub(2); path =
minfo:match("(.*[/\\])") or "."

dofile(path.."stream.lua")

Ts={SiZ5={int={5}}, RIZ5={int={5,10},},SRZ5={int={30}}}
--инструменты и интервалы свечей

list_task="task3,task4"  -- список задач

nkLog=true;

----------------не трогать---------------

minfo =
debug.getinfo(1, "S").source:sub(2); path =
minfo:match("(.*[/\\])") or "."

dofile(path.."stream.lua")

list_stream="B,C"  --список потоков
nkLog=true; --включаем лог файл

--Пример асинхронного запроса свечей--результат в массиве ds для каждого инструмента
----------------------
name="nk_bot"
fnlog="D:/"..name..".log"; nkLog=io.open(fnlog,"w") 
Tclas={}
Tclas.QJSIM={SBER={int={1,2,5,10,20},ds={}}, GAZP={int={2,5},ds={}}, LKOH={int={5},ds={}}}
Tclas.SPBFUT={SiZ5={int={5},ds={}}, RIZ5={int={5,10},ds={}},SRZ5={int={30},ds={}}}
local tim=os.clock()
 ------------------------
 function main()
  run=true;
  local x=0; for c,tc in pairs(Tclas) do  for s,ts in pairs(tc) do  x=x+1 end  end    MaxDS=x;
  while run do 
     if MaxDS then 
   for c,tc in pairs(Tclas) do 
      for s,ts in pairs(tc) do  
         local ts=tc[s]; local int=ts.int; local ds=ts.ds;local  N=#int; local M=#ds;
       if N~=M then local j=0; 
           while N>j do j=j+1; 
            if ds[j]==nil then local x=CreateDataSource(c,s, int[j]);  
            if x and x:Size()>0  then    local ti=math.tointeger(1000*(os.clock()-tim)//1);
            ds[j]=x; nkLog:write("time(ms)="..tostring(ti)..","..c..","..s..",j="..j..",int="..int[j]..",size="..ds[j]:Size().."\n"); nkLog:flush();
            end
         end
       end
       M=#ds; if N==M then MaxDS=MaxDS-1; nkLog:write(s..",подписка завершена\n");        nkLog:flush(); end
         end
      end
   end
   if MaxDS==0 then  nkLog:write("блокируем блок подписки\n");    nkLog:flush(); MaxDS=nil end
   end
 --  Выполнение заданий скрипта --
      sleep (10)
   end 
end
function OnStop(signal)    run = false   return 1000 end

function OnParam(c,s)
if MaxDS then 
for c,tc in pairs(Tclas) do 
   for s,ts in pairs(tc) do  
   local ts=tc[s]; local int=ts.int; local ds=ts.ds;local  N=#int; local M=#ds;
   if N~=M then local j=0; 
   while N>j do j=j+1; 
   if ds[j]==nil then  local x=CreateDataSource(c,s, int[j]);  
   if x:Size()>0  then  local ti=math.tointeger(1000*(os.clock()-tim)//1);
   ds[j]=x; nkLog:write("time(ms)="..tostring(ti)..","..c..","..s..",j="..j..",int="..int[j]..",size="..ds[j]:Size().."\n"); nkLog:flush();
       end
      end
   end
   M=#ds; if N==M then MaxDS=MaxDS-1; nkLog:write(s..",подписка завершена\n"); nkLog:flush(); end
      end
   end
   end
   if MaxDS==0 then  nkLog:write("блокируем OnParam\n"); nkLog:flush(); MaxDS=nil end
  end
end

--Пример асинхронного запроса свечей--
--результат в массиве ds для каждого инструмента
Tclas={}
Tclas.QJSIM={SBER={int={1,2,5,10,20},ds={}}, GAZP={int={2,5},ds={}}, LKOH={int={5},ds={}}}
Tclas.SPBFUT={SiZ5={int={5},ds={}}, RIZ5={int={5,10},ds={}},SRZ5={int={30},ds={}}}
local tim=os.clock()
 ------------------------
RUN = true
function main()
local fDS=true;
 while RUN do 
 --  Выполнение заданий скрипта --
    sleep (10)
   end 
end
---------------------------------]
function OnParam(c,s)
  if MaxDS then 
     for c,tc in pairs(Tclas) do 
   for s,ts in pairs(tc) do  
     local ts=tc[s]; local int=ts.int; local ds=ts.ds;local  N=#int; local M=#ds;
     if N~=M then       local j=0; 
        while N>j do j=j+1; 
      if ds[j]==nil then    local x=CreateDataSource(c,s, int[j]);  
        if x:Size()>0  then    local ti=math.tointeger(1000*(os.clock()-tim)//1);
           ds[j]=x; nkLog:write("time(ms)="..tostring(ti)..","..c..","..s..",j="..j..",int="..int[j]..",size="..ds[j]:Size().."\n");nkLog:flush();
                   end
      end
       end
       M=#ds; if N==M then MaxDS=MaxDS-1; nkLog:write(s..",подписка завершена\n"); nkLog:flush(); end
   end
    end
   end
  end
 if MaxDS==0 then  nkLog:write("блокируем OnParam\n");    nkLog:flush(); MaxDS=nil end
end

function OnStop(signal)    RUN = false   return 5000 end

function OnInit(p) -- инициализация функции main
local p=string.reverse(p); local n,m=string.find(p,"\\"); 
local pS=string.reverse(string.sub(p,n)); name=string.reverse(string.sub(p,5,n-1)) ;
package.cpath =package.cpath..";"..pS.."?.dll;"
package.path =package.path..";"..pS.."?.lua;"..pS.."?.luac;"
fnlog=pS..name.."_nk.log";   nkLog=io.open(fnlog,"w")
local x=0; for c,tc in pairs(Tclas) do  for s,ts in pairs(tc) do  x=x+1 end  end MaxDS=x;
end

time(ms)=53,QJSIM,SBER,j=1,int=1,size=1041
time(ms)=54,QJSIM,SBER,j=2,int=2,size=523
time(ms)=54,QJSIM,SBER,j=3,int=5,size=209
time(ms)=54,QJSIM,SBER,j=4,int=10,size=105
time(ms)=54,QJSIM,SBER,j=5,int=20,size=53
SBER,подписка завершена
time(ms)=55,QJSIM,GAZP,j=1,int=2,size=523
time(ms)=55,QJSIM,GAZP,j=2,int=5,size=209
GAZP,подписка завершена
time(ms)=207,QJSIM,LKOH,j=1,int=5,size=209
LKOH,подписка завершена
time(ms)=207,SPBFUT,SiZ5,j=1,int=5,size=18572
SiZ5,подписка завершена
time(ms)=207,SPBFUT,SRZ5,j=1,int=30,size=2262
SRZ5,подписка завершена
time(ms)=207,SPBFUT,RIZ5,j=1,int=5,size=11347
time(ms)=207,SPBFUT,RIZ5,j=2,int=10,size=13811
RIZ5,подписка завершена
блокируем OnParam