// 定义外部变量 let sitename = "VPS到期监控"; // 变量名SITENAME，自定义站点名称，默认为“域名监控” let vpsinfo = ""; // 变量名VPSINFO，填入域名信息json文件直链，必须设置的变量 let tgid = ""; // 变量名TGID，填入TG机器人ID，不需要提醒则不填 let tgtoken = ""; // 变量名TGTOKEN，填入TG的TOKEN，不需要提醒则不填 let days = "5"; // 变量名DAYS，提前几天发送TG提醒，默认为5天，必须为大于0的整数 // 访问绑定的 KV 命名空间 async function sendtgMessage(message, tgid, tgtoken) { if (!tgid || !tgtoken) return; const url = `https://api.telegram.org/bot${tgtoken}/sendMessage`; const params = { chat_id: tgid, text: message, }; try { await fetch(url, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(params), }); } catch (error) { console.error('Telegram 消息推送失败:', error); } } export default { async fetch(request, env) { sitename = env.SITENAME || sitename; vpsinfo = env.VPSINFO || vpsinfo; tgid = env.TGID || tgid; tgtoken = env.TGTOKEN || tgtoken; days = parseInt(env.DAYS || days, 10); // 读取变量VPSINFO中的VPS数据，格式为json if (!vpsinfo) { return new Response("VPSINFO 环境变量未设置", { status: 500 }); } try { const response = await fetch(vpsinfo); if (!response.ok) { throw new Error('Network response was not ok'); } const data = await response.json(); if (!Array.isArray(data)) { throw new Error('JSON 数据格式不正确'); } vpsinfo = data; // 检查即将到期的VPS并发送 Telegram 消息 for (const info of vpsinfo) { const expirationDate = new Date(info.expirationDate); const today = new Date(); const daysRemaining = Math.ceil((expirationDate - today) / (1000 * 60 * 60 * 24)); if (daysRemaining > 0 && daysRemaining <= days) { const message = `[VPS] ${info.country} ${info.system} ${info.type} 将在 ${daysRemaining} 天后到期。到期日期：${info.expirationDate}`; // 在发送通知之前检查是否已经发送过通知 const lastSent = await env.VPS_TG_KV.get(info.system); // 使用KV存储检查上次发送的状态 if (!lastSent || (new Date(lastSent).toISOString().split('T')[0] !== today.toISOString().split('T')[0])) { // 如果没有记录，或者记录的时间不是今天，则发送通知并更新 KV await sendtgMessage(message, tgid, tgtoken); await env.VPS_TG_KV.put(info.system, new Date().toISOString()); // 更新 KV 存储的发送时间 } } } // 处理 generateHTML 的返回值 const htmlContent = await generateHTML(vpsinfo, sitename); return new Response(htmlContent, { headers: { 'Content-Type': 'text/html' }, }); } catch (error) { console.error("Fetch error:", error); return new Response("无法获取或解析VPS的 json 文件", { status: 500 }); } } }; async function generateHTML(vpsinfo, SITENAME) { const rows = await Promise.all(vpsinfo.map(async info => { const registrationDate = new Date(info.registrationDate); const expirationDate = new Date(info.expirationDate); const today = new Date(); const totalDays = (expirationDate - registrationDate) / (1000 * 60 * 60 * 24); const daysElapsed = (today - registrationDate) / (1000 * 60 * 60 * 24); const progressPercentage = Math.min(100, Math.max(0, (daysElapsed / totalDays) * 100)); const daysRemaining = Math.ceil((expirationDate - today) / (1000 * 60 * 60 * 24)); const isExpired = today > expirationDate; const statusColor = isExpired ? '#e74c3c' : '#2ecc71'; const statusText = isExpired ? '已过期' : '正常'; return `