Merge branch 'main' into all_in_one

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

pyproject.toml

@@ -1,5 +1,5 @@
 [project]
 name = "weather2oag"
-version = "1.1.1"
+version = "1.1.0"
 description = "Monatlicher Wetterbericht der Sternwarte Welzheim"
 requires-python = ">=3.12"

weather_report.py

@@ -4,7 +4,7 @@
 import os
 import smtplib
 import tempfile
-
+from collections import defaultdict
 from datetime import datetime, timedelta, timezone
 from email.mime.image import MIMEImage
 from email.mime.multipart import MIMEMultipart
@@ -49,7 +49,7 @@ def last_month_range() -> tuple[datetime, datetime, str]:
     today = datetime.now(timezone.utc)
     first_of_this = today.replace(day=1, hour=0, minute=0, second=0, microsecond=0)
     start = (first_of_this - timedelta(days=1)).replace(day=1, hour=0, minute=0, second=0, microsecond=0)
-    end = first_of_this + timedelta(days=1)  # inkl. 1. Folgemonat
+    end = first_of_this  # exklusives Ende: < Juni 1 = komplett Mai
     label = f"{MONTHS_DE[start.month - 1]} {start.year}"
     return start, end, label
 
@@ -85,19 +85,32 @@ def _data_temp_hourly(start: datetime, end: datetime):
 
 
 def _data_rain_daily(start: datetime, end: datetime):
-    today = datetime.now(timezone.utc).replace(hour=0, minute=0, second=0, microsecond=0)
+    # +1 Tag extra damit der Abschlusswert des letzten Tages (kum. Zähler) enthalten ist
-    days = min((today - start).days + 2, 365)
+    data = fetch("/weather/range", {
-    data = fetch("/weather/rain-daily", {"days": days})
+        "start": start.isoformat(),
-    pairs = []
+        "end": (end + timedelta(days=1)).isoformat(),
+        "limit": 50000,
+    })
+    by_day: dict[str, list[float]] = defaultdict(list)
     for d in data:
-        day_dt = parse_dt(d["date"]).replace(hour=0, minute=0, second=0, microsecond=0)
+        if d.get("rain") is not None:
-        if start <= day_dt < end:
+            by_day[parse_dt(d["datetime"]).strftime("%Y-%m-%d")].append(d["rain"])
-            pairs.append((day_dt, round(d["total_rain"], 1)))
+
-    pairs.sort()
+    dates, rain = [], []
-    if not pairs:
+    for day_key in sorted(by_day):
-        return [], []
+        day_dt = datetime.fromisoformat(day_key).replace(tzinfo=timezone.utc)
-    dates, rain = zip(*pairs)
+        if day_dt >= end:
-    return list(dates), list(rain)
+            break
+        vals = list(by_day[day_key])
+        next_key = (day_dt + timedelta(days=1)).strftime("%Y-%m-%d")
+        if next_key in by_day:
+            vals.append(by_day[next_key][0])
+        daily = max(vals) - min(vals)
+        if daily < 0:
+            daily = max(vals)
+        dates.append(day_dt)
+        rain.append(round(daily, 1))
+    return dates, rain
 
 
 def create_combined_chart(start: datetime, end: datetime, label: str) -> bytes: