Quantumult-X/Scripts/pingan/pinganIkea.js

/*
平安银行宜家礼品卡优惠券
https://b.pingan.com.cn/kuaizhan/v2/5K2422/20230925/k84123/index.html?paesuperbank=%7B%22dLinkId%22%3A%22M0P5EnN0addUoXCs240814104407%22%7D

pahkebank://

[Script]
# > 平安银行宜家礼品卡优惠券
^https?:\/\/b\.pingan\.com\.cn url script-request-body https://git.jojo21.top/shawenguan/Quantumult-X/raw/master/Scripts/pingan/pinganIkea.js
^https?:\/\/b\.pingan\.com\.cn url script-response-body https://git.jojo21.top/shawenguan/Quantumult-X/raw/master/Scripts/pingan/pinganIkea.js
^https?:\/\/rsb\.pingan\.com\.cn url script-request-body https://git.jojo21.top/shawenguan/Quantumult-X/raw/master/Scripts/pingan/pinganIkea.js
^https?:\/\/rsb\.pingan\.com\.cn url script-response-body https://git.jojo21.top/shawenguan/Quantumult-X/raw/master/Scripts/pingan/pinganIkea.js
^https?:\/\/rmb\.pingan\.com\.cn url script-request-body https://git.jojo21.top/shawenguan/Quantumult-X/raw/master/Scripts/pingan/pinganIkea.js
^https?:\/\/rmb\.pingan\.com\.cn url script-response-body https://git.jojo21.top/shawenguan/Quantumult-X/raw/master/Scripts/pingan/pinganIkea.js

[MITM]
hostname = b.pingan.com.cn,rsb.pingan.com.cn,rmb.pingan.com.cn

*/

const scriptName = `平安银行宜家礼品卡优惠券`;
const magicJS = MagicJS(scriptName, "INFO");

const PingAnConstKey = {
    // 基础数据
    Cookie: 'PingAnInnerWebCookie',
    DeviceId: 'PingAnInnerWebDeviceId',
    x_g_sid: 'PingAnInnerWeb#x_g_sid',
    x_g_vid: 'PingAnInnerWeb#x_g_vid',
    x_g_rid: 'PingAnInnerWeb#x_g_rid',
    PageData: 'PingAnInnerWeb#PageData',
    PageActionId: 'PingAnInnerWeb#PageActionId',
};

let gRetBody;

let errCodeStrMap = {
    900111: "notStart",
    900112: "notStart",
    900113: "finish",
    900109: "exceed",
    910179: "nonLottery",
    910204: "nonBindCard",
    701001: "limitFlow",
    700116: "nonBindWechat",
    700118: "nonInterestWechat",
    960002: "nonDayStock",
    900537: "nonStock",
    900139: "nonWhiteList",
    900320: "riskList",
    900130: "nonRules",
    900982: "mutex",
    950010: "nonDayTimes",
    950710: "nonWeekTimes",
    700119: "nonMonthTimes",
    900144: "nonTimes",
    950008: "nonDayPrizeTimes",
    900745: "nonWeekPrizeTimes",
    950009: "nonMonthPrizeTimes",
    900143: "nonPrizeTimes",
    600056: "timesCutDown",
    780001: "nonBindAliPay",
    900203: "notSendAble",
    999999: "stockValidateText"
};

const gHost = 'b.pingan.com.cn';
const gTeamId = `5K2422`;
const gActivityId = `PK084123`;
const gPageUrlFirstPath = '/kuaizhan/v2';
const gPageUrlSuffix = `5K2422/20230925/k84123`;
const gHomePageUrl = `https://b.pingan.com.cn/kuaizhan/v2/${gPageUrlSuffix}/index.html?paesuperbank=%7B%22dLinkId%22%3A%22M0P5EnN0addUoXCs240814104407%22%7D`;

const gWebUserAgent = `Mozilla/5.0 (iPhone; CPU iPhone OS 16_6_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 MicroMessenger/8.0.50(0x18003237) NetType/WIFI Language/zh_CN`;

let gDeviceId = magicJS.data.read(PingAnConstKey.DeviceId, 'AUUID_918d439ffcef935c2fd84d3a3e593b6523c916fc');

let gPageActionId = magicJS.data.read(PingAnConstKey.PageActionId, '1F908E50');
let gAppUserAgent = `Mozilla/5.0 (iPhone; CPU iPhone OS 16_6_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 iphone 14 pro AladdinHybrid/4.8.77 (PAEBank 6.23.0) AladdinBridge/3.0.0 subContracting/AppStore deviceId/${gDeviceId} UnionPay/1.0 PABANK deviceType/1 networkState/WIFI KiwiBridge/1.0.0 device-dpr/3 device-dr/852*393 AppStyle/BZ bz-navbarHeight/309 dzTab-navbarHeight/327 pageActionId/${gPageActionId}`;

let gTmpRequsetTimeStamp = Date.now();
let gTmpRequestSortId = 100 + Math.floor(Math.random() * 100);

const gCommonHeaders = {
    'osVersion': `16.6.1`,
    'Accept-Encoding': `gzip, deflate, br`,
    'Host': `rsb.pingan.com.cn`,
    'X-App-Version': `6.23.0`,
    'phoneModel': `iPhone15,2`,
    'Connection': `keep-alive`,
    'bank-mobile-model': `iPhone15,2`,
    'Accept-Language': `zh-Hans-CN;q=1`,
    'nativeVersion': `6.23.0`,
    'User-Agent': `${gAppUserAgent}`,
    'Referer': `https://b.pingan.com.cn/kuaizhan/v2/5K2422/20230925/k84123/index.html`,
    'X-Aladdin-Version': `4.8.77`,
    'bank-mobile-brand': `Apple`,
    'x-o-spanid': `0`,
    'Accept': `*/*`,
    'x-g-sid': `iSb07mg4hmSUYbUg5izmW0`,
    'x-g-vid': `53mWJHzK00401M5Vv+uR3w`,
    'x-g-rid': `J3/I3jF+hI6xiREInsHZlg5dn320120r`,
    'X-REQUEST-ID': `${gDeviceId}-${gTmpRequsetTimeStamp}-${gTmpRequestSortId}`,
    'Cookie': ``
};

let gPageData = {};

// 忽略执行的本地领券状态
let gIgnoreCouponGotStatus = false;
// 忽略查询的领券状态
let gIgnoreActivityStatus = false;;

async function Main() {
    if (magicJS.isStrictRequest) {
        magicJS.checkRecordRequestBody();
    }
    if (magicJS.isRequest) {
        checkHandleRequest();
    } else {
        gCommonHeaders[`Cookie`] = magicJS.data.read(PingAnConstKey.Cookie, '');
        await tryGrabCoupon();
    }
    magicJS.notification.msg('');
    if (gRetBody) {
        magicJS.done({
            body: JSON.stringify(gRetBody)
        });
    } else {
        magicJS.done();
    }
}

function checkHandleRequest() {
    const url = $request.url;
    const path = $request.path;
    magicJS.log(`请求url=${url}#${$request.method}`);
    if ($request && $request.method != 'OPTIONS') {
        switch (path) {
            case '/brop/cmp/cust/cmpsf/mgm/share/createTokenId.do':
                handleCreateTokenId();
                break;
            case '/brop/mop/cust/mopsf/nrp/uc/simple/rule/info/batchSatisfy':
                handleBatchSatisfy();
                break;
            case '/brop/cmp/cust/cmpsf/mgm/origin/queryPageConfig.do':
                handlePageConfig();
                break;
            case '/brcp/uc/cust/uc-login-web.qryLoginStatus.do':
                break;
            case '/brop/mop/cust/mopsf/lottery/getLeftOfferNum':
                break;
            case '/brop/mop/cust/mopsf/uc/auth/lottery/sendCustomerOffer':
                handleCustomerOffer();
                break;
            default:
                if (path.indexOf('/kuaizhan/v2/5K2422/20230925/k84123/index.html') > -1) {
                    handleHomePage();
                } else if (path.indexOf('/rmb/brcp/uc/cust/uc-login-web.qryLoginStatus.do') > -1) {
                    handleLoginStatus();
                } else if (path.indexOf('/brop/mop/cust/mopsf/personality/activity/status/query') > -1) {
                    handlePublicActivityStatus();
                } else if (path.indexOf('/bron/coss/cust/app/getSupernatant') > -1) {

                } else if (path.indexOf('/brop/mop/cust/mopsf/uc/auth/lottery/queryCustomerActivityStatus') > -1) {
                    handleCustomerActivityStatus();
                } else if (path.indexOf('/brop/stp/kafka/http/h5monitor_web/rest/ac/h5Monitor') > -1) {
                    handleH5MonitorUploadInfo();
                }
                break;
        }
    }
}

function getResponsePlainData() {
    let data = magicJS.getResponseBody();
    if (!data) {
        return;
    }
    try {
        return JSON.parse(data);
    } catch (err) {
        magicJS.logger.error(err);
    }
}

