-- SimpleEngine.lua
-- ПРОСТОЙ ТОРГОВЫЙ ДВИЖОК "Simple Engine" ДЛЯ QLua
 
SE_Run            = true            -- Флаг работы цикла while в функции main
 
SE_trans_id       = os.time()       -- Текущие дата и время в секундах хорошо подходят для уникальных номеров транзакций
 
SE_TransReplies   = {}              -- Массив для хранения ответов по транзакциям
SE_LastTransID    = 0               -- Последний ID транзакции, ответ по которой был обработан и удален из массива
SE_Orders         = {}              -- Массив для хранения информации о заявках
SE_LastOrderNum   = 0               -- Последний номер заявки, которая была обработана и удалена из массива
SE_Trades         = {}              -- Массив для хранения информации о сделках
SE_LastTradeNum   = 0               -- Последний номер сделки, которая была обработана и удалена из массива
 
 
-- =========================================================
-- ===  МЕХАНИЗМ ДВИЖКА  ===================================
-- =========================================================
 
-- Основная функция скрипта, пока работает эта функция, работает скрипт
function main()
   -- Пока работает данный цикл, работает функция main, следовательно, работает скрипт
   while SE_Run do
      -- Выполняет предопределенную функцию итераций, если она объявлена
      if SE_OnMainLoop ~= nil then SE_OnMainLoop() end
   -- МОНИТОРИТ ИЗМЕНЕНИЯ
      -- Перебирает ОТВЕТЫ ПО ТРАНЗАКЦИЯМ
      for i,TransReplie in ipairs(SE_TransReplies) do
         -- Если ответ еще не был учтен
         if SE_TransReplies[i].checked == nil then
            -- Проверяет на наличие ошибок по транзакции
            if SE_TransReplies[i].status > 1 and SE_TransReplies[i].status ~= 3 then
               -- Вызывает функцию обратного вызова (если она объявлена)
               if SE_OnTransExecutionError ~= nil then SE_OnTransExecutionError(SE_TransReplies[i]) end
               -- Запоминает, что ответ был учтен
               SE_TransReplies[i].checked = true
            -- Если транзакция выполнена
            elseif SE_TransReplies[i].status == 3 then
               -- Вызывает функцию обратного вызова (если она объявлена)
               if SE_OnTransOK ~= nil then SE_OnTransOK(SE_TransReplies[i]) end
               -- Запоминает, что ответ был учтен
               SE_TransReplies[i].checked = true
            end
         end
      end
      -- Перебирает ЗАЯВКИ
      for i,Order in ipairs(SE_Orders) do
         -- Если выставление заявки еще не было учтено
         if SE_Orders[i].checked == nil then
            -- Вызывает функцию обратного вызова (если она объявлена)
            if SE_OnNewOrder ~= nil then SE_OnNewOrder(SE_Orders[i]) end
            SE_Orders[i].checked = true
         end
         -- Проверяет какое количество в заявке исполнено
         local ExecutionCount = SE_Orders[i].qty - SE_Orders[i].balance
         -- Если это первая проверка, или с предыдущей проверки количество изменилось и заявка частично, или полностью исполнена
         if (SE_Orders[i].last_execution_count == nil or SE_Orders[i].last_execution_count ~= ExecutionCount) and ExecutionCount > 0 then
            -- Вызывает функцию обратного вызова (если она объявлена)
            if SE_OnExecutionOrder ~= nil then
               SE_OnExecutionOrder(SE_Orders[i])
               -- Запоминает исполненное количество для последующего сравнения
               SE_Orders[i].last_execution_count = ExecutionCount
            end
         end
      end
      -- Перебирает СДЕЛКИ
      for i,Trade in ipairs(SE_Trades) do
         -- Если в сделке уже появилось поле с номером заявки, по которой она была совершена
         if SE_Trades[i].order_num ~= nil then
            -- Перебирает заявки
            for j,Order in ipairs(SE_Orders) do
               -- Если найдена заявка, по которой совершена сделка
               if SE_Trades[i].order_num == SE_Orders[j].order_num then
                  -- Добавляет таблице сделки номер транзакции, которая инициировала данную сделку
                  SE_Trades[i].trans_id = SE_Orders[j].trans_id
                  -- Вызывает функцию обратного вызова (если она объявлена)
                  if SE_OnNewTrade ~= nil then SE_OnNewTrade(SE_Trades[i]) end
                  -- Запоминает номер последней обработанной сделки
                  SE_LastTradeNum = SE_Trades[i].trade_num
                  -- Удаляет сделку из массива, чтобы больше ее не обрабатывать
                  table.sremove(SE_Trades, i)
                  -- Если заявка сделки полностью исполнена и обработана
                  if SE_Orders[j].last_execution_count ~= nil and SE_Orders[j].last_execution_count == SE_Orders[j].qty then
                     -- Запоминает номер последней обработанной транзакции
                     SE_LastTransID = SE_Orders[j].trans_id
                     -- Удаляет ответ по транзакции из массива, чтобы больше ее не обрабатывать
                     for k,TransReplie in ipairs(SE_TransReplies) do
                        if TransReplie.trans_id == SE_Orders[j].trans_id then
                           table.sremove(SE_TransReplies, k)
                           break
                        end
                     end
                     -- Запоминает номер последней обработанной заявки
                     SE_LastOrderNum = SE_Orders[j].order_num
                     -- Удаляет заявку из массива, чтобы больше ее не обрабатывать
                     table.sremove(SE_Orders, j)
                     -- Прерывает цикл по заявкам
                     break
                  end
               end
            end
         end
      end
 
      sleep(1)
   end
