app.js

import axios from "axios";
import qs from "qs";
import xmlJs from "xml-js";
import iconv from "iconv-lite";
import * as cheerio from 'cheerio';

axios.defaults.retry = 3; //设置全局请求次数
axios.defaults.retryDelay = 1000;//设置全局请求间隙

// 填写Telegram的Bot API和Chat ID
const telegramToken = process.env.TELEGRAM_TOKEN
const telegramID = process.env.TELEGRAM_ID

// 填写server酱sckey,不开启server酱则不用填
const sckey = process.env["SCKEY"];

// 填写pushplus的token,不开启pushplus则不用填
const token = process.env["PPTOKEN"];

// 填写PushDeer的key, 不开启不用填
const pushDeer = process.env["PDKEY"]

// 填写Bark的key, 不开启不用填
const barkKey = process.env["BARKKEY"]

// 填写Bark的服务器地址, 不开启不用填
const barkServer = process.env["BARKSERVER"]

//配置需要打开的服务信息,hao4k 和 4ksj，未配置只对hao4k
// const needCheckHost = process.env["CHECKHOST"]
const needCheckHost = '4ksj'

// 填入Hao4k账号对应cookie
let cookie = process.env["COOKIE"];


// 填入4KSJ账号对应Cookie
let cookieSJ = process.env["SJCOOKIE"];

// 更新 cookie 中 will_timelogout_XXXXXX 的值为当前时间戳加一天
function updateCookieLogoutTimePlusOneDay(cookieStr) {
    const oneDayInSeconds = 24 * 60 * 60;
    const timestampPlusOneDay = Math.floor(Date.now() / 1000) + oneDayInSeconds;
    return cookieStr.replace(/(will_timelogout_\d+=)\d+/, `$1${timestampPlusOneDay}`);
}

cookieSJ = updateCookieLogoutTimePlusOneDay(cookieSJ);



const SJUrl =
    "https://www.4ksj.com/";
const hao4kUrl =
    "https://www.hao4k.cn/qiandao/";

const userAgent =
    "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.0.0 Safari/537.36";

const SJUserAgent =
    "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/129.0.0.0 Safari/537.36 Edg/129.0.0.0";

const headers = {
    cookie: cookie ?? "",
    "User-Agent": userAgent,
    "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9"
};

const SJHeaders = {
    cookie: cookieSJ ?? cookie,
    "User-Agent": SJUserAgent,
    "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9"
};

class HostInfo {
    name;
    url;
    header;
    status;
    formHash;
    message;

    constructor(name, url, header) {
        this.name = name;
        this.url = url;
        this.header = header;
    }
}

async function getFormHashSJ(host) {
    let headers = host.header;
    await axios
        .get(host.url + 'qiandao.php', {
            headers,
            responseType: "arraybuffer",
        })
        .then(async (response) => {
            const gb = iconv.decode(response.data, "utf-8");
            const $ = cheerio.load(gb);
            let formHash = '';
            const userName = $('.nexmemberintels>h5').text().replace('\n', '');
            
            if (userName === '') {
                console.log("cookie失效！");
                host.status = false;
                host.message = "cookie失效！";
            } else {
                console.log(host.name, "获取用户信息成功！");
                formHash = $('#scbar_form input:nth-child(2)').val();
                host.status = true;
                host.formHash = formHash;
                await checkinSJ(host);
            }
        })
        .catch((error) => {
            host.status = false;
            host.message = "获取formhash出错" + error;
            console.log(host.name, error);
        });
}

async function getFormHash(host) {
    let headers = host.header;
    await axios
        .get(host.url, {
            headers,
            responseType: "arraybuffer",
        })
        .then(async (response) => {
            const gb = iconv.decode(response.data, "gb2312");
            const $ = cheerio.load(gb);
            let formHash = '';
            const userName = $('#mumucms_username').text();
            if (userName === '') {
                console.log("cookie失效！");
                host.status = false;
                host.message = "cookie失效！";
            } else {
                console.log(host.name, "获取用户信息成功！");
                formHash = $('#scbar_form input').eq(1).val();
                host.status = true;
                host.formHash = formHash;
                await checkin(host);
            }
        })
        .catch((error) => {
            host.status = false;
            host.message = "获取formhash出错" + error;
            console.log(host.name, error);
        });
}

