From 772636df63f3fad1f5c30b623ea1a5b003495353 Mon Sep 17 00:00:00 2001
From: Claude <noreply@anthropic.com>
Date: Mon, 24 Aug 2026 01:00:16 +0000
Subject: [PATCH] =?UTF-8?q?=E8=BF=91=E5=82=8D=E3=83=90=E3=82=B9=E5=81=9C?=
 =?UTF-8?q?=E3=81=AE=E7=B5=9E=E3=82=8A=E8=BE=BC=E3=81=BF=E3=82=92=E4=BB=B6?=
 =?UTF-8?q?=E6=95=B0=E3=81=AE=E4=B8=8A=E9=99=90=E3=82=88=E3=82=8A=E5=85=88?=
 =?UTF-8?q?=E3=81=AB=E8=A1=8C=E3=81=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

get_bus_stops_near_stations は半径以内のバス停を距離順に limit_per_station
件へ切り詰めてから、路線を引けるか (かつ路線が有効か) を見ていた。移行前の
SQL が LATERAL 側で LIMIT を掛けてから lines を JOIN していたのをそのまま
写したものだが、路線を引けないバス停や廃止路線のバス停が上限の枠を埋めると、
その分だけ採用件数が減る。

先に路線で絞り、有効なものが limit_per_station 件そろった時点で打ち切る。
座標の順・距離順という並びは変わらない。

あわせて index::within_radius と docs/nearby-bus-stops.md の、絞り込みと
上限の順序を述べた記述を実装に合わせた。
---
 docs/nearby-bus-stops.md |  2 +-
 src/index.rs             |  2 +-
 src/repository.rs        | 30 ++++++++++++++----------------
 3 files changed, 16 insertions(+), 18 deletions(-)

diff --git a/docs/nearby-bus-stops.md b/docs/nearby-bus-stops.md
index b99c87ae..6f370751 100644
--- a/docs/nearby-bus-stops.md
+++ b/docs/nearby-bus-stops.md
@@ -125,5 +125,5 @@ async fn get_nearby_bus_lines(&self, ref_lat: f64, ref_lon: f64) -> Result<Vec<L
 
 ## 注意事項
 
-- バス路線検索は最大50件のバス停候補を取得し、その中から300m以内のものをフィルタリング
+- バス路線検索は300m以内のバス停を近い順に見て、有効な路線を持つものを最大50件採用
 - 鉄道駅の `lines` 配列に近傍バス路線が追加されるのは、未指定または `transportType: RailAndBus` の場合
diff --git a/src/index.rs b/src/index.rs
index 3d1f0a34..fad35725 100644
--- a/src/index.rs
+++ b/src/index.rs
@@ -735,7 +735,7 @@ fn by_distance_then_station_cd(
 /// 「上位 N 件」ではなく半径で切る用途 (駅の近傍バス停) 向け。最寄り N 件を
 /// 作ってから半径で捨てると、採用されない駅の分まで組み立てることになる。
 /// `nearest` と違い、路線を引けるかどうかは見ない (呼び出し側が
-/// 件数を確定させてから路線で絞るため)。
+/// 路線で絞ってから件数を確定させるため)。
 pub fn within_radius(
     lat: f64,
     lon: f64,
diff --git a/src/repository.rs b/src/repository.rs
index 0b04610c..e9f21555 100644
--- a/src/repository.rs
+++ b/src/repository.rs
@@ -322,8 +322,9 @@ impl StationRepository for MemStationRepository {
             .collect())
     }
 
-    /// 各座標につき半径以内のバス停を近い順に N 件取り、そのあと有効な路線を
-    /// 持つものだけに絞る。先に路線で絞ると件数が変わるため、この順序を保つ。
+    /// 各座標につき半径以内のバス停を近い順に見て、有効な路線を持つものだけを
+    /// N 件まで採る。上限を先に掛けると、路線を引けないバス停や廃止路線の
+    /// バス停が枠を埋めたぶんだけ件数が減るため、絞り込みを先に行う。
     /// 並びは指定された座標の順、その中では距離順。
     async fn get_bus_stops_near_stations(
         &self,
@@ -337,20 +338,17 @@ impl StationRepository for MemStationRepository {
         let mut out = Vec::new();
 
         for &(source_g_cd, lat, lon) in coords {
-            let mut hits = index::within_radius(lat, lon, radius_km, want);
-            hits.truncate(limit);
-            for (record, _distance) in hits {
-                let Some(line) = index::line_by_cd(record.line_cd) else {
-                    continue;
-                };
-                if line.e_status != 0 {
-                    continue;
-                }
-                let mut station = record.to_entity(Some(line));
-                station.line_group_cd = index::first_line_group_cd(record.station_cd);
-                station.has_train_types = station.line_group_cd.is_some();
-                out.push((source_g_cd, station));
-            }
+            let hits = index::within_radius(lat, lon, radius_km, want)
+                .into_iter()
+                .filter_map(|(record, _distance)| {
+                    let line = index::line_by_cd(record.line_cd).filter(|l| l.e_status == 0)?;
+                    let mut station = record.to_entity(Some(line));
+                    station.line_group_cd = index::first_line_group_cd(record.station_cd);
+                    station.has_train_types = station.line_group_cd.is_some();
+                    Some((source_g_cd, station))
+                })
+                .take(limit);
+            out.extend(hits);
         }
         Ok(out)
     }