fix: imdroid_mix 暂时关闭雷达瓦片的影响

This commit is contained in:
yarnom 2025-11-06 11:32:29 +08:00
parent 85c7691d0b
commit 9b40bde332

View File

@ -140,24 +140,10 @@ func runForStation(ctx context.Context, db *sql.DB, st stationInfo, issued time.
fused := fuseForecastsWith(matrix, eff) fused := fuseForecastsWith(matrix, eff)
preMask := []float64{fused[0].Rain, fused[1].Rain, fused[2].Rain} preMask := []float64{fused[0].Rain, fused[1].Rain, fused[2].Rain}
maskApplied := false maskApplied := false
// Mask requires radar context // Radar mask disabled by request: skip scanning tiles and altering rain.
if hasMaskCtx(st) { // if hasMaskCtx(st) { ... }
rep, err := checkRadarMask(db, buildMaskContext(st), issued) postMask := preMask
if err == nil && rep.Scanned { log.Printf("预报 %s , mask(disabled)=%v , 融合的结果 %s", formatFloatSlice(preMask), maskApplied, formatFloatSlice(postMask))
// per-hour apply: if hits==0 then zero rain
for h := 0; h < 3; h++ {
if rep.HitsByHour[h] == 0 {
fused[h].Rain = 0
maskApplied = true
}
}
log.Printf("mask t=%s wind=%.1fm/s %.0f° tiles=%d hits=[%d,%d,%d] applied=%v",
issued.Format("2006-01-02 15:04:05"), rep.WindSpeed, rep.WindDir, rep.Tiles,
rep.HitsByHour[0], rep.HitsByHour[1], rep.HitsByHour[2], maskApplied)
}
}
postMask := []float64{fused[0].Rain, fused[1].Rain, fused[2].Rain}
log.Printf("预报 %s , mask=%v , 融合的结果 %s", formatFloatSlice(preMask), maskApplied, formatFloatSlice(postMask))
// Persist fused rows // Persist fused rows
if err := upsertFused(ctx, db, st.ID, issued, fused); err != nil { if err := upsertFused(ctx, db, st.ID, issued, fused); err != nil {