woniuyuedu.js

/*
微信阅读
阅读入口，复制链接微信打开 
https://lh100-1253806495.cos.ap-beijing.myqcloud.com/index.html?carteamflg=100036&extflg=undefined变量名称：woniu

抓包搜索关键词 userid 和passport   passport@userid
多账号换行即可
黄鸟在文本里面可以抓到userid 和passport 

每2小时刷新一轮50篇文章
每日50篇 不上线
定时一小时一次 一天跑6次

*/


const $ = new Env("蜗牛阅读");
const notify = $.isNode() ? require('./sendNotify') : '';
let envSplitor = ['@', '\n']
let httpResult, httpReq, httpResp
let ckName = 'woniu'
let userCookie = ($.isNode() ? process.env[ckName] : $.getdata(ckName)) || '';
let userList = []
let userIdx = 0
let userCount = 0
var msg = ''
let newurl = "https://api.shandian.shandianyueche.com/task/Task.php"
///////////////////////////////////////////////////////////////////
class UserInfo {
    constructor(str,id) {
        this.index = ++userIdx, 
        this.idx = `账号[${this.index}] `,
        this.ck = str//.split('#'), this.u = this.ck[0], this.t = this.ck[1]
        this.userid=id
    }

    async getreadurl(id) {
        try {
            //用户领取任务
            // let t = Date.now()
            // this.ul = newurl;
            let body = {act:"userDrawReadTaskBaidu",passport:this.ck,task_id:id}
            let urlObject = popu(newurl, body,this.ck)
            //let urlObject = popu(this.ul, body,this.ck)
            await httpRequest('post', urlObject)
            let result = httpResult;
            if ( result && result.code==='0') {
                console.log(result.msg+",任务id:"+result.data.user_task_id)
                await this.read(result.data.user_task_id)
               
            }
            /*
            "1" == result.info.type && 1 !== this.dx && (console.log(`文章获取成功 `), this.b = 1, await $.wait(1000), await this.readfinish()),
                "3" == result.info.type && 1 !== this.dx && (console.log(`已限制阅读   尝试过验证`), this.x = result.info.key, this.c = result.info.url.split("/s/")[1], this.b = 2,
                    await $.wait(6000), await this.readfinish());
                    */
        } catch (e) {
            console.log(e)
        }
    }

    //提交任务
    async read(user_task_id) {
        try {
            let t = Date.now()
            //readurl = decodeURIComponent(readurl);
            var sj = Math.random() * 20000+ 8000
           
            //等待时间提交
            await $.wait(sj)
            let body = {act:"finishUserReadTaskBaidu",passport:this.ck,user_task_id:user_task_id}
            let urlObject = popu(newurl, body,this.ck)
            await httpRequest('post', urlObject)
            let result= httpResult;
            if(result && result.code==='0'){
                   //获取用户阅读金额
                console.log('阅读成功金币+100')
            }else{
               console.log(result.meg) 
            }
        } catch (e) {
            console.log(e)
        } finally {
            return Promise.resolve(1);
        }
    }
    async readfinish() {
        try {

            this.url=newurl+'/tuijian/do_read?for=&zs=&pageshow=&r=0.7882316111246435&jkey='+this.jkey
            let body = ``;
            let urlObject = popu(this.url, body,this.ck)
            //console.log(urlObject)
            await httpRequest('get', urlObject)
            let result = httpResult;
            if (result && result.success_msg) {
                console.log(result.success_msg)
            } else {
                console.log(result)
            }
            
            /*
            "success" == result.msg && console.log(`增加金币-> ${result.info.num} 阅读次数 ${result.info.read_num} 当前金币 ${result.info.read_money}`),
                result.code > 200 && (console.log(`已达到阅读量 等待刷新`), this.fx = 1);
                */
        } catch (e) {
            console.log(e)
        } finally {
            return Promise.resolve(1);
        }
    }
    async getreadinfo() {
        try {
            let t = Date.now()
            let url = newurl;
            let body = {act:"getReadTaskListBaidu",passport:this.ck}
            let urlObject = popu(url, body,'')
            await httpRequest('post', urlObject)
            let result = httpResult;
            if(result && result.ret==='succ'){
                return result.task_list 
            }
        } catch (e) {
            console.log(e)
        }
    }

     async getmoney() {
        try {
            let t = Date.now()
            let url = newurl;
            let body = {act:"getUserMoneyAccounts",passport:this.ck}
            let urlObject = popu(url, body,this.ck)
            await httpRequest('get', urlObject)
            let result = httpResult;
            if (result && result.ret==='succ') {
                result = result.money_account
                console.log(`\n当前账号余额 ${result.read_money}分 \n`)
            }
        } catch (e) {
            console.log(e)
        } finally {
            return Promise.resolve(1);
        }
    }


