| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404 |
- package service
- import (
- "context"
- "net/http"
- "strings"
- "time"
- "cmr-backend/internal/apperr"
- "cmr-backend/internal/platform/security"
- "cmr-backend/internal/store/postgres"
- )
- type AdminProductionService struct {
- store *postgres.Store
- }
- type AdminPlaceSummary struct {
- ID string `json:"id"`
- Code string `json:"code"`
- Name string `json:"name"`
- Region *string `json:"region,omitempty"`
- CoverURL *string `json:"coverUrl,omitempty"`
- Description *string `json:"description,omitempty"`
- CenterPoint map[string]any `json:"centerPoint,omitempty"`
- Status string `json:"status"`
- }
- type AdminPlaceDetail struct {
- Place AdminPlaceSummary `json:"place"`
- MapAssets []AdminMapAssetSummary `json:"mapAssets"`
- }
- type CreateAdminPlaceInput struct {
- Code string `json:"code"`
- Name string `json:"name"`
- Region *string `json:"region,omitempty"`
- CoverURL *string `json:"coverUrl,omitempty"`
- Description *string `json:"description,omitempty"`
- CenterPoint map[string]any `json:"centerPoint,omitempty"`
- Status string `json:"status"`
- }
- type AdminMapAssetSummary struct {
- ID string `json:"id"`
- PlaceID string `json:"placeId"`
- PlaceName *string `json:"placeName,omitempty"`
- LegacyMapID *string `json:"legacyMapId,omitempty"`
- Code string `json:"code"`
- Name string `json:"name"`
- MapType string `json:"mapType"`
- CoverURL *string `json:"coverUrl,omitempty"`
- Description *string `json:"description,omitempty"`
- Status string `json:"status"`
- CurrentTileRelease *AdminTileReleaseBrief `json:"currentTileRelease,omitempty"`
- }
- type AdminTileReleaseBrief struct {
- ID string `json:"id"`
- VersionCode string `json:"versionCode"`
- Status string `json:"status"`
- }
- type AdminMapAssetDetail struct {
- MapAsset AdminMapAssetSummary `json:"mapAsset"`
- TileReleases []AdminTileReleaseView `json:"tileReleases"`
- CourseSets []AdminCourseSetBrief `json:"courseSets"`
- LinkedEvents []AdminMapLinkedEventBrief `json:"linkedEvents"`
- }
- type CreateAdminMapAssetInput struct {
- Code string `json:"code"`
- Name string `json:"name"`
- MapType string `json:"mapType"`
- LegacyMapID *string `json:"legacyMapId,omitempty"`
- CoverURL *string `json:"coverUrl,omitempty"`
- Description *string `json:"description,omitempty"`
- Status string `json:"status"`
- }
- type UpdateAdminMapAssetInput struct {
- Code string `json:"code"`
- Name string `json:"name"`
- MapType string `json:"mapType"`
- CoverURL *string `json:"coverUrl,omitempty"`
- Description *string `json:"description,omitempty"`
- Status string `json:"status"`
- }
- type AdminMapLinkedEventBrief struct {
- EventID string `json:"eventId"`
- Title string `json:"title"`
- Summary *string `json:"summary,omitempty"`
- Status string `json:"status"`
- IsDefaultExperience bool `json:"isDefaultExperience"`
- ShowInEventList bool `json:"showInEventList"`
- CurrentReleaseID *string `json:"currentReleaseId,omitempty"`
- ConfigLabel *string `json:"configLabel,omitempty"`
- RouteCode *string `json:"routeCode,omitempty"`
- CurrentPresentationID *string `json:"currentPresentationId,omitempty"`
- CurrentPresentation *string `json:"currentPresentation,omitempty"`
- CurrentContentBundleID *string `json:"currentContentBundleId,omitempty"`
- CurrentContentBundle *string `json:"currentContentBundle,omitempty"`
- }
- type AdminTileReleaseView struct {
- ID string `json:"id"`
- LegacyVersionID *string `json:"legacyVersionId,omitempty"`
- VersionCode string `json:"versionCode"`
- Status string `json:"status"`
- TileBaseURL string `json:"tileBaseUrl"`
- MetaURL string `json:"metaUrl"`
- PublishedAssetRoot *string `json:"publishedAssetRoot,omitempty"`
- Metadata map[string]any `json:"metadata,omitempty"`
- PublishedAt *time.Time `json:"publishedAt,omitempty"`
- }
- type CreateAdminTileReleaseInput struct {
- LegacyVersionID *string `json:"legacyVersionId,omitempty"`
- VersionCode string `json:"versionCode"`
- Status string `json:"status"`
- TileBaseURL string `json:"tileBaseUrl"`
- MetaURL string `json:"metaUrl"`
- PublishedAssetRoot *string `json:"publishedAssetRoot,omitempty"`
- Metadata map[string]any `json:"metadata,omitempty"`
- SetAsCurrent bool `json:"setAsCurrent"`
- }
- type AdminCourseSourceSummary struct {
- ID string `json:"id"`
- LegacyVersionID *string `json:"legacyVersionId,omitempty"`
- SourceType string `json:"sourceType"`
- FileURL string `json:"fileUrl"`
- Checksum *string `json:"checksum,omitempty"`
- ParserVersion *string `json:"parserVersion,omitempty"`
- ImportStatus string `json:"importStatus"`
- Metadata map[string]any `json:"metadata,omitempty"`
- ImportedAt time.Time `json:"importedAt"`
- }
- type CreateAdminCourseSourceInput struct {
- LegacyPlayfieldID *string `json:"legacyPlayfieldId,omitempty"`
- LegacyVersionID *string `json:"legacyVersionId,omitempty"`
- SourceType string `json:"sourceType"`
- FileURL string `json:"fileUrl"`
- Checksum *string `json:"checksum,omitempty"`
- ParserVersion *string `json:"parserVersion,omitempty"`
- ImportStatus string `json:"importStatus"`
- Metadata map[string]any `json:"metadata,omitempty"`
- }
- type AdminCourseSetBrief struct {
- ID string `json:"id"`
- Code string `json:"code"`
- Mode string `json:"mode"`
- Name string `json:"name"`
- Description *string `json:"description,omitempty"`
- Status string `json:"status"`
- CurrentVariant *AdminCourseVariantBrief `json:"currentVariant,omitempty"`
- }
- type AdminCourseVariantBrief struct {
- ID string `json:"id"`
- Name string `json:"name"`
- RouteCode *string `json:"routeCode,omitempty"`
- Status string `json:"status"`
- }
- type AdminCourseSetDetail struct {
- CourseSet AdminCourseSetBrief `json:"courseSet"`
- Variants []AdminCourseVariantView `json:"variants"`
- }
- type CreateAdminCourseSetInput struct {
- Code string `json:"code"`
- Mode string `json:"mode"`
- Name string `json:"name"`
- Description *string `json:"description,omitempty"`
- Status string `json:"status"`
- }
- type AdminCourseVariantView struct {
- ID string `json:"id"`
- SourceID *string `json:"sourceId,omitempty"`
- Name string `json:"name"`
- RouteCode *string `json:"routeCode,omitempty"`
- Mode string `json:"mode"`
- ControlCount *int `json:"controlCount,omitempty"`
- Difficulty *string `json:"difficulty,omitempty"`
- Status string `json:"status"`
- IsDefault bool `json:"isDefault"`
- ConfigPatch map[string]any `json:"configPatch,omitempty"`
- Metadata map[string]any `json:"metadata,omitempty"`
- }
- type CreateAdminCourseVariantInput struct {
- SourceID *string `json:"sourceId,omitempty"`
- Name string `json:"name"`
- RouteCode *string `json:"routeCode,omitempty"`
- Mode string `json:"mode"`
- ControlCount *int `json:"controlCount,omitempty"`
- Difficulty *string `json:"difficulty,omitempty"`
- Status string `json:"status"`
- IsDefault bool `json:"isDefault"`
- ConfigPatch map[string]any `json:"configPatch,omitempty"`
- Metadata map[string]any `json:"metadata,omitempty"`
- }
- type AdminRuntimeBindingSummary struct {
- ID string `json:"id"`
- EventID string `json:"eventId"`
- PlaceID string `json:"placeId"`
- MapAssetID string `json:"mapAssetId"`
- TileReleaseID string `json:"tileReleaseId"`
- CourseSetID string `json:"courseSetId"`
- CourseVariantID string `json:"courseVariantId"`
- Status string `json:"status"`
- Notes *string `json:"notes,omitempty"`
- }
- type CreateAdminRuntimeBindingInput struct {
- EventID string `json:"eventId"`
- PlaceID string `json:"placeId"`
- MapAssetID string `json:"mapAssetId"`
- TileReleaseID string `json:"tileReleaseId"`
- CourseSetID string `json:"courseSetId"`
- CourseVariantID string `json:"courseVariantId"`
- Status string `json:"status"`
- Notes *string `json:"notes,omitempty"`
- }
- type ImportAdminTileReleaseInput struct {
- PlaceCode string `json:"placeCode"`
- PlaceName string `json:"placeName"`
- PlaceRegion *string `json:"placeRegion,omitempty"`
- PlaceCoverURL *string `json:"placeCoverUrl,omitempty"`
- PlaceDescription *string `json:"placeDescription,omitempty"`
- PlaceCenterPoint map[string]any `json:"placeCenterPoint,omitempty"`
- MapAssetCode string `json:"mapAssetCode"`
- MapAssetName string `json:"mapAssetName"`
- MapType string `json:"mapType"`
- MapCoverURL *string `json:"mapCoverUrl,omitempty"`
- MapDescription *string `json:"mapDescription,omitempty"`
- VersionCode string `json:"versionCode"`
- Status string `json:"status"`
- TileBaseURL string `json:"tileBaseUrl"`
- MetaURL string `json:"metaUrl"`
- PublishedAssetRoot *string `json:"publishedAssetRoot,omitempty"`
- Metadata map[string]any `json:"metadata,omitempty"`
- SetAsCurrent bool `json:"setAsCurrent"`
- }
- type ImportAdminTileReleaseResult struct {
- Place AdminPlaceSummary `json:"place"`
- MapAsset AdminMapAssetSummary `json:"mapAsset"`
- TileRelease AdminTileReleaseView `json:"tileRelease"`
- }
- type ImportAdminCourseRouteInput struct {
- Name string `json:"name"`
- RouteCode string `json:"routeCode"`
- FileURL string `json:"fileUrl"`
- SourceType string `json:"sourceType"`
- ControlCount *int `json:"controlCount,omitempty"`
- Difficulty *string `json:"difficulty,omitempty"`
- Status string `json:"status"`
- Metadata map[string]any `json:"metadata,omitempty"`
- }
- type ImportAdminCourseSetBatchInput struct {
- PlaceCode string `json:"placeCode"`
- PlaceName string `json:"placeName"`
- MapAssetCode string `json:"mapAssetCode"`
- MapAssetName string `json:"mapAssetName"`
- MapType string `json:"mapType"`
- CourseSetCode string `json:"courseSetCode"`
- CourseSetName string `json:"courseSetName"`
- Mode string `json:"mode"`
- Description *string `json:"description,omitempty"`
- Status string `json:"status"`
- DefaultRouteCode *string `json:"defaultRouteCode,omitempty"`
- Routes []ImportAdminCourseRouteInput `json:"routes"`
- }
- type ImportAdminCourseSetBatchResult struct {
- Place AdminPlaceSummary `json:"place"`
- MapAsset AdminMapAssetSummary `json:"mapAsset"`
- CourseSet AdminCourseSetBrief `json:"courseSet"`
- Variants []AdminCourseVariantView `json:"variants"`
- }
- func NewAdminProductionService(store *postgres.Store) *AdminProductionService {
- return &AdminProductionService{store: store}
- }
- func (s *AdminProductionService) ListPlaces(ctx context.Context, limit int) ([]AdminPlaceSummary, error) {
- items, err := s.store.ListPlaces(ctx, limit)
- if err != nil {
- return nil, err
- }
- result := make([]AdminPlaceSummary, 0, len(items))
- for _, item := range items {
- result = append(result, buildAdminPlaceSummary(item))
- }
- return result, nil
- }
- func (s *AdminProductionService) ListMapAssets(ctx context.Context, limit int) ([]AdminMapAssetSummary, error) {
- items, err := s.store.ListMapAssets(ctx, limit)
- if err != nil {
- return nil, err
- }
- result := make([]AdminMapAssetSummary, 0, len(items))
- for _, item := range items {
- summary, err := s.buildAdminMapAssetSummary(ctx, item)
- if err != nil {
- return nil, err
- }
- result = append(result, summary)
- }
- return result, nil
- }
- func (s *AdminProductionService) CreatePlace(ctx context.Context, input CreateAdminPlaceInput) (*AdminPlaceSummary, error) {
- input.Code = strings.TrimSpace(input.Code)
- input.Name = strings.TrimSpace(input.Name)
- if input.Code == "" || input.Name == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "code and name are required")
- }
- publicID, err := security.GeneratePublicID("place")
- if err != nil {
- return nil, err
- }
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- item, err := s.store.CreatePlace(ctx, tx, postgres.CreatePlaceParams{
- PublicID: publicID,
- Code: input.Code,
- Name: input.Name,
- Region: trimStringPtr(input.Region),
- CoverURL: trimStringPtr(input.CoverURL),
- Description: trimStringPtr(input.Description),
- CenterPoint: input.CenterPoint,
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- result := buildAdminPlaceSummary(*item)
- return &result, nil
- }
- func (s *AdminProductionService) GetPlaceDetail(ctx context.Context, placePublicID string) (*AdminPlaceDetail, error) {
- place, err := s.store.GetPlaceByPublicID(ctx, strings.TrimSpace(placePublicID))
- if err != nil {
- return nil, err
- }
- if place == nil {
- return nil, apperr.New(http.StatusNotFound, "place_not_found", "place not found")
- }
- mapAssets, err := s.store.ListMapAssetsByPlaceID(ctx, place.ID)
- if err != nil {
- return nil, err
- }
- result := &AdminPlaceDetail{
- Place: buildAdminPlaceSummary(*place),
- MapAssets: make([]AdminMapAssetSummary, 0, len(mapAssets)),
- }
- for _, item := range mapAssets {
- summary, err := s.buildAdminMapAssetSummary(ctx, item)
- if err != nil {
- return nil, err
- }
- result.MapAssets = append(result.MapAssets, summary)
- }
- return result, nil
- }
- func (s *AdminProductionService) CreateMapAsset(ctx context.Context, placePublicID string, input CreateAdminMapAssetInput) (*AdminMapAssetSummary, error) {
- place, err := s.store.GetPlaceByPublicID(ctx, strings.TrimSpace(placePublicID))
- if err != nil {
- return nil, err
- }
- if place == nil {
- return nil, apperr.New(http.StatusNotFound, "place_not_found", "place not found")
- }
- input.Code = strings.TrimSpace(input.Code)
- input.Name = strings.TrimSpace(input.Name)
- mapType := strings.TrimSpace(input.MapType)
- if mapType == "" {
- mapType = "standard"
- }
- if input.Code == "" || input.Name == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "code and name are required")
- }
- var legacyMapID *string
- if input.LegacyMapID != nil && strings.TrimSpace(*input.LegacyMapID) != "" {
- legacyMap, err := s.store.GetResourceMapByPublicID(ctx, strings.TrimSpace(*input.LegacyMapID))
- if err != nil {
- return nil, err
- }
- if legacyMap == nil {
- return nil, apperr.New(http.StatusNotFound, "legacy_map_not_found", "legacy map not found")
- }
- legacyMapID = &legacyMap.ID
- }
- publicID, err := security.GeneratePublicID("mapasset")
- if err != nil {
- return nil, err
- }
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- item, err := s.store.CreateMapAsset(ctx, tx, postgres.CreateMapAssetParams{
- PublicID: publicID,
- PlaceID: place.ID,
- LegacyMapID: legacyMapID,
- Code: input.Code,
- Name: input.Name,
- MapType: mapType,
- CoverURL: trimStringPtr(input.CoverURL),
- Description: trimStringPtr(input.Description),
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- result, err := s.buildAdminMapAssetSummary(ctx, *item)
- if err != nil {
- return nil, err
- }
- return &result, nil
- }
- func (s *AdminProductionService) GetMapAssetDetail(ctx context.Context, mapAssetPublicID string) (*AdminMapAssetDetail, error) {
- item, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(mapAssetPublicID))
- if err != nil {
- return nil, err
- }
- if item == nil {
- return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
- }
- summary, err := s.buildAdminMapAssetSummary(ctx, *item)
- if err != nil {
- return nil, err
- }
- tileReleases, err := s.store.ListTileReleasesByMapAssetID(ctx, item.ID)
- if err != nil {
- return nil, err
- }
- courseSets, err := s.store.ListCourseSetsByMapAssetID(ctx, item.ID)
- if err != nil {
- return nil, err
- }
- linkedEvents, err := s.store.ListMapAssetLinkedEvents(ctx, item.ID, 100)
- if err != nil {
- return nil, err
- }
- result := &AdminMapAssetDetail{
- MapAsset: summary,
- TileReleases: make([]AdminTileReleaseView, 0, len(tileReleases)),
- CourseSets: make([]AdminCourseSetBrief, 0, len(courseSets)),
- LinkedEvents: make([]AdminMapLinkedEventBrief, 0, len(linkedEvents)),
- }
- for _, release := range tileReleases {
- result.TileReleases = append(result.TileReleases, buildAdminTileReleaseView(release))
- }
- for _, courseSet := range courseSets {
- brief, err := s.buildAdminCourseSetBrief(ctx, courseSet)
- if err != nil {
- return nil, err
- }
- result.CourseSets = append(result.CourseSets, brief)
- }
- for _, linked := range linkedEvents {
- result.LinkedEvents = append(result.LinkedEvents, buildAdminMapLinkedEventBrief(linked))
- }
- return result, nil
- }
- func (s *AdminProductionService) UpdateMapAsset(ctx context.Context, mapAssetPublicID string, input UpdateAdminMapAssetInput) (*AdminMapAssetSummary, error) {
- item, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(mapAssetPublicID))
- if err != nil {
- return nil, err
- }
- if item == nil {
- return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
- }
- input.Code = strings.TrimSpace(input.Code)
- input.Name = strings.TrimSpace(input.Name)
- input.MapType = strings.TrimSpace(input.MapType)
- if input.Code == "" || input.Name == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "code and name are required")
- }
- if input.MapType == "" {
- input.MapType = "standard"
- }
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- updated, err := s.store.UpdateMapAsset(ctx, tx, postgres.UpdateMapAssetParams{
- MapAssetID: item.ID,
- Code: input.Code,
- Name: input.Name,
- MapType: input.MapType,
- CoverURL: trimStringPtr(input.CoverURL),
- Description: trimStringPtr(input.Description),
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- refreshed, err := s.store.GetMapAssetByPublicID(ctx, updated.PublicID)
- if err != nil {
- return nil, err
- }
- if refreshed == nil {
- return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
- }
- result, err := s.buildAdminMapAssetSummary(ctx, *refreshed)
- if err != nil {
- return nil, err
- }
- return &result, nil
- }
- func (s *AdminProductionService) CreateTileRelease(ctx context.Context, mapAssetPublicID string, input CreateAdminTileReleaseInput) (*AdminTileReleaseView, error) {
- mapAsset, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(mapAssetPublicID))
- if err != nil {
- return nil, err
- }
- if mapAsset == nil {
- return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
- }
- input.VersionCode = strings.TrimSpace(input.VersionCode)
- input.TileBaseURL = strings.TrimSpace(input.TileBaseURL)
- input.MetaURL = strings.TrimSpace(input.MetaURL)
- if input.VersionCode == "" || input.TileBaseURL == "" || input.MetaURL == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "versionCode, tileBaseUrl and metaUrl are required")
- }
- var legacyVersionID *string
- if input.LegacyVersionID != nil && strings.TrimSpace(*input.LegacyVersionID) != "" {
- if mapAsset.LegacyMapPublicID == nil || strings.TrimSpace(*mapAsset.LegacyMapPublicID) == "" {
- return nil, apperr.New(http.StatusBadRequest, "legacy_map_missing", "map asset has no linked legacy map")
- }
- legacyVersion, err := s.store.GetResourceMapVersionByPublicID(ctx, *mapAsset.LegacyMapPublicID, strings.TrimSpace(*input.LegacyVersionID))
- if err != nil {
- return nil, err
- }
- if legacyVersion == nil {
- return nil, apperr.New(http.StatusNotFound, "legacy_tile_version_not_found", "legacy map version not found")
- }
- legacyVersionID = &legacyVersion.ID
- }
- publicID, err := security.GeneratePublicID("tile")
- if err != nil {
- return nil, err
- }
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- publishedAt := time.Now()
- release, err := s.store.CreateTileRelease(ctx, tx, postgres.CreateTileReleaseParams{
- PublicID: publicID,
- MapAssetID: mapAsset.ID,
- LegacyMapVersionID: legacyVersionID,
- VersionCode: input.VersionCode,
- Status: normalizeReleaseStatus(input.Status),
- TileBaseURL: input.TileBaseURL,
- MetaURL: input.MetaURL,
- PublishedAssetRoot: trimStringPtr(input.PublishedAssetRoot),
- MetadataJSON: input.Metadata,
- PublishedAt: &publishedAt,
- })
- if err != nil {
- return nil, err
- }
- if input.SetAsCurrent {
- if err := s.store.SetMapAssetCurrentTileRelease(ctx, tx, mapAsset.ID, release.ID); err != nil {
- return nil, err
- }
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- view := buildAdminTileReleaseView(*release)
- return &view, nil
- }
- func (s *AdminProductionService) ListCourseSources(ctx context.Context, limit int) ([]AdminCourseSourceSummary, error) {
- items, err := s.store.ListCourseSources(ctx, limit)
- if err != nil {
- return nil, err
- }
- result := make([]AdminCourseSourceSummary, 0, len(items))
- for _, item := range items {
- result = append(result, buildAdminCourseSourceSummary(item))
- }
- return result, nil
- }
- func (s *AdminProductionService) CreateCourseSource(ctx context.Context, input CreateAdminCourseSourceInput) (*AdminCourseSourceSummary, error) {
- sourceType := strings.TrimSpace(input.SourceType)
- fileURL := strings.TrimSpace(input.FileURL)
- if sourceType == "" || fileURL == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "sourceType and fileUrl are required")
- }
- var legacyPlayfieldVersionID *string
- if input.LegacyPlayfieldID != nil && input.LegacyVersionID != nil && strings.TrimSpace(*input.LegacyPlayfieldID) != "" && strings.TrimSpace(*input.LegacyVersionID) != "" {
- version, err := s.store.GetResourcePlayfieldVersionByPublicID(ctx, strings.TrimSpace(*input.LegacyPlayfieldID), strings.TrimSpace(*input.LegacyVersionID))
- if err != nil {
- return nil, err
- }
- if version == nil {
- return nil, apperr.New(http.StatusNotFound, "legacy_playfield_version_not_found", "legacy playfield version not found")
- }
- legacyPlayfieldVersionID = &version.ID
- }
- publicID, err := security.GeneratePublicID("csrc")
- if err != nil {
- return nil, err
- }
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- item, err := s.store.CreateCourseSource(ctx, tx, postgres.CreateCourseSourceParams{
- PublicID: publicID,
- LegacyPlayfieldVersionID: legacyPlayfieldVersionID,
- SourceType: sourceType,
- FileURL: fileURL,
- Checksum: trimStringPtr(input.Checksum),
- ParserVersion: trimStringPtr(input.ParserVersion),
- ImportStatus: normalizeCourseSourceStatus(input.ImportStatus),
- MetadataJSON: input.Metadata,
- })
- if err != nil {
- return nil, err
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- result := buildAdminCourseSourceSummary(*item)
- return &result, nil
- }
- func (s *AdminProductionService) GetCourseSource(ctx context.Context, sourcePublicID string) (*AdminCourseSourceSummary, error) {
- item, err := s.store.GetCourseSourceByPublicID(ctx, strings.TrimSpace(sourcePublicID))
- if err != nil {
- return nil, err
- }
- if item == nil {
- return nil, apperr.New(http.StatusNotFound, "course_source_not_found", "course source not found")
- }
- result := buildAdminCourseSourceSummary(*item)
- return &result, nil
- }
- func (s *AdminProductionService) CreateCourseSet(ctx context.Context, mapAssetPublicID string, input CreateAdminCourseSetInput) (*AdminCourseSetBrief, error) {
- mapAsset, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(mapAssetPublicID))
- if err != nil {
- return nil, err
- }
- if mapAsset == nil {
- return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
- }
- input.Code = strings.TrimSpace(input.Code)
- input.Mode = strings.TrimSpace(input.Mode)
- input.Name = strings.TrimSpace(input.Name)
- if input.Code == "" || input.Mode == "" || input.Name == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "code, mode and name are required")
- }
- publicID, err := security.GeneratePublicID("cset")
- if err != nil {
- return nil, err
- }
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- item, err := s.store.CreateCourseSet(ctx, tx, postgres.CreateCourseSetParams{
- PublicID: publicID,
- PlaceID: mapAsset.PlaceID,
- MapAssetID: mapAsset.ID,
- Code: input.Code,
- Mode: input.Mode,
- Name: input.Name,
- Description: trimStringPtr(input.Description),
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- brief, err := s.buildAdminCourseSetBrief(ctx, *item)
- if err != nil {
- return nil, err
- }
- return &brief, nil
- }
- func (s *AdminProductionService) GetCourseSetDetail(ctx context.Context, courseSetPublicID string) (*AdminCourseSetDetail, error) {
- item, err := s.store.GetCourseSetByPublicID(ctx, strings.TrimSpace(courseSetPublicID))
- if err != nil {
- return nil, err
- }
- if item == nil {
- return nil, apperr.New(http.StatusNotFound, "course_set_not_found", "course set not found")
- }
- brief, err := s.buildAdminCourseSetBrief(ctx, *item)
- if err != nil {
- return nil, err
- }
- variants, err := s.store.ListCourseVariantsByCourseSetID(ctx, item.ID)
- if err != nil {
- return nil, err
- }
- result := &AdminCourseSetDetail{
- CourseSet: brief,
- Variants: make([]AdminCourseVariantView, 0, len(variants)),
- }
- for _, variant := range variants {
- result.Variants = append(result.Variants, buildAdminCourseVariantView(variant))
- }
- return result, nil
- }
- func (s *AdminProductionService) CreateCourseVariant(ctx context.Context, courseSetPublicID string, input CreateAdminCourseVariantInput) (*AdminCourseVariantView, error) {
- courseSet, err := s.store.GetCourseSetByPublicID(ctx, strings.TrimSpace(courseSetPublicID))
- if err != nil {
- return nil, err
- }
- if courseSet == nil {
- return nil, apperr.New(http.StatusNotFound, "course_set_not_found", "course set not found")
- }
- input.Name = strings.TrimSpace(input.Name)
- input.Mode = strings.TrimSpace(input.Mode)
- if input.Name == "" || input.Mode == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "name and mode are required")
- }
- var sourceID *string
- if input.SourceID != nil && strings.TrimSpace(*input.SourceID) != "" {
- source, err := s.store.GetCourseSourceByPublicID(ctx, strings.TrimSpace(*input.SourceID))
- if err != nil {
- return nil, err
- }
- if source == nil {
- return nil, apperr.New(http.StatusNotFound, "course_source_not_found", "course source not found")
- }
- sourceID = &source.ID
- }
- publicID, err := security.GeneratePublicID("cvar")
- if err != nil {
- return nil, err
- }
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- item, err := s.store.CreateCourseVariant(ctx, tx, postgres.CreateCourseVariantParams{
- PublicID: publicID,
- CourseSetID: courseSet.ID,
- SourceID: sourceID,
- Name: input.Name,
- RouteCode: trimStringPtr(input.RouteCode),
- Mode: input.Mode,
- ControlCount: input.ControlCount,
- Difficulty: trimStringPtr(input.Difficulty),
- Status: normalizeCatalogStatus(input.Status),
- IsDefault: input.IsDefault,
- ConfigPatch: input.ConfigPatch,
- MetadataJSON: input.Metadata,
- })
- if err != nil {
- return nil, err
- }
- if input.IsDefault {
- if err := s.store.SetCourseSetCurrentVariant(ctx, tx, courseSet.ID, item.ID); err != nil {
- return nil, err
- }
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- view := buildAdminCourseVariantView(*item)
- return &view, nil
- }
- func (s *AdminProductionService) ListRuntimeBindings(ctx context.Context, limit int) ([]AdminRuntimeBindingSummary, error) {
- items, err := s.store.ListMapRuntimeBindings(ctx, limit)
- if err != nil {
- return nil, err
- }
- result := make([]AdminRuntimeBindingSummary, 0, len(items))
- for _, item := range items {
- result = append(result, buildAdminRuntimeBindingSummary(item))
- }
- return result, nil
- }
- func (s *AdminProductionService) CreateRuntimeBinding(ctx context.Context, input CreateAdminRuntimeBindingInput) (*AdminRuntimeBindingSummary, error) {
- eventRecord, err := s.store.GetAdminEventByPublicID(ctx, strings.TrimSpace(input.EventID))
- if err != nil {
- return nil, err
- }
- if eventRecord == nil {
- return nil, apperr.New(http.StatusNotFound, "event_not_found", "event not found")
- }
- place, err := s.store.GetPlaceByPublicID(ctx, strings.TrimSpace(input.PlaceID))
- if err != nil {
- return nil, err
- }
- if place == nil {
- return nil, apperr.New(http.StatusNotFound, "place_not_found", "place not found")
- }
- mapAsset, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(input.MapAssetID))
- if err != nil {
- return nil, err
- }
- if mapAsset == nil || mapAsset.PlaceID != place.ID {
- return nil, apperr.New(http.StatusBadRequest, "map_asset_mismatch", "map asset does not belong to place")
- }
- tileRelease, err := s.store.GetTileReleaseByPublicID(ctx, strings.TrimSpace(input.TileReleaseID))
- if err != nil {
- return nil, err
- }
- if tileRelease == nil || tileRelease.MapAssetID != mapAsset.ID {
- return nil, apperr.New(http.StatusBadRequest, "tile_release_mismatch", "tile release does not belong to map asset")
- }
- courseSet, err := s.store.GetCourseSetByPublicID(ctx, strings.TrimSpace(input.CourseSetID))
- if err != nil {
- return nil, err
- }
- if courseSet == nil || courseSet.PlaceID != place.ID || courseSet.MapAssetID != mapAsset.ID {
- return nil, apperr.New(http.StatusBadRequest, "course_set_mismatch", "course set does not match place/map asset")
- }
- courseVariant, err := s.store.GetCourseVariantByPublicID(ctx, strings.TrimSpace(input.CourseVariantID))
- if err != nil {
- return nil, err
- }
- if courseVariant == nil || courseVariant.CourseSetID != courseSet.ID {
- return nil, apperr.New(http.StatusBadRequest, "course_variant_mismatch", "course variant does not belong to course set")
- }
- publicID, err := security.GeneratePublicID("rtbind")
- if err != nil {
- return nil, err
- }
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- item, err := s.store.CreateMapRuntimeBinding(ctx, tx, postgres.CreateMapRuntimeBindingParams{
- PublicID: publicID,
- EventID: eventRecord.ID,
- PlaceID: place.ID,
- MapAssetID: mapAsset.ID,
- TileReleaseID: tileRelease.ID,
- CourseSetID: courseSet.ID,
- CourseVariantID: courseVariant.ID,
- Status: normalizeRuntimeBindingStatus(input.Status),
- Notes: trimStringPtr(input.Notes),
- })
- if err != nil {
- return nil, err
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- created, err := s.store.GetMapRuntimeBindingByPublicID(ctx, item.PublicID)
- if err != nil {
- return nil, err
- }
- if created == nil {
- return nil, apperr.New(http.StatusNotFound, "runtime_binding_not_found", "runtime binding not found")
- }
- result := buildAdminRuntimeBindingSummary(*created)
- return &result, nil
- }
- func (s *AdminProductionService) ImportTileRelease(ctx context.Context, input ImportAdminTileReleaseInput) (*ImportAdminTileReleaseResult, error) {
- input.PlaceCode = strings.TrimSpace(input.PlaceCode)
- input.PlaceName = strings.TrimSpace(input.PlaceName)
- input.MapAssetCode = strings.TrimSpace(input.MapAssetCode)
- input.MapAssetName = strings.TrimSpace(input.MapAssetName)
- input.VersionCode = strings.TrimSpace(input.VersionCode)
- input.TileBaseURL = strings.TrimSpace(input.TileBaseURL)
- input.MetaURL = strings.TrimSpace(input.MetaURL)
- if input.PlaceCode == "" || input.PlaceName == "" || input.MapAssetCode == "" || input.MapAssetName == "" || input.VersionCode == "" || input.TileBaseURL == "" || input.MetaURL == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "placeCode, placeName, mapAssetCode, mapAssetName, versionCode, tileBaseUrl and metaUrl are required")
- }
- place, err := s.store.GetPlaceByCode(ctx, input.PlaceCode)
- if err != nil {
- return nil, err
- }
- if place == nil {
- created, err := s.CreatePlace(ctx, CreateAdminPlaceInput{
- Code: input.PlaceCode,
- Name: input.PlaceName,
- Region: trimStringPtr(input.PlaceRegion),
- CoverURL: trimStringPtr(input.PlaceCoverURL),
- Description: trimStringPtr(input.PlaceDescription),
- CenterPoint: input.PlaceCenterPoint,
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- place, err = s.store.GetPlaceByPublicID(ctx, created.ID)
- if err != nil {
- return nil, err
- }
- }
- if place == nil {
- return nil, apperr.New(http.StatusNotFound, "place_not_found", "place not found")
- }
- mapAsset, err := s.store.GetMapAssetByCode(ctx, input.MapAssetCode)
- if err != nil {
- return nil, err
- }
- if mapAsset == nil {
- created, err := s.CreateMapAsset(ctx, place.PublicID, CreateAdminMapAssetInput{
- Code: input.MapAssetCode,
- Name: input.MapAssetName,
- MapType: strings.TrimSpace(input.MapType),
- CoverURL: trimStringPtr(input.MapCoverURL),
- Description: trimStringPtr(input.MapDescription),
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- mapAsset, err = s.store.GetMapAssetByPublicID(ctx, created.ID)
- if err != nil {
- return nil, err
- }
- }
- if mapAsset == nil || mapAsset.PlaceID != place.ID {
- return nil, apperr.New(http.StatusBadRequest, "map_asset_mismatch", "map asset does not belong to place")
- }
- release, err := s.store.GetTileReleaseByMapAssetIDAndVersionCode(ctx, mapAsset.ID, input.VersionCode)
- if err != nil {
- return nil, err
- }
- if release == nil {
- created, err := s.CreateTileRelease(ctx, mapAsset.PublicID, CreateAdminTileReleaseInput{
- VersionCode: input.VersionCode,
- Status: normalizeReleaseStatus(input.Status),
- TileBaseURL: input.TileBaseURL,
- MetaURL: input.MetaURL,
- PublishedAssetRoot: trimStringPtr(input.PublishedAssetRoot),
- Metadata: input.Metadata,
- SetAsCurrent: input.SetAsCurrent,
- })
- if err != nil {
- return nil, err
- }
- release, err = s.store.GetTileReleaseByPublicID(ctx, created.ID)
- if err != nil {
- return nil, err
- }
- } else if input.SetAsCurrent {
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- if err := s.store.SetMapAssetCurrentTileRelease(ctx, tx, mapAsset.ID, release.ID); err != nil {
- return nil, err
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- mapAsset, err = s.store.GetMapAssetByPublicID(ctx, mapAsset.PublicID)
- if err != nil {
- return nil, err
- }
- }
- if release == nil {
- return nil, apperr.New(http.StatusNotFound, "tile_release_not_found", "tile release not found")
- }
- placeSummary := buildAdminPlaceSummary(*place)
- mapSummary, err := s.buildAdminMapAssetSummary(ctx, *mapAsset)
- if err != nil {
- return nil, err
- }
- return &ImportAdminTileReleaseResult{
- Place: placeSummary,
- MapAsset: mapSummary,
- TileRelease: buildAdminTileReleaseView(*release),
- }, nil
- }
- func (s *AdminProductionService) ImportCourseSetKMLBatch(ctx context.Context, input ImportAdminCourseSetBatchInput) (*ImportAdminCourseSetBatchResult, error) {
- input.PlaceCode = strings.TrimSpace(input.PlaceCode)
- input.PlaceName = strings.TrimSpace(input.PlaceName)
- input.MapAssetCode = strings.TrimSpace(input.MapAssetCode)
- input.MapAssetName = strings.TrimSpace(input.MapAssetName)
- input.CourseSetCode = strings.TrimSpace(input.CourseSetCode)
- input.CourseSetName = strings.TrimSpace(input.CourseSetName)
- input.Mode = strings.TrimSpace(input.Mode)
- if input.PlaceCode == "" || input.PlaceName == "" || input.MapAssetCode == "" || input.MapAssetName == "" || input.CourseSetCode == "" || input.CourseSetName == "" || input.Mode == "" || len(input.Routes) == 0 {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "placeCode, placeName, mapAssetCode, mapAssetName, courseSetCode, courseSetName, mode and routes are required")
- }
- place, err := s.store.GetPlaceByCode(ctx, input.PlaceCode)
- if err != nil {
- return nil, err
- }
- if place == nil {
- created, err := s.CreatePlace(ctx, CreateAdminPlaceInput{
- Code: input.PlaceCode,
- Name: input.PlaceName,
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- place, err = s.store.GetPlaceByPublicID(ctx, created.ID)
- if err != nil {
- return nil, err
- }
- }
- mapAsset, err := s.store.GetMapAssetByCode(ctx, input.MapAssetCode)
- if err != nil {
- return nil, err
- }
- if mapAsset == nil {
- created, err := s.CreateMapAsset(ctx, place.PublicID, CreateAdminMapAssetInput{
- Code: input.MapAssetCode,
- Name: input.MapAssetName,
- MapType: strings.TrimSpace(input.MapType),
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- mapAsset, err = s.store.GetMapAssetByPublicID(ctx, created.ID)
- if err != nil {
- return nil, err
- }
- }
- if mapAsset == nil || mapAsset.PlaceID != place.ID {
- return nil, apperr.New(http.StatusBadRequest, "map_asset_mismatch", "map asset does not belong to place")
- }
- courseSet, err := s.store.GetCourseSetByCode(ctx, input.CourseSetCode)
- if err != nil {
- return nil, err
- }
- if courseSet == nil {
- created, err := s.CreateCourseSet(ctx, mapAsset.PublicID, CreateAdminCourseSetInput{
- Code: input.CourseSetCode,
- Mode: input.Mode,
- Name: input.CourseSetName,
- Description: trimStringPtr(input.Description),
- Status: normalizeCatalogStatus(input.Status),
- })
- if err != nil {
- return nil, err
- }
- courseSet, err = s.store.GetCourseSetByPublicID(ctx, created.ID)
- if err != nil {
- return nil, err
- }
- }
- if courseSet == nil || courseSet.PlaceID != place.ID || courseSet.MapAssetID != mapAsset.ID {
- return nil, apperr.New(http.StatusBadRequest, "course_set_mismatch", "course set does not match place/map asset")
- }
- defaultRouteCode := ""
- if input.DefaultRouteCode != nil {
- defaultRouteCode = strings.TrimSpace(*input.DefaultRouteCode)
- }
- for _, route := range input.Routes {
- route.Name = strings.TrimSpace(route.Name)
- route.RouteCode = strings.TrimSpace(route.RouteCode)
- route.FileURL = strings.TrimSpace(route.FileURL)
- sourceType := strings.TrimSpace(route.SourceType)
- if sourceType == "" {
- sourceType = "kml"
- }
- if route.Name == "" || route.RouteCode == "" || route.FileURL == "" {
- return nil, apperr.New(http.StatusBadRequest, "invalid_params", "route name, routeCode and fileUrl are required")
- }
- existing, err := s.store.GetCourseVariantByCourseSetIDAndRouteCode(ctx, courseSet.ID, route.RouteCode)
- if err != nil {
- return nil, err
- }
- if existing != nil {
- if defaultRouteCode != "" && route.RouteCode == defaultRouteCode {
- tx, err := s.store.Begin(ctx)
- if err != nil {
- return nil, err
- }
- defer tx.Rollback(ctx)
- if err := s.store.SetCourseSetCurrentVariant(ctx, tx, courseSet.ID, existing.ID); err != nil {
- return nil, err
- }
- if err := tx.Commit(ctx); err != nil {
- return nil, err
- }
- }
- continue
- }
- source, err := s.CreateCourseSource(ctx, CreateAdminCourseSourceInput{
- SourceType: sourceType,
- FileURL: route.FileURL,
- ImportStatus: "imported",
- Metadata: route.Metadata,
- })
- if err != nil {
- return nil, err
- }
- isDefault := defaultRouteCode != "" && route.RouteCode == defaultRouteCode
- _, err = s.CreateCourseVariant(ctx, courseSet.PublicID, CreateAdminCourseVariantInput{
- SourceID: &source.ID,
- Name: route.Name,
- RouteCode: &route.RouteCode,
- Mode: input.Mode,
- ControlCount: route.ControlCount,
- Difficulty: trimStringPtr(route.Difficulty),
- Status: normalizeCatalogStatus(route.Status),
- IsDefault: isDefault,
- Metadata: route.Metadata,
- })
- if err != nil {
- return nil, err
- }
- }
- courseSet, err = s.store.GetCourseSetByPublicID(ctx, courseSet.PublicID)
- if err != nil {
- return nil, err
- }
- variants, err := s.store.ListCourseVariantsByCourseSetID(ctx, courseSet.ID)
- if err != nil {
- return nil, err
- }
- views := make([]AdminCourseVariantView, 0, len(variants))
- for _, variant := range variants {
- views = append(views, buildAdminCourseVariantView(variant))
- }
- placeSummary := buildAdminPlaceSummary(*place)
- mapSummary, err := s.buildAdminMapAssetSummary(ctx, *mapAsset)
- if err != nil {
- return nil, err
- }
- courseBrief, err := s.buildAdminCourseSetBrief(ctx, *courseSet)
- if err != nil {
- return nil, err
- }
- return &ImportAdminCourseSetBatchResult{
- Place: placeSummary,
- MapAsset: mapSummary,
- CourseSet: courseBrief,
- Variants: views,
- }, nil
- }
- func (s *AdminProductionService) GetRuntimeBinding(ctx context.Context, runtimeBindingPublicID string) (*AdminRuntimeBindingSummary, error) {
- item, err := s.store.GetMapRuntimeBindingByPublicID(ctx, strings.TrimSpace(runtimeBindingPublicID))
- if err != nil {
- return nil, err
- }
- if item == nil {
- return nil, apperr.New(http.StatusNotFound, "runtime_binding_not_found", "runtime binding not found")
- }
- result := buildAdminRuntimeBindingSummary(*item)
- return &result, nil
- }
- func (s *AdminProductionService) buildAdminMapAssetSummary(ctx context.Context, item postgres.MapAsset) (AdminMapAssetSummary, error) {
- result := AdminMapAssetSummary{
- ID: item.PublicID,
- PlaceID: item.PlaceID,
- PlaceName: item.PlaceName,
- LegacyMapID: item.LegacyMapPublicID,
- Code: item.Code,
- Name: item.Name,
- MapType: item.MapType,
- CoverURL: item.CoverURL,
- Description: item.Description,
- Status: item.Status,
- }
- if item.CurrentTileReleaseID != nil {
- releases, err := s.store.ListTileReleasesByMapAssetID(ctx, item.ID)
- if err != nil {
- return result, err
- }
- for _, release := range releases {
- if release.ID == *item.CurrentTileReleaseID {
- result.CurrentTileRelease = &AdminTileReleaseBrief{
- ID: release.PublicID,
- VersionCode: release.VersionCode,
- Status: release.Status,
- }
- break
- }
- }
- }
- return result, nil
- }
- func buildAdminMapLinkedEventBrief(item postgres.MapAssetLinkedEvent) AdminMapLinkedEventBrief {
- return AdminMapLinkedEventBrief{
- EventID: item.EventPublicID,
- Title: item.DisplayName,
- Summary: item.Summary,
- Status: item.Status,
- IsDefaultExperience: item.IsDefaultExperience,
- ShowInEventList: item.ShowInEventList,
- CurrentReleaseID: item.CurrentReleasePublicID,
- ConfigLabel: item.ConfigLabel,
- RouteCode: item.RouteCode,
- CurrentPresentationID: item.CurrentPresentationID,
- CurrentPresentation: item.CurrentPresentationName,
- CurrentContentBundleID: item.CurrentContentBundleID,
- CurrentContentBundle: item.CurrentContentBundleName,
- }
- }
- func (s *AdminProductionService) buildAdminCourseSetBrief(ctx context.Context, item postgres.CourseSet) (AdminCourseSetBrief, error) {
- result := AdminCourseSetBrief{
- ID: item.PublicID,
- Code: item.Code,
- Mode: item.Mode,
- Name: item.Name,
- Description: item.Description,
- Status: item.Status,
- }
- if item.CurrentVariantID != nil {
- variants, err := s.store.ListCourseVariantsByCourseSetID(ctx, item.ID)
- if err != nil {
- return result, err
- }
- for _, variant := range variants {
- if variant.ID == *item.CurrentVariantID {
- result.CurrentVariant = &AdminCourseVariantBrief{
- ID: variant.PublicID,
- Name: variant.Name,
- RouteCode: variant.RouteCode,
- Status: variant.Status,
- }
- break
- }
- }
- }
- return result, nil
- }
- func buildAdminPlaceSummary(item postgres.Place) AdminPlaceSummary {
- return AdminPlaceSummary{
- ID: item.PublicID,
- Code: item.Code,
- Name: item.Name,
- Region: item.Region,
- CoverURL: item.CoverURL,
- Description: item.Description,
- CenterPoint: decodeJSONMap(item.CenterPoint),
- Status: item.Status,
- }
- }
- func buildAdminTileReleaseView(item postgres.TileRelease) AdminTileReleaseView {
- return AdminTileReleaseView{
- ID: item.PublicID,
- LegacyVersionID: item.LegacyMapVersionPub,
- VersionCode: item.VersionCode,
- Status: item.Status,
- TileBaseURL: item.TileBaseURL,
- MetaURL: item.MetaURL,
- PublishedAssetRoot: item.PublishedAssetRoot,
- Metadata: decodeJSONMap(item.MetadataJSON),
- PublishedAt: item.PublishedAt,
- }
- }
- func buildAdminCourseSourceSummary(item postgres.CourseSource) AdminCourseSourceSummary {
- return AdminCourseSourceSummary{
- ID: item.PublicID,
- LegacyVersionID: item.LegacyPlayfieldVersionPub,
- SourceType: item.SourceType,
- FileURL: item.FileURL,
- Checksum: item.Checksum,
- ParserVersion: item.ParserVersion,
- ImportStatus: item.ImportStatus,
- Metadata: decodeJSONMap(item.MetadataJSON),
- ImportedAt: item.ImportedAt,
- }
- }
- func buildAdminCourseVariantView(item postgres.CourseVariant) AdminCourseVariantView {
- return AdminCourseVariantView{
- ID: item.PublicID,
- SourceID: item.SourcePublicID,
- Name: item.Name,
- RouteCode: item.RouteCode,
- Mode: item.Mode,
- ControlCount: item.ControlCount,
- Difficulty: item.Difficulty,
- Status: item.Status,
- IsDefault: item.IsDefault,
- ConfigPatch: decodeJSONMap(item.ConfigPatch),
- Metadata: decodeJSONMap(item.MetadataJSON),
- }
- }
- func buildAdminRuntimeBindingSummary(item postgres.MapRuntimeBinding) AdminRuntimeBindingSummary {
- return AdminRuntimeBindingSummary{
- ID: item.PublicID,
- EventID: item.EventPublicID,
- PlaceID: item.PlacePublicID,
- MapAssetID: item.MapAssetPublicID,
- TileReleaseID: item.TileReleasePublicID,
- CourseSetID: item.CourseSetPublicID,
- CourseVariantID: item.CourseVariantPublicID,
- Status: item.Status,
- Notes: item.Notes,
- }
- }
- func normalizeCourseSourceStatus(value string) string {
- switch strings.TrimSpace(value) {
- case "draft":
- return "draft"
- case "parsed":
- return "parsed"
- case "failed":
- return "failed"
- case "archived":
- return "archived"
- default:
- return "imported"
- }
- }
- func normalizeRuntimeBindingStatus(value string) string {
- switch strings.TrimSpace(value) {
- case "active":
- return "active"
- case "disabled":
- return "disabled"
- case "archived":
- return "archived"
- default:
- return "draft"
- }
- }
- func normalizeReleaseStatus(value string) string {
- switch strings.TrimSpace(value) {
- case "active":
- return "active"
- case "published":
- return "published"
- case "retired":
- return "retired"
- case "archived":
- return "archived"
- default:
- return "draft"
- }
- }
|