Von der Erzeugung
bis zur Anwendung.

-- Feiertage + Ferien + Kontexte CREATE TABLE public.atlas_calendar ( id uuid PRIMARY KEY DEFAULT gen_random_uuid(), uid text NOT NULL, date date NOT NULL, event_type text NOT NULL, -- 'feiertag','ferien_start','ferien_end','arbeitstag','heizperiode_start' description text, occupancy_expected text DEFAULT 'unknown', -- 'absent','partial','present' custom boolean DEFAULT false, created_at timestamptz DEFAULT now(), UNIQUE(uid, date) ); CREATE INDEX atlas_calendar_uid_date ON public.atlas_calendar(uid, date); -- Wetter-Cache (optional) CREATE TABLE public.atlas_weather_cache ( id uuid PRIMARY KEY DEFAULT gen_random_uuid(), uid text NOT NULL, date date NOT NULL, hour int NOT NULL, cloud_cover_percent int, temperature_c numeric, wind_speed_ms numeric, fetched_at timestamptz DEFAULT now(), UNIQUE(uid, date, hour) );

import { serve } from "https://deno.land/std@0.208.0/http/server.ts"; const SUPABASE_URL = Deno.env.get("SUPABASE_URL"); const SUPABASE_SERVICE_ROLE = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY"); const MYPV_API_KEY = Deno.env.get("MYPV_API_KEY"); const MYPV_DEVICE_ID = Deno.env.get("MYPV_DEVICE_ID"); serve(async (req) => { if (req.method !== "POST") return new Response("Method not allowed", { status: 405 }); const { uid = "5341475905ea7789" } = await req.json().catch(() => ({})); const today = new Date().toISOString().split("T")[0]; // 1. Kalender-Kontext const calRes = await fetch(`${SUPABASE_URL}/rest/v1/atlas_calendar?uid=eq.${uid}&date=eq.${today}`, { headers: { Authorization: `Bearer ${SUPABASE_SERVICE_ROLE}` } }); const calData = await calRes.json(); const calendar = calData.length > 0 ? calData[0] : null; // 2. Wetter-Prognose (OpenMeteo) const wRes = await fetch(`https://api.open-meteo.com/v1/forecast?latitude=48.117&longitude=15.817&hourly=cloud_cover,temperature_2m&timezone=Europe/Vienna&forecast_days=1`); const wData = await wRes.json(); const weather = { cloud_cover_percent: wData.hourly.cloud_cover[new Date().getHours()] || 50 }; // 3. Aktueller Messwert const rRes = await fetch(`${SUPABASE_URL}/rest/v1/atlas_readings?uid=eq.${uid}&order=ts.desc&limit=1`, { headers: { Authorization: `Bearer ${SUPABASE_SERVICE_ROLE}` } }); const rData = await rRes.json(); const reading = rData.length > 0 ? rData[0] : null; if (!reading) return new Response(JSON.stringify({ error: "No readings" }), { status: 400 }); // 4. Intelligente Schwellwert-Berechnung let heaterThreshold = 2000; if (calendar?.occupancy_expected === "absent") heaterThreshold = 5000; else if (calendar?.occupancy_expected === "present") heaterThreshold = 1500; if ((weather.cloud_cover_percent || 50) > 80) heaterThreshold = Math.max(heaterThreshold - 500, 1000); else if ((weather.cloud_cover_percent || 50) < 20) heaterThreshold += 500; // 5. Steuerung: Überschuss = negative Netto-Leistung const excess = -reading.instant_power_net; const action = excess >= heaterThreshold ? "on" : "off"; const mypv = await fetch(`https://api.my-pv.com/v1/devices/${MYPV_DEVICE_ID}/control`, { method: "POST", headers: { Authorization: `Bearer ${MYPV_API_KEY}`, "Content-Type": "application/json" }, body: JSON.stringify(action === "on" ? { power: Math.max(excess, 3000) } : { power: 0 }), }); return new Response(JSON.stringify({ uid, timestamp: new Date().toISOString(), excess_kw: (excess / 1000).toFixed(2), calendar_context: calendar?.event_type || "normal_day", weather_cloud_cover: weather.cloud_cover_percent, threshold_adjusted_w: heaterThreshold, action }), { headers: { "Content-Type": "application/json" } }); });

# Secrets (Supabase CLI) supabase secrets set MYPV_API_KEY="<dein-key>" supabase secrets set MYPV_DEVICE_ID="<device-id>" -- Cron-Trigger (alle 2 Minuten) SELECT cron.schedule('atlas-control-2min', '*/2 * * * *', $$ SELECT net.http_post( 'https://henfrhwlkqvjxxdzhqtv.supabase.co/functions/v1/atlas-control', '{"uid":"5341475905ea7789"}', headers := '{"Authorization":"Bearer <SERVICE_ROLE_KEY>"}'::jsonb ); $$);