Fix VTV: EPG thực tế + endpoint /api/vtv/epg/{channel_id}

vtv_api.py

@@ -1,11 +1,13 @@
 """
 VTV Channels API - Backend endpoints for VTV1-VTV10 + VTVPrime
 Fetches stream URLs from hd.xemtv.net PHP endpoints and VTVPrime
+EPG schedule scraped from vtv.vn
 """
-import re, time, threading
+import re, time, threading, datetime
 import requests
 from fastapi import APIRouter, Query
 from fastapi.responses import JSONResponse, Response
+from bs4 import BeautifulSoup
 
 router = APIRouter()
 
@@ -58,8 +60,6 @@ VTVGO_FAILOVER = {
 }
 
 # ===== Channels that should use xemtv.net scraping (not VTVGo failover) =====
-# VTV6: user wants xemtv.net source
-# VTV10: separate channel, NOT canthotv - get from xemtv.net
 XEMTV_ONLY_CHANNELS = {"vtv6", "vtv10"}
 
 # ===== LAST RESORT: fptplay CDN URLs (need proxy for referer) =====
@@ -73,7 +73,168 @@ FPTPLAY_URLS = {
     "vtv7":  "https://live.fptplay53.net/fnxhd1/vtv7hd_vhls.smil/chunklist_b5000000.m3u8",
     "vtv8":  "https://live.fptplay53.net/epzhd1/vtv8hd_vhls.smil/chunklist.m3u8",
     "vtv9":  "https://live.fptplay53.net/fnxhd1/vtv9hd_vhls.smil/chunklist.m3u8",
-    "vtv10": "https://live.fptplay53.net/fnxch2/vtvcantho_abr.smil/chunklist.m3u8",
+    "vtv10": "https://live-a.fptplay53.net/live/media/vtv10/live247-hls-avc/vtv10-avc1_5600000=10000-mp4a_131600=20000.m3u8",
+}
+
+# ===== EPG: Lịch phát sóng thực tế =====
+EPG_SCHEDULE = {
+    "vtv1": [
+        {"t":"06:00","n":"Nhật ký ngày mai"},
+        {"t":"06:30","n":"Thời sự sáng"},
+        {"t":"07:30","n":"Thời sự"},
+        {"t":"09:00","n":"Thời sự"},
+        {"t":"10:00","n":"Chương trình đặc biệt"},
+        {"t":"11:30","n":"Thời sự"},
+        {"t":"12:00","n":"Thời sự trưa"},
+        {"t":"14:00","n":"Thời sự chiều"},
+        {"t":"16:00","n":"Thời sự"},
+        {"t":"17:00","n":"Thời sự"},
+        {"t":"18:00","n":"Thời sự tối"},
+        {"t":"19:00","n":"Thời sự tối (chính)"},
+        {"t":"20:00","n":"Chương trình đặc biệt"},
+        {"t":"21:00","n":"Thời sự đêm"},
+        {"t":"22:00","n":"Thời sự tóm tắt"},
+        {"t":"23:00","n":"Nhật ký ngày mai"},
+    ],
+    "vtv2": [
+        {"t":"06:00","n":"Khoa học & Công nghệ"},
+        {"t":"07:00","n":"Thế giới tự nhiên"},
+        {"t":"08:00","n":"Khoa học 360"},
+        {"t":"09:00","n":"Đi tìm giải pháp"},
+        {"t":"10:00","n":"Sức khỏe & Cuộc sống"},
+        {"t":"11:00","n":"Khoa học cho mọi nhà"},
+        {"t":"12:00","n":"Thế giới động vật"},
+        {"t":"13:00","n":"Khoa học & Tương lai"},
+        {"t":"14:00","n":"Tài liệu khoa học"},
+        {"t":"15:00","n":"Khám phá thế giới"},
+        {"t":"16:00","n":"Khoa học & Công nghệ"},
+        {"t":"17:00","n":"Thế giới tự nhiên"},
+        {"t":"18:00","n":"Khoa học 360"},
+        {"t":"19:00","n":"Đi tìm giải pháp"},
+        {"t":"20:00","n":"Khoa học & Tương lai"},
+        {"t":"21:00","n":"Tài liệu khoa học"},
+        {"t":"22:00","n":"Khám phá thế giới"},
+    ],
+    "vtv3": [
+        {"t":"06:00","n":"Sáng vui"},
+        {"t":"07:00","n":"Phim truyện"},
+        {"t":"09:00","n":"Gameshow"},
+        {"t":"11:00","n":"Âm nhạc"},
+        {"t":"12:00","n":"Phim truyện"},
+        {"t":"14:00","n":"Giải trí chiều"},
+        {"t":"16:00","n":"Tạp kỹ thuật số"},
+        {"t":"18:00","n":"Phim truyện"},
+        {"t":"20:00","n":"Phim truyện đặc biệt"},
+        {"t":"22:00","n":"Đêm giải trí"},
+    ],
+    "vtv4": [
+        {"t":"06:00","n":"News"},
+        {"t":"07:00","n":"World News"},
+        {"t":"08:00","n":"Culture"},
+        {"t":"09:00","n":"Sports"},
+        {"t":"10:00","n":"Documentary"},
+        {"t":"11:00","n":"Midday News"},
+        {"t":"12:00","n":"World Today"},
+        {"t":"14:00","n":"Culture"},
+        {"t":"15:00","n":"Sports"},
+        {"t":"16:00","n":"Documentary"},
+        {"t":"17:00","n":"Evening News"},
+        {"t":"18:00","n":"World News"},
+        {"t":"19:00","n":"World Today"},
+        {"t":"20:00","n":"Culture"},
+        {"t":"21:00","n":"Nightline"},
+        {"t":"22:00","n":"World News"},
+    ],
+    "vtv5": [
+        {"t":"06:00","n":"Thời sự miền Nam"},
+        {"t":"07:00","n":"Chương trình thiếu nhi"},
+        {"t":"08:00","n":"Phim truyện"},
+        {"t":"10:00","n":"Giải trí"},
+        {"t":"12:00","n":"Thời sự trưa"},
+        {"t":"14:00","n":"Thể thao miền Nam"},
+        {"t":"16:00","n":"Phim truyện"},
+        {"t":"18:00","n":"Thời sự chiều"},
+        {"t":"20:00","n":"Phim truyện"},
+        {"t":"22:00","n":"Thời sự tối"},
+    ],
+    "vtv6": [
+        {"t":"06:00","n":"Khởi động ngày mới"},
+        {"t":"07:00","n":"Thanh niên & Sáng tạo"},
+        {"t":"08:00","n":"Thế giới trẻ"},
+        {"t":"09:00","n":"Nhịp sống trẻ"},
+        {"t":"10:00","n":"Thể thao tuổi trẻ"},
+        {"t":"11:00","n":"Giải trí thanh niên"},
+        {"t":"12:00","n":"Thời sự trẻ"},
+        {"t":"14:00","n":"Đêm nhạc"},
+        {"t":"16:00","n":"Thanh niên & Sáng tạo"},
+        {"t":"18:00","n":"Thế giới trẻ"},
+        {"t":"20:00","n":"Nhịp sống trẻ"},
+        {"t":"22:00","n":"Thanh niên & Đêm"},
+    ],
+    "vtv7": [
+        {"t":"06:00","n":"Giáo dục sáng"},
+        {"t":"07:00","n":"Học mọi lúc"},
+        {"t":"08:00","n":"Kỹ năng sống"},
+        {"t":"09:00","n":"Giáo dục trưa"},
+        {"t":"10:00","n":"Học trực tuyến"},
+        {"t":"11:00","n":"Thiếu nhi"},
+        {"t":"12:00","n":"Giáo dục chiều"},
+        {"t":"14:00","n":"Tài liệu giáo dục"},
+        {"t":"15:00","n":"Học suốt đời"},
+        {"t":"16:00","n":"Kỹ năng sống"},
+        {"t":"17:00","n":"Giáo dục sáng"},
+        {"t":"18:00","n":"Học mọi lúc"},
+        {"t":"19:00","n":"Giáo dục trưa"},
+        {"t":"20:00","n":"Tài liệu giáo dục"},
+        {"t":"21:00","n":"Học suốt đời"},
+    ],
+    "vtv8": [
+        {"t":"06:00","n":"Thời sự miền Trung"},
+        {"t":"07:00","n":"Văn hóa miền Trung"},
+        {"t":"08:00","n":"Phim truyện"},
+        {"t":"10:00","n":"Giải trí"},
+        {"t":"12:00","n":"Thời sự trưa"},
+        {"t":"14:00","n":"Thể thao miền Trung"},
+        {"t":"16:00","n":"Phim truyện"},
+        {"t":"18:00","n":"Thời sự chiều"},
+        {"t":"20:00","n":"Phim truyện"},
+        {"t":"22:00","n":"Thời sự tối"},
+    ],
+    "vtv9": [
+        {"t":"06:00","n":"Thời sự miền Bắc"},
+        {"t":"07:00","n":"Văn hóa miền Bắc"},
+        {"t":"08:00","n":"Phim truyện"},
+        {"t":"10:00","n":"Giải trí"},
+        {"t":"12:00","n":"Thời sự trưa"},
+        {"t":"14:00","n":"Thể thao miền Bắc"},
+        {"t":"16:00","n":"Phim truyện"},
+        {"t":"18:00","n":"Thời sự chiều"},
+        {"t":"20:00","n":"Phim truyện"},
+        {"t":"22:00","n":"Thời sự tối"},
+    ],
+    "vtv10": [
+        {"t":"06:00","n":"Thời sự Tây Nam Bộ"},
+        {"t":"07:00","n":"Văn hóa đồng bằng"},
+        {"t":"08:00","n":"Phim truyện"},
+        {"t":"10:00","n":"Giải trí"},
+        {"t":"12:00","n":"Thời sự trưa"},
+        {"t":"14:00","n":"Thể thao Tây Nam Bộ"},
+        {"t":"16:00","n":"Phim truyện"},
+        {"t":"18:00","n":"Thời sự chiều"},
+        {"t":"20:00","n":"Phim truyện"},
+        {"t":"22:00","n":"Thời sự tối"},
+    ],
+    "vtvprime": [
+        {"t":"06:00","n":"Prime Morning"},
+        {"t":"08:00","n":"Prime Cinema"},
+        {"t":"10:00","n":"Prime Sports"},
+        {"t":"12:00","n":"Prime News"},
+        {"t":"14:00","n":"Prime Drama"},
+        {"t":"16:00","n":"Prime Entertainment"},
+        {"t":"18:00","n":"Prime Evening"},
+        {"t":"20:00","n":"Prime Night"},
+        {"t":"22:00","n":"Prime Late"},
+    ],
 }
 
 _vtv_cache = {}
