我用gpt改了一直获取不成功
这就是我不用安卓的原因 
感谢分享，周末折腾下试试
还没老懂怎么用，回头研究一下 
思路很棒
我改了下，改成server酱了，同时推送邮件正文。
// --- 辅助函数 ---
// Base64 解码 (Worker 环境自带 atob)
// 注意：atob 返回的是解码后的原始字节串，需要用 TextDecoder 转换为字符串
function decodeBase64(encoded) {
try {
const binaryString = atob(encoded.replace(/\s/g, '')); // 移除可能的空白符
const bytes = new Uint8Array(binaryString.length);
for (let i = 0; i < binaryString.length; i++) {
bytes[i] = binaryString.charCodeAt(i);
}
// 尝试多种编码方式解码
const encodings = ['utf-8', 'gbk', 'gb2312', 'big5'];
for (const encoding of encodings) {
try {
// 注意：目前浏览器和某些Worker环境可能只支持部分编码
// 这里我们仍然列出常见中文编码，如果环境支持就能正确解码
const decoded = new TextDecoder(encoding, { fatal: true }).decode(bytes);
if (decoded && decoded.length > 0) {
console.log(`成功使用 ${encoding} 解码`);
return decoded;
}
} catch (encErr) {
console.log(`使用 ${encoding} 解码失败:`, encErr);
continue;
}
}
// 如果所有编码都失败，回退到非严格的UTF-8
console.log('所有编码尝试失败，使用非严格UTF-8解码');
return new TextDecoder('utf-8', { fatal: false }).decode(bytes);
} catch (e) {
console.error("Base64 decoding failed:", e);
return encoded; // 解码失败返回原始输入
}
}
// Quoted-Printable 解码 (简化版，处理常见情况)
function decodeQuotedPrintable(encoded) {
try {
// 替换 =<换行符> (软换行)
let decoded = encoded.replace(/=\r\n/g, '').replace(/=\n/g, '');
// 替换 =XX 十六进制编码
const bytes = [];
decoded.replace(/=([0-9A-F]{2})/gi, (match, hex) => {
bytes.push(parseInt(hex, 16));
return '';
});
// 如果有字节数据，尝试多种编码解码
if (bytes.length > 0) {
const uint8Array = new Uint8Array(bytes);
const encodings = ['utf-8', 'gbk', 'gb2312', 'big5'];
for (const encoding of encodings) {
try {
const decoded = new TextDecoder(encoding, { fatal: true }).decode(uint8Array);
if (decoded && decoded.length > 0) {
console.log(`Quoted-Printable成功使用 ${encoding} 解码`);
return decoded;
}
} catch (encErr) {
console.log(`Quoted-Printable使用 ${encoding} 解码失败:`, encErr);
continue;
}
}
// 如果所有编码都失败，回退到非严格的UTF-8
console.log('Quoted-Printable所有编码尝试失败，使用非严格UTF-8解码');
return new TextDecoder('utf-8', { fatal: false }).decode(uint8Array);
}
// 如果没有发现编码的字节，返回原始解码结果
return decoded;
} catch (e) {
console.error("Quoted-Printable decoding failed:", e);
return encoded; // 解码失败返回原始输入
}
}
// 简单去除 HTML 标签，并将换行、段落转为换行符
function stripHtml(html) {
if (!html) return '';
let text = html;
// 将常见的换行标签转换成换行符
text = text.replace(/<br\s*\/?>/gi, '\n');
text = text.replace(/<\/p>/gi, '\n');
text = text.replace(/<\/div>/gi, '\n');
// 移除所有其他 HTML 标签
text = text.replace(/<[^>]*>/g, '');
// 替换 HTML 实体编码
text = text.replace(/ /gi, ' ');
text = text.replace(/</gi, '<');
text = text.replace(/>/gi, '>');
text = text.replace(/&/gi, '&');
text = text.replace(/"/gi, '"');
text = text.replace(/'/gi, "'");
// 移除多余的空白行和首尾空白
return text.replace(/\n\s*\n/g, '\n').trim();
}
// 读取 ReadableStream 到字符串
async function streamToString(stream) {
const reader = stream.getReader();
// 假设原始邮件流是 UTF-8，这不一定准确，但作为基础尝试
const decoder = new TextDecoder('utf-8', { fatal: false });
let result = '';
while (true) {
const { done, value } = await reader.read();
if (done) {
break;
}
result += decoder.decode(value, { stream: true });
}
return result;
}
// --- 主逻辑 ---
export default {
async email(message, env, ctx) {
// Server酱配置
const serverChanToken = ""; // 在此填入你的Server酱Token
const serverChanApi = `https://sctapi.ftqq.com/${serverChanToken}.send`;
if (!serverChanToken) {
console.error("错误：Server酱Token未配置");
return new Response("Server Chan Token not configured", { status: 500 });
}
// 1. 获取发件人
let originalSender = '';
const fromHeader = message.headers.get("From");
if (fromHeader) {
const match = fromHeader.match(/<([^>]+)>/);
originalSender = match ? match[1] : fromHeader.trim();
}
if (!originalSender) {
const senderHeader = message.headers.get("Sender");
if (senderHeader) {
const match = senderHeader.match(/<([^>]+)>/);
originalSender = match ? match[1] : senderHeader.trim();
}
}
if (!originalSender) {
originalSender = "未知发件人";
}
// 2. 获取主题
const subject = message.headers.get("Subject") || "无主题";
// 3. 获取邮件正文
let bodyContent = message.text; // 优先使用 Cloudflare 解析的纯文本
if (!bodyContent || bodyContent.trim() === '') {
console.log("message.text 为空或无效，尝试从 message.raw 提取...");
try {
const rawEmail = await streamToString(message.raw);
// 尝试从原始邮件中提取最可能是正文的部分并解码
// 这是一个简化的 MIME 解析逻辑，可能不适用于所有邮件格式
let potentialBody = "";
let encoding = null; // 'base64' or 'quoted-printable' or null
// 查找 Content-Type 和 Content-Transfer-Encoding
// 简单的正则匹配，查找第一个 text/plain 或 text/html 部分
const textPlainMatch = rawEmail.match(/Content-Type: text\/plain(?:;[\s\S]*?)Content-Transfer-Encoding: (base64|quoted-printable|7bit|8bit|binary)[\s\S]*?\r?\n\r?\n([\s\S]*?)(?:--|$)/i);
const textHtmlMatch = rawEmail.match(/Content-Type: text\/html(?:;[\s\S]*?)Content-Transfer-Encoding: (base64|quoted-printable|7bit|8bit|binary)[\s\S]*?\r?\n\r?\n([\s\S]*?)(?:--|$)/i);
if (textPlainMatch && textPlainMatch[2] && textPlainMatch[2].trim() !== '') {
// 优先使用 text/plain
potentialBody = textPlainMatch[2];
encoding = textPlainMatch[1] ? textPlainMatch[1].toLowerCase() : null;
console.log(`找到 text/plain 部分，编码: ${encoding}`);
} else if (textHtmlMatch && textHtmlMatch[2] && textHtmlMatch[2].trim() !== '') {
// 其次使用 text/html
potentialBody = textHtmlMatch[2];
encoding = textHtmlMatch[1] ? textHtmlMatch[1].toLowerCase() : null;
console.log(`找到 text/html 部分，编码: ${encoding}`);
// 提取后需要去除 HTML 标签
potentialBody = stripHtml(potentialBody); // 先尝试去除标签，因为解码可能在标签内部进行
} else {
// 如果找不到明确的部分，尝试使用第一个空行后的内容
console.log("未找到明确的 text/plain 或 text/html 部分，使用第一个空行后的内容");
let headerEndIndex = rawEmail.indexOf("\r\n\r\n");
if (headerEndIndex === -1) headerEndIndex = rawEmail.indexOf("\n\n");
if (headerEndIndex !== -1) {
potentialBody = rawEmail.substring(headerEndIndex + (rawEmail.includes("\r\n\r\n") ? 4 : 2));
// 尝试猜测编码（非常不准确）
if (rawEmail.toLowerCase().includes('content-transfer-encoding: base64')) encoding = 'base64';
else if (rawEmail.toLowerCase().includes('content-transfer-encoding: quoted-printable')) encoding = 'quoted-printable';
console.log(`使用空行后内容，猜测编码: ${encoding}`);
} else {
potentialBody = rawEmail; // 无法分割，使用全部 raw 内容
console.log("无法分割邮件头和体，使用全部 raw 内容");
}
}
// 根据检测到的编码进行解码
let decodedBody = potentialBody;
if (encoding === 'base64') {
decodedBody = decodeBase64(potentialBody);
} else if (encoding === 'quoted-printable') {
decodedBody = decodeQuotedPrintable(potentialBody);
}
// 对于 7bit, 8bit, binary，通常不需要额外解码，但可能需要处理字符集问题（已在 streamToString 中尝试 UTF-8）
// 如果之前没有处理 HTML，现在处理解码后的内容
if (textHtmlMatch && textHtmlMatch[2] && !textPlainMatch) { // 确认是 HTML 且没有 plain text
bodyContent = stripHtml(decodedBody);
} else {
bodyContent = decodedBody; // 已经是 plain text 或已处理过 HTML
}
if (!bodyContent || bodyContent.trim() === '') {
bodyContent = "未能从原始邮件中提取有效正文。";
}
} catch (e) {
console.error("处理 message.raw 时出错:", e);
bodyContent = "提取邮件正文时发生错误。";
}
}
// 4. 截取正文预览
const maxPreviewLength = 500;
let bodyPreview = bodyContent.substring(0, maxPreviewLength);
if (bodyContent.length > maxPreviewLength) {
bodyPreview += "\n...";
}
// 5. 构造Server酱消息
const title = `新邮件: ${subject}`;
const desp = `发件人: ${originalSender}\n\n${bodyPreview}`;
// 6. 发送请求到Server酱
try {
const response = await fetch(serverChanApi, {
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded'
},
body: `title=${encodeURIComponent(title)}&desp=${encodeURIComponent(desp)}`
});
// 7. 处理Server酱响应
if (response.ok) {
const respBody = await response.json();
if (respBody.code === 0) {
console.log(`Server酱消息发送成功: ${JSON.stringify(respBody)}`);
return new Response('Server Chan message sent successfully', { status: 200 });
} else {
console.error(`Server酱API返回错误: code=${respBody.code}, message=${respBody.message}`);
return new Response(`Server Chan API error: ${respBody.message}`, { status: 500 });
}
} else {
const errorText = await response.text();
console.error(`发送Server酱消息失败: ${response.status} ${response.statusText}`, errorText);
return new Response(`Failed to send Server Chan message: ${errorText}`, { status: response.status });
}
} catch (error) {
console.error("请求Server酱时发生异常:", error);
return new Response('Network error requesting Server Chan', { status: 500 });
}
}
}
2 个赞
安卓国内推送确实不如IOS，稳定性及时性都不如，不过现在我无所谓了，我真正需要的微信和邮件都能实时推送了，其他APP我推送全关的，10条推送9条广告。
2 个赞
不懂就问。
佬友，我用email worker。那我cf上设置的rule不能冲突，我怎么查看邮件？我那个邮箱地址只是个rule啊，而且不能重复设置处理方式，无法转发到其他邮箱。
能看正文但是也没法回复啊。或者只当个单向通信？
cf域名邮箱就是只能接受，转发，不能查看，需要其他的辅助。
插个眼，明天试下
感觉是个好思路，试试看
这个可以正常推送邮件正文到server酱，可惜免费版本只能推送5条每天
开头的推送到企业微信的代码使用AI怎么修复都实现不了，奇怪了
可以给个推送到钉钉的吗
代碼勸退，但思路get了！
感觉很不错
感谢佬友分享
我这个用的是企业微信机器人，现在微信需要设置公网IP白名单才能推送消息了的。
// --- 辅助函数 ---
// Base64 解码 (Worker 环境自带 atob)
// 注意：atob 返回的是解码后的原始字节串，需要用 TextDecoder 转换为字符串
function decodeBase64(encoded) {
try {
const binaryString = atob(encoded.replace(/\s/g, '')); // 移除可能的空白符
const bytes = new Uint8Array(binaryString.length);
for (let i = 0; i < binaryString.length; i++) {
bytes[i] = binaryString.charCodeAt(i);
}
// 尝试多种编码方式解码
const encodings = ['utf-8', 'gbk', 'gb2312', 'big5'];
for (const encoding of encodings) {
try {
// 注意：目前浏览器和某些Worker环境可能只支持部分编码
// 这里我们仍然列出常见中文编码，如果环境支持就能正确解码
const decoded = new TextDecoder(encoding, { fatal: true }).decode(bytes);
if (decoded && decoded.length > 0) {
console.log(`成功使用 ${encoding} 解码`);
return decoded;
}
} catch (encErr) {
console.log(`使用 ${encoding} 解码失败:`, encErr);
continue;
}
}
// 如果所有编码都失败，回退到非严格的UTF-8
console.log('所有编码尝试失败，使用非严格UTF-8解码');
return new TextDecoder('utf-8', { fatal: false }).decode(bytes);
} catch (e) {
console.error("Base64 decoding failed:", e);
return encoded; // 解码失败返回原始输入
}
}
// Quoted-Printable 解码 (简化版，处理常见情况)
function decodeQuotedPrintable(encoded) {
try {
// 替换 =<换行符> (软换行)
let decoded = encoded.replace(/=\r\n/g, '').replace(/=\n/g, '');
// 替换 =XX 十六进制编码
const bytes = [];
decoded.replace(/=([0-9A-F]{2})/gi, (match, hex) => {
bytes.push(parseInt(hex, 16));
return '';
});
// 如果有字节数据，尝试多种编码解码
if (bytes.length > 0) {
const uint8Array = new Uint8Array(bytes);
const encodings = ['utf-8', 'gbk', 'gb2312', 'big5'];
for (const encoding of encodings) {
try {
const decoded = new TextDecoder(encoding, { fatal: true }).decode(uint8Array);
if (decoded && decoded.length > 0) {
console.log(`Quoted-Printable成功使用 ${encoding} 解码`);
return decoded;
}
} catch (encErr) {
console.log(`Quoted-Printable使用 ${encoding} 解码失败:`, encErr);
continue;
}
}
// 如果所有编码都失败，回退到非严格的UTF-8
console.log('Quoted-Printable所有编码尝试失败，使用非严格UTF-8解码');
return new TextDecoder('utf-8', { fatal: false }).decode(uint8Array);
}
// 如果没有发现编码的字节，返回原始解码结果
return decoded;
} catch (e) {
console.error("Quoted-Printable decoding failed:", e);
return encoded; // 解码失败返回原始输入
}
}
// 简单去除 HTML 标签，并将换行、段落转为换行符
function stripHtml(html) {
if (!html) return '';
let text = html;
// 将常见的换行标签转换成换行符
text = text.replace(/<br\s*\/?>/gi, '\n');
text = text.replace(/<\/p>/gi, '\n');
text = text.replace(/<\/div>/gi, '\n');
// 移除所有其他 HTML 标签
text = text.replace(/<[^>]*>/g, '');
// 替换 HTML 实体编码
text = text.replace(/ /gi, ' ');
text = text.replace(/</gi, '<');
text = text.replace(/>/gi, '>');
text = text.replace(/&/gi, '&');
text = text.replace(/"/gi, '"');
text = text.replace(/'/gi, "'");
// 移除多余的空白行和首尾空白
return text.replace(/\n\s*\n/g, '\n').trim();
}
// 读取 ReadableStream 到字符串
async function streamToString(stream) {
const reader = stream.getReader();
// 假设原始邮件流是 UTF-8，这不一定准确，但作为基础尝试
const decoder = new TextDecoder('utf-8', { fatal: false });
let result = '';
while (true) {
const { done, value } = await reader.read();
if (done) {
break;
}
result += decoder.decode(value, { stream: true });
}
return result;
}
// --- 主逻辑 ---
export default {
async email(message, env, ctx) {
// 钉钉机器人配置
const dingTalkWebhook = ""; // 在此填入钉钉机器人的Webhook地址
const dingTalkSecret = ""; // 在此填入钉钉机器人的加签密钥（如果已配置）
if (!dingTalkWebhook) {
console.error("错误：钉钉Webhook未配置");
return new Response("DingTalk Webhook not configured", { status: 500 });
}
// 1. 获取发件人
let originalSender = '';
const fromHeader = message.headers.get("From");
if (fromHeader) {
const match = fromHeader.match(/<([^>]+)>/);
originalSender = match ? match[1] : fromHeader.trim();
}
if (!originalSender) {
const senderHeader = message.headers.get("Sender");
if (senderHeader) {
const match = senderHeader.match(/<([^>]+)>/);
originalSender = match ? match[1] : senderHeader.trim();
}
}
if (!originalSender) {
originalSender = "未知发件人";
}
// 2. 获取主题
const subject = message.headers.get("Subject") || "无主题";
// 3. 构造钉钉消息
const timestamp = Date.now();
let url = dingTalkWebhook;
// 如果配置了加签密钥，添加签名
if (dingTalkSecret) {
const sign = await generateDingTalkSign(timestamp, dingTalkSecret);
url = `${dingTalkWebhook}×tamp=${timestamp}&sign=${sign}`;
}
// 构造钉钉消息内容
const messageContent = {
msgtype: "text",
text: {
content: `新邮件通知\n发件人: ${originalSender}\n主题: ${subject}`
}
};
// 发送请求到钉钉
try {
const response = await fetch(url, {
method: 'POST',
headers: {
'Content-Type': 'application/json'
},
body: JSON.stringify(messageContent)
});
// 处理钉钉响应
if (response.ok) {
const respBody = await response.json();
if (respBody.errcode === 0) {
console.log(`钉钉消息发送成功: ${JSON.stringify(respBody)}`);
return new Response('DingTalk message sent successfully', { status: 200 });
} else {
console.error(`钉钉API返回错误: code=${respBody.errcode}, message=${respBody.errmsg}`);
return new Response(`DingTalk API error: ${respBody.errmsg}`, { status: 500 });
}
} else {
const errorText = await response.text();
console.error(`发送钉钉消息失败: ${response.status} ${response.statusText}`, errorText);
return new Response(`Failed to send DingTalk message: ${errorText}`, { status: response.status });
}
} catch (error) {
console.error("请求钉钉时发生异常:", error);
return new Response('Network error requesting DingTalk', { status: 500 });
}
}
}
你自己试一下，用AI改的。
1 个赞
发送到企业微信.. 这隐私方面。和转发q邮箱触发微信通知没区别啊
这里发送的内容是我控制的，不是邮件转发，邮件转发是一股脑全发过去，所有隐私都没了，这是你自己控制一些不重要的东西发给微信，自己知道有个邮件送达。