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

os.date() .. " ".. proc_name .. "\n"

--константы
ds = {} --таблица datasource по инструментам
--переменные скрипта
is_run = true      --Режим работы скрипта, работает или остановлен
shares = {}      --Список акций
shares_count = 0   --Количество акций
SEC_PRICE_STEP=0 --шаг цены
t = nil   --Данные для визуальной таблицы
sec_code = "CRH3"
class_code = "SPBFUT"
QUANTITY = 1
MAX_QUANTITY = 1 --максимальное количество дозакупки


file_log = nul         --указатель на файл лога
count_error = 0    --количество ошибок

--Дополнительый поток
function main()
   while is_run do
      if IsWindowClosed(t) then
         is_run=false
         return        
      end   
      sleep(50)
   end
end

event_table = {
        [QTABLE_LBUTTONDBLCLK] = "Левый даблклик",
        [QTABLE_RBUTTONDBLCLK]  = "Правый даблклик",        
        [QTABLE_CLOSE] = "Закрыли таблицу"
        }

-- колбек на изменение данных. расчитывает в текущей свече данные ЕМА и показывает в таблице.
function collback_H1( index )
end


--События основного потока
function OnInit(quik_path)
   --Создаем структуру, описывающую таблицу
   t = AllocTable()

   --столбцы
   CreateWindow(t)
   SetWindowPos(t, 200, 200, 600, 110)
   SetTableNotificationCallback(t, table_str)
   

      InsertRow(t, -1)
      InsertRow(t, -1)
      InsertRow(t, -1)

    
-- заполняем таблицу используя сортировку по ключам
   SetCell(t, 2, 1, tostring(sec_code))

   SetCell(t, 3, 9, tostring(currentprice))
   SERVERTIME = getInfoParam("SERVERTIME")
   file_log, error_desc   = io.open(getScriptPath() .. "\\M15_".. sec_code ..".log", "a")
   if not file_log then 
      message("Ошибка получения файла лога:" .. error_desc)
   else
      writeToLog("OnInit")
      writeToLog(SERVERTIME)
   end
end

function OnStop()
   is_run = false
   DestroyTable(t)
   writeToLog("OnStop")   
end

--служебные функции
function quantity_total() --подсчет количество позиций
end

function price_total() --цена позиции
end

function table_str(t_id, msg, par1, par2)
   --par1 номер строки. par2 номер колонки
   if msg == QTABLE_CLOSE then 
      is_run=false
      return
   elseif (par1 == 3) and (par2 == 9) and (msg == QTABLE_LBUTTONDBLCLK) then
      
   end
end


function apply_scale(value) --округляем до шага цены
   return math.floor((tonumber(value) or 0)/SEC_PRICE_STEP+0.5)*SEC_PRICE_STEP
end

function format_scale(value, scale)
    return string.format("%."..scale .."f", tonumber(value) or 0)
end

function writeToLog(proc_name)
    file_log:write(os.date() .. " ".. proc_name .. "\n")
    file_log:flush()
end

f, error_desc   = io.open(getScriptPath() .. "\\M15_".. sec_code ..".log", "a")
        if not f then 
      message("Ошибка получения файла лога:" .. error_desc)
   else
      writeToLog("MA" .. tostring(MA))
   end

f = nil            --указатель на файл лога
MA = 0
sec_code = "SRH3"
function main()
    while is_run do
        if IsWindowClosed(t) then
            is_run=false
            return        
        end 
        exMA()
        f, error_desc   = io.open(getScriptPath() .. "\\M15_".. sec_code ..".log", "a")
        if not f then 
      message("Ошибка получения файла лога:" .. error_desc)
   else
      writeToLog("MA" .. tostring(MA))
   end
        sleep(50) 
   end
end

function writeToLog(proc_name)
    f:write(os.date() .. " ".. proc_name .. "\n")
    f:flush()
end

function OnCalculate(index)
   local old_value = 0 
   old_value = GetValue(index, 1)
   return old_value
end

OI_Opt = {}
SecList = getClassSecurities("SPBOPT")
SecCode="BRX7" --тест по текущей нефти. заработает, допилим по газпрому
interval = 1

for TempSecCode in string.gmatch(SecList, "([^,]+)") do --перебираем опционы по очереди. --опускаю код сравнения базового актива опциона с нужным.
   ds_oi, dserror = CreateDataSource("SPBOPT", TempSecCode , interval, "NUMCONTRACTS") --подписался на ОИ
   ds_oi:SetEmptyCallback() --если нет в ТТП опциона, подпишемся
        
   for candle_num = 1, ds_oi:Size() do --перебираю исторические данные

