ip_dsj.js

const $ = new Env("电视家");
const notify = $.isNode() ? require('./sendNotify') : '';
message = ""
let dsj_header = "";
let subTitle = ``;
const defaultHeader = {
    'systemSdkVersion': 29,
    'User-Agent': 'android%2Fclient',
    'hwBrand': 'HONOR',
    'appVerName': '2.9.3-beta3',
    'hwDevice': 'HWBKL',
    'language': 'zh_CN_%23Hans',
    'uuid': '25cfdedc03562423e177d610d601f7bc',
    'platform': '10',
    'hwModel': 'BKL-AL20',
    'generation': 'com.dianshijia.tvlive',
    'hwHardware': 'kirin970',
    'Connection': 'close',
    'routermac': '047970789cdf',
    'appVerCode': '353',
    'areaCode': '440300',
    'cuuid': '325c08175f8e5b2419d2e415b812a516',
    'appid': '0990028e54b2329f2dfb4e5aeea6d625',
    'marketChannelName': 'default_oy',
    'Host': '47.95.69.248',
    'Accept-Encoding': 'gzip'
};

const rewardId = 42;
/**
 * @type object[]
 */
let accounts;
if ($.isNode()) {
    const dsjCookie = require('./dsjCOOKIE')
    accounts = dsjCookie.datas.filter(x => x.val !== '')
    var cks = accounts.map(x => getHeader(x));
    dsj_header = cks.join('@')
}
else
    dsj_header = $.getdata('dsj_header') ? $.getdata('dsj_header') : ""

let dsj_headerArr = []
let dsj_headers = ""

const dianshijia_API = 'http://47.95.69.248/api'
const walkstep = '20000';
const gametimes = "1999";

var time = Date.parse(new Date()).toString();


if (typeof $request !== "undefined") {
    getdsj_header()
    $.done()
}

if (!dsj_header) {
    $.msg($.name, '【提示】没有电视家cookie，获取cookie，再跑一次脚本', '不知道说啥好', {
        "open-url": "给您劈个叉吧"
    });
    $.done()
}
else if (dsj_header.indexOf("@") == -1 && dsj_header.indexOf("@") == -1) {
    dsj_headerArr.push(dsj_header)
}
else if (dsj_header.indexOf("@") > -1) {
    dsj_headers = dsj_header.split("@")
}
else if (process.env.dsj_header && process.env.dsj_header.indexOf('@') > -1) {
    dsj_headerArr = process.env.dsj_header.split('@');
    console.log(`您选择的是用"@"隔开\n`)
}
else {
    dsj_headers = [process.env.dsj_header]
};
Object.keys(dsj_headers).forEach((item) => {
    if (dsj_headers[item]) {
        dsj_headerArr.push(dsj_headers[item])
    }
})

function getHeader(account) {
    var accountCK = account.val.split('&');
    const headers = { ...defaultHeader, ...{ authorization: accountCK[1], userid: accountCK[0] }, ...account.headerEx }
    return JSON.stringify(headers);
}

!(async () => {
    console.log(`共${dsj_headerArr.length}个cookie`)
    for (let k = 0; k < dsj_headerArr.length; k++) {
        $.message = ""
        current_dsj_header = dsj_headerArr[k]
        current_reward_id = rewardId
        if (accounts && accounts[k].rewardId) {
            current_reward_id = accounts[k].rewardId
        }
        console.log(`--------第 ${k + 1} 个账号任务中--------\n`)

        await dsj_rwzt();
        await signin()
        //await signinfo()
        await dsj_led()
        await run()
        await run_rw()

        await dsj_lqp()
        // for (let k = 0; k < 5; k++) {
        //     await lhz()
        //     await $.wait(60000)
        // }
        await tasks(); // 任务状态
        await wx_tasks()
        await getGametime(); // 游戏时长
        await dsj_getinfo()// 用户信息
        //await coinlist(); //总计
        //await total(); // 金币状态
        await cash(); // 现金状态


        console.log("\n\n")
    }
    // if ($.isNode()) { await notify.sendNotify($.name, subTitle) }

})()
    .catch((e) => $.logErr(e))
    .finally(() => $.done())


