diff --git a/internal/fusion/fusion.go b/internal/fusion/fusion.go index 9068689..51d1982 100644 --- a/internal/fusion/fusion.go +++ b/internal/fusion/fusion.go @@ -140,24 +140,10 @@ func runForStation(ctx context.Context, db *sql.DB, st stationInfo, issued time. fused := fuseForecastsWith(matrix, eff) preMask := []float64{fused[0].Rain, fused[1].Rain, fused[2].Rain} maskApplied := false - // Mask requires radar context - if hasMaskCtx(st) { - rep, err := checkRadarMask(db, buildMaskContext(st), issued) - if err == nil && rep.Scanned { - // 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)) + // Radar mask disabled by request: skip scanning tiles and altering rain. + // if hasMaskCtx(st) { ... } + postMask := preMask + log.Printf("预报 %s , mask(disabled)=%v , 融合的结果 %s", formatFloatSlice(preMask), maskApplied, formatFloatSlice(postMask)) // Persist fused rows if err := upsertFused(ctx, db, st.ID, issued, fused); err != nil {