update

smzdm_checkin.py

@@ -84,11 +84,11 @@ class SmzdmBot(object):
             cards = resp_data["cards"]
 
             msg = f"""⭐签到成功{checkin_num}天
-🏅金币:{gold}
-🏅积分:{point}
-🏅经验:{exp}
-🏅等级:{rank}
-🏅补签卡:{cards}\n"""
+🏅金币: {gold}
+🏅积分: {point}
+🏅经验: {exp}
+🏅等级: {rank}
+🏅补签卡: {cards}\n"""
 
             print(msg)
             return sep + "\n" + msg
@@ -146,6 +146,7 @@ def conf_kwargs():
         for cookie in cookies:
             try:
                 token = re.findall(r"sess=(.*?);", cookie)[0]
+                cookie = cookie.replace("iphone", "android").replace("iPhone", "Android").replace("apk_partner_name=appstore", "apk_partner_name=android")
                 conf_kwargs.append({
                     "SK": "1",
                     "COOKIE": cookie,

smzdm_lottery.js

@@ -0,0 +1,508 @@
+/*
+什么值得买抽奖
+项目地址: 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]) {
+			const cookie = cookiesArr[i];
+
+			console.log(`\n******开始账号${i + 1}*********\n`);
+
+      const msg = await lottery(cookie);
+
+      notifyContent += msg;
+
+      $.msg(msg);
+
+      await $.wait(5000)
+		}
+	}
+
+  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}`);
+  }
+}
+
+
+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)
+}