GTFSのDBマイグレーション

cmd/atlas-loader/main.go

@@ -12,8 +12,11 @@ import (
 func main() {
 	stmts, err := gormschema.New("postgres").Load(
 		&model.Announcement{},
+		&model.Calendar{},
+		&model.CalendarDate{},
 		&model.CancelledClass{},
 		&model.CourseRegistration{},
+		&model.FareRule{},
 		&model.FCMToken{},
 		&model.Faculty{},
 		&model.FacultyRoom{},
@@ -22,13 +25,17 @@ func main() {
 		&model.NotificationTargetUser{},
 		&model.Room{},
 		&model.RoomChange{},
+		&model.Route{},
+		&model.Stop{},
+		&model.StopTime{},
 		&model.Subject{},
 		&model.SubjectEligibleAttribute{},
 		&model.SubjectFaculty{},
 		&model.SubjectRequirement{},
 		&model.Syllabus{},
 		&model.TimetableItem{},
 		&model.TimetableItemRoom{},
+		&model.Trip{},
 		&model.User{},
 	)
 	if err != nil {

internal/shared/model/calendar.go

@@ -0,0 +1,16 @@
+package model
+
+type Calendar struct {
+	Common
+
+	ServiceID string `gorm:"not null;uniqueIndex"`
+	Monday    int    `gorm:"not null"`
+	Tuesday   int    `gorm:"not null"`
+	Wednesday int    `gorm:"not null"`
+	Thursday  int    `gorm:"not null"`
+	Friday    int    `gorm:"not null"`
+	Saturday  int    `gorm:"not null"`
+	Sunday    int    `gorm:"not null"`
+	StartDate string `gorm:"not null"`
+	EndDate   string `gorm:"not null"`
+}

internal/shared/model/calendar_date.go

@@ -0,0 +1,10 @@
+package model
+
+type CalendarDate struct {
+	Common
+
+	ServiceID     string    `gorm:"not null;index"`
+	Calendar      *Calendar `gorm:"belongsTo;foreignKey:ServiceID;references:ServiceID;constraint:OnUpdate:CASCADE,OnDelete:CASCADE"`
+	Date          string    `gorm:"not null;index"`
+	ExceptionType int       `gorm:"not null"`
+}

internal/shared/model/fare_rule.go

@@ -0,0 +1,13 @@
+package model
+
+type FareRule struct {
+	Common
+
+	RouteID       string  `gorm:"not null;index"`
+	Route         *Route  `gorm:"belongsTo;foreignKey:RouteID;references:RouteID;constraint:OnUpdate:CASCADE,OnDelete:CASCADE"`
+	OriginID      string  `gorm:"not null;index"`
+	Origin        *Stop   `gorm:"belongsTo;foreignKey:OriginID;references:StopID;constraint:OnUpdate:CASCADE,OnDelete:CASCADE"`
+	DestinationID string  `gorm:"not null;index"`
+	Destination   *Stop   `gorm:"belongsTo;foreignKey:DestinationID;references:StopID;constraint:OnUpdate:CASCADE,OnDelete:CASCADE"`
+	Price         float64 `gorm:"not null"`
+}

internal/shared/model/route.go

@@ -0,0 +1,8 @@
+package model
+
+type Route struct {
+	Common
+
+	RouteID        string `gorm:"not null;uniqueIndex"`
+	RouteShortName string `gorm:"not null"`
+}

internal/shared/model/stop.go

@@ -0,0 +1,8 @@
+package model
+
+type Stop struct {
+	Common
+
+	StopID   string `gorm:"not null;uniqueIndex"`
+	StopName string `gorm:"not null"`
+}

internal/shared/model/stop_time.go

@@ -0,0 +1,13 @@
+package model
+
+type StopTime struct {
+	Common
+
+	TripID        string `gorm:"not null;index"`
+	Trip          *Trip  `gorm:"belongsTo;foreignKey:TripID;references:TripID;constraint:OnUpdate:CASCADE,OnDelete:CASCADE"`
+	ArrivalTime   string `gorm:"not null"`
+	DepartureTime string `gorm:"not null"`
+	StopID        string `gorm:"not null;index"`
+	Stop          *Stop  `gorm:"belongsTo;foreignKey:StopID;references:StopID;constraint:OnUpdate:CASCADE,OnDelete:CASCADE"`
+	StopSequence  int    `gorm:"not null"`
+}

internal/shared/model/trip.go

@@ -0,0 +1,12 @@
+package model
+
+type Trip struct {
+	Common
+
+	TripID      string    `gorm:"not null;uniqueIndex"`
+	RouteID     string    `gorm:"not null;index"`
+	Route       *Route    `gorm:"belongsTo;foreignKey:RouteID;references:RouteID;constraint:OnUpdate:CASCADE,OnDelete:CASCADE"`
+	ServiceID   string    `gorm:"not null;index"`
+	Calendar    *Calendar `gorm:"belongsTo;foreignKey:ServiceID;references:ServiceID;constraint:OnUpdate:CASCADE,OnDelete:CASCADE"`
+	DirectionID int       `gorm:"not null"`
+}

migrations/20260820171158_add_gtfs.sql

@@ -0,0 +1,113 @@
+-- Create "calendars" table
+CREATE TABLE "public"."calendars" (
+  "id" uuid NOT NULL DEFAULT gen_random_uuid(),
+  "created_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "updated_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "service_id" text NOT NULL,
+  "monday" bigint NOT NULL,
+  "tuesday" bigint NOT NULL,
+  "wednesday" bigint NOT NULL,
+  "thursday" bigint NOT NULL,
+  "friday" bigint NOT NULL,
+  "saturday" bigint NOT NULL,
+  "sunday" bigint NOT NULL,
+  "start_date" text NOT NULL,
+  "end_date" text NOT NULL,
+  PRIMARY KEY ("id")
+);
+-- Create index "idx_calendars_service_id" to table: "calendars"
+CREATE UNIQUE INDEX "idx_calendars_service_id" ON "public"."calendars" ("service_id");
+-- Create "calendar_dates" table
+CREATE TABLE "public"."calendar_dates" (
+  "id" uuid NOT NULL DEFAULT gen_random_uuid(),
+  "created_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "updated_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "service_id" text NOT NULL,
+  "date" text NOT NULL,
+  "exception_type" bigint NOT NULL,
+  PRIMARY KEY ("id"),
+  CONSTRAINT "fk_calendar_dates_calendar" FOREIGN KEY ("service_id") REFERENCES "public"."calendars" ("service_id") ON UPDATE CASCADE ON DELETE CASCADE
+);
+-- Create index "idx_calendar_dates_date" to table: "calendar_dates"
+CREATE INDEX "idx_calendar_dates_date" ON "public"."calendar_dates" ("date");
+-- Create index "idx_calendar_dates_service_id" to table: "calendar_dates"
+CREATE INDEX "idx_calendar_dates_service_id" ON "public"."calendar_dates" ("service_id");
+-- Create "stops" table
+CREATE TABLE "public"."stops" (
+  "id" uuid NOT NULL DEFAULT gen_random_uuid(),
+  "created_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "updated_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "stop_id" text NOT NULL,
+  "stop_name" text NOT NULL,
+  PRIMARY KEY ("id")
+);
+-- Create index "idx_stops_stop_id" to table: "stops"
+CREATE UNIQUE INDEX "idx_stops_stop_id" ON "public"."stops" ("stop_id");
+-- Create "routes" table
+CREATE TABLE "public"."routes" (
+  "id" uuid NOT NULL DEFAULT gen_random_uuid(),
+  "created_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "updated_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "route_id" text NOT NULL,
+  "route_short_name" text NOT NULL,
+  PRIMARY KEY ("id")
+);
+-- Create index "idx_routes_route_id" to table: "routes"
+CREATE UNIQUE INDEX "idx_routes_route_id" ON "public"."routes" ("route_id");
+-- Create "fare_rules" table
+CREATE TABLE "public"."fare_rules" (
+  "id" uuid NOT NULL DEFAULT gen_random_uuid(),
+  "created_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "updated_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "route_id" text NOT NULL,
+  "origin_id" text NOT NULL,
+  "destination_id" text NOT NULL,
+  "price" numeric NOT NULL,
+  PRIMARY KEY ("id"),
+  CONSTRAINT "fk_fare_rules_destination" FOREIGN KEY ("destination_id") REFERENCES "public"."stops" ("stop_id") ON UPDATE CASCADE ON DELETE CASCADE,
+  CONSTRAINT "fk_fare_rules_origin" FOREIGN KEY ("origin_id") REFERENCES "public"."stops" ("stop_id") ON UPDATE CASCADE ON DELETE CASCADE,
+  CONSTRAINT "fk_fare_rules_route" FOREIGN KEY ("route_id") REFERENCES "public"."routes" ("route_id") ON UPDATE CASCADE ON DELETE CASCADE
+);
+-- Create index "idx_fare_rules_destination_id" to table: "fare_rules"
+CREATE INDEX "idx_fare_rules_destination_id" ON "public"."fare_rules" ("destination_id");
+-- Create index "idx_fare_rules_origin_id" to table: "fare_rules"
+CREATE INDEX "idx_fare_rules_origin_id" ON "public"."fare_rules" ("origin_id");
+-- Create index "idx_fare_rules_route_id" to table: "fare_rules"
+CREATE INDEX "idx_fare_rules_route_id" ON "public"."fare_rules" ("route_id");
+-- Create "trips" table
+CREATE TABLE "public"."trips" (
+  "id" uuid NOT NULL DEFAULT gen_random_uuid(),
+  "created_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "updated_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "trip_id" text NOT NULL,
+  "route_id" text NOT NULL,
+  "service_id" text NOT NULL,
+  "direction_id" bigint NOT NULL,
+  PRIMARY KEY ("id"),
+  CONSTRAINT "fk_trips_calendar" FOREIGN KEY ("service_id") REFERENCES "public"."calendars" ("service_id") ON UPDATE CASCADE ON DELETE CASCADE,
+  CONSTRAINT "fk_trips_route" FOREIGN KEY ("route_id") REFERENCES "public"."routes" ("route_id") ON UPDATE CASCADE ON DELETE CASCADE
+);
+-- Create index "idx_trips_route_id" to table: "trips"
+CREATE INDEX "idx_trips_route_id" ON "public"."trips" ("route_id");
+-- Create index "idx_trips_service_id" to table: "trips"
+CREATE INDEX "idx_trips_service_id" ON "public"."trips" ("service_id");
+-- Create index "idx_trips_trip_id" to table: "trips"
+CREATE UNIQUE INDEX "idx_trips_trip_id" ON "public"."trips" ("trip_id");
+-- Create "stop_times" table
+CREATE TABLE "public"."stop_times" (
+  "id" uuid NOT NULL DEFAULT gen_random_uuid(),
+  "created_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "updated_at" timestamptz NULL DEFAULT CURRENT_TIMESTAMP,
+  "trip_id" text NOT NULL,
+  "arrival_time" text NOT NULL,
+  "departure_time" text NOT NULL,
+  "stop_id" text NOT NULL,
+  "stop_sequence" bigint NOT NULL,
+  PRIMARY KEY ("id"),
+  CONSTRAINT "fk_stop_times_stop" FOREIGN KEY ("stop_id") REFERENCES "public"."stops" ("stop_id") ON UPDATE CASCADE ON DELETE CASCADE,
+  CONSTRAINT "fk_stop_times_trip" FOREIGN KEY ("trip_id") REFERENCES "public"."trips" ("trip_id") ON UPDATE CASCADE ON DELETE CASCADE
+);
+-- Create index "idx_stop_times_stop_id" to table: "stop_times"
+CREATE INDEX "idx_stop_times_stop_id" ON "public"."stop_times" ("stop_id");
+-- Create index "idx_stop_times_trip_id" to table: "stop_times"
+CREATE INDEX "idx_stop_times_trip_id" ON "public"."stop_times" ("trip_id");

migrations/atlas.sum

@@ -1,4 +1,5 @@
-h1:mQA8+6XzgUFnR6Z3XZPxHD6GVSUJkrzddFL0jnGEnxs=
+h1:D5+i7UkpjX21CwSfHPnweaD2G/XBWhvNtDxh558HwkY=
 20260510075358_baseline.sql h1:S1fQ5KJJJ/pulk/6WuV0GWMpC7jrMdg8uFGScIAr18A=
 20260510085829.sql h1:Jo1Alddu/vC51J4L/XttheZYY7FERVzLgRQLPStkHwk=
 20260716124002.sql h1:QVA3ZUNeL5M7ohqzdf7ZQ6RefAuQ5UGD1/SKZIje0OU=
+20260820171158_add_gtfs.sql h1:bqlu65oO9vfinAtbIXE7Mg5j3bbm9npUAPk9po9kRc0=