1
// by 鈴奈咲桜
2
import ical from "node-ical";
3
import schedule from "node-schedule";
4
import axios from "axios";
5
import fs from "fs";
6

7
const icsPath = "./kebiao.ics"; // 你的课表文件
8
const webhookUrl =
9
  "https://your.wechat.webhook"; // webhook地址
10

11
const data = fs.readFileSync(icsPath, "utf8");
12
const events = ical.parseICS(data);
13

14
console.log("==== 上课提醒任务 ====");
15

16
let upcoming = []; // 保存未来所有提醒
17
for (let k in events) {
18
  const ev = events[k];
19
  if (ev.type === "VEVENT") {
20
    let startTimes = [];
21
    if (ev.rrule) {
22
      startTimes = ev.rrule.all();
23
    } else if (ev.start) {
24
      startTimes = [ev.start];
25
    }
26

27
    for (let start of startTimes) {
28
      const remindTimes = [
29
        new Date(start.getTime() - 30 * 60 * 1000), // 提前 30 分钟
30
        new Date(start.getTime() - 15 * 60 * 1000), // 提前 15 分钟
31
      ];
32

33
      for (let remindTime of remindTimes) {
34
        if (remindTime > new Date()) {
35
          upcoming.push({ ev, start, remindTime });
36
        }
37
      }
38
    }
39
  }
40
}
41

42
// 按提醒时间排序
43
upcoming.sort((a, b) => a.remindTime - b.remindTime);
44

45
if (upcoming.length === 0) {
46
  console.log("近期没有需要提醒的课程。");
47
} else {
48
  // 最近的一次提醒
49
  const first = upcoming[0];
50
  console.log(
51
    `最近提醒: ${first.ev.summary} | 上课时间: ${first.start.toLocaleString()} | 提醒时间: ${first.remindTime.toLocaleString()}`
52
  );
53

54
  // 启动时推送一次测试提醒
55
  await sendReminder(first.ev, first.start, true);
56

57
  // 注册所有提醒
58
  for (const { ev, start, remindTime } of upcoming) {
59
    schedule.scheduleJob(remindTime, () => sendReminder(ev, start, false));
60
  }
61
}
62

63
console.log("========================");
64

65
async function sendReminder(ev, start, isTest = false) {
66
  const header = isTest ? "[本次为测试提醒（可以不理会）]\n" : "**上课提醒**\n";
67
  const text =
68
    `${header}` +
69
    `课程：${ev.summary}\n` +
70
    `地点：${ev.location}\n` +
71
    `时间：${start.toLocaleString()}`;
72

73
  const payload = {
74
    msgtype: "markdown",
75
    markdown: {
76
      content: text,
77
    },
78
  };
79

80
  try {
81
    const res = await axios.post(webhookUrl, payload, {
82
      headers: { "Content-Type": "application/json" },
83
    });
84
    console.log("提醒已发送:", text);
85
    console.log("服务器返回:", res.data);
86
  } catch (err) {
87
    console.error("发送失败:", err.message);
88
    if (err.response) {
89
      console.error("响应状态:", err.response.status);
90
      console.error("响应内容:", err.response.data);
91
    }
92
  }
93
}