Upgrade personal opinion post v2: AI tổng hợp bài viết từ nguồn tin + hình ảnh

app_v2_entry.py

@@ -1463,24 +1463,24 @@ async def api_url_wall(request: Request):
     return await api_rewrite_share(request)
 
 
-# ===== PERSONAL OPINION POST: viết bài dựa trên quan điểm cá nhân + tin HOT =====
-@app.post("/api/personal_post")
-async def api_personal_post(request: Request):
-    """Create a post based on personal opinion with HOT news references."""
+# ===== PERSONAL OPINION POST v2: AI tổng hợp bài viết từ quan điểm + nguồn tin HOT =====
+@app.post("/api/personal_post/preview")
+async def api_personal_post_preview(request: Request):
+    """Preview personal post: fetch full articles, let AI compose logical article with images."""
     body = await request.json()
     opinion = _clean(body.get("opinion", ""))
     selected_topics = body.get("selected_topics", []) or []
     selected_sources = body.get("selected_sources", []) or []
-    custom_title = body.get("custom_title", "")
-    custom_slides = body.get("custom_slides", [])
     
     if not opinion or len(opinion) < 10:
         return JSONResponse({"error": "Quan điểm cá nhân quá ngắn (cần ít nhất 10 ký tự)"}, status_code=400)
     
+    # Lấy HOT topics nếu ko có selected
     if not selected_topics:
         hot = _get_hot_topics()
         selected_topics = [t.get("topic", "") for t in hot[:3] if t.get("topic")]
     
+    # Tìm nguồn tin
     all_sources = []
     seen_urls = set()
     for topic in selected_topics[:3]:
@@ -1489,120 +1489,153 @@ async def api_personal_post(request: Request):
             if s.get("url") and s["url"] not in seen_urls:
                 seen_urls.add(s["url"])
                 all_sources.append(s)
-                if len(all_sources) >= 8:
+                if len(all_sources) >= 6:
                     break
-        if len(all_sources) >= 8:
+        if len(all_sources) >= 6:
             break
     
     for src in selected_sources:
         if src.get("url") and src["url"] not in seen_urls:
             all_sources.insert(0, src)
     
+    # Scrape nội dung đầy đủ từng nguồn (paragraphs + images)
+    source_details = []
     source_images = []
-    for src in all_sources[:6]:
+    for src in all_sources[:5]:
         url = src.get("url", "")
-        if url:
-            try:
-                art = _scrape_article_for_rewrite(url)
-                if art and art.get("og_image"):
-                    img = art.get("og_image")
-                    if any(x in img for x in ["cdnphoto.dantri", "refooty", "vnexpress", "vcdn"]):
+        if not url:
+            continue
+        try:
+            art = _scrape_article_for_rewrite(url)
+            if art:
+                src_detail = {
+                    "title": art.get("title", src.get("title", "")),
+                    "url": url,
+                    "via": src.get("via", ""),
+                    "paragraphs": art.get("paragraphs", [])[:8],
+                    "images": art.get("images", [])[:3],
+                    "og_image": art.get("og_img", "")
+                }
+                source_details.append(src_detail)
+                # Collect images for proxy
+                for img in art.get("images", [])[:2]:
+                    if any(x in img for x in ["cdnphoto.dantri", "vnexpress", "vcdn", "refooty"]):
                         img = "/api/proxy/img?url=" + _quote2(img, safe="")
                     source_images.append(img)
-            except:
-                pass
+        except:
+            pass
+        if len(source_details) >= 5:
+            break
     
-    if custom_title:
-        title = custom_title[:80]
-    else:
-        import re
-        opinion_words = re.findall(r"[A-Za-zÀ-ỹ0-9]+", opinion)
-        title_words = opinion_words[:8] if len(opinion_words) >= 8 else opinion_words[:4]
-        if title_words:
-            title = " ".join([w[0].upper() + w[1:] for w in title_words])
-        else:
-            title = "Quan điểm cá nhân"
-        title = title[:80]
+    # Tạo title từ opinion
+    opinion_words = re.findall(r"[A-Za-zÀ-ỹ0-9]+", opinion)
+    title_words = opinion_words[:8] if len(opinion_words) >= 8 else opinion_words[:4]
+    title = " ".join([w[0].upper() + w[1:] for w in title_words]) if title_words else "Quan điểm cá nhân"
+    title = title[:80]
     
