wn/energyanalysis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

total_energy

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2021-05-26 14:43:04 +02:00
parent 9164ff3e12
commit 1c5fa54c8f
1 changed files with 100 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

126
function_total_energy_by_day_and_device.sql
View File

@ -1,36 +1,110 @@
create or replace function total_energy_by_day_and_device(p_day date, p_device varchar) create table rt_totalizer_result (
returns double precision day date,
device text,
total double precision
);
select total_energy_by_day_and_device('2021-05-01','2021-05-10','Computer');
create or replace function total_energy_by_day_and_device(p_start_day date, p_end_say date, p_device varchar)
returns setof rt_totalizer_result
language plpgsql language plpgsql
as $$ as $$
declare declare
v_firstEnergy double precision; v_firstEnergy double precision;
v_lastEnergy double precision; v_lastEnergy double precision;
v_total double precision; v_total double precision;
v_day date;
v_result rt_totalizer_result%rowtype;
begin begin
select energy v_day := p_start_day;
into v_lastEnergy loop
from power_measurement_t select energy
where time = ( into v_lastEnergy
select max(time) from power_measurement_t
from power_measurement_t where time = (
where time between p_day + time '00:00' and p_day + time '00:00' + interval '24h' and select max(time)
deviceid = p_device and from power_measurement_t
status = 'Ok' where time between v_day + time '00:00' and v_day + time '00:00' + interval '24h' and
) and deviceid = p_device and
deviceid = p_device; status = 'Ok'
select energy ) and
into v_firstEnergy deviceid = p_device;
from power_measurement_t select energy
where time = ( into v_firstEnergy
select min(time) from power_measurement_t
from power_measurement_t where time = (
where time between p_day + time '00:00' and p_day + time '00:00' + interval '24h' and select min(time)
deviceid = p_device and from power_measurement_t
status = 'Ok' where time between v_day + time '00:00' and v_day + time '00:00' + interval '24h' and
) and deviceid = p_device and
deviceid = p_device; status = 'Ok'
v_total := v_lastEnergy - v_firstEnergy; ) and
return v_total; deviceid = p_device;
v_total := v_lastEnergy - v_firstEnergy;
v_result.day := v_day;
v_result.device := p_device;
v_result.total := v_total;
return next v_result;
v_day := v_day + interval '1 day';
exit when v_day > p_end_say;
end loop;
return;
end;
$$;
select total_energy('2021-05-01','2021-05-10');
create or replace function total_energy(p_start_day date, p_end_say date)
returns setof rt_totalizer_result
language plpgsql
as $$
declare
v_firstEnergy double precision;
v_lastEnergy double precision;
v_total double precision;
v_day date;
v_deviceid text;
v_result rt_totalizer_result%rowtype;
begin
for v_deviceid in select distinct deviceid from power_measurement_t loop
v_day := p_start_day;
loop
select energy
into v_lastEnergy
from power_measurement_t
where time = (
select max(time)
from power_measurement_t
where time between v_day + time '00:00' and v_day + time '00:00' + interval '24h' and
deviceid = v_deviceid and
status = 'Ok'
) and
deviceid = v_deviceid;
select energy
into v_firstEnergy
from power_measurement_t
where time = (
select min(time)
from power_measurement_t
where time between v_day + time '00:00' and v_day + time '00:00' + interval '24h' and
deviceid = v_deviceid and
status = 'Ok'
) and
deviceid = v_deviceid;
v_total := v_lastEnergy - v_firstEnergy;
v_result.day := v_day;
v_result.device := v_deviceid;
v_result.total := v_total;
return next v_result;
v_day := v_day + interval '1 day';
exit when v_day > p_end_say;
end loop;
end loop;
return;
end; end;
$$; $$;