//总计
function coinlist() {
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            let url = {
                url: `${dianshijia_API}/coin/detail`,
                headers: JSON.parse(current_dsj_header),
            }
            $.get(url, (error, response, data) => {
                //console.log(`金币列表: ${data}`)
                let result = JSON.parse(data)
                let onlamount = 0,
                    vdamount = 0,
                    gamestime = 0,
                    todaysign = 0;
                try {
                    for (i = 0; i < result.data.length && result.data[i].ctime >= time; i++) {
                        if (result.data[i].from == "领取走路金币") {
                            detail += `【走路任务】✅ 获得金币` + result.data[i].amount + '\n'
                        }
                        if (result.data[i].from == "领取睡觉金币") {
                            detail += `【睡觉任务】✅ 获得金币` + result.data[i].amount + '\n'
                        }
                        if (result.data[i].from == "手机分享") {
                            detail += `【分享任务】✅ 获得金币` + result.data[i].amount + '\n'
                        }
                        if (result.data[i].from == "双端活跃") {
                            detail += `【双端活跃】✅ 获得金币` + result.data[i].amount + '\n'
                        }
                        if (result.data[i].from == "播放任务") {
                            detail += `【播放任务】✅ 获得金币` + result.data[i].amount + '\n'
                        }
                        if (result.data[i].from == "领取瓜分金币") {
                            detail += `【瓜分金币】✅ 获得金币` + result.data[i].amount + '\n'
                        }
                        if (result.data[i].from == "游戏时长奖励") {
                            gamestime += result.data[i].amount
                        }
                        if (result.data[i].from == "激励视频") {
                            vdamount += result.data[i].amount
                        }
                        if (result.data[i].from == "手机在线") {
                            onlamount += result.data[i].amount
                        }
                        if (result.data[i].from == "签到") {
                            todaysign += result.data[i].amount
                        }
                    }
                    if (todaysign) {
                        detail += `【每日签到】✅ 获得金币` + todaysign + '\n'
                    }
                    if (vdamount) {
                        detail += `【激励视频】✅ 获得金币` + vdamount + '\n'
                    }
                    if (onlamount) {
                        detail += `【手机在线】✅ 获得金币` + onlamount + '\n'
                    }
                    if (gamestime) {
                        detail += `【游戏时长】✅ 获得金币` + gamestime + '\n'
                    }
                    if (i > 0) {
                        detail += `【任务统计】共完成${i + 1}次任务🌷`
                    }
                    $.msg($.name + `  ` + sleeping, subTitle, detail)


                } catch (e) {
                    console.log(`获取任务金币列表失败，错误代码${e}+ \n响应数据:${data}`)
                    //$.msg($.name + ` 获取金币详情失败 `, subTitle, detail)
                }
                /*if ($.isNode()) {
                    notify.sendNotify(`【${$.name}】账号 ${i} , ${subTitle} '\n' ${detail}`)
                }
                return*/
                resolve()
            })
        }, 1000)
    })
}


function total() {
    return new Promise((resolve, reject) => {
        $.get({
            url: `${dianshijia_API}/coin/info`,
            headers: JSON.parse(current_dsj_header),
        }, (error, response, data) => {
            let result = JSON.parse(data)
            console.log(`\n【当前金币状态】待兑换金币: ${result.data.coin}`)
            try {
                if (result.data.tempCoin) {
                    for (i = 0; i < result.data.tempCoin.length; i++) {
                        coinid = result.data.tempCoin[i].id
                        $.get({
                            url: `http://api.47.95.69.248/api/coin/temp/exchange?id=` + coinid,
                            headers: DSJ_headers
                        }, (error, response, data))
                    }
                }
                resolve()
            } catch (e) {

                resolve()
            }
        })
    })
}

function wx_tasks(tkcode) {
    return new Promise(async (resolve, reject) => {
        let taskcode = ['1M002', 'SpWatchVideo', 'Mobilewatchvideo', 'MutilPlatformActive', 'MiniLoginIn', 'MiniWatchVideo', 'FirstDownLoginMobile', 'FirstDownLoginTv']
        for (code of taskcode) {
            await wx_dotask(code)
            await $.wait(10000);
        }
        resolve()
    })
}
//小程序任务
function wx_dotask(code) {
    return new Promise((resolve, reject) => {
        let url = {
            url: `https://47.95.69.248/api/v4/task/complete?code=${code}&comType=1`,
            headers: JSON.parse(`{"userid":"${JSON.parse(current_dsj_header).userid}","authorization":"${JSON.parse(current_dsj_header).authorization}","appid":"3c3065a6f979f9b2b49e98ea1d02f313","Host":"api.dianshihome.com","content-type":"application/x-www-form-urlencoded","Referer":"https://servicewechat.com/wx9e8718eb2360dfb8/109/page-frame.html"}`)
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log('\n【微信任务代码】：' + code + '，获得金币:' + result.data.getCoin)
            } else {
                console.log('\n【微信任务代码】: ' + code + '，' + result.msg)
            }
            resolve()
        })
    })
}

