Update from GitHub Actions

components.d.ts

@@ -16,6 +16,7 @@ declare module 'vue' {
     TCard: typeof import('tdesign-vue-next')['Card']
     TCheckbox: typeof import('tdesign-vue-next')['Checkbox']
     TContent: typeof import('tdesign-vue-next')['Content']
+    TDatePicker: typeof import('tdesign-vue-next')['DatePicker']
     TDialog: typeof import('tdesign-vue-next')['Dialog']
     TDivider: typeof import('tdesign-vue-next')['Divider']
     TDrawer: typeof import('tdesign-vue-next')['Drawer']
@@ -26,6 +27,7 @@ declare module 'vue' {
     THeader: typeof import('tdesign-vue-next')['Header']
     TIcon: typeof import('tdesign-vue-next')['Icon']
     TInput: typeof import('tdesign-vue-next')['Input']
+    TInputNumber: typeof import('tdesign-vue-next')['InputNumber']
     TLayout: typeof import('tdesign-vue-next')['Layout']
     TList: typeof import('tdesign-vue-next')['List']
     TListItem: typeof import('tdesign-vue-next')['ListItem']
@@ -34,6 +36,12 @@ declare module 'vue' {
     TMenuItem: typeof import('tdesign-vue-next')['MenuItem']
     TPagination: typeof import('tdesign-vue-next')['Pagination']
     TTable: typeof import('tdesign-vue-next')['Table']
+    TTbody: typeof import('tdesign-vue-next')['Tbody']
+    TTd: typeof import('tdesign-vue-next')['Td']
     TTextarea: typeof import('tdesign-vue-next')['Textarea']
+    TTh: typeof import('tdesign-vue-next')['Th']
+    TThead: typeof import('tdesign-vue-next')['Thead']
+    TTimePicker: typeof import('tdesign-vue-next')['TimePicker']
+    TTr: typeof import('tdesign-vue-next')['Tr']
   }
 }

functions/types.d.ts

@@ -6,7 +6,6 @@ interface KVNamespace {
 }
 
 interface Env {
-  SEND_PASSWORD:string;
   API_TOKEN: string;    // API 访问令牌
   JWT_SECRET: string;   // JWT 密钥
   USER_NAME: string;    // 用户名

functions/utils/feishu.ts

@@ -0,0 +1,407 @@
+import crypto from 'node:crypto';
+import { v4 as uuidv4 } from 'uuid';
+
+// 响应数据的接口定义
+interface TenantAccessTokenResponse {
+    code: number;
+    expire: number;
+    msg: string;
+    tenant_access_token: string;
+}
+
+interface EventHeader {
+    event_id: string;
+    token: string;
+    create_time: string;
+    event_type: string;
+    tenant_key: string;
+    app_id: string;
+}
+
+interface SenderId {
+    open_id: string;
+    union_id: string;
+    user_id: string;
+}
+
+interface Sender {
+    sender_id: SenderId;
+    sender_type: string;
+    tenant_key: string;
+}
+
+interface Message {
+    chat_id: string;
+    chat_type: string;
+    content: string;
+    create_time: string;
+    message_id: string;
+    message_type: string;
+    update_time: string;
+    user_agent: string;
+}
+
+interface EventBody {
+    message: Message;
+    sender: Sender;
+}
+
+export interface EventMessage {
+    schema: string;
+    header: EventHeader;
+    event: EventBody;
+}
+
+/**
+ * 获取飞书租户访问令牌
+ * @param appId 应用 ID
+ * @param appSecret 应用密钥
+ * @returns Promise<TenantAccessTokenResponse>
+ */
+export async function getTenantAccessToken(appId: string, appSecret: string): Promise<TenantAccessTokenResponse> {
+    const url = 'https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal';
+
+    const response = await fetch(url, {
+        method: 'POST',
+        headers: {
+            'Content-Type': 'application/json',
+        },
+        body: JSON.stringify({
+            app_id: appId,
+            app_secret: appSecret,
+        }),
+    });
+
+    if (!response.ok) {
+        throw new Error(`HTTP error! status: ${response.status}`);
+    }
+
+    return await response.json() as TenantAccessTokenResponse
+}
+
+
+
+
+
+
+//https://open.feishu.cn/document/server-docs/event-subscription-guide/event-subscription-configure-/encrypt-key-encryption-configuration-case
+export class AESCipher {
+    private decryptKey: Buffer;
+    private encryptKey: string;
+    constructor(key: string) {
+        this.encryptKey = key;
+        const hash = crypto.createHash('sha256');
+        hash.update(key);
+        this.decryptKey = hash.digest();
+    }
+
+    async decrypt(encrypt: string): Promise<string> {
+        // 将 base64 字符串转换为 Uint8Array
+        const encryptBuffer = Uint8Array.from(atob(encrypt), c => c.charCodeAt(0));
+
+        // 提取 IV (前16字节)
+        const iv = encryptBuffer.slice(0, 16);
+        // 提取加密数据
+        const data = encryptBuffer.slice(16);
+
+        // 从密钥字符串创建 CryptoKey
+        const cryptoKey = await crypto.subtle.importKey(
+            'raw',
+            this.decryptKey,
+            { name: 'AES-CBC' },
+            false,
+            ['decrypt']
+        );
+
+        // 解密
+        const decryptedBuffer = await crypto.subtle.decrypt(
+            {
+                name: 'AES-CBC',
+                iv: iv
+            },
+            cryptoKey,
+            data
+        );
+
+        // 转换为字符串
+        return new TextDecoder().decode(decryptedBuffer);
+    }
+
+    calculateSignature(
+        timestamp: string,
+        nonce: string,
+        body: string
+    ): string {
+        const content = timestamp + nonce + this.encryptKey + body;
+        const sign = crypto.createHash('sha256').update(content).digest('hex');
+        return sign;
+    }
+}
+
+
+
+
+export async function handleAuth(request: Request,verificationToken:string,encryptKey:string ): Promise<Response | EventMessage> {
+
+    const { headers } = request
+    const contentType = headers.get('content-type') || ''
+    if (request.method !== 'POST' || !contentType.includes('application/json')) {
+        return new Response('Invalid request', { status: 400 })
+    }
+    const body: string = await request.text()
+    const cipher = new AESCipher(encryptKey)
+    let data = JSON.parse(body)
+    // 如果是加密事件，进行解密
+    if (data.encrypt) {
+        data = JSON.parse(await cipher.decrypt(data.encrypt))
+    }
+    const signature = headers.get('X-Lark-Signature');
+    //绑定的时候没有signature,所以得判断下
+    if (signature) {
+        const timestamp = headers.get('X-Lark-Request-Timestamp')!;
+        const nonce = headers.get('X-Lark-Request-Nonce')!;
+        const sign = cipher.calculateSignature(timestamp, nonce, body)
+
+        if (sign !== signature) {
+            return new Response('Invalid request', { status: 400 })
+        }
+    }
+
+    // 如果校验通过，返回 challenge 值
+    if (data.type && data.type === 'url_verification') {
+        return new Response(JSON.stringify({ challenge: data.challenge }), {
+            headers: { 'Content-Type': 'application/json' },
+        })
+    }
+
+    if (data.header.token != verificationToken) {
+        return new Response('Invalid request', { status: 400 })
+    }
+
+    return data;
+}
+
+
+// 定义响应接口
+interface MessageResponse {
+    code: number;
+    msg: string;
+    data: {
+        body: {
+            content: string;
+        };
+        chat_id: string;
+        create_time: string;
+        deleted: boolean;
+        message_id: string;
+        msg_type: string;
+        sender: {
+            id: string;
+            id_type: string;
+            sender_type: string;
+            tenant_key: string;
+        };
+        update_time: string;
+        updated: boolean;
+    };
+}
+
+// 定义请求参数接口
+interface MessageRequest {
+    content: string;
+    msg_type: string;
+    receive_id: string;
+    uuid: string;
+}
+
+// 发送消息函数
+//https://open.feishu.cn/document/uAjLw4CM/ukTMukTMukTM/reference/im-v1/message/create
+export async function sendFeishuMessageText(token: string, receive_id: string, content: string): Promise<MessageResponse> {
+    const url = 'https://open.feishu.cn/open-apis/im/v1/messages';
+    try {
+        const response = await fetch(`${url}?receive_id_type=open_id`, {
+            method: 'POST',
+            headers: {
+                'Content-Type': 'application/json',
+                'Authorization': `Bearer ${token}`
+            },
+            body: JSON.stringify({
+                msg_type: "text",
+                content: JSON.stringify({ text: content }),
+                receive_id: receive_id, // 需要配置接收者ID
+                uuid: uuidv4()
+            } as MessageRequest)
+        });
+
+        if (!response.ok) {
+            throw new Error(`HTTP error! status: ${response.status}, ${await response.text()}`);
+        }
+        const data: MessageResponse = await response.json() as MessageResponse;
+
+        return data;
+    } catch (error) {
+        console.error('发送消息失败:', error);
+        throw error;
+    }
+}
+
+
+
+
+interface LarkCardRequest {
+    type: string;
+    data: string;
+}
+interface LarkCardResponse {
+    code: number;
+    data: {
+        card_id: string;
+    };
+    msg: string;
+}
+
+//第一步创建卡片
+//https://open.feishu.cn/document/uAjLw4CM/ukzMukzMukzM/feishu-cards/streaming-updates-openapi-overview#5ac65a50
+export async function sendFeishuCreateCard(token: string, title: string, content: string, element_id: string = "markdown_content"): Promise<LarkCardResponse> {
+
+    const url = 'https://open.feishu.cn/open-apis/cardkit/v1/cards';
+    const requestBody: LarkCardRequest = {
+        type: "card_json",
+        data: JSON.stringify({
+            schema: "2.0",
+            header: {
+                title: {
+                    content: title,
+                    tag: "plain_text"
+                }
+            },
+            config: {
+                streaming_mode: true,
+                summary: {
+                    content: ""
+                }
+            },
+            body: {
+                elements: [
+                    {
+                        tag: "markdown",
+                        content: content,
+                        element_id: element_id
+                    }
+                ]
+            }
+        })
+    };
+
+    try {
+        const response = await fetch(url, {
+            method: 'POST',
+            headers: {
+                'Authorization': `Bearer ${token}`,
+                'Content-Type': 'application/json; charset=utf-8'
+            },
+            body: JSON.stringify(requestBody)
+        });
+
+        if (!response.ok) {
+            throw new Error(`HTTP error! status: ${response.status}`);
+        }
+
+        const data = await response.json();
+        return data as LarkCardResponse;
+    } catch (error) {
+        console.error('Error:', error instanceof Error ? error.message : 'Unknown error');
+        throw error;
+    }
+}
+
+//第二部发送消息
+export async function sendFeishuMessageCard(token: string, card_id: string, receive_id: string): Promise<MessageResponse> {
+    const url = 'https://open.feishu.cn/open-apis/im/v1/messages';
+    try {
+        const response = await fetch(`${url}?receive_id_type=open_id`, {
+            method: 'POST',
+            headers: {
+                'Content-Type': 'application/json',
+                'Authorization': `Bearer ${token}`
+            },
+            body: JSON.stringify({
+                msg_type: "interactive",
+                content: JSON.stringify({
+                    type: "card", data: {
+                        "card_id": card_id
+                    }
+                }),
+                receive_id: receive_id, // 需要配置接收者ID
+                uuid: uuidv4()
+            } as MessageRequest)
+        });
+
+        if (!response.ok) {
+            throw new Error(`HTTP error! status: ${response.status}, ${await response.text()}`);
+        }
+        const data: MessageResponse = await response.json() as MessageResponse;
+        return data;
+    } catch (error) {
+        console.error('发送消息失败:', error);
+        throw error;
+    }
+}
+
+//第三部更新卡片
+interface UpdateCardParams {
+    token: string;
+    card_id: string;
+    element_id: string;
+    sequence: number;
+    content: string;
+}
+
+interface UpdateCardResponse {
+    code: number;
+    data: Record<string, unknown>;
+    msg: string;
+}
+
+export async function updateMarkdownCard({
+    token,
+    card_id,
+    element_id,
+    sequence,
+    content
+}: UpdateCardParams): Promise<UpdateCardResponse> {
+    const url = `https://open.feishu.cn/open-apis/cardkit/v1/cards/${card_id}/elements/${element_id}/content`;
+    const headers = {
+        'Authorization': `Bearer ${token}`,
+        'Content-Type': 'application/json'
+    };
+    const body = JSON.stringify({
+        content,
+        sequence,
+        uuid: uuidv4()
+    });
+
+    try {
+        const response = await fetch(url, {
+            method: 'PUT',
+            headers,
+            body
+        });
+
+        if (!response.ok) {
+            throw new Error(`HTTP error! status: ${response.status}`);
+        }
+
+        const result: UpdateCardResponse = await response.json() as UpdateCardResponse;
+        if (result.code !== 0) {
+            throw new Error(`API error: ${result.msg}`);
+        }
+
+        return result;
+    } catch (error) {
+        console.error('Update failed:', error);
+        throw error;
+    }
+}
+
+

functions/utils/mail.ts

@@ -142,9 +142,6 @@ async function parseEmail(email: any): Promise<ParsedEmail> {
 
 export async function getEmails(accessToken: string, limit = 50): Promise<ParsedEmail[]> {
     const endpoint = 'https://graph.microsoft.com/v1.0/me/messages';
-    
-
-    console.log(accessToken)
     const response = await fetch(`${endpoint}?$top=${limit}`, {
       method: 'GET',
       headers: {
@@ -155,14 +152,10 @@ export async function getEmails(accessToken: string, limit = 50): Promise<Parsed
     
     const data = await response.json() as any;
     
-
-
     if (!response.ok) {
       throw new Error(`获取邮件失败: ${data.error?.message}`);
     }
-    
     const emails = data.value;
-    console.log(emails)
     const parsedEmails = await Promise.all(emails.map(parseEmail));
     return parsedEmails;
   }

index.ts

@@ -12,6 +12,8 @@ import { serveStatic } from '@hono/node-server/serve-static'
 import path from 'path'
 import { fileURLToPath } from 'url'
 import { dirname } from 'path'
+import { getTenantAccessToken, sendFeishuMessageText } from './functions/utils/feishu.js'
+import { get_access_token, getEmails } from './functions/utils/mail.js'
 
 // 导入所有路由处理函数
 import { onRequest as handleAccount } from './functions/api/account.js'
@@ -48,7 +50,7 @@ const storage = createStorage({
     }),
 });
 
-var kv: KVNamespace = {
+const kv: KVNamespace = {
     get: async (key: string) => {
         const value = await storage.getItemRaw(key);
         return value as string;
@@ -179,6 +181,110 @@ app.get('/*', serveStatic({
 }))
 
 
+// 邮箱监控功能
+async function checkEmailsForNewMessages(env: Env) {
+    try {
+        // 获取设置
+        const KV_KEY = "settings";
+        const settingsStr = await env.KV.get(KV_KEY);
+        if (!settingsStr) {
+            console.log('未找到设置信息');
+            return;
+        }
+
+        const settings = JSON.parse(settingsStr);
+        if (!settings.emailMonitor || !Array.isArray(settings.emailMonitor) || settings.emailMonitor.length === 0) {
+            console.log('未配置监控邮箱');
+            return;
+        }
+
+        // 获取飞书访问令牌
+        const feishuConfig = settings.feishu;
+        if (!feishuConfig || !feishuConfig.app_id || !feishuConfig.app_secret || !feishuConfig.receive_id) {
+            console.log('飞书配置不完整');
+            return;
+        }
+
+        const tokenResponse = await getTenantAccessToken(feishuConfig.app_id, feishuConfig.app_secret);
+        if (tokenResponse.code !== 0) {
+            console.log('获取飞书访问令牌失败:', tokenResponse.msg);
+            return;
+        }
+
+        const feishuToken = tokenResponse.tenant_access_token;
+        const now = new Date();
+        const currentTime = now.toISOString();
+
+        // 遍历所有监控邮箱
+        for (const monitor of settings.emailMonitor) {
+            if (!monitor.email) continue;
+
+            // 检查是否到了检查间隔
+            let shouldCheck = false;
+            if (monitor.lastCheckTime) {
+                const lastCheck = new Date(monitor.lastCheckTime);
+                const diffMinutes = Math.floor((now.getTime() - lastCheck.getTime()) / (1000 * 60));
+                shouldCheck = diffMinutes >= (monitor.checkInterval || 60);
+            } else {
+                shouldCheck = true; // 如果从未检查过，则立即检查
+            }
+
+            if (shouldCheck) {
+                try {
+                    // 获取邮箱的访问令牌
+                    const tokenInfoStr = await env.KV.get(`refresh_token_${monitor.email}`);
+                    if (!tokenInfoStr) {
+                        console.log(`邮箱 ${monitor.email} 未授权`);
+                        continue;
+                    }
+
+                    const tokenInfo = JSON.parse(tokenInfoStr);
+                    const access_token = await get_access_token(tokenInfo, env.ENTRA_CLIENT_ID, env.ENTRA_CLIENT_SECRET);
+
+                    // 获取最新邮件
+                    const emails = await getEmails(access_token, 1);
+                    if (emails.length === 0) {
+                        console.log(`邮箱 ${monitor.email} 没有邮件`);
+                        continue;
+                    }
+
+                    const latestEmail = emails[0];
+
+                    // 更新检查时间
+                    monitor.lastCheckTime = currentTime;
+                 
+
+                    // 获取最新邮件的时间戳
+                    const latestEmailTime = new Date(latestEmail.date.received || latestEmail.date.created || latestEmail.date.sent || latestEmail.date.modified).getTime();
+                    const lastEmailTime = monitor.lastEmailTimestamp ? new Date(monitor.lastEmailTimestamp).getTime() : 0;
+                    console.log(JSON.stringify(latestEmail),latestEmailTime,lastEmailTime)
+                    // 如果最新邮件的时间戳大于用户设置的时间戳，且ID不同，则认为有新邮件
+                    if (latestEmailTime > lastEmailTime && (!monitor.lastEmailId || monitor.lastEmailId !== latestEmail.id)) {
+                        // 只更新最新邮件ID，不更新lastEmailTimestamp（该值由用户手动设置）
+                        monitor.lastEmailId = latestEmail.id;
+
+                        // 发送飞书通知
+                        const notificationContent = `邮箱 ${monitor.email} 收到新邮件\n主题: ${latestEmail.subject}\n发件人: ${latestEmail.from}\n时间: ${latestEmail.date.received}\n预览: ${latestEmail.preview || '无预览内容'}`;
+
+                        await sendFeishuMessageText(feishuToken, feishuConfig.receive_id, notificationContent);
+                        console.log(`已发送邮箱 ${monitor.email} 的新邮件通知`);
+                    } else {
+                        console.log(`邮箱 ${monitor.email} 没有新邮件`);
+                    }
+                } catch (error) {
+                    console.error(`检查邮箱 ${monitor.email} 失败:`, error);
+                }
+            }
+        }
+
+        // 保存更新后的设置
+        await env.KV.put(KV_KEY, JSON.stringify(settings));
+        console.log('邮箱监控完成');
+    } catch (error) {
+        console.error('邮箱监控出错:', error);
+    }
+}
+
 // 启动服务器
 const port = parseInt(process.env.PORT || '8788')
 serve({
@@ -186,6 +292,12 @@ serve({
     port
 }, () => {
     console.log(`Server running at http://localhost:${port}`)
+
+    // 启动定时监控邮箱
+    setInterval(() => {
+        const envWithKV = { ...process.env, KV: kv };
+        checkEmailsForNewMessages(envWithKV as unknown as Env);
+    }, 60000); // 每分钟检查一次
 })
 
 export default app

package-lock.json

@@ -13,6 +13,7 @@
 				"@tailwindcss/vite": "^4.0.14",
 				"dotenv": "^16.4.7",
 				"hono": "^4.7.4",
+				"moment-timezone": "^0.5.48",
 				"monaco-editor": "^0.52.2",
 				"pinia": "^3.0.1",
 				"playwright": "^1.51.0",
@@ -20,6 +21,7 @@
 				"tailwindcss": "^4.0.14",
 				"tdesign-vue-next": "^1.11.4",
 				"unstorage": "^1.15.0",
+				"uuid": "^11.1.0",
 				"vue": "^3.5.13",
 				"vue-router": "^4.5.0"
 			},
@@ -3424,6 +3426,27 @@
 				"pathe": "^2.0.1"
 			}
 		},
+		"node_modules/moment": {
+			"version": "2.30.1",
+			"resolved": "https://registry.npmmirror.com/moment/-/moment-2.30.1.tgz",
+			"integrity": "sha512-uEmtNhbDOrWPFS+hdjFCBfy9f2YoyzRpwcl+DqpC6taX21FzsTLQVbMV/W7PzNSX6x/bhC1zA3c2UQ5NzH6how==",
+			"license": "MIT",
+			"engines": {
+				"node": "*"
+			}
+		},
+		"node_modules/moment-timezone": {
+			"version": "0.5.48",
+			"resolved": "https://registry.npmmirror.com/moment-timezone/-/moment-timezone-0.5.48.tgz",
+			"integrity": "sha512-f22b8LV1gbTO2ms2j2z13MuPogNoh5UzxL3nzNAYKGraILnbGc9NEE6dyiiiLv46DGRb8A4kg8UKWLjPthxBHw==",
+			"license": "MIT",
+			"dependencies": {
+				"moment": "^2.29.4"
+			},
+			"engines": {
+				"node": "*"
+			}
+		},
 		"node_modules/monaco-editor": {
 			"version": "0.52.2",
 			"resolved": "https://registry.npmmirror.com/monaco-editor/-/monaco-editor-0.52.2.tgz",
@@ -5056,6 +5079,19 @@
 				"url": "https://paulmillr.com/funding/"
 			}
 		},
+		"node_modules/uuid": {
+			"version": "11.1.0",
+			"resolved": "https://registry.npmmirror.com/uuid/-/uuid-11.1.0.tgz",
+			"integrity": "sha512-0/A9rDy9P7cJ+8w1c9WD9V//9Wj15Ce2MPz8Ri6032usz+NfePxx5AcN3bN+r6ZL6jEo066/yNYB3tn4pQEx+A==",
+			"funding": [
+				"https://github.com/sponsors/broofa",
+				"https://github.com/sponsors/ctavan"
+			],
+			"license": "MIT",
+			"bin": {
+				"uuid": "dist/esm/bin/uuid"
+			}
+		},
 		"node_modules/validator": {
 			"version": "13.12.0",
 			"resolved": "https://registry.npmmirror.com/validator/-/validator-13.12.0.tgz",

package.json

@@ -20,6 +20,7 @@
 		"@tailwindcss/vite": "^4.0.14",
 		"dotenv": "^16.4.7",
 		"hono": "^4.7.4",
+		"moment-timezone": "^0.5.48",
 		"monaco-editor": "^0.52.2",
 		"pinia": "^3.0.1",
 		"playwright": "^1.51.0",
@@ -27,6 +28,7 @@
 		"tailwindcss": "^4.0.14",
 		"tdesign-vue-next": "^1.11.4",
 		"unstorage": "^1.15.0",
+		"uuid": "^11.1.0",
 		"vue": "^3.5.13",
 		"vue-router": "^4.5.0"
 	},

src/services/settingApi.ts

@@ -1,5 +1,18 @@
 import { API_BASE_URL, getHeaders, handleResponse } from './util';
 
+export interface EmailMonitorConfig {
+    /** 监控的邮箱地址 */
+    email: string;
+    /** 上次邮件时间戳 (用于判断新邮件) */
+    lastEmailTimestamp: string;
+    /** 检查间隔 (分钟) */
+    checkInterval: number;
+    /** 上次检查时间 */
+    lastCheckTime?: string;
+    /** 上次邮件ID */
+    lastEmailId?: string;
+}
+
 export interface Settings {
     /** 飞书配置 */
     feishu: {
@@ -13,7 +26,9 @@ export interface Settings {
         encrypt_key: string;
         /** 飞书机器人接收ID */
         receive_id: string;
-    }
+    };
+    /** 邮箱监控配置 */
+    emailMonitor?: EmailMonitorConfig[];
 }
 
 

src/views/SettingView.vue

@@ -2,6 +2,7 @@
 import { ref, onMounted } from 'vue';
 import { MessagePlugin } from 'tdesign-vue-next';
 import { settingApi, type Settings } from '../services/settingApi';
+import moment from 'moment-timezone';
 
 const settings = ref<Settings>({
     feishu: {
@@ -10,7 +11,8 @@ const settings = ref<Settings>({
         verification_token: '',
         encrypt_key: '',
         receive_id: ''
-    }
+    },
+    emailMonitor: []
 });
 
 const loading = ref(false);
@@ -23,7 +25,8 @@ onMounted(async () => {
             feishu: {
                 ...settings.value.feishu,
                 ...data.feishu
-            }
+            },
+            emailMonitor: data.emailMonitor || []
         };
     } catch (error) {
         MessagePlugin.error('获取设置失败');
@@ -45,6 +48,31 @@ const handleSave = async () => {
         loading.value = false;
     }
 };
+
+// 添加新的监控邮箱
+const addEmailMonitor = () => {
+    if (!settings.value.emailMonitor) {
+        settings.value.emailMonitor = [];
+    }
+    // 初始化为上海时区的当前时间
+    // 使用moment-timezone获取上海时区的当前时间
+    const shanghaiTime = moment().tz('Asia/Shanghai');
+
+    settings.value.emailMonitor.push({
+        email: '',
+        lastEmailTimestamp: shanghaiTime.format('YYYY-MM-DD HH:mm:ss'),
+        checkInterval: 60
+    });
+};
+
+// 删除监控邮箱
+const removeEmailMonitor = (index: number) => {
+    if (settings.value.emailMonitor) {
+        settings.value.emailMonitor.splice(index, 1);
+    }
+};
+
+
 </script>
 
 <template>
@@ -69,13 +97,54 @@ const handleSave = async () => {
                     <t-input v-model="settings.feishu.receive_id" placeholder="请输入飞书机器人接收ID" />
                 </t-form-item>
 
+                <t-divider>监控邮箱配置</t-divider>
+                <div class="mb-4 flex justify-end">
+                    <t-button theme="default" @click="addEmailMonitor">
+                        <template #icon><t-icon name="add" /></template>
+                        添加监控邮箱
+                    </t-button>
+                </div>
+
+                <div v-if="settings.emailMonitor && settings.emailMonitor.length > 0" class="mb-4">
+                    <!-- 表头 -->
+                    <div class="grid grid-cols-4 gap-4 mb-2 font-bold">
+                        <div>邮箱地址</div>
+                        <div>检查间隔(分钟)</div>
+                        <div>邮件时间</div>
+                        <div>操作</div>
+                    </div>
+
+                    <!-- 每一行邮箱配置 -->
+                    <div v-for="(item, index) in settings.emailMonitor" :key="index" class="grid grid-cols-4 gap-4 mb-3 items-center">
+                        <div>
+                            <t-input v-model="item.email" placeholder="请输入邮箱地址" />
+                        </div>
+                        <div>
+                            <t-input-number v-model="item.checkInterval" :min="1" :max="1440" placeholder="请输入检查间隔" />
+                        </div>
+                        <div>
+                            <t-date-picker
+                                v-model="item.lastEmailTimestamp"
+                                enable-time-picker
+                                clearable
+                                placeholder="请选择上次邮件时间"
+                                format="YYYY-MM-DD HH:mm:ss"
+                                :timezone="{ name: 'Asia/Shanghai', offset: 8 }"
+                            />
+                        </div>
+                        <div>
+                            <t-button theme="danger" variant="text" @click="removeEmailMonitor(index)">
+                                <template #icon><t-icon name="delete" /></template>
+                                删除
+                            </t-button>
+                        </div>
+                    </div>
+                </div>
 
                 <t-form-item class="flex justify-center">
                     <t-button theme="primary" type="submit" :loading="loading">保存设置</t-button>
                 </t-form-item>
             </t-card>
-
-
         </t-form>
     </div>
 </template>