    async withdrawal() {
        try {
            let t = Date.now()
            let url = newurl+`/withdrawal`;
            let body = ``;
            let urlObject = popu(url, body,this.ck)
            await httpRequest('get', urlObject)
            let result = httpResult;
            if (result.data.user) {
                result = result.data.user
                console.log(`\n当前账号余额 ${result.score}分 \n`)
                if (this.ck.indexOf('##') != -1) return
                this.f = parseInt(result.score)//= Number(Math.floor(result.info.sum / 1000))
                /*
                if (this.f < 3) console.log(`\n 不满足0.3 提现门槛\n`)
                this.f >= 3 && this.f < 5 && (this.cash = .3), this.f >= 10 && this.f < 20 && (this.cash = 1), this.f >= 20 && this.f < 50 && (this.cash = 2),
                    this.f >= 50 && this.f < 100 && (this.cash = 2), this.f >= 100 && this.f < 200 && (this.cash = 10), this.f >= 200 && (this.cash = 20)
                if (this.f >= 3) console.log(`\n可以提现 ${result.info.sum}金币 去提现 ${this.cash} 元\n`), await this.exchange()
                */
                if (this.f < 30) {
                    console.log(`不满足0.3 提现门槛`)
                } else {
                    console.log(`去提现${this.f/100}元。。。。。。`)
                    await this.doWithdraw(this.f)
                }
            }
        } catch (e) {
            console.log(e)
        } finally {
            return Promise.resolve(1);
        }
    }
    async doWithdraw(tx) {
        try {
            let t = Date.now()
            let url = newurl+`/withdrawal/doWithdraw`;
            let body = `amount=` + tx;
            let urlObject = popu(url, body,this.ck)
            await httpRequest('post', urlObject)
            let result = httpResult;
            console.log(result)

        } catch (e) {
            console.log(e)
        } finally {
            return Promise.resolve(1);
        }
    }

     async gettasklist() {
        try {
            let tasklist=await this.getreadinfo()
            if (tasklist && tasklist.length>0) {
                //await this.getreadurl(tasklist[0].id)
                for (let i = 0;i< tasklist.length;i++) {
                    //console.log(tasklist[i].id)
                    await this.getreadurl(tasklist[i].id)
                }
                // await this.getreadinfo()
                //await $.wait(15000)
                
            }

        } catch (e) {
            console.log(e)
        }
    }

    async task() {
        try {
            
            let abc = [...new Array(15).keys()]
            console.log(`\n=========== ${this.idx} 开始阅读文章 ===========\n`)
            


            for(let i=0;i<=10;i++){
                await this.gettasklist()
            }
          


            // let tasklist=await this.getreadinfo()
            // if (tasklist && tasklist.length>0) {
            //     for (let i = 0;i< tasklist.length;i++) {
            //         //console.log(tasklist[i].id)
            //         await this.getreadurl(3607)
            //     }
            //    // await this.getreadinfo()
            //     //await $.wait(15000)
                
            // }
            // await this.withdrawal()
            
        } catch (e) {
            console.log(e)
        } finally {
            return Promise.resolve(1);
        }
    }
}


!(async () => {
    if (typeof $request !== "undefined") {
        await GetRewrite()
    } else {
        
        if (!(await checkEnv())) {
            console.log('环境变量错误，检查环境变量后在执行')
            return;
        }
      
        if (userList.length > 0) {
            
            //  console.log('获取到newurl：'+newurl)
             for (let user of userList) {
                await gethost(user.ck,user.userid)
                await user.task()
             }
             if (msg) await notify.sendNotify('微信阅读检测文章',msg)
        }
    }
})()
    .catch((e) => console.log(e))
    .finally(() => $.done())

///////////////////////////////////////////////////////////////////

async function gethost(ck,userid) {
    //构建请求体
    try {
        let t = Date.now()
        let url = 'https://api.shandian.shandianyueche.com/task/Task.php';
        let body = {act:"getUserInfoByID",passport:ck,userid:userid}
        let urlObject = popugethost(url, body)
        await httpRequest('post', urlObject)
        let result = httpResult;
        if (result.ret==='succ') {
           console.log('账号登录成功')
         }
    } catch (e) {
        console.log(e)
    } finally {
        return Promise.resolve(1);
    }
}

//获取环境变量的ck 放到userList中去
async function checkEnv() {
    if (userCookie) {
        for(let userCookies of userCookie.split(envSplitor[1])){

            let aa=userCookies.split(envSplitor[0])
            userList.push(new UserInfo(aa[0],aa[1]))
        }
        userCount = userList.length
    } else {
       console.log(`找到[${ckName}] 变量 配置错误`) 
       return false
    }
    console.log(`找到[${ckName}] 变量 ${userCount}个账号`)
   
    return true
}