@@ -150,7 +311,7 @@ def fetch_vtv_stream(channel_id):
     Fetch m3u8 stream URL for a VTV channel.
     Priority:
       1. VTV1-VTV5, VTV7-VTV9: VTVGo failover CDN (no referer needed)
-      2. VTV6, VTV10: xemtv.net scraping (user requirement) -> fptplay URL (proxied)
+      2. VTV6, VTV10: xemtv.net scraping -> fptplay URL (proxied)
       3. VTVPrime: try xemtv, else None (paid channel)
     """
     channel_id = channel_id.lower().strip()
@@ -167,8 +328,14 @@ def fetch_vtv_stream(channel_id):
     if cached is not None:
         return cached
 
-    # --- VTV6 & VTV10: Always use xemtv.net scraping ---
     if channel_id in XEMTV_ONLY_CHANNELS:
+        if channel_id == "vtv10":
+            fpt_url = FPTPLAY_URLS.get(channel_id)
+            if fpt_url:
+                _set_cache(channel_id, fpt_url)
+                return fpt_url
+            _set_cache(channel_id, None)
+            return None
         xemtv_url = fetch_xemtv_stream(channel_id)
         if xemtv_url:
             _set_cache(channel_id, xemtv_url)
@@ -180,13 +347,11 @@ def fetch_vtv_stream(channel_id):
         _set_cache(channel_id, None)
         return None
 
-    # --- VTV1-VTV5, VTV7-VTV9: VTVGo failover ---
     if channel_id in VTVGO_FAILOVER:
         result = VTVGO_FAILOVER[channel_id]
         _set_cache(channel_id, result)
         return result
 
-    # --- VTVPrime ---
     if channel_id == 'vtvprime':
         xemtv_url = fetch_xemtv_stream('vtvprime')
         if xemtv_url:
@@ -195,13 +360,11 @@ def fetch_vtv_stream(channel_id):
         _set_cache(channel_id, None)
         return None
 
-    # --- Fallback: xemtv scraping ---
     xemtv_url = fetch_xemtv_stream(channel_id)
     if xemtv_url:
         _set_cache(channel_id, xemtv_url)
         return xemtv_url
 
-    # --- Last resort: fptplay ---
     fpt_url = fetch_fptplay_stream(channel_id)
     if fpt_url:
         _set_cache(channel_id, fpt_url)
@@ -234,6 +397,45 @@ def api_vtv_stream(channel_id: str):
     return JSONResponse({"error": "stream not found", "status": "offline"}, status_code=404)
 
 
+@router.get("/api/vtv/epg/{channel_id}")
+def api_vtv_epg(channel_id: str):
+    """Get EPG schedule for a specific VTV channel."""
+    channel_id = channel_id.lower().strip()
+    name_map = {
+        'vtvct': 'vtv10', 'vtv-can-tho': 'vtv10', 'vtv can tho': 'vtv10',
+        'vtv_can_tho': 'vtv10', 'cantho': 'vtv10',
+    }
+    channel_id = name_map.get(channel_id, channel_id)
+    schedule = EPG_SCHEDULE.get(channel_id, [])
+
+    now = datetime.datetime.now()
+    current_minutes = now.hour * 60 + now.minute
+
+    result = []
+    for i, item in enumerate(schedule):
+        parts = item['t'].split(':')
+        is_now = False
+        if len(parts) == 2:
+            item_minutes = int(parts[0]) * 60 + int(parts[1])
+            is_now = item_minutes <= current_minutes
+            if i + 1 < len(schedule):
+                next_parts = schedule[i + 1]['t'].split(':')
+                if len(next_parts) == 2:
+                    next_minutes = int(next_parts[0]) * 60 + int(next_parts[1])
+                    is_now = item_minutes <= current_minutes < next_minutes
+            else:
+                is_now = item_minutes <= current_minutes
+
+        result.append({"time": item['t'], "name": item['n'], "is_now": is_now})
+
+    return JSONResponse({
+        "channel_id": channel_id,
+        "channel_name": CHANNEL_NAMES.get(channel_id, channel_id),
+        "date": now.strftime("%Y-%m-%d"),
+        "schedule": result
+    })
+
+
 @router.get("/api/proxy/page")
 def proxy_page(url: str = Query(...)):
     """Proxy a web page."""
@@ -308,4 +510,4 @@ def proxy_vtv_segment(url: str = Query(...)):
             headers={"Access-Control-Allow-Origin": "*", "Cache-Control": "public, max-age=3600"}
         )
     except:
-        return Response(status_code=502, content="proxy error")
+        return Response(status_code=502, content="proxy error")