/*
什么值得买抽奖
项目地址: https://github.com/hex-ci/smzdm_script

cron: 10 8 * * *
*/

const $ = new Env('什么值得买抽奖');
const notify = $.isNode() ? require('./sendNotify') : '';

let cookiesArr = [];

// 判断环境变量里面是否有 cookie
if (process.env.SMZDM_COOKIE) {
  if (process.env.SMZDM_COOKIE.indexOf('&') > -1) {
    cookiesArr = process.env.SMZDM_COOKIE.split('&');
  } else if (process.env.SMZDM_COOKIE.indexOf('\n') > -1) {
    cookiesArr = process.env.SMZDM_COOKIE.split('\n');
  } else {
    cookiesArr = [process.env.SMZDM_COOKIE];
  }
}

!(async () => {
  if (!cookiesArr[0]) {
    $.msg($.name, '请先设置 SMZDM_COOKIE 环境变量');
    return;
  }

  let notifyContent = '';

  for (let i = 0; i < cookiesArr.length; i++) {
    if (cookiesArr[i]) {
      if (i > 0) {
        $.log('\n延时 5 秒执行\n');
        await $.wait(5000)
      }

      const cookie = cookiesArr[i];
      const sep = `\n******开始账号${i + 1}******\n`;

      const msg = await lottery(cookie);

      notifyContent += sep + msg + "\n";

      $.log(sep + msg + "\n");
    }
  }

  await notify.sendNotify($.name, notifyContent);
})()
  .catch((e) => {
    $.log('', `❌ ${$.name}, 失败! 原因: ${e}!`, '')
  })
  .finally(() => {
    $.done();
  });


// 每日抽奖
async function lottery(cookie) {
  let activeId = '';

  try {
    const resp = await $.http.get({
      url: "https://m.smzdm.com/zhuanti/life/choujiang/",
      headers: {
        Accept: "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8",
        "Accept-Encoding": "gzip, deflate, br",
        "Accept-Language": "zh-cn",
        Connection: "keep-alive",
        Host: "m.smzdm.com",
        "User-Agent": "Mozilla/5.0 (iPhone; CPU iPhone OS 14_5 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148/smzdm 9.9.6 rv:93.4 (iPhone13,4; iOS 14.5; zh_CN)/iphone_smzdmapp/9.9.6/wkwebview/jsbv_1.0.0",
        Cookie: cookie
      }
    });

    let _activeId = /name\s?=\s?\"lottery_activity_id\"\s+value\s?=\s?\"([a-zA-Z0-9]*)\"/.exec(resp.body);
    if (_activeId) {
      activeId = _activeId[1];
    } else {
      $.log(`获取每日抽奖activeId失败`);
    }

    if (!!activeId) {
      const resp = await $.http.get({
        url: `https://zhiyou.smzdm.com/user/lottery/jsonp_draw?callback=jQuery34109305207178886287_${new Date().getTime()}&active_id=${activeId}&_=${new Date().getTime()}`,
        headers: {
          Accept: "*/*",
          "Accept-Encoding": "gzip, deflate, br",
          "Accept-Language": "zh-cn",
          Connection: "keep-alive",
          Host: "zhiyou.smzdm.com",
          Referer: "https://m.smzdm.com/zhuanti/life/choujiang/",
          "User-Agent": "Mozilla/5.0 (iPhone; CPU iPhone OS 14_2 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148/smzdm 9.9.0 rv:91 (iPhone 11 Pro Max; iOS 14.2; zh_CN)/iphone_smzdmapp/9.9.0/wkwebview/jsbv_1.0.0",
          Cookie: cookie
        }
      });

      let data = /\((.*)\)/.exec(resp.body);
      let obj = JSON.parse(data[1]);
      if (
        obj["error_code"] === 0 ||
        obj["error_code"] === 1 ||
        obj["error_code"] === 4
      ) {
        return obj["error_msg"];
      } else {
        $.log(`每日抽奖失败，接口响应异常：${data}`);
        return "每日抽奖失败，接口响应异常";
      }
    }
  } catch (error) {
    $.log(`每日抽奖失败，${error}`);
    return "每日抽奖失败，接口响应异常";
  }
}


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("", `🔔${this.name}, 开始!`)
      }
      isNode() {
        return "undefined" != typeof module && !!module.exports
      }
      isQuanX() {
        return "undefined" != typeof $task
      }
      isSurge() {
        return "undefined" != typeof $httpClient && "undefined" == typeof $loon
      }
      isLoon() {
        return "undefined" != typeof $loon
      }
      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("@"),
            n = {
              url: `http://${h}/v1/scripting/evaluate`,
              body: {
                script_text: t,
                mock_type: "cron",
                timeout: r
              },
              headers: {
                "X-Key": o,
                Accept: "*/*"
              }
            };
          this.post(n, (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();
                s && 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, e = null) {
        const s = e ? new Date(e) : new Date;
        let i = {
          "M+": s.getMonth() + 1,
          "d+": s.getDate(),
          "H+": s.getHours(),
          "m+": s.getMinutes(),
          "s+": s.getSeconds(),
          "q+": Math.floor((s.getMonth() + 3) / 3),
          S: s.getMilliseconds()
        };
        /(y+)/.test(t) && (t = t.replace(RegExp.$1, (s.getFullYear() + "").substr(4 - RegExp.$1.length)));
        for (let e in i)
          new RegExp("(" + e + ")").test(t) && (t = t.replace(RegExp.$1, 1 == RegExp.$1.length ? i[e] : ("00" + i[e]).substr(("" + i[e]).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
              }
            }
          }
        };
        if (this.isMute || (this.isSurge() || this.isLoon() ? $notification.post(e, s, i, o(r)) : this.isQuanX() && $notify(e, s, i, o(r))), !this.isMuteLog) {
          let t = ["", "==============📣系统通知📣=============="];
          t.push(e),
            s && t.push(s),
            i && t.push(i),
            console.log(t.join("\n")),
            this.logs = this.logs.concat(t)
        }
      }
      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("", `❗️${this.name}, 错误!`, t.stack) : this.log("", `❗️${this.name}, 错误!`, t)
      }
      wait(t) {
        return new Promise(e => setTimeout(e, t))
      }
      done(t = {}) {
        const e = (new Date).getTime(),
          s = (e - this.startTime) / 1e3;
        this.log("", `🔔${this.name}, 结束! 🕛 ${s} 秒`),
          this.log(),
          (this.isSurge() || this.isQuanX() || this.isLoon()) && $done(t)
      }
    }
    (t, e)
}