forked from LinYuanovo/scripts
-
Notifications
You must be signed in to change notification settings - Fork 0
/
fmp.js
356 lines (316 loc) · 20.5 KB
/
fmp.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
/**
* @ 临渊
* 软件：飞猫盘及橘猫众包
* 功能：飞猫盘及橘猫众包每日签到获取福利点，可加速下载使用
* 抓取域名：
* mapi.fmapp.com
* mapi.tgy123.com
* 里面的token即可
* 变量格式：export fmtoken=' xxxx@xxxx ' 多个账号用 @分割
*/
const jsname = "飞猫盘+橘猫众包每日签到";
const $ = Env(jsname);
const notify = $.isNode() ? require('./sendNotify') : '';
const Notify = 1; //0为关闭通知，1为打开通知,默认为1
const debug = 0; //0为关闭调试，1为打开调试,默认为0
//////////////////////
let fmtoken = process.env.fmtoken;
let fmtokenArr = [];
let data = '';
let msg = '';
let back = '';
!(async () => {
if (!(await Envs()))
return;
else {
console.log(`===================作者：临渊===================`);
console.log(`\n\n========================================= \n脚本执行 - 北京时间：${new Date(
new Date().getTime() + new Date().getTimezoneOffset() * 60 * 1000 +
8 * 60 * 60 * 1000).toLocaleString()} \n=========================================\n`);
console.log(`\n=================== 共找到 ${fmtokenArr.length} 个账号 ===================`)
if (debug) {
console.log(`【debug】 这是你的全部账号数组:\n ${fmtokenArr}`);
}
for (let index = 0; index < fmtokenArr.length; index++) {
fmtoken = fmtokenArr[index]
let num = index + 1
console.log(`\n========= 开始【第 ${num} 个账号】=========\n`)
if (debug) {
console.log(`\n 【debug】 这是你第 ${num} 账号信息:\n ${data}\n`);
}
msg+=`第${num}个账号签到结果：\n`
console.log('开始飞猫盘APP签到');
await signin1();
await $.wait(2 * 1000);
while (back == "undefined"){
await signin1();
await $.wait(2 * 1000);
}
console.log('开始飞猫盘连签10天奖励');
await getBonus10();
await $.wait(2 * 1000);
while (back == "undefined"){
await getBonus10();
await $.wait(2 * 1000);
}
console.log('开始飞猫盘连签30天奖励');
await getBonus30();
await $.wait(2 * 1000);
while (back == "undefined"){
await getBonus30();
await $.wait(2 * 1000);
}
console.log('开始橘猫众包APP签到');
await signin2();
await $.wait(2 * 1000);
while (back == "undefined"){
await signin2();
await $.wait(2 * 1000);
}
}
await SendMsg(msg);
}
})()
.catch((e) => console.logErr(e))
.finally(() => $.done())
/**
*飞猫盘签到
*/
function signin1(timeout = 3 * 1000) {
return new Promise((resolve) => {
let url = {
url: `https://mapi.fmapp.com/tgy/tosign`,
headers: {
"Host": "mapi.fmapp.com",
"fmver": "55",
"token": `${fmtoken}`,
"plat": "feemoo",
"os": "android",
"content-length": "0",
"accept-encoding": "gzip",
"user-agent": "okhttp/3.14.9"
},
body: '' //虽然是post请求，但是body为空
}
if (debug) {
console.log(`\n【debug】=============== 这是 签到 请求 url ===============`);
console.log(JSON.stringify(url));
}
$.post(url, async (error, response, data) => {
try {
if (debug) {
console.log(`\n\n【debug】===============这是 签到 返回data==============`);
console.log(data)
}
back = eval("(" + data + ")");
let result = eval("(" + data + ")");
if (result.status == 1) {
console.log(`【签到成功】🎉`)
msg += `\n【飞猫签到成功】🎉\n您的福利点点数为：${result.data.point}`
msg += `\n您的连续签到天数为：${result.data.sigcount}`
} else {
console.log(`\n【签到失败】，原因是:${result.msg}!\n `)
msg += `【飞猫签到失败】，原因是:${result.msg}!\n`
}
} catch (e) {
console.log(e)
} finally {
resolve();
}
}, timeout)
})
}
/**
*飞猫盘领取额外10天签到奖励
*/
function getBonus10(timeout = 3 * 1000) {
return new Promise((resolve) => {
let url = {
url: `https://mapi.fmapp.com/tgy/getpoint`,
headers: {
"Host": "mapi.fmapp.com",
"fmver": "57",
"token": `${fmtoken}`,
"plat": "xiaomi",
"os": "android",
"content-type": "application/x-www-form-urlencoded",
"content-length": "5",
"accept-encoding": "gzip",
"user-agent": "okhttp/3.14.9"
},
body: 'tid=7'
}
if (debug) {
console.log(`\n【debug】=============== 这是 领取连签10天奖励 请求 url ===============`);
console.log(JSON.stringify(url));
}
$.post(url, async (error, response, data) => {
try {
if (debug) {
console.log(`\n\n【debug】===============这是 领取连签10天奖励 返回data==============`);
console.log(data)
}
back = eval("(" + data + ")");
let result = eval("(" + data + ")");
if (result.status == 1) {
console.log(`领取连签10天奖励成功`)
msg += `\n领取连签10天奖励成功`
} else if(result.status == 0){
console.log(`\n领取连签10天奖励失败，原因是:已领取!\n `)
} else{
console.log(`领取失败`)
}
} catch (e) {
console.log(e)
} finally {
resolve();
}
}, timeout)
})
}
/**
*飞猫盘领取额外30天签到奖励
*/
function getBonus30(timeout = 3 * 1000) {
return new Promise((resolve) => {
let url = {
url: `https://mapi.fmapp.com/tgy/getpoint`,
headers: {
"Host": "mapi.fmapp.com",
"fmver": "57",
"token": `${fmtoken}`,
"plat": "xiaomi",
"os": "android",
"content-type": "application/x-www-form-urlencoded",
"content-length": "5",
"accept-encoding": "gzip",
"user-agent": "okhttp/3.14.9"
},
body: 'tid=8'
}
if (debug) {
console.log(`\n【debug】=============== 这是 领取连签30天奖励 请求 url ===============`);
console.log(JSON.stringify(url));
}
$.post(url, async (error, response, data) => {
try {
if (debug) {
console.log(`\n\n【debug】===============这是 领取连签30天奖励 返回data==============`);
console.log(data)
}
back = eval("(" + data + ")");
let result = eval("(" + data + ")");
if (result.status == 1) {
console.log(`领取连签30天奖励成功🎉`)
msg += `\n领取连签30天奖励成功`
} else if(result.status == 0){
console.log(`\n领取连签30天奖励失败，原因是:已领取!\n `)
} else{
console.log(`领取失败`)
}
} catch (e) {
console.log(e)
} finally {
resolve();
}
}, timeout)
})
}
/**
*橘猫众包签到
*/
function signin2(timeout = 3 * 1000) {
return new Promise((resolve) => {
let url = {
url: `https://mapi.tgy123.com/index.php/marketing/signIn`,
headers: {
"Host": "mapi.tgy123.com",
"os": "android",
"version": "14",
"token": `${fmtoken}`,
"channel": "jmzb",
"content-type": "application/x-www-form-urlencoded",
"content-length": "5",
"accept-encoding": "gzip",
"user-agent": "okhttp/3.10.0"
},
body: 'flag='
}
if (debug) {
console.log(`\n【debug】=============== 这是 签到 请求 url ===============`);
console.log(JSON.stringify(url));
}
$.post(url, async (error, response, data) => {
try {
if (debug) {
console.log(`\n\n【debug】===============这是 签到 返回data==============`);
console.log(data)
}
back = eval("(" + data + ")");
let result = eval("(" + data + ")");
if (result.status == 1) {
console.log(`【签到成功】🎉`)
msg += `\n【橘猫签到成功】🎉\n您的福利点点数为：${result.data.point}`
msg += `\n您的连续签到天数为：${result.data.sigcount}\n`
} else {
console.log(`\n【签到失败】，原因是:${result.msg}!\n `)
msg += `【橘猫签到失败】，原因是:${result.msg}!\n`
}
} catch (e) {
console.log(e)
} finally {
resolve();
}
}, timeout)
})
}
// ============================================变量检查============================================ \\
async function Envs() {
if (fmtoken) {
if (fmtoken.indexOf("@") != -1) {
fmtoken.split("@").forEach((item) => {
fmtokenArr.push(item);
});
} else {
fmtokenArr.push(fmtoken);
}
} else {
console.log(`\n 【${$.name}】：未填写变量 fmtoken`)
return;
}
return true;
}
// ============================================发送消息============================================ \\
async function SendMsg(message) {
if (!message)
return;
if (Notify > 0) {
if ($.isNode()) {
var notify = require('./sendNotify');
await notify.sendNotify($.name, message);
} else {
$.msg(message);
}
} else {
console.log(message);
}
}
/**
* 随机数生成
*/
function randomString(e) {
e = e || 32;
var t = "QWERTYUIOPASDFGHJKLZXCVBNM1234567890",
a = t.length,
n = "";
for (i = 0; i < e; i++)
n += t.charAt(Math.floor(Math.random() * a));
return n
}
/**
* 随机整数生成
*/
function randomInt(min, max) {
return Math.round(Math.random() * (max - min) + min)
}
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) }