function getRequestPlainData() {
    let data = magicJS.getRequestBody();
    let reqData = null;
    if (data) {
        reqData = magicJS.parseQueryStr(data);
    } else {
        reqData = magicJS.parseQueryStr($request.url);
    }
    return reqData;
}

function getQueryPlainData() {
    let params = magicJS.parseQueryStr($request.url);
    return params;
}

function getXRequestId() {
    gTmpRequestSortId++;
    return `${gDeviceId}-${gTmpRequsetTimeStamp}-${gTmpRequestSortId}`
}

function handleHeaders() {
    if ($request && $request.method != 'OPTIONS') {
        let headers = $request.headers;
        let x_g_sid = headers['x-g-sid'];
        if (x_g_sid) {
            magicJS.data.write(PingAnConstKey.x_g_sid, x_g_sid);
        }
        let x_g_vid = headers['x-g-vid'];
        if (x_g_sid) {
            magicJS.data.write(PingAnConstKey.x_g_vid, x_g_vid);
        }
        let x_g_rid = headers['x-g-rid'];
        if (x_g_sid) {
            magicJS.data.write(PingAnConstKey.x_g_rid, x_g_rid);
        }
        if (headers['X-REQUEST-ID']) {
            let tmpArr = headers['X-REQUEST-ID'].split('-');
            magicJS.data.write(PingAnConstKey.DeviceId, tmpArr[0]);
        }

        let newCookieStr = headers['Cookie'];
        if (newCookieStr) {
            let oldCookieStr = magicJS.data.read(PingAnConstKey.Cookie, null);
            magicJS.logger.info(`oldCookieStr=${oldCookieStr}`);
            magicJS.logger.info(`newCookieStr=${newCookieStr}`);
            if (compareCookieStr(newCookieStr, oldCookieStr) != 0) {
                magicJS.data.write(PingAnConstKey.Cookie, newCookieStr);
                magicJS.logger.info(`当前Cookie刷新到最新`);
                magicJS.notification.appendNotifyInfo(`🎉当前Cookie刷新到最新`);
            } else {
                magicJS.data.write(PingAnConstKey.Cookie, newCookieStr);
                magicJS.logger.info(`当前Cookie已经是最新无需更新`);
            }
        }

        let userAgent = headers['User-Agent'];
        let mRet = userAgent.match(/pageActionId\/([\S.]+)\s*/);
        let pageActionId = mRet && mRet[1] ? mRet[1] : "";
        if (pageActionId && pageActionId.length > 0) {
            magicJS.data.write(PingAnConstKey.PageActionId, pageActionId);
        }
    }
}

function compareCookieStr(cookieStr1, cookieStr2) {
    let cookieDict1 = magicJS.parseCookies(cookieStr1);
    let cookieDict2 = magicJS.parseCookies(cookieStr2);
    let skipKeys = ['NGWhitelist', 'PAEBANK_PARAM', 'PAEBANK_PARAM_N', 'PAEBANK_PARAM_W', 'WEBTRENDS_SESSIONID', 'brcpSessionTicket', 'sdc_PABankParam', 'shuntid'];
    skipKeys = ['PAEBANK_PARAM', 'WEBTRENDS_SESSIONID'];
    let retCode = 0;
    for (let key in cookieDict1) {
        if (!skipKeys.includes(key)) {
            if (cookieDict1[key] != void 0 && cookieDict2[key] != void 0 && cookieDict1[key] != cookieDict2[key]) {
                magicJS.logger.info(`${key}`);
                retCode = -1;
                break;
            }
        }
    }
    return retCode;
}

function handleHomePage() {
    handleHeaders();
}

function handleCreateTokenId() {

}

function handleBatchSatisfy() {

}

function handlePageConfig() {
    handleHeaders();
    let rspData = getResponsePlainData();
    if (!rspData) {
        return;
    }
    if (rspData.responseCode != "000000") {
        return;
    }
    let data = rspData.data;
    if (data.reShow) {

    }
}



function handlePublicActivityStatus() {
    handleHeaders();
    let rspData = getResponsePlainData();
    if (!rspData) {
        return;
    }
    if (rspData.responseCode != "000000") {
        return;
    }
    let queryParams = getQueryPlainData();
    let activityCode = queryParams.activityCode;
    let queryNextTime = queryParams.queryNextTime;

    let data = rspData.data;
}

function handleCustomerActivityStatus() {
    handleHeaders();
    let rspData = getResponsePlainData();
    if (!rspData) {
        return;
    }
    rspData = { pagination: null, data: null, responseCode: "000000", responseMsg: "成功" };
    gRetBody = rspData;

    if (rspData.responseCode != "000000") {
        return;
    }
}

function handleCustomerOffer() {
    let rspData = getResponsePlainData();
    if (!rspData) {
        return;
    }
    rspData.responseCode = "000000";
    gRetBody = rspData;

    if (rspData.responseCode != "000000") {
        return;
    }
}

function handleLoginStatus() {
    handleHeaders();
    let rspData = getResponsePlainData();
    if (!rspData) {
        return;
    }

    if (rspData.responseCode != "000000") {
        return;
    }
}

function handleH5MonitorUploadInfo() {
    let rspData = getResponsePlainData();
    if (!rspData) {
        return;
    }

    if (rspData.responseCode != "000000") {
        return;
    }

    let reqData = getRequestPlainData();
    if (!reqData || !reqData.uploadInfo) {
        return;
    }
    let uploadInfo = reqData.uploadInfo;
    let reqObject = null;
    // reqObject = {
    //     "countType": 32,
    //     "totalDelay": 464,
    //     "h5monitor_sdk_version": "1.7.0",
    //     "performanceTiming": {
    //         "navigationStart": 1724052379766,
    //         "unloadEventStart": 0,
    //         "unloadEventEnd": 0,
    //         "redirectStart": 0,
    //         "redirectEnd": 0,
    //         "fetchStart": 1724052379766,
    //         "domainLookupStart": 1724052379766,
    //         "domainLookupEnd": 1724052379766,
    //         "connectStart": 1724052379766,
    //         "connectEnd": 1724052379766,
    //         "secureConnectionStart": 0,
    //         "requestStart": 1724052379766,
    //         "responseStart": 1724052379766,
    //         "responseEnd": 1724052379766,
    //         "domLoading": 1724052380035,
    //         "domInteractive": 1724052380184,
    //         "domContentLoadedEventStart": 1724052380184,
    //         "domContentLoadedEventEnd": 1724052380189,
    //         "domComplete": 1724052380230,
    //         "loadEventStart": 1724052380230,
    //         "loadEventEnd": 1724052380230
    //     },
    //     "navigation": {
    //         "type": 0,
    //         "redirectCount": 0
    //     },
    //     "ttfb": 0,
    //     "domReady": 418,
    //     "qs": "?traceid=fixed_innerid_KDAPP-96SS-HDY-1&innerid=KDAPP-96SS-HDY-1",
    //     "firstScreen": 418,
    //     "routelabel": 0,
    //     "firstSource": "api",
    //     "dt": 1724052381231,
    //     "fbextension": "",
    //     "source": "mozilla/5.0 (iphone; cpu iphone os 16_6_1 like mac os x) applewebkit/605.1.15 (khtml, like gecko) mobile/15e148 iphone 14 pro aladdinhybrid/4.8.77 (paebank 6.23.0) aladdinbridge/3.0.0 subcontracting/appstore deviceid/auuid_918d439ffcef935c2fd84d3a3e593b6523c916fc unionpay/1.0 pabank devicetype/1 networkstate/wifi kiwibridge/1.0.0 device-dpr/3 device-dr/852*393 appstyle/bz bz-navbarheight/309 dztab-navbarheight/327 pageactionid/662fc3b8",
    //     "webtrendsid": "AUUID_918d439ffcef935c2fd84d3a3e593b6523c916fc",
    //     "appversion": "6.23.0",
    //     "platform": "ios",
    //     "pageID": "PK084123",
    //     "h5_app_id": "A208848050024B1584C78C904A4900E4",
    //     "pagetitle": "宜家礼品卡88折起",
    //     "ymd": "2024-08-19 15:26:21",
    //     "page": "https://b.pingan.com.cn/kuaizhan/v2/5K2422/20230925/k84123/index.html",
    //     "requestId": "6ugxCquxgrG49lDeOVXSqw61OT00123s"
    // };
    try {
        reqObject = JSON.parse(decodeURIComponent(uploadInfo));
    } catch (error) {

    }
}