+    # AI sinh bài viết hoàn chỉnh
     ai_text = None
     try:
         import ai_ext
         if hasattr(ai_ext, 'qwen_generate'):
-            sources_str = "\n".join([f"- {s.get('title', '')} ({s.get('via', '')})" for s in all_sources[:5]])
-            prompt = "Viết bài blog dựa trên quan điểm cá nhân:\n\nQuan điểm: " + opinion[:2000] + "\n\nNguồn tin tham khảo:\n" + sources_str + "\n\nYêu cầu:\n1. Mở đầu bằng ý kiến cá nhân\n2. Phân tích dựa trên các nguồn tin\n3. Kết luận rõ ràng\n4. Ghi nguồn tin cuối bài"
-            ai_text = await ai_ext.qwen_generate(prompt, max_tokens=1500)
+            # Build detailed context from source articles
+            source_context = ""
+            for i, sd in enumerate(source_details[:5]):
+                src_title = sd.get("title", "")
+                src_via = sd.get("via", "")
+                src_paras = sd.get("paragraphs", [])
+                source_context += f"\n=== Nguồn {i+1}: {src_title} ({src_via}) ===\n"
+                for j, p in enumerate(src_paras[:4]):
+                    source_context += f"  - {p[:300]}\n"
+            
+            prompt = (
+                "Bạn là nhà báo chuyên nghiệp tiếng Việt. Hãy viết một bài phân tích dựa trên quan điểm cá nhân và các nguồn tin sau đây.\n\n"
+                "=== QUAN ĐIỂM CÁ NHÂN ===\n" + opinion[:2000] + "\n\n"
+                "=== NGUỒN TIN THAM KHẢO (kèm nội dung chi tiết) ===\n" + source_context + "\n\n"
+                "=== YÊU CẦU BÀI VIẾT ===\n"
+                "1. Mở đầu: Giới thiệu chủ đề và nêu quan điểm cá nhân (1-2 câu)\n"
+                "2. Thân bài: Phân tích luận điểm, dùng dẫn chứng CỤ THỂ từ nguồn tin (trích dẫn nguồn kèm tên báo)\n"
+                "3. Mỗi luận điểm là 1 đoạn ngắn 2-4 câu, có ghi nguồn rõ ràng (VD: Theo VnExpress, ...)\n"
+                "4. Kết luận: Tổng kết quan điểm, gợi mở suy nghĩ\n"
+                "5. Cuối bài: Ghi danh sách nguồn tham khảo\n\n"
+                "Viết tự nhiên, mạch lạc, giọng văn báo chí - phân tích. Độ dài: 300-600 từ."
+            )
+            ai_text = await ai_ext.qwen_generate(prompt, max_tokens=2000)
     except:
         pass
     
     if not ai_text or len(ai_text) < 100:
