// 提供6种通知

// desp += author;

// 根据标题跳过一些消息推送，环境变量：SKIP_PUSH_TITLE 用回车分隔

let skipTitle = process.env.SKIP_PUSH_TITLE;

if (skipTitle) {

if (skipTitle.split('\n').includes(text)) {

console.info(text + '在SKIP_PUSH_TITLE环境变量内，跳过推送！');

return;

}

}

await Promise.all([

serverNotify(text, desp), // 微信server酱

pushPlusNotify(text, desp), // pushplus(推送加)

wxPusherNotify(text, desp),

]);

// 由于上述两种微信通知需点击进去才能查看到详情，故text(标题内容)携带了账号序号以及昵称信息，方便不点击也可知道是哪个京东哪个活动

text = text.match(/.*?(?=\s?-)/g) ? text.match(/.*?(?=\s?-)/g)[0] : text;

await Promise.all([

BarkNotify(text, desp, params), // iOS Bark APP

tgBotNotify(text, desp), // telegram 机器人

ddBotNotify(text, desp), // 钉钉机器人

qywxBotNotify(text, desp), // 企业微信机器人

qywxamNotify(text, desp), // 企业微信应用消息推送

iGotNotify(text, desp, params), // iGot

gobotNotify(text, desp), // go-cqhttp

gotifyNotify(text, desp), // gotify

ChatNotify(text, desp), // synolog chat

PushDeerNotify(text, desp), // PushDeer

aibotkNotify(text, desp), // 智能微秘书

fsBotNotify(text, desp), // 飞书机器人

smtpNotify(text, desp), // SMTP 邮件

pushMeNotify(text, desp, params), // PushMe

chronocatNotify(text, desp), // Chronocat

webhookNotify(text, desp), // 自定义通知

]);

return new Promise((resolve) => {

if (GOTIFY_URL && GOTIFY_TOKEN) {

const options = {

url: `${GOTIFY_URL}/message?token=${GOTIFY_TOKEN}`,

body: `title=${encodeURIComponent(text)}&message=${encodeURIComponent(

headers: {

'Content-Type': 'application/x-www-form-urlencoded',

},

};

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\ngotify发送通知调用API失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

if (data.id) {

console.log('\ngotify发送通知消息成功🎉\n');

} else {

console.log(`${data.message}\n`);

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve();

}

});

} else {

resolve();

}

});

return new Promise((resolve) => {

if (GOBOT_URL) {

const options = {

url: `${GOBOT_URL}?access_token=${GOBOT_TOKEN}&${GOBOT_QQ}`,

json: {message: `${text}\n${desp}`},

headers: {

'Content-Type': 'application/json',

},

timeout,

};

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\n发送go-cqhttp通知调用API失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

if (data.retcode === 0) {

console.log('\ngo-cqhttp发送通知消息成功🎉\n');

} else if (data.retcode === 100) {

console.log(`\ngo-cqhttp发送通知消息异常: ${data.errmsg}\n`);

} else {

console.log(`\ngo-cqhttp发送通知消息异常\n${JSON.stringify(data)}`);

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve(data);

}

});

} else {

resolve();

}

});

return new Promise((resolve) => {

if (SCKEY) {

// 微信server酱推送通知一个\n不会换行，需要两个\n才能换行，故做此替换

desp = desp.replace(/[\n\r]/g, '\n\n');

const options = {

url: SCKEY.includes('SCT')

? `https://sctapi.ftqq.com/${SCKEY}.send`

: `https://sc.ftqq.com/${SCKEY}.send`,

body: `text=${text}&desp=${desp}`,

headers: {

'Content-Type': 'application/x-www-form-urlencoded',

},

timeout,

};

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\n发送通知调用API失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

// server酱和Server酱·Turbo版的返回json格式不太一样

if (data.errno === 0 || data.data.errno === 0) {

console.log('\nserver酱发送通知消息成功🎉\n');

} else if (data.errno === 1024) {

// 一分钟内发送相同的内容会触发

console.log(`\nserver酱发送通知消息异常: ${data.errmsg}\n`);

} else {

console.log(`\nserver酱发送通知消息异常\n${JSON.stringify(data)}`);

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve(data);

}

});

} else {

resolve();

}

});

return new Promise((resolve) => {

if (PUSHDEER_KEY) {

// PushDeer 建议对消息内容进行 urlencode

desp = encodeURI(desp);

const options = {

url: PUSHDEER_URL || `https://api2.pushdeer.com/message/push`,

body: `pushkey=${PUSHDEER_KEY}&text=${text}&desp=${desp}&type=markdown`,

headers: {

'Content-Type': 'application/x-www-form-urlencoded',

},

timeout,

};

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\n发送通知调用API失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

// 通过返回的result的长度来判断是否成功

if (

data.content.result.length !== undefined &&

data.content.result.length > 0

) {

console.log('\nPushDeer发送通知消息成功🎉\n');

} else {

console.log(`\nPushDeer发送通知消息异常\n${JSON.stringify(data)}`);

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve(data);

}

});

} else {

resolve();

}

});

return new Promise((resolve) => {

if (CHAT_URL && CHAT_TOKEN) {

// 对消息内容进行 urlencode

desp = encodeURI(desp);

const options = {

url: `${CHAT_URL}${CHAT_TOKEN}`,

body: `payload={"text":"${text}\n${desp}"}`,

headers: {

'Content-Type': 'application/x-www-form-urlencoded',

},

};

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\n发送通知调用API失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

if (data.success) {

console.log('\nChat发送通知消息成功🎉\n');

} else {

console.log(`\nChat发送通知消息异常\n${JSON.stringify(data)}`);

}

}

} catch (e) {

$.logErr(e);

} finally {

resolve(data);

}

});

} else {

resolve();

}

});

