Domoticz

Code: Select all

local scriptVar = 'readTelegram'

return
{
    on =
    {
        timer =
        {
            'every minute',
        },
        httpResponses =
        {
            scriptVar,
        },
    },

    logging =
    {
        level = domoticz.LOG_DEBUG, -- set to domoticz.LOG_ERROR when all OK
        marker = scriptVar,
    },

    execute = function(dz, item)

        local smartFile = '/tmp/p1Data/p1msg.txt' --  full qualified file name

        local function openURL(delay)
            dz.openURL(
            {
                url = 'http://192.168.178.16/api/v1/telegram',
                callback = scriptVar,
            }).afterSec(delay or 0)
        end

        local function writeFile(fn, str)
            local f = io.open(fn, 'w' )
            f:write(str)
            f:close()
        end

        -- main code
        if item.isTimer  then
            openURL()
        elseif item.isHTTPResponse and item.ok then
            writeFile(smartFile, item.data)
        else
            dz.log('Problem reading the telegram', dz.LOG_ERROR)
            dz.log(tostring(item.data), dz.LOG_DEBUG)
        end
    end
}

Code: Select all

local scriptVar = 'readTelegram'

return
{
    on =
    {
        timer =
        {
            'every minute',
        },
        httpResponses =
        {
            scriptVar,
        },
    },

    logging =
    {
        level = domoticz.LOG_DEBUG,
        marker = scriptVar,
    },

    execute = function(dz, item)

        local debug = _G.logLevel == dz.LOG_DEBUG

        local power = dz.devices('Power') -- change to name of your virtual smart meter (P1 smart Meter (Electric))
        local gas = dz.devices('Gas') -- change to name of your virtual smart meter (Gas)
        local volt = dz.devices('Input Voltage') -- change to name of your virtual voltage device

        local l1 = dz.devices('Usage l1')  -- change to name of your virtual Usage L1 (Usage Electric)
        local l2 = dz.devices('Usage l2')  -- change to name of your virtual Usage L1 (Usage Electric)
        local l3 = dz.devices('Usage l3')  -- change to name of your virtual Usage L1 (Usage Electric)

        local ampere1Phase = dz.devices('amperageTotal') -- change to name of your virtual amperage device (1 phase)
        local ampere3Phases = dz.devices('amperageCombined') -- change to name of your virtual amperage device (3 phases)
        local amperage1, amperage2, amperage3 = 0, 0, 0

        local delivered = dz.devices('Delivered') -- change to name of your virtual counter 
        local received = dz.devices('Received') -- change to name of your virtual counter

        local frequency = 6 -- every 60 / frequency seconds
        local P1Reference =
        {
             l1Power = '22.7.0',
             tariff = '96.14.0',
             usage2 = '1.8.2',
             usage1 = '1.8.1',
             returned1 = '2.8.1',
             returned2 = '2.8.2',
             powerReceived = '2.7.0',
             gas = '24.2.1',
             powerUsageL1 = '21.7.0',
             powerUsageL2 = '41.7.0',
             powerUsageL3 = '61.7.0',
             powerDelivery = '1.7.0',
             amperageL1 = '31.7.0',
             amperageL2 = '51.7.0',
             amperageL3 = '71.7.0',
             voltageL1 = '32.7.0',
             voltageL2 = '52.7.0',
             voltageL3 = '72.7.0',
        }

        local function openURL(delay)
            dz.openURL(
            {
                url = 'http://192.168.178.16/api/v1/telegram',
                callback = scriptVar,
            }).afterSec(delay or 0)
        end

        function table.invert(t)
           local it = {}
           for k,v in pairs(t) do
             it[v]=k
           end
           return it
        end

        local function readResult( telegram, it )

            local function crLines(s)
                return s:gsub('\r\n?', '\n'):gmatch('(.-)\n') -- Normalize CR/LF
            end

            local lines = {}
            for line in crLines(telegram) do
                if line:find(':') then
                    key = it[line:match(':(%d+.%d+.%d+)')]
                    if key then
                        lines[key] = math.floor((line:match('%b()%s*%c*$'):match('%d+%.*%d*') or -1) * 1000)
                    end
                end
            end

            if debug then dz.utils.dumpTable(lines) end

            return lines

        end

        local function updateDevices(t)
            power.updateP1  (
                                t.usage1 or 0,
                                t.usage2  or 0,
                                t.returned1  or 0,
                                t.returned2  or 0,
                                t.powerUsageL1 + t.powerUsageL2 + t.powerUsageL3,
                                t.powerDelivery  or 0
                            )

            if t.gas then gas.updateGas(t.gas) end

            if t.powerUsageL1 then
                l1.updateEnergy(t.powerUsageL1)
                amperage1 = dz.utils.round( t.powerUsageL1 / t.voltageL1 , 2)
            end

            if t.powerUsageL2 then
                l2.updateEnergy(t.powerUsageL2)
                amperage2 = dz.utils.round( t.powerUsageL2 / t.voltageL2 , 2)
            end

            if t.powerUsageL3 then
                l3.updateEnergy(t.powerUsageL3 )
                amperage3 = dz.utils.round( t.powerUsageL3 / t.voltageL3 , 2)
            end

            ampere1Phase.updateCurrent( dz.utils.round( amperage1 + amperage2 + amperage3 , 2 ) )
            ampere3Phases.updateCurrent( amperage1, amperage2, amperage3 )

            volt.updateVoltage( dz.utils.round( t.voltageL1 / 1000 ,1 ) )

            delivered.updateCounter(t.powerDelivery or 0) 
            received.updateCounter(t.powerReceived or 0) 
        end

        local function showResults(t, it)
            if not(debug) then return end
            for code, value in pairs(t) do
                if it[code] then
                    dz.log(it[code] .. ' ==>> ' .. value, dz.LOG_DEBUG)
                end
            end
        end

        -- main code
        if item.isTimer then
            openURL()

            local interval = math.floor(60/frequency)
            for secondsDelay = interval, (60 - interval), interval do
                openURL(secondsDelay)
            end
        elseif item.isHTTPResponse and item.ok then
            local invertedTable = table.invert(P1Reference)

            local actual = readResult(item.data, invertedTable)
            showResults(actual, invertedTable)
            updateDevices(actual, invertedTable)
        else
            dz.log('Problem reading the telegram', dz.LOG_ERROR)
            dz.log(tostring(item.data), dz.LOG_DEBUG)
        end
    end
}

Code: Select all

url = "dz:8084/json.htm?type=command&param=getversion"