async function getPageData() {
    let url = `https://b.pingan.com.cn/kuaizhan/v2/5K2422/20230925/k84123/pageData.js?v=${new Date().getTime()}`;
    let body = ``;
    let headers = {
        'Cookie': magicJS.data.read(PingAnConstKey.Cookie, ''),
        'Sec-Fetch-Mode': `navigate`,
        'Connection': `keep-alive`,
        'Accept': `text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8`,
        'Accept-Encoding': `gzip, deflate, br`,
        'Host': `b.pingan.com.cn`,
        'User-Agent': `${gAppUserAgent}`,
        'Sec-Fetch-Site': `none`,
        'Accept-Language': `zh-CN,zh-Hans;q=0.9`,
        'Sec-Fetch-Dest': `document`,
        // 'If-Modified-Since': `Thu, 18 Jul 2024 11:10:01 GMT`
    };;
    let options = {
        url: url,
        headers: headers,
        body: body,
    };
    let result = await magicJS.http.get(options).then(response => {
        try {
            const body = response.body;
            let rspData = null;
            let retMatch = body.match(/var pageData = ([\s\S]*)/); // 正则表达式匹配
            if (retMatch) {
                rspData = JSON.parse(retMatch[1]);
            }
            // magicJS.logger.info(`rspData=${JSON.stringify(rspData)}`);
            return rspData;
        } catch (e) {
            magicJS.logger.error(e);
        }
    }).catch(err => {
        const msg = `请求页面配置数据异常\n${JSON.stringify(err)}`;
        magicJS.logger.error(msg);
    });
    return result;
}

async function checkGetPageData() {
    let strToday = magicJS.formatDate(new Date(), 'yyyy-MM-dd');
    let key = `${PingAnConstKey.PageData}`;
    let cacheData = magicJS.data.read(key, null);
    if (cacheData && cacheData.storeDate == strToday) {
        magicJS.logger.info(`今日已更新过活动页面数据`);
        gPageData = cacheData.data;
    } else {
        magicJS.logger.info(`今日首次更新活动页面数据`);
        gPageData = await getPageData();
        magicJS.data.write(key, { storeDate: strToday, data: gPageData });
    }
    if (gPageData) {
        let buildTime = gPageData.buildTime;
        magicJS.logger.info(`当前活动页面数据最新构建时间：${magicJS.formatDate(new Date(buildTime), 'yyyy-MM-dd')}`);
    }
    return gPageData;
}

async function getClientTag() {
    if (!gPageData) {
        gPageData = await checkGetPageData();
    }
    if (!gPageData) {
        return;
    }
    let clientTag = '';
    let widgets = gPageData.widgets;
    for (let i = 0; i < widgets.length; i++) {
        const widget = widgets[i];
        if (widget.label.indexOf('简易规则') > -1) {
            clientTag = widget.config.clientTag;
        }
    }
    return clientTag;
}

function getResponseErrorMsg(errCode, config, responseMsg) {
    let key = errCodeStrMap[errCode];
    if (key && config && config[key]) {
        return config[key].toastText || responseMsg;
    } else {
        return responseMsg;
    }
}

function setActCouponStatus(activityCode, status) {
    let day = magicJS.formatDate(new Date(), 'yyyy-MM-dd');
    let key = `PingAnIKEA#${activityCode}_${day}`;
    magicJS.data.write(key, status);
    if (status == 1 || status == 2) {// 已领取
        key = `PingAnIKEA#${activityCode}_CouponGotTime}`;
        magicJS.data.write(key, new Date().getTime());
    }
}

function getActCouponStatus(activityCode) {
    let day = magicJS.formatDate(new Date(), 'yyyy-MM-dd');
    let key = `PingAnIKEA#${activityCode}_${day}`;
    let status = magicJS.data.read(key, -1);
    return Number(status);
}

// 今日是否执行过获取优惠券任务
function isCouponExecToday(activityCode) {
    if (gIgnoreCouponGotStatus) {
        return false;
    }
    let status = getActCouponStatus(activityCode);
    if (status == 1 || status == 2 || status == 3) {
        return true;
    } else if (status == -1) {
        return false;
    } else {
        return false;
    }
}

// 当月是否领取过优惠券
function hasCouponGotMonth(activityCode) {
    if (gIgnoreCouponGotStatus) {
        return false;
    }
    let key = `PingAnIKEA#${activityCode}_CouponGotTime}`;
    let strNum = magicJS.data.read(key, null);
    if (strNum) {
        let now = new Date();
        let date = new Date(Number(strNum));
        if (now.getFullYear() == date.getFullYear() && now.getMonth() == date.getMonth()) {
            return true;
        }
        return false;
    }
    return false;
}

function hasCouponGotWeek(activityCode) {
    if (gIgnoreCouponGotStatus) {
        return false;
    }
    let key = `PingAnIKEA#${activityCode}_CouponGotTime}`;
    let strNum = magicJS.data.read(key, null);
    if (strNum) {
        let now = new Date();
        let date = new Date(Number(strNum));
        if (isSameWeek(now, date)) {
            return true;
        }
        return false;
    }
    return false;
}

function hasCouponGotDay(activityCode) {
    if (gIgnoreCouponGotStatus) {
        return false;
    }
    let key = `PingAnIKEA#${activityCode}_CouponGotTime}`;
    let strNum = magicJS.data.read(key, null);
    if (strNum) {
        let now = new Date();
        let date = new Date(Number(strNum));
        if (now.getFullYear() == date.getFullYear() && now.getMonth() == date.getMonth() && now.getDate() == date.getDate()) {
            return true;
        }
        return false;
    }
    return false;
}


function isSameWeek(date1, date2) {
    // 获取每个日期的星期几
    const day1 = date1.getDay(); // 返回值为 0（周日）到 6（周六）
    const day2 = date2.getDay();

    // 获取每个日期的时间戳
    const time1 = date1.getTime();
    const time2 = date2.getTime();

    // 根据星期几和时间戳判断是否属于同一个星期
    const weekDiff = Math.floor(Math.abs(time1 - time2) / (1000 * 60 * 60 * 24 * 7));

    if (day1 <= day2) {
        return weekDiff === 0;
    } else {
        return weekDiff === 1;
    }
}