-- отладочная информация.
      PrintDbgStr("QLua: " .. TempSecCode .. " " .. ds_oi:T(candle_num).month .. "." .. ds_oi:T(candle_num).day .. "." .. ds_oi:T(candle_num).hour .. "." .. ds_oi:T(candle_num).min .. " " ..ds_oi:C(candle_num))

--получаю по порядковому номеру значение ОИ
      OI_Opt[candle_num] = tonumber(OI_Opt[candle_num]) + ds_oi:C(candle_num)
   end
end

TRANS_ID = 1

function main()
   while is_run do
        sleep(350)
        robot()
   end
end

function robot()
   --сигнал на вход
   if (price ~= 0) and (need_order) and (quantity_total() < Maximum_quantity) and (quantity_total() > 0-Maximum_quantity) then --проверка на цену, необходимость выставления заявки и что текущее количество не больше разрешенного для лонга/шорта
      SetOrder("B", price, 1) --выставляем заявку
      need_order = false --условие, что есть заявка, то новую не ставим
   end
end

function SetOrder(type, price, qua) -- подать заявку
    Status =  tonumber(getParamEx(ClassCode,  SecCode, "status").param_value);    
    if (Status ~= 1) then 
        writeToLog("Status of " .. SecCode .. " is " .. Status)
        return
    end    
    if  (qua == 0) then
        writeToLog("QUANTITY is 0")
        return
    end
    
    if  (price == 0) then
        writeToLog("Price is 0")
        return
    end
    
    local    trans = {
      ["CLASSCODE"]=ClassCode,
      ["SECCODE"]=SecCode,
      ["ACTION"]="NEW_ORDER",
      ["ACCOUNT"]=ACCOUNT,
      ["CLIENT_CODE"]=CLIENT_CODE,
      ["TYPE"]="L",
      ["OPERATION"]=type,
      ["QUANTITY"]=tostring(qua),
      ["PRICE"]=tostring(price),
      ["TRANS_ID"]=TRANS_ID
                    }        
    local res = sendTransaction(trans)
end

function OnOrder(trans_reply) -- обработка  событий по заявке
    nord = trans_reply["order_num"]  -- номер заявки ORDERNUM    
    
    if nord==nil or nord==0 or nord=="0" then
        message("Заявка не выставилась",1)
        need_order = true
        return        
    elseif tostring(trans_reply["trans_id"]) == tostring(TRANS_ID) then        
        writeToLog(table2string(trans_reply))
        if trans_reply["flags"] == 24 or trans_reply["flags"] == 26 or trans_reply["flags"] == 28 then
            if trans_reply["balance"] == 0 then
                need_order = true --здесь условие, что выставленная заявка выполнилась и дальше контроль только на превышение разрешенного от депо
            end
        end
    end
    
end

function quantity_total() --подсчет количество позиций
    local q_total=0
    
    for i = 0,getNumberOf("FUTURES_CLIENT_HOLDINGS") - 1 do
        if getItem("FUTURES_CLIENT_HOLDINGS",i).sec_code == SecCode then -- ЕСЛИ строка по нужному инструменту           
            q_total = getItem("FUTURES_CLIENT_HOLDINGS",i).totalnet
            if q_total== nil then
                return 0
            else
                return q_total -- возвращаем количество позиций
            end
       end;
    end;
    return 0
end

--константы
data_file = "s_test.txt"   --путь к файлу со списком акций и кодов классов

--переменные скрипта
is_run = true      --Режим работы скрипта, работает или остановлен
shares = {}      --Список акций
shares_count = 0   --Количество акций
table_data = nil   --Данные для визуальной таблицы
class_code = "TQBR"     --Код классов
t = nil         --Указатель на визуальную таблицу


--Дополнительый поток
function main()
   while is_run do
      for key, value in spairs(shares) do
         i = i + 1
                   Subscribe_Level_II_Quotes(class_code, key)
         Quotes(key)         
      end
   end
end