function tasks(tkcode) {
    return new Promise(async (resolve, reject) => {
        let taskcode = ['1M002', 'SpWatchVideo', 'Mobilewatchvideo', 'MutilPlatformActive', 'MiniLoginIn', 'MiniWatchVideo', 'FirstDownLoginMobile', 'FirstDownLoginTv']
        for (code of taskcode) {
            await dotask(code)
            await $.wait(10000);
        }
        resolve()
    })
}
//播放时长
function dotask(code) {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v4/task/complete?code=${code}`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log('\n【任务代码】：' + code + '，获得金币:' + result.data.getCoin)
            } else {
                console.log('\n【任务代码】: ' + code + '，' + result.msg)
            }
            resolve()
        })
    })
}

//任务列表查看，待修改
function dsj_rwzt() {
    return new Promise((resolve) => {
        let url = {
            url: `http://47.95.69.248/api/v5/task/get`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, async (err, resp, data) => {
            try {
                //console.log(data)
                data = JSON.parse(data)

                if (data.errCode == 0) {
                    console.log(`\n【任务状态】: \n`)
                    for (let index = 0; index < data.data.length; index++) {
                        const task = data.data[index];
                        const finish = task.dayCompCount == task.dayDoCountMax;

                        switch (task.code) {
                            case 'task_xiaoman':
                                task_xiaoman = finish;
                                break;
                            case 'playTask':
                                playTask = finish;
                                break;
                            case 'ShortvideoPlay':
                                ShortvideoPlay = finish;
                                break;
                            case 'task_mobile_visit_album':
                                task_mobile_visit_album = finish;
                                break;
                            case 'task_mobile_upload_album':
                                task_mobile_upload_album = finish;
                                break;
                            case 'task_mobile_create_family':
                                task_mobile_create_family = finish;
                                break;
                            case '1M005':
                                M005 = finish;
                                break;
                        }
                        console.log(`${task.name}: ${finish ? '已完成' : '未完成'}`)
                    }
                    //浏览广告赚
                    // if (data.data[2].dayCompCount == 5) {
                    //     console.log(`${data.data[2].name}: 已完成`)
                    //     H5Page_4 = 1
                    // } else {
                    //     console.log(`${data.data[2].name}: 未完成`)
                    //     H5Page_4 = 0
                    // }

                    //访问点歌台
                    // if (data.data[13].dayCompCount == 1) {
                    //     console.log(`${data.data[13].name}: 已完成`)
                    //     task_mobile_visit_song = 1
                    // } else {
                    //     console.log(`${data.data[13].name}: 未完成`)
                    //     task_mobile_visit_song = 0
                    // }
                } else {
                    console.log(data)
                }

            } catch (e) {
            } finally {
                resolve()
            }
        })
    })
}
//看视频奖励
function video() {
    return new Promise((resolve, reject) => {
        let url = {
            url: 'http:/47.95.69.248/api/v5/task/complete?code=ShortvideoPlay&comType=0',
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, async (err, resp, data) => {
            try {
                const result = JSON.parse(data)
                if (result.errCode === 0) {
                    console.log(`\n【看视频赚钱】:获得 ${result.data.getCoin} 金币`)
                } else {
                    console.log(`\n【看视频赚钱】: ${result.msg}`)
                }

            } catch (e) {
                $.logErr(e + resp);
            } finally {
                resolve()
            }
        })
    })
}
//签到
function signin() {
    return new Promise((resolve, reject) => {
        let url = {
            url: 'http://47.95.69.248/api/v5/sign/signin?accelerate=0&ext=0&ticket=',
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, async (error, response, data) => {
            //console.log(data)
            //{"errCode":4,"msg":"不能重复签到"}
            //if (logs) $.log(`${$.name}, 签到结果: ${data}\n`)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                //signinres = `\n签到成功 `
                console.log(`\n【签到收益】: ${result.data.reward[0].count} 金币 `)
                /*var h = result.data.reward.length
                if (h > 1) {
                    dconsole.log( `\n【签到收益】` + signinres + `${result.data.reward[0].count}金币，奖励${result.data.reward[1].name} `)
                } else {
                    console.log( `\n【签到收益】` + signinres + `+${result.data.reward[0].count}金币 `)
                }*/
            } else if (result.errCode == 4) {
                console.log(`\n【签到结果】 重复签到 🔁 `)
            } else if (result.errCode == 6) {
                console.log(`\n【签到结果】 失败`)
                //detail = `\n原因: ${result.msg}`
                /*if ($.isNode()) {
                    await notify.sendNotify($.name, subTitle + '\n' + detail)
                }
                return*/
            }
            resolve()
        })
    })
}

//领明天额度
function dsj_led() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `http://47.95.69.248/api/sign/chooseAdditionalReward?rewardId=${current_reward_id}`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            resolve()
        })
    })
}