////////////////////////////////////////////////////////////////////

//组装请求头
function popu(url, body = '',ck) {
    let host = url.replace('//', '/').split('/')[1]
    let urlObject = {
        url: url,
        headers:   {
            "Host": host,
            "Content-Type":"application/x-www-form-urlencoded", 
            "Origin": "http://read.imoney888.shop",   
            "User-Agent": "Mozilla/5.0 (Linux; Android 12; M2012K11AC Build/SKQ1.211006.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/86.0.4240.99 XWEB/4425 MMWEBSDK/20221206 Mobile Safari/537.36 MMWEBID/4883 MicroMessenger/8.0.32.2300(0x2800205D) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64",
            "Accept": "*/*",
            "Referer": "http://read.imoney888.shop"
        },
        timeout: 6000,
        form:body
    }
    return urlObject;
}
function popugethost(url, body = '') {
    let host = url.replace('//', '/').split('/')[1]
    let urlObject = {
        url: url,
        headers:   {
            "Host": host,
            "Content-Type":"application/x-www-form-urlencoded", 
            "Origin": "http://read.imoney888.shop",   
            "User-Agent": "Mozilla/5.0 (Linux; Android 12; M2012K11AC Build/SKQ1.211006.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/86.0.4240.99 XWEB/4425 MMWEBSDK/20221206 Mobile Safari/537.36 MMWEBID/4883 MicroMessenger/8.0.32.2300(0x2800205D) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64",
            "Accept": "*/*",
            "Referer": "http://read.imoney888.shop"
        },
        form: body,
        timeout: 6000,
    }
    return urlObject;
}

