text: /*
  京东到家鲜豆任务脚本,支持qx,loon,shadowrocket,surge,nodejs
  兼容京东jdCookie.js
  手机设备在boxjs里填写cookie
  boxjs订阅地址:https://gitee.com/passerby-b/javascript/raw/master/JD/passerby-b.boxjs.json
  TG群:https://t.me/passerbyb2021
  
  [task_local]
  10 0 * * * https://raw.githubusercontent.com/passerby-b/JDDJ/main/jddj_bean.js
  
  [Script]
  cron "10 0 * * *" script-path=https://raw.githubusercontent.com/passerby-b/JDDJ/main/jddj_bean.js,tag=京东到家鲜豆任务
  
  */
  
  const $ = new API("jddj_bean");
  let ckPath = './jdCookie.js';//ck路径,环境变量:JDDJ_CKPATH
  let cookies = [];
  let thiscookie = '', deviceid = '';
  !(async () => {
      if (cookies.length == 0) {
          if ($.env.isNode) {
              if (process.env.JDDJ_CKPATH) ckPath = process.env.JDDJ_CKPATH;
              delete require.cache[ckPath];
              let jdcookies = require(ckPath);
              for (let key in jdcookies) if (!!jdcookies[key]) cookies.push(jdcookies[key]);
          }
          else {
              let ckstr = $.read('#jddj_cookies');
              if (!!ckstr) {
                  if (ckstr.indexOf(',') < 0) {
                      cookies.push(ckstr);
                  } else {
                      cookies = ckstr.split(',');
                  }
              }
          }
      }
      if (cookies.length == 0) {
          console.log(`\r\n请先填写cookie`);
          return;
      }
      for (let i = 0; i < cookies.length; i++) {
          console.log(`\r\n★★★★★开始执行第${i + 1}个账号,共${cookies.length}个账号★★★★★`);
          thiscookie = cookies[i];
          if (!thiscookie.trim()) continue;
  
          thiscookie = await taskLoginUrl(thiscookie);
  
          await userinfo();
          await $.wait(1000);
  
          let tslist = await taskList();
          if (tslist.code == 1) {
              $.notify('第' + (i + 1) + '个账号cookie过期', '请访问\nhttps://bean.m.jd.com/bean/signIndex.action\n抓取cookie', { url: 'https://bean.m.jd.com/bean/signIndex.action' });
              continue;
          }
  
          await runTask(tslist);
  
      }
  
  })().catch((e) => {
      console.log('', `❌失败! 原因: ${e}!`, '');
  }).finally(() => {
      $.done();
  })
  
  //个人信息
  async function userinfo() {
      return new Promise(async resolve => {
          try {
              let option = urlTask('https://daojia.jd.com/client?_jdrandom=' + Math.round(new Date()) + '&platCode=H5&appName=paidaojia&channel=&appVersion=8.7.6&jdDevice=&functionId=mine%2FgetUserAccountInfo&body=%7B%22refPageSource%22:%22%22,%22fromSource%22:2,%22pageSource%22:%22myinfo%22,%22ref%22:%22%22,%22ctp%22:%22myinfo%22%7D&jda=&traceId=' + deviceid + Math.round(new Date()) + '&deviceToken=' + deviceid + '&deviceId=' + deviceid + '', '')
  
              //$.http.get(option).then(response => {
                  let data = JSON.parse(response.body);
                  if (data.code == 0) {
                      nickname = data.result.userInfo.userBaseInfo.nickName;
                      console.log("●●●" + nickname + "●●●");
                  }
              })
              resolve();
  
          } catch (error) {
              console.log('\n【个人信息】:' + error);
              resolve();
          }
      })
  }
  
  //任务列表
  async function taskList() {
      return new Promise(async resolve => {
          try {
              let option = urlTask('https://daojia.jd.com/client?_jdrandom=' + Math.round(new Date()) + '&functionId=task%2Flist&isNeedDealError=true&body=%7B%22modelId%22%3A%22M10001%22%2C%22plateCode%22%3A1%7D&channel=ios&platform=6.6.0&platCode=h5&appVersion=6.6.0&appName=paidaojia&deviceModel=appmodel&traceId=' + deviceid + '&deviceToken=' + deviceid + '&deviceId=' + deviceid, '');
  
              //$.http.get(option).then(response => {
                  var data = JSON.parse(response.body);
                  //console.log(response.body);
                  resolve(data);
              })
  
          } catch (error) {
              console.log('\n【任务列表】:' + error);
              resolve({});
          }
  
      })
  }
  
  
  async function runTask(tslist) {
      return new Promise(async resolve => {
          try {
              for (let index = 0; index < tslist.result.taskInfoList.length; index++) {
                  const item = tslist.result.taskInfoList[index];
  
                  //领取任务
                  let option = urlTask('https://daojia.jd.com/client?_jdrandom=' + Math.round(new Date()) + '&functionId=task%2Freceived&isNeedDealError=true&body=%7B%22modelId%22%3A%22' + item.modelId + '%22%2C%22taskId%22%3A%22' + encodeURIComponent(item.taskId) + '%22%2C%22taskType%22%3A' + item.taskType + '%2C%22plateCode%22%3A1%7D&channel=ios&platform=6.6.0&platCode=h5&appVersion=6.6.0&appName=paidaojia&deviceModel=appmodel&traceId=' + deviceid + Math.round(new Date()) + '&deviceToken=' + deviceid + '&deviceId=' + deviceid + '', ``);
                  await //$.http.get(option).then(response => {
                      var data = JSON.parse(response.body), msg = '';
                      if (data.code == 0) {
                          msg = data.msg + ',奖励:' + data.result.awardValue;
                      } else {
                          msg = data.msg;
                      }
                      console.log('\n领取任务【' + item.taskName + '】:' + msg);
                  })
  
                  if (item.browseTime > -1) {
                      for (let t = 0; t < parseInt(item.browseTime); t++) {
                          await $.wait(1000);
                          console.log('计时:' + (t + 1) + '秒...');
                      }
                  }
  
                  //结束任务
                  option = urlTask('https://daojia.jd.com/client?_jdrandom=' + Math.round(new Date()) + '&functionId=task%2Ffinished&isNeedDealError=true&body=%7B%22modelId%22%3A%22' + item.modelId + '%22%2C%22taskId%22%3A%22' + encodeURIComponent(item.taskId) + '%22%2C%22taskType%22%3A' + item.taskType + '%2C%22plateCode%22%3A1%7D&channel=ios&platform=6.6.0&platCode=h5&appVersion=6.6.0&appName=paidaojia&deviceModel=appmodel&traceId=' + deviceid + Math.round(new Date()) + '&deviceToken=' + deviceid + '&deviceId=' + deviceid + '', ``);
                  await //$.http.get(option).then(response => {
                      var data = JSON.parse(response.body), msg = '';
                      if (data.code == 0) {
                          msg = data.msg + ',奖励:' + data.result.awardValue;
                      } else {
                          msg = data.msg;
                      }
                      console.log('\n任务完成【' + item.taskName + '】:' + msg);
                  })
  
                  //领取奖励
                  option = urlTask('https://daojia.jd.com/client?_jdrandom=' + Math.round(new Date()) + '&functionId=task%2FsendPrize&isNeedDealError=true&body=%7B%22modelId%22%3A%22' + item.modelId + '%22%2C%22taskId%22%3A%22' + encodeURIComponent(item.taskId) + '%22%2C%22taskType%22%3A' + item.taskType + '%2C%22plateCode%22%3A1%7D&channel=ios&platform=6.6.0&platCode=h5&appVersion=6.6.0&appName=paidaojia&deviceModel=appmodel&traceId=' + deviceid + Math.round(new Date()) + '&deviceToken=' + deviceid + '&deviceId=' + deviceid, ``);
                  await //$.http.get(option).then(response => {
                      var data = JSON.parse(response.body), msg = '';
                      if (data.code == 0) {
                          msg = data.msg + ',奖励:' + data.result.awardValue;
                      } else {
                          msg = data.msg;
                      }
                      console.log('\n领取奖励【' + item.taskName + '】:' + msg);
                  })
  
              }
              resolve();
          } catch (error) {
              console.log('\n【执行任务】:' + error);
              resolve();
          }
  
      })
  }
  
  function urlTask(url, body) {
      let option = {
          url: url,
          headers: {
              'Host': 'daojia.jd.com',
              'Content-Type': 'application/x-www-form-urlencoded;',
              'Origin': 'https://daojia.jd.com',
              'Cookie': thiscookie,
              'Connection': 'keep-alive',
              'Accept': '*/*',
              'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 14_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148________appName=jdLocal&platform=iOS&commonParams={"sharePackageVersion":"2"}&djAppVersion=8.7.5&supportDJSHWK',
              'Accept-Language': 'zh-cn'
          },
          body: body
      };
      return option;
  }
  
  //根据京东ck获取到家ck
  async function taskLoginUrl(thiscookie) {
      return new Promise(async resolve => {
          try {
              if (thiscookie.indexOf('deviceid_pdj_jd') > -1) {
                  let arr = thiscookie.split(';');
                  for (const o of arr) {
                      if (o.indexOf('deviceid_pdj_jd') > -1) {
                          deviceid = o.split('=')[1];
                      }
                  }
                  resolve(thiscookie);
              }
              else {
                  deviceid = _uuid();
                  let option = {
                      url: encodeURI('https://daojia.jd.com/client?_jdrandom=' + (+new Date()) + '&_funid_=login/treasure&functionId=login/treasure&body={}&lat=&lng=&lat_pos=&lng_pos=&city_id=&channel=h5&platform=6.6.0&platCode=h5&appVersion=6.6.0&appName=paidaojia&deviceModel=appmodel&isNeedDealError=false&traceId=' + deviceid + '&deviceToken=' + deviceid + '&deviceId=' + deviceid + '&_jdrandom=' + (+new Date()) + '&_funid_=login/treasure'),
                      headers: {
                          "Cookie": 'deviceid_pdj_jd=' + deviceid + ';' + thiscookie + ';',
                          "Host": "daojia.jd.com",
                          'Content-Type': 'application/x-www-form-urlencoded;',
                          "User-Agent": 'jdapp;iPhone;10.0.10;14.1;' + deviceid + ';network/wifi;model/iPhone11,6;appBuild/167764;jdSupportDarkMode/0;Mozilla/5.0 (iPhone; CPU iPhone OS 14_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1'
                      }
                  };
                  let ckstr = '';
                  await //$.http.get(option).then(async response => {
                      //console.log(response);
                      let body = JSON.parse(response.body);
                      if (body.code == 0) {
                          for (const key in response.headers) {
                              if (key.toLowerCase().indexOf('cookie') > -1) {
                                  ckstr = response.headers[key].toString();
                              }
                          }
                          ckstr += ';deviceid_pdj_jd=' + deviceid;
                      }
                      else {
                          console.log(body.msg);
                      }
                  });
                  resolve(ckstr);
              }
  
          } catch (error) {
              console.log(error);
              resolve('');
          }
      })
  }
  
  function _uuid() {
      function s4() {
          return Math.floor((1 + Math.random()) * 0x10000).toString(16).substring(1);
      }
      return s4() + s4() + '-' + s4() + '-' + s4() + '-' + s4() + '-' + s4() + s4() + s4();
  }
  
  /*********************************** API *************************************/
  function ENV() { const e = "undefined" != typeof $task, t = "undefined" != typeof $loon, s = "undefined" != typeof $httpClient && !t, i = "function" == typeof require && "undefined" != typeof $jsbox; return { isQX: e, isLoon: t, isSurge: s, isNode: "function" == typeof require && !i, isJSBox: i, isRequest: "undefined" != typeof $request, isScriptable: "undefined" != typeof importModule } } function HTTP(e = { baseURL: "" }) { const { isQX: t, isLoon: s, isSurge: i, isScriptable: n, isNode: o } = ENV(), r = /https?:\/\/(www\.)?[-a-zA-Z0-9@:%._\+~#=]{1,256}\.[a-zA-Z0-9()]{1,6}\b([-a-zA-Z0-9()@:%_\+.~#?&\/\/=]*)/; const u = {}; return ["GET", "POST", "PUT", "DELETE", "HEAD", "OPTIONS", "PATCH"].forEach(l => u[l.toLowerCase()] = (u => (function (u, l) { l = "string" == typeof l ? { url: l } : l; const h = e.baseURL; h && !r.test(l.url || "") && (l.url = h ? h + l.url : l.url); const a = (l = { ...e, ...l }).timeout, c = { onRequest: () => { }, onResponse: e => e, onTimeout: () => { }, ...l.events }; let f, d; if (c.onRequest(u, l), t) f = $task.fetch({ method: u, ...l }); else if (s || i || o) f = new Promise((e, t) => { (o ? require("request") : $httpClient)[u.toLowerCase()](l, (s, i, n) => { s ? t(s) : e({ statusCode: i.status || i.statusCode, headers: i.headers, body: n }) }) }); else if (n) { const e = new Request(l.url); e.method = u, e.headers = l.headers, e.body = l.body, f = new Promise((t, s) => { e.loadString().then(s => { t({ statusCode: e.response.statusCode, headers: e.response.headers, body: s }) }).catch(e => s(e)) }) } const p = a ? new Promise((e, t) => { d = setTimeout(() => (c.onTimeout(), t(`${u} URL: ${l.url} exceeds the timeout ${a} ms`)), a) }) : null; return (p ? Promise.race([p, f]).then(e => (clearTimeout(d), e)) : f).then(e => c.onResponse(e)) })(l, u))), u } function API(e = "untitled", t = !1) { const { isQX: s, isLoon: i, isSurge: n, isNode: o, isJSBox: r, isScriptable: u } = ENV(); return new class { constructor(e, t) { this.name = e, this.debug = t, this.http = HTTP(), this.env = ENV(), this.node = (() => { if (o) { return { fs: require("fs") } } return null })(), this.initCache(); Promise.prototype.delay = function (e) { return this.then(function (t) { return ((e, t) => new Promise(function (s) { setTimeout(s.bind(null, t), e) }))(e, t) }) } } initCache() { if (s && (this.cache = JSON.parse($prefs.valueForKey(this.name) || "{}")), (i || n) && (this.cache = JSON.parse($persistentStore.read(this.name) || "{}")), o) { let e = "root.json"; this.node.fs.existsSync(e) || this.node.fs.writeFileSync(e, JSON.stringify({}), { flag: "wx" }, e => console.log(e)), this.root = {}, e = `${this.name}.json`, this.node.fs.existsSync(e) ? this.cache = JSON.parse(this.node.fs.readFileSync(`${this.name}.json`)) : (this.node.fs.writeFileSync(e, JSON.stringify({}), { flag: "wx" }, e => console.log(e)), this.cache = {}) } } persistCache() { const e = JSON.stringify(this.cache, null, 2); s && $prefs.setValueForKey(e, this.name), (i || n) && $persistentStore.write(e, this.name), o && (this.node.fs.writeFileSync(`${this.name}.json`, e, { flag: "w" }, e => console.log(e)), this.node.fs.writeFileSync("root.json", JSON.stringify(this.root, null, 2), { flag: "w" }, e => console.log(e))) } write(e, t) { if (this.log(`SET ${t}`), -1 !== t.indexOf("#")) { if (t = t.substr(1), n || i) return $persistentStore.write(e, t); if (s) return $prefs.setValueForKey(e, t); o && (this.root[t] = e) } else this.cache[t] = e; this.persistCache() } read(e) { return this.log(`READ ${e}`), -1 === e.indexOf("#") ? this.cache[e] : (e = e.substr(1), n || i ? $persistentStore.read(e) : s ? $prefs.valueForKey(e) : o ? this.root[e] : void 0) } delete(e) { if (this.log(`DELETE ${e}`), -1 !== e.indexOf("#")) { if (e = e.substr(1), n || i) return $persistentStore.write(null, e); if (s) return $prefs.removeValueForKey(e); o && delete this.root[e] } else delete this.cache[e]; this.persistCache() } notify(e, t = "", l = "", h = {}) { const a = h["open-url"], c = h["media-url"]; if (s && $notify(e, t, l, h), n && $notification.post(e, t, l + `${c ? "\n多媒体:" + c : ""}`, { url: a }), i) { let s = {}; a && (s.openUrl = a), c && (s.mediaUrl = c), "{}" === JSON.stringify(s) ? $notification.post(e, t, l) : $notification.post(e, t, l, s) } if (o || u) { const s = l + (a ? `\n点击跳转: ${a}` : "") + (c ? `\n多媒体: ${c}` : ""); if (r) { require("push").schedule({ title: e, body: (t ? t + "\n" : "") + s }) } else console.log(`${e}\n${t}\n${s}\n\n`) } } log(e) { this.debug && console.log(`[${this.name}] LOG: ${this.stringify(e)}`) } info(e) { console.log(`[${this.name}] INFO: ${this.stringify(e)}`) } error(e) { console.log(`[${this.name}] ERROR: ${this.stringify(e)}`) } wait(e) { return new Promise(t => setTimeout(t, e)) } done(e = {}) { console.log('done!'); s || i || n ? $done(e) : o && !r && "undefined" != typeof $context && ($context.headers = e.headers, $context.statusCode = e.statusCode, $context.body = e.body) } stringify(e) { if ("string" == typeof e || e instanceof String) return e; try { return JSON.stringify(e, null, 2) } catch (e) { return "[object Object]" } } }(e, t) }
  /*****************************************************************************/
  