【关键词研究】
   ├─ 使用AI分析竞争对手关键词
   ├─ 挖掘长尾关键词（搜索量100-1000）
   └─ 评估关键词难度和商业价值
   ↓
【内容规划】
   ├─ 按主题聚类分组
   ├─ 规划内链结构（Topic Cluster）
   └─ 制定发布计划（每天5-10篇）
   ↓
【AI内容生成】
   ├─ 分析TOP3搜索结果结构
   ├─ 生成大纲（匹配搜索意图）
   ├─ 逐段生成内容
   └─ 添加代码示例和图表
   ↓
【SEO优化】
   ├─ 标题优化（含关键词+吸引点击）
   ├─ Meta描述优化
   ├─ 内链自动插入
   └─ Schema标记添加
   ↓
【发布与监控】
   ├─ 自动发布到WordPress/Next.js
   ├─ 提交Sitemap到Google
   └─ 监控排名和流量变化

class AIKeywordResearcher:
    def __init__(self, niche="programming"):
        self.niche = niche
        self.keywords_db = []
    
    def discover_keywords(self, seed_keyword, count=100):
        """从种子关键词发现长尾关键词"""
        prompt = f"""
        你是一个SEO专家，请基于种子关键词"{seed_keyword}"，
        生成{count}个相关的长尾关键词。
        
        要求：
        1. 关键词要具体，搜索意图明确
        2. 优先选择"how to"、"tutorial"、"example"类型
        3. 包含初级、中级、高级难度
        4. 每个关键词附带预估搜索量和竞争度
        
        输出格式（JSON）：
        [
            {{"keyword": "...", "volume": 500, "difficulty": "low", "intent": "informational"}},
            ...
        ]
        """
        
        result = qwen_api.call(prompt)
        keywords = json.loads(result)
        
        # 过滤和排序
        filtered = [kw for kw in keywords if kw["difficulty"] in ["low", "medium"]]
        sorted_kws = sorted(filtered, key=lambda x: x["volume"], reverse=True)
        
        return sorted_kws
    
    def analyze_serp(self, keyword):
        """分析搜索结果页面结构"""
        prompt = f"""
        分析关键词"{keyword}"的搜索意图和TOP结果特征：
        
        1. 搜索意图类型（信息型/导航型/交易型）
        2. 用户期望看到的内容格式（教程/列表/对比/评测）
        3. 建议的文章结构（H2/H3标题）
        4. 建议的文章长度
        5. 需要包含的关键元素（代码示例/图表/视频等）
        """
        
        return qwen_api.call(prompt)
    
    def cluster_keywords(self, keywords):
        """将关键词按主题聚类"""
        prompt = f"""
        将以下关键词按主题聚类，每个聚类确定一个"支柱页面"和多个"子页面"：
        
        关键词列表：{json.dumps(keywords)}
        
        输出格式：
        {{
            "clusters": [
                {{
                    "pillar": "主题名称",
                    "pillar_keyword": "核心关键词",
                    "sub_pages": ["子关键词1", "子关键词2", ...]
                }}
            ]
        }}
        """
        
        return json.loads(qwen_api.call(prompt))