async function run() {
    if (new Date().getTimezoneOffset() == '0') {
        if ($.time('HH') > 11) {
            await sleep();
            await $.wait(10000);
            await CarveUp();
        } else if ($.time('HH') > 3 && $.time('HH') < 5) {
            await getCUpcoin();
            await $.wait(10000);
            await walk();
        } else if ($.time('HH') > 22) {
            await wakeup()
        }
    } else {
        if ($.time('HH') > 17) {
            await sleep();
            await $.wait(10000);
            await CarveUp();
        } else if ($.time('HH') > 11 && $.time('HH') < 14) {
            await getCUpcoin();
            await $.wait(10000);
            await walk();
        } else if ($.time('HH') > 6 && $.time('HH') < 9) {
            await wakeup()
        }
    }
}

//睡觉任务
function sleep() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `http://47.95.69.248/api/taskext/getSleep?ext=0`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            try {
                $.log(`睡觉任务: ${data}\n`)
                let sleepres = JSON.parse(data)
                if (sleepres.errCode == 0) {
                    sleeping = sleepres.data.name + '报名成功 🛌'
                } else if (sleepres.errCode == 4006) {
                    sleeping = '睡觉中😴'
                } else {
                    sleeping = ''
                }
                resolve()
            } catch (e) {
                $.msg($.name, `睡觉结果: 失败`, `说明: ${e}`)
            }
            console.log(`\n【睡觉任务】: ${sleeping}`)
            resolve()
        })
    })
}
//瓜分百万金币
function CarveUp() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v2/taskext/getCarveUp?ext=1`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            $.log(`瓜分百万金币: ${data}`)
            const result = JSON.parse(data)
            if (result.errCode == 0) {
                //detail += `【金币瓜分】✅ 报名成功\n`
                $.log(`金币瓜分】✅ 报名成功\n`)
            }
            resolve()
        })
    })
}

//瓜分百元
function getCUpcoin() {
    return new Promise((resolve, reject) => {
        $.get({
            url: `${dianshijia_API}/taskext/getCoin?ext=0&code=carveUp`,
            headers: JSON.parse(current_dsj_header),
        }, (error, response, data) => {
            //console.log(data)
            $.log(`【瓜分百万金币】: 获得 ${data} 金币`)
        })
        resolve()
    })
}

function walk() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/taskext/getWalk?step=${walkstep}`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            $.log(`走路任务: ${data}\n`)
            let result = JSON.parse(data)
            if (result.data.unGetCoin > 10) {
                $.get({
                    url: `${dianshijia_API}/taskext/getCoin?code=walk&coin=${result.data.unGetCoin}&ext=1`,
                    headers: JSON.parse(current_dsj_header),
                }, (error, response, data) => { })
            }
            resolve()
        })
    })
}

function wakeup() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/taskext/getCoin?code=sleep&coin=1910&ext=1`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            $.log(`睡觉打卡: ${data}\n`)
        })
        resolve()
    })
}

async function run_rw() {
    //天天签到看视频任务8次
    if (task_xiaoman == 0) {
        await video()//天天签到看视频任务8次
        await $.wait(10000);
    }
    //浏览广告赚
    // if (H5Page_4 == 0) {
    //     await dsj_ggz()//浏览广告赚
    //     await $.wait(10000);
    // }
    //播放任务
    if (playTask == 0) {
        await dsj_jrydz()//今日阅读赚
        await $.wait(10000);
    }
    //手机版分享
    if (M005 == 0) {
        await dsj_sjbfx()//手机分享
        await $.wait(10000);
    }
    //访问点歌台
    // if (task_mobile_visit_song == 0) {
    //     await dsj_dgt()
    //     await $.wait(10000);
    // }
    //浏览电视相册
    if (task_mobile_visit_album == 0) {
        await dsj_fwxc()//访问相册
        await $.wait(10000);
    }
    //相册上电视task_mobile_upload_album
    if (task_mobile_upload_album == 0) {
        await dsj_xcsds()//相册上电视
        await $.wait(10000);
    }
    //开家庭号task_mobile_create_family
    if (task_mobile_create_family == 0) {
        await dsj_kjth() //开家庭号
        await $.wait(10000);
    }
    //刷短视频
    if (ShortvideoPlay == 0) {
        await dsj_sdsp()//刷短视频
        await $.wait(10000);
    }

}
//浏览广告赚
function dsj_ggz() {
    return new Promise((resolve, reject) => {
        $.get({
            url: `${dianshijia_API}/v5/task/complete?code=H5Page_4&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }, async (error, response, data) => {
            //console.log(data)
            //{"errCode":4,"msg":"不能重复签到"}
            //if (logs) $.log(`${$.name}, 签到结果: ${data}\n`)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log(`\n【浏览广告赚】:获得 ${result.data.getCoin} 金币`)
            } else {
                console.log(`\n【浏览广告赚】: ${result.msg}`)
            }
            resolve()
        })
    })
}
//今日阅读赚
function dsj_jrydz() {
    return new Promise((resolve, reject) => {
        $.get({
            url: `${dianshijia_API}/v5/task/complete?code=playTask&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }, async (error, response, data) => {
            //console.log(data)
            //{"errCode":4,"msg":"不能重复签到"}
            //if (logs) $.log(`${$.name}, 签到结果: ${data}\n`)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log(`\n【播放任务】:获得 ${result.data.getCoin} 金币`)
            } else {
                console.log(`\n【播放任务】: ${result.msg}`)
            }
            resolve()
        })
    })
}
//手机版分享
function dsj_sjbfx() {
    return new Promise((resolve, reject) => {
        $.get({
            url: `${dianshijia_API}/v5/task/complete?code=1M005&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }, async (error, response, data) => {
            //console.log(data)
            //{"errCode":4,"msg":"不能重复签到"}
            //if (logs) $.log(`${$.name}, 签到结果: ${data}\n`)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log(`\n【手机版分享】:获得 ${result.data.getCoin} 金币`)
            } else {
                console.log(`\n【手机版分享】: ${result.msg}`)
            }
            resolve()
        })
    })
}

