From 467928f2e238af7ed38cc814acdc6521aae4f51f Mon Sep 17 00:00:00 2001
From: EchoZenith <60392923+EchoZenith@users.noreply.github.com>
Date: Sun, 24 May 2026 00:29:57 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=96=B0=E5=A2=9ETelegram=E9=80=9A?=
 =?UTF-8?q?=E7=9F=A5=E6=94=AF=E6=8C=81=EF=BC=8C=E6=96=B0=E5=A2=9E=E6=89=8B?=
 =?UTF-8?q?=E5=8A=A8=E5=8F=91=E9=80=81=E6=97=A5=E6=8A=A5=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

1. 新增Telegram机器人通知配置项和实现逻辑
2. 重构通知发送逻辑为统一的sendAllNotifications方法
3. 调整日报定时任务时间为23:30，优化日报内容
4. 后台页面新增手动发送日报按钮和相关接口
5. 优化通知提示文案，兼容多通知渠道
---
 .env.example                   |  7 ++-
 client/src/pages/Dashboard.jsx | 28 ++++++++++-
 server.js                      | 85 +++++++++++++++++++++++++++-------
 3 files changed, 100 insertions(+), 20 deletions(-)

diff --git a/.env.example b/.env.example
index 97cb225..67c869b 100644
--- a/.env.example
+++ b/.env.example
@@ -8,7 +8,12 @@ LOGIN_PASSWORD=你的密码
 # 选填 - 企业微信群机器人 Webhook URL
 WECOM_WEBHOOK_URL=https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=你的key
 
-# 选填 - 电费余额预警阈值（低于此值时发送企业微信通知，设为0或留空关闭）
+# 选填 - Telegram 机器人 Token（从 @BotFather 获取）
+TELEGRAM_BOT_TOKEN=1234567890:ABCdefGHIjklmNOPqrstUVwxyz
+# 选填 - 接收通知的 Telegram 用户 ID（从 @userinfobot 获取）
+TELEGRAM_CHAT_ID=123456789
+
+# 选填 - 电费余额预警阈值（低于此值时发送通知，设为0或留空关闭）
 ALERT_THRESHOLD=20
 
 # 选填 - Cookie 签名密钥
