为 Mac 邮箱安装“大脑”：自动抓取、自动总结、自动汇报

on run{input, parameters} AppleScript 脚本 end run

cd 脚本路径 /opt/homebrew/bin/node 脚本名称

tell application "Mail" -- 获取 iCloud 账户中的 newsletter 邮箱 set theAccount to account "iCloud" set theMailbox to mailbox "newsletter" of theAccount -- 获取 newsletter 邮箱中的所有未读邮件 set unreadMessages to (every message of theMailbox whose read status is false) -- 遍历所有未读邮件 repeat with eachMessage in unreadMessages -- 获取邮件的主题作为文件名的一部分 set theSubject to subject of eachMessage -- 获取邮件的正文并转换为纯文本格式 set theContent to content of eachMessage set plainTextContent to do shell script "echo " & quoted form of theContent & " | textutil -convert txt -stdin -stdout" -- 获取邮件的 message-ID 并生成 URI set messageID to message id of eachMessage set messageURL to "message://%3c" & messageID & "%3e" -- 创建文件名，移除文件名中的不合法字符 set cleanSubject to do shell script "echo " & quoted form of theSubject & " | tr -d '\"/:<>?\|+[]{};=,'" set fileName to (cleanSubject & ".txt") -- 使用指定的 POSIX 路径并转换为 AppleScript 路径格式 set savePath to POSIX file "保存 txt 文件的路径" -- 完整的文件路径 set filePath to (savePath as string) & fileName -- 将邮件内容写入到指定路径的 txt 文件 try set fileReference to open for access file filePath with write permission write plainTextContent to fileReference starting at eof -- 在文件末尾添加邮件 URI write return & "emailURL=" & messageURL to fileReference starting at eof close access fileReference on error errMsg close access file filePath display dialog "Error: " & errMsg end try -- 将邮件标记为已读 set read status of eachMessage to true end repeat end tell return input

const fs = require('fs'); const path = require('path'); const axios = require('axios'); const nodemailer = require('nodemailer'); const directoryPath = '存放文本文件的目录路径'; // 指定存放文本文件的目录路径 const today = new Date().toLocaleDateString('zh-CN'); // 获取系统本地日期 let allContents = ''; // 用于存储所有查询接口返回的内容 let fileCounter = 0; // 用于文件计数 let validFileCount = 0; // 有效文件计数 let emailSent = false; // 添加一个标志来跟踪邮件是否已发送 // 读取指定目录下的文件 fs.readdir(directoryPath, async (err, files) => { if (err) { console.error('无法读取目录:', err); return; } const filePromises = files.map(file => processFile(file)); await Promise.all(filePromises); checkAllFilesProcessed(); }); async function processFile(file) { const filePath = path.join(directoryPath, file); try { const stats = await fs.promises.stat(filePath); const fileCreationDate = stats.birthtime.toLocaleDateString('zh-CN'); // 获取文件创建的本地日期 if (fileCreationDate === today && path.extname(file) === '.txt') { validFileCount++; // 增加有效文件计数 const content = await fs.promises.readFile(filePath, 'utf8'); await callAIAPI(content, file); } } catch (err) { console.error('处理文件时出错:', err); } } // 使用 async/await 优化异步处理 async function callAIAPI(content, fileName) { const apiUrl = 'https://api.coze.cn/v3/chat'; const headers = getHeaders(); // 根据 content 的长度设置 bot_id const botId = content.length > 32000 ? 'bot_id' : 'bot_id'; const data = { bot_id: botId, // 使用动态 bot_id user_id: '**', stream: false, auto_save_history: true, additional_messages: [ { role: 'user', content: content, content_type: 'text' } ] }; let attempts = 0; const maxAttempts = 5; while (attempts < maxAttempts) { try { const response = await axios.post(apiUrl, data, { headers, timeout: 5000 }); console.log('API响应:', response.data); const { id, conversation_id } = response.data.data; await new Promise(resolve => setTimeout(resolve, 1000)); // 增加等待时间，1秒钟 await pollConversationStatus(id, conversation_id, fileName); break; // 成功后退出循环 } catch (error) { attempts++; console.error(`API调用错误 (尝试 ${attempts}/${maxAttempts}):`, error); if (attempts >= maxAttempts) { console.error('多次尝试后仍然失败'); } } } } // 提取 headers 设置函数 function getHeaders() { return { 'Authorization': 'Bearer api_key', 'Content-Type': 'application/json' }; } // 轮询对话详情接口的函数 async function pollConversationStatus(chat_id, conversation_id, fileName) { const retrieveUrl = `https://api.coze.cn/v3/chat/retrieve?chat_id=${chat_id}&conversation_id=${conversation_id}`; const headers = getHeaders(); let pollCount = 0; const maxPollCount = 120; return new Promise((resolve, reject) => { const intervalId = setInterval(async () => { pollCount++; if (pollCount > maxPollCount) { clearInterval(intervalId); reject(new Error(`轮询超时，chat_id: ${chat_id}, conversation_id: ${conversation_id}`)); return; } try { const response = await axios.get(retrieveUrl, { headers }); // 取消打印轮询接口的日志 // console.log('对话详情API响应:', response.data); if (response.data.data.status === 'completed') { clearInterval(intervalId); await queryAIAPI(chat_id, conversation_id, fileName); resolve(); } } catch (error) { console.error('对话详情API调用错误:', error); clearInterval(intervalId); reject(error); } }, 1000); // 每秒调用一次 }); } // 调用查询接口的函数 async function queryAIAPI(chat_id, conversation_id, fileName) { const queryUrl = `https://api.coze.cn/v3/chat/message/list?chat_id=${chat_id}&conversation_id=${conversation_id}`; const headers = getHeaders(); try { const response = await axios.get(queryUrl, { headers }); console.log('查询API响应:', response.data); const contents = response.data.data
.filter(item => item.type === 'answer') // 过滤出 type 为 'answer' 的元素
.map(item => item.content)
.join('
'); // 读取文件的最后一行以获取 MessageID const filePath = path.join(directoryPath, fileName); const fileContent = await fs.promises.readFile(filePath, 'utf8'); const lastLine = fileContent.trim().split('
').pop(); const messageId = lastLine.split('=')[1]; // 提取 MessageID fileCounter++; // 增加文件计数 console.log(`文件计数: ${fileCounter}`); // 打印 fileCounter 的日志 const fileNameWithoutExt = fileName.replace(/\.[^/.]+$/, ""); // 删除文件扩展名 allContents += `
${fileCounter}. ${fileNameWithoutExt}

${contents.replace(/\n/g, '
')}

`; // 将换行符替换为 <br> } catch (error) { console.error('查询API调用错误:', error); } } // 检查是否所有文件都已处理完毕 function checkAllFilesProcessed() { if (fileCounter === validFileCount && !emailSent) { emailSent = true; // 设置标志，表示邮件已发送 sendEmail(allContents); // 调用发送邮件函数 } } // 发送邮件的函数 function sendEmail(contents) { const transporter = nodemailer.createTransport({ host: 'smtp.qq.com', port: 465, secure: true, // 使用 SSL auth: { user: '邮箱地址', // 你的邮箱地址 pass: '邮箱授权码' // 你的邮箱授权码 } }); const mailOptions = { from: '邮箱地址', // 发送者邮箱地址 to: '邮箱地址', // 收件人邮箱地址 subject: `${today} 当日邮件总结`, // 邮件主题 html: `未读邮件数量: ${validFileCount}

${contents}` // 将内容类型改为 HTML }; transporter.sendMail(mailOptions, (error, info) => { if (error) { return console.error('无法发送邮件:', error); } console.log('邮件已发送:', info.response); }); }