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

error("Сообщение об ошибке");

function bad(str)
    message(str, 1);
    local t
    t[1] = nil;
end

function main()
    local success, err = pcall(bad, "test string");
    if not success then
        message("Error: " .. err);
    end
end

while(true) do end

local MAIN_SCRIPT = "main_script";

-- в Lua 5.1 не функции table.pack, которая присутствует в Lua 5.2
function table.pack(...)
   return { n=select('#', ...); ... }
end
table.unpack = unpack;

package.path = string.format('%s;%s\\?.lua', package.path, getScriptPath());
if not pcall(require, MAIN_SCRIPT) then      -- безопасно загружаем main_script.lua (основной скрипт) из папки с этим скриптом
   error("Error loading " .. MAIN_SCRIPT .. ".lua");
end

local function create_proxy(func_name)
   if (_G[func_name] == nil) then
      return;
   end
   local old = _G[func_name];
   _G[func_name] = function(...)
      local res = table.pack(pcall(old, ...));
      if res[1] then
         return table.unpack(res, 2, res.n);
      else
         -- вызов функции завершился с ошибкой
         -- здесь можно выполнить любого рода код, сообщающий об ошибке.
         -- Чтобы прикратить выполнение скрипта в этот момент с той же
         -- ошибкой, которая произошла в вызываемом коде, достаточно:
         error(res[2]);
      end
   end
end

-- список функций, которые вызывает Quik
local func_list = {
   "main",
   -- список callback'ов из документации Quik 7.1.1.16
   "OnAccountBalance",
   "OnAccountPosition",
   "OnAllTrade",
   "OnCleanUp",
   "OnClose",
   "OnConnected",
   "OnDepoLimit",
   "OnDepoLimitDelete",
   "OnDisconnected",
   "OnFirm",
   "OnFuturesClientHolding",
   "OnFuturesLimitChange",
   "OnFuturesLimitDelete",
   "OnInit",
   "OnMoneyLimit",
   "OnMoneyLimitDelete",
   "OnNegDeal",
   "OnNegTrade",
   "OnOrder",
   "OnParam",
   "OnQuote",
   "OnStop",
   "OnStopOrder",
   "OnTrade",
   "OnTransReply",
};
for _,v in ipairs(func_list) do
   create_proxy(v);
end

while (true) do end

callback {
    найти (связать со сделкой) экземпляр ордера
    в случае, если весь объйм транзакции выбран полностью, отписаться в лог и удалить из списка активных транзакций
    если выбранный объём изменился или произошла ошибка, отписаться в лог
}

main {
    while(running) do
        по алгоритму выставить нужные транзакции
        по алгоритму выполнять подписку на стаканы нужных инструментов с помощью Subscribe_Level_II_Quotes
        раз в 5 секунд {
            блокировать список активных транзакций
            проверять не истёк ли для них таймаут ожидания ответа (для связки ordernum -- trans_id)
           те, для которых истёк, удалять из списка с записью в лог
        }
    end
}

message(_VERSION);

-- положим, есть внешняя библиотека, которая создаёт userdata для std::recursive_mutex в lua
-- mtx:lock() вызывает std::recursive_mutex::lock() (или EnterCriticalSection, если используются критические секции вместо recursive_mutex)
-- mtx:unlock() вызывает std::recursive_mutex::unlock() (или LeaveCriticalSection, если --//--)
mtx = recursive_mutex.create();
tbl = {};

function OnParam(class_code, sec_code)
    local idx = class_code .. "|" .. sec_code;
    mtx:lock();
    tbl[idx] = (tbl[idx] or 0) + 1;
    mtx:unlock();
end

running = true;

function OnStop()
    running = false;
end

function main()
    while (running) do
        sleep(50);
        mtx:lock();
        local str = {};
        -- ВОПРОС: Будет ли в этом месте таблица tbl содержать актуальные значение?
        -- Допустим, только что выполнился вызов mtx:unlock() в OnQuote в callback'е и мы попали сюда в потоке main.
        -- Отразится ли изменение выполненное в потоке callback'а строкой кода "tbl[idx] = (tbl[idx] or 0) + 1"
        -- на таблице tbl в потоке main?
        -- Как добиться здесь актуального значения полей таблицы tbl в этом месте?
        for k,v in pairs(tbl) do
            str[#str+1] = k .. "=" .. v;
        end
        message(table.concat(str, "\n"));
        mtx:unlock();
    end
end

t={{1,2,3,4},{5,nil,nil,8},{9,10,11,12}};

columns = 4;
rows = 3;

local f = io.open("myfile.log", "w+");
local temp = {};
for y = 1,rows do
   local line = t[y];
    for x = 1,columns do
       temp[x] = tostring(line[x]);
    end
    f:write(table.concat(temp, ' '), '\n');
end
f:close();

local f = io.open(getScriptPath().."\\myfile.log", "w+");

t={{1,2,3,4},{5,6,7,8},{9,10,11,12}};

local f = io.open("myfile.log", "w+");
for _,line in ipairs(t) do
    for _,item in ipairs(line) do
        f:write(tostring(item), ' ');
    end
    f:write('\n');
end
f:close();

message(tostring(Price).." ("..tostring(type(Price))..")");

function OnTrade(order)
    local pf = order.pending_fields;
    -- пример:
    -- order.pending_fields = {
    --     ["qty"] = true,
    --     ["price"] = true
    -- };
    -- вместо true можно использовать любое другое значение отличное от false, чтобы было удобно проверять наличие поля в хеше:
    -- if order.pending_fields["order_num"] then 
    --     -- .....
    -- end
    local msg = "Поля: "
    for k,_ in pairs(pf) do
        msg = msg..tostring(k).." ";
    end
    msg = msg .. " ожидают изменения".
    message(msg);
end

OnOrder({})

t = {};
message(tostring(t.order_num));

a = ("test").sub;
message(tostring(a));

function main()
    test1();
end

function test1()
    test2();
end

function test2()
    message("Test message");
end

function main()
    test2 = function()
        message("Test message");
    end
    test1();
end

function test1()
    test2();
end

transactions = {};

function OnOrder(order)
    if (transactions[order.order_num]) then
        return;
    end
    transactions[order.order_num] = true;

    -- .....
end

GetInfoParam("USERID")

Multimap = {};
Multimap.__index = Multimap;

function Multimap.Create()
   local self = {};
   setmetatable(self, Multimap);
   return self;
end

function Multimap:Ins ert(key, value)
   local list = self[key];
   if (list == nil) then
      list = {};
      self[key] = list;
   end
   table.ins ert(list, value);
end

function Multimap:Remove(key, value)
   local list = self[key];
   assert(list ~= nil, "key not found");
   for k,v in ipairs(list) do
      if (v == value) then
         table.remove(list, k);
         if (#list == 0) then
            self[key] = nil;
         end
         return;
      end
   end
   assert(false, "val ue not found");
end





-- Transaction class

Transaction = {};
Transaction.__index = Transaction;

ST_PENDING_NEW = 1;
ST_REJECTED = 2;
ST_NEW = 3;
ST_FILLED = 4;

function Transaction.CreateLimit(request)
   local self = {};
   setmetatable(self, Transaction);
   
   self.request = request;
   local os_time = os.time();
   self.id = self:GenerateId(os_time);
   self.time = os_time;
   self:ModifyHeader();
   
   self.status = ST_PENDING_NEW;
   Robot.transid_map[self.id] = self;
   
   self.volume = tonumber(self.request.QUANTITY);
   self.pending_volume = self.volume;
   self.trades = {};
   
   local ret = sendTransaction(self.request);
   if (ret ~= '') then
      Robot.transid_map[self.id] = nil;
      self:OnStatusChanged(ST_REJECTED);
   else
      Robot.time_map:Insert(os_time, self);
   end
end

function Transaction:ModifyHeader(os_time)
   assert(self.request.TRANS_ID == nil, "We use trans_id internally.");
   self.request.TRANS_ID = string.format("%d", self.id);
   self.request.CLIENT_CODE = string.format("%s//L%04d", self.request.CLIENT_CODE, Robot.id);
end

Transaction.max_trans_id = 0;
function Transaction:GenerateId(os_time)
   Transaction.max_trans_id = Transaction.max_trans_id + 1;
   local id = Robot.id * 10000 + os_time % (60*60*24*30 * 300) + Transaction.max_trans_id;
   assert(Robot.transid_map[id] == nil);
   return id;
end

function Transaction:UpdateTiming()
   Robot.time_map:Remove(self.time, self);
   local os_time = os.time();
   self.time = os_time;
   Robot.time_map:Insert(os_time, self);
end

function Transaction:InternalDelete()
   Robot.time_map:Remove(self.time, self);
   Robot.transid_map[self.id] = nil;
   if (self.orderid ~= nil) then
      Robot.orderid_map[self.orderid] = nil;
   end
end

-- consider we matched transaction by id and client_code already
function Transaction:OnTransReply(trans_reply)
   if (self.flag_ontransreply) then
      -- ignore all callback duplicates
      return;
   end
   assert(trans_reply.class_code == self.request.CLASSCODE and trans_reply.sec_code == self.request.SECCODE, "classcode or seccode mismatch");

   self.flag_ontransreply = true;
   -- только status == 3 говорит об успешном выставлении заявки
   if (trans_reply.status == 3) then
      self:OnStatusChanged(ST_NEW);
      if (self.orderid == nil) then
         self.orderid = trans_reply.order_num;
         Robot.orderid_map[self.orderid] = self;
      else
         assert(self.orderid == trans_reply.order_num);
      end
      self:UpdateTiming();
   else
      self:OnStatusChanged(ST_REJECTED);
      self:InternalDelete();
   end
end

-- consider we matched transaction by id and client_code already
function Transaction:OnOrder(order)
   if (self.flag_onorder) then
      -- ignore all callback duplicates
      return;
   end
   assert(order.class_code == self.request.CLASSCODE and order.sec_code == self.request.SECCODE, "classcode or seccode mismatch");
   
   self.flag_onorder = true;
   if (self.orderid == nil) then
      self.orderid = trans_reply.order_num;
      Robot.orderid_map[self.orderid] = self;
   else
      assert(self.orderid == order.order_num);
   end

   local test = bittest(order.flags, 3);
   if (test == 0) then
      -- если бит 0 и 1 не установлены -- заявка выполнена
      self:OnStatusChanged(ST_FILLED);
      self:InternalDelete();
   else
      local sell = bittest(order.flags, 4) ~= 0;
      assert((sell == (self.request.OPERATION == "S")) and (not sell == (self.request.OPERATION == "B")));
      if (test == 2) then
         self:OnStatusChanged(ST_REJECTED);
         self:InternalDelete();
      else
         self:UpdateTiming();
      end
   end
end

-- consider we matched transaction by id and client_code already
function Transaction:OnTrade(order)
   if (self.trades[order.trade_num]) then
      -- ignore all callback duplicates
      return;
   end
   assert(order.class_code == self.request.CLASSCODE and order.sec_code == self.request.SECCODE, "classcode or seccode mismatch");
   
   self.trades[order.trade_num] = true;
   print(string.format("OnTrade: %s:%s qty %g price %g settle %s:%s:%d", 
      order.class_code, order.sec_code, order.qty, order.price, order.settle_currency, order.settlecode, order.settle_date));
   self.pending_volume = self.pending_volume - order.qty;
   assert(self.pending_volume >= 0);
   self:UpdateTiming();
end

function Transaction:OnStatusChanged(new_status)
   message("Transaction changed status fr om "..self.status.." to "..new_status, 1);
   self.status = new_status;
end

function Transaction:OnTimeout()
   if (self.pending_volume == 0) then
      self:InternalDelete();
   else
      self:UpdateTiming();
   end
end





-- Robot class

Robot = {};
Robot.__index = {};

function Robot.Create(id, timeout)
   assert(id ~= nil, "id is required");
   timeout = timeout or 5;
   
   assert(Robot.id == nil, "Robot is singleton class");
   Robot.id = id;
   Robot.timeout = timeout;
   Robot.time_map = Multimap.Create();
   Robot.transid_map = {};
   Robot.orderid_map = {};
   Robot.trade_queue = Multimap.Create();
   return Robot;
end

function Robot:CheckTimeouts()
   local limit_time = os.time() - Robot.timeout;
   for timestamp,list in pairs(Robot.time_map) do
      if (timestamp <= limit_time) then
         for _,trans in ipairs(list) do
            trans:OnTimeout();
         end
      end
   end

   -- check not matched yet transactions
   for orderid,list in pairs(self.trade_queue) do
      local trans = self.orderid_map[orderid];
      if (trans ~= nil) then
         self.trade_queue[orderid] = nil;
         for _,v in ipairs(list) do
            trans:OnTrade(v);
         end
      end
   end
end

function Robot:CheckTradeQueueFor(trans)
   local list = self.trade_queue[trans.orderid];
   if (list ~= nil) then
      self.trade_queue[trans.orderid] = nil;
      for _,v in pairs(list) do
         trans:OnTrade(v);
      end
   end
end

function Robot:CheckComment(comment)
   return tonumber(string.match(comment, ".+//L(%d%d%d%d)$")) == self.id;
end

function Robot:SearchTransaction(transid, comment)
   if comment and not self:CheckComment(comment) then
      return nil;
   end
   if transid then
      return self.transid_map[transid];
   end
   return nil;
end

function OnTransReply(trans_reply)
   local trans = Robot:SearchTransaction(trans_reply.trans_id, nil, trans_reply.brokerref);
   if (trans ~= nil) then
      trans:OnTransReply(trans_reply);
   end
end

function OnTrade(order)
   if Robot:CheckComment(order.brokerref) then
      local trans = Robot.orderid_map[order.order_num];
      if (trans ~= nil) then
         Robot:CheckTradeQueueFor(trans);
         trans:OnTrade(order);
      else
         Robot.trade_queue:Insert(order.order_num, order);
      end
   end
end

function OnOrder(order)
   local trans = Robot:SearchTransaction(order.trans_id, order.brokerref);
   if (trans ~= nil) then
      trans:OnOrder(order);
   end
end


running = true;
function OnStop()
   running = false;
end

function main()
   print("Main function execution");
   local robot = Robot.Create(4242);
   
   Transaction.CreateLim it {
      ACCOUNT = "L01-00000F00",
      CLIENT_CODE = "51448",
      ACTION = "NEW_ORDER",
      CLASSCODE = "TQBR", SECCODE = "MTSS",
      OPERATION = "S",
      TYPE = "M", PRICE = "0", QUANTITY = "1",
   };
   
   while running do
      sleep(50);
      robot:CheckTimeouts();
   end
end








-- Utilities

function bittest(val ue, mask)
   local v = 1;
   local v2 = 2;
   local res = 0;
   for i = 1,32 do
      if (v > mask) then
         break;
      end
      local m = mask % v2 / v >= 1;
      local s = val ue % v2 / v >= 1;
      if (m and s) then
         res = res + v1;
      end
      v = v2;
      v2 = v2 * 2;
   end
    return res;
end

log_file = io.open(getScriptPath().."\\robot.log", "a");
log_file:write("\n");
function print(...)
   local r = { '[', os.date(), ']' };
   local first = true;
   for _,v in pairs({...}) do
      if (first) then first = false; else r[#r+1] = '\t'; end
      r[#r+1] = tostring(v);
   end
   r[#r+1] = '\n';
   log_file:write(table.concat(r));
end

function bittest(number, shift)
    local v = 1;
    for i=1,shift do
        v = v * 2;
    end
    return number / v % 2 >= 1;
end

-- Utility. Not optimized. Just an example.
function bittest(number, shift)
   local v = 1;
   for i=1,shift do
      v = v * 2;
   end
   return (number - v) ~= number;
end


running = true;

transaction = {}
transaction_stage = "not send";
transaction_details = {};

function set_stage(new_stage)
   transaction_stage = new_stage;
   message(transaction_stage, 1);
end


function OnStop()
   running = false;
end

function main()
   transaction = {
      ACCOUNT = "L01-00000***", -- (*** - для приватности)
      CLIENT_CODE = "51***//COMMENT",   -- лимит 20 символов для этого поля, это верно для транзаций по всем инструментам?
      ACTION = "NEW_ORDER",
      CLASSCODE = "TQBR", SECCODE = "MTSS",
      OPERATION = "B",
      TYPE = "M", PRICE = "0", QUANTITY = "1",
      TRANS_ID = "1000001", -- какие есть ограничения на значения этого поля? (самые жёсткие, для всех классов инструментов сразу)
   };
   local result = sendTransaction(transaction);
   if (result ~= '') then
      message("Ошибка отправки транзакции: "..result, 1);
   else
      transaction_stage = "send";
   end

   while running do sleep(50); end
end

function OnTransReply(trans_reply)
   if (tostring(trans_reply.trans_id) == transaction.TRANS_ID) then
      if (trans_reply.brokerref ~= transaction.CLIENT_CODE) then
         -- Возможна ли такая ситуация, и в каком состоянии находится транзация?
         set_stage("???");   -- прошу уточнить, что должно быть вместо ??? (в каком состоянии транзакция)
         return;
      end
      if (trans_reply.class_code ~= transaction.CLASSCODE or trans_reply.sec_code ~= transaction.SECCODE) then
         -- Возможна ли такая ситуация, и в каком состоянии находится транзация?
         set_stage("???");
         return;
      end
      if (trans_reply.quantity ~= tonumber(transaction.QUANTITY)) then
         -- Возможна ли такая ситуация, и в каком состоянии находится транзация?
         -- Может ли транзакция выполниться частично? При каких условиях?
         set_stage("???");
         return;
      end
      -- какие коды (ret_code) могут быть в result_msg? где можно посмотреть весь список?
      local ret_code = string.match(trans_reply.result_msg, "^%((%d+)%)");
      -- в чём измеряется time? как привести время к текущему?
      local time = trans_reply.time;
      if (trans_reply.status == 3) then
         transaction_details.order_num = trans_reply.order_num;
         set_stage("Транзакция успешно отправлена на сервер в "..time.." с кодом сообщения "..ret_code);
      else
         set_stage("Ошибка отправки транзакции на сервер (время "..time..", код "..ret_code..")");
      end
   end
end

function OnTrade(order)
   if (transaction_details.order_num == order.order_num) then
      -- пожалуйста, прокомментируйте возможные значащие значения order.flags в этом месте
      if (order.account ~= transaction.ACCOUNT) then
         -- Возможна ли такая ситуация, и в каком состоянии находится сделка?
         set_stage("???");
         return;
      end
      if (order.brokerref ~= transaction.CLIENT_CODE) then
         -- Возможна ли такая ситуация, и в каком состоянии находится сделка?
         set_stage("???");
         return;
      end
      if (order.class_code ~= transaction.CLASSCODE or order.sec_code ~= transaction.SECCODE) then
         -- Возможна ли такая ситуация, и в каком состоянии находится сделка?
         set_stage("???");
         return;
      end
      if (order.qty ~= tonumber(transaction.QUANTITY)) then
         -- Возможна ли такая ситуация, и как будет выглядеть частичное выполнение транзакции на максимально доступный объём?
         set_stage("???");
         return;
      end
      transaction_details.price = order.price;
      -- где ещё может использоваться trade_num в дальнейшем? при каких условиях? (пока не встречал этот id вне метода OnTrade)
      transaction_details.trade_num = order.trade_num;
      -- правильный ли тут статус?
      set_stage(string.format("Совершается сделка %d на %s лотов %d по цене %s",
         order.trade_num, bittest(order.flags, 2) and "продажу" or "покупку", order.qty, order.price))
   end
end

function OnOrder(order)
   if (transaction_details.order_num == order.order_num) then
      -- те же проверки, что и в OnTrade      
      if (order.account ~= transaction.ACCOUNT) then
         -- Возможна ли такая ситуация, и в каком состоянии находится сделка?
         set_stage("???");
         return;
      end
      if (order.brokerref ~= transaction.CLIENT_CODE) then
         -- Возможна ли такая ситуация, и в каком состоянии находится сделка?
         set_stage("???");
         return;
      end
      if (order.class_code ~= transaction.CLASSCODE or order.sec_code ~= transaction.SECCODE) then
         -- Возможна ли такая ситуация, и в каком состоянии находится сделка?
         set_stage("???");
         return;
      end
      if (order.qty ~= tonumber(transaction.QUANTITY)) then
         -- Возможна ли такая ситуация, и как будет выглядеть частичное выполнение транзакции на максимально доступный объём?
         set_stage("???");
         return;
      end

      -- какие биты в order.flags в этом месте являются значащими?
      -- что значит в этом месте установленный бит 4 в order.flags? (бит 4 (0x10)  Разрешить / запретить сделки по разным ценам)

      -- правильный ли тут статус?
      set_stage(string.format("Заявка %d на %s лотов %d выполнена",
         order.order_num, bittest(order.flags, 2) and "продажу" or "покупку", order.qty))
   end
end