end
-- Срабатывает при остановке скрипта
function OnStop() SE_Run = false if SE_OnStop ~= nil then SE_OnStop() end end
 
-- ========================================
-- ===  Функции, собирающие информацию  ===
 
-- Функция вызывается терминалом когда с сервера приходит ответ по транзакции
function OnTransReply(trans_reply)
   -- Если не относится к движку, выходит из функции
   if trans_reply.brokerref:find('SE_'..SEC_CODE) == nil then return end
   -- Перебирает массив ответов по транзакциям
   for i,TransReplie in ipairs(SE_TransReplies) do
      -- Если если ответ по данной транзакции уже занесен в массив
      if SE_TransReplies[i].trans_id == trans_reply.trans_id then
         -- Если появление ответа уже было учтено, сохраняет эту информацию
         if SE_TransReplies[i].checked ~= nil then trans_reply.checked = true end
         -- Заменяет его в массиве
         table.sremove(SE_TransReplies, i)
         table.sinsert(SE_TransReplies, trans_reply)
         -- Выходит из функции
         return
      end
   end
   -- Ответ еще не был добавлен в массив, добавляет
   if SE_LastTransID < trans_reply.trans_id then table.sinsert(SE_TransReplies, trans_reply) end
end
 
-- Функция вызывается терминалом когда с сервера приходит информация по заявке
function OnOrder(order)
   -- Если не относится к движку, выходит из функции
   if order.brokerref:find('SE_'..SEC_CODE) == nil then return end
   -- Перебирает массив заявок
   for i,Order in ipairs(SE_Orders) do
      -- Если заявка уже занесена в массив
      if SE_Orders[i].trans_id == order.trans_id then
         -- Если появление заявки уже было учтено, сохраняет эту информацию
         if SE_Orders[i].checked ~= nil then order.checked = true end
         -- Если исполненное количество уже учитывалось, сохраняет эту информацию
         if SE_Orders[i].last_execution_count ~= nil then order.last_execution_count = SE_Orders[i].last_execution_count end
         -- Заменяет ее
         table.sremove(SE_Orders, i)
         table.sinsert(SE_Orders, order)
         -- Выходит из функции
         return
      end
   end
   -- Заявка еще не была добавлена в массив, добавляет
   if SE_LastOrderNum < order.order_num then table.sinsert(SE_Orders, order) end
end
 
-- Функция вызывается терминалом когда с сервера приходит информация по сделке
function OnTrade(trade)
   -- Если не относится к движку, выходит из функции
   if trade.brokerref:find('SE_'..SEC_CODE) == nil then return end
   -- Перебирает массив сделок
   for i,Trade in ipairs(SE_Trades) do
      -- Если данная сделка уже занесена в массив
      if SE_Trades[i].trade_num == trade.trade_num then
         -- Если появление сделки уже было учтено, сохраняет эту информацию
         if SE_Trades[i].checked ~= nil then trade.checked = true end
         -- Заменяет ее
         table.sremove(SE_Trades, i)
         table.sinsert(SE_Trades, trade)
         -- Выходит из функции
         return
      end
   end
   -- Сделка еще не была добавлена в массив, добавляет
   if SE_LastTradeNum < trade.trade_num then table.sinsert(SE_Trades, trade) end
end
-- ========================================
-- =========================================================
 
 
 
-- =========================================================
-- ===  ФУНКЦИИ ДВИЖКА  ====================================
-- =========================================================
 
-- Выставляет лимитированную заявку
function SE_SetLimitOrder(
   account,    -- Код счета
   class_code, -- Код класса
   sec_code,   -- Код инструмента
   operation,  -- Операция ('B' - buy, 'S' - sell)
   price,      -- Цена
   qty         -- Количество
)
   -- Выставляет лимитированную заявку
   -- Получает ID для следующей транзакции
   SE_trans_id = SE_trans_id + 1
   -- Заполняет структуру для отправки транзакции
   local Transaction={
      ['TRANS_ID']   = tostring(SE_trans_id),-- Номер транзакции
      ['ACCOUNT']    = account,              -- Код счета
      ['CLASSCODE']  = class_code,           -- Код класса
      ['SECCODE']    = sec_code,             -- Код инструмента
      ['ACTION']     = 'NEW_ORDER',          -- Тип транзакции ('NEW_ORDER' - новая заявка)
      ['TYPE']       = 'L',                  -- Тип ('L' - лимитированная, 'M' - рыночная)
      ['OPERATION']  = operation,            -- Операция ('B' - buy, или 'S' - sell)
      ['PRICE']      = tostring(price),      -- Цена
      ['QUANTITY']   = tostring(qty),        -- Количество
      ['CLIENT_CODE']= 'SE_'..sec_code       -- Комментарий к транзакции, который будет виден в транзакциях, заявках и сделках в поле brokerref
   }
   -- Отправляет транзакцию
   local Res = sendTransaction(Transaction)
   -- Если при отправке транзакции возникла ошибка
   if Res ~= '' then
      -- Вызывает функцию обратного вызова (если она объявлена)
      if SE_OnTransSendError ~= nil then
         local trans = {}
         trans.trans_id = SE_trans_id
         trans.transaction = Transaction
         trans.result_msg = Res
         SE_OnTransSendError(trans)
      end
      -- Возвращает номер транзакции и сообщение об ошибке
      return SE_trans_id, Res
   end
   -- Если транзакция отправлена, возвращает ее номер
   return SE_trans_id
