jd_dreamFactory.js

/*
京东京喜工厂
未完，待续
 */
const $hammer = (() => {
  const isRequest = "undefined" != typeof $request,
      isSurge = "undefined" != typeof $httpClient,
      isQuanX = "undefined" != typeof $task;

  const log = (...n) => { for (let i in n) console.log(n[i]) };
  const alert = (title, body = "", subtitle = "", link = "", option) => {
    if (isSurge) return $notification.post(title, subtitle, body, link);
    if (isQuanX) return $notify(title, subtitle, (link && !body ? link : body), option);
    log("==============📣系统通知📣==============");
    log("title:", title, "subtitle:", subtitle, "body:", body, "link:", link);
  };
  const read = key => {
        if (isSurge) return $persistentStore.read(key);
        if (isQuanX) return $prefs.valueForKey(key);
      },
      write = (key, val) => {
        if (isSurge) return $persistentStore.write(key, val);
        if (isQuanX) return $prefs.setValueForKey(key, val);
      };
  const request = (method, params, callback) => {
    /**
     *
     * params(<object>): {url: <string>, headers: <object>, body: <string>} | <url string>
     *
     * callback(
     *      error,
     *      {status: <int>, headers: <object>, body: <string>} | ""
     * )
     *
     */
    let options = {};
    if (typeof params == "string") {
      options.url = params;
    } else {
      options.url = params.url;
      if (typeof params == "object") {
        params.headers && (options.headers = params.headers);
        params.body && (options.body = params.body);
      }
    }
    method = method.toUpperCase();

    const writeRequestErrorLog = function (m, u) {
      return err => {
        log("=== request error -s--");
        log(`${m} ${u}`, err);
        log("=== request error -e--");
      };
    }(method, options.url);

    if (isSurge) {
      const _runner = method == "GET" ? $httpClient.get : $httpClient.post;
      return _runner(options, (error, response, body) => {
        if (error == null || error == "") {
          response.body = body;
          callback("", response);
        } else {
          writeRequestErrorLog(error);
          callback(error, "");
        }
      });
    }
    if (isQuanX) {
      options.method = method;
      $task.fetch(options).then(
          response => {
            response.status = response.statusCode;
            delete response.statusCode;
            callback("", response);
          },
          reason => {
            writeRequestErrorLog(reason.error);
            callback(reason.error, "");
          }
      );
    }
  };
  const done = (value = {}) => {
    if (isQuanX) return isRequest ? $done(value) : null;
    if (isSurge) return isRequest ? $done(value) : $done();
  };
  return { isRequest, isSurge, isQuanX, log, alert, read, write, request, done };
})();


//京东接口地址
const JD_API_HOST = 'https://wq.jd.com';

//直接用NobyDa的jd cookie
// const cookie = $hammer.read('CookieJD');
const cookie = 'unpl=V2_ZzNtbUAHRRx0DxZVch9aBWIBRllLAhMSfQtDUnxLWVdnBhpcclRCFnQUR1JnGFUUZAMZXURcQhJFOEZVehhdDWMEGllyZ0sdGwgLVBUaMgUqTl9tQVdzFEUIQlx%252bGlwAZAAXW0tRRhZ9DU5TfRpsNWcFIl1DVkIUcgBBVnkaVDU8VnxbEgJDESFYRFNyHllQVwIiXHJWc0MbCEdVehteBmYAEhBCU0sQdghDV3gcWgxhBhFVR19EE3Y4R2R4; PPRD_P=CT.138912.3.26-UUID.1594174344038855825195; __jda=122270672.1594174344038855825195.1594174344.1594619829.1594628524.29; __jdb=122270672.4.1594174344038855825195|29.1594628524; __jdc=122270672; __jdv=122270672%7Ckong%7Ct_1000170136%7Ctuiguang%7Cnotset%7C1594569450665; __wga=1594631325352.1594630264664.1594619828892.1594619828892.3.2; _tj_rvurl=https%3A//wq.jd.com/cube/front/activePublish/dream_factory_report/380556.html%3Fptag%3D138912.3.26%26lng%3D113.321134%26lat%3D23.139617%26sid%3D6c732f3e20be25526c2e67df89e488dw%26un_area%3D19_1601_50258_51885; cid=8; mba_muid=1594174344038855825195.33.1594631325409; mba_sid=33.18; retina=1; shshshfp=3f7499d014a4f06d56edfb5378a934ee; shshshfpb=w5O9mqDoHWvVwOS9jAYB%20zg%3D%3D; shshshsID=ed6e17a13e5b4921d09de669e2b06c89_3_1594631325584; wqmnx1=MDEyNjM1M3B3am1ncmZyZHR0My4mMTImMjlzYzNlNjdld2ExMDIxNjg1NnBoOTsuNWE0ZWVjYmRla2lEQS0tLS1ENXV0ZTNVL3NpTzFlaDFkczAzaFA7dTEzcGV5ZG9yZXYxcE1HYWVKZXJDbzs0Ly9hOTBjZmEyMTswZzAwdGFvfDUwMTY7O2RlO0o1Mi5JMztsLlA7IG4gX2tjWHBiNi5LLGVrby80cEpLMWY3bjI0MllPT1UhSCU%3D; wxa_level=1; pt_key=app_openAAJfBSQbAEBjl86WMnH-4g3Is6PISRQsx5CU-pQolK0klfaTVHmW5nfZL7DkOGhtRWp6ttQKfdDSiHZ1el6DX2SEjWkotlT2; pt_pin=%E8%A2%AB%E6%8A%98%E5%8F%A0%E7%9A%84%E8%AE%B0%E5%BF%8633; pwdt_id=%E8%A2%AB%E6%8A%98%E5%8F%A0%E7%9A%84%E8%AE%B0%E5%BF%8633; sid=6c732f3e20be25526c2e67df89e488dw; wq_area=19_1601_3633%7C3; visitkey=270851475495567; jxsid=15946198288819114076; sc_width=414; webp=0; shshshfpa=b134218e-f14e-6005-fa8e-52d2bc02126f-1594364440';
let shareCodes = [
    'V5LkjP4WRyjeCKR9VRwcRX0bBuTz7MEK0-E99EJ7u0k=',
];
let factoryId, productionId, userTaskStatusList, dailyTask = [], produceTask = [];
const name = '京喜工厂';
let message = '';
let subTitle = '';
const Task = step()
Task.next();
function* step() {
  const startTime = Date.now();
  yield userInfo();
  yield collectElectricity();
  yield investElectric();
  yield taskList();
  //yield produceTaskFun();//生产任务
  const end = ((Date.now() - startTime) / 1000).toFixed(2);
  console.log(`\n完成${name}脚本耗时:  ${end} 秒\n`);
  $hammer.alert(name, message, subTitle);
}

