gavindiaz/PolyWeather
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Handle TAF hour rollover in period parsing

Browse Source
This commit is contained in:
2569718930@qq.com
2026-03-24 03:27:50 +08:00
parent 05184cb2ad
commit 29f6542a72
1 changed files with 47 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
web/analysis_service.py
+47 -5
View File
@@ -326,17 +326,59 @@ def _build_taf_signal(
base = issue_dt base = issue_dt
year = base.year year = base.year
month = base.month month = base.month
candidate = datetime(year, month, day, hour, minute, tzinfo=timezone.utc) day_offset = 0
normalized_hour = hour
if normalized_hour >= 24:
day_offset += normalized_hour // 24
normalized_hour = normalized_hour % 24
candidate = datetime(
year,
month,
day,
normalized_hour,
minute,
tzinfo=timezone.utc,
)
if day_offset:
candidate += timedelta(days=day_offset)
if candidate < base - timedelta(days=20): if candidate < base - timedelta(days=20):
if month == 12: if month == 12:
candidate = datetime(year + 1, 1, day, hour, minute, tzinfo=timezone.utc) candidate = datetime(
year + 1,
1,
day,
normalized_hour,
minute,
tzinfo=timezone.utc,
) + timedelta(days=day_offset)
else: else:
candidate = datetime(year, month + 1, day, hour, minute, tzinfo=timezone.utc) candidate = datetime(
year,
month + 1,
day,
normalized_hour,
minute,
tzinfo=timezone.utc,
) + timedelta(days=day_offset)
elif candidate > base + timedelta(days=20): elif candidate > base + timedelta(days=20):
if month == 1: if month == 1:
candidate = datetime(year - 1, 12, day, hour, minute, tzinfo=timezone.utc) candidate = datetime(
year - 1,
12,
day,
normalized_hour,
minute,
tzinfo=timezone.utc,
) + timedelta(days=day_offset)
else: else:
candidate = datetime(year, month - 1, day, hour, minute, tzinfo=timezone.utc) candidate = datetime(
year,
month - 1,
day,
normalized_hour,
minute,
tzinfo=timezone.utc,
) + timedelta(days=day_offset)
return candidate return candidate
def _parse_period(token: str) -> tuple[Optional[datetime], Optional[datetime]]: def _parse_period(token: str) -> tuple[Optional[datetime], Optional[datetime]]: