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

my_table_DataSource, error_desc_2 = CreateDataSource("TQBR", "SBER",  INTERVAL_M5)  

message("Table_Size:" .. tostring(my_table_DataSource.Size()))

table_stock = getQuoteLevel2("TQBR", "SBER")

message("bid_count:" .. table_stock.bid_count)

       //index - номер таблицы в стеке Lua

    lua_getfield(L, index, "Size");            //"Извлекаем" из "таблицы" функцию отвечающую за возвращения размера этой таблицы.
    lua_pushvalue(L, index);                //Помещаем копию обьекта таблицы на вершину стека.

    int status_lua_pcall = lua_pcall(L, 1, 1, 0);      //Вызываем функцию Size 

    lua_getfield(L, index, "bid_count");            //"Извлекаем" из "таблицы" функцию отвечающую за возвращения размера этой таблицы.
    lua_pushvalue(L, index);                //Помещаем копию обьекта таблицы на вершину стека.

    int status_lua_pcall = lua_pcall(L, 1, 1, 0);      //Вызываем функцию Size 

function main()


local my_class_code  = "TQBR"
local my_class_paper = "SBER"

local Subscribe_Level_II__BOOLEAN = Subscribe_Level_II_Quotes(my_class_code, my_class_paper)     

message("Subscribe_Level_II__BOOLEAN:" .. tostring(Subscribe_Level_II__BOOLEAN))


if Subscribe_Level_II__BOOLEAN == true then

local local_table_stock = getQuoteLevel2(class, sec)

message("bid_count:" .. tostring(local_table_stock.bid_count))

end





-------------------------
while not stopped do 
sleep(1)
end 
-------------------------



end -- end main()

global_cntr=0;



function my_callback_CreateDataSource_(my_table_data_candle_, code_class_, code_paper_, interval_, idx)


message(code_paper_ ..":" .. interval_string_..":" ..tostring(my_table_data_history_candle_:C(idx))  )




if global_cntr == 13 then

my_table_data_history_candle_:Close()     --отписываемся
message("CLOSE")

end
global_cntr=global_cntr+1


end








function main()

message("start")

local code_class_1= "TQBR"          
local code_paper_1= "SBER"
local intervakla_1= INTERVAL_M1



local my_table_1, error_desc_1 = CreateDataSource(code_class_1, code_paper_1, intervakla_1)  


------------------------Проверка на ошибки:-------------------
if error_desc_1 ~= nil then 
message("1:" .. error_desc_1)
end
--------------------------------------------------------------

status = my_table_1:SetUpdateCallback(function(idx)my_callback_CreateDataSource_(my_table_1, code_class_1, code_paper_1, intervakla_1, idx) end)









while not stopped do 

sleep(1)

if global_cntr == 14 then

message("START_2")

local code_class_1= "TQBR"          
local code_paper_1= "SBER"
local intervakla_1= INTERVAL_M1



local my_table_2, error_desc_2 = CreateDataSource(code_class_1, code_paper_1, intervakla_1)  


------------------------Проверка на ошибки:-------------------
if error_desc_2 ~= nil then 
message("1:" .. error_desc_2)
end
--------------------------------------------------------------

status = my_table_2:SetUpdateCallback(function(idx)my_callback_CreateDataSource_(my_table_2, code_class_1, code_paper_1, intervakla_1, idx) end)

message(tostring(status))

global_cntr = global_cntr + 1

message("END")
break

end


end








-------------------------
while not stopped do 
sleep(1)
end 
-------------------------



end -- end main()

Позволяет задать пользователю функцию обратного вызова для обработки изменившихся СВЕЧЕК

local is_run = true

local function is_date(val)
    local status = pcall(function() return type(val) == "table" and os.time(val); end)
    return status
end

local function call_back_processor(action, context)
    if not action then return end
    return function(index)
        action(index, context)
    end
end

local function on_ds_action(index, context)
    local time = is_date(context.ds:T(index)) and os.time(context.ds:T(index)) or nil

    message(tostring(index) .. "\n" .. tostring(context.interval))
    context.ds:Close()

end

local function create_ds(context, action)

    if not context then return end

    local ds, err = _G.CreateDataSource(context.class_code, context.sec_code, context.interval)

    if not ds then
        _G.message(err, 3)
        return
    end

    if ds and action then
        ds:SetUpdateCallback(call_back_processor(action, context))
    end
    context.ds = ds

    return ds
end

function _G.main()

    create_ds({sec_code = 'PRMB', class_code = 'TQBR', interval = _G.INTERVAL_W1}, on_ds_action)       --VLHZ
    create_ds({sec_code = 'PRMB', class_code = 'TQBR', interval = _G.INTERVAL_MN1}, on_ds_action)

    while is_run do
        _G.sleep(100)
    end
end

