2020-11-10 09:29:58 +08:00
/ *
京东京喜工厂
2020-11-20 19:17:33 +08:00
活动入口 : 京东APP - > 游戏与互动 - > 查看更多 - > 京喜工厂
或者 : 京东APP首页搜索 "玩一玩" , 造物工厂即可
2020-11-25 22:29:54 +08:00
已支持IOS双京东账号 , Node . js支持N个京东账号
脚本兼容 : QuantumultX , Surge , Loon , JSBox , Node . js
=== === === === Quantumultx === === === === ===
[ task _local ]
# 京喜工厂
10 * * * * https : //raw.githubusercontent.com/lxk0301/jd_scripts/master/jd_dreamFactory.js, tag=京喜工厂, enabled=true
=== === === === === = Loon === === === === ==
[ Script ]
cron "10 * * * *" script - path = https : //raw.githubusercontent.com/lxk0301/jd_scripts/master/jd_dreamFactory.js,tag=京喜工厂
=== === === === === Surge === === === === === ==
京喜工厂 = type = cron , cronexp = "10 * * * *" , wake - system = 1 , timeout = 20 , script - path = https : //raw.githubusercontent.com/lxk0301/jd_scripts/master/jd_dreamFactory.js
=== === === === 小火箭 === === ===
京喜工厂 = type = cron , script - path = https : //raw.githubusercontent.com/lxk0301/jd_scripts/master/jd_dreamFactory.js, cronexpr="10 * * * *", timeout=200, enable=true
2020-11-10 09:29:58 +08:00
* /
2020-11-20 14:23:04 +08:00
const $ = new Env ( '京喜工厂' ) ;
const JD _API _HOST = 'https://m.jingxi.com' ;
2020-11-20 16:36:17 +08:00
let ele , factoryId , productionId ;
2020-11-20 14:23:04 +08:00
let message = '' , subTitle = '' , option = { } ;
const notify = $ . isNode ( ) ? require ( './sendNotify' ) : '' ;
2020-11-20 19:05:09 +08:00
let jdNotify = true ; //是否关闭通知， ，
2020-11-20 14:23:04 +08:00
let cookiesArr = [ ] , cookie = '' ;
2020-11-27 08:35:06 +08:00
const inviteCodes = [ 'V5LkjP4WRyjeCKR9VRwcRX0bBuTz7MEK0-E99EJ7u0k=' ] ;
2020-11-20 14:23:04 +08:00
const jdCookieNode = $ . isNode ( ) ? require ( './jdCookie.js' ) : '' ;
if ( $ . isNode ( ) ) {
Object . keys ( jdCookieNode ) . forEach ( ( item ) => {
cookiesArr . push ( jdCookieNode [ item ] )
} )
if ( process . env . JD _DEBUG && process . env . JD _DEBUG === 'false' ) console . log = ( ) => {
2020-11-10 09:29:58 +08:00
} ;
2020-11-20 14:23:04 +08:00
} else {
cookiesArr . push ( ... [ $ . getdata ( 'CookieJD' ) , $ . getdata ( 'CookieJD2' ) ] )
}
! ( async ( ) => {
if ( ! cookiesArr [ 0 ] ) {
$ . msg ( $ . name , '【提示】请先获取京东账号一cookie\n直接使用NobyDa的京东签到获取' , 'https://bean.m.jd.com/' , { "open-url" : "https://bean.m.jd.com/" } ) ;
return ;
}
for ( let i = 0 ; i < cookiesArr . length ; i ++ ) {
if ( cookiesArr [ i ] ) {
cookie = cookiesArr [ i ] ;
$ . UserName = decodeURIComponent ( cookie . match ( /pt_pin=(.+?);/ ) && cookie . match ( /pt_pin=(.+?);/ ) [ 1 ] )
$ . index = i + 1 ;
$ . isLogin = true ;
$ . nickName = '' ;
await TotalBean ( ) ;
console . log ( ` \n ***********开始【京东账号 ${ $ . index } 】 ${ $ . nickName || $ . UserName } ******** \n ` ) ;
if ( ! $ . isLogin ) {
$ . msg ( $ . name , ` 【提示】cookie已失效 ` , ` 京东账号 ${ $ . index } ${ $ . nickName || $ . UserName } \n 请重新登录获取 \n https://bean.m.jd.com/ ` , { "open-url" : "https://bean.m.jd.com/" } ) ;
2020-11-10 09:29:58 +08:00
2020-11-20 14:23:04 +08:00
if ( $ . isNode ( ) ) {
await notify . sendNotify ( ` ${ $ . name } cookie已失效 - ${ $ . UserName } ` , ` 京东账号 ${ $ . index } ${ $ . UserName } \n 请重新登录获取cookie ` ) ;
2020-11-10 09:29:58 +08:00
} else {
2020-11-20 14:23:04 +08:00
$ . setdata ( '' , ` CookieJD ${ i ? i + 1 : "" } ` ) ; //cookie失效， ，
2020-11-10 09:29:58 +08:00
}
2020-11-20 14:23:04 +08:00
continue
}
message = '' ;
subTitle = '' ;
goodsUrl = '' ;
taskInfoKey = [ ] ;
option = { } ;
await jdDreamFactory ( ) ;
2020-11-10 09:29:58 +08:00
}
2020-11-20 14:23:04 +08:00
}
} ) ( )
. catch ( ( e ) => {
$ . log ( '' , ` ❌ ${ $ . name } , 失败! 原因: ${ e } ! ` , '' )
} )
. finally ( ( ) => {
$ . done ( ) ;
} )
async function jdDreamFactory ( ) {
ele = 0 ;
await userInfo ( ) ;
2020-11-25 09:55:51 +08:00
await helpFriends ( inviteCodes )
2020-11-20 16:42:03 +08:00
if ( $ . unActive ) return
2020-11-20 14:23:04 +08:00
await getUserElectricity ( ) ;
await taskList ( ) ;
await investElectric ( ) ;
// await assistFriend('gB99tYLjvPcEFloDgamoBw==');
await hireAward ( ) ;
await stealFriend ( ) ;
await showMsg ( ) ;
}
// 收取发电机的电力
2020-11-27 11:02:05 +08:00
function collectElectricity ( facId = factoryId , help = false , master ) {
2020-11-20 14:23:04 +08:00
return new Promise ( async resolve => {
2020-11-26 11:57:17 +08:00
let url = ` /dreamfactory/generator/CollectCurrentElectricity?zone=dream_factory&apptoken=&pgtimestamp=&phoneID=&factoryid= ${ facId } &doubleflag=1&sceneval=2&g_login_type=1 ` ;
if ( help && master ) {
url = ` /dreamfactory/generator/CollectCurrentElectricity?zone=dream_factory&factoryid= ${ facId } &master= ${ master } &sceneval=2&g_login_type=1 ` ;
}
2020-11-20 14:23:04 +08:00
$ . get ( taskurl ( url ) , ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
if ( help ) {
ele += Number ( data . data [ 'loginPinCollectElectricity' ] )
console . log ( ` 帮助好友收取 ${ data . data [ 'CollectElectricity' ] } 电力，获得 ${ data . data [ 'loginPinCollectElectricity' ] } 电力 ` ) ;
message += ` 【帮助好友】帮助成功，获得 ${ data . data [ 'loginPinCollectElectricity' ] } 电力 \n `
} else {
ele += Number ( data . data [ 'CollectElectricity' ] )
console . log ( ` 收取 ${ data . data [ 'loginPinCollectElectricity' ] } 电力 ` ) ;
message += ` 【收取发电站】收取成功，获得 ${ data . data [ 'CollectElectricity' ] } 电力 \n `
}
} else {
2020-11-26 11:57:17 +08:00
console . log ( data . msg )
2020-11-10 09:29:58 +08:00
}
2020-11-20 14:23:04 +08:00
} else {
console . log ( ` 京东服务器返回空数据 ` )
2020-11-10 09:29:58 +08:00
}
2020-11-20 14:23:04 +08:00
}
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
2020-11-10 09:29:58 +08:00
}
2020-11-20 14:23:04 +08:00
} )
} )
2020-11-10 09:29:58 +08:00
}
// 投入电力
function investElectric ( ) {
2020-11-20 14:23:04 +08:00
return new Promise ( async resolve => {
const url = ` /dreamfactory/userinfo/InvestElectric?zone=dream_factory&productionId= ${ productionId } &sceneval=2&g_login_type=1 ` ;
$ . get ( taskurl ( url ) , ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
// console.log(data)
data = JSON . parse ( data ) ;
if ( data . ret === 0 ) {
console . log ( ` 成功投入电力 ${ data . data . investElectric } 电力 ` ) ;
message += ` 【投入电力】投入成功，共计 ${ data . data . investElectric } 电力 \n ` ;
} else {
console . log ( ` 投入失败， ${ data . msg } ` ) ;
message += ` 【投入电力】投入失败， ${ data . msg } \n ` ;
}
} else {
console . log ( ` 京东服务器返回空数据 ` )
}
}
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
2020-11-10 09:29:58 +08:00
}
2020-11-20 14:23:04 +08:00
} )
2020-11-10 09:29:58 +08:00
} )
}
2020-11-20 14:23:04 +08:00
2020-11-10 09:29:58 +08:00
// 初始化任务
function taskList ( ) {
2020-11-20 14:23:04 +08:00
return new Promise ( async resolve => {
const url = ` /newtasksys/newtasksys_front/GetUserTaskStatusList?source=dreamfactory&bizCode=dream_factory&sceneval=2&g_login_type=1 ` ;
$ . get ( taskurl ( url ) , async ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
// console.log(data)
data = JSON . parse ( data ) ;
let userTaskStatusList = data [ 'data' ] [ 'userTaskStatusList' ] ;
for ( let i = 0 ; i < userTaskStatusList . length ; ++ i ) {
const vo = userTaskStatusList [ i ] ;
if ( vo [ 'awardStatus' ] !== 1 ) {
if ( vo . completedTimes >= vo . targetTimes ) {
console . log ( ` 任务： ${ vo . description } 可完成 ` )
await completeTask ( vo . taskId , vo . taskName )
2020-11-20 16:36:17 +08:00
await $ . wait ( 1000 ) ; //延迟等待一秒
2020-11-20 14:23:04 +08:00
} else {
switch ( vo . taskType ) {
case 2 : // 逛一逛任务
case 6 : // 浏览商品任务
case 9 : // 开宝箱
for ( let i = vo . completedTimes ; i <= vo . configTargetTimes ; ++ i ) {
console . log ( ` 去做任务： ${ vo . taskName } ` )
await doTask ( vo . taskId )
await completeTask ( vo . taskId , vo . taskName )
2020-11-20 16:36:17 +08:00
await $ . wait ( 1000 ) ; //延迟等待一秒
2020-11-20 14:23:04 +08:00
}
break
case 4 : // 招工
break
case 5 :
// 收集类
break
case 1 : // 登陆领奖
default :
break
}
}
}
}
console . log ( ` 完成任务：共领取 ${ ele } 电力 ` )
message += ` 【每日任务】领奖成功，共计 ${ ele } 电力 \n ` ;
} else {
console . log ( ` 京东服务器返回空数据 ` )
2020-11-10 09:29:58 +08:00
}
2020-11-20 14:23:04 +08:00
}
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
}
} )
} )
}
// 获得用户电力情况
function getUserElectricity ( ) {
return new Promise ( async resolve => {
const url = ` /dreamfactory/generator/QueryCurrentElectricityQuantity?zone=dream_factory&factoryid= ${ factoryId } &sceneval=2&g_login_type=1 `
$ . get ( taskurl ( url ) , async ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
// console.log(data)
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
console . log ( ` 发电机：当前 ${ data . data . currentElectricityQuantity } 电力，最大值 ${ data . data . maxElectricityQuantity } 电力 ` )
if ( data . data . currentElectricityQuantity === data . data . maxElectricityQuantity
&& data . data . doubleElectricityFlag ) {
console . log ( ` 发电机：电力可翻倍并收获 ` )
await collectElectricity ( )
} else {
message += ` 【发电机电力】当前 ${ data . data . currentElectricityQuantity } 电力，未达到收获标准 \n `
}
}
} else {
console . log ( ` 京东服务器返回空数据 ` )
2020-11-10 09:29:58 +08:00
}
}
2020-11-20 14:23:04 +08:00
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
2020-11-10 09:29:58 +08:00
}
2020-11-20 14:23:04 +08:00
} )
} )
}
// 收取招工电力
function hireAward ( ) {
return new Promise ( async resolve => {
const url = ` /dreamfactory/friend/HireAward?zone=dream_factory&date= ${ new Date ( ) . Format ( "yyyyMMdd" ) } &type=0&sceneval=2&g_login_type=1 `
$ . get ( taskurl ( url ) , async ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
console . log ( ` 打工电力：收取成功 ` )
message += ` 【打工电力】：收取成功 \n `
} else {
console . log ( ` 打工电力：收取失败， ${ data . msg } ` )
2020-11-26 13:02:12 +08:00
message += ` 【打工电力】收取失败， ${ data . msg } \n `
2020-11-20 14:23:04 +08:00
}
} else {
console . log ( ` 京东服务器返回空数据 ` )
}
}
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
}
} )
2020-11-10 09:29:58 +08:00
} )
}
2020-11-25 09:55:51 +08:00
async function helpFriends ( codes ) {
for ( let code of codes ) {
if ( code ) {
await assistFriend ( code ) ;
}
}
}
2020-11-20 14:23:04 +08:00
// 帮助用户
function assistFriend ( sharepin ) {
return new Promise ( async resolve => {
2020-11-27 08:33:58 +08:00
const url = ` /dreamfactory/friend/AssistFriend?zone=dream_factory&sharepin= ${ escape ( sharepin ) } &sceneval=2&g_login_type=1 `
2020-11-20 14:23:04 +08:00
$ . get ( taskurl ( url ) , async ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
console . log ( ` 助力朋友： ${ sharepin } 成功 ` )
} else {
2020-11-26 11:57:17 +08:00
console . log ( ` 助力朋友[ ${ sharepin } ]失败： ${ data . msg } ` )
2020-11-20 14:23:04 +08:00
}
} else {
console . log ( ` 京东服务器返回空数据 ` )
}
}
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
}
} )
} )
}
// 任务领奖
function completeTask ( taskId , taskName ) {
return new Promise ( async resolve => {
const url = ` /newtasksys/newtasksys_front/Award?source=dreamfactory&bizCode=dream_factory&taskId= ${ taskId } &sceneval=2&g_login_type=1 ` ;
$ . get ( taskurl ( url ) , ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
// console.log(data)
data = JSON . parse ( data ) ;
switch ( data [ 'data' ] [ 'awardStatus' ] ) {
case 1 :
ele += Number ( data [ 'data' ] [ 'prizeInfo' ] . replace ( '\\n' , '' ) )
console . log ( ` 领取 ${ taskName } 任务奖励成功，收获： ${ Number ( data [ 'data' ] [ 'prizeInfo' ] . replace ( '\\n' , '' ) ) } 电力 ` ) ;
break
case 1013 :
case 0 :
console . log ( ` 领取 ${ taskName } 任务奖励失败，任务已领奖 ` ) ;
break
default :
console . log ( ` 领取 ${ taskName } 任务奖励失败， ${ data [ 'msg' ] } ` )
break
}
} else {
console . log ( ` 京东服务器返回空数据 ` )
}
}
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
}
} )
} )
}
// 完成任务
function doTask ( taskId ) {
return new Promise ( async resolve => {
const url = ` /newtasksys/newtasksys_front/DoTask?source=dreamfactory&bizCode=dream_factory&taskId= ${ taskId } &sceneval=2&g_login_type=1 ` ;
$ . get ( taskurl ( url ) , ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
// console.log(data)
data = JSON . parse ( data ) ;
if ( data . ret === 0 ) {
console . log ( "做任务完成！" )
}
} else {
console . log ( ` 京东服务器返回空数据 ` )
}
}
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
}
} )
} )
}
// 初始化个人信息
2020-11-10 09:29:58 +08:00
function userInfo ( ) {
2020-11-20 14:23:04 +08:00
return new Promise ( async resolve => {
const url = ` /dreamfactory/userinfo/GetUserInfo?zone=dream_factory&pin=&sharePin=&shareType=&materialTuanPin=&materialTuanId=&sceneval=2 ` ;
2020-11-26 17:56:27 +08:00
$ . get ( taskurl ( url ) , async ( err , resp , data ) => {
2020-11-20 14:23:04 +08:00
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
data = data [ 'data' ] ;
2020-11-10 09:29:58 +08:00
if ( data . factoryList && data . productionList ) {
const production = data . productionList [ 0 ] ;
const factory = data . factoryList [ 0 ] ;
factoryId = factory . factoryId ; //工厂ID
productionId = production . productionId ; //商品ID
subTitle = data . user . pin ;
2020-11-26 17:56:27 +08:00
await GetCommodityDetails ( production . commodityDimId ) ;
2020-11-26 18:22:15 +08:00
await DrawProductionStagePrize ( productionId ) ;
2020-11-20 14:23:04 +08:00
console . log ( ` 当前电力： ${ data . user . electric } ` )
console . log ( ` 分享码: ${ data . user . encryptPin } ` ) ;
console . log ( ` 生产进度： ${ ( production . investedElectric / production . needElectric ) . toFixed ( 2 ) * 100 } % ` ) ;
2020-11-26 17:56:27 +08:00
message += ` 【京东账号 ${ $ . index } 】 ${ $ . nickName } \n `
message += ` 【生产商品】 ${ $ . productName } \n ` ;
2020-11-10 09:29:58 +08:00
message += ` 【生产进度】 ${ ( ( production . investedElectric / production . needElectric ) * 100 ) . toFixed ( 2 ) } % \n ` ;
2020-11-26 17:56:27 +08:00
if ( production . investedElectric >= production . needElectric ) {
2020-11-26 18:02:59 +08:00
$ . msg ( $ . name , ` ` , ` 【京东账号 ${ $ . index } 】 ${ $ . nickName } \n 【生产商品】 ${ $ . productName } \n 已生产完,请速去兑换 ` , { 'open-url' : 'openjd://virtual?params=%7B%20%22category%22:%20%22jump%22,%20%22des%22:%20%22m%22,%20%22url%22:%20%22https://wqsd.jd.com/pingou/dream_factory/index.html%22%20%7D' } )
await notify . sendNotify ( ` ${ $ . name } - 京东账号 ${ $ . index } - ${ $ . nickName } ` , ` 【京东账号 ${ $ . index } 】 ${ $ . nickName } \n 【生产商品】 ${ $ . productName } \n 已生产完,请速去兑换 ` )
2020-11-26 17:56:27 +08:00
}
2020-11-10 09:29:58 +08:00
} else {
2020-11-26 17:56:27 +08:00
$ . unActive = true ; //标记是否开启了京喜活动或者选购了商品进行生产
if ( ! data . factoryList ) {
console . log ( '【提示】此账号京喜工厂活动未开始\n请手动去京东APP->游戏与互动->查看更多->京喜工厂 开启活动\n' ) ;
$ . msg ( $ . name , '' , ` 【提示】此账号[ ${ $ . nickName } ]京喜工厂活动未开始 \n 请手动去京东APP->游戏与互动->查看更多->京喜工厂 开启活动 ` ) ;
} else if ( data . factoryList && ! data . productionList ) {
console . log ( ` 【提示】此账号京喜工厂未选购商品 \n 请手动去京东APP->游戏与互动->查看更多->京喜工厂 选购 \n ` )
$ . msg ( $ . name , '' , ` 【提示】此账号[ ${ $ . nickName } ]京喜工厂未选择商品 \n 请手动去京东APP->游戏与互动->查看更多->京喜工厂 选择商品 ` ) ;
}
2020-11-10 09:29:58 +08:00
}
}
2020-11-20 14:23:04 +08:00
resolve ( )
} )
2020-11-10 09:29:58 +08:00
} )
}
2020-11-26 17:56:27 +08:00
//查询当前生产的商品名称
function GetCommodityDetails ( commodityDimId ) {
return new Promise ( async resolve => {
const url = ` /dreamfactory/diminfo/GetCommodityDetails?zone=dream_factory&sceneval=2&g_login_type=1&commodityId= ${ commodityDimId } ` ;
$ . get ( taskurl ( url ) , ( err , resp , data ) => {
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
data = data [ 'data' ] ;
$ . productName = data [ 'commodityList' ] [ 0 ] . name ;
}
resolve ( )
} )
} )
}
2020-11-26 18:22:15 +08:00
//领取红包
function DrawProductionStagePrize ( productionId ) {
return new Promise ( async resolve => {
const url = ` /dreamfactory/userinfo/DrawProductionStagePrize?zone=dream_factory&sceneval=2&g_login_type=1&productionId= ${ productionId } ` ;
$ . get ( taskurl ( url ) , ( err , resp , data ) => {
console . log ( ` 领取红包(测试中)结果： ${ data } ` )
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
// data = data['data'];
// $.productName = data['commodityList'][0].name;
}
resolve ( )
} )
} )
}
2020-11-20 14:23:04 +08:00
function stealFriend ( ) {
return new Promise ( async resolve => {
const url = ` //dreamfactory/friend/QueryFactoryManagerList?zone=dream_factory&sceneval=2 ` ;
2020-11-26 11:57:17 +08:00
$ . get ( taskurl ( url ) , async ( err , resp , data ) => {
2020-11-20 14:23:04 +08:00
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
data = data [ 'data' ] ;
for ( let i = 0 ; i < data . list . length ; ++ i ) {
let pin = data . list [ i ] [ 'encryptPin' ] ;
2020-11-27 11:02:05 +08:00
const facId = await getFactoryIdByPin ( pin ) ;
if ( facId ) await collectElectricity ( facId , true , data . list [ i ] [ 'key' ] )
2020-11-20 14:23:04 +08:00
}
}
resolve ( )
} )
2020-11-10 09:29:58 +08:00
} )
}
2020-11-20 14:23:04 +08:00
function getFactoryIdByPin ( pin ) {
2020-11-10 09:29:58 +08:00
return new Promise ( ( resolve , reject ) => {
2020-11-20 14:23:04 +08:00
const url = ` /dreamfactory/userinfo/GetUserInfoByPin?zone=dream_factory&pin= ${ pin } &sceneval=2 ` ;
$ . get ( taskurl ( url ) , ( err , resp , data ) => {
data = JSON . parse ( data ) ;
if ( data [ 'ret' ] === 0 ) {
2020-11-25 09:55:51 +08:00
if ( data . data . factoryList ) {
//做此判断,有时候返回factoryList为null
resolve ( data [ 'data' ] [ 'factoryList' ] [ 0 ] [ 'factoryId' ] )
} else {
resolve ( ) ;
}
2020-11-20 14:23:04 +08:00
} else {
reject ( )
2020-11-10 09:29:58 +08:00
}
} )
} )
}
2020-11-20 14:23:04 +08:00
async function showMsg ( ) {
let ctrTemp ;
if ( $ . isNode ( ) && process . env . DREAMFACTORY _NOTIFY _CONTROL ) {
ctrTemp = ` ${ process . env . DREAMFACTORY _NOTIFY _CONTROL } ` === 'false' ;
} else if ( $ . getdata ( 'jdDreamFactory' ) ) {
ctrTemp = $ . getdata ( 'jdDreamFactory' ) === 'false' ;
} else {
ctrTemp = ` ${ jdNotify } ` === 'false' ;
}
if ( ctrTemp ) {
$ . msg ( $ . name , subTitle , message , option ) ;
if ( $ . isNode ( ) ) {
await notify . sendNotify ( ` ${ $ . name } - 账号 ${ $ . index } - ${ $ . nickName } ` , ` ${ subTitle } \n ${ message } ` ) ;
}
} else {
$ . log ( ` \n ${ message } \n ` ) ;
}
}
function TotalBean ( ) {
return new Promise ( async resolve => {
const options = {
"url" : ` https://wq.jd.com/user/info/QueryJDUserInfo?sceneval=2 ` ,
"headers" : {
"Accept" : "application/json,text/plain, */*" ,
"Content-Type" : "application/x-www-form-urlencoded" ,
"Accept-Encoding" : "gzip, deflate, br" ,
"Accept-Language" : "zh-cn" ,
"Connection" : "keep-alive" ,
"Cookie" : cookie ,
"Referer" : "https://wqs.jd.com/my/jingdou/my.shtml?sceneval=2" ,
"User-Agent" : "Mozilla/5.0 (iPhone; CPU iPhone OS 14_0_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/14.0 Mobile/15E148 Safari/604.1"
}
}
$ . post ( options , ( err , resp , data ) => {
try {
if ( err ) {
console . log ( ` ${ JSON . stringify ( err ) } ` )
console . log ( ` ${ $ . name } API请求失败， ` )
} else {
if ( data ) {
data = JSON . parse ( data ) ;
if ( data [ 'retcode' ] === 13 ) {
$ . isLogin = false ; //cookie过期
return
}
$ . nickName = data [ 'base' ] . nickname ;
} else {
console . log ( ` 京东服务器返回空数据 ` )
}
}
} catch ( e ) {
$ . logErr ( e , resp )
} finally {
resolve ( ) ;
}
} )
} )
}
// 生成url
2020-11-10 09:29:58 +08:00
function taskurl ( url , body ) {
return {
url : ` ${ JD _API _HOST } ${ url } ` ,
headers : {
2020-11-20 14:23:04 +08:00
'Cookie' : cookie ,
'Host' : 'm.jingxi.com' ,
2020-11-10 09:29:58 +08:00
'Accept' : '*/*' ,
'Connection' : 'keep-alive' ,
2020-11-20 14:23:04 +08:00
'User-Agent' : 'jdpingou;iPhone;3.14.4;14.0;ae75259f6ca8378672006fc41079cd8c90c53be8;network/wifi;model/iPhone10,2;appBuild/100351;ADID/00000000-0000-0000-0000-000000000000;supportApplePay/1;hasUPPay/0;pushNoticeIsOpen/1;hasOCPay/0;supportBestPay/0;session/62;pap/JA2015_311210;brand/apple;supportJDSHWK/1;Mozilla/5.0 (iPhone; CPU iPhone OS 14_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148' ,
2020-11-10 09:29:58 +08:00
'Accept-Language' : 'zh-cn' ,
'Referer' : 'https://wqsd.jd.com/pingou/dream_factory/index.html' ,
'Accept-Encoding' : 'gzip, deflate, br' ,
}
}
2020-11-20 14:23:04 +08:00
}
Date . prototype . Format = function ( fmt ) { //author: meizz
var o = {
"M+" : this . getMonth ( ) + 1 , //月份
"d+" : this . getDate ( ) , //日
"h+" : this . getHours ( ) , //小时
"m+" : this . getMinutes ( ) , //分
"s+" : this . getSeconds ( ) , //秒
"q+" : Math . floor ( ( this . getMonth ( ) + 3 ) / 3 ) , //季度
"S" : this . getMilliseconds ( ) //毫秒
} ;
if ( /(y+)/ . test ( fmt ) )
fmt = fmt . replace ( RegExp . $1 , ( this . getFullYear ( ) + "" ) . substr ( 4 - RegExp . $1 . length ) ) ;
for ( var k in o )
if ( new RegExp ( "(" + k + ")" ) . test ( fmt ) )
fmt = fmt . replace ( RegExp . $1 , ( RegExp . $1 . length == 1 ) ? ( o [ k ] ) : ( ( "00" + o [ k ] ) . substr ( ( "" + o [ k ] ) . length ) ) ) ;
return fmt ;
}
// prettier-ignore
function Env ( t , e ) {
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 , o ) => {
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 . logSeparator = "\n" , this . startTime = ( new Date ) . getTime ( ) , Object . assign ( this , e ) , this . log ( "" , ` \u d83d \u dd14 ${ this . name } , \u 5f00 \u 59cb! ` )
}
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 o = this . getdata ( "@chavy_boxjs_userCfgs.httpapi_timeout" ) ;
o = o ? 1 * o : 20 , o = e && e . timeout ? e . timeout : o ;
const [ r , h ] = i . split ( "@" ) , a = {
url : ` http:// ${ h } /v1/scripting/evaluate ` ,
body : { script _text : t , mock _type : "cron" , timeout : o } ,
headers : { "X-Key" : r , 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 ) , o = JSON . stringify ( this . data ) ;
s ? this . fs . writeFileSync ( t , o ) : i ? this . fs . writeFileSync ( e , o ) : this . fs . writeFileSync ( t , o )
}
}
lodash _get ( t , e , s ) {
const i = e . replace ( /\[(\d+)\]/g , ".$1" ) . split ( "." ) ;
let o = t ;
for ( const t of i ) if ( o = Object ( o ) [ t ] , void 0 === o ) return s ;
return o
}
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 ) , o = s ? this . getval ( s ) : "" ;
if ( o ) try {
const t = JSON . parse ( o ) ;
e = t ? this . lodash _get ( t , i , "" ) : e
} catch ( t ) {
e = ""
}
}
return e
}
setdata ( t , e ) {
let s = ! 1 ;
if ( /^@/ . test ( e ) ) {
const [ , i , o ] = /^@(.*?)\.(.*?)$/ . exec ( e ) , r = this . getval ( i ) , h = i ? "null" === r ? null : r || "{}" : "{}" ;
try {
const e = JSON . parse ( h ) ;
this . lodash _set ( e , o , t ) , s = this . setval ( JSON . stringify ( e ) , i )
} catch ( e ) {
const r = { } ;
this . lodash _set ( r , o , t ) , s = this . setval ( JSON . stringify ( r ) , 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 ( ) ? $httpClient . get ( t , ( t , s , i ) => {
! t && s && ( s . body = i , s . statusCode = s . status ) , e ( t , s , i )
} ) : this . isQuanX ( ) ? $task . fetch ( t ) . then ( t => {
const { statusCode : s , statusCode : i , headers : o , body : r } = t ;
e ( null , { status : s , statusCode : i , headers : o , body : r } , r )
} , t => e ( t ) ) : this . isNode ( ) && ( this . initGotEnv ( t ) , this . got ( t ) . on ( "redirect" , ( t , e ) => {
try {
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 : o , body : r } = t ;
e ( null , { status : s , statusCode : i , headers : o , body : r } , r )
} , t => e ( t ) ) )
}
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 ( ) ) $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" , $task . fetch ( t ) . then ( t => {
const { statusCode : s , statusCode : i , headers : o , body : r } = t ;
e ( null , { status : s , statusCode : i , headers : o , body : r } , r )
} , 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 : o , body : r } = t ;
e ( null , { status : s , statusCode : i , headers : o , body : r } , r )
} , t => e ( t ) )
}
}
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 = "" , o ) {
const r = t => {
if ( ! t || ! this . isLoon ( ) && this . isSurge ( ) ) return t ;
if ( "string" == typeof t ) return this . isLoon ( ) ? t : this . isQuanX ( ) ? { "open-url" : t } : void 0 ;
if ( "object" == typeof t ) {
if ( this . isLoon ( ) ) {
let e = t . openUrl || t [ "open-url" ] , s = t . mediaUrl || t [ "media-url" ] ;
return { openUrl : e , mediaUrl : s }
}
if ( this . isQuanX ( ) ) {
let e = t [ "open-url" ] || t . openUrl , s = t [ "media-url" ] || t . mediaUrl ;
return { "open-url" : e , "media-url" : s }
}
}
} ;
this . isMute || ( this . isSurge ( ) || this . isLoon ( ) ? $notification . post ( e , s , i , r ( o ) ) : this . isQuanX ( ) && $notify ( e , s , i , r ( o ) ) ) ;
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 ( "" , ` \u 2757 \u fe0f ${ this . name } , \u 9519 \u 8bef! ` , t . stack ) : this . log ( "" , ` \u 2757 \u fe0f ${ this . name } , \u 9519 \u 8bef! ` , t )
}
wait ( t ) {
return new Promise ( e => setTimeout ( e , t ) )
}
done ( t = { } ) {
const e = ( new Date ) . getTime ( ) , s = ( e - this . startTime ) / 1e3 ;
this . log ( "" , ` \u d83d \u dd14 ${ this . name } , \u 7ed3 \u 675f! \u d83d \u dd5b ${ s } \u 79d2 ` ) , this . log ( ) , ( this . isSurge ( ) || this . isQuanX ( ) || this . isLoon ( ) ) && $done ( t )
}
} ( t , e )
}
