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

CLASS_CODE = "TQBR"
SEC_CODE   = "GAZP"
INTERVAL   = INTERVAL_D1

ds = nil

function OnInit()
    message("Starting duplicate candles check (DataSource mode)")

    ds = CreateDataSource(CLASS_CODE, SEC_CODE, INTERVAL)

    if ds == nil then
        message("Error: failed to create DataSource")
        return
    end

    while ds:Size() == 0 do
        sleep(100)
    end

    message("Data loaded. Candles count: " .. ds:Size())

    check_duplicates()
end

function check_duplicates()
    local groups = {}

    for i = 1, ds:Size() do
        local dt = ds:T(i)

        local key

        if dt ~= nil then
            -- если время нормальное
            if dt.hour ~= 0 or dt.min ~= 0 or (dt.sec or 0) ~= 0 then
                key = string.format("%04d%02d%02d %02d:%02d:%02d",
                    dt.year, dt.month, dt.day,
                    dt.hour, dt.min, dt.sec or 0)
            else
                -- fallback: только дата (важно!)
                key = string.format("%04d%02d%02d",
                    dt.year, dt.month, dt.day)
            end
        else
            key = "unknown"
        end

        if groups[key] == nil then
            groups[key] = {}
        end

        table.insert(groups[key], i)
    end

    local found = false

    for key, indexes in pairs(groups) do
        if #indexes > 1 then
            found = true
            message("Duplicate group: " .. key .. " | candles: " .. #indexes)

            for _, i in ipairs(indexes) do
                message(string.format(
                    "  index=%d O=%.2f H=%.2f L=%.2f C=%.2f V=%.0f",
                    i,
                    ds:O(i),
                    ds:H(i),
                    ds:L(i),
                    ds:C(i),
                    ds:V(i)
                ))
            end

        end
    end

    if not found then
        message("No duplicates found")
    end
end

function OnStop()
    if ds ~= nil then
        ds:Close()
    end
    message("Script stopped")
end

  ckeck_Lua_Stack(L_global);       
//Проверяю что находится на данный момент в стеке Lua.        
 //Находится следующее: 
---------------------------------------- 
Total element is stack:3 
type:string:1     //Таблица глобальных функций 
type:table:      //Это как раз запрошенная таблица CreateDataSource 
type:nil:        //Ошибка при запросе таблицы CreateDataSource - то есть nil - ошибки нет.
----------------------------------------

lua_State* L_global;
int static nummer_table_from_stack;

void SetUpdateCallcak_wrapper(lua_State* L)
{

    L_global = L;
    std::cout << "L_global_adress:" << &L_global << std::endl;


    //-----------------------------------------------------------------1-Вызовем функцию CreateDataSource:Начало--------------------------------------------
    lua_getglobal(L, "CreateDataSource");                 

    lua_pushstring(L, "TQBR");       //Добавим первый параметр функции CreateDataSource на вершину стека
    lua_pushstring(L, "SBER");          //Добавим второй параметр функции CreateDataSource на вершину стека
    lua_pushnumber(L, 1);            //Добавим третий параметр функции CreateDataSource на вершину стека

    int status_lua_pcall = lua_pcall(L, 3, 2, 0);    //Так как все необходимые параметры добавлены в стек, то вызываем функцию lua_pcall - которая использя доабвенные параметры в правильном порядке - реализует вызов функции CreateDataSource: 2-ой параметр - это число аргументов, которые мы добаили в стек и которая принимает функция CreateDataSource; 2-ой: параметр - это число параметров, которое возвращает функция CreateDataSource. После успешного выполнения lua_pcall удаляет и значение функции и переданные аргменты со стека в кол-во указанном во втором параметре(не велючая функцию) и доабвляеи результат на стек в кол-во указанном во втором параметре.
    //-----------------------------------------------------------------1-Вызовем функцию CreateDataSource:Конец--------------------------------------------



    //-------------------------------------------------------------------5-Проверка на ошибку lua_pcall:Начало---------------------------------------------------------------------
    if (status_lua_pcall != 0)
    {
        //Ошибка произошла при вызове функции lua_pcall при вызове CreateDataSource:
        std::cout << "ERROR CreateDataSource" << std::endl;
        return;
    }
    //-------------------------------------------------------------------5-Проверка на ошибку lua_pcall:Конец---------------------------------------------------------------------
    else
    {

         nummer_table_from_stack = lua_gettop(L) - 1;   //Это номер элемента в стеке L - в котором теперь размещается полученная от CreateDataSource таблица. "-1" - потому что CreateDataSource поместила на вершину стека две перменные: таблицу и переменную об ошибке. То есть таблица находить на предпоследнем месте с вершины стека.

         my_call_SetUpdateCallback(L);     //Вызываем SetUpdateCallback wrapper
    }

}

static void ckeck_Lua_Stack(lua_State* L)
{

    std::cout << "----------------------------------------" << std::endl;

    int top = lua_gettop(L);
    std::cout << "Total element is stack:"<< top << std::endl;

    for (int i = 1; i <= top; i++) 
    {
        int type = lua_type(L, i);

        const char* type_name = lua_typename(L, type);

        std::cout << "type:" << type_name << ":";


        if (type == LUA_TSTRING || type == LUA_TNUMBER) 
        {
            std::cout << lua_tostring(L, i) << std::endl;
        }
        else
        {
            std::cout << std::endl;
        }
    }
    std::cout << "----------------------------------------" << std::endl << std::endl;


    //std::this_thread::sleep_for(std::chrono::milliseconds(100000));

}

static int my_callback__for__SetUpdateCallback(lua_State* L)
{

//Значит произошла сделка!

    std::cout << "Number_candle:"<< lua_tonumber(L, -1) << std::endl;

    ckeck_Lua_Stack(L_global);         //Проверяем стек Lua!!! И теперь в нем находится сдедующее:

----------------------------------------
Total element is stack:1                          //Куда черт возьми делать моя ранее заказанная таблица CreateDataSource ?????
type:number:1
----------------------------------------


    return 0;

}

static void my_call_SetUpdateCallback(lua_State* L)
{

    
    //--------------------------------------------------------
    lua_getfield(L_global, nummer_table_from_stack, "SetUpdateCallback");                       //"Извлекаем" из "таблицы" функцию SetUpdateCallback.
     
    lua_pushvalue(L_global, nummer_table_from_stack);                                                       //Помещаем копию обьекта таблицы CreateDataSource на вершину стека.
    //--------------------------------------------------------


    lua_pushnumber(L_global, 555);  //Просто для примера связываю какое то любое значение для передачи в колбек. 

    lua_pushcclosure(L_global, my_callback__for__SetUpdateCallback, 1);       //Захватываем.


    //--------------------------------------------------------
    int status_lua_pcall = lua_pcall(L_global, 2, 0, 0);                  //Реализауем вызов функции SetUpdateCallback с аргументом таблицы, которую поместили на вершину стека 
    //--------------------------------------------------------
    

    if (status_lua_pcall != 0)
    {
        std::cout << "lua_pcall__ERROR" << std::endl;
        return; 
    }
    else
    {
        std::cout << "SetUpdateCallback Success Call" << std::endl;
        
        ckeck_Lua_Stack(L_global);       //Проверяю что находится на данный момент в стеке Lua.

       //Находится следующее:

 ----------------------------------------
Total element is stack:3
type:string:1     //Таблица глобьальный функций
type:table:        //Это как раз запрошенная таблица CreateDataSource
type:nil:            //Ошибка при запросе таблицы CreateDataSource - то есть nil - ошибки нет.
----------------------------------------

        return;
    }


}

function main()
    local class_code = "TQBR" -- Код класса
    local sec_code = "SBER" -- Код бумаги

    ds = CreateDataSource(class_code, sec_code, INTERVAL_M1)
    ds:SetUpdateCallback(function(index)
        local last_price = ds:C(index)
        local volume = ds:V(index) -- Получение объема по свече
        message("Last Price of " .. sec_code .. ": " .. tostring(last_price) .. ", Volume: " .. tostring(volume)) -- Вывод цены и объема по свече
    end)

    while true do
        sleep(1000)
    end
end

function updateCallback(index)
    local last_price = ds:C(index)
    local volume = ds:V(index) -- Получение объема по свече
    message("Last Price of " .. sec_code .. ": " .. tostring(last_price) .. ", Volume: " .. tostring(volume)) -- Вывод цены и объема по свече
end

function main()
    local class_code = "TQBR" -- Код класса
    local sec_code = "SBER" -- Код бумаги

    ds = CreateDataSource(class_code, sec_code, INTERVAL_M1)
    ds:SetUpdateCallback(updateCallback)

    while true do
        sleep(1000)
    end
end