async function checkinSJ(host) {
    const checkInUrl =
        host.url + "qiandao.php?sign=" + host.formHash;
    let headers = host.header;
    await axios
        .get(checkInUrl, {
            headers,
            responseType: "arraybuffer",
        })
        .then(async (response) => {
            const GBK = iconv.decode(response.data, "GBK");
            const $ = cheerio.load(GBK);
            const msg = $('#messagetext>p').text()

            host.message = msg;
            host.status = true;
            await getCheckinInfoSJ(host);
        })
        .catch((error) => {
            console.log(host.name, "签到出错或超时" + error);
            host.status = false;
            host.message = "签到出错或超时" + error;
        });
}

async function checkin(host) {
    const checkInUrl =
        host.url + "?mod=sign&operation=qiandao&formhash=" + host.formHash + "&format=empty&inajax=1&ajaxtarget=";
    let headers = host.header;
    await axios
        .get(checkInUrl, {
            headers,
            responseType: "arraybuffer",
        })
        .then(async (response) => {
            const resUtf8 = iconv.decode(response.data, "GBK");
            const dataStr = xmlJs.xml2json(resUtf8, {
                compact: true,
                spaces: 4,
            });
            const data = JSON.parse(dataStr);
            const content = data?.root?._cdata;

            if (content) {
                if (content === "今日已签") {
                    host.message = "今日已签！";
                }
            } else {
                host.message = "签到成功!";
            }
            host.status = true;
            await getCheckinInfo(host);
        })
        .catch((error) => {
            console.log(host.name, "签到出错或超时" + error);
            host.status = false;
            host.message = "签到出错或超时" + error;
        });
}

async function getCheckinInfoSJ(host) {
    let headers = host.header;
    await axios
        .get(host.url + 'qiandao.php', {
            headers,
            responseType: "arraybuffer",
        })
        .then((response) => {
            const gb = iconv.decode(response.data, "GBK");
            const $ = cheerio.load(gb);
            //本月打卡
            let month = $('#wp > .ct2 > .sd div:nth-child(2) .xl1 li:nth-child(2):eq(0)').text(); 
            //连续打卡
            let ctu = $('#wp > .ct2 > .sd div:nth-child(2) .xl1 li:nth-child(3):eq(0)').text();
            //累计打卡
            let total = $('#wp > .ct2 > .sd div:nth-child(2) .xl1 li:nth-child(4):eq(0)').text();
            //累计奖励
            let totalPrice = $('#wp > .ct2 > .sd div:nth-child(2) .xl1 li:nth-child(5):eq(0)').text();
            //最近奖励
            let price = $('#wp > .ct2 > .sd div:nth-child(2) .xl1 li:nth-child(6):eq(0)').text();
          
            let info = month +'; '+ ctu +'; '+ total +'; '+ totalPrice +'; '+ price;
            host.message = host.message + info;
            // console.log(host.name, info)
        })
        .catch((error) => {
            host.message = "获取签到信息出错！" + error;
            console.log(host.name, "获取签到信息出错！" + error);
        });
}

async function getCheckinInfo(host) {
    let headers = host.header;
    await axios
        .get(host.url, {
            headers,
            responseType: "arraybuffer",
        })
        .then((response) => {
            const gb = iconv.decode(response.data, "gb2312");
            const $ = cheerio.load(gb);
            let days = $('#lxdays').val(); //连续签到天数
            let reward = $('#lxreward').val(); // 签到奖励
            let allDays = $('#lxtdays').val(); // 签到总天数
            let rank = $('#qiandaobtnnum').val();// 签到排名
            let info = " 本次签到奖励： " + reward + " 个币； 已连续签到： " + days + " 天; 今日排名： " + rank + " 位； 签到总天数： " + allDays + " 天；";
            host.message = host.message + info;
            console.log(host.name, info)
        })
        .catch((error) => {
            host.message = "获取签到信息出错！" + error;
            console.log(host.name, "获取签到信息出错！" + error);
        });
}