async function httpRequest(method, url) {
    //console.log(url)
    httpResult = null, httpReq = null, httpResp = null;
    return new Promise((resolve) => {
        $.send(method, url, async (err, req, resp) => {
            try {
                httpReq = req;
                httpResp = resp;
                if (err) {
                } else {
                    if (resp.body) {
                        if (typeof resp.body == "object") {
                            httpResult = resp.body;
                        } else {
                            try {
                                httpResult = JSON.parse(resp.body);
                            } catch (e) {
                                httpResult = resp.body;
                            }
                        }
                    }
                }
            } catch (e) {
                console.log(e);
            } finally {
                resolve();
            }
        });
    });
}
////////////////////////////////////////////////////////////////////
function Env(a, b) {
    return "undefined" != typeof process && JSON.stringify(process.env).indexOf("GITHUB") > -1 && process.exit(0), new class {
        constructor(a, b) {
            this.name = a, this.notifyStr = "", this.startTime = (new Date).getTime(), Object.assign(this, b), console.log(`${this.name} 开始运行：
`)
        } isNode() { return "undefined" != typeof module && !!module.exports } isQuanX() { return "undefined" != typeof $task } isSurge() { return "undefined" != typeof $httpClient && "undefined" == typeof $loon } isLoon() { return "undefined" != typeof $loon } getdata(b) { let a = this.getval(b); if (/^@/.test(b)) { let [, c, f] = /^@(.*?)\.(.*?)$/.exec(b), d = c ? this.getval(c) : ""; if (d) try { let e = JSON.parse(d); a = e ? this.lodash_get(e, f, "") : a } catch (g) { a = "" } } return a } setdata(c, d) { let a = !1; if (/^@/.test(d)) { let [, b, e] = /^@(.*?)\.(.*?)$/.exec(d), f = this.getval(b), i = b ? "null" === f ? null : f || "{}" : "{}"; try { let g = JSON.parse(i); this.lodash_set(g, e, c), a = this.setval(JSON.stringify(g), b) } catch (j) { let h = {}; this.lodash_set(h, e, c), a = this.setval(JSON.stringify(h), b) } } else a = this.setval(c, d); return a } getval(a) { return this.isSurge() || this.isLoon() ? $persistentStore.read(a) : this.isQuanX() ? $prefs.valueForKey(a) : this.isNode() ? (this.data = this.loaddata(), this.data[a]) : this.data && this.data[a] || null } setval(b, a) { return this.isSurge() || this.isLoon() ? $persistentStore.write(b, a) : this.isQuanX() ? $prefs.setValueForKey(b, a) : this.isNode() ? (this.data = this.loaddata(), this.data[a] = b, this.writedata(), !0) : this.data && this.data[a] || null } send(b, a, f = () => { }) { if ("get" != b && "post" != b && "put" != b && "delete" != b) { console.log(`无效的http方法：${b}`); return } if ("get" == b && a.headers ? (delete a.headers["Content-Type"], delete a.headers["Content-Length"]) : a.body && a.headers && (a.headers["Content-Type"] || (a.headers["Content-Type"] = "application/x-www-form-urlencoded")), this.isSurge() || this.isLoon()) { this.isSurge() && this.isNeedRewrite && (a.headers = a.headers || {}, Object.assign(a.headers, { "X-Surge-Skip-Scripting": !1 })); let c = { method: b, url: a.url, headers: a.headers, timeout: a.timeout, data: a.body }; "get" == b && delete c.data, $axios(c).then(a => { let { status: b, request: c, headers: d, data: e } = a; f(null, c, { statusCode: b, headers: d, body: e }) }).catch(a => console.log(a)) } else if (this.isQuanX()) a.method = b.toUpperCase(), this.isNeedRewrite && (a.opts = a.opts || {}, Object.assign(a.opts, { hints: !1 })), $task.fetch(a).then(a => { let { statusCode: b, request: c, headers: d, body: e } = a; f(null, c, { statusCode: b, headers: d, body: e }) }, a => f(a)); else if (this.isNode()) { this.got = this.got ? this.got : require("got"); let { url: d, ...e } = a; this.instance = this.got.extend({ followRedirect: !1 }), this.instance[b](d, e).then(a => { let { statusCode: b, request: c, headers: d, body: e } = a; f(null, c, { statusCode: b, headers: d, body: e }) }, b => { let { message: c, response: a } = b; f(c, a, a && a.body) }) } } time(a) { let b = { "M+": (new Date).getMonth() + 1, "d+": (new Date).getDate(), "h+": (new Date).getHours(), "m+": (new Date).getMinutes(), "s+": (new Date).getSeconds(), "q+": Math.floor(((new Date).getMonth() + 3) / 3), S: (new Date).getMilliseconds() }; for (let c in /(y+)/.test(a) && (a = a.replace(RegExp.$1, ((new Date).getFullYear() + "").substr(4 - RegExp.$1.length))), b) new RegExp("(" + c + ")").test(a) && (a = a.replace(RegExp.$1, 1 == RegExp.$1.length ? b[c] : ("00" + b[c]).substr(("" + b[c]).length))); return a } async showmsg() { if (!this.notifyStr) return; let a = this.name + " \u8FD0\u884C\u901A\u77E5\n\n" + this.notifyStr; if ($.isNode()) { var b = require("./sendNotify"); console.log("\n============== \u63A8\u9001 =============="), await b.sendNotify(this.name, a) } else this.msg(a) } logAndNotify(a) { console.log(a), this.notifyStr += a, this.notifyStr += "\n" } msg(d = t, a = "", b = "", e) { let f = a => { if (!a) return a; if ("string" == typeof a) return this.isLoon() ? a : this.isQuanX() ? { "open-url": a } : this.isSurge() ? { url: a } : void 0; if ("object" == typeof a) { if (this.isLoon()) { let b = a.openUrl || a.url || a["open-url"], c = a.mediaUrl || a["media-url"]; return { openUrl: b, mediaUrl: c } } if (this.isQuanX()) { let d = a["open-url"] || a.url || a.openUrl, e = a["media-url"] || a.mediaUrl; return { "open-url": d, "media-url": e } } if (this.isSurge()) return { url: a.url || a.openUrl || a["open-url"] } } }; this.isMute || (this.isSurge() || this.isLoon() ? $notification.post(d, a, b, f(e)) : this.isQuanX() && $notify(d, a, b, f(e))); let c = ["", "============== \u7CFB\u7EDF\u901A\u77E5 =============="]; c.push(d), a && c.push(a), b && c.push(b), console.log(c.join("\n")) } getMin(a, b) { return a < b ? a : b } getMax(a, b) { return a < b ? b : a } padStr(e, b, f = "0") { let a = String(e), g = b > a.length ? b - a.length : 0, c = ""; for (let d = 0; d < g; d++)c += f; return c + a } json2str(b, e, f = !1) { let c = []; for (let d of Object.keys(b).sort()) { let a = b[d]; a && f && (a = encodeURIComponent(a)), c.push(d + "=" + a) } return c.join(e) } str2json(e, f = !1) { let d = {}; for (let a of e.split("#")) { if (!a) continue; let b = a.indexOf("="); if (-1 == b) continue; let g = a.substr(0, b), c = a.substr(b + 1); f && (c = decodeURIComponent(c)), d[g] = c } return d } randomString(d, a = "abcdef0123456789") { let b = ""; for (let c = 0; c < d; c++)b += a.charAt(Math.floor(Math.random() * a.length)); return b } randomList(a) { let b = Math.floor(Math.random() * a.length); return a[b] } wait(a) { return new Promise(b => setTimeout(b, a)) } done(a = {}) {
            let b = (new Date).getTime(), c = (b - this.startTime) / 1e3; console.log(`
${this.name} 运行结束，共运行了 ${c} 秒！`), (this.isSurge() || this.isQuanX() || this.isLoon()) && $done(a)
        }
    }(a, b)
}