Domoticz

Code: Select all

-- Define the period for the moving average (e.g., 10 minutes)
local period = 10

-- Store the last 'period' values of water flow in an array
local flow_values = {}

-- Function to calculate the moving average
function calculate_moving_average(new_flow)
    table.insert(flow_values, new_flow)
    if #flow_values > period then
        table.remove(flow_values, 1)
    end

    local sum = 0
    for _, flow in ipairs(flow_values) do
        sum = sum + flow
    end

    local moving_average = sum / #flow_values
    return moving_average
end

-- Example of using the function
local current_flow = 5 -- Replace this with the actual instantaneous water flow value
local moving_average = calculate_moving_average(current_flow)

print("Current flow: " .. current_flow)
print("Moving average: " .. moving_average)

-- Check for leak
if moving_average == current_flow and current_flow ~= 0 then
    print("Leak suspected!")
else
    print("No leak.")
end

Code: Select all

return {
	on = {
		timer = {'every 1 minutes'},
		devices = {'Waterflow'}
	},
	logging =
    {
        level = domoticz.LOG_DEBUG,
        marker = 'Leak detection',
    },
	data =
    {
        Waterflow_History = { history = true, maxMinutes = 5},
    },
	
	execute = function(domoticz)
        local Waterflow = domoticz.devices('Waterflow').flow
                -- add new data waterflow
        domoticz.data.Waterflow_History.add(Waterflow)
       		-- average for waterflow
        local Moving_avg_Flow = domoticz.data.Waterflow_History.avg()
        domoticz.log('Water flow avg  ' .. Moving_avg_Flow, domoticz.LOG_INFO)
        if Moving_avg_Flow == Waterflow and Waterflow > 0 then
            domoticz.devices('Water_Leak').switchOn().checkFirst()
               
            end
        if Moving_avg_Flow ~= Waterflow or Waterflow == 0 then
            domoticz.devices('Water_Leak').switchOff().checkFirst()
            end
end
}