//访问点歌台
function dsj_dgt() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v5/task/complete?code=task_mobile_visit_song&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            //console.log(`\n【今日阅读赚】: 成功`)
            if (result.errCode == 0) {
                console.log(`\n【访问点歌台】:获得 ${result.data.getCoin} 金币`)
            } else {
                console.log(`\n【访问点歌台】: ${result.msg}`)
            }

            resolve()
        })
    })
}

//访问相册
function dsj_fwxc() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v5/task/complete?code=task_mobile_visit_album&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log(`\n【访问相册】:获得 ${result.data.getCoin} 金币`)
            } else {
                console.log(`\n【访问相册】: ${result}`)
            }

            resolve()
        })
    })
}

//相册上电视
function dsj_xcsds() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v5/task/complete?code=task_mobile_upload_album&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log(`\n【相册上电视】:获得 ${result.data.getCoin} 金币`)
            } else {
                console.log(`\n【相册上电视】: ${result.msg}`)
            }

            resolve()
        })
    })
}
//开家庭号
function dsj_kjth() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v5/task/complete?code=task_mobile_create_family&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log(`\n【开家庭号】:获得 ${result.data.getCoin} 金币`)
            } else {
                console.log(`\n【开家庭号】: ${result.msg}`)
            }

            resolve()
        })
    })
}

//刷短视频
function dsj_sdsp() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v5/task/complete?code=ShortvideoPlay&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log(`\n【刷短视频】:获得 ${result.data.getCoin} 金币`)
            } else {
                console.log(`\n【刷短视频】: ${result.msg}`)
            }

            resolve()
        })
    })
}

//列出气泡信息
function dsj_lqp() {
    return new Promise((resolve, reject) => {
        $.get({
            url: `${dianshijia_API}/coin/info`,
            headers: JSON.parse(current_dsj_header),
        }, async (error, response, data) => {
            //console.log(data)
            //{"errCode":4,"msg":"不能重复签到"}
            //if (logs) $.log(`${$.name}, 签到结果: ${data}\n`)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                if (!result.data.tempCoin) {
                    console.log(`\n【${$.name}】: 首页没有气泡了`)
                } else {
                    for (let a = 0; a < result.data.tempCoin.length; a++) {
                        await dsj_dqp(result.data.tempCoin[a].id)
                        await $.wait(3000)
                    }
                }

            } else {
                //console.log(`\n【${$.name}】: ${result.msg}`
                //subTitle = `【看视频赚钱】 失败`
                /*detail = `原因: ${result.msg}`
                if ($.isNode()) {
                    await notify.sendNotify($.name, subTitle + '\n' + detail)
                }
                return*/
            }
            resolve()
        })
    })
}
//点气泡
function dsj_dqp(code) {
    return new Promise((resolve, reject) => {
        $.get({
            url: `${dianshijia_API}/coin/temp/exchange?id=${code}`,
            headers: JSON.parse(current_dsj_header),
        }, async (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            console.log(`\n【${$.name}】: 点气泡成功`)
            resolve()
        })
    })
}

