feat: add movie management API and database schema

- Implemented movie CRUD operations with endpoints for creating, retrieving, updating, and deleting movies.
- Added pagination and filtering capabilities for movie retrieval.
- Integrated Redis caching for improved performance on movie data retrieval.
- Created database schema for movies with necessary fields and types.
- Added migration files for initial movie table creation and subsequent updates.
- Configured database connection using Drizzle ORM with MySQL.
- Established Redis connection utility for caching.

server/api/admin/sync.post.ts

@@ -0,0 +1,104 @@
+import { movies } from '../../database/schema'
+import { eq, and } from 'drizzle-orm'
+import { getOphimKoreanMovies, getNguoncKoreanMovies, getKkphimKoreanMovies } from '../../utils/movies'
+
+const SYNC_PAGES = 10
+const ALL_SOURCES = ['ophim', 'nguonc', 'kkphim'] as const
+
+export default defineEventHandler(async (event) => {
+  const db = useDb()
+  const body = await readBody(event).catch(() => ({})) || {}
+  const requestedSources = Array.isArray(body.sources) ? body.sources : ALL_SOURCES
+  const sources = requestedSources.filter((s: string) => ALL_SOURCES.includes(s as any))
+
+  if (!sources.length) {
+    throw createError({ statusCode: 400, message: 'Nguồn không hợp lệ' })
+  }
+
+  const allMovies: any[] = []
+  const fetchers: Record<string, (page: number) => Promise<any>> = {
+    ophim: getOphimKoreanMovies,
+    nguonc: getNguoncKoreanMovies,
+    kkphim: getKkphimKoreanMovies,
+  }
+
+  for (const sourceName of sources) {
+    const fetcher = fetchers[sourceName]
+    if (!fetcher) continue
+    for (let page = 1; page <= SYNC_PAGES; page++) {
+      try {
+        const result = await fetcher(page)
+        for (const movie of result.items) {
+          allMovies.push({ ...movie, source: sourceName })
+        }
+        if (!result.items.length) break
+      } catch {
+        break
+      }
+    }
+  }
+
+  let created = 0
+  let updated = 0
+
+  for (const movie of allMovies) {
+    const existing = await db
+      .select()
+      .from(movies)
+      .where(and(eq(movies.source, movie.source), eq(movies.slug, movie.slug)))
+      .limit(1)
+
+    if (existing.length) {
+      await db
+        .update(movies)
+        .set({
+          name: movie.name,
+          originName: movie.originName || null,
+          thumb: movie.thumb || null,
+          poster: movie.poster || null,
+          year: movie.year || null,
+          time: movie.time || null,
+          episode: movie.episode || null,
+          quality: movie.quality || null,
+          lang: movie.lang || null,
+          type: movie.type || null,
+          rating: movie.rating || null,
+          categories: movie.categories || null,
+          countries: movie.countries || null,
+          sources: movie.sources || null,
+          syncedAt: new Date(),
+        })
+        .where(eq(movies.id, existing[0].id))
+      updated++
+    } else {
+      await db.insert(movies).values({
+        source: movie.source,
+        slug: movie.slug,
+        name: movie.name,
+        originName: movie.originName || null,
+        thumb: movie.thumb || null,
+        poster: movie.poster || null,
+        year: movie.year || null,
+        time: movie.time || null,
+        episode: movie.episode || null,
+        quality: movie.quality || null,
+        lang: movie.lang || null,
+        type: movie.type || null,
+        rating: movie.rating || null,
+        categories: movie.categories || null,
+        countries: movie.countries || null,
+        sources: movie.sources || null,
+        active: false,
+      })
+      created++
+    }
+  }
+
+  return {
+    success: true,
+    sources,
+    total: allMovies.length,
+    created,
+    updated,
+  }
+})