Discord 用户
     │
     ▼
┌─────────────────────────────────────────┐
│            OpenCLAW Bot                 │
├─────────────────────────────────────────┤
│  欢迎系统  │  问答系统  │  监控系统  │  活动系统  │
└─────────────────────────────────────────┘
     │
     ▼
┌─────────────────────────────────────────┐
│         知识库 + AI 分析                 │
└─────────────────────────────────────────┘

from openclaw import DiscordBot
import discord

bot = DiscordBot(
    token="your-discord-token",
    intents=[
        discord.Intents.guilds,
        discord.Intents.members,
        discord.Intents.messages,
        discord.Intents.message_content
    ]
)

# 设置命令前缀
bot.command_prefix = "!"

@bot.event("member_join")
async def welcome(member):
    # 发送欢迎消息
    welcome_channel = bot.get_channel("123456789")

    embed = discord.Embed(
        title=f"👋 欢迎 {member.name} 加入！",
        description="""
        这里是技术交流社区，请先看看：

        📖 社区规则：#规则
        ❓ 常见问题：#FAQ
        💬 交流频道：#general

        有问题随时问我～
        """,
        color=discord.Color.blue()
    )

    await welcome_channel.send(embed=embed)

    # 发送私聊欢迎
    try:
        dm = await member.create_dm()
        await dm.send("""
        🎉 欢迎加入我们的社区！

        为了让你更快融入，这里有一些小贴士：

        1. 自我介绍：发送 !intro 来创建你的个人资料
        2. 技术栈：在个人资料中标注你擅长的领域
        3. 提问礼仪：描述清楚问题背景和已尝试的方案

        祝你在这里玩得开心！
        """)
    except:
        pass

from openclaw import KnowledgeBase

kb = KnowledgeBase()

# 预置常见问题
kb.add("如何加入会员？", "点击群公告的会员链接，年费 199 元")
kb.add("怎么提问？", "请描述：1.问题背景 2.你尝试了什么 3.具体报错信息")
kb.add("能发广告吗？", "不能！违者直接移出并拉黑")

@bot.event("message")
async def auto_reply(message):
    # 忽略机器人消息
    if message.author.bot:
        return

    # 搜索知识库
    answer = kb.search(message.content)

    if answer and len(message.content) > 10:
        # 置信度高于 80% 时自动回复
        if answer.confidence > 0.8:
            await message.reply(answer.text)

# 多频道欢迎
@bot.event("member_join")
async def smart_welcome(member):
    # 根据用户角色发送不同欢迎语
    if member.is_bot:
        await bot.send_welcome(member, "bot")
    else:
        await bot.send_welcome(member, "human")

    # 自动分配频道权限
    await member.add_roles("新手")

    # 发送新手任务
    await member.send("""
    🌟 新手任务：
    1. 完成自我介绍 (!intro)
    2. 绑定技术栈 (!stack set python)
    3. 介绍一个你喜欢的工具 (!share)

    完成任务可获得：
    - 解锁更多频道
    - 获得"活跃成员"标签
    """)

# 敏感词过滤
SENSITIVE_WORDS = ["广告", "免费", "加微信", "扫码"]

@bot.event("message")
async def detect_spam(message):
    # 检测广告
    for word in SENSITIVE_WORDS:
        if word in message.content and "http" in message.content:
            await message.delete()
            await message.author.warn("检测到广告内容，已删除")
            await bot.log(f"广告检测: {message.author} - {message.content[:50]}")
            return

    # 检测刷屏
    recent = await message.channel.history(limit=10)
    if len([m for m in recent if m.author == message.author]) > 5:
        await message.author.timeout(minutes=5, reason="刷屏检测")

@bot.command("活动")
async def create_event(ctx, *args):
    # 创建周末分享活动
    event = await bot.create_event(
        title="周末 AI 工具分享会",
        description="每人分享 3 个自己常用的 AI 工具",
        start_time="2026-03-28 15:00",
        duration_minutes=120,
        max_participants=20
    )

    await ctx.send(f"活动已创建！报名请回复：!报名 {event.id}")

# 报名功能
@bot.command("报名")
async def join_event(ctx, event_id):
    result = await bot.add_participant(event_id, ctx.author)
    if result.success:
        await ctx.send(f"报名成功！已加入活动 {event.title}")
    else:
        await ctx.send(f"报名失败：{result.error}")

@bot.command("统计")
async def stats(ctx):
    # 生成社区统计
    report = await bot.get_community_report()

    await ctx.send(f"""
    📊 社区统计

    成员总数: {report.total_members}
    今日活跃: {report.today_active}
    本周新增: {report.week_new}

    频道活跃 Top 3:
    {report.top_channels}

    今日问题解答: {report.questions_answered}
    """)

# 跟踪用户行为
@bot.event("message")
async def track_user(message):
    if not message.author.bot:
        await bot.update_user_profile(
            user_id=message.author.id,
            activity=message.channel.name,
            topics=extract_topics(message.content)
        )

# 根据用户兴趣推荐内容
@bot.command("推荐")
async def recommend(ctx):
    user_profile = await bot.get_user_profile(ctx.author.id)

    recommended = await bot.recommend(
        user_interests=user_profile.interests,
        limit=5
    )

    await ctx.send("为你推荐的内容：")
    for item in recommended:
        await ctx.send(f"- {item.title} (#{item.channel})")

# 检测用户情绪
@bot.event("message")
async def detect_mood(message):
    mood = await bot.detect_mood(message.content)

    if mood == "frustrated":
        # 用户 frustrated，转人工客服
        await bot.notify_admin(f"用户 {message.author} 似乎遇到了问题")