async function tryGrabCoupon() {
    gPageData = await checkGetPageData();
    let widgets = gPageData.widgets;
    let sk88Names = ['【天天88】满100减12优惠券'];
    // 天天88
    let path88 = ['pwm-kuaizhan-section', 'pwm-mkt-offer'];
    // 五折限量购
    let sk55Names = ['【五折限量购】满100减50优惠券'];
    let path55 = ['pwm-kuaizhan-simple-rule', 'pwm-kuaizhan-section', 'pwm-mkt-offer'];
    // 9.25折限量购
    let sk925Names = [
        '【9.25折限量折扣】满100减7.5优惠券',
        '【9.25折限量折扣】满100减15优惠券',
        '【9.25折限量折扣】满100减37.5优惠券',
        '【9.25折限量折扣】满1000减75优惠券',
    ];
    let path925 = ['pwm-kuaizhan-section-split', 'pwm-kuaizhan-section', 'pwm-mkt-offer'];

    let items925 = seekWidgets(widgets, path925);

    let isLogin = true;
    let strLoginFailMsg = `登录失败，请点击通知栏打开APP下载页面`;
    magicJS.logger.info(`########9.25折限量购########`);
    for (let i = items925.length - 1; i >= 0; i--) {
        const item = items925[i];
        const config = item.config;
        if (isCouponExecToday(config.activityCode)) {
            magicJS.logger.info(`${sk925Names[i]}今天已经执行过了[${config.activityCode}]`);
            continue;
        }
        if (hasCouponGotMonth(config.activityCode)) {
            magicJS.logger.info(`${sk925Names[i]}本月已经领过了[${config.activityCode}]`);
            continue;
        }
        // magicJS.logger.info(`activityCode=${config.activityCode} activityValue=${config.activityValue}`);
        let ret = await doGrabCoupon(config.activityCode, config.activityValue);
        let tipsText = ``;
        if (ret) {
            if (ret.responseCode == '900100') {//未登录
                isLogin = false;
                strLoginFailMsg = ret.responseMsg;
                // magicJS.notification.appendNotifyInfo(ret.responseMsg);
                break;
            }
            if (ret.data) {
                let activityData = ret.data.activityData;
                if (activityData) {
                    sk925Names[i] = activityData.activityName;
                }
            }
            if (ret.responseCode == '000000') {
                setActCouponStatus(config.activityCode, 1);
            } else if (ret.responseCode == '950008' || ret.responseCode == '900745' || ret.responseCode == '950009') {//领奖机会已经用完
                setActCouponStatus(config.activityCode, 2);
            } else if (ret.responseCode == '960002') {//今天奖励已经发完
                setActCouponStatus(config.activityCode, 3);
            } else if (ret.responseCode == '900130') {//不符合领取规则
                setActCouponStatus(config.activityCode, 3);
            }
            if (ret.responseCode == '000000') {
                tipsText = `${sk925Names[i]}-领取成功`;
            } else {
                tipsText = sk925Names[i] + '-' + getResponseErrorMsg(ret.responseCode, config, ret.responseMsg)
            }
        } else {
            tipsText = `${sk925Names[i]}-领取失败`;
        }
        magicJS.notification.appendNotifyInfo(tipsText);
    }
    if (!isLogin) {
        let params = {
            "td": {
                "id": "唤醒浮层",
                "label": "APP下载浮层立即打开-样式2",
                "param": { "dlink_id": "M0P5EnN0addUoXCs240814104407" },
                "pageId": "PK084123"
            },
            "url": "https://b.pingan.com.cn/kuaizhan/v2/5K2422/20230925/k84123/index.html? paesuperbank=%7B%22dLinkId%22%3A%22M0P5EnN0addUoXCs240814104407%22%7D"
        };
        let schemaUrl = `paesuperbank://?paesuperbank=${encodeURIComponent(JSON.stringify(params))}`;
        magicJS.notification.post(scriptName, '', strLoginFailMsg, schemaUrl);
        return;
    }
    magicJS.logger.info(`##########天天88##########`);
    let items88 = seekWidgets(widgets, path88);
    for (let i = 0; i < items88.length; i++) {
        const item = items88[i];
        const config = item.config;
        if (isCouponExecToday(config.activityCode)) {
            magicJS.logger.info(`${sk88Names[i]}今天已经执行过了[${config.activityCode}]`);
            continue;
        }
        if (hasCouponGotMonth(config.activityCode)) {
            magicJS.logger.info(`${sk88Names[i]}本月已经领过了[${config.activityCode}]`);
            continue;
        }
        // magicJS.logger.info(`activityCode=${config.activityCode} activityValue=${config.activityValue}`);
        let ret = await doGrabCoupon(config.activityCode, config.activityValue);
        let tipsText = ``;
        if (ret) {
            if (ret.responseCode == '900100') {//未登录
                magicJS.notification.appendNotifyInfo(ret.responseMsg);
                break;
            }
            if (ret.data) {
                let activityData = ret.data.activityData;
                if (activityData) {
                    sk88Names[i] = activityData.activityName;
                }
            }
            if (ret.responseCode == '000000') {
                setActCouponStatus(config.activityCode, 1);
            } else if (ret.responseCode == '950008' || ret.responseCode == '900745' || ret.responseCode == '950009') {//领奖机会已经用完
                setActCouponStatus(config.activityCode, 2);
            } else if (ret.responseCode == '960002') {//今天奖励已经发完
                setActCouponStatus(config.activityCode, 3);
            } else if (ret.responseCode == '900130') {//不符合领取规则
                setActCouponStatus(config.activityCode, 3);
            }
            if (ret.responseCode == '000000') {
                tipsText = `${sk88Names[i]}-领取成功`;
            } else {
                tipsText = sk88Names[i] + '-' + getResponseErrorMsg(ret.responseCode, config, ret.responseMsg)
            }
        } else {
            tipsText = `${sk88Names[i]}-领取失败`;
        }
        magicJS.notification.appendNotifyInfo(tipsText);
    }

    magicJS.logger.info(`########五折限量购########`);
    let items55 = seekWidgets(widgets, path55);
    for (let i = 0; i < items55.length; i++) {
        const item = items55[i];
        const config = item.config;
        if (isCouponExecToday(config.activityCode)) {
            magicJS.logger.info(`${sk55Names[i]}今天已经执行过了[${config.activityCode}]`);
            continue;
        }
        if (hasCouponGotMonth(config.activityCode)) {
            magicJS.logger.info(`${sk55Names[i]}本月已经领过了[${config.activityCode}]`);
            continue;
        }
        // magicJS.logger.info(`activityCode=${config.activityCode} activityValue=${config.activityValue}`);
        let ret = await doGrabCoupon(config.activityCode, config.activityValue);
        let tipsText = ``;
        if (ret) {
            if (ret.responseCode == '900100') {//未登录
                magicJS.notification.appendNotifyInfo(ret.responseMsg);
                break;
            }
            if (ret.data) {
                let activityData = ret.data.activityData;
                if (activityData) {
                    sk55Names[i] = activityData.activityName;
                }
            }
            if (ret.responseCode == '000000') {
                setActCouponStatus(config.activityCode, 1);
            } else if (ret.responseCode == '950008' || ret.responseCode == '900745' || ret.responseCode == '950009') {//领奖机会已经用完
                setActCouponStatus(config.activityCode, 2);
            } else if (ret.responseCode == '960002') {//今天奖励已经发完
                setActCouponStatus(config.activityCode, 3);
            } else if (ret.responseCode == '900130') {//不符合领取规则
                setActCouponStatus(config.activityCode, 3);
            }
            if (ret.responseCode == '000000') {
                tipsText = `${sk55Names[i]}-领取成功`;
            } else {
                tipsText = sk55Names[i] + '-' + getResponseErrorMsg(ret.responseCode, config, ret.responseMsg)
            }
        } else {
            tipsText = `${sk55Names[i]}-领取失败`;
        }
        magicJS.notification.appendNotifyInfo(tipsText);
    }
}

function seekWidgets(widgets, namePaths, layer = 0) {
    let retLst = [];
    let name = namePaths[layer];
    if (namePaths.length == layer + 1) {
        for (let i = 0; i < widgets.length; i++) {
            const widget = widgets[i];
            if (widget.name == name) {
                retLst.push(widget);
            }
        }
    } else {
        for (let i = 0; i < widgets.length; i++) {
            const widget = widgets[i];
            if (widget.name == name) {
                retLst = retLst.concat(seekWidgets(widget.widgets, namePaths, layer + 1));
            }
        }
    }
    return retLst;
}

async function doGrabCoupon(activityCode, activityValue) {
    let result = await queryCustomerActivityStatus(activityCode, activityValue);
    if (result && gIgnoreActivityStatus) {
        result.responseCode = '000000';
    }
    if (result && result.responseCode == '000000') {
        result = await sendCustomerOffer(activityCode, activityValue);
    }
    return result;
}

async function queryCustomerActivityStatus(activityCode, activityValue, channelSource = 'KOUDAI', taskProVal = '') {
    let reqData = {
        activityCode: activityCode,
        activityValue: activityValue,
        channelSource: channelSource,
        taskProVal: taskProVal || '',
    };
    let url = `https://rsb.pingan.com.cn/brop/mop/cust/mopsf/uc/auth/lottery/queryCustomerActivityStatus?${magicJS.objToQueryStr(reqData)}`;
    let headers = gCommonHeaders;
    let options = {
        url: url,
        headers: headers,
        body: ``,
    };

    let result = await magicJS.http.get(options).then(response => {
        try {
            let rspData = response.body;
            magicJS.logger.info(`rspData=${JSON.stringify(rspData)}`);
            return rspData;
        } catch (e) {
            magicJS.logger.error(e);
        }
    }).catch(err => {
        const msg = `请求用户活动状态异常\n${JSON.stringify(err)}`;
        magicJS.logger.error(msg);
    });
    return result;
}

async function sendCustomerOffer(activityCode, activityValue, channelSource = 'KOUDAI', taskProVal = '') {
    let url = `https://rsb.pingan.com.cn/brop/mop/cust/mopsf/uc/auth/lottery/sendCustomerOffer`;
    let info = {
        MGM: {
            activity_flowid: undefined,
            activity_id: undefined,
        },
        N: {
            campaignid: undefined,
            channel_source: undefined,
            source: 'all',
            innerid: 'KDAPP-96SS-HDY-1',
            outersource: undefined,
        },
        W: {
            outerid: undefined,
        },
    };
    let orderNo = '';
    let traceid = 'fixed_innerid_KDAPP-96SS-HDY-1';
    let offerAppid = '';
    let buryData = {
        "login_type": `Mozilla/5.0 (iPhone; CPU iPhone OS 16_6_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 iphone 14 pro AladdinHybrid/4.8.77 (PAEBank 6.23.0) AladdinBridge/3.0.0 subContracting/AppStore deviceId/${gDeviceId} UnionPay/1.0 PABANK deviceType/1 networkState/WIFI KiwiBridge/1.0.0 device-dpr/3 device-dr/852*393 AppStyle/BZ bz-navbarHeight/309 dzTab-navbarHeight/327 pageActionId/${gPageActionId}`,
        "idfa": "00000000-0000-0000-0000-000000000000",
        "osVersion": "16.6.1",
        "memoryStatus": { "totalMemory": 5644, "usedMemory": 3700 + Math.ceil(160 * Math.random()) },
        "language": "zh-Hans-CN",
        "deviceId": gDeviceId,
        "deviceType": "1",
        "sourceIP": "10.4.175.51",
        "deviceName": "iPhone",
        "vpn": "1",
        "isJailBroken": false,
        "deviceToken": "524be0e96038a72223cfe66c8c9044c65227c9c818225a28159100bbd9729ba4",
        "wifiMac": "Not Found",
        "appVersion": "6.23.0",
        "wifiSid": "Not Found",
        "appName": "平安口袋银行App",
        "idfv": "07A9900D-FBD5-4EB4-B16D-830E090913CF",
        "deviceModel": "iphone 14 pro",
        "aldDeviceId": "8A093177-C77E-49B6-B096-63F736D4B9F5",
        "osName": "iOS",
        "sourceIPType": "04",
        "subContracting": "AppStore"
    };
    let modifyNoVpn = true;
    if (modifyNoVpn) {
        buryData.vpn = '0';
        buryData.sourceIP = '14.145.199.18';
    }
    let reqData = {
        activityCode: activityCode,
        activityValue: activityValue,
        activityFlowId: String(info.MGM.activity_flowid),
        activityId: String(info.MGM.activity_id),
        buryData: encodeURIComponent(JSON.stringify(buryData)),
        campaignId: String(info.N.campaignid),
        channelsource: String(info.N.channel_source),
        channelSource: channelSource,
        drawTimesQueryFLag: "1",
        innerid: info.N.innerid,
        orderNo: orderNo,
        outerid: String(info.W.outerid),
        outersource: String(info.N.outersource),
        source: info.N.source,
        taskProVal: taskProVal,
        offerAppid: offerAppid,
        traceId: traceid
    }

    let headers = gCommonHeaders;
    let options = {
        url: url,
        headers: headers,
        body: magicJS.objToQueryStr(reqData),
    };

    let result = await magicJS.http.post(options).then(response => {
        try {
            let rspData = response.body;
            magicJS.logger.info(`rspData=${JSON.stringify(rspData)}`);
            return rspData;
        } catch (e) {
            magicJS.logger.error(e);
        }
    }).catch(err => {
        const msg = `请求用户报单异常\n${JSON.stringify(err)}`;
        magicJS.logger.error(msg);
    });
    return result;
}