return new Promise((resolve) => {

if (BARK_PUSH) {

const options = {

url: `${BARK_PUSH}/${encodeURIComponent(text)}/${encodeURIComponent(

headers: {

'Content-Type': 'application/x-www-form-urlencoded',

},

timeout,

};

$.get(options, (err, resp, data) => {

try {

if (err) {

console.log('\nBark APP发送通知调用API失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

if (data.code === 200) {

console.log('\nBark APP发送通知消息成功🎉\n');

} else {

console.log(`${data.message}\n`);

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve();

}

});

} else {

resolve();

}

});

return new Promise((resolve) => {

if (TG_BOT_TOKEN && TG_USER_ID) {

const options = {

url: `${TG_API_HOST}/bot${TG_BOT_TOKEN}/sendMessage`,

json: {

chat_id: `${TG_USER_ID}`,

text: `${text}\n\n${desp}`,

disable_web_page_preview: true,

},

headers: {

'Content-Type': 'application/json',

},

timeout,

};

if (TG_PROXY_HOST && TG_PROXY_PORT) {

const {HttpProxyAgent, HttpsProxyAgent} = require('hpagent');

const options = {

keepAlive: true,

keepAliveMsecs: 1000,

maxSockets: 256,

maxFreeSockets: 256,

proxy: `http://${TG_PROXY_AUTH}${TG_PROXY_HOST}:${TG_PROXY_PORT}`,

};

const httpAgent = new HttpProxyAgent(options);

const httpsAgent = new HttpsProxyAgent(options);

const agent = {

http: httpAgent,

https: httpsAgent,

};

Object.assign(options, {agent});

}

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\ntelegram发送通知消息失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

if (data.ok) {

console.log('\nTelegram发送通知消息成功🎉。\n');

} else if (data.error_code === 400) {

console.log(

'\n请主动给bot发送一条消息并检查接收用户ID是否正确。\n',

);

} else if (data.error_code === 401) {

console.log('\nTelegram bot token 填写错误。\n');

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve(data);

}

});

} else {

resolve();

}

});

return new Promise((resolve) => {

const options = {

url: `https://oapi.dingtalk.com/robot/send?access_token=${DD_BOT_TOKEN}`,

json: {

msgtype: 'text',

text: {

content: `${text}\n\n${desp}`,

},

},

headers: {

'Content-Type': 'application/json',

},

timeout,

};

if (DD_BOT_TOKEN && DD_BOT_SECRET) {

const crypto = require('crypto');

const dateNow = Date.now();

const hmac = crypto.createHmac('sha256', DD_BOT_SECRET);

hmac.update(`${dateNow}\n${DD_BOT_SECRET}`);

const result = encodeURIComponent(hmac.digest('base64'));

options.url = `${options.url}&timestamp=${dateNow}&sign=${result}`;

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\n钉钉发送通知消息失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

if (data.errcode === 0) {

console.log('\n钉钉发送通知消息成功🎉。\n');

} else {

console.log(`${data.errmsg}\n`);

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve(data);

}

});

} else if (DD_BOT_TOKEN) {

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\n钉钉发送通知消息失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

if (data.errcode === 0) {

console.log('\n钉钉发送通知消息完成。\n');

} else {

console.log(`${data.errmsg}\n`);

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve(data);

}

});

} else {

resolve();

}

});

return new Promise((resolve) => {

const options = {

url: `${QYWX_ORIGIN}/cgi-bin/webhook/send?key=${QYWX_KEY}`,

json: {

msgtype: 'text',

text: {

content: `${text}\n\n${desp}`,

},

},

headers: {

'Content-Type': 'application/json',

},

timeout,

};

if (QYWX_KEY) {

$.post(options, (err, resp, data) => {

try {

if (err) {

console.log('\n企业微信发送通知消息失败！！\n');

console.log(err);

} else {

data = JSON.parse(data);

if (data.errcode === 0) {

console.log('\n企业微信发送通知消息成功🎉。\n');

} else {

console.log(`${data.errmsg}\n`);

}

}

} catch (e) {

$.logErr(e, resp);

} finally {

resolve(data);

}

});

} else {

resolve();

}

});

const QYWX_AM_AY = QYWX_AM.split(',');

if (QYWX_AM_AY[2]) {

const userIdTmp = QYWX_AM_AY[2].split('|');

let userId = '';

for (let i = 0; i < userIdTmp.length; i++) {

const count = '账号' + (i + 1);

const count2 = '签到号 ' + (i + 1);

if (desp.match(count2)) {

userId = userIdTmp[i];

}

}

if (!userId) userId = QYWX_AM_AY[2];

return userId;

} else {

return '@all';

}

const MAX_LENGTH = 900;

if (desp.length > MAX_LENGTH) {

let d = desp.substr(0, MAX_LENGTH) + '\n==More==';

await do_qywxamNotify(text, d);

await qywxamNotify(text, desp.substr(MAX_LENGTH));

} else {

return await do_qywxamNotify(text, desp);

}

return new Promise((resolve) => {

if (QYWX_AM) {

const QYWX_AM_AY = QYWX_AM.split(',');

const options_accesstoken = {

url: `${QYWX_ORIGIN}/cgi-bin/gettoken`,

json: {

corpid: `${QYWX_AM_AY[0]}`,

corpsecret: `${QYWX_AM_AY[1]}`,

},

headers: {

'Content-Type': 'application/json',

},

timeout,

};

$.post(options_accesstoken, (err, resp, data) => {

let html = desp.replace(/\n/g, '<br/>');

let json = JSON.parse(data);