function pushNotice(status, message) {
    console.log("开始推送消息")
    if (sckey) {
        console.log("通过server酱推送消息");
        sendSCMsg(status, message);
    }
    if (token) {
        console.log("通过pushPlus推送消息");
        sendPushPlusMsg(status, message);
    }
    if (pushDeer) {
        console.log("通过pushDeer推送消息");
        sendPushDeerMsg(status, message);
    }
    if (barkKey) {
        console.log("通过bark推送消息");
        sendBarkMsg(status, message);
    }
    
    if (telegramToken) {
        console.log("通过Telegram推送消息");
        sendTelegramMsg(status, message);
    }
    console.log("结束推送消息")
}

function sendSCMsg(status, info) {
    let serverUrl = "https://sctapi.ftqq.com/" + sckey + ".send";
    axios.post(serverUrl, qs.stringify({
        "title": status,
        "desp": info
    }))
        .catch((e) => {
            console.log(e);
        })
}

function sendPushPlusMsg(status, info) {
    axios
        .post("http://www.pushplus.plus/send", {
            'token': token,
            'title': status,
            'content': info
        })
        .catch((e) => {
            console.log(e);
        });
}

function sendPushDeerMsg(status, info) {
    let message = status + info;
    axios
        .post("https://api2.pushdeer.com/message/push", {
            'pushkey': pushDeer,
            'type': 'text',
            'text': message
        })
        .catch((e) => {
            console.log(e);
        });
}

function sendBarkMsg(status, info) {
    let title = encodeURI(status);
    let message = encodeURI(info);
    let barkRealServer = barkServer ? barkServer : "https://api.day.app";
    let barkUrl = barkRealServer + "/" + barkKey + "/" + title + "/" + message;
    axios
        .get(barkUrl)
        .catch((e) => {
            console.log(e);
        })
}

/**
 * 通过 Telegram 发送消息
 * @param {*} status 签到结果
 * @param {*} info 签到返回信息
 */
function sendTelegramMsg(status, info) {
    axios
        .post("https://api.telegram.org/bot" + telegramToken + "/sendMessage", {
            'chat_id': telegramID,
            'text': '<b>' + status + '</b>\n' + info,
            'parse_mode': 'HTML'
        })
        .catch((e)=>{
            console.log(e);
        })
}

async function start() {
    let status = "未配置";
    let message = "未配置";
    let checkIn = false;
    console.log("配置的打卡的服务", needCheckHost);
    const needCheck = needCheckHost ? needCheckHost : "hao4k";
    if (needCheck.indexOf("4ksj") !== -1) {
        if (!checkIn) {
            checkIn = true;
            status = "";
            message = "";
        }
        let sj = new HostInfo("4K视界", SJUrl, SJHeaders);
        await getFormHashSJ(sj);
        status += sj.name + ": ";
        if (sj.status) {
            status += "签到成功！";
        } else {
            status += "签到失败！";
        }
        message += "* " + sj.name + ": " + sj.message;
    }
    if (needCheck.indexOf("hao4k") !== -1) {
        if (!checkIn) {
            checkIn = true;
            status = "";
            message = "";
        }
        let hao4k = new HostInfo("hao4K", hao4kUrl, headers);
        await getFormHash(hao4k);
        status += hao4k.name + ": ";
        if (hao4k.status) {
            status += "签到成功！";
        } else {
            status += "签到失败！";
        }
        message += "* " + hao4k.name + ": " + hao4k.message;
    }
    console.log(status, message);
    pushNotice(status, message);
}

await start()