Main().catch((e) => magicJS.logger.log(`-\n ${e}`)).finally(() => magicJS.done());

//---SyncByPyScript---MagicJS3-start
function MagicJS(e = "MagicJS", t = "INFO") { const r = () => { const e = "undefined" != typeof $loon, t = "undefined" != typeof $task, n = "undefined" != typeof module, r = "undefined" != typeof $httpClient && !e, o = "undefined" != typeof $storm, i = "undefined" != typeof $environment && void 0 !== $environment["stash-build"]; var s = r || e || o || i; const a = "undefined" != typeof importModule; return { isLoon: e, isQuanX: t, isNode: n, isSurge: r, isStorm: o, isStash: i, isSurgeLike: s, isScriptable: a, get name() { return e ? "Loon" : t ? "QuantumultX" : n ? "NodeJS" : r ? "Surge" : a ? "Scriptable" : "unknown" }, get build() { return r ? $environment["surge-build"] : i ? $environment["stash-build"] : o ? $storm.buildVersion : void 0 }, get language() { if (r || i) return $environment.language }, get version() { return r ? $environment["surge-version"] : i ? $environment["stash-version"] : o ? $storm.appVersion : n ? process.version : void 0 }, get system() { return r ? $environment.system : n ? process.platform : void 0 }, get systemVersion() { if (o) return $storm.systemVersion }, get deviceName() { if (o) return $storm.deviceName } } }, o = (n, e = "INFO") => { let r = e, t = "\n"; const o = { SNIFFER: 6, DEBUG: 5, INFO: 4, NOTIFY: 3, WARNING: 2, ERROR: 1, CRITICAL: 0, NONE: -1 }, i = { SNIFFER: "", DEBUG: "", INFO: "", NOTIFY: "", WARNING: "❗ ", ERROR: "❌ ", CRITICAL: "❌ ", NONE: "" }, s = (e, t = "INFO") => { o[r] < o[t.toUpperCase()] || console.log(`██[${n}][${t}]` + i[t.toUpperCase()] + e + "\n") }; return { getLevel: () => r, setLevel: e => { r = e }, sniffer: (...e) => { e = e.join(t); s(e, "SNIFFER") }, log: (...e) => { e = e.join(t); console.log(`██[${n}]` + e + "\n") }, debug: (...e) => { e = e.join(t); s(e, "DEBUG") }, info: (...e) => { e = e.join(t); s(e, "INFO") }, notify: (...e) => { e = e.join(t); s(e, "NOTIFY") }, warning: (...e) => { e = e.join(t); s(e, "WARNING") }, error: (...e) => { e = e.join(t); s(e, "ERROR") }, retry: (...e) => { e = e.join(t); s(e, "RETRY") } } }; return new class { constructor(e, t) { var n; this._startTime = Date.now(), this.version = "3.0.0", this.scriptName = e, this.env = r(), this.logger = o(e, t), this.http = "function" == typeof MagicHttp ? MagicHttp(this.env, this.logger) : void 0, this.data = "function" == typeof MagicData ? MagicData(this.env, this.logger) : void 0, this.notification = "function" == typeof MagicNotification ? MagicNotification(this.scriptName, this.env, this.logger, this.http) : void 0, this.utils = "function" == typeof MagicUtils ? MagicUtils(this.env, this.logger) : void 0, this.qinglong = "function" == typeof MagicQingLong ? MagicQingLong(this.env, this.data, this.logger) : void 0, void 0 !== this.data && (t = this.data.read("magic_loglevel"), n = this.data.read("magic_bark_url"), t && this.logger.setLevel(t.toUpperCase()), n) && this.notification.setBark(n), this.logger.info(e + ", 开始执行!") } get isRequest() { return "undefined" != typeof $request } get isStrictRequest() { return "undefined" != typeof $request && "undefined" == typeof $response } get isResponse() { return "undefined" != typeof $response } get isDebug() { return "DEBUG" === this.logger.level } get request() { return "undefined" != typeof $request ? $request : void 0 } get response() { if ("undefined" != typeof $response) return $response.hasOwnProperty("status") && ($response.statusCode = $response.status), $response.hasOwnProperty("statusCode") && ($response.status = $response.statusCode), $response } log(...e) { this.logger.log(e) } toStr(e, t = null) { try { return JSON.stringify(e) } catch { return t } } toObj(e, t = null) { try { return JSON.parse(e) } catch { return t } } checkRecordRequestBody() { if (this.isRequest) { var t = $request.body; if (t) { var n = this.env, r = $request.path; let e = this.scriptName + "#" + r.replace("/", "_"); e = e.replace("?", "#"), n.isQuanX && $prefs.setValueForKey(t, e), (n.isLoon || n.isSurge) && $persistentStore.write(t, e), n.isNode && require("fs").writeFileSync(e + ".json", t, { flag: "w" }, e => console.log(e)) } } } getRequestBody() { var e = this.env, t = $request.path; let n = this.scriptName + "#" + t.replace("/", "_"); if (n = n.replace("?", "#"), e.isSurge || e.isLoon) return $persistentStore.read(n); if (e.isQuanX) return $prefs.valueForKey(n); if (e.isNode) { t = n + ".json", e = require("fs"); if (!e.existsSync(t)) return JSON.parse(e.readFileSync(t)) } } getResponseBody() { if ($response) return $response.body } parseCookies(e) { let t = {}; return e && e.split(";").forEach(function (e) { e = e.split("="); t[e.shift().trim()] = decodeURI(e.join("=")) }), t } serializeCookies(e) { var t, n = []; for (t in e) { var r = e[t], r = encodeURIComponent(t) + "=" + encodeURIComponent(r); n.push(r) } return n.join("; ") } parseSetCookies(e) { const o = ["Expires", "Max-Age", "Domain", "Path", "HttpOnly", "SameSite"]; e = e.split(";"); let i = null; const s = {}, a = []; return e.forEach(e => { var t, e = e.trim(); let n = null, r = !0; if (e.includes("=") ? (t = e.split("="), n = t[0].trim(), r = t[1].trim()) : n = e, o.includes(n)) s[i] && (s[i][n] = r, s[i].attribs[n] = r); else { i = n; let t = {}; i.includes(",") && i.split(",").forEach(e => { e = e.trim(); o.includes(e) ? t[e] = !0 : i = e }), s[i] = { name: i, value: r, attribs: t }, a.push(s[i]) } }), a } objToQueryStr(t, n) { let r = ""; for (const o in t) { let e = t[o]; null != e && "" !== e && ("object" == typeof e ? e = JSON.stringify(e) : n && (e = encodeURIComponent(e)), r += `${o}=${e}&`) } return r = r.substring(0, r.length - 1) } parseQueryStr(e) { var t = {}, n = (e = -1 < e.indexOf("?") ? e.split("?")[1] : e).split("&"); for (let e = 0; e < n.length; e++) { var r = n[e].split("="); t[r[0]] = r[1] } return t } deepClone(e, t) { for (var n in t = t || {}, e) "object" == typeof e[n] ? (t[n] = e[n].constructor === Array ? [] : {}, this.deepClone(e[n], t[n])) : t[n] = e[n]; return t } formatDate(e, t) { var n, r = { "M+": e.getMonth() + 1, "d+": e.getDate(), "H+": e.getHours(), "m+": e.getMinutes(), "s+": e.getSeconds(), "q+": Math.floor((e.getMonth() + 3) / 3), S: e.getMilliseconds() }; for (n in /(y+)/.test(t) && (t = t.replace(RegExp.$1, (e.getFullYear() + "").substr(4 - RegExp.$1.length))), r) new RegExp("(" + n + ")").test(t) && (t = t.replace(RegExp.$1, 1 == RegExp.$1.length ? r[n] : ("00" + r[n]).substr(("" + r[n]).length))); return t } parseDate(a, e) { let l = { y: 0, M: 1, d: 0, H: 0, h: 0, m: 0, s: 0, S: 0 }; (e = e || "yyyy-MM-dd").replace(/([^yMdHmsS]*?)(([yMdHmsS])\3*)([^yMdHmsS]*?)/g, function (e, t, n, r, o, i, s) { return a = a.replace(new RegExp(t + "(\\d{" + n.length + "})" + o), function (e, t) { return l[r] = parseInt(t), "" }), "" }), l.M--; e = new Date(l.y, l.M, l.d, l.H, l.m, l.s); return 0 !== l.S && e.setMilliseconds(l.S), e } costTime() { var e = this.scriptName + "执行完毕！", t = (this._endTime = (new Date).getTime(), this._endTime - this._startTime); this.logger.info(e + `耗时【${t / 1e3}】秒`) } done = (e = {}) => { this.costTime(), "undefined" != typeof $done && $done(e) } }(e, t) } function MagicHttp(d, g) { var e; let p; d.isNode && (e = require("axios"), p = e.create()); class t { constructor(e = !0) { this.handlers = [], this.isRequest = e } use(e, t, n) { return "function" == typeof e && g.debug("Register fulfilled " + e.name), "function" == typeof t && g.debug("Register rejected " + t.name), this.handlers.push({ fulfilled: e, rejected: t, synchronous: !(!n || "boolean" != typeof n.synchronous) && n.synchronous, runWhen: n ? n.runWhen : null }), this.handlers.length - 1 } eject(e) { this.handlers[e] && (this.handlers[e] = null) } forEach(t) { this.handlers.forEach(e => { null !== e && t(e) }) } } function f(e) { let n = { ...e }; return n.params && !d.isNode && (e = Object.keys(n.params).map(e => { var t = encodeURIComponent(e); return n.url = n.url.replace(new RegExp(e + "=[^&]*", "ig"), ""), n.url = n.url.replace(new RegExp(t + "=[^&]*", "ig"), ""), t + "=" + encodeURIComponent(n.params[e]) }).join("&"), n.url.indexOf("?") < 0 && (n.url += "?"), /(&|\?)$/g.test(n.url) || (n.url += "&"), n.url += e, delete n.params, g.debug("Params to QueryString: " + n.url)), n } const y = (e, t = null) => { if (e) { t = { ...e, config: e.config || t, status: e.statusCode || e.status, body: e.body || e.data, headers: e.headers || e.header }; if ("string" == typeof t.body) try { t.body = JSON.parse(t.body) } catch { } return delete t.data, t } return e }; const h = (e, t = null) => { if (e && 400 <= e.status) return g.debug("Raise exception when status code is " + e.status), { name: "RequestException", message: "Request failed with status code " + e.status, config: t || e.config, response: e } }, m = { request: new t, response: new t(!1) }; let v = [], b = [], S = !0; function N(e) { return e = f(e), g.debug(`HTTP ${e.method.toUpperCase()}:` + "\n" + JSON.stringify(e)), e } function E(t) { try { t = t && y(t), g.sniffer(`HTTP ${t.config.method.toUpperCase()}:` + "\n" + JSON.stringify(t.config) + "\nSTATUS CODE:\n" + t.status + "\nRESPONSE:\n" + ("object" == typeof t.body ? JSON.stringify(t.body) : t.body)); var e = h(t); return e ? Promise.reject(e) : t } catch (e) { return g.error(e), t } } const n = (e, n) => { let r; n = ((e, t) => { let n = "object" == typeof t ? { headers: {}, ...t } : { url: t, headers: {} }; return n.method || (n.method = e), !0 === (n = f(n)).rewrite && (d.isSurge ? (n.headers["X-Surge-Skip-Scripting"] = !1, delete n.rewrite) : d.isQuanX && (n.hints = !1, delete n.rewrite)), d.isSurgeLike ? (t = n.headers["content-type"] || n.headers["Content-Type"], "GET" !== n.method && t && 0 <= t.indexOf("application/json") && n.body instanceof Array && (n.body = JSON.stringify(n.body), g.debug("Convert Array object to String: " + n.body))) : d.isQuanX ? (n.hasOwnProperty("body") && "string" != typeof n.body && (n.body = JSON.stringify(n.body)), n.method = e) : d.isNode && ("POST" === e || "PUT" === e || "PATCH" === e || "DELETE" === e ? n.data = n.data || n.body : "GET" === e && (n.params = n.params || n.body), delete n.body), n })(e.toUpperCase(), n), r = d.isNode ? p : d.isSurgeLike ? i => new Promise((r, o) => { $httpClient[e.toLowerCase()](i, (e, t, n) => { e ? (e = { name: e.name || e, message: e.message || e, stack: e.stack || e, config: i, response: y(t) }, o(e)) : (t.config = i, t.body = n, r(t)) }) }) : r => new Promise((n, t) => { $task.fetch(r).then(e => { e = y(e, r); var t = h(e, r); if (t) return Promise.reject(t); n(e) }).catch(e => { e = { name: e.message || e.error, message: e.message || e.error, stack: e.error, config: r, response: e.response ? y(e.response) : null }; t(e) }) }); let o; var t = n; try { v = [], b = [], m.request.forEach(e => { "function" == typeof e.runWhen && !1 === e.runWhen(t) || (S = S && e.synchronous, v.unshift(e.fulfilled, e.rejected)) }), m.response.forEach(e => { b.push(e.fulfilled, e.rejected) }) } catch (e) { g.error(`Failed to register interceptors: ${e}.`) } var i = [N, void 0], s = [E, void 0]; if (S) { for (g.debug("Interceptors are executed in synchronous mode"), Array.prototype.unshift.apply(v, i), v = v.concat([N, void 0]); v.length;) { var a = v.shift(), l = v.shift(); try { "function" == typeof a && g.debug("Executing request fulfilled " + a.name), n = a(n) } catch (e) { "function" == typeof l && g.debug("Executing request rejected " + l.name), l(e); break } } try { o = (!d.isNode && n.timeout ? c : r)(n) } catch (e) { return Promise.reject(e) } for (Array.prototype.unshift.apply(b, s); b.length;)o = o.then(b.shift(), b.shift()); return o } { g.debug("Interceptors are executed in asynchronous mode"); let t = [r, void 0]; for (Array.prototype.unshift.apply(t, i), Array.prototype.unshift.apply(t, v), t = (t = t.concat(s)).concat(b), o = Promise.resolve(n); t.length;)try { let e = t.shift(); var u = t.shift(); "function" == typeof (e = !d.isNode && n.timeout && e === r ? c : e) && g.debug("Executing request fulfilled " + e.name), "function" == typeof u && g.debug("Executing request rejected " + u.name), o = o.then(e, u) } catch (e) { g.error("request exception: " + e) } return o } function c(n) { try { var e = new Promise((e, t) => { setTimeout(() => { var e = { message: `timeout of ${n.timeout}ms exceeded.`, config: n }; t(e) }, n.timeout) }); return Promise.race([r(n), e]) } catch (e) { g.error(`Request Timeout exception: ${e}.`) } } }; return { request: n, interceptors: m, convertHeadersToLowerCase: n => Object.keys(n).reduce((e, t) => (e[t.toLowerCase()] = n[t], e), {}), convertHeadersToCamelCase: n => Object.keys(n).reduce((e, t) => { return e[t.split("-").map(e => e[0].toUpperCase() + e.slice(1)).join("-")] = n[t], e }, {}), modifyResponse: y, get: e => n("GET", e), post: e => n("POST", e), put: e => n("PUT", e), patch: e => n("PATCH", e), delete: e => n("DELETE", e), head: e => n("HEAD", e), options: e => n("OPTIONS", e) } } function MagicData(d, g) { let p = { fs: void 0, data: {} }; if (d.isNode) { p.fs = require("fs"); try { p.fs.accessSync("./magic.json", p.fs.constants.R_OK | p.fs.constants.W_OK) } catch (e) { p.fs.writeFileSync("./magic.json", "{}", { encoding: "utf8" }) } p.data = require("./magic.json") } const s = (e, t) => "object" != typeof t && e === t, a = e => "true" === e || "false" !== e && (void 0 === e ? null : e), l = (e, t, n, r) => { if (n) try { e = !0 === (e = "string" == typeof e ? JSON.parse(e) : e).magic_session ? e[n] : null } catch { e = null } if ("string" == typeof e && "null" !== e) try { e = JSON.parse(e) } catch { } return null == (e = !1 === r && e && !0 === e.magic_session ? null : e) && null != t && (e = t), e = a(e) }, f = t => { if ("string" != typeof t) return t instanceof Array || null == t || t != t || "boolean" == typeof t ? {} : t; { let e = {}; try { var n = typeof (e = JSON.parse(t)); ("object" != n || e instanceof Array || "bool" == n || null === e) && (e = {}) } catch { } return e } }, u = (e, t = null, n = "", r = !1, o = null) => { let i = ""; return i = o || d.isNode ? ((e, t = null, n = "", r = !1, o = null) => { o = o || p.data; return val = o && void 0 !== o[e] && null !== o[e] ? o[e] : n ? {} : null, val = l(val, t, n, r) })(e, t, n, r, o) : (d.isSurgeLike ? i = $persistentStore.read(e) : d.isQuanX && (i = $prefs.valueForKey(e)), l(i, t, n, r)), g.debug(`READ DATA [${e}]${n ? `[${n}]` : ""} <${typeof i}>` + "\n" + JSON.stringify(i)), i }, c = (e, t, n = "", r = null) => { if (void 0 === t || t != t) return !1; d.isNode || "boolean" != typeof t && "number" != typeof t || (t = String(t)); let o = ""; var i, s, a, l, u, c; if (r || d.isNode ? o = ([i, s, a = "", l = null] = [e, t, n, r], c = l || p.data, c = f(c), a ? ((u = f(c[i])).magic_session = !0, u[a] = s, c[i] = u) : c[i] = s, null !== l && (l = c), c) : n ? (d.isSurgeLike ? o = $persistentStore.read(e) ? $persistentStore.read(e) : o : d.isQuanX && (o = $prefs.valueForKey(e) ? $prefs.valueForKey(e) : o), (o = f(o)).magic_session = !0, o[n] = t) : o = t, o && "object" == typeof o && (o = JSON.stringify(o, null, 4)), g.debug(`WRITE DATA [${e}]${n ? `[${n}]` : ""} <${typeof t}>` + "\n" + JSON.stringify(t)), !r) { if (d.isSurgeLike) return $persistentStore.write(o, e); if (d.isQuanX) return $prefs.setValueForKey(o, e); if (d.isNode) try { p.fs.writeFileSync("./magic.json", o) } catch (e) { return g.error(e), !1 } } return !0 }; return { read: u, write: c, del: (e, t = "", n = null) => { let r = {}; if (n || d.isNode) r = (o = e, i = t, s = n || p.data, s = f(s), i ? (delete (obj = f(s[o]))[i], s[o] = obj) : delete s[o], s), n ? n = r : p.fs.writeFileSync("./magic.json", JSON.stringify(r, null, 4)); else if (t) { d.isSurgeLike ? r = $persistentStore.read(e) : d.isQuanX && (r = $prefs.valueForKey(e)), delete (r = f(r))[t]; i = JSON.stringify(r, null, 4); c(e, i) } else { if (d.isStorm) return $persistentStore.remove(e); if (d.isSurgeLike) return $persistentStore.write(null, e); if (d.isQuanX) return $prefs.removeValueForKey(e) } var o, i, s; g.debug(`DELETE KEY [${e}]` + (t ? `[${t}]` : "")) }, update: (e, t, n, r = s, o = null) => { var i; return t = a(t), !0 !== r(u(e, null, n, !1, o), t) && (i = c(e, t, n, o), e = u(e, null, n, !1, o), r === s && "object" == typeof e ? i : r(t, e)) }, allSessions: (e, t = null) => { let n = {}; t = u(e, null, null, !0, t); return !0 === (t = f(t)).magic_session && delete (n = { ...t }).magic_session, g.debug(`READ ALL SESSIONS [${e}] <${typeof n}>` + "\n" + JSON.stringify(n, null, 4)), n }, allSessionNames: (e, t = null) => { let n = []; t = u(e, null, null, !0, t), t = f(t); return n = !0 !== t.magic_session ? [] : Object.keys(t).filter(e => "magic_session" !== e), g.debug(`READ ALL SESSIONS [${e}] <${typeof n}>` + "\n" + JSON.stringify(n, null, 4)), n }, defaultValueComparator: s, convertToObject: f } } function MagicNotification(i, o, s, a) { let l = null, u = null, c = []; function d(e = i, t = "", n = "", r = "") { r = (t => { try { let e = {}; var n; return "string" == typeof t ? 0 < t.length && (o.isLoon ? e = { openUrl: t } : o.isQuanX ? e = { "open-url": t } : o.isSurge && (e = { url: t })) : "object" == typeof t && (o.isLoon ? (e.openUrl = t["open-url"] || "", e.mediaUrl = t["media-url"] || "") : o.isQuanX ? e = t["open-url"] || t["media-url"] ? t : {} : o.isSurge && (n = t["open-url"] || t.openUrl, e = n ? { url: n } : {})), e } catch (e) { s.error("通知选项转换失败" + e) } return t })(r), 1 === arguments.length && (e = i, t = "", n = arguments[0]), s.notify("\ntitle:" + e + "\nsubTitle:" + t + "\nbody:" + n + "\noptions:" + ("object" == typeof r ? JSON.stringify(r) : r)), o.isSurge ? $notification.post(e, t, n, r) : o.isLoon ? r ? $notification.post(e, t, n, r) : $notification.post(e, t, n) : o.isQuanX && $notify(e, t, n, r), l && u && g(e, t, n) } function g(e = i, t = "", n = "", r) { if (void 0 === a || void 0 === a.post) throw "Bark notification needs to import MagicHttp module."; e = { url: l, headers: { "content-type": "application/json; charset=utf-8" }, body: { title: e, body: t ? t + "\n" + n : n, device_key: u } }; a.post(e).catch(e => { s.error("Bark notify error: " + e) }) } return { post: d, debug: function (e = i, t = "", n = "", r = "") { "DEBUG" === s.getLevel() && (1 === arguments.length && (e = i, t = "", n = arguments[0]), this.post(e, t, n, r)) }, bark: g, setBark: e => { try { var t = e.replace(/\/+$/g, ""); l = /^https?:\/\/([^/]*)/.exec(t)[0] + "/push", u = /\/([^\/]+)\/?$/.exec(t)[1] } catch (e) { s.error(`Bark url error: ${e}.`) } }, appendNotifyInfo: function (e, t) { 1 == t ? c = e : c.push(e) }, prependNotifyInfo: function (e) { c.splice(0, 0, e) }, msg: function (e, t, n, r) { var o = {}; n && (o["open-url"] = n), r && (o["media-url"] = r), (t = t && 0 != t.length ? t : Array.isArray(c) ? c.join("\n") : c) && 0 < t.length && d(i, "", t, o) } } } function MagicUtils(r, u) { const e = (e, t = "yyyy-MM-dd hh:mm:ss") => { var n, r = { "M+": e.getMonth() + 1, "d+": e.getDate(), "h+": e.getHours(), "m+": e.getMinutes(), "s+": e.getSeconds(), "q+": Math.floor((e.getMonth() + 3) / 3), S: e.getMilliseconds() }; for (n in /(y+)/.test(t) && (t = t.replace(RegExp.$1, (e.getFullYear() + "").substr(4 - RegExp.$1.length))), r) new RegExp("(" + n + ")").test(t) && (t = t.replace(RegExp.$1, 1 === RegExp.$1.length ? r[n] : ("00" + r[n]).substr(("" + r[n]).length))); return t }; return { retry: (i, s = 5, a = 0, l = null) => (...e) => new Promise((n, r) => { function o(...t) { Promise.resolve().then(() => i.apply(this, t)).then(e => { "function" == typeof l ? Promise.resolve().then(() => l(e)).then(() => { n(e) }).catch(e => { 1 <= s ? 0 < a ? setTimeout(() => o.apply(this, t), a) : o.apply(this, t) : r(e), s-- }) : n(e) }).catch(e => { u.error(e), 1 <= s && 0 < a ? setTimeout(() => o.apply(this, t), a) : 1 <= s ? o.apply(this, t) : r(e), s-- }) } o.apply(this, e) }), formatTime: e, now: () => e(new Date, "yyyy-MM-dd hh:mm:ss"), today: () => e(new Date, "yyyy-MM-dd"), sleep: t => new Promise(e => setTimeout(e, t)), assert: (e, t = null) => { var n; r.isNode ? (n = require("assert"), t ? n(e, t) : n(e)) : !0 !== e && u.error("AssertionError: " + (t || "The expression evaluated to a falsy value.")) } } } function MagicQingLong(e, a, o) { let i = "", s = "", l = "", u = "", c = "", t = ""; const d = "magic.json", g = MagicHttp(e, o); async function n() { return l = l || a.read("magic_qlclient"), u = u || a.read("magic_qlsecrt"), s = s || a.read("magic_qlname"), c = c || a.read("magic_qlpwd"), i && l && u ? (o.info("Get token from QingLong Panel"), await g.get({ url: "/open/auth/token", headers: { "content-type": "application/json" }, params: { client_id: l, client_secret: u } }).then(e => { if (!(0 < Object.keys(e.body).length && e.body.data && e.body.data.token)) throw new Error("Get QingLong Panel token failed."); o.info("Successfully logged in to QingLong Panel"), t = e.body.data.token, a.write("magic_qltoken", t) }).catch(e => { o.error("Error logging in to QingLong Panel.\n" + (e.message || e)) })) : i && s && c && await g.post({ url: "/api/user/login", headers: { "content-type": "application/json" }, body: { username: s, password: c } }).then(e => { o.info("Successfully logged in to QingLong Panel"), t = e.body.data.token, a.write("magic_qltoken", t) }).catch(e => { o.error("Error logging in to QingLong Panel.\n" + (e.message || e)) }), t } async function p(e) { let t = []; return await g.post({ url: "/api/envs", headers: { "content-type": "application/json" }, body: e }).then(e => { 200 === e.body.code ? e.body.data.forEach(e => { o.debug(`QINGLONG ADD ENV ${e.name} <${typeof e.value}> (${e.id})` + "\n" + JSON.stringify(e)), t.push(e.id) }) : o.error("Error adding environments variable from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error adding environments variable from QingLong Panel.\n" + (e.message || e)) }), t } async function r(r = null, e = "", t) { let o = []; return await g.get({ url: "/api/envs", headers: { "content-type": "application/json" }, params: { searchValue: e } }).then(e => { if (200 !== e.body.code) throw new Error("Error reading environment variable from QingLong Panel.\n" + JSON.stringify(e)); e = e.body.data; if (r) { var t = []; for (const n of e) n.name === r && o.push(n); o = t } o = e }).catch(e => { throw new Error("Error reading environments variable from QingLong Panel.\n" + (e.message || e)) }), o } async function f(e, t = "") { let n = ""; return await g.get({ url: "/api/scripts/" + e, params: { path: t } }).then(e => { if (200 !== e.body.code) throw new Error("Error reading data from QingLong Panel.\n" + JSON.stringify(e)); n = e.body.data }).catch(e => { throw new Error("Error reading data from QingLong Panel.\n" + (e.message || e)) }), n } async function y(e, t = "", n = "") { let r = !1; return await g.put({ url: "/api/scripts", headers: { "content-type": "application/json" }, body: { filename: e, path: t, content: n } }).then(e => { 200 === e.body.code ? r = !0 : o.error("Error reading data from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error reading data from QingLong Panel.\n" + (e.message || e)) }), r } return g.interceptors.request.use(function (e) { return i = i || a.read("magic_qlurl"), e.url.indexOf(i) < 0 && (e.url = "" + i + e.url), { ...e, timeout: 3e3 } }, void 0), g.interceptors.request.use(function (e) { return (l = l || a.read("magic_qlclient")) && (e.url = e.url.replace("/api/", "/open/")), e }, void 0, { runWhen: e => e.url.indexOf("api/user/login") < 0 && e.url.indexOf("open/auth/token") < 0 }), g.interceptors.request.use(async function (e) { return (t = t || a.read("magic_qltoken", "")) || await n(), e.headers.authorization = "Bearer " + t, e }, void 0, { runWhen: e => e.url.indexOf("api/user/login") < 0 && e.url.indexOf("open/auth/token") < 0 }), g.interceptors.request.use(function (e) { return e.params = { ...e.params, t: Date.now() }, e }, void 0, { runWhen: e => e.url.indexOf("open/auth/token") < 0 }), g.interceptors.request.use(function (e) { return i = i || a.read("magic_qlurl"), t = t || a.read("magic_qltoken"), o.debug("QingLong url: " + i + "\nQingLong token: " + t), e }, void 0), g.interceptors.response.use(void 0, async function (e) { try { var t = e.message || e.error || JSON.stringify(e); return (0 <= t.indexOf("NSURLErrorDomain") && 0 <= t.indexOf("-1012") || e.response && 401 === e.response.status) && e.config && !0 !== e.config.refreshToken ? (o.warning("QingLong Panel token has expired"), o.info("Refreshing the QingLong Panel token"), await n(), e.config.refreshToken = !0, o.info("Call the previous method again"), await g.request(e.config.method, e.config)) : Promise.reject(e) } catch (e) { return Promise.reject(e) } }), { url: i || a.read("magic_qlurl"), init: (e, t, n, r, o) => { i = e, l = t, u = n, s = r, c = o }, getToken: n, setEnv: async function (t, n, r = null) { if (i = i || a.read("magic_qlurl"), null === r) { var e = await p([{ name: t, value: n }]); if (e && 1 === e.length) return e[0] } else await g.put({ url: "/api/envs", headers: { "content-type": "application/json" }, body: { name: t, value: n, id: r } }).then(e => { if (200 === e.body.code) return o.debug(`QINGLONG UPDATE ENV ${t} <${typeof n}> (${r})` + "\n" + JSON.stringify(n)), !0; o.error("Error adding environment variable from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => (o.error("Error adding environment variable from QingLong Panel.\n" + (e.message || e)), !1)) }, setEnvs: p, getEnv: async function (e) { let t = null; for (const n of await r()) if (n.id === e) { t = n; break } return t }, getEnvs: r, delEnvs: async function (t) { return g.delete({ url: "/api/envs", headers: { accept: "application/json", "accept-language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6", connection: "keep-alive", "content-type": "application/json;charset=UTF-8", "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.5005.63 Safari/537.36 Edg/102.0.1245.30" }, body: t }).then(e => 200 === e.body.code ? (o.debug("QINGLONG DELETE ENV IDS: " + t), !0) : (o.error("Error deleting environments variable from QingLong Panel.\n" + JSON.stringify(e)), !1)).catch(e => { o.error("Error deleting environments variable from QingLong Panel.\n" + (e.message || e)) }) }, disableEnvs: async function (t) { let n = !1; return await g.put({ url: "/api/envs/disable", headers: { accept: "application/json", "accept-Language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6", connection: "keep-alive", "content-type": "application/json;charset=UTF-8", "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.5005.63 Safari/537.36 Edg/102.0.1245.30" }, body: t }).then(e => { 200 === e.body.code ? (o.debug("QINGLONG DISABLED ENV IDS: " + t), n = !0) : o.error("Error disabling environments variable from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error disabling environments variable from QingLong Panel.\n" + (e.message || e)) }), n }, enableEnvs: async function (t) { let n = !1; return await g.put({ url: "/api/envs/enable", headers: { accept: "application/json", "accept-language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6", connection: "keep-alive", "content-type": "application/json;charset=UTF-8", "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.5005.63 Safari/537.36 Edg/102.0.1245.30" }, body: t }).then(e => { 200 === e.body.code ? (o.debug("QINGLONG ENABLED ENV IDS: " + t), n = !0) : o.error("Error enabling environments variable from Qilong panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error enabling environments variable from Qilong panel.\n" + (e.message || e)) }), n }, addScript: async function (e, t = "", n = "") { let r = !1; return await g.post({ url: "/api/scripts", headers: { "content-type": "application/json" }, body: { filename: e, path: t, content: n } }).then(e => { 200 === e.body.code ? r = !0 : o.error("Error reading data from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error reading data from QingLong Panel.\n" + (e.message || e)) }), r }, getScript: f, editScript: y, delScript: async function (e, t = "") { let n = !1; return await g.delete({ url: "/api/scripts", headers: { "content-type": "application/json" }, body: { filename: e, path: t } }).then(e => { 200 === e.body.code ? n = !0 : o.error("Error reading data from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error reading data from QingLong Panel.\n" + (e.message || e)) }), n }, write: async function (e, t, n = "") { var r = await f(d, ""), o = a.convertToObject(r), e = a.write(e, t, n, o), r = JSON.stringify(o, null, 4); return await y(d, "", r) && e }, read: async function (e, t, n = "", r = !1) { var o = await f(d, ""), o = a.convertToObject(o); return a.read(e, t, n, r, o) }, del: async function (e, t = "") { var n = await f(d, ""), r = a.convertToObject(n), e = a.del(e, t, r), n = JSON.stringify(r, null, 4), t = await y(d, "", n); return e && t }, update: async function (e, t, n, r = a.defaultValueComparator) { var o = await f(d, ""), i = a.convertToObject(o), e = a.update(e, t, n, r, i); let s = !1; return !0 === e && (o = JSON.stringify(i, null, 4), s = await y(d, "", o)), e && s }, batchWrite: async function (...e) { var t, n = await f(d, ""), r = a.convertToObject(n); for (t of e) a.write(t[0], t[1], void 0 !== t[2] ? t[2] : "", r); return n = JSON.stringify(r, null, 4), y(d, "", n) }, batchRead: async function (...e) { var t, n = await f(d, ""), r = a.convertToObject(n), o = []; for (t of e) { var i = a.read(t[0], t[1], void 0 !== t[2] ? t[2] : "", "boolean" == typeof t[3] && t[3], r); o.push(i) } return o }, batchUpdate: async function (...e) { var t, n = await f(d, ""), r = a.convertToObject(n); for (t of e) a.update(t[0], t[1], void 0 !== t[2] ? t[2] : "", void 0 !== t[3] ? t.comparator : a.defaultValueComparator, r); return n = JSON.stringify(r, null, 4), y(d, "", n) }, batchDel: async function (...e) { var t, n = await f(d, ""), r = a.convertToObject(n); for (t of e) a.del(t[0], void 0 !== t[1] ? t[1] : "", r); return n = JSON.stringify(r, null, 4), y(d, "", n) }, allSessions: async function (e) { var t = await f(d, ""), t = a.convertToObject(t); return a.allSessions(e, t) }, allSessionNames: async function (e) { var t = await f(d, ""), t = a.convertToObject(t); return a.allSessionNames(e, t) } } }
//---SyncByPyScript---MagicJS3-end