diff --git a/client/src/pages/Dashboard.jsx b/client/src/pages/Dashboard.jsx
index f2bfce1..c5f8ffb 100644
--- a/client/src/pages/Dashboard.jsx
+++ b/client/src/pages/Dashboard.jsx
@@ -86,7 +86,21 @@ export default function Dashboard({ onLogout }) {
       const res = await fetch('/api/test-notify');
       const data = await res.json();
       if (data.success) {
-        message.success('测试消息已发送，请查看企业微信');
+        message.success('测试消息已发送，请检查通知渠道');
+      } else {
+        message.error('发送失败');
+      }
+    } catch {
+      message.error('发送失败');
+    }
+  };
+
+  const handleSendReport = async () => {
+    try {
+      const res = await fetch('/api/send-report');
+      const data = await res.json();
+      if (data.success) {
+        message.success('日报已发送');
       } else {
         message.error('发送失败');
       }
@@ -333,6 +347,18 @@ body { margin: 0; }
             >
               测试通知
             </Button>
+            <Button
+              onClick={handleSendReport}
+              size="small"
+              style={{
+                border: '1px solid var(--border-light)',
+                borderRadius: 20,
+                color: 'var(--text-secondary)',
+                fontSize: 13,
+              }}
+            >
+              发送日报
+            </Button>
             <Button
               icon={<LogoutOutlined />}
               onClick={handleLogout}
diff --git a/server.js b/server.js
index 81fada3..6ec7a57 100644
--- a/server.js
+++ b/server.js
@@ -54,10 +54,21 @@ if (!WECOM_WEBHOOK_URL) {
   console.warn('警告: 环境变量 WECOM_WEBHOOK_URL 未设置，企业微信通知功能将不可用');
 }
 
+const TELEGRAM_BOT_TOKEN = process.env.TELEGRAM_BOT_TOKEN;
+const TELEGRAM_CHAT_ID = process.env.TELEGRAM_CHAT_ID;
+
+if (TELEGRAM_BOT_TOKEN && TELEGRAM_CHAT_ID) {
+  console.log('Telegram 机器人通知已启用');
+} else if (TELEGRAM_BOT_TOKEN || TELEGRAM_CHAT_ID) {
+  console.warn('警告: 需要同时设置 TELEGRAM_BOT_TOKEN 和 TELEGRAM_CHAT_ID 才能使用 Telegram 通知');
+} else {
+  console.log('Telegram 机器人通知未配置');
+}
+
 const ALERT_THRESHOLD = parseFloat(process.env.ALERT_THRESHOLD) || 0;
 
 if (ALERT_THRESHOLD > 0) {
-  console.log(`电费预警: 当余额低于 ¥${ALERT_THRESHOLD} 时将发送企业微信通知`);
+  console.log(`电费预警: 当余额低于 ¥${ALERT_THRESHOLD} 时将发送通知`);
 }
 
 let lastAlertedAmount = null;
@@ -99,6 +110,39 @@ async function sendWecomNotification(content) {
   }
 }
 
+async function sendTelegramNotification(text) {
+  if (!TELEGRAM_BOT_TOKEN || !TELEGRAM_CHAT_ID) return;
+  const tgText = text
+    .replace(/^## (.+)$/gm, '*$1*')
+    .replace(/^> /gm, '')
+    .trim();
+  try {
+    const res = await fetch(`https://api.telegram.org/bot${TELEGRAM_BOT_TOKEN}/sendMessage`, {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({
+        chat_id: TELEGRAM_CHAT_ID,
+        text: tgText,
+        parse_mode: 'Markdown',
+        disable_web_page_preview: true,
+      })
+    });
+    const body = await res.json();
+    if (!body.ok) {
+      console.error(`Telegram 通知发送失败: ${body.description}`);
+    }
+  } catch (err) {
+    console.error('Telegram 通知发送失败:', err.message);
+  }
+}
+
+async function sendAllNotifications(markdownContent, plainText) {
+  await Promise.all([
+    sendWecomNotification(markdownContent),
+    sendTelegramNotification(plainText || markdownContent),
+  ]);
+}
+
 function getLocalDateStr(d) {
   return `${d.getFullYear()}-${String(d.getMonth() + 1).padStart(2, '0')}-${String(d.getDate()).padStart(2, '0')}`;
 }
@@ -156,7 +200,7 @@ async function collectData() {
   const data = await fetchData();
   if (!data) {
     console.log(`[${new Date().toLocaleString()}] 采集失败: 接口请求异常`);
-    await sendWecomNotification(
+    await sendAllNotifications(
       '## 电费采集异常\n\n' +
       `> 时间：${new Date().toLocaleString('zh-CN')}\n\n` +
       '电费接口请求失败，请检查网络或 Cookie 是否过期。'
@@ -189,7 +233,7 @@ async function checkThresholdAndAlert(amount) {
   if (lastAlertedAmount !== null && amount >= lastAlertedAmount) return;
   lastAlertedAmount = amount;
   console.log(`[预警] 余额 ¥${amount} 低于阈值 ¥${ALERT_THRESHOLD}`);
-  await sendWecomNotification(
+  await sendAllNotifications(
     '## 电费余额预警\n\n' +
     `> 时间：${new Date().toLocaleString('zh-CN')}\n\n` +
     `当前余额 **¥${amount.toFixed(2)}**\n\n` +
@@ -370,16 +414,15 @@ cron.schedule('0 * * * *', async () => {
 });
 
 async function sendDailyReport() {
-  const yesterday = new Date();
-  yesterday.setDate(yesterday.getDate() - 1);
-  const dateStr = getLocalDateStr(yesterday);
+  const now = new Date();
+  const dateStr = getLocalDateStr(now);
 
   const records = getRecordsByDate(dateStr);
   if (records.length < 1) {
-    await sendWecomNotification(
+    await sendAllNotifications(
       '## 电费日报\n\n' +
       `> 日期：${dateStr}\n\n` +
-      `昨日无数据记录`
+      `今日无数据记录`
     );
     return;
   }
@@ -388,7 +431,7 @@ async function sendDailyReport() {
   const first = sorted[0];
   const last = sorted[sorted.length - 1];
 
-  const dayBefore = new Date(yesterday);
+  const dayBefore = new Date(now);
   dayBefore.setDate(dayBefore.getDate() - 1);
   const dayBeforeRecords = getRecordsByDate(getLocalDateStr(dayBefore));
   const dayBeforeLast = dayBeforeRecords.length > 0 ? dayBeforeRecords[dayBeforeRecords.length - 1] : null;
@@ -399,14 +442,15 @@ async function sendDailyReport() {
   const cost = Math.round(Math.max(0, baseAmount - last.amount) * 100) / 100;
 
   const hoursSpan = (last.timestamp - first.timestamp) / (1000 * 60 * 60);
-  const avgPower = hoursSpan > 0 ? Math.round((usage / hoursSpan) * 1000) / 1000 : 0;
+  const reportHours = hoursSpan > 0 ? hoursSpan : Math.max(1, (Date.now() - first.timestamp) / 3600000);
+  const avgPower = Math.round((usage / reportHours) * 1000) / 1000;
 
   const latest = getLatestRecord();
 
   let content = '## 电费日报\n\n';
   content += `> 日期：${dateStr}\n\n`;
-  content += `**昨日用电**：${usage.toFixed(2)} 度\n`;
-  content += `**昨日电费**：¥${cost.toFixed(2)}\n`;
+  content += `**今日用电**：${usage.toFixed(2)} 度\n`;
+  content += `**今日电费**：¥${cost.toFixed(2)}\n`;
   content += `**平均功率**：${avgPower.toFixed(3)} kW\n`;
   content += `**数据记录**：${sorted.length} 条\n`;
   if (latest) {
@@ -414,11 +458,11 @@ async function sendDailyReport() {
     content += `**当前剩余余额**：¥${latest.amount.toFixed(2)}\n`;
   }
 
-  await sendWecomNotification(content);
+  await sendAllNotifications(content);
 }
 
-cron.schedule('0 0 * * *', async () => {
-  console.log(`[定时任务] 发送昨日用电报告...`);
+cron.schedule('30 23 * * *', async () => {
+  console.log(`[定时任务] 发送今日用电报告...`);
   await sendDailyReport();
 });
 
@@ -428,12 +472,17 @@ app.get('/api/trigger-collect', requireAuth, async (req, res) => {
 });
 
 app.get('/api/test-notify', requireAuth, async (req, res) => {
-  await sendWecomNotification(
+  await sendAllNotifications(
     '## 电费监控测试消息\n\n' +
     `> 时间：${new Date().toLocaleString('zh-CN')}\n\n` +
-    '如果收到此消息，说明企业微信通知配置正常。'
+    '如果收到此消息，说明推送通知配置正常。'
   );
-  res.json({ success: true, message: '测试消息已发送，请查看企业微信' });
+  res.json({ success: true, message: '测试消息已发送，请检查通知渠道' });
+});
+
+app.get('/api/send-report', requireAuth, async (req, res) => {
+  await sendDailyReport();
+  res.json({ success: true, message: '日报已发送' });
 });
 
 app.get('*', (req, res) => {