import "date"
import "experimental/aggregate"
nightTariff = 
  from(bucket: "homedata")
    |> range(start: date.truncate(t: now(), unit: 1mo), stop: v.timeRangeStop)
    |> filter(fn: (r) => r._measurement == "apcupsd")
    |> filter(fn: (r) => r._field == "load_percent")
    |> filter(fn: (r) => r["status"] == "ONLINE")
    |> hourSelection(start: 20, stop: 3)
    |> map(fn: (r) => ({r with _value: float(v: r._value) * 5.40 / 1000.0 * 3.56 / 120.0}))

dayTariff = 
  from(bucket: "homedata")
    |> range(start: date.truncate(t: now(), unit: 1mo), stop: v.timeRangeStop)
    |> filter(fn: (r) => r._measurement == "apcupsd")
    |> filter(fn: (r) => r._field == "load_percent")
    |> filter(fn: (r) => r["status"] == "ONLINE")
    |> hourSelection(start: 4, stop: 19)
    |> map(fn: (r) => ({r with _value: float(v: r._value) * 5.40 / 1000.0 * 6.51 / 120.0}))

union(tables: [nightTariff, dayTariff])
  |> sort(columns: ["_time"], desc: false)
  |> cumulativeSum(columns: ["_value"])
  |> timedMovingAverage(every: 10m, period: 20m)