-        ai_text = "## Quan điểm cá nhân\n\n" + opinion + "\n\n"
-        if all_sources:
-            ai_text += "## Nguồn tham khảo\n\n"
-            for i, s in enumerate(all_sources[:5]):
-                ai_text += str(i+1) + ". " + s.get('title', '') + " (" + s.get('via', '') + ")\n"
+        # Fallback: build article manually
+        ai_text = "## " + title + "\n\n"
+        ai_text += opinion + "\n\n"
+        for i, sd in enumerate(source_details[:5]):
+            ai_text += "### " + sd.get("title", f"Nguồn {i+1}") + "\n"
+            for p in sd.get("paragraphs", [])[:3]:
+                ai_text += p[:250] + "\n"
+            ai_text += "*Nguồn: " + sd.get("via", "") + "*\n\n"
+        ai_text += "\n---\n*Bài viết tổng hợp từ quan điểm cá nhân và các nguồn tin liên quan*"
+    
+    # Tạo slides từ bài viết
+    slide_parts = []
+    if ai_text:
+        paragraphs = [p.strip() for p in ai_text.split("\n") if p.strip() and len(p.strip()) > 40]
+        current_para = ""
+        para_count = 0
+        for p in paragraphs:
+            if p.startswith("## ") or p.startswith("### ") or p.startswith("---"):
+                if current_para and para_count < 6:
+                    slide_parts.append(current_para)
+                    para_count += 1
+                current_para = ""
+            elif not p.startswith("*") and not p.startswith("- "):
+                if len(p) > 80:
+                    if current_para:
+                        current_para += "\n\n" + p
+                    else:
+                        current_para = p
+        if current_para and para_count < 6:
+            slide_parts.append(current_para)
+    
+    if len(slide_parts) < 2:
+        # Create slides from opinion + sources
+        slide_parts = [opinion[:300]]
+        for sd in source_details[:4]:
+            slide_parts.append(sd.get("title", "")[:200] + "\n\n" + (sd.get("paragraphs", [""])[0][:200] if sd.get("paragraphs") else ""))
     
-    if custom_slides and len(custom_slides) > 0:
-        slides = []
-        for i, slide in enumerate(custom_slides):
-            slides.append({
-                "text": slide.get("text", ""),
-                "image": slide.get("image", ""),
-                "index": i + 1
-            })
-    else:
-        slides = []
+    slides = []
+    total = min(len(slide_parts), 6)
+    for i in range(total):
+        img = source_images[i] if i < len(source_images) else ""
         slides.append({
-            "text": opinion[:250] if len(opinion) > 250 else opinion,
-            "image": source_images[0] if source_images else "",
-            "index": 1
+            "text": slide_parts[i],
+            "image": img,
+            "index": i + 1
         })
-        for i, src in enumerate(all_sources[:5]):
-            slide_text = src.get("title", "")[:200]
-            if src.get("via"):
-                slide_text += "\n\nNguồn: " + src.get('via')
-            slides.append({
-                "text": slide_text,
-                "image": source_images[i+1] if i+1 < len(source_images) else "",
-                "index": i + 2
-            })
-    
-    lang, emotion = detect_language_and_emotion(title, ai_text)
-    voice = get_voice_for_content(title, ai_text)
     
