← 返回 TimeAmber
logo NodeSeekbeta

基于CF worker手动撸一个自动监控补充的自动化通知

rouxyang
rouxyangLv 1楼主Dev
in 技术
#0

使用说明：

1、将代码中的TARGETS替换为你需要监控的页面URL和信息
2、将TELEGRAM_BOT_TOKEN替换为你的Telegram Bot Token
3、将TELEGRAM_CHAT_ID替换为你的Telegram Chat ID
4、在Cloudflare Workers中创建新Worker，粘贴代码

在worker里配置触发器：
在Workers的Triggers页面添加Cron Trigger
设置Cron表达式为* * * * *（每分钟执行）

保存并部署。其他家的补货也可以添加进来~~

最后，祝大家玩的愉快~~

export default {
  async fetch(request, env, ctx) {
    // 默认页面响应
    const html = `
      <!DOCTYPE html>
      <html>
        <head>
          <title>Stock 监控</title>
          <meta charset="UTF-8">
          <style>
            body { font-family: Arial, sans-serif; text-align: center; padding: 50px; }
            h1 { color: #333; }
            p { color: #666; }
          </style>
        </head>
        <body>
          <h1>Stock 监控运行中</h1>
          <p>每 60 秒检查一次新回复，并通过 Telegram 通知。</p>
        </body>
      </html>
    `;
    await handleRequest(env);
    return new Response(html, {
      headers: { 'Content-Type': 'text/html; charset=utf-8' },
      status: 200
    });
  },

  async scheduled(event, env, ctx) {
    ctx.waitUntil(handleRequest(env));
  },

  
};

async function handleRequest(request) {
  // Telegram Bot配置
  const TELEGRAM_BOT_TOKEN = 'TELEGRAM_BOT_TOKEN';
  const TELEGRAM_CHAT_ID = 'TELEGRAM_CHAT_ID';
  const TELEGRAM_API = `https://api.telegram.org/bot${TELEGRAM_BOT_TOKEN}/sendMessage`;

  // 目标地址、对应的缺货标志词、名称和描述
  const TARGETS = [
    {
      name: 'hostdzire 32刀',
      url: 'https://hostdzire.com/billing/index.php?rp=/store/indian-cloudvps/in-cloudvps-5-nodeseek-special',
      outOfStockText: 'out of stock',
      description: `hostdzire 32刀闪购补货了。 `
    },
    {
      name: 'colocrossing E3-2124G',
      url: 'https://portal.colocrossing.com/register/order/service/592',
      outOfStockText: 'this service is not available',
      description: `colocrossing E3-2124G有货了。`
    }
  ];

  // 转义MarkdownV2特殊字符，仅用于动态内容
  function escapeMarkdown(text) {
    return text.replace(/([_*[\]()~`>#+=|{}!.])/g, '\\$1');
  }

  // 存储有货的目标信息
  const inStockTargets = [];

  async function checkStock() {
    // 记录循环开始
    console.log('Starting stock check for all targets...');
    
    for (const target of TARGETS) {
      console.log(`Checking target: ${target.name} (${target.url})`);
      try {
        // 设置超时（例如 10 秒）
        const controller = new AbortController();
        const timeoutId = setTimeout(() => controller.abort(), 10000);
        
        const response = await fetch(target.url, {
          headers: {
            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36'
          },
          signal: controller.signal
        });
        
        clearTimeout(timeoutId);
        
        if (!response.ok) {
          throw new Error(`HTTP error! Status: ${response.status}`);
        }
        
        const text = await response.text();
        
        // 检查页面是否包含对应的缺货标志词
        if (!text.toLowerCase().includes(target.outOfStockText.toLowerCase())) {
          console.log(`Stock found for ${target.name}`);
          // 添加到有货列表
          inStockTargets.push({
            name: target.name,
            message: `🎉 ` + target.description + `\n\n🔗 ${target.url}`
          });
        } else {
          console.log(`No stock for ${target.name}`);
        }
      } catch (error) {
        console.error(`Error checking ${target.name} (${target.url}):`, error.message);
        // 发送错误通知，仅转义动态内容
        await fetch(TELEGRAM_API, {
          method: 'POST',
          headers: {
            'Content-Type': 'application/json'
          },
          body: JSON.stringify({
            chat_id: TELEGRAM_CHAT_ID,
            text: `监控错误 (${escapeMarkdown(target.name)}): ${escapeMarkdown(error.message)}`,
            parse_mode: 'MarkdownV2'
          })
        });
        // 继续循环，不中断
        continue;
      }
    }

    console.log('Completed stock check for all targets.');
    
    // 如果有货，发送合并通知
    if (inStockTargets.length > 0) {
      console.log(`Found ${inStockTargets.length} targets in stock, sending combined notification...`);
      // 合并消息
      const combinedMessage = inStockTargets.map(target => target.message).join("\n\n ----- \n\n");

      console.log(combinedMessage);
      
      const telegramResponse = await fetch(TELEGRAM_API, {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json'
        },
        body: JSON.stringify({
          chat_id: TELEGRAM_CHAT_ID,
          text: combinedMessage
        })
      });
      
      if (!telegramResponse.ok) {
        console.error(`Failed to send Telegram notification: ${telegramResponse.status}`);
      } else {
        console.log('Combined notification sent successfully.');
      }
    } else {
      console.log('No targets in stock, no notification sent.');
    }
    
    console.log('Completed stock check for all targets.');
  }

  // 立即执行一次检查
  await checkStock();

  // 返回响应（Cloudflare Workers需要返回Response对象）
  return new Response('Monitor running', { status: 200 });

}
5
0
11
引用
回复
内容
预览
对照
AC娘
洋葱头
小黄鸡
App