Discord.js 机器人自动消息发送与缓存管理教程

const axios = require('axios');
const cheerio = require('cheerio');
const { Client, GatewayIntentBits } = require('discord.js');
const cron = require('node-cron');

// ... (其他初始化代码，例如bot客户端、express服务器、fetchData函数等) ...

const bot = new Client({
  intents: [
    GatewayIntentBits.Guilds,
    GatewayIntentBits.GuildMessages,
    GatewayIntentBits.MessageContent,
  ],
});

let targetGuildId = null; // 存储需要发送自动更新的服务器ID
const NEWS_CHANNEL_ID = '1111638079103574159'; // 目标新闻频道ID
const BASE_URL = 'URL I can not mention because of privacy agreement'; // 基础URL

// 假设 fetchData 和 promptNews 数组已定义并正常工作
let promptNews = []; // 假设这里有新闻数据

// 模拟 fetchData 函数，实际应从网站抓取
const fetchData = async () => {
  console.log('Fetching news data...');
  // 实际中会使用axios和cheerio抓取数据
  promptNews = [
    { title: '最新新闻标题 1', link: '/news/1' },
    { title: '最新新闻标题 2', link: '/news/2' },
  ];
};

// 机器人就绪事件
bot.on('ready', () => {
  console.log(`Logged in as ${bot.user.tag}`);
  fetchData(); // 机器人启动时立即抓取一次数据
});

// 消息创建事件，用于设置 targetGuildId 和处理用户命令
bot.on('messageCreate', async (message) => {
  if (message.author.bot) return; // 忽略机器人自身的消息

  if (message.content.toLowerCase() === 'news' && !targetGuildId) {
    targetGuildId = message.guildId;
    message.reply({ content: '此服务器将接收自动新闻更新。' });
  } else if (message.content.toLowerCase() === 'stop news' && message.guildId === targetGuildId) {
    targetGuildId = null;
    message.reply({ content: '此服务器的自动新闻更新已停止。' });
  } else if (message.content.toLowerCase() === 'news' && message.guildId === targetGuildId) {
    // 假设这里可以触发一次手动新闻发送
    try {
      // 实际中这里可以调用 sendPromptNews 或类似函数
      const newsData = promptNews.map((item) => `${item.title}\n${BASE_URL}${item.link}`);
      newsData.forEach((data) => {
        message.reply({ content: `最新新闻摘要：\n\n${data}` });
      });
    } catch (error) {
      console.error('手动获取新闻时发生错误:', error);
      message.reply('获取新闻摘要时发生错误。');
    }
  }
});

/**
 * 发送自动新闻更新到指定频道。
 * 使用 fetch 确保获取最新的服务器和频道信息。
 */
const sendPromptNews = async () => {
  if (targetGuildId) {
    try {
      // 1. 使用 bot.guilds.fetch 获取服务器，确保数据最新
      const guild = await bot.guilds.fetch(targetGuildId);
      if (!guild) {
        console.error(`错误：未找到ID为 ${targetGuildId} 的服务器。`);
        return;
      }

      // 2. 使用 guild.channels.fetch 获取所有频道，确保数据最新
      const channels = await guild.channels.fetch();
      // 查找目标新闻频道
      const channel = channels.find(
        (ch) => ch.type === GatewayIntentBits.GuildMessages && ch.id === NEWS_CHANNEL_ID
      );

      if (!channel) {
        console.error(`错误：在服务器 ${guild.name} 中未找到ID为 ${NEWS_CHANNEL_ID} 的文本频道。`);
        return;
      }

      // 3. 抓取最新新闻数据（或从已缓存的 promptNews 中获取）
      // 实际应用中，这里可以再次调用 fetchData() 或从外部API获取
      await fetchData(); // 确保 promptNews 是最新的

      if (promptNews.length === 0) {
        console.log('没有新的新闻可供发送。');
        return;
      }

      // 4. 格式化并发送新闻
      const newsData = promptNews.map((item) => `${item.title}\n${BASE_URL}${item.link}`);
      for (const data of newsData) {
        await channel.send(`突发自动新闻：\n\n${data}`);
      }
      console.log(`成功发送 ${newsData.length} 条新闻到频道 ${channel.name}。`);

    } catch (error) {
      console.error('发送自动新闻时发生错误:', error);
      // 如果发生错误，尝试通知目标频道 (如果频道对象已获取)
      const guild = bot.guilds.cache.get(targetGuildId);
      if (guild) {
        const channel = guild.channels.cache.get(NEWS_CHANNEL_ID);
        if (channel) {
          channel.send('获取或发送新闻更新时发生错误。');
        }
      }
    }
  } else {
    console.log('未设置目标服务器ID，跳过自动新闻发送。');
  }
};

// 使用 cron.schedule 安排每10秒发送一次新闻
cron.schedule('*/10 * * * * *', () => {
  console.log('触发自动新闻发送任务...');
  sendPromptNews();
});

// 机器人登录
bot.login('YOUR_BOT_TOKEN'); // 替换为你的机器人Token