update

jd_twcyz.js

@@ -113,7 +113,7 @@ async function main() {
     //}
     console.log(`\n可抽奖${$.drawtimes}次，开始...`);
     for (let i = 0; i < $.drawtimes; i++) {
-        //console.log(`进行第${i + 1}抽奖：`);;
+        console.log(`进行${i + 1}次抽奖：`);;
         await takeRequest('superBrandTaskLottery');//抽奖
         await $.wait(1000);
         if (!$.runFlag) break;
@@ -242,16 +242,23 @@ function dealReturn(type, data) {
             } else {
                 console.log(JSON.stringify(data));
             }
+
             break;
         case 'superBrandTaskLottery':
             if (data.code === '0' && data.data.bizCode !== 'TK000') {
                 $.runFlag = false;
-                console.log(`抽奖次数已用完`);
+                console.log(`抽奖打到上限！`);
             } else if (data.code === '0' && data.data.bizCode == 'TK000') {
-                if (data.data && data.data.result && data.data.result.rewardComponent && data.data.result.rewardComponent.beanList) {
+                if (data?.data?.result?.rewardComponent?.beanList) {
                     if (data.data.result.rewardComponent.beanList.length > 0) {
                         console.log(`获得豆子：${data.data.result.rewardComponent.beanList[0].quantity}`)
                     }
+                } else if (data?.data?.result?.rewardComponent?.couponList) {
+                    $.log('获得优惠券');
+                } else if (data?.data?.result?.rewardComponent?.realList) {
+                    $.log('可能抽中实物，到APP查看！');
+                } else {
+                    $.log('空气');
                 }
             } else {
                 $.runFlag = false;

sendNotify.js

@@ -21,7 +21,7 @@ const querystring = require('querystring');
 const exec = require('child_process').exec;
 const $ = new Env();
 const timeout = 15000; //超时时间(单位毫秒)
-console.log("加载sendNotify，当前版本: 20230314");
+console.log("加载sendNotify，当前版本: 20230415");
 // =======================================go-cqhttp通知设置区域===========================================
 //gobot_url 填写请求地址http://127.0.0.1/send_private_msg
 //gobot_token 填写在go-cqhttp文件设置的访问密钥
@@ -116,6 +116,13 @@ let WP_UIDS_ONE = "";
 let GOTIFY_URL = '';
 let GOTIFY_TOKEN = '';
 let GOTIFY_PRIORITY = 0;
+
+// =======================================BncrBot通知设置区域==============================================
+//BncrHost 填写BncrHost地址,如https://192.168.31.192:9090
+//BncrToken 填写Bncr的消息应用Token
+let BncrHost = '';
+let BncrToken = '';
+
 let PushErrorTime = 0;
 let strTitle = "";
 let ShowRemarkType = "1";
@@ -129,12 +136,12 @@ const {
 } = require('./ql');
 const fs = require('fs');
 let isnewql = fs.existsSync('/ql/data/config/auth.json');
-let strCKFile="";
+let strCKFile = "";
-let strUidFile ="";
+let strUidFile = "";
-if(isnewql){
+if (isnewql) {
     strCKFile = '/ql/data/scripts/CKName_cache.json';
     strUidFile = '/ql/data/scripts/CK_WxPusherUid.json';
-}else{
+} else {
     strCKFile = '/ql/scripts/CKName_cache.json';
     strUidFile = '/ql/scripts/CK_WxPusherUid.json';
 }
@@ -239,7 +246,7 @@ async function sendNotify(text, desp, params = {}, author = '\n\n本通知 By cc
         var Use_WxPusher = true;
         var strtext = text;
         var strdesp = desp;
-		var titleIndex =-1;
+        var titleIndex = -1;
         if (process.env.NOTIFY_NOCKFALSE) {
             Notify_NoCKFalse = process.env.NOTIFY_NOCKFALSE;
         }
@@ -291,7 +298,7 @@ async function sendNotify(text, desp, params = {}, author = '\n\n本通知 By cc
                                     tempid = temptest._id;
                                 }
                                 if (temptest.id) {
-								    tempid =temptest.id;
+                                    tempid = temptest.id;
                                 }
                                 const DisableCkBody = await DisableCk(tempid);
                                 strPtPin = temptest.value;
@@ -487,9 +494,9 @@ async function sendNotify(text, desp, params = {}, author = '\n\n本通知 By cc
                 if (strCustomTempArr.length > 1) {
                     if (strTitle == strCustomTempArr[0]) {
                         console.log("检测到自定义设定,开始执行配置...");
-						if(strCustomTempArr[1].indexOf("组")!=-1){
+                        if (strCustomTempArr[1].indexOf("组") != -1) {
-							UseGroupNotify = strCustomTempArr[1].replace("组","") * 1;
+                            UseGroupNotify = strCustomTempArr[1].replace("组", "") * 1;
-							console.log("自定义设定强制使用组"+UseGroupNotify+"配置通知...");
+                            console.log("自定义设定强制使用组" + UseGroupNotify + "配置通知...");
                         } else {
                             UseGroupNotify = 1;
                         }
@@ -669,6 +676,12 @@ async function sendNotify(text, desp, params = {}, author = '\n\n本通知 By cc
         if (process.env["GOTIFY_PRIORITY" + UseGroupNotify]) {
             GOTIFY_PRIORITY = process.env["GOTIFY_PRIORITY" + UseGroupNotify];
         }
+        if (process.env["BncrHost" + UseGroupNotify]) {
+            BncrHost = process.env["BncrHost" + UseGroupNotify];
+        }
+        if (process.env["BncrToken" + UseGroupNotify]) {
+            BncrToken = process.env["BncrToken" + UseGroupNotify];
+        }
         //检查是否在不使用Remark进行名称替换的名单
         const notifySkipRemarkList = process.env.NOTIFY_SKIP_NAMETYPELIST ? process.env.NOTIFY_SKIP_NAMETYPELIST.split('&') : [];
         const titleIndex3 = notifySkipRemarkList.findIndex((item) => item === strTitle);
@@ -747,13 +760,13 @@ async function sendNotify(text, desp, params = {}, author = '\n\n本通知 By cc
                             text = text.replace(new RegExp(`${$.UserName}|${$.nickName}`, 'gm'), $.Remark);
                             if (text == "京东资产变动" || text == "京东资产变动#2" || text == "京东资产变动#3" || text == "京东资产变动#4") {
                                 var Tempinfo = "";
-								if(envs[i].created)
+                                if (envs[i].created)
-									Tempinfo=getQLinfo(cookie, envs[i].created, envs[i].timestamp, envs[i].remarks);
+                                    Tempinfo = getQLinfo(cookie, envs[i].created, envs[i].timestamp, envs[i].remarks);
                                 else
-									if(envs[i].updatedAt)
+                                    if (envs[i].updatedAt)
-										Tempinfo=getQLinfo(cookie, envs[i].createdAt, envs[i].updatedAt, envs[i].remarks);
+                                        Tempinfo = getQLinfo(cookie, envs[i].createdAt, envs[i].updatedAt, envs[i].remarks);
                                     else
-										Tempinfo=getQLinfo(cookie, envs[i].createdAt, envs[i].timestamp, envs[i].remarks);
+                                        Tempinfo = getQLinfo(cookie, envs[i].createdAt, envs[i].timestamp, envs[i].remarks);
                                 if (Tempinfo) {
                                     $.Remark += Tempinfo;
                                 }
@@ -841,6 +854,7 @@ async function sendNotify(text, desp, params = {}, author = '\n\n本通知 By cc
         iGotNotify(text, desp, params), //iGot
         gobotNotify(text, desp), //go-cqhttp
         gotifyNotify(text, desp), //gotify
+        bncrNotify(text, desp), //bncr
         wxpusherNotify(text, desp) // wxpusher
     ]);
 }
@@ -993,13 +1007,13 @@ async function sendNotifybyWxPucher(text, desp, PtPin, author = '\n\n本通知 B
                             $.nickName = $.nickName.replace(new RegExp(`[*]`, 'gm'), "[*]");
 
                             var Tempinfo = "";
-							if(tempEnv.created)
+                            if (tempEnv.created)
-								Tempinfo=getQLinfo(cookie, tempEnv.created, tempEnv.timestamp, tempEnv.remarks);
+                                Tempinfo = getQLinfo(cookie, tempEnv.created, tempEnv.timestamp, tempEnv.remarks);
                             else
-								if(tempEnv.updatedAt)
+                                if (tempEnv.updatedAt)
-									Tempinfo=getQLinfo(cookie, tempEnv.createdAt, tempEnv.updatedAt, tempEnv.remarks);
+                                    Tempinfo = getQLinfo(cookie, tempEnv.createdAt, tempEnv.updatedAt, tempEnv.remarks);
                                 else
-									Tempinfo=getQLinfo(cookie, tempEnv.createdAt, tempEnv.timestamp, tempEnv.remarks);
+                                    Tempinfo = getQLinfo(cookie, tempEnv.createdAt, tempEnv.timestamp, tempEnv.remarks);
 
                             if (Tempinfo) {
                                 Tempinfo = $.nickName + Tempinfo;
@@ -1113,6 +1127,43 @@ async function isLoginByX1a0He(cookie) {
     });
 }
 
+function bncrNotify(text, desp) {
+    return new Promise(resolve => {
+        try {
+            if (BncrHost && BncrToken) {
+                const options = {
+                    url: `${BncrHost}/api/qinglongMessage`,
+                    body: `title=${encodeURIComponent(text)}&message=${encodeURIComponent(
+                        desp
+                    )}&token=${BncrToken}`,
+                    headers: {
+                        'Content-Type': 'application/x-www-form-urlencoded',
+                    },
+                };
+                $.post(options, (err, resp, data) => {
+                    if (err) {
+                        console.log('\nBncr发送通知调用API失败！！\n');
+                        console.log(err);
+                    } else {
+                        data = JSON.parse(data);
+                        if (data.code === 200) {
+                            console.log('\nBncr发送通知消息成功🎉\n');
+                        } else {
+                            console.log(`\nBncr发送通知调用API失败：${data.msg}\n`);
+                        }
+                    }
+                });
+            } else {
+                resolve();
+            }
+        } catch (e) {
+            $.logErr(`\nBncr发送通知调用API失败：`, e);
+        } finally {
+            resolve();
+        }
+    });
+}
+
 function gotifyNotify(text, desp) {
     return new Promise((resolve) => {
         if (GOTIFY_URL && GOTIFY_TOKEN) {
@@ -1327,7 +1378,7 @@ function tgBotNotify(text, desp) {
                 json: {
                     chat_id: `${TG_USER_ID}`,
                     text: `${text}\n\n${desp}`,
-            disable_web_page_preview:true
+                    disable_web_page_preview: true
                 },
                 headers: {
                     'Content-Type': 'application/json',
@@ -1345,7 +1396,7 @@ function tgBotNotify(text, desp) {
                         }
                     })
                 }
-        Object.assign(options, {agent})
+                Object.assign(options, { agent })
             }
             $.post(options, (err, resp, data) => {
                 try {
@@ -1575,7 +1626,7 @@ function qywxamNotify(text, desp, strsummary = "") {
                                     content_source_url: ``,
                                     content: `${html}`,
                                     digest: `${strsummary}`,
-                                }, ],
+                                },],
                             },
                         };
                 }
@@ -1950,7 +2001,7 @@ function GetnickName() {
 }
 
 function GetnickName2() {
-    return new Promise(async(resolve) => {
+    return new Promise(async (resolve) => {
         const options = {
             "url": `https://wq.jd.com/user/info/QueryJDUserInfo?sceneval=2`,
             "headers": {
@@ -2000,7 +2051,7 @@ module.exports = {
 
 // prettier-ignore
 function Env(t, s) {
-    return new(class {
+    return new (class {
         constructor(t, s) {
             (this.name = t),
                 (this.data = null),
@@ -2037,7 +2088,7 @@ function Env(t, s) {
                 let o = this.getdata('@chavy_boxjs_userCfgs.httpapi_timeout');
                 (o = o ? 1 * o : 20),
                     (o = s && s.timeout ? s.timeout : o);
-                const[h, a] = i.split('@'),
+                const [h, a] = i.split('@'),
                     r = {
                         url: `http://${a}/v1/scripting/evaluate`,
                         body: {
@@ -2099,7 +2150,7 @@ function Env(t, s) {
         getdata(t) {
             let s = this.getval(t);
             if (/^@/.test(t)) {
-                const[, e, i] = /^@(.*?)\.(.*?)$/.exec(t),
+                const [, e, i] = /^@(.*?)\.(.*?)$/.exec(t),
                     o = e ? this.getval(e) : '';
                 if (o)
                     try {
@@ -2114,7 +2165,7 @@ function Env(t, s) {
         setdata(t, s) {
             let e = !1;
             if (/^@/.test(s)) {
-                const[, i, o] = /^@(.*?)\.(.*?)$/.exec(s),
+                const [, i, o] = /^@(.*?)\.(.*?)$/.exec(s),
                     h = this.getval(i),
                     a = i ? ('null' === h ? null : h || '{}') : '{}';
                 try {
@@ -2142,7 +2193,7 @@ function Env(t, s) {
                 (this.ckjar = this.ckjar ? this.ckjar : new this.cktough.CookieJar()),
                 t && ((t.headers = t.headers ? t.headers : {}), void 0 === t.headers.Cookie && void 0 === t.cookieJar && (t.cookieJar = this.ckjar));
         }
-        get(t, s = () => {}) {
+        get(t, s = () => { }) {
             t.headers && (delete t.headers['Content-Type'], delete t.headers['Content-Length']),
                 this.isSurge() || this.isLoon() ? $httpClient.get(t, (t, e, i) => {
                     !t && e && ((e.body = i), (e.statusCode = e.status)),
@@ -2183,7 +2234,7 @@ function Env(t, s) {
                     }, h);
                 }, (t) => s(t)));
         }
-        post(t, s = () => {}) {
+        post(t, s = () => { }) {
             if ((t.body && t.headers && !t.headers['Content-Type'] && (t.headers['Content-Type'] = 'application/x-www-form-urlencoded'), delete t.headers['Content-Length'], this.isSurge() || this.isLoon()))
                 $httpClient.post(t, (t, e, i) => {
                     !t && e && ((e.body = i), (e.statusCode = e.status)),