admin_production_service.go 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404
  1. package service
  2. import (
  3. "context"
  4. "net/http"
  5. "strings"
  6. "time"
  7. "cmr-backend/internal/apperr"
  8. "cmr-backend/internal/platform/security"
  9. "cmr-backend/internal/store/postgres"
  10. )
  11. type AdminProductionService struct {
  12. store *postgres.Store
  13. }
  14. type AdminPlaceSummary struct {
  15. ID string `json:"id"`
  16. Code string `json:"code"`
  17. Name string `json:"name"`
  18. Region *string `json:"region,omitempty"`
  19. CoverURL *string `json:"coverUrl,omitempty"`
  20. Description *string `json:"description,omitempty"`
  21. CenterPoint map[string]any `json:"centerPoint,omitempty"`
  22. Status string `json:"status"`
  23. }
  24. type AdminPlaceDetail struct {
  25. Place AdminPlaceSummary `json:"place"`
  26. MapAssets []AdminMapAssetSummary `json:"mapAssets"`
  27. }
  28. type CreateAdminPlaceInput struct {
  29. Code string `json:"code"`
  30. Name string `json:"name"`
  31. Region *string `json:"region,omitempty"`
  32. CoverURL *string `json:"coverUrl,omitempty"`
  33. Description *string `json:"description,omitempty"`
  34. CenterPoint map[string]any `json:"centerPoint,omitempty"`
  35. Status string `json:"status"`
  36. }
  37. type AdminMapAssetSummary struct {
  38. ID string `json:"id"`
  39. PlaceID string `json:"placeId"`
  40. PlaceName *string `json:"placeName,omitempty"`
  41. LegacyMapID *string `json:"legacyMapId,omitempty"`
  42. Code string `json:"code"`
  43. Name string `json:"name"`
  44. MapType string `json:"mapType"`
  45. CoverURL *string `json:"coverUrl,omitempty"`
  46. Description *string `json:"description,omitempty"`
  47. Status string `json:"status"`
  48. CurrentTileRelease *AdminTileReleaseBrief `json:"currentTileRelease,omitempty"`
  49. }
  50. type AdminTileReleaseBrief struct {
  51. ID string `json:"id"`
  52. VersionCode string `json:"versionCode"`
  53. Status string `json:"status"`
  54. }
  55. type AdminMapAssetDetail struct {
  56. MapAsset AdminMapAssetSummary `json:"mapAsset"`
  57. TileReleases []AdminTileReleaseView `json:"tileReleases"`
  58. CourseSets []AdminCourseSetBrief `json:"courseSets"`
  59. LinkedEvents []AdminMapLinkedEventBrief `json:"linkedEvents"`
  60. }
  61. type CreateAdminMapAssetInput struct {
  62. Code string `json:"code"`
  63. Name string `json:"name"`
  64. MapType string `json:"mapType"`
  65. LegacyMapID *string `json:"legacyMapId,omitempty"`
  66. CoverURL *string `json:"coverUrl,omitempty"`
  67. Description *string `json:"description,omitempty"`
  68. Status string `json:"status"`
  69. }
  70. type UpdateAdminMapAssetInput struct {
  71. Code string `json:"code"`
  72. Name string `json:"name"`
  73. MapType string `json:"mapType"`
  74. CoverURL *string `json:"coverUrl,omitempty"`
  75. Description *string `json:"description,omitempty"`
  76. Status string `json:"status"`
  77. }
  78. type AdminMapLinkedEventBrief struct {
  79. EventID string `json:"eventId"`
  80. Title string `json:"title"`
  81. Summary *string `json:"summary,omitempty"`
  82. Status string `json:"status"`
  83. IsDefaultExperience bool `json:"isDefaultExperience"`
  84. ShowInEventList bool `json:"showInEventList"`
  85. CurrentReleaseID *string `json:"currentReleaseId,omitempty"`
  86. ConfigLabel *string `json:"configLabel,omitempty"`
  87. RouteCode *string `json:"routeCode,omitempty"`
  88. CurrentPresentationID *string `json:"currentPresentationId,omitempty"`
  89. CurrentPresentation *string `json:"currentPresentation,omitempty"`
  90. CurrentContentBundleID *string `json:"currentContentBundleId,omitempty"`
  91. CurrentContentBundle *string `json:"currentContentBundle,omitempty"`
  92. }
  93. type AdminTileReleaseView struct {
  94. ID string `json:"id"`
  95. LegacyVersionID *string `json:"legacyVersionId,omitempty"`
  96. VersionCode string `json:"versionCode"`
  97. Status string `json:"status"`
  98. TileBaseURL string `json:"tileBaseUrl"`
  99. MetaURL string `json:"metaUrl"`
  100. PublishedAssetRoot *string `json:"publishedAssetRoot,omitempty"`
  101. Metadata map[string]any `json:"metadata,omitempty"`
  102. PublishedAt *time.Time `json:"publishedAt,omitempty"`
  103. }
  104. type CreateAdminTileReleaseInput struct {
  105. LegacyVersionID *string `json:"legacyVersionId,omitempty"`
  106. VersionCode string `json:"versionCode"`
  107. Status string `json:"status"`
  108. TileBaseURL string `json:"tileBaseUrl"`
  109. MetaURL string `json:"metaUrl"`
  110. PublishedAssetRoot *string `json:"publishedAssetRoot,omitempty"`
  111. Metadata map[string]any `json:"metadata,omitempty"`
  112. SetAsCurrent bool `json:"setAsCurrent"`
  113. }
  114. type AdminCourseSourceSummary struct {
  115. ID string `json:"id"`
  116. LegacyVersionID *string `json:"legacyVersionId,omitempty"`
  117. SourceType string `json:"sourceType"`
  118. FileURL string `json:"fileUrl"`
  119. Checksum *string `json:"checksum,omitempty"`
  120. ParserVersion *string `json:"parserVersion,omitempty"`
  121. ImportStatus string `json:"importStatus"`
  122. Metadata map[string]any `json:"metadata,omitempty"`
  123. ImportedAt time.Time `json:"importedAt"`
  124. }
  125. type CreateAdminCourseSourceInput struct {
  126. LegacyPlayfieldID *string `json:"legacyPlayfieldId,omitempty"`
  127. LegacyVersionID *string `json:"legacyVersionId,omitempty"`
  128. SourceType string `json:"sourceType"`
  129. FileURL string `json:"fileUrl"`
  130. Checksum *string `json:"checksum,omitempty"`
  131. ParserVersion *string `json:"parserVersion,omitempty"`
  132. ImportStatus string `json:"importStatus"`
  133. Metadata map[string]any `json:"metadata,omitempty"`
  134. }
  135. type AdminCourseSetBrief struct {
  136. ID string `json:"id"`
  137. Code string `json:"code"`
  138. Mode string `json:"mode"`
  139. Name string `json:"name"`
  140. Description *string `json:"description,omitempty"`
  141. Status string `json:"status"`
  142. CurrentVariant *AdminCourseVariantBrief `json:"currentVariant,omitempty"`
  143. }
  144. type AdminCourseVariantBrief struct {
  145. ID string `json:"id"`
  146. Name string `json:"name"`
  147. RouteCode *string `json:"routeCode,omitempty"`
  148. Status string `json:"status"`
  149. }
  150. type AdminCourseSetDetail struct {
  151. CourseSet AdminCourseSetBrief `json:"courseSet"`
  152. Variants []AdminCourseVariantView `json:"variants"`
  153. }
  154. type CreateAdminCourseSetInput struct {
  155. Code string `json:"code"`
  156. Mode string `json:"mode"`
  157. Name string `json:"name"`
  158. Description *string `json:"description,omitempty"`
  159. Status string `json:"status"`
  160. }
  161. type AdminCourseVariantView struct {
  162. ID string `json:"id"`
  163. SourceID *string `json:"sourceId,omitempty"`
  164. Name string `json:"name"`
  165. RouteCode *string `json:"routeCode,omitempty"`
  166. Mode string `json:"mode"`
  167. ControlCount *int `json:"controlCount,omitempty"`
  168. Difficulty *string `json:"difficulty,omitempty"`
  169. Status string `json:"status"`
  170. IsDefault bool `json:"isDefault"`
  171. ConfigPatch map[string]any `json:"configPatch,omitempty"`
  172. Metadata map[string]any `json:"metadata,omitempty"`
  173. }
  174. type CreateAdminCourseVariantInput struct {
  175. SourceID *string `json:"sourceId,omitempty"`
  176. Name string `json:"name"`
  177. RouteCode *string `json:"routeCode,omitempty"`
  178. Mode string `json:"mode"`
  179. ControlCount *int `json:"controlCount,omitempty"`
  180. Difficulty *string `json:"difficulty,omitempty"`
  181. Status string `json:"status"`
  182. IsDefault bool `json:"isDefault"`
  183. ConfigPatch map[string]any `json:"configPatch,omitempty"`
  184. Metadata map[string]any `json:"metadata,omitempty"`
  185. }
  186. type AdminRuntimeBindingSummary struct {
  187. ID string `json:"id"`
  188. EventID string `json:"eventId"`
  189. PlaceID string `json:"placeId"`
  190. MapAssetID string `json:"mapAssetId"`
  191. TileReleaseID string `json:"tileReleaseId"`
  192. CourseSetID string `json:"courseSetId"`
  193. CourseVariantID string `json:"courseVariantId"`
  194. Status string `json:"status"`
  195. Notes *string `json:"notes,omitempty"`
  196. }
  197. type CreateAdminRuntimeBindingInput struct {
  198. EventID string `json:"eventId"`
  199. PlaceID string `json:"placeId"`
  200. MapAssetID string `json:"mapAssetId"`
  201. TileReleaseID string `json:"tileReleaseId"`
  202. CourseSetID string `json:"courseSetId"`
  203. CourseVariantID string `json:"courseVariantId"`
  204. Status string `json:"status"`
  205. Notes *string `json:"notes,omitempty"`
  206. }
  207. type ImportAdminTileReleaseInput struct {
  208. PlaceCode string `json:"placeCode"`
  209. PlaceName string `json:"placeName"`
  210. PlaceRegion *string `json:"placeRegion,omitempty"`
  211. PlaceCoverURL *string `json:"placeCoverUrl,omitempty"`
  212. PlaceDescription *string `json:"placeDescription,omitempty"`
  213. PlaceCenterPoint map[string]any `json:"placeCenterPoint,omitempty"`
  214. MapAssetCode string `json:"mapAssetCode"`
  215. MapAssetName string `json:"mapAssetName"`
  216. MapType string `json:"mapType"`
  217. MapCoverURL *string `json:"mapCoverUrl,omitempty"`
  218. MapDescription *string `json:"mapDescription,omitempty"`
  219. VersionCode string `json:"versionCode"`
  220. Status string `json:"status"`
  221. TileBaseURL string `json:"tileBaseUrl"`
  222. MetaURL string `json:"metaUrl"`
  223. PublishedAssetRoot *string `json:"publishedAssetRoot,omitempty"`
  224. Metadata map[string]any `json:"metadata,omitempty"`
  225. SetAsCurrent bool `json:"setAsCurrent"`
  226. }
  227. type ImportAdminTileReleaseResult struct {
  228. Place AdminPlaceSummary `json:"place"`
  229. MapAsset AdminMapAssetSummary `json:"mapAsset"`
  230. TileRelease AdminTileReleaseView `json:"tileRelease"`
  231. }
  232. type ImportAdminCourseRouteInput struct {
  233. Name string `json:"name"`
  234. RouteCode string `json:"routeCode"`
  235. FileURL string `json:"fileUrl"`
  236. SourceType string `json:"sourceType"`
  237. ControlCount *int `json:"controlCount,omitempty"`
  238. Difficulty *string `json:"difficulty,omitempty"`
  239. Status string `json:"status"`
  240. Metadata map[string]any `json:"metadata,omitempty"`
  241. }
  242. type ImportAdminCourseSetBatchInput struct {
  243. PlaceCode string `json:"placeCode"`
  244. PlaceName string `json:"placeName"`
  245. MapAssetCode string `json:"mapAssetCode"`
  246. MapAssetName string `json:"mapAssetName"`
  247. MapType string `json:"mapType"`
  248. CourseSetCode string `json:"courseSetCode"`
  249. CourseSetName string `json:"courseSetName"`
  250. Mode string `json:"mode"`
  251. Description *string `json:"description,omitempty"`
  252. Status string `json:"status"`
  253. DefaultRouteCode *string `json:"defaultRouteCode,omitempty"`
  254. Routes []ImportAdminCourseRouteInput `json:"routes"`
  255. }
  256. type ImportAdminCourseSetBatchResult struct {
  257. Place AdminPlaceSummary `json:"place"`
  258. MapAsset AdminMapAssetSummary `json:"mapAsset"`
  259. CourseSet AdminCourseSetBrief `json:"courseSet"`
  260. Variants []AdminCourseVariantView `json:"variants"`
  261. }
  262. func NewAdminProductionService(store *postgres.Store) *AdminProductionService {
  263. return &AdminProductionService{store: store}
  264. }
  265. func (s *AdminProductionService) ListPlaces(ctx context.Context, limit int) ([]AdminPlaceSummary, error) {
  266. items, err := s.store.ListPlaces(ctx, limit)
  267. if err != nil {
  268. return nil, err
  269. }
  270. result := make([]AdminPlaceSummary, 0, len(items))
  271. for _, item := range items {
  272. result = append(result, buildAdminPlaceSummary(item))
  273. }
  274. return result, nil
  275. }
  276. func (s *AdminProductionService) ListMapAssets(ctx context.Context, limit int) ([]AdminMapAssetSummary, error) {
  277. items, err := s.store.ListMapAssets(ctx, limit)
  278. if err != nil {
  279. return nil, err
  280. }
  281. result := make([]AdminMapAssetSummary, 0, len(items))
  282. for _, item := range items {
  283. summary, err := s.buildAdminMapAssetSummary(ctx, item)
  284. if err != nil {
  285. return nil, err
  286. }
  287. result = append(result, summary)
  288. }
  289. return result, nil
  290. }
  291. func (s *AdminProductionService) CreatePlace(ctx context.Context, input CreateAdminPlaceInput) (*AdminPlaceSummary, error) {
  292. input.Code = strings.TrimSpace(input.Code)
  293. input.Name = strings.TrimSpace(input.Name)
  294. if input.Code == "" || input.Name == "" {
  295. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "code and name are required")
  296. }
  297. publicID, err := security.GeneratePublicID("place")
  298. if err != nil {
  299. return nil, err
  300. }
  301. tx, err := s.store.Begin(ctx)
  302. if err != nil {
  303. return nil, err
  304. }
  305. defer tx.Rollback(ctx)
  306. item, err := s.store.CreatePlace(ctx, tx, postgres.CreatePlaceParams{
  307. PublicID: publicID,
  308. Code: input.Code,
  309. Name: input.Name,
  310. Region: trimStringPtr(input.Region),
  311. CoverURL: trimStringPtr(input.CoverURL),
  312. Description: trimStringPtr(input.Description),
  313. CenterPoint: input.CenterPoint,
  314. Status: normalizeCatalogStatus(input.Status),
  315. })
  316. if err != nil {
  317. return nil, err
  318. }
  319. if err := tx.Commit(ctx); err != nil {
  320. return nil, err
  321. }
  322. result := buildAdminPlaceSummary(*item)
  323. return &result, nil
  324. }
  325. func (s *AdminProductionService) GetPlaceDetail(ctx context.Context, placePublicID string) (*AdminPlaceDetail, error) {
  326. place, err := s.store.GetPlaceByPublicID(ctx, strings.TrimSpace(placePublicID))
  327. if err != nil {
  328. return nil, err
  329. }
  330. if place == nil {
  331. return nil, apperr.New(http.StatusNotFound, "place_not_found", "place not found")
  332. }
  333. mapAssets, err := s.store.ListMapAssetsByPlaceID(ctx, place.ID)
  334. if err != nil {
  335. return nil, err
  336. }
  337. result := &AdminPlaceDetail{
  338. Place: buildAdminPlaceSummary(*place),
  339. MapAssets: make([]AdminMapAssetSummary, 0, len(mapAssets)),
  340. }
  341. for _, item := range mapAssets {
  342. summary, err := s.buildAdminMapAssetSummary(ctx, item)
  343. if err != nil {
  344. return nil, err
  345. }
  346. result.MapAssets = append(result.MapAssets, summary)
  347. }
  348. return result, nil
  349. }
  350. func (s *AdminProductionService) CreateMapAsset(ctx context.Context, placePublicID string, input CreateAdminMapAssetInput) (*AdminMapAssetSummary, error) {
  351. place, err := s.store.GetPlaceByPublicID(ctx, strings.TrimSpace(placePublicID))
  352. if err != nil {
  353. return nil, err
  354. }
  355. if place == nil {
  356. return nil, apperr.New(http.StatusNotFound, "place_not_found", "place not found")
  357. }
  358. input.Code = strings.TrimSpace(input.Code)
  359. input.Name = strings.TrimSpace(input.Name)
  360. mapType := strings.TrimSpace(input.MapType)
  361. if mapType == "" {
  362. mapType = "standard"
  363. }
  364. if input.Code == "" || input.Name == "" {
  365. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "code and name are required")
  366. }
  367. var legacyMapID *string
  368. if input.LegacyMapID != nil && strings.TrimSpace(*input.LegacyMapID) != "" {
  369. legacyMap, err := s.store.GetResourceMapByPublicID(ctx, strings.TrimSpace(*input.LegacyMapID))
  370. if err != nil {
  371. return nil, err
  372. }
  373. if legacyMap == nil {
  374. return nil, apperr.New(http.StatusNotFound, "legacy_map_not_found", "legacy map not found")
  375. }
  376. legacyMapID = &legacyMap.ID
  377. }
  378. publicID, err := security.GeneratePublicID("mapasset")
  379. if err != nil {
  380. return nil, err
  381. }
  382. tx, err := s.store.Begin(ctx)
  383. if err != nil {
  384. return nil, err
  385. }
  386. defer tx.Rollback(ctx)
  387. item, err := s.store.CreateMapAsset(ctx, tx, postgres.CreateMapAssetParams{
  388. PublicID: publicID,
  389. PlaceID: place.ID,
  390. LegacyMapID: legacyMapID,
  391. Code: input.Code,
  392. Name: input.Name,
  393. MapType: mapType,
  394. CoverURL: trimStringPtr(input.CoverURL),
  395. Description: trimStringPtr(input.Description),
  396. Status: normalizeCatalogStatus(input.Status),
  397. })
  398. if err != nil {
  399. return nil, err
  400. }
  401. if err := tx.Commit(ctx); err != nil {
  402. return nil, err
  403. }
  404. result, err := s.buildAdminMapAssetSummary(ctx, *item)
  405. if err != nil {
  406. return nil, err
  407. }
  408. return &result, nil
  409. }
  410. func (s *AdminProductionService) GetMapAssetDetail(ctx context.Context, mapAssetPublicID string) (*AdminMapAssetDetail, error) {
  411. item, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(mapAssetPublicID))
  412. if err != nil {
  413. return nil, err
  414. }
  415. if item == nil {
  416. return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
  417. }
  418. summary, err := s.buildAdminMapAssetSummary(ctx, *item)
  419. if err != nil {
  420. return nil, err
  421. }
  422. tileReleases, err := s.store.ListTileReleasesByMapAssetID(ctx, item.ID)
  423. if err != nil {
  424. return nil, err
  425. }
  426. courseSets, err := s.store.ListCourseSetsByMapAssetID(ctx, item.ID)
  427. if err != nil {
  428. return nil, err
  429. }
  430. linkedEvents, err := s.store.ListMapAssetLinkedEvents(ctx, item.ID, 100)
  431. if err != nil {
  432. return nil, err
  433. }
  434. result := &AdminMapAssetDetail{
  435. MapAsset: summary,
  436. TileReleases: make([]AdminTileReleaseView, 0, len(tileReleases)),
  437. CourseSets: make([]AdminCourseSetBrief, 0, len(courseSets)),
  438. LinkedEvents: make([]AdminMapLinkedEventBrief, 0, len(linkedEvents)),
  439. }
  440. for _, release := range tileReleases {
  441. result.TileReleases = append(result.TileReleases, buildAdminTileReleaseView(release))
  442. }
  443. for _, courseSet := range courseSets {
  444. brief, err := s.buildAdminCourseSetBrief(ctx, courseSet)
  445. if err != nil {
  446. return nil, err
  447. }
  448. result.CourseSets = append(result.CourseSets, brief)
  449. }
  450. for _, linked := range linkedEvents {
  451. result.LinkedEvents = append(result.LinkedEvents, buildAdminMapLinkedEventBrief(linked))
  452. }
  453. return result, nil
  454. }
  455. func (s *AdminProductionService) UpdateMapAsset(ctx context.Context, mapAssetPublicID string, input UpdateAdminMapAssetInput) (*AdminMapAssetSummary, error) {
  456. item, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(mapAssetPublicID))
  457. if err != nil {
  458. return nil, err
  459. }
  460. if item == nil {
  461. return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
  462. }
  463. input.Code = strings.TrimSpace(input.Code)
  464. input.Name = strings.TrimSpace(input.Name)
  465. input.MapType = strings.TrimSpace(input.MapType)
  466. if input.Code == "" || input.Name == "" {
  467. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "code and name are required")
  468. }
  469. if input.MapType == "" {
  470. input.MapType = "standard"
  471. }
  472. tx, err := s.store.Begin(ctx)
  473. if err != nil {
  474. return nil, err
  475. }
  476. defer tx.Rollback(ctx)
  477. updated, err := s.store.UpdateMapAsset(ctx, tx, postgres.UpdateMapAssetParams{
  478. MapAssetID: item.ID,
  479. Code: input.Code,
  480. Name: input.Name,
  481. MapType: input.MapType,
  482. CoverURL: trimStringPtr(input.CoverURL),
  483. Description: trimStringPtr(input.Description),
  484. Status: normalizeCatalogStatus(input.Status),
  485. })
  486. if err != nil {
  487. return nil, err
  488. }
  489. if err := tx.Commit(ctx); err != nil {
  490. return nil, err
  491. }
  492. refreshed, err := s.store.GetMapAssetByPublicID(ctx, updated.PublicID)
  493. if err != nil {
  494. return nil, err
  495. }
  496. if refreshed == nil {
  497. return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
  498. }
  499. result, err := s.buildAdminMapAssetSummary(ctx, *refreshed)
  500. if err != nil {
  501. return nil, err
  502. }
  503. return &result, nil
  504. }
  505. func (s *AdminProductionService) CreateTileRelease(ctx context.Context, mapAssetPublicID string, input CreateAdminTileReleaseInput) (*AdminTileReleaseView, error) {
  506. mapAsset, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(mapAssetPublicID))
  507. if err != nil {
  508. return nil, err
  509. }
  510. if mapAsset == nil {
  511. return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
  512. }
  513. input.VersionCode = strings.TrimSpace(input.VersionCode)
  514. input.TileBaseURL = strings.TrimSpace(input.TileBaseURL)
  515. input.MetaURL = strings.TrimSpace(input.MetaURL)
  516. if input.VersionCode == "" || input.TileBaseURL == "" || input.MetaURL == "" {
  517. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "versionCode, tileBaseUrl and metaUrl are required")
  518. }
  519. var legacyVersionID *string
  520. if input.LegacyVersionID != nil && strings.TrimSpace(*input.LegacyVersionID) != "" {
  521. if mapAsset.LegacyMapPublicID == nil || strings.TrimSpace(*mapAsset.LegacyMapPublicID) == "" {
  522. return nil, apperr.New(http.StatusBadRequest, "legacy_map_missing", "map asset has no linked legacy map")
  523. }
  524. legacyVersion, err := s.store.GetResourceMapVersionByPublicID(ctx, *mapAsset.LegacyMapPublicID, strings.TrimSpace(*input.LegacyVersionID))
  525. if err != nil {
  526. return nil, err
  527. }
  528. if legacyVersion == nil {
  529. return nil, apperr.New(http.StatusNotFound, "legacy_tile_version_not_found", "legacy map version not found")
  530. }
  531. legacyVersionID = &legacyVersion.ID
  532. }
  533. publicID, err := security.GeneratePublicID("tile")
  534. if err != nil {
  535. return nil, err
  536. }
  537. tx, err := s.store.Begin(ctx)
  538. if err != nil {
  539. return nil, err
  540. }
  541. defer tx.Rollback(ctx)
  542. publishedAt := time.Now()
  543. release, err := s.store.CreateTileRelease(ctx, tx, postgres.CreateTileReleaseParams{
  544. PublicID: publicID,
  545. MapAssetID: mapAsset.ID,
  546. LegacyMapVersionID: legacyVersionID,
  547. VersionCode: input.VersionCode,
  548. Status: normalizeReleaseStatus(input.Status),
  549. TileBaseURL: input.TileBaseURL,
  550. MetaURL: input.MetaURL,
  551. PublishedAssetRoot: trimStringPtr(input.PublishedAssetRoot),
  552. MetadataJSON: input.Metadata,
  553. PublishedAt: &publishedAt,
  554. })
  555. if err != nil {
  556. return nil, err
  557. }
  558. if input.SetAsCurrent {
  559. if err := s.store.SetMapAssetCurrentTileRelease(ctx, tx, mapAsset.ID, release.ID); err != nil {
  560. return nil, err
  561. }
  562. }
  563. if err := tx.Commit(ctx); err != nil {
  564. return nil, err
  565. }
  566. view := buildAdminTileReleaseView(*release)
  567. return &view, nil
  568. }
  569. func (s *AdminProductionService) ListCourseSources(ctx context.Context, limit int) ([]AdminCourseSourceSummary, error) {
  570. items, err := s.store.ListCourseSources(ctx, limit)
  571. if err != nil {
  572. return nil, err
  573. }
  574. result := make([]AdminCourseSourceSummary, 0, len(items))
  575. for _, item := range items {
  576. result = append(result, buildAdminCourseSourceSummary(item))
  577. }
  578. return result, nil
  579. }
  580. func (s *AdminProductionService) CreateCourseSource(ctx context.Context, input CreateAdminCourseSourceInput) (*AdminCourseSourceSummary, error) {
  581. sourceType := strings.TrimSpace(input.SourceType)
  582. fileURL := strings.TrimSpace(input.FileURL)
  583. if sourceType == "" || fileURL == "" {
  584. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "sourceType and fileUrl are required")
  585. }
  586. var legacyPlayfieldVersionID *string
  587. if input.LegacyPlayfieldID != nil && input.LegacyVersionID != nil && strings.TrimSpace(*input.LegacyPlayfieldID) != "" && strings.TrimSpace(*input.LegacyVersionID) != "" {
  588. version, err := s.store.GetResourcePlayfieldVersionByPublicID(ctx, strings.TrimSpace(*input.LegacyPlayfieldID), strings.TrimSpace(*input.LegacyVersionID))
  589. if err != nil {
  590. return nil, err
  591. }
  592. if version == nil {
  593. return nil, apperr.New(http.StatusNotFound, "legacy_playfield_version_not_found", "legacy playfield version not found")
  594. }
  595. legacyPlayfieldVersionID = &version.ID
  596. }
  597. publicID, err := security.GeneratePublicID("csrc")
  598. if err != nil {
  599. return nil, err
  600. }
  601. tx, err := s.store.Begin(ctx)
  602. if err != nil {
  603. return nil, err
  604. }
  605. defer tx.Rollback(ctx)
  606. item, err := s.store.CreateCourseSource(ctx, tx, postgres.CreateCourseSourceParams{
  607. PublicID: publicID,
  608. LegacyPlayfieldVersionID: legacyPlayfieldVersionID,
  609. SourceType: sourceType,
  610. FileURL: fileURL,
  611. Checksum: trimStringPtr(input.Checksum),
  612. ParserVersion: trimStringPtr(input.ParserVersion),
  613. ImportStatus: normalizeCourseSourceStatus(input.ImportStatus),
  614. MetadataJSON: input.Metadata,
  615. })
  616. if err != nil {
  617. return nil, err
  618. }
  619. if err := tx.Commit(ctx); err != nil {
  620. return nil, err
  621. }
  622. result := buildAdminCourseSourceSummary(*item)
  623. return &result, nil
  624. }
  625. func (s *AdminProductionService) GetCourseSource(ctx context.Context, sourcePublicID string) (*AdminCourseSourceSummary, error) {
  626. item, err := s.store.GetCourseSourceByPublicID(ctx, strings.TrimSpace(sourcePublicID))
  627. if err != nil {
  628. return nil, err
  629. }
  630. if item == nil {
  631. return nil, apperr.New(http.StatusNotFound, "course_source_not_found", "course source not found")
  632. }
  633. result := buildAdminCourseSourceSummary(*item)
  634. return &result, nil
  635. }
  636. func (s *AdminProductionService) CreateCourseSet(ctx context.Context, mapAssetPublicID string, input CreateAdminCourseSetInput) (*AdminCourseSetBrief, error) {
  637. mapAsset, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(mapAssetPublicID))
  638. if err != nil {
  639. return nil, err
  640. }
  641. if mapAsset == nil {
  642. return nil, apperr.New(http.StatusNotFound, "map_asset_not_found", "map asset not found")
  643. }
  644. input.Code = strings.TrimSpace(input.Code)
  645. input.Mode = strings.TrimSpace(input.Mode)
  646. input.Name = strings.TrimSpace(input.Name)
  647. if input.Code == "" || input.Mode == "" || input.Name == "" {
  648. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "code, mode and name are required")
  649. }
  650. publicID, err := security.GeneratePublicID("cset")
  651. if err != nil {
  652. return nil, err
  653. }
  654. tx, err := s.store.Begin(ctx)
  655. if err != nil {
  656. return nil, err
  657. }
  658. defer tx.Rollback(ctx)
  659. item, err := s.store.CreateCourseSet(ctx, tx, postgres.CreateCourseSetParams{
  660. PublicID: publicID,
  661. PlaceID: mapAsset.PlaceID,
  662. MapAssetID: mapAsset.ID,
  663. Code: input.Code,
  664. Mode: input.Mode,
  665. Name: input.Name,
  666. Description: trimStringPtr(input.Description),
  667. Status: normalizeCatalogStatus(input.Status),
  668. })
  669. if err != nil {
  670. return nil, err
  671. }
  672. if err := tx.Commit(ctx); err != nil {
  673. return nil, err
  674. }
  675. brief, err := s.buildAdminCourseSetBrief(ctx, *item)
  676. if err != nil {
  677. return nil, err
  678. }
  679. return &brief, nil
  680. }
  681. func (s *AdminProductionService) GetCourseSetDetail(ctx context.Context, courseSetPublicID string) (*AdminCourseSetDetail, error) {
  682. item, err := s.store.GetCourseSetByPublicID(ctx, strings.TrimSpace(courseSetPublicID))
  683. if err != nil {
  684. return nil, err
  685. }
  686. if item == nil {
  687. return nil, apperr.New(http.StatusNotFound, "course_set_not_found", "course set not found")
  688. }
  689. brief, err := s.buildAdminCourseSetBrief(ctx, *item)
  690. if err != nil {
  691. return nil, err
  692. }
  693. variants, err := s.store.ListCourseVariantsByCourseSetID(ctx, item.ID)
  694. if err != nil {
  695. return nil, err
  696. }
  697. result := &AdminCourseSetDetail{
  698. CourseSet: brief,
  699. Variants: make([]AdminCourseVariantView, 0, len(variants)),
  700. }
  701. for _, variant := range variants {
  702. result.Variants = append(result.Variants, buildAdminCourseVariantView(variant))
  703. }
  704. return result, nil
  705. }
  706. func (s *AdminProductionService) CreateCourseVariant(ctx context.Context, courseSetPublicID string, input CreateAdminCourseVariantInput) (*AdminCourseVariantView, error) {
  707. courseSet, err := s.store.GetCourseSetByPublicID(ctx, strings.TrimSpace(courseSetPublicID))
  708. if err != nil {
  709. return nil, err
  710. }
  711. if courseSet == nil {
  712. return nil, apperr.New(http.StatusNotFound, "course_set_not_found", "course set not found")
  713. }
  714. input.Name = strings.TrimSpace(input.Name)
  715. input.Mode = strings.TrimSpace(input.Mode)
  716. if input.Name == "" || input.Mode == "" {
  717. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "name and mode are required")
  718. }
  719. var sourceID *string
  720. if input.SourceID != nil && strings.TrimSpace(*input.SourceID) != "" {
  721. source, err := s.store.GetCourseSourceByPublicID(ctx, strings.TrimSpace(*input.SourceID))
  722. if err != nil {
  723. return nil, err
  724. }
  725. if source == nil {
  726. return nil, apperr.New(http.StatusNotFound, "course_source_not_found", "course source not found")
  727. }
  728. sourceID = &source.ID
  729. }
  730. publicID, err := security.GeneratePublicID("cvar")
  731. if err != nil {
  732. return nil, err
  733. }
  734. tx, err := s.store.Begin(ctx)
  735. if err != nil {
  736. return nil, err
  737. }
  738. defer tx.Rollback(ctx)
  739. item, err := s.store.CreateCourseVariant(ctx, tx, postgres.CreateCourseVariantParams{
  740. PublicID: publicID,
  741. CourseSetID: courseSet.ID,
  742. SourceID: sourceID,
  743. Name: input.Name,
  744. RouteCode: trimStringPtr(input.RouteCode),
  745. Mode: input.Mode,
  746. ControlCount: input.ControlCount,
  747. Difficulty: trimStringPtr(input.Difficulty),
  748. Status: normalizeCatalogStatus(input.Status),
  749. IsDefault: input.IsDefault,
  750. ConfigPatch: input.ConfigPatch,
  751. MetadataJSON: input.Metadata,
  752. })
  753. if err != nil {
  754. return nil, err
  755. }
  756. if input.IsDefault {
  757. if err := s.store.SetCourseSetCurrentVariant(ctx, tx, courseSet.ID, item.ID); err != nil {
  758. return nil, err
  759. }
  760. }
  761. if err := tx.Commit(ctx); err != nil {
  762. return nil, err
  763. }
  764. view := buildAdminCourseVariantView(*item)
  765. return &view, nil
  766. }
  767. func (s *AdminProductionService) ListRuntimeBindings(ctx context.Context, limit int) ([]AdminRuntimeBindingSummary, error) {
  768. items, err := s.store.ListMapRuntimeBindings(ctx, limit)
  769. if err != nil {
  770. return nil, err
  771. }
  772. result := make([]AdminRuntimeBindingSummary, 0, len(items))
  773. for _, item := range items {
  774. result = append(result, buildAdminRuntimeBindingSummary(item))
  775. }
  776. return result, nil
  777. }
  778. func (s *AdminProductionService) CreateRuntimeBinding(ctx context.Context, input CreateAdminRuntimeBindingInput) (*AdminRuntimeBindingSummary, error) {
  779. eventRecord, err := s.store.GetAdminEventByPublicID(ctx, strings.TrimSpace(input.EventID))
  780. if err != nil {
  781. return nil, err
  782. }
  783. if eventRecord == nil {
  784. return nil, apperr.New(http.StatusNotFound, "event_not_found", "event not found")
  785. }
  786. place, err := s.store.GetPlaceByPublicID(ctx, strings.TrimSpace(input.PlaceID))
  787. if err != nil {
  788. return nil, err
  789. }
  790. if place == nil {
  791. return nil, apperr.New(http.StatusNotFound, "place_not_found", "place not found")
  792. }
  793. mapAsset, err := s.store.GetMapAssetByPublicID(ctx, strings.TrimSpace(input.MapAssetID))
  794. if err != nil {
  795. return nil, err
  796. }
  797. if mapAsset == nil || mapAsset.PlaceID != place.ID {
  798. return nil, apperr.New(http.StatusBadRequest, "map_asset_mismatch", "map asset does not belong to place")
  799. }
  800. tileRelease, err := s.store.GetTileReleaseByPublicID(ctx, strings.TrimSpace(input.TileReleaseID))
  801. if err != nil {
  802. return nil, err
  803. }
  804. if tileRelease == nil || tileRelease.MapAssetID != mapAsset.ID {
  805. return nil, apperr.New(http.StatusBadRequest, "tile_release_mismatch", "tile release does not belong to map asset")
  806. }
  807. courseSet, err := s.store.GetCourseSetByPublicID(ctx, strings.TrimSpace(input.CourseSetID))
  808. if err != nil {
  809. return nil, err
  810. }
  811. if courseSet == nil || courseSet.PlaceID != place.ID || courseSet.MapAssetID != mapAsset.ID {
  812. return nil, apperr.New(http.StatusBadRequest, "course_set_mismatch", "course set does not match place/map asset")
  813. }
  814. courseVariant, err := s.store.GetCourseVariantByPublicID(ctx, strings.TrimSpace(input.CourseVariantID))
  815. if err != nil {
  816. return nil, err
  817. }
  818. if courseVariant == nil || courseVariant.CourseSetID != courseSet.ID {
  819. return nil, apperr.New(http.StatusBadRequest, "course_variant_mismatch", "course variant does not belong to course set")
  820. }
  821. publicID, err := security.GeneratePublicID("rtbind")
  822. if err != nil {
  823. return nil, err
  824. }
  825. tx, err := s.store.Begin(ctx)
  826. if err != nil {
  827. return nil, err
  828. }
  829. defer tx.Rollback(ctx)
  830. item, err := s.store.CreateMapRuntimeBinding(ctx, tx, postgres.CreateMapRuntimeBindingParams{
  831. PublicID: publicID,
  832. EventID: eventRecord.ID,
  833. PlaceID: place.ID,
  834. MapAssetID: mapAsset.ID,
  835. TileReleaseID: tileRelease.ID,
  836. CourseSetID: courseSet.ID,
  837. CourseVariantID: courseVariant.ID,
  838. Status: normalizeRuntimeBindingStatus(input.Status),
  839. Notes: trimStringPtr(input.Notes),
  840. })
  841. if err != nil {
  842. return nil, err
  843. }
  844. if err := tx.Commit(ctx); err != nil {
  845. return nil, err
  846. }
  847. created, err := s.store.GetMapRuntimeBindingByPublicID(ctx, item.PublicID)
  848. if err != nil {
  849. return nil, err
  850. }
  851. if created == nil {
  852. return nil, apperr.New(http.StatusNotFound, "runtime_binding_not_found", "runtime binding not found")
  853. }
  854. result := buildAdminRuntimeBindingSummary(*created)
  855. return &result, nil
  856. }
  857. func (s *AdminProductionService) ImportTileRelease(ctx context.Context, input ImportAdminTileReleaseInput) (*ImportAdminTileReleaseResult, error) {
  858. input.PlaceCode = strings.TrimSpace(input.PlaceCode)
  859. input.PlaceName = strings.TrimSpace(input.PlaceName)
  860. input.MapAssetCode = strings.TrimSpace(input.MapAssetCode)
  861. input.MapAssetName = strings.TrimSpace(input.MapAssetName)
  862. input.VersionCode = strings.TrimSpace(input.VersionCode)
  863. input.TileBaseURL = strings.TrimSpace(input.TileBaseURL)
  864. input.MetaURL = strings.TrimSpace(input.MetaURL)
  865. if input.PlaceCode == "" || input.PlaceName == "" || input.MapAssetCode == "" || input.MapAssetName == "" || input.VersionCode == "" || input.TileBaseURL == "" || input.MetaURL == "" {
  866. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "placeCode, placeName, mapAssetCode, mapAssetName, versionCode, tileBaseUrl and metaUrl are required")
  867. }
  868. place, err := s.store.GetPlaceByCode(ctx, input.PlaceCode)
  869. if err != nil {
  870. return nil, err
  871. }
  872. if place == nil {
  873. created, err := s.CreatePlace(ctx, CreateAdminPlaceInput{
  874. Code: input.PlaceCode,
  875. Name: input.PlaceName,
  876. Region: trimStringPtr(input.PlaceRegion),
  877. CoverURL: trimStringPtr(input.PlaceCoverURL),
  878. Description: trimStringPtr(input.PlaceDescription),
  879. CenterPoint: input.PlaceCenterPoint,
  880. Status: normalizeCatalogStatus(input.Status),
  881. })
  882. if err != nil {
  883. return nil, err
  884. }
  885. place, err = s.store.GetPlaceByPublicID(ctx, created.ID)
  886. if err != nil {
  887. return nil, err
  888. }
  889. }
  890. if place == nil {
  891. return nil, apperr.New(http.StatusNotFound, "place_not_found", "place not found")
  892. }
  893. mapAsset, err := s.store.GetMapAssetByCode(ctx, input.MapAssetCode)
  894. if err != nil {
  895. return nil, err
  896. }
  897. if mapAsset == nil {
  898. created, err := s.CreateMapAsset(ctx, place.PublicID, CreateAdminMapAssetInput{
  899. Code: input.MapAssetCode,
  900. Name: input.MapAssetName,
  901. MapType: strings.TrimSpace(input.MapType),
  902. CoverURL: trimStringPtr(input.MapCoverURL),
  903. Description: trimStringPtr(input.MapDescription),
  904. Status: normalizeCatalogStatus(input.Status),
  905. })
  906. if err != nil {
  907. return nil, err
  908. }
  909. mapAsset, err = s.store.GetMapAssetByPublicID(ctx, created.ID)
  910. if err != nil {
  911. return nil, err
  912. }
  913. }
  914. if mapAsset == nil || mapAsset.PlaceID != place.ID {
  915. return nil, apperr.New(http.StatusBadRequest, "map_asset_mismatch", "map asset does not belong to place")
  916. }
  917. release, err := s.store.GetTileReleaseByMapAssetIDAndVersionCode(ctx, mapAsset.ID, input.VersionCode)
  918. if err != nil {
  919. return nil, err
  920. }
  921. if release == nil {
  922. created, err := s.CreateTileRelease(ctx, mapAsset.PublicID, CreateAdminTileReleaseInput{
  923. VersionCode: input.VersionCode,
  924. Status: normalizeReleaseStatus(input.Status),
  925. TileBaseURL: input.TileBaseURL,
  926. MetaURL: input.MetaURL,
  927. PublishedAssetRoot: trimStringPtr(input.PublishedAssetRoot),
  928. Metadata: input.Metadata,
  929. SetAsCurrent: input.SetAsCurrent,
  930. })
  931. if err != nil {
  932. return nil, err
  933. }
  934. release, err = s.store.GetTileReleaseByPublicID(ctx, created.ID)
  935. if err != nil {
  936. return nil, err
  937. }
  938. } else if input.SetAsCurrent {
  939. tx, err := s.store.Begin(ctx)
  940. if err != nil {
  941. return nil, err
  942. }
  943. defer tx.Rollback(ctx)
  944. if err := s.store.SetMapAssetCurrentTileRelease(ctx, tx, mapAsset.ID, release.ID); err != nil {
  945. return nil, err
  946. }
  947. if err := tx.Commit(ctx); err != nil {
  948. return nil, err
  949. }
  950. mapAsset, err = s.store.GetMapAssetByPublicID(ctx, mapAsset.PublicID)
  951. if err != nil {
  952. return nil, err
  953. }
  954. }
  955. if release == nil {
  956. return nil, apperr.New(http.StatusNotFound, "tile_release_not_found", "tile release not found")
  957. }
  958. placeSummary := buildAdminPlaceSummary(*place)
  959. mapSummary, err := s.buildAdminMapAssetSummary(ctx, *mapAsset)
  960. if err != nil {
  961. return nil, err
  962. }
  963. return &ImportAdminTileReleaseResult{
  964. Place: placeSummary,
  965. MapAsset: mapSummary,
  966. TileRelease: buildAdminTileReleaseView(*release),
  967. }, nil
  968. }
  969. func (s *AdminProductionService) ImportCourseSetKMLBatch(ctx context.Context, input ImportAdminCourseSetBatchInput) (*ImportAdminCourseSetBatchResult, error) {
  970. input.PlaceCode = strings.TrimSpace(input.PlaceCode)
  971. input.PlaceName = strings.TrimSpace(input.PlaceName)
  972. input.MapAssetCode = strings.TrimSpace(input.MapAssetCode)
  973. input.MapAssetName = strings.TrimSpace(input.MapAssetName)
  974. input.CourseSetCode = strings.TrimSpace(input.CourseSetCode)
  975. input.CourseSetName = strings.TrimSpace(input.CourseSetName)
  976. input.Mode = strings.TrimSpace(input.Mode)
  977. if input.PlaceCode == "" || input.PlaceName == "" || input.MapAssetCode == "" || input.MapAssetName == "" || input.CourseSetCode == "" || input.CourseSetName == "" || input.Mode == "" || len(input.Routes) == 0 {
  978. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "placeCode, placeName, mapAssetCode, mapAssetName, courseSetCode, courseSetName, mode and routes are required")
  979. }
  980. place, err := s.store.GetPlaceByCode(ctx, input.PlaceCode)
  981. if err != nil {
  982. return nil, err
  983. }
  984. if place == nil {
  985. created, err := s.CreatePlace(ctx, CreateAdminPlaceInput{
  986. Code: input.PlaceCode,
  987. Name: input.PlaceName,
  988. Status: normalizeCatalogStatus(input.Status),
  989. })
  990. if err != nil {
  991. return nil, err
  992. }
  993. place, err = s.store.GetPlaceByPublicID(ctx, created.ID)
  994. if err != nil {
  995. return nil, err
  996. }
  997. }
  998. mapAsset, err := s.store.GetMapAssetByCode(ctx, input.MapAssetCode)
  999. if err != nil {
  1000. return nil, err
  1001. }
  1002. if mapAsset == nil {
  1003. created, err := s.CreateMapAsset(ctx, place.PublicID, CreateAdminMapAssetInput{
  1004. Code: input.MapAssetCode,
  1005. Name: input.MapAssetName,
  1006. MapType: strings.TrimSpace(input.MapType),
  1007. Status: normalizeCatalogStatus(input.Status),
  1008. })
  1009. if err != nil {
  1010. return nil, err
  1011. }
  1012. mapAsset, err = s.store.GetMapAssetByPublicID(ctx, created.ID)
  1013. if err != nil {
  1014. return nil, err
  1015. }
  1016. }
  1017. if mapAsset == nil || mapAsset.PlaceID != place.ID {
  1018. return nil, apperr.New(http.StatusBadRequest, "map_asset_mismatch", "map asset does not belong to place")
  1019. }
  1020. courseSet, err := s.store.GetCourseSetByCode(ctx, input.CourseSetCode)
  1021. if err != nil {
  1022. return nil, err
  1023. }
  1024. if courseSet == nil {
  1025. created, err := s.CreateCourseSet(ctx, mapAsset.PublicID, CreateAdminCourseSetInput{
  1026. Code: input.CourseSetCode,
  1027. Mode: input.Mode,
  1028. Name: input.CourseSetName,
  1029. Description: trimStringPtr(input.Description),
  1030. Status: normalizeCatalogStatus(input.Status),
  1031. })
  1032. if err != nil {
  1033. return nil, err
  1034. }
  1035. courseSet, err = s.store.GetCourseSetByPublicID(ctx, created.ID)
  1036. if err != nil {
  1037. return nil, err
  1038. }
  1039. }
  1040. if courseSet == nil || courseSet.PlaceID != place.ID || courseSet.MapAssetID != mapAsset.ID {
  1041. return nil, apperr.New(http.StatusBadRequest, "course_set_mismatch", "course set does not match place/map asset")
  1042. }
  1043. defaultRouteCode := ""
  1044. if input.DefaultRouteCode != nil {
  1045. defaultRouteCode = strings.TrimSpace(*input.DefaultRouteCode)
  1046. }
  1047. for _, route := range input.Routes {
  1048. route.Name = strings.TrimSpace(route.Name)
  1049. route.RouteCode = strings.TrimSpace(route.RouteCode)
  1050. route.FileURL = strings.TrimSpace(route.FileURL)
  1051. sourceType := strings.TrimSpace(route.SourceType)
  1052. if sourceType == "" {
  1053. sourceType = "kml"
  1054. }
  1055. if route.Name == "" || route.RouteCode == "" || route.FileURL == "" {
  1056. return nil, apperr.New(http.StatusBadRequest, "invalid_params", "route name, routeCode and fileUrl are required")
  1057. }
  1058. existing, err := s.store.GetCourseVariantByCourseSetIDAndRouteCode(ctx, courseSet.ID, route.RouteCode)
  1059. if err != nil {
  1060. return nil, err
  1061. }
  1062. if existing != nil {
  1063. if defaultRouteCode != "" && route.RouteCode == defaultRouteCode {
  1064. tx, err := s.store.Begin(ctx)
  1065. if err != nil {
  1066. return nil, err
  1067. }
  1068. defer tx.Rollback(ctx)
  1069. if err := s.store.SetCourseSetCurrentVariant(ctx, tx, courseSet.ID, existing.ID); err != nil {
  1070. return nil, err
  1071. }
  1072. if err := tx.Commit(ctx); err != nil {
  1073. return nil, err
  1074. }
  1075. }
  1076. continue
  1077. }
  1078. source, err := s.CreateCourseSource(ctx, CreateAdminCourseSourceInput{
  1079. SourceType: sourceType,
  1080. FileURL: route.FileURL,
  1081. ImportStatus: "imported",
  1082. Metadata: route.Metadata,
  1083. })
  1084. if err != nil {
  1085. return nil, err
  1086. }
  1087. isDefault := defaultRouteCode != "" && route.RouteCode == defaultRouteCode
  1088. _, err = s.CreateCourseVariant(ctx, courseSet.PublicID, CreateAdminCourseVariantInput{
  1089. SourceID: &source.ID,
  1090. Name: route.Name,
  1091. RouteCode: &route.RouteCode,
  1092. Mode: input.Mode,
  1093. ControlCount: route.ControlCount,
  1094. Difficulty: trimStringPtr(route.Difficulty),
  1095. Status: normalizeCatalogStatus(route.Status),
  1096. IsDefault: isDefault,
  1097. Metadata: route.Metadata,
  1098. })
  1099. if err != nil {
  1100. return nil, err
  1101. }
  1102. }
  1103. courseSet, err = s.store.GetCourseSetByPublicID(ctx, courseSet.PublicID)
  1104. if err != nil {
  1105. return nil, err
  1106. }
  1107. variants, err := s.store.ListCourseVariantsByCourseSetID(ctx, courseSet.ID)
  1108. if err != nil {
  1109. return nil, err
  1110. }
  1111. views := make([]AdminCourseVariantView, 0, len(variants))
  1112. for _, variant := range variants {
  1113. views = append(views, buildAdminCourseVariantView(variant))
  1114. }
  1115. placeSummary := buildAdminPlaceSummary(*place)
  1116. mapSummary, err := s.buildAdminMapAssetSummary(ctx, *mapAsset)
  1117. if err != nil {
  1118. return nil, err
  1119. }
  1120. courseBrief, err := s.buildAdminCourseSetBrief(ctx, *courseSet)
  1121. if err != nil {
  1122. return nil, err
  1123. }
  1124. return &ImportAdminCourseSetBatchResult{
  1125. Place: placeSummary,
  1126. MapAsset: mapSummary,
  1127. CourseSet: courseBrief,
  1128. Variants: views,
  1129. }, nil
  1130. }
  1131. func (s *AdminProductionService) GetRuntimeBinding(ctx context.Context, runtimeBindingPublicID string) (*AdminRuntimeBindingSummary, error) {
  1132. item, err := s.store.GetMapRuntimeBindingByPublicID(ctx, strings.TrimSpace(runtimeBindingPublicID))
  1133. if err != nil {
  1134. return nil, err
  1135. }
  1136. if item == nil {
  1137. return nil, apperr.New(http.StatusNotFound, "runtime_binding_not_found", "runtime binding not found")
  1138. }
  1139. result := buildAdminRuntimeBindingSummary(*item)
  1140. return &result, nil
  1141. }
  1142. func (s *AdminProductionService) buildAdminMapAssetSummary(ctx context.Context, item postgres.MapAsset) (AdminMapAssetSummary, error) {
  1143. result := AdminMapAssetSummary{
  1144. ID: item.PublicID,
  1145. PlaceID: item.PlaceID,
  1146. PlaceName: item.PlaceName,
  1147. LegacyMapID: item.LegacyMapPublicID,
  1148. Code: item.Code,
  1149. Name: item.Name,
  1150. MapType: item.MapType,
  1151. CoverURL: item.CoverURL,
  1152. Description: item.Description,
  1153. Status: item.Status,
  1154. }
  1155. if item.CurrentTileReleaseID != nil {
  1156. releases, err := s.store.ListTileReleasesByMapAssetID(ctx, item.ID)
  1157. if err != nil {
  1158. return result, err
  1159. }
  1160. for _, release := range releases {
  1161. if release.ID == *item.CurrentTileReleaseID {
  1162. result.CurrentTileRelease = &AdminTileReleaseBrief{
  1163. ID: release.PublicID,
  1164. VersionCode: release.VersionCode,
  1165. Status: release.Status,
  1166. }
  1167. break
  1168. }
  1169. }
  1170. }
  1171. return result, nil
  1172. }
  1173. func buildAdminMapLinkedEventBrief(item postgres.MapAssetLinkedEvent) AdminMapLinkedEventBrief {
  1174. return AdminMapLinkedEventBrief{
  1175. EventID: item.EventPublicID,
  1176. Title: item.DisplayName,
  1177. Summary: item.Summary,
  1178. Status: item.Status,
  1179. IsDefaultExperience: item.IsDefaultExperience,
  1180. ShowInEventList: item.ShowInEventList,
  1181. CurrentReleaseID: item.CurrentReleasePublicID,
  1182. ConfigLabel: item.ConfigLabel,
  1183. RouteCode: item.RouteCode,
  1184. CurrentPresentationID: item.CurrentPresentationID,
  1185. CurrentPresentation: item.CurrentPresentationName,
  1186. CurrentContentBundleID: item.CurrentContentBundleID,
  1187. CurrentContentBundle: item.CurrentContentBundleName,
  1188. }
  1189. }
  1190. func (s *AdminProductionService) buildAdminCourseSetBrief(ctx context.Context, item postgres.CourseSet) (AdminCourseSetBrief, error) {
  1191. result := AdminCourseSetBrief{
  1192. ID: item.PublicID,
  1193. Code: item.Code,
  1194. Mode: item.Mode,
  1195. Name: item.Name,
  1196. Description: item.Description,
  1197. Status: item.Status,
  1198. }
  1199. if item.CurrentVariantID != nil {
  1200. variants, err := s.store.ListCourseVariantsByCourseSetID(ctx, item.ID)
  1201. if err != nil {
  1202. return result, err
  1203. }
  1204. for _, variant := range variants {
  1205. if variant.ID == *item.CurrentVariantID {
  1206. result.CurrentVariant = &AdminCourseVariantBrief{
  1207. ID: variant.PublicID,
  1208. Name: variant.Name,
  1209. RouteCode: variant.RouteCode,
  1210. Status: variant.Status,
  1211. }
  1212. break
  1213. }
  1214. }
  1215. }
  1216. return result, nil
  1217. }
  1218. func buildAdminPlaceSummary(item postgres.Place) AdminPlaceSummary {
  1219. return AdminPlaceSummary{
  1220. ID: item.PublicID,
  1221. Code: item.Code,
  1222. Name: item.Name,
  1223. Region: item.Region,
  1224. CoverURL: item.CoverURL,
  1225. Description: item.Description,
  1226. CenterPoint: decodeJSONMap(item.CenterPoint),
  1227. Status: item.Status,
  1228. }
  1229. }
  1230. func buildAdminTileReleaseView(item postgres.TileRelease) AdminTileReleaseView {
  1231. return AdminTileReleaseView{
  1232. ID: item.PublicID,
  1233. LegacyVersionID: item.LegacyMapVersionPub,
  1234. VersionCode: item.VersionCode,
  1235. Status: item.Status,
  1236. TileBaseURL: item.TileBaseURL,
  1237. MetaURL: item.MetaURL,
  1238. PublishedAssetRoot: item.PublishedAssetRoot,
  1239. Metadata: decodeJSONMap(item.MetadataJSON),
  1240. PublishedAt: item.PublishedAt,
  1241. }
  1242. }
  1243. func buildAdminCourseSourceSummary(item postgres.CourseSource) AdminCourseSourceSummary {
  1244. return AdminCourseSourceSummary{
  1245. ID: item.PublicID,
  1246. LegacyVersionID: item.LegacyPlayfieldVersionPub,
  1247. SourceType: item.SourceType,
  1248. FileURL: item.FileURL,
  1249. Checksum: item.Checksum,
  1250. ParserVersion: item.ParserVersion,
  1251. ImportStatus: item.ImportStatus,
  1252. Metadata: decodeJSONMap(item.MetadataJSON),
  1253. ImportedAt: item.ImportedAt,
  1254. }
  1255. }
  1256. func buildAdminCourseVariantView(item postgres.CourseVariant) AdminCourseVariantView {
  1257. return AdminCourseVariantView{
  1258. ID: item.PublicID,
  1259. SourceID: item.SourcePublicID,
  1260. Name: item.Name,
  1261. RouteCode: item.RouteCode,
  1262. Mode: item.Mode,
  1263. ControlCount: item.ControlCount,
  1264. Difficulty: item.Difficulty,
  1265. Status: item.Status,
  1266. IsDefault: item.IsDefault,
  1267. ConfigPatch: decodeJSONMap(item.ConfigPatch),
  1268. Metadata: decodeJSONMap(item.MetadataJSON),
  1269. }
  1270. }
  1271. func buildAdminRuntimeBindingSummary(item postgres.MapRuntimeBinding) AdminRuntimeBindingSummary {
  1272. return AdminRuntimeBindingSummary{
  1273. ID: item.PublicID,
  1274. EventID: item.EventPublicID,
  1275. PlaceID: item.PlacePublicID,
  1276. MapAssetID: item.MapAssetPublicID,
  1277. TileReleaseID: item.TileReleasePublicID,
  1278. CourseSetID: item.CourseSetPublicID,
  1279. CourseVariantID: item.CourseVariantPublicID,
  1280. Status: item.Status,
  1281. Notes: item.Notes,
  1282. }
  1283. }
  1284. func normalizeCourseSourceStatus(value string) string {
  1285. switch strings.TrimSpace(value) {
  1286. case "draft":
  1287. return "draft"
  1288. case "parsed":
  1289. return "parsed"
  1290. case "failed":
  1291. return "failed"
  1292. case "archived":
  1293. return "archived"
  1294. default:
  1295. return "imported"
  1296. }
  1297. }
  1298. func normalizeRuntimeBindingStatus(value string) string {
  1299. switch strings.TrimSpace(value) {
  1300. case "active":
  1301. return "active"
  1302. case "disabled":
  1303. return "disabled"
  1304. case "archived":
  1305. return "archived"
  1306. default:
  1307. return "draft"
  1308. }
  1309. }
  1310. func normalizeReleaseStatus(value string) string {
  1311. switch strings.TrimSpace(value) {
  1312. case "active":
  1313. return "active"
  1314. case "published":
  1315. return "published"
  1316. case "retired":
  1317. return "retired"
  1318. case "archived":
  1319. return "archived"
  1320. default:
  1321. return "draft"
  1322. }
  1323. }