end
-- =========================================================

-- SimpleEngineExample.lua
-- ПРИМЕР ИСПОЛЬЗОВАНИЯ ДВИЖКА
-- для примера отправляется транзакция на выставление лимитированной заявки на покупку по определенной цене
 
require('SimpleEngine')                -- Подключение движка
 
ACCOUNT              = "SPBFUT00k59"   -- Код счета
CLASS_CODE           = "SPBFUT"        -- Код класса
SEC_CODE             = "RIH6"          -- Код инструмента
 
MyTransactionSended  = false           -- Флаг, что транзакция отправлена
 
-- =========================================================
-- ===  ФУНКЦИИ ОБРАТНОГО ВЫЗОВА (вызываются движком)  =====
-- =========================================================
 
-- Функция выполняется при каждой итерации цикла while в функции main
function SE_OnMainLoop()
   -- Здесь можно выполнять какой-то свой код
   -- ...
   -- ПРИМЕР
   -- Если тестовая транзакция еще не отправлена
   if not MyTransactionSended then
      -- Выставляет лимитированную заявку
      local trans_id, Res = SE_SetLimitOrder(
         ACCOUNT,    -- Код счета
         CLASS_CODE, -- Код класса
         SEC_CODE,   -- Код инструмента
         'B',        -- Операция ('B' - buy, 'S' - sell)
         77000,      -- Цена
         1           -- Количество
      )
      -- Запоминает, что транзакция отправлена, чтобы отправлена ее при каждой итерации цикла в main
      MyTransactionSended = true
   end
end
 
-- Вызывается движком при ОШИБКЕ отправки ТРАНЗАКЦИИ
function SE_OnTransSendError(trans)
   -- Здесь Ваш код для действий при ошибке отправки транзакции (возможно повторная отправка транзакции)
   -- ...
   -- Выводит сообщение
   message('SE_OnTransSendError() ОШИБКА отправки транзакции №'..trans.trans_id..': '..trans.result_msg)
end
-- Вызывается движком при ОШИБКЕ выполнения ТРАНЗАКЦИИ
function SE_OnTransExecutionError(trans)
   -- Здесь Ваш код для действий при ошибке выполнения транзакции (возможно повторная отправка транзакции)
   -- ...
   -- Выводит сообщение
   message('SE_OnTransExecutionError() ОШИБКА выполнения транзакции №'..trans.trans_id..': '..trans.result_msg)
end
-- Вызывается движком при успешном ВЫПОЛНЕНИИ ТРАНЗАКЦИИ
function SE_OnTransOK(trans)
   -- Здесь Ваш код для действий при успешном выполнении транзакции
   -- ...
   -- Выводит сообщение
   message('SE_OnTransOK() Транзакция №'..trans.trans_id..' УСПЕШНО выполнена')
end
 
-- Вызывается движком при появлении НОВОЙ ЗАЯВКИ
function SE_OnNewOrder(order)
   -- Здесь Ваш код для действий при появлении новой заявки
   -- ...
   -- Выводит сообщение
   message('SE_OnNewOrder() Выставлена новая заявка №'..order.order_num..' по транзакции №'..order.trans_id..', инструменту '..order.sec_code..', цене '..order.price..', на объем '..order.qty)
end
-- Вызывается движком при полном, или частичном ИСПОЛНЕНИИ ЗАЯВКИ
function SE_OnExecutionOrder(order)
   -- Здесь Ваш код для действий при полном, или частичном исполнении заявки
   -- ...
   -- Выводит сообщение
   message('SE_OnExecutionOrder() БАЛАНС заявки №'..order.order_num..' изменился с '..(order.qty - (order.last_execution_count or 0))..' на '..order.balance)
end
 
-- Вызывается движком при появлении НОВОЙ СДЕЛКИ
function SE_OnNewTrade(trade)
   -- Здесь Ваш код для действий при появлении новой сделки
   -- ...
   -- Выводит сообщение
   message('SE_OnNewTrade() Новая СДЕЛКА №'..trade.trade_num..' по транзакции №'..trade.trans_id..' по цене '..trade.price..' объемом '..trade.qty)
end
 
-- Вызывается движком при остановке скрипта
function SE_OnStop()
 
end
-- =========================================================