//游戏时长
function getGametime() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v4/task/complete?code=gameTime&time=${gametimes}`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            $.log(`游戏时长: ${data}\n`)
        })
        resolve()
    })
}

//用户信息，调用的函数待修改
function dsj_getinfo() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v3/user/info`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                nickname = result.data.nickname
                headImgUrl = result.data.headImgUrl
                dsj_info()
            } else {
                console.log(`\n【电视家提示】: ${result.msg}`)
            }

            resolve()
        })
    })
}
function dsj_info() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/activity/invite/bind?ename=${nickname}&eavatar=${headImgUrl}&uid=${JSON.parse(current_dsj_header).userid}&inviteCode=1126139`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            if (result.errCode == 0) {

            } else {
                //console.log(`\n【电视家提示】: ${result.msg}`)
            }

            resolve()
        })
    })
}

async function getdsj_header() {
    if ($request.url.match(/\/v3\/user\/info/)) {
        bodyVal1 = JSON.stringify($request.headers)
        result = JSON.parse(bodyVal1)
        uuid = result.uuid
        userid = result.userid
        authorization = result.authorization
        deviceId = result.deviceId
        let bodyVal = { 'uuid': uuid, 'userid': userid, 'authorization': authorization, 'deviceId': deviceId, 'Host': '47.95.69.248', "appid": "0990028e54b2329f2dfb4e5aeea6d625" }
        bodyVal2 = JSON.stringify(bodyVal)

        if (dsj_header) {
            if (dsj_header.indexOf(userid) > -1) {
                $.log("此cookie已存在，本次跳过")
            } else if (dsj_header.indexOf(userid) === -1) {
                dsj_headers = dsj_header + "@" + bodyVal2;
                console.log(bodyVal2)
                $.setdata(dsj_headers, 'dsj_header');
                $.log(`${$.name}获取cookie: 成功, dsj_headers: ${bodyVal}`);
                bodys = dsj_headers.split("@")
                // $.msg($.name, "获取第" + bodys.length + "个阅读请求: 成功🎉", ``)
            }
        } else {
            $.setdata(bodyVal2, 'dsj_header');
            console.log(bodyVal2)
            $.log(`${$.name}获取cookie: 成功, dsj_headers: ${bodyVal}`);
            $.msg($.name, `获取第一个cookie: 成功🎉`, ``)
        }
    }

}

//现金详情
function cash() {
    return new Promise((resolve, reject) => {
        $.get({
            url: `${dianshijia_API}/cash/info`,
            headers: JSON.parse(current_dsj_header),
        }, (error, response, data) => {
            //if (logs) $.log(`现金: ${data}\n`)
            let cashresult = JSON.parse(data)
            if (cashresult.errCode == "0") {
                console.log(`\n【当前现金状态】总现金: ${cashresult.data.amount / 100} , 提现额度: ${cashresult.data.withdrawalQuota / 100}`)
                // subTitle += `\n【账号 ${k + 1} 现金状态】总现金: ${cashresult.data.amount / 100} , 提现额度: ${cashresult.data.withdrawalQuota / 100}`
                //cashtotal = cashresult.data.totalWithdrawn / 100
                /*zh=i
                if ($.isNode()) {
                 notify.sendNotify($.name,'账号: '+i+'\n'+ subTitle + '\n')
                }
                return*/

            }
            resolve()
        })
    })
}

//零花赚
function lhz() {
    return new Promise((resolve, reject) => {
        let url = {
            url: `${dianshijia_API}/v5/task/complete?code=H5Page_2&comType=0`,
            headers: JSON.parse(current_dsj_header),
        }
        $.get(url, (error, response, data) => {
            //console.log(data)
            let result = JSON.parse(data)
            if (result.errCode == 0) {
                console.log('\n阅读零花赚：' + '阅读次数:' + result.data.dayCompCount)
            } else {
                console.log('\n【阅读零花赚: ' + result.msg)
            }
            resolve()
        })
    })
}

function Env(t, e) { "undefined" != typeof process && JSON.stringify(process.env).indexOf("GITHUB") > -1 && process.exit(0); class s { constructor(t) { this.env = t } send(t, e = "GET") { t = "string" == typeof t ? { url: t } : t; let s = this.get; return "POST" === e && (s = this.post), new Promise((e, i) => { s.call(this, t, (t, s, r) => { t ? i(t) : e(s) }) }) } get(t) { return this.send.call(this.env, t) } post(t) { return this.send.call(this.env, t, "POST") } } return new class { constructor(t, e) { this.name = t, this.http = new s(this), this.data = null, this.dataFile = "box.dat", this.logs = [], this.isMute = !1, this.isNeedRewrite = !1, this.logSeparator = "\n", this.startTime = (new Date).getTime(), Object.assign(this, e), this.log("", `\ud83d\udd14${this.name}, \u5f00\u59cb!`) } 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 } toObj(t, e = null) { try { return JSON.parse(t) } catch { return e } } toStr(t, e = null) { try { return JSON.stringify(t) } catch { return e } } getjson(t, e) { let s = e; const i = this.getdata(t); if (i) try { s = JSON.parse(this.getdata(t)) } catch { } return s } setjson(t, e) { try { return this.setdata(JSON.stringify(t), e) } catch { return !1 } } getScript(t) { return new Promise(e => { this.get({ url: t }, (t, s, i) => e(i)) }) } runScript(t, e) { return new Promise(s => { let i = this.getdata("@chavy_boxjs_userCfgs.httpapi"); i = i ? i.replace(/\n/g, "").trim() : i; let r = this.getdata("@chavy_boxjs_userCfgs.httpapi_timeout"); r = r ? 1 * r : 20, r = e && e.timeout ? e.timeout : r; const [o, h] = i.split("@"), a = { url: `http://${h}/v1/scripting/evaluate`, body: { script_text: t, mock_type: "cron", timeout: r }, headers: { "X-Key": o, Accept: "*/*" } }; this.post(a, (t, e, i) => s(i)) }).catch(t => this.logErr(t)) } loaddata() { if (!this.isNode()) return {}; { this.fs = this.fs ? this.fs : require("fs"), this.path = this.path ? this.path : require("path"); const t = this.path.resolve(this.dataFile), e = this.path.resolve(process.cwd(), this.dataFile), s = this.fs.existsSync(t), i = !s && this.fs.existsSync(e); if (!s && !i) return {}; { const i = s ? t : e; try { return JSON.parse(this.fs.readFileSync(i)) } catch (t) { return {} } } } } writedata() { if (this.isNode()) { this.fs = this.fs ? this.fs : require("fs"), this.path = this.path ? this.path : require("path"); const t = this.path.resolve(this.dataFile), e = this.path.resolve(process.cwd(), this.dataFile), s = this.fs.existsSync(t), i = !s && this.fs.existsSync(e), r = JSON.stringify(this.data); s ? this.fs.writeFileSync(t, r) : i ? this.fs.writeFileSync(e, r) : this.fs.writeFileSync(t, r) } } lodash_get(t, e, s) { const i = e.replace(/\[(\d+)\]/g, ".$1").split("."); let r = t; for (const t of i) if (r = Object(r)[t], void 0 === r) return s; return r } lodash_set(t, e, s) { return Object(t) !== t ? t : (Array.isArray(e) || (e = e.toString().match(/[^.[\]]+/g) || []), e.slice(0, -1).reduce((t, s, i) => Object(t[s]) === t[s] ? t[s] : t[s] = Math.abs(e[i + 1]) >> 0 == +e[i + 1] ? [] : {}, t)[e[e.length - 1]] = s, t) } getdata(t) { let e = this.getval(t); if (/^@/.test(t)) { const [, s, i] = /^@(.*?)\.(.*?)$/.exec(t), r = s ? this.getval(s) : ""; if (r) try { const t = JSON.parse(r); e = t ? this.lodash_get(t, i, "") : e } catch (t) { e = "" } } return e } setdata(t, e) { let s = !1; if (/^@/.test(e)) { const [, i, r] = /^@(.*?)\.(.*?)$/.exec(e), o = this.getval(i), h = i ? "null" === o ? null : o || "{}" : "{}"; try { const e = JSON.parse(h); this.lodash_set(e, r, t), s = this.setval(JSON.stringify(e), i) } catch (e) { const o = {}; this.lodash_set(o, r, t), s = this.setval(JSON.stringify(o), i) } } else s = this.setval(t, e); return s } getval(t) { return this.isSurge() || this.isLoon() ? $persistentStore.read(t) : this.isQuanX() ? $prefs.valueForKey(t) : this.isNode() ? (this.data = this.loaddata(), this.data[t]) : this.data && this.data[t] || null } setval(t, e) { return this.isSurge() || this.isLoon() ? $persistentStore.write(t, e) : this.isQuanX() ? $prefs.setValueForKey(t, e) : this.isNode() ? (this.data = this.loaddata(), this.data[e] = t, this.writedata(), !0) : this.data && this.data[e] || null } initGotEnv(t) { this.got = this.got ? this.got : require("got"), this.cktough = this.cktough ? this.cktough : require("tough-cookie"), this.ckjar = this.ckjar ? this.ckjar : new this.cktough.CookieJar, t && (t.headers = t.headers ? t.headers : {}, void 0 === t.headers.Cookie && void 0 === t.cookieJar && (t.cookieJar = this.ckjar)) } get(t, e = (() => { })) { t.headers && (delete t.headers["Content-Type"], delete t.headers["Content-Length"]), this.isSurge() || this.isLoon() ? (this.isSurge() && this.isNeedRewrite && (t.headers = t.headers || {}, Object.assign(t.headers, { "X-Surge-Skip-Scripting": !1 })), $httpClient.get(t, (t, s, i) => { !t && s && (s.body = i, s.statusCode = s.status), e(t, s, i) })) : this.isQuanX() ? (this.isNeedRewrite && (t.opts = t.opts || {}, Object.assign(t.opts, { hints: !1 })), $task.fetch(t).then(t => { const { statusCode: s, statusCode: i, headers: r, body: o } = t; e(null, { status: s, statusCode: i, headers: r, body: o }, o) }, t => e(t))) : this.isNode() && (this.initGotEnv(t), this.got(t).on("redirect", (t, e) => { try { if (t.headers["set-cookie"]) { const s = t.headers["set-cookie"].map(this.cktough.Cookie.parse).toString(); this.ckjar.setCookieSync(s, null), e.cookieJar = this.ckjar } } catch (t) { this.logErr(t) } }).then(t => { const { statusCode: s, statusCode: i, headers: r, body: o } = t; e(null, { status: s, statusCode: i, headers: r, body: o }, o) }, t => { const { message: s, response: i } = t; e(s, i, i && i.body) })) } post(t, e = (() => { })) { if (t.body && t.headers && !t.headers["Content-Type"] && (t.headers["Content-Type"] = "application/x-www-form-urlencoded"), t.headers && delete t.headers["Content-Length"], this.isSurge() || this.isLoon()) this.isSurge() && this.isNeedRewrite && (t.headers = t.headers || {}, Object.assign(t.headers, { "X-Surge-Skip-Scripting": !1 })), $httpClient.post(t, (t, s, i) => { !t && s && (s.body = i, s.statusCode = s.status), e(t, s, i) }); else if (this.isQuanX()) t.method = "POST", this.isNeedRewrite && (t.opts = t.opts || {}, Object.assign(t.opts, { hints: !1 })), $task.fetch(t).then(t => { const { statusCode: s, statusCode: i, headers: r, body: o } = t; e(null, { status: s, statusCode: i, headers: r, body: o }, o) }, t => e(t)); else if (this.isNode()) { this.initGotEnv(t); const { url: s, ...i } = t; this.got.post(s, i).then(t => { const { statusCode: s, statusCode: i, headers: r, body: o } = t; e(null, { status: s, statusCode: i, headers: r, body: o }, o) }, t => { const { message: s, response: i } = t; e(s, i, i && i.body) }) } } time(t) { let e = { "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() }; /(y+)/.test(t) && (t = t.replace(RegExp.$1, ((new Date).getFullYear() + "").substr(4 - RegExp.$1.length))); for (let s in e) new RegExp("(" + s + ")").test(t) && (t = t.replace(RegExp.$1, 1 == RegExp.$1.length ? e[s] : ("00" + e[s]).substr(("" + e[s]).length))); return t } msg(e = t, s = "", i = "", r) { const o = t => { if (!t) return t; if ("string" == typeof t) return this.isLoon() ? t : this.isQuanX() ? { "open-url": t } : this.isSurge() ? { url: t } : void 0; if ("object" == typeof t) { if (this.isLoon()) { let e = t.openUrl || t.url || t["open-url"], s = t.mediaUrl || t["media-url"]; return { openUrl: e, mediaUrl: s } } if (this.isQuanX()) { let e = t["open-url"] || t.url || t.openUrl, s = t["media-url"] || t.mediaUrl; return { "open-url": e, "media-url": s } } if (this.isSurge()) { let e = t.url || t.openUrl || t["open-url"]; return { url: e } } } }; this.isMute || (this.isSurge() || this.isLoon() ? $notification.post(e, s, i, o(r)) : this.isQuanX() && $notify(e, s, i, o(r))); let h = ["", "==============\ud83d\udce3\u7cfb\u7edf\u901a\u77e5\ud83d\udce3=============="]; h.push(e), s && h.push(s), i && h.push(i), console.log(h.join("\n")), this.logs = this.logs.concat(h) } log(...t) { t.length > 0 && (this.logs = [...this.logs, ...t]), console.log(t.join(this.logSeparator)) } logErr(t, e) { const s = !this.isSurge() && !this.isQuanX() && !this.isLoon(); s ? this.log("", `\u2757\ufe0f${this.name}, \u9519\u8bef!`, t.stack) : this.log("", `\u2757\ufe0f${this.name}, \u9519\u8bef!`, t) } wait(t) { return new Promise(e => setTimeout(e, t)) } done(t = {}) { const e = (new Date).getTime(), s = (e - this.startTime) / 1e3; this.log("", `\ud83d\udd14${this.name}, \u7ed3\u675f! \ud83d\udd5b ${s} \u79d2`), this.log(), (this.isSurge() || this.isQuanX() || this.isLoon()) && $done(t) } }(t, e) }