function produceTaskFun() {
  for (let item of produceTask) {
    if (item.awardStatus !== 1) {
      if (item.completedTimes >= item.targetTimes) {
        const url = `/newtasksys/newtasksys_front/Award?source=dreamfactory&bizCode=dream_factory&taskId=${item.taskId}&sceneval=2&g_login_type=1`;
        request(url).then((res) => {
          console.log(`每日任务完成结果${JSON.stringify(res)}}`);
          try {
            if (res.ret === 0) {
              console.log(`${item.taskName}任务完成`)
            }
          } catch (e) {
            console.log(`${item.taskName}任务异常`)
          }
        })
      }
    }
  }
  Task.next();
}

// 收取发电机的电力
function collectElectricity() {
 const url = `/dreamfactory/generator/CollectCurrentElectricity?zone=dream_factory&apptoken=&pgtimestamp=&phoneID=&factoryid=${factoryId}&doubleflag=1&sceneval=2`;
 request(url).then((res) => {
   try {
     if (res.ret === 0) {
       console.log(`成功从发电机收取${res.data.CollectElectricity}电力`);
     }
     Task.next();
   } catch (e) {
     console.log('收集电力异常')
   }
 })
}
// 投入电力
function investElectric() {
  const url = `/dreamfactory/userinfo/InvestElectric?zone=dream_factory&productionId=${productionId}&sceneval=2&g_login_type=1`;
  request(url).then((res) => {
    try {
      if (res.ret === 0) {
        console.log(`成功投入电力${res.data.investElectric}电力`);
        message += `【投入电力】${res.data.investElectric}`;
      } else {
        console.log(`投入失败，${res.message}`);
      }
      Task.next();
    } catch (e) {
      console.log('收集电力异常')
    }
  })
}
// 初始化任务
function taskList() {
  const url = `/newtasksys/newtasksys_front/GetUserTaskStatusList?source=dreamfactory&bizCode=dream_factory&sceneval=2&g_login_type=1`;
  request(url).then((res) => {
    try {
      //console.log(`${JSON.stringify(res)}`)
      //console.log(res)
      if (res.ret === 0) {
        userTaskStatusList = res.data.userTaskStatusList;
        for (let item of res.data.userTaskStatusList) {
          if (item.dateType === 2) {
            dailyTask.push(item);
          }
          if (item.dateType === 1) {
            produceTask.push(item);
          }
        }
        Task.next();
      }
    } catch (e) {
      console.log('初始化任务异常')
    }
  }).catch((error) => {
    console.log(error)
  })
}
//初始化个人信息
function userInfo() {
  const url = `/dreamfactory/userinfo/GetUserInfo?zone=dream_factory&pin=&sharePin=&shareType=&materialTuanPin=&materialTuanId=&sceneval=2`;
  request(url).then((response) => {
    try {
      // taskInfo = res.data.result.taskInfos;
      if (response.ret === 0) {
        const { data } = response;
        // !data.productionList && !data.factoryList
        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;
          console.log(`\n我的分享码\n${data.user.encryptPin}\n`);
          // console.log(`进度：${(production.investedElectric/production.needElectric).toFixed(2) * 100}%\n`);
          message += `【生产进度】${((production.investedElectric / production.needElectric) * 100).toFixed(2)}%\n`;
          Task.next();
        } else {
          return $hammer.alert(name, '\n【提示】此账号京喜工厂活动未开始\n请手动去京东APP->游戏与互动->查看更多->京喜工厂 开启活动\n');
        }
      } else {
        Task.return();
      }
    } catch (e) {
      console.log(e);
      console.log('初始化任务异常');
    }
  })
}

//等待一下
function sleep(s) {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      resolve();
    }, s * 1000);
  })
}

async function request(url, body = {}) {
  await sleep(2); //歇口气儿, 不然会报操作频繁
  return new Promise((resolve, reject) => {
    $hammer.request('GET', taskurl(url, body), (error, response) => {
      if(error){
        $hammer.log("Error:", error);
      }else{
        //console.log(response.body)
        resolve(JSON.parse(response.body));
      }
    })
  })
}

function taskurl(url, body) {
  return {
    url: `${JD_API_HOST}${url}`,
    headers: {
      'Cookie' : cookie,
      'Host': 'wq.jd.com',
      'Accept': '*/*',
      'Connection': 'keep-alive',
      'User-Agent': 'jdapp;iPhone;9.0.4;13.5.1;;Mozilla/5.0 (iPhone; CPU iPhone OS 13_5_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1',
      'Accept-Language': 'zh-cn',
      'Referer': 'https://wqsd.jd.com/pingou/dream_factory/index.html',
      'Accept-Encoding': 'gzip, deflate, br',
    }
  }
}