class AICommunityManager:
    def __init__(self):
        self.ai = QwenAPI()
        self.scheduler = ContentScheduler()
        self.user_db = UserDatabase()
    
    def daily_operation(self, group_id):
        """每日社群运营流程"""
        
        # 1. 早安问候（8:00）
        morning_greeting = self.generate_greeting("morning", group_id)
        self.send_message(group_id, morning_greeting)
        
        # 2. 干货分享（10:00）
        content = self.generate_daily_content(group_id)
        self.send_message(group_id, content)
        
        # 3. 互动话题（14:00）
        topic = self.generate_discussion_topic(group_id)
        self.send_message(group_id, topic)
        
        # 4. 产品种草（16:00）
        promotion = self.generate_soft_promotion(group_id)
        self.send_message(group_id, promotion)
        
        # 5. 晚间总结（21:00）
        summary = self.generate_daily_summary(group_id)
        self.send_message(group_id, summary)
    
    def generate_daily_content(self, group_id):
        """生成每日干货内容"""
        # 获取群主题和用户画像
        group_info = self.get_group_info(group_id)
        
        prompt = f"""
        为"{group_info['theme']}"主题社群生成今日干货分享。
        
        群成员画像：{group_info['member_profile']}
        近期热门话题：{group_info['recent_topics']}
        
        内容要求：
        1. 实用性强，看完就能用
        2. 长度适中（200-300字）
        3. 格式清晰（分点+emoji）
        4. 结尾引导互动（"你们觉得呢？"）
        5. 不要有广告感
        6. 语气亲切，像群里的大佬分享经验
        """
        
        return self.ai.call(prompt)
    
    def auto_reply(self, group_id, message, sender):
        """智能自动回复"""
        # 获取上下文
        context = self.get_conversation_context(group_id, limit=10)
        user_profile = self.user_db.get_profile(sender)
        
        # 判断是否需要回复
        should_reply = self.should_respond(message, context)
        if not should_reply:
            return None
        
        prompt = f"""
        你是社群助手"小助"，请回复以下消息：
        
        群主题：{self.get_group_info(group_id)['theme']}
        发送者：{user_profile['name']}（{user_profile['level']}）
        消息内容：{message}
        对话上下文：{context}
        
        回复要求：
        1. 如果是提问：给出有用的回答
        2. 如果是闲聊：适当互动，活跃气氛
        3. 如果是广告：礼貌提醒群规
        4. 如果涉及产品：自然引导到产品页面
        5. 语气：亲切、专业、有人情味
        6. 长度：20-50字
        """
        
        return self.ai.call(prompt)
    
    def user_segmentation(self, group_id):
        """AI用户分层"""
        members = self.get_group_members(group_id)
        
        for member in members:
            behavior = self.analyze_behavior(member)
            
            # AI打标签
            tags = self.ai.call(f"""
            根据以下用户行为数据，为用户打标签：
            
            用户行为：
            - 发言频率：{behavior['message_frequency']}/天
            - 活跃时段：{behavior['active_hours']}
            - 关注话题：{behavior['interested_topics']}
            - 点击链接：{behavior['link_clicks']}
            - 购买记录：{behavior['purchases']}
            
            标签体系：
            - 活跃度：高活跃/中活跃/低活跃/沉默
            - 购买意向：强意向/弱意向/无意向
            - 价值等级：高价值/中价值/低价值
            - 兴趣标签：（根据行为判断）
            
            输出JSON格式的标签。
            """)
            
            self.user_db.update_tags(member["id"], json.loads(tags))

class AIPrecisionConversion:
    def __init__(self):
        self.ai = QwenAPI()
        self.user_db = UserDatabase()
    
    def identify_purchase_intent(self, user_id):
        """识别购买意向"""
        behavior = self.user_db.get_recent_behavior(user_id, days=7)
        
        signals = {
            "询问价格": 0.8,
            "查看产品页": 0.6,
            "收藏商品": 0.7,
            "加入购物车": 0.9,
            "咨询售后": 0.5,
            "对比竞品": 0.7
        }
        
        intent_score = self.calculate_intent_score(behavior, signals)
        return intent_score
    
    def personalized_promotion(self, user_id, product):
        """个性化促销推送"""
        profile = self.user_db.get_profile(user_id)
        intent = self.identify_purchase_intent(user_id)
        
        if intent < 0.3:
            # 低意向：种草内容
            return self.generate_seeding_content(product, profile)
        elif intent < 0.7:
            # 中意向：案例+优惠
            return self.generate_case_study(product, profile)
        else:
            # 高意向：限时优惠+紧迫感
            return self.generate_urgency_offer(product, profile)
    
    def generate_urgency_offer(self, product, profile):
        """生成紧迫感促销文案"""
        prompt = f"""
        为以下高意向用户生成促销私信：
        
        用户画像：{profile}
        产品信息：{product}
        
        文案要求：
        1. 开头：称呼用户名，表示专属优惠
        2. 中间：强调产品价值+限时优惠
        3. 结尾：制造紧迫感（限量/限时/涨价）
        4. 附带购买链接
        5. 语气：像朋友推荐，不像销售
        6. 长度：50-100字
        """
        return self.ai.call(prompt)
    
    def automated_follow_up(self, user_id, stage):
        """自动化跟进流程"""
        follow_up_sequences = {
            "new_member": [
                {"day": 0, "action": "welcome_message"},
                {"day": 1, "action": "value_content"},
                {"day": 3, "action": "case_study"},
                {"day": 7, "action": "soft_promotion"}
            ],
            "interested": [
                {"day": 0, "action": "detailed_info"},
                {"day": 1, "action": "testimonial"},
                {"day": 2, "action": "limited_offer"},
                {"day": 3, "action": "last_chance"}
            ],
            "purchased": [
                {"day": 0, "action": "thank_you"},
                {"day": 3, "action": "usage_tips"},
                {"day": 7, "action": "feedback_request"},
                {"day": 14, "action": "upsell"}
            ]
        }
        
        sequence = follow_up_sequences.get(stage, [])
        return sequence

class AILeadGeneration:
    def __init__(self):
        self.ai = QwenAPI()
        self.platforms = ["xiaohongshu", "douyin", "zhihu", "weibo"]
    
    def generate_lead_magnet_content(self, target_audience, platform):
        """生成引流内容"""
        prompt = f"""
        为{platform}平台生成一篇引流内容，目标是吸引{target_audience}加入微信社群。
        
        内容策略：
        1. 提供80%的价值（让用户觉得有用）
        2. 留20%的悬念（引导加群获取完整版）
        3. 自然植入"加群"的钩子
        4. 符合{platform}的内容调性
        
        引流钩子选择：
        - 免费资料包（PDF/模板/工具）
        - 免费直播/分享会
        - 限时优惠券
        - 专属社群福利
        
        请生成完整的引流内容。
        """
        return self.ai.call(prompt)
    
    def create_welcome_flow(self, new_member):
        """新成员欢迎流程"""
        welcome_msg = self.ai.call(f"""
        为新加入社群的成员生成欢迎消息：
        
        成员信息：{new_member}
        社群主题：AI变现实战
        
        欢迎消息要求：
        1. 热情欢迎
        2. 简介社群价值
        3. 引导自我介绍
        4. 告知群规
        5. 推荐必看内容
        """)
        
        return welcome_msg