GTFSを用いた停車駅更新検出

.env

@@ -2,3 +2,5 @@
 DATABASE_URL=postgresql://stationapi:stationapi@localhost/stationapi
 DISABLE_BUS_FEATURE=false
 DISABLE_GRPC_WEB=false
+ODPT_API_KEY=
+ENABLE_RAIL_GTFS=true

data/create_table.sql

@@ -643,7 +643,7 @@ ALTER TABLE public.gtfs_agencies OWNER TO stationapi;
 
 --
 -- Name: gtfs_routes; Type: TABLE; Schema: public
--- GTFS route information (bus lines)
+-- GTFS route information (bus lines and rail lines from GTFS sources)
 --
 
 CREATE UNLOGGED TABLE public.gtfs_routes (
@@ -656,18 +656,23 @@ CREATE UNLOGGED TABLE public.gtfs_routes (
     route_long_name_zh TEXT,
     route_long_name_ko TEXT,
     route_desc TEXT,
-    route_type INTEGER NOT NULL DEFAULT 3,  -- 3 = Bus
+    route_type INTEGER NOT NULL DEFAULT 3,  -- 3 = Bus, 1 = Subway, 2 = Rail
     route_url TEXT,
     route_color VARCHAR(6),
     route_text_color VARCHAR(6),
     route_sort_order INTEGER,
-    line_cd INTEGER REFERENCES public.lines(line_cd)
+    line_cd INTEGER REFERENCES public.lines(line_cd),
+    transport_type INTEGER DEFAULT 1,  -- 1: Bus, 2: Rail (GTFS)
+    company_cd INTEGER REFERENCES public.companies(company_cd),
+    source_id VARCHAR(50)  -- GTFS source identifier (e.g., "toei_bus", "tokyo_metro")
 );
 
 ALTER TABLE public.gtfs_routes OWNER TO stationapi;
 
 CREATE INDEX idx_gtfs_routes_agency_id ON public.gtfs_routes USING btree (agency_id);
 CREATE INDEX idx_gtfs_routes_line_cd ON public.gtfs_routes USING btree (line_cd);
+CREATE INDEX idx_gtfs_routes_transport_type ON public.gtfs_routes USING btree (transport_type);
+CREATE INDEX idx_gtfs_routes_source_id ON public.gtfs_routes USING btree (source_id);
 
 --
 -- Name: gtfs_stops; Type: TABLE; Schema: public
@@ -856,3 +861,62 @@ ALTER TABLE public.gtfs_feed_info OWNER TO stationapi;
 -- ============================================================
 -- End of GTFS Bus Integration Schema
 -- ============================================================
+
+-- ============================================================
+-- Stop Pattern Detection Schema
+-- For detecting train type stop pattern changes from ODPT API
+-- ============================================================
+
+--
+-- Name: stop_pattern_snapshots; Type: TABLE; Schema: public
+-- Snapshots of stop patterns extracted from ODPT TrainTimetable
+--
+
+CREATE TABLE public.stop_pattern_snapshots (
+    id SERIAL PRIMARY KEY,
+    operator_id VARCHAR(100) NOT NULL,     -- odpt.Operator:TokyoMetro
+    railway_id VARCHAR(100) NOT NULL,      -- odpt.Railway:TokyoMetro.Marunouchi
+    train_type_id VARCHAR(100) NOT NULL,   -- odpt.TrainType:TokyoMetro.Local
+    train_type_name VARCHAR(100),          -- 各停
+    station_ids TEXT[] NOT NULL,           -- Array of station IDs
+    station_names TEXT[],                  -- Array of station names (for reference)
+    captured_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    captured_date DATE DEFAULT CURRENT_DATE,
+    UNIQUE(railway_id, train_type_id, captured_date)
+);
+
+ALTER TABLE public.stop_pattern_snapshots OWNER TO stationapi;
+
+CREATE INDEX idx_stop_pattern_snapshots_railway ON public.stop_pattern_snapshots USING btree (railway_id, train_type_id);
+CREATE INDEX idx_stop_pattern_snapshots_operator ON public.stop_pattern_snapshots USING btree (operator_id);
+CREATE INDEX idx_stop_pattern_snapshots_captured ON public.stop_pattern_snapshots USING btree (captured_at DESC);
+
+--
+-- Name: stop_pattern_changes; Type: TABLE; Schema: public
+-- Log of detected stop pattern changes
+--
+
+CREATE TABLE public.stop_pattern_changes (
+    id SERIAL PRIMARY KEY,
+    operator_id VARCHAR(100) NOT NULL,
+    railway_id VARCHAR(100) NOT NULL,
+    railway_name VARCHAR(100),             -- 丸ノ内線
+    train_type_id VARCHAR(100) NOT NULL,
+    train_type_name VARCHAR(100),          -- 各停
+    change_type VARCHAR(20) NOT NULL,      -- 'added' or 'removed'
+    station_id VARCHAR(100) NOT NULL,
+    station_name VARCHAR(100),
+    detected_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    acknowledged BOOLEAN DEFAULT FALSE,
+    acknowledged_at TIMESTAMP
+);
+
+ALTER TABLE public.stop_pattern_changes OWNER TO stationapi;
+
+CREATE INDEX idx_stop_pattern_changes_detected ON public.stop_pattern_changes USING btree (detected_at DESC);
+CREATE INDEX idx_stop_pattern_changes_unack ON public.stop_pattern_changes (acknowledged) WHERE acknowledged = FALSE;
+CREATE INDEX idx_stop_pattern_changes_railway ON public.stop_pattern_changes USING btree (railway_id, train_type_id);
+
+-- ============================================================
+-- End of Stop Pattern Detection Schema
+-- ============================================================