function _G.OnStop()
    is_run = false
end

function my_callback_CreateDataSource_HISTORY_1(my_table_data_history_candle_, code_class_, code_paper_, interval_, interval_string_)

message("SIZE_TABLE:" ..tostring(my_table_data_history_candle_:Size() .. "\n" .. ":" ..  code_paper_ ..":" .. interval_string_ ..":" ..my_int_1))

end




function my_callback_CreateDataSource_HISTORY_2(my_table_data_history_candle_, code_class_, code_paper_, interval_, interval_string_)

message("SIZE_TABLE:" ..tostring(my_table_data_history_candle_:Size() .. "\n" .. ":" ..  code_paper_ ..":" .. interval_string_..":" ..my_int_2))

end








-----------------------------------------------------------------------------------------------------------int main:-----------------------------------------------------------------------------------------------------


function main()


local code_class_1= "TQBR"          
local code_paper_1= "GAZP"           
local intervakla_1= INTERVAL_MN1
local intervakla_string_1 = "INTERVAL_MN1"



my_table_1, error_desc_1 = CreateDataSource(code_class_1, code_paper_1, intervakla_1)  


------------------------Проверка на ошибки:-------------------
if error_desc_1 ~= nil then 
message("1:" .. error_desc_1)
end
--------------------------------------------------------------

my_table_1:SetUpdateCallback(function(idx)my_callback_CreateDataSource_HISTORY_1(my_table_1, code_class_1, code_paper_1, intervakla_1, intervakla_string_1) end)








local code_class_2= "TQBR"          
local code_paper_2= "SBER"           
local intervakla_2= INTERVAL_W1
local intervakla_string_2 = "INTERVAL_W1"


my_table_2, error_desc_2 = CreateDataSource(code_class_2, code_paper_2, intervakla_2) 

------------------------Проверка на ошибки:-------------------
if error_desc_2 ~= nil then 
message("2:" .. error_desc_2)
end
--------------------------------------------------------------


my_table_2:SetUpdateCallback(function(idx)my_callback_CreateDataSource_HISTORY_1(my_table_2, code_class_2, code_paper_2, intervakla_2, intervakla_string_2) end)





-------------------------
while not stopped do 
sleep(1)
end 
-------------------------



end -- end main()

int my_callback(lua_State* L)
{
//Доп.пераметры извелкаем через lua_upvalueindex.

std::cout<<"interval_int:" <<interval_int <<std::endl;
}



void my_call_CreateDataSource(lua_State* L_, name_class_insrument, name_code_paper, interval_int)
{
lua_getglobal(L, "CreateDataSource");          

lua_pushstring(L,_ name_class_insrument);    
lua_pushstring(L_, name_code_paper);        
lua_pushnumber(L_, interval_int);                

int status_lua_pcall = lua_pcall(L, 3, 2, 0); 



my_call_SetUpdateCallback(L_, my_callback, name_class_insrument, name_code_paper, interval_int);    //Вызываем SetUpdateCallback и передаем в нее функцкиб обратного вызова и доп.параметры.
}


int ruc_cpp(lua_State* L_main)
{



lua_State* L_1 = lua_newthread(L_main);       //Создаю "поток" связанный с главным стеком.
lua_State* L_2 = lua_newthread(L_main);


my_call_CreateDataSource(L_1 , "TQBR", "GAZP", "INTERVAL_H2");
my_call_CreateDataSource(L_2 , "TQBR", "GAZP", "INTERVAL_H4");






    //-----------------------------------------------
    for (int i = 0; i < 1000000; i++)
    {
        std::this_thread::sleep_for(std::chrono::milliseconds(100)); 
    }
    //-----------------------------------------------
}

function main()

local code_class_= "TQBR"          
local code_paper_= "ZVEZ"           
local interval_= INTERVAL_W1

my_table_, error_desc = CreateDataSource(code_class_, code_paper_, interval_)  

------------------------Проверка на ошибки:-------------------
if error_desc ~= nil then 
message(error_desc)
end
--------------------------------------------------------------

my_table_:SetUpdateCallback(function(idx)my_callback_CreateDataSource_HISTORY(my_table_, code_class_, code_paper_, intervakla_) end)




code_class_= "TQBR"          
code_paper_= "ZVEZ"           
interval_= INTERVAL_M15   


local my_table_1, error_desc_1 = CreateDataSource(code_class_, code_paper_, interval_) 

------------------------Проверка на ошибки:-------------------
if error_desc_1 ~= nil then 
message(error_desc_1)
end
--------------------------------------------------------------

my_table_1:SetUpdateCallback(function(idx)my_callback_CreateDataSource_HISTORY(my_table_1, code_class_, code_paper_, intervakla_) end)



-------------------------
while not stopped do 
sleep(1)
end 
-------------------------


end -- end main()