function OnInit(quik_path)
   --читаем из файла акции и коды классов
   for line in io.lines(getScriptPath() .. "\\" .. data_file) do
      pos = string.len(line)
      share = string.sub(line, 0, pos)

      share_item = {}
      share_item["class"] = class_code
      shares[share] = share_item
      shares_count = shares_count + 1
   end

   table.sort(shares)

   --содержимое таблицы   
   table_data = {}


   --Создаем структуру, описывающую таблицу
   t = AllocTable()

   --столбцы
   AddColumn(t, 1, "Ticker", true, QTABLE_STRING_TYPE, 10)
   AddColumn(t, 2, "Count Bid", true, QTABLE_INT_TYPE, 10)
   AddColumn(t, 3, "Bid Price", true, QTABLE_STRING_TYPE, 10)
   AddColumn(t, 4, "Count Ask", true, QTABLE_INT_TYPE, 10)
   AddColumn(t, 5, "Ask Price", true, QTABLE_STRING_TYPE, 10)
   AddColumn(t, 6, "Delta", true, QTABLE_STRING_TYPE, 10)

   CreateWindow(t)
   SetWindowCaption(t, "Price_Delta")
   SetWindowPos(t, 200, 200, 500, 600)

   for i=1, shares_count do
      InsertRow(t, -1)
   end
 
   i = 0

   -- заполняем таблицу используя сортировку по ключам
   for key, value in spairs(shares) do
      i = i + 1
      sec_code = key
      SetCell(t, i, 1, tostring(sec_code))
      SetColor(t, i, 1, RGB(150, 150, 150), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
   end
end


function OnStop()
   is_run = false
   for key, value in spairs(shares) do      
      Unsubscribe_Level_II_Quotes(class_code, key)
   end
end

function Quotes(code)
   sleep(150)
   for i=1, shares_count do
      local row = GetCell(t, i, 1)
      row_sec = tostring(row["image"])
           if (row_sec == code) then
              q = getQuoteLevel2(class_code, code)
                   bid_count = tonumber(q["bid_count"])
         ask_count = tonumber(q["offer_count"])

         bid = q["bid"]   --покупатели
         ask = q["offer"]   --продавцы
                   max_bid_count = 0   --количество лотов (максимальный спрос)
         max_ask_count = 0   --количество лотов (максимальное предложение)
         max_bid_price = ""   --цена максимального спроса
         max_ask_price = ""   --цена максимального предложения


         --перебираем всех покупателей и находим самый большой объем
         for ii=1, bid_count, 1 do
            bid_quantity = tonumber( bid[ii]["quantity"] )
            if (bid_quantity > max_bid_count) then
               max_bid_count = bid_quantity
               max_bid_price = bid[ii]["price"]
            end
         end

         --перебираем всех продавцов находим самый большой объем
         for ii=1, ask_count, 1 do
            ask_quantity = tonumber( ask[ii]["quantity"] )
      
            if (ask_quantity > max_ask_count) then
               max_ask_count = ask_quantity
               max_ask_price = ask[ii]["price"]
            end
         end
                   
         SetCell(t, i, 2, tostring(max_bid_count))
         SetColor(t, i, 2, RGB(50, 250, 50), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
         SetCell(t, i, 3, tostring(max_bid_price))
         SetColor(t, i, 3, RGB(50, 250, 50), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
         SetCell(t, i, 4, tostring(max_ask_count))
         SetColor(t, i, 4, RGB(250, 50, 50), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
         SetCell(t, i, 5, tostring(max_ask_price))
         SetColor(t, i, 5, RGB(250, 50, 50), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
          

         if (max_ask_count>max_bid_count) then   
            price_max=max_ask_price
            SetCell(t, i, 2, "")
            SetColor(t, i, 2, RGB(255, 255, 255), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
            SetCell(t, i, 3, "")
            SetColor(t, i, 3, RGB(255, 255, 255), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)   
         elseif (max_ask_count<max_bid_count) then
            price_max=max_bid_price
            SetCell(t, i, 4, "")
            SetColor(t, i, 4, RGB(255, 255, 255), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
            SetCell(t, i, 5, "")
            SetColor(t, i, 5, RGB(255, 255, 255), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)   
         else 
            price_max=max_bid_price
         end
          
         closeprice=tonumber(getParamEx(class_code, code,"last").param_value)
         if (closeprice==0) then
            delta=0
         else
            delta=(tonumber(price_max)/closeprice-1)*100
         end
         
         SetCell(t, i, 6, apply_scale(delta,2))
         if delta>=2 then
            SetColor(t, i, 6, RGB(50, 250, 50), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
         elseif delta<=-2 then
            SetColor(t, i, 6, RGB(250, 50, 50), QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
         else 
                           SetColor(t, i, 6, RGB(255, 255, 255), QTABLE_DEFAULT_COLOR,QTABLE_DEFAULT_COLOR, QTABLE_DEFAULT_COLOR)
         end
      end
   end   
end
 

bid_count = tonumber(q["bid_count"])
ask_count = tonumber(q["offer_count"])
bid = q["bid"]
ask = q["offer"]

for bid_i=1, bid_count, 1 do
   bid_quantity = tonumber( bid[bid_i]["quantity"] )
   if (bid_quantity > max_bid_count) then
      max_bid_count = bid_quantity
      max_bid_price = bid[bid_i]["price"]
   end
end 

 if (max_bid_price~=nil) or (max_bid_price==0) then

                delta==0