class SEOContentGenerator:
    def __init__(self):
        self.quality_threshold = 0.8
    
    def generate_article(self, keyword, serp_analysis):
        """生成完整的SEO优化文章"""
        
        # Step 1: 生成大纲
        outline = self.generate_outline(keyword, serp_analysis)
        
        # Step 2: 逐段生成内容
        sections = []
        for heading in outline["headings"]:
            section_content = self.generate_section(
                keyword=keyword,
                heading=heading,
                context=sections[-2:] if sections else []
            )
            sections.append(section_content)
        
        # Step 3: 生成元数据
        meta = self.generate_meta(keyword, sections)
        
        # Step 4: 添加内链
        content_with_links = self.add_internal_links(sections)
        
        # Step 5: 质量检查
        quality_score = self.check_quality(content_with_links)
        
        if quality_score < self.quality_threshold:
            # 质量不达标，重新生成
            return self.generate_article(keyword, serp_analysis)
        
        return {
            "title": meta["title"],
            "meta_description": meta["description"],
            "content": content_with_links,
            "word_count": len("".join(sections)),
            "quality_score": quality_score
        }
    
    def generate_outline(self, keyword, serp_analysis):
        """基于SERP分析生成文章大纲"""
        prompt = f"""
        为关键词"{keyword}"生成一篇SEO优化文章的大纲。
        
        SERP分析结果：{serp_analysis}
        
        要求：
        1. H1标题包含关键词，同时吸引点击
        2. H2/H3结构清晰，覆盖用户可能的所有问题
        3. 包含"什么是"、"如何做"、"最佳实践"、"常见问题"等板块
        4. 每个H2下有2-4个H3
        5. 标注每个部分建议的内容类型（文字/代码/表格/图片）
        
        输出JSON格式的大纲。
        """
        
        return json.loads(qwen_api.call(prompt))
    
    def generate_section(self, keyword, heading, context):
        """生成单个章节内容"""
        prompt = f"""
        你正在写一篇关于"{keyword}"的技术教程文章。
        
        当前章节标题：{heading}
        前文摘要：{context}
        
        要求：
        1. 内容专业、准确、有深度
        2. 包含实际代码示例（如果适用）
        3. 语言通俗易懂，适合初中级开发者
        4. 自然融入关键词，不要堆砌
        5. 段落长度适中，每段3-5句话
        6. 使用Markdown格式
        
        请生成这个章节的完整内容（300-500字）。
        """
        
        return qwen_api.call(prompt)
    
    def add_internal_links(self, sections):
        """自动添加内链"""
        # 从已发布文章库中匹配相关文章
        all_content = "\n".join(sections)
        
        prompt = f"""
        在以下文章内容中，找出适合添加内链的位置。
        已有文章列表：{self.get_published_articles()}
        
        文章内容：{all_content[:2000]}
        
        请标注建议添加内链的位置和目标文章。
        """
        
        link_suggestions = qwen_api.call(prompt)
        return self.apply_links(all_content, link_suggestions)

class ContentPublisher:
    def __init__(self, site_url, api_key):
        self.site_url = site_url
        self.api_key = api_key
    
    def batch_publish(self, articles, schedule="daily"):
        """批量定时发布文章"""
        publish_queue = []
        
        for i, article in enumerate(articles):
            # 计算发布时间（每天发布5篇，间隔3小时）
            publish_time = self.calculate_publish_time(i, schedule)
            
            publish_queue.append({
                "article": article,
                "publish_at": publish_time,
                "status": "scheduled"
            })
        
        # 提交到发布队列
        for item in publish_queue:
            self.schedule_post(item)
        
        return publish_queue
    
    def schedule_post(self, item):
        """定时发布单篇文章"""
        payload = {
            "title": item["article"]["title"],
            "content": item["article"]["content"],
            "meta_description": item["article"]["meta_description"],
            "status": "scheduled",
            "publish_date": item["publish_at"],
            "categories": item["article"].get("categories", []),
            "tags": item["article"].get("tags", [])
        }
        
        response = requests.post(
            f"{self.site_url}/api/posts",
            json=payload,
            headers={"Authorization": f"Bearer {self.api_key}"}
        )
        
        return response.json()

class AffiliateContentEngine:
    def __init__(self):
        self.affiliate_programs = {
            "jasper": {"commission": 30, "cookie_days": 30},
            "midjourney": {"commission": 20, "cookie_days": 7},
            "notion_ai": {"commission": 25, "cookie_days": 30},
            "grammarly": {"commission": 20, "cookie_days": 90}
        }
    
    def generate_review_article(self, product_name, category):
        """生成产品评测文章"""
        prompt = f"""
        写一篇关于{product_name}的深度评测文章，用于SEO排名。
        
        文章结构：
        1. 产品概述（是什么、解决什么问题）
        2. 核心功能详解（5-8个功能点）
        3. 实际使用体验（附截图描述）
        4. 优缺点分析（客观公正）
        5. 定价方案对比
        6. 适合人群推荐
        7. 与竞品对比
        8. 总结评分（1-10分）
        
        要求：
        - 文章长度2000-3000字
        - 语言专业但易懂
        - 包含具体数据和使用场景
        - 自然融入CTA（行动号召）
        - SEO优化：关键词密度1-2%
        """
        
        return qwen_api.call(prompt)
    
    def generate_comparison_article(self, products, keyword):
        """生成对比文章"""
        prompt = f"""
        写一篇"{keyword}"的对比评测文章。
        
        对比产品：{products}
        
        文章结构：
        1. 快速推荐（TL;DR）
        2. 评测标准说明
        3. 逐个产品详细评测
        4. 功能对比表格
        5. 价格对比
        6. 不同场景推荐
        7. 最终推荐
        
        要求包含对比表格，每个产品给出评分。
        """
        
        return qwen_api.call(prompt)