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

{"SECCODE":"SiU2","ACTION":"NEW_ORDER","QUANTITY":"1","Переносить заявку":"Да","TRANS_ID":"23091660","PRICE":"62000","ACCOUNT":"SPBFUT000kg","CLIENT_CODE":"23091660","OPERATION":"B","Дата экспирации":"20220829","CLASSCODE":"SPBFUT"}

TRANS_ID=1;CLASSCODE=SPBFUT;ACTION=Ввод заявки;Торговый счет=SPBFUT000kg;К/П=Покупка;Тип=Лимитированная;Класс=SPBFUT;Инструмент=SiU2;Цена=61000;
Количество=1;Условие исполнения=Поставить в очередь;Комментарий=;Переносить заявку=Да;Дата экспирации=20221223;

--
-- Подсчёт количества событий, произошедших за последние несколько секунд.
-- При регистрации очередного события в массив событий добавляется новый элемент с указанием текущего момента времени.
-- При подсчёте числа событий учитываются только те события, которые произошли не более чем указанное количество
-- секунд назад, а остальные события удаляются из массива.
--

local EventsCounter = {}

local function systime()
    local d = os.sysdate()
    local mcs = d.mcs or 0
    d.ms = nil
    d.mcs = nil
    return os.time(d) + mcs * 0.000001
end

--- Конструктор.
-- @param self объект
-- @param interval количество секунд, на протяжении которых отслеживаются события
-- @param bump максимальное количество секунд, на протяжении которого событие занимает очередь без регистрации
local function new(self, interval, bump)
    local object = {
        interval = interval,
      bump = bump,
        events = {},
    }
    setmetatable(object, self)
    self.__index = self
    return object
end

EventsCounter.new = new

--- Зарегистрировать событие.
-- @param self объект
local function registerEvent(self, trans_id)
    self.events[trans_id] = systime()
end

EventsCounter.registerEvent = registerEvent

--- Запомнить событие до его регистрации
-- @param self объект
local function preRegisterEvent(self, trans_id)
    self.events[trans_id] = systime() + self.bump
end

EventsCounter.preRegisterEvent = preRegisterEvent

--- Узнать, сколько событий произошло за последние несколько секунд.
-- @param self объект
-- @return количество событий, произошедших за последние несколько секунд
local function getCount(self)
    local now = systime()
    local count = 0
    local remove = {}
    for id, time in pairs(self.events) do
        if now - time <= self.interval then
            count = count + 1
        else
            remove[id] = true
        end
    end
    for id, _ in pairs(remove) do
        self.events[id] = nil
    end
    return count
end

EventsCounter.getCount = getCount


return EventsCounter

local EventsCounter = require("EventsCounter")

local eventsCounter = EventsCounter:new(1.0, 30.0)

function myTransactionSend(transaction)
-- Перед отправкой транзакции проверяем количество событий и притормаживаем, если надо
  while eventsCounter:getCount() >= 50 do
    sleep(10)
  end

-- Ваш код, который отсылает заявку
  sendTransaction()

  eventsCounter:preRegisterEvent(tonumber(transaction.TRANS_ID))
end

-- ответ на отправку транзакции
function OnTransReply(trans_reply)
  eventsCounter:registerEvent(transReply.trans_id)
end

while eventsCounter:getCount() > 45 do
    sleep(10)
end

-- отправка траназакции квику
function router:processTransaction(transaction, tJson)
  trace("info", "NEW TRANSACTION: " .. tJson)
  local ok = sendTransaction(transaction)
  if ok ~= "" then
     -- код, чтобы обработать ошибку
  end  
end