-    post = {
-        "id": str(int(time.time() * 1000)) + str(_random2.randint(100, 999)),
+    preview = {
         "title": title,
         "text": ai_text,
-        "img": source_images[0] if source_images else "",
-        "url": "",
-        "kind": "personal_opinion",
-        "slides": slides,
+        "opinion": opinion,
         "images": source_images[:10],
-        "video": "",
-        "voice": voice,
-        "emotion": emotion,
-        "language": lang,
-        "ts": int(time.time()),
-        "sources": all_sources[:5]
+        "sources": source_details[:5],
+        "slides": slides
     }
     
-    posts = _load_wall_posts()
-    posts.insert(0, post)
-    _save_wall_posts(posts)
-    
-    return JSONResponse({"post": post, "slides": slides})
+    return JSONResponse({"preview": preview})
 
 
-@app.post("/api/personal_post/preview")
-async def api_personal_post_preview(request: Request):
-    """Preview personal post before publishing."""
+@app.post("/api/personal_post")
+async def api_personal_post(request: Request):
+    """Create and save personal opinion post."""
     body = await request.json()
     opinion = _clean(body.get("opinion", ""))
     selected_topics = body.get("selected_topics", []) or []
     selected_sources = body.get("selected_sources", []) or []
+    custom_title = body.get("custom_title", "")
+    custom_slides = body.get("custom_slides", [])
     
     if not opinion or len(opinion) < 10:
-        return JSONResponse({"error": "Quan điểm cá nhân quá ngắn"}, status_code=400)
+        return JSONResponse({"error": "Quan điểm cá nhân quá ngắn (cần ít nhất 10 ký tự)"}, status_code=400)
     
     if not selected_topics:
         hot = _get_hot_topics()
@@ -1616,68 +1649,152 @@ async def api_personal_post_preview(request: Request):
             if s.get("url") and s["url"] not in seen_urls:
                 seen_urls.add(s["url"])
                 all_sources.append(s)
-                if len(all_sources) >= 8:
+                if len(all_sources) >= 6:
                     break
-        if len(all_sources) >= 8:
+        if len(all_sources) >= 6:
             break
     
     for src in selected_sources:
         if src.get("url") and src["url"] not in seen_urls:
             all_sources.insert(0, src)
     
+    source_details = []
     source_images = []
-    for src in all_sources[:6]:
+    for src in all_sources[:5]:
         url = src.get("url", "")
-        if url:
-            try:
-                art = _scrape_article_for_rewrite(url)
-                if art and art.get("og_image"):
-                    img = art.get("og_image")
-                    if any(x in img for x in ["cdnphoto.dantri", "refooty", "vnexpress", "vcdn"]):
+        if not url:
+            continue
+        try:
+            art = _scrape_article_for_rewrite(url)
+            if art:
+                src_detail = {
+                    "title": art.get("title", src.get("title", "")),
+                    "url": url,
+                    "via": src.get("via", ""),
+                    "paragraphs": art.get("paragraphs", [])[:6],
+                    "images": art.get("images", [])[:2],
+                    "og_image": art.get("og_img", "")
+                }
+                source_details.append(src_detail)
+                for img in art.get("images", [])[:2]:
+                    if any(x in img for x in ["cdnphoto.dantri", "vnexpress", "vcdn", "refooty"]):
                         img = "/api/proxy/img?url=" + _quote2(img, safe="")
                     source_images.append(img)
-            except:
-                pass
+        except:
+            pass
     
-    import re
-    opinion_words = re.findall(r"[A-Za-zÀ-ỹ0-9]+", opinion)
-    title_words = opinion_words[:8] if len(opinion_words) >= 8 else opinion_words[:4]
-    title = " ".join([w[0].upper() + w[1:] for w in title_words]) if title_words else "Quan điểm cá nhân"
-    title = title[:80]
-    
-    sources_str = "\n".join([f"- {s.get('title', '')}" for s in all_sources[:5]])
-    prompt = "Tóm tắt quan điểm + tham khảo nguồn tin:\n\nQuan điểm: " + opinion[:2000] + "\n\nNguồn: " + sources_str + "\n\nTạo 4-6 ý slide ngắn gọn."
+    # Title
+    if custom_title:
+        title = custom_title[:80]
+    else:
+        opinion_words = re.findall(r"[A-Za-zÀ-ỹ0-9]+", opinion)
+        title_words = opinion_words[:8] if len(opinion_words) >= 8 else opinion_words[:4]
+        title = " ".join([w[0].upper() + w[1:] for w in title_words]) if title_words else "Quan điểm cá nhân"
+        title = title[:80]
     
+    # AI sinh bài
     ai_text = None
     try:
         import ai_ext
-        if hasattr(ai_ext, "qwen_generate"):
-            ai_text = await ai_ext.qwen_generate(prompt, max_tokens=800)
+        if hasattr(ai_ext, 'qwen_generate'):
+            source_context = ""
+            for i, sd in enumerate(source_details[:5]):
+                src_title = sd.get("title", "")
+                src_via = sd.get("via", "")
+                src_paras = sd.get("paragraphs", [])
+                source_context += f"\nNguồn {i+1}: {src_title} ({src_via})\n"
+                for j, p in enumerate(src_paras[:3]):
+                    source_context += f"  - {p[:300]}\n"
+            prompt = (
+                "Bạn là nhà báo tiếng Việt. Viết bài phân tích dựa trên quan điểm cá nhân và các nguồn tin sau.\n\n"
+                "=== QUAN ĐIỂM ===\n" + opinion[:2000] + "\n\n"
+                "=== NGUỒN TIN ===\n" + source_context + "\n\n"
+                "Yêu cầu:\n- Mở đầu: giới thiệu chủ đề + nêu quan điểm\n- Thân bài: phân tích có dẫn chứng từ nguồn (ghi rõ nguồn)\n- Mỗi đoạn 2-4 câu\n- Kết luận: tổng kết\n- Cuối: danh sách nguồn\n\nViết tự nhiên, 300-600 từ."
+            )
+            ai_text = await ai_ext.qwen_generate(prompt, max_tokens=2000)
     except:
         pass
     
-    if not ai_text or len(ai_text) < 50:
-        ai_text = opinion[:300]
+    if not ai_text or len(ai_text) < 100:
+        ai_text = "## " + title + "\n\n" + opinion + "\n\n"
+        for i, sd in enumerate(source_details[:5]):
+            ai_text += "### " + sd.get("title", "") + "\n"
+            for p in sd.get("paragraphs", [])[:2]:
+                ai_text += p[:250] + "\n"
+            ai_text += "\n---\n*Nguồn: " + sd.get("via", "") + "*\n\n"
+    
+    # Tạo slides
+    if custom_slides and len(custom_slides) > 0:
+        slides = []
+        for i, slide in enumerate(custom_slides):
+            slides.append({
+                "text": slide.get("text", ""),
+                "image": slide.get("image", ""),
+                "index": i + 1
+            })
+    else:
+        slide_parts = []
+        if ai_text:
+            paragraphs = [p.strip() for p in ai_text.split("\n") if p.strip() and len(p.strip()) > 40]
+            current = ""
+            count = 0
+            for p in paragraphs:
+                if p.startswith("## ") or p.startswith("### ") or p.startswith("---"):
+                    if current and count < 6:
+                        slide_parts.append(current)
+                        count += 1
+                    current = ""
+                elif len(p) > 80:
+                    if current:
+                        current += "\n\n" + p
+                    else:
+                        current = p
+            if current and count < 6:
+                slide_parts.append(current)
+        
+        if len(slide_parts) < 2:
+            slide_parts = [opinion[:300]]
+            for sd in source_details[:5]:
+                slide_parts.append(sd.get("title", "")[:200] + "\n" + (sd.get("paragraphs", [""])[0][:200] if sd.get("paragraphs") else ""))
+        
+        slides = []
+        total = min(len(slide_parts), 6)
+        for i in range(total):
+            img = source_images[i] if i < len(source_images) else ""
+            slides.append({
+                "text": slide_parts[i],
+                "image": img,
+                "index": i + 1
+            })
+    
+    lang, emotion = detect_language_and_emotion(title, ai_text)
+    voice = get_voice_for_content(title, ai_text)
     
-    preview = {
+    post = {
+        "id": str(int(time.time() * 1000)) + str(_random2.randint(100, 999)),
         "title": title,
         "text": ai_text,
-        "opinion": opinion,
-        "images": source_images,
-        "sources": all_sources[:5],
-        "slides": [
-            {"text": opinion[:250], "image": source_images[0] if source_images else ""},
-            *[
-                {"text": s.get("title", "")[:200], "image": source_images[i+1] if i+1 < len(source_images) else ""}
-                for i, s in enumerate(all_sources[:4])
-            ]
-        ]
+        "img": source_images[0] if source_images else "",
+        "url": "",
+        "kind": "personal_opinion",
+        "slides": slides,
+        "images": source_images[:10],
+        "video": "",
+        "voice": voice,
+        "emotion": emotion,
+        "language": lang,
+        "ts": int(time.time()),
+        "sources": source_details[:5]
     }
     
-    return JSONResponse({"preview": preview})
+    posts = _load_wall_posts()
+    posts.insert(0, post)
+    _save_wall_posts(posts)
+    
+    return JSONResponse({"post": post, "slides": slides})
 
 
-# ===== END PERSONAL OPINION POST =====
+# ===== END PERSONAL OPINION POST v2 =====
 
 def _bg():
     time.sleep(15)