-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathjd_superMarket.js
1453 lines (1441 loc) · 60.3 KB
/
jd_superMarket.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
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
/*
* @Author: lxk0301 https://github.com/lxk0301
* @Date: 2020-08-16 18:54:16
* @Last Modified by: lxk0301
* @Last Modified time: 2020-11-24 08:22:37
*/
/*
东东超市(活动入口：京东APP-》首页-》京东超市-》底部东东超市)
Some Functions Modified From https://github.com/Zero-S1/JD_tools/blob/master/JD_superMarket.py
支持京东双账号
京小超兑换奖品请使用此脚本 https://raw.githubusercontent.com/lxk0301/jd_scripts/master/jd_blueCoin.js
脚本兼容: QuantumultX, Surge, Loon, JSBox, Node.js
// QuantumultX
[task_local]
#东东超市
11 1-23/5 * * * https://raw.githubusercontent.com/lxk0301/jd_scripts/master/jd_superMarket.js, tag=东东超市, img-url=https://raw.githubusercontent.com/58xinian/icon/master/jxc.png, enabled=true
// Loon
[Script]
cron "11 1-23/5 * * *" script-path=https://raw.githubusercontent.com/lxk0301/jd_scripts/master/jd_superMarket.js,tag=东东超市
// Surge
东东超市 = type=cron,cronexp="11 1-23/5 * * *",wake-system=1,timeout=320,script-path=https://raw.githubusercontent.com/lxk0301/jd_scripts/master/jd_superMarket.js
*/
const $ = new Env('东东超市');
//Node.js用户请在jdCookie.js处填写京东ck;
//IOS等用户直接用NobyDa的jd cookie
let cookiesArr = [], cookie = '', jdSuperMarketShareArr = [], notify, newShareCodes;
let jdNotify = true;//用来是否关闭弹窗通知，true表示关闭，false表示开启。
let superMarketUpgrade = false;//自动升级,顺序:解锁升级商品、升级货架,true表示自动升级,false表示关闭自动升级
let businessCircleJump = true;//小于对方300热力值自动更换商圈队伍,true表示运行,false表示禁止
let drawLotteryFlag = true;//是否用500蓝币去抽奖，true表示开启，false表示关闭。默认关闭
let message = '', subTitle;
const JD_API_HOST = 'https://api.m.jd.com/api';
//助力好友分享码
//此此内容是IOS用户下载脚本到本地使用，填写互助码的地方，同一京东账号的好友互助码请使用@符号隔开。
//下面给出两个账号的填写示例（iOS只支持2个京东账号）
let shareCodes = [ // IOS本地脚本用户这个列表填入你要助力的好友的shareCode
//账号一的好友shareCode,不同好友的shareCode中间用@符号隔开
'-4msulYas0O2JsRhE-2TA5XZmBQ@eU9Yar_mb_9z92_WmXNG0w@eU9YaejjYv4g8T2EwnsVhQ',
//账号二的好友shareCode,不同好友的shareCode中间用@符号隔开
'aURoM7PtY_Q@eU9Ya-y2N_5z9DvXwyIV0A@eU9YaOnjYK4j-GvWmXIWhA',
]
!(async () => {
await requireConfig();
if (!cookiesArr[0]) {
$.msg($.name, '【提示】请先获取京东账号一cookie\n直接使用NobyDa的京东签到获取', 'https://bean.m.jd.com/', {"open-url": "https://bean.m.jd.com/"});
}
for (let i = 0; i < cookiesArr.length; i++) {
if (cookiesArr[i]) {
cookie = cookiesArr[i];
$.UserName = decodeURIComponent(cookie.match(/pt_pin=(.+?);/) && cookie.match(/pt_pin=(.+?);/)[1])
$.index = i + 1;
$.coincount = 0;//收取了多少个蓝币
$.coinerr = "";
$.blueCionTimes = 0;
$.isLogin = true;
$.nickName = '';
await TotalBean();
console.log(`\n开始【京东账号${$.index}】${$.nickName || $.UserName}\n`);
if (!$.isLogin) {
$.msg($.name, `【提示】cookie已失效`, `京东账号${$.index} ${$.nickName || $.UserName}\n请重新登录获取\nhttps://bean.m.jd.com/`, {"open-url": "https://bean.m.jd.com/"});
if ($.isNode()) {
await notify.sendNotify(`${$.name}cookie已失效 - ${$.UserName}`, `京东账号${$.index} ${$.UserName}\n请重新登录获取cookie`);
} else {
$.setdata('', `CookieJD${i ? i + 1 : "" }`);//cookie失效，故清空cookie。$.setdata('', `CookieJD${i ? i + 1 : "" }`);//cookie失效，故清空cookie。
}
continue
}
message = '';
subTitle = '';
//await shareCodesFormat();//格式化助力码
await jdSuperMarket();
await showMsg();
// await businessCircleActivity();
}
}
})()
.catch((e) => {
$.log('', `❌ ${$.name}, 失败! 原因: ${e}!`, '')
})
.finally(() => {
$.done();
})
async function jdSuperMarket() {
await receiveGoldCoin();//收金币
await businessCircleActivity();//商圈活动
await receiveBlueCoin();//收蓝币（小费）
await receiveLimitProductBlueCoin();//收限时商品的蓝币
await smtgSign();//每日签到
await smtgBeanSign()//
await doDailyTask();//做日常任务，分享，关注店铺，
await help();//商圈助力
//await smtgQueryPkTask();//做商品PK任务
await myProductList();//货架
await drawLottery();
await upgrade();//升级货架和商品
await manageProduct();
await limitTimeProduct();
await smtgHome();
}
function showMsg() {
$.log(`\n${message}\n`);
jdNotify = $.getdata('jdSuperMarketNotify') ? $.getdata('jdSuperMarketNotify') : jdNotify;
if (!jdNotify || jdNotify === 'false') {
$.msg($.name, subTitle ,`【京东账号${$.index}】${$.nickName}\n${message}`);
}
}
//抽奖功能(招财进宝)
async function drawLottery() {
console.log(`\n注意⚠:京小超抽奖已改版,花费500蓝币抽奖一次,现在脚本默认已关闭抽奖功能\n`);
drawLotteryFlag = $.getdata('jdSuperMarketLottery') ? $.getdata('jdSuperMarketLottery') : drawLotteryFlag;
if ($.isNode() && process.env.SUPERMARKET_LOTTERY) {
drawLotteryFlag = process.env.SUPERMARKET_LOTTERY;
}
if (`${drawLotteryFlag}` === 'true') {
const smtg_lotteryIndexRes = await smtg_lotteryIndex();
if (smtg_lotteryIndexRes && smtg_lotteryIndexRes.data.bizCode === 0) {
const { result } = smtg_lotteryIndexRes.data
if (result.blueCoins > result.costCoins && result.remainedDrawTimes > 0) {
const drawLotteryRes = await smtg_drawLottery();
console.log(`\n花费${result.costCoins}蓝币抽奖结果${JSON.stringify(drawLotteryRes)}`);
await drawLottery();
} else {
console.log(`\n抽奖失败:已抽奖或者蓝币不足`);
console.log(`失败详情：\n现有蓝币:${result.blueCoins},抽奖次数:${result.remainedDrawTimes}`)
}
}
} else {
console.log(`设置的为不抽奖`)
}
}
async function help() {
return
console.log(`\n开始助力好友`);
for (let code of newShareCodes) {
if (!code) continue;
const res = await smtgDoAssistPkTask(code);
console.log(`助力好友${JSON.stringify(res)}`);
}
}
async function doDailyTask() {
const smtgQueryShopTaskRes = await smtgQueryShopTask();
if (smtgQueryShopTaskRes.code === 0 && smtgQueryShopTaskRes.data.success) {
const taskList = smtgQueryShopTaskRes.data.result.taskList;
console.log(`\n日常赚钱任务 完成状态`)
for (let item of taskList) {
console.log(` ${item['title'].length < 4 ? item['title']+`\xa0` : item['title'].slice(-4)} ${item['finishNum'] === item['targetNum'] ? '已完成':'未完成'} ${item['finishNum']}/${item['targetNum']}`)
}
for (let item of taskList) {
//领奖
if (item.taskStatus === 1 && item.prizeStatus === 1) {
const res = await smtgObtainShopTaskPrize(item.taskId);
console.log(`\n领取做完任务的奖励${JSON.stringify(res)}\n`)
}
if ((item.type === 1 || item.type === 11) && item.taskStatus === 0) {
// 分享任务
const res = await smtgDoShopTask(item.taskId);
console.log(`${item.subTitle}结果${JSON.stringify(res)}`)
}
if (item.type === 2) {
//逛会场
if (item.taskStatus === 0) {
console.log('开始逛会场')
const itemId = item.content[item.type].itemId;
const res = await smtgDoShopTask(item.taskId, itemId);
console.log(`${item.subTitle}结果${JSON.stringify(res)}`);
}
}
if (item.type === 8) {
//关注店铺
if (item.taskStatus === 0) {
console.log('开始关注店铺')
const itemId = item.content[item.type].itemId;
const res = await smtgDoShopTask(item.taskId, itemId);
console.log(`${item.subTitle}结果${JSON.stringify(res)}`);
}
}
if (item.type === 10) {
//关注店铺
if (item.taskStatus === 0) {
console.log('开始关注店铺')
const itemId = item.content[item.type].itemId;
const res = await smtgDoShopTask(item.taskId, itemId);
console.log(`${item.subTitle}结果${JSON.stringify(res)}`);
}
}
if ((item.type === 8 || item.type === 2 || item.type === 10) && item.taskStatus === 0) {
await doDailyTask();
}
}
}
}
async function receiveGoldCoin() {
$.goldCoinData = await smtgReceiveCoin(0);
if ($.goldCoinData.data.bizCode === 0) {
console.log(`领取金币成功${$.goldCoinData.data.result.receivedGold}`)
message += `【领取金币】${$.goldCoinData.data.result.receivedGold}个\n`;
} else {
console.log(`${$.goldCoinData.data.bizMsg}`);
}
}
//领限时商品的蓝币
async function receiveLimitProductBlueCoin() {
const res = await smtgReceiveCoin(1);
console.log(`\n限时商品领蓝币结果：[${res.data.bizMsg}]\n`);
if (res.data.bizCode === 0) {
message += `【限时商品】获得${res.data.result.receivedBlue}个蓝币\n`;
}
}
//领蓝币
function receiveBlueCoin(timeout = 0) {
return new Promise((resolve) => {
setTimeout( ()=>{
$.get(taskUrl('smtg_receiveCoin', { type: 2 }), async (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
$.data = data;
if ($.data.data.bizCode !== 0 && $.data.data.bizCode !== 809) {
$.coinerr = `${$.data.data.bizMsg}`;
message += `【收取小费】${$.data.data.bizMsg}\n`;
console.log(`收取蓝币失败：${$.data.data.bizMsg}`)
return
}
if ($.data.data.bizCode === 0) {
$.coincount += $.data.data.result.receivedBlue;
$.blueCionTimes ++;
console.log(`【京东账号${$.index}】${$.nickName} 第${$.blueCionTimes}次领蓝币成功，获得${$.data.data.result.receivedBlue}个\n`)
if (!$.data.data.result.isNextReceived) {
message += `【收取小费】${$.coincount}个\n`;
return
}
}
await receiveBlueCoin(3000);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve()
}
})
},timeout)
})
}
//每日签到
function smtgSign() {
return new Promise((resolve) => {
$.get(taskUrl('smtg_sign'), async (err, resp, data) => {
try {
// console.log('ddd----ddd', data)
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
// console.log('ddd----ddd', data)
const signList = await smtgSignList();
if (signList.data.bizCode === 0) {
$.todayDay = signList.data.result.todayDay;
}
if (data.code === 0 && data.data.success) {
message += `【第${$.todayDay}日签到】成功，奖励${data.data.result.rewardBlue}蓝币\n`
} else {
message += `【第${$.todayDay}日签到】${data.data.bizMsg}\n`
}
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtgBeanSign() {
return new Promise((resolve) => {
$.get(taskUrl('smtg_sign',{"channel": "1"}), async (err, resp, data) => {
try {
// console.log('ddd----ddd', data)
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
//data = JSON.parse(data);
console.log(data)
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
// 商圈活动
async function businessCircleActivity() {
// console.log(`\n商圈PK奖励,次日商圈大战开始的时候自动领领取\n`)
const smtg_getTeamPkDetailInfoRes = await smtg_getTeamPkDetailInfo();
if (smtg_getTeamPkDetailInfoRes && smtg_getTeamPkDetailInfoRes.data.bizCode === 0) {
const { joinStatus, pkStatus, inviteCount, inviteCode, currentUserPkInfo, pkUserPkInfo, prizeInfo, pkActivityId, teamId } = smtg_getTeamPkDetailInfoRes.data.result;
console.log(`\njoinStatus:${joinStatus}`);
console.log(`pkStatus:${pkStatus}\n`);
console.log(teamId)
console.log(inviteCode)
console.log(pkActivityId)
// console.log(smtg_getTeamPkDetailInfoRes.data.result)
// return
if (joinStatus === 0) {
console.log(`\n注：PK会在每天的七点自动随机加入lxk0301创建的队伍\n`)
await updatePkActivityId();
if (!$.updatePkActivityIdRes) await updatePkActivityIdCDN('http://elemhb.cn:9991/jd_updateTeam.json');
if (!$.updatePkActivityIdRes) await updatePkActivityIdCDN('http://elemhb.cn:9991/jd_updateTeam.json');
console.log(`\nupdatePkActivityId[pkActivityId]:::${$.updatePkActivityIdRes.pkActivityId}`);
console.log(`\n京东服务器返回的[pkActivityId] ${pkActivityId}`);
if ($.updatePkActivityIdRes && ($.updatePkActivityIdRes.pkActivityId === pkActivityId)) {
let Teams = [
{"teamId":"eU9Yar-xYvQv-G6Ew3BG3g_1609172689106","inviteCode":"U9Yar-xYvQv-G6Ew3BG3g"}
];
Teams = $.updatePkActivityIdRes['Teams'] || Teams;
const randomNum = randomNumber(0, Teams.length);
const res = await smtg_joinPkTeam(Teams[randomNum].teamId, Teams[randomNum].inviteCode, pkActivityId);
if (res && res.data.bizCode === 0) {
console.log(`加入战队成功`)
} else if (res && res.data.bizCode === 229) {
console.log(`加入战队失败,该战队已满\n无法加入`)
} else {
console.log(`加入战队其他未知情况:${JSON.stringify(res)}`)
}
} else {
console.log('\nupdatePkActivityId请求返回的pkActivityId与京东服务器返回不一致,暂时不加入战队')
}
} else if (joinStatus === 1) {
if (teamId) {
console.log(`inviteCode: [${inviteCode}]`);
console.log(`PK队伍teamId: [${teamId}]`);
console.log(`PK队伍名称: [${currentUserPkInfo && currentUserPkInfo.teamName}]`);
console.log(`我邀请的人数:${inviteCount}\n`)
console.log(`\n我方战队战队 [${currentUserPkInfo && currentUserPkInfo.teamName}]/【${currentUserPkInfo && currentUserPkInfo.teamCount}】`);
console.log(`对方战队战队 [${pkUserPkInfo && pkUserPkInfo.teamName}]/【${pkUserPkInfo && pkUserPkInfo.teamCount}】\n`);
}
}
if (pkStatus === 1) {
console.log(`商圈PK进行中\n`)
} else if (pkStatus === 2) {
console.log(`商圈PK结束了`)
if (prizeInfo.pkPrizeStatus === 2) {
console.log(`开始领取商圈PK奖励`);
const receivedPkTeamPrize = await smtg_receivedPkTeamPrize();
console.log(`商圈PK奖励领取结果：${JSON.stringify(receivedPkTeamPrize)}`)
if (receivedPkTeamPrize.data.bizCode === 0) {
if (receivedPkTeamPrize.data.result.pkResult === 1) {
const { pkTeamPrizeInfoVO } = receivedPkTeamPrize.data.result;
message += `【商圈PK奖励】${pkTeamPrizeInfoVO.blueCoin}蓝币领取成功\n`;
if ($.isNode()) {
await notify.sendNotify(`${$.name} - 账号${$.index} - ${$.nickName}`, `【京东账号${$.index}】 ${$.nickName}\n【商圈队伍】PK获胜\n【奖励】${pkTeamPrizeInfoVO.blueCoin}蓝币领取成功`)
}
} else if (receivedPkTeamPrize.data.result.pkResult === 2) {
if ($.isNode()) {
await notify.sendNotify(`${$.name} - 账号${$.index} - ${$.nickName}`, `【京东账号${$.index}】 ${$.nickName}\n【商圈队伍】PK失败`)
}
}
}
} else if (prizeInfo.pkPrizeStatus === 1) {
console.log(`商圈PK奖励已经领取\n`)
}
} else if (pkStatus === 3) {
console.log(`商圈PK暂停中\n`)
}
} else {
console.log(`\n${JSON.stringify(smtg_getTeamPkDetailInfoRes)}\n`)
}
return
const businessCirclePKDetailRes = await smtg_businessCirclePKDetail();
if (businessCirclePKDetailRes && businessCirclePKDetailRes.data.bizCode === 0) {
const { businessCircleVO, otherBusinessCircleVO, inviteCode, pkSettleTime } = businessCirclePKDetailRes.data.result;
console.log(`\n【您的商圈inviteCode互助码】：\n${inviteCode}\n\n`);
const businessCircleIndexRes = await smtg_businessCircleIndex();
const { result } = businessCircleIndexRes.data;
const { pkPrizeStatus, pkStatus } = result;
if (pkPrizeStatus === 2) {
console.log(`开始领取商圈PK奖励`);
const getPkPrizeRes = await smtg_getPkPrize();
console.log(`商圈PK奖励领取结果：${JSON.stringify(getPkPrizeRes)}`)
if (getPkPrizeRes.data.bizCode === 0) {
const { pkPersonPrizeInfoVO, pkTeamPrizeInfoVO } = getPkPrizeRes.data.result;
message += `【商圈PK奖励】${pkPersonPrizeInfoVO.blueCoin + pkTeamPrizeInfoVO.blueCoin}蓝币领取成功\n`;
}
}
console.log(`我方商圈人气值/对方商圈人气值：${businessCircleVO.hotPoint}/${otherBusinessCircleVO.hotPoint}`);
console.log(`我方商圈成员数量/对方商圈成员数量：${businessCircleVO.memberCount}/${otherBusinessCircleVO.memberCount}`);
message += `【我方商圈】${businessCircleVO.memberCount}/${businessCircleVO.hotPoint}\n`;
message += `【对方商圈】${otherBusinessCircleVO.memberCount}/${otherBusinessCircleVO.hotPoint}\n`;
// message += `【我方商圈人气值】${businessCircleVO.hotPoint}\n`;
// message += `【对方商圈人气值】${otherBusinessCircleVO.hotPoint}\n`;
businessCircleJump = $.getdata('jdBusinessCircleJump') ? $.getdata('jdBusinessCircleJump') : businessCircleJump;
if ($.isNode() && process.env.jdBusinessCircleJump) {
businessCircleJump = process.env.jdBusinessCircleJump;
}
if (`${businessCircleJump}` === 'false') {
console.log(`\n小于对方300热力值自动更换商圈队伍: 您设置的是禁止自动更换商圈队伍\n`);
return
}
if (otherBusinessCircleVO.hotPoint - businessCircleVO.hotPoint > 300 && (Date.now() > (pkSettleTime - 24 * 60 * 60 * 1000))) {
//退出该商圈
if (inviteCode === '-4msulYas0O2JsRhE-2TA5XZmBQ') return;
console.log(`商圈PK已过1天，对方商圈人气值还大于我方商圈人气值300，退出该商圈重新加入`);
await smtg_quitBusinessCircle();
} else if (otherBusinessCircleVO.hotPoint > businessCircleVO.hotPoint && (Date.now() > (pkSettleTime - 24 * 60 * 60 * 1000 * 2))) {
//退出该商圈
if (inviteCode === '-4msulYas0O2JsRhE-2TA5XZmBQ') return;
console.log(`商圈PK已过2天，对方商圈人气值还大于我方商圈人气值，退出该商圈重新加入`);
await smtg_quitBusinessCircle();
}
} else if (businessCirclePKDetailRes && businessCirclePKDetailRes.data.bizCode === 222) {
console.log(`${businessCirclePKDetailRes.data.bizMsg}`);
console.log(`开始领取商圈PK奖励`);
const getPkPrizeRes = await smtg_getPkPrize();
console.log(`商圈PK奖励领取结果：${JSON.stringify(getPkPrizeRes)}`)
if (getPkPrizeRes && getPkPrizeRes.data.bizCode === 0) {
const { pkPersonPrizeInfoVO, pkTeamPrizeInfoVO } = getPkPrizeRes.data.result;
$.msg($.name, '', `【京东账号${$.index}】 ${$.nickName}\n【商圈PK奖励】${pkPersonPrizeInfoVO.blueCoin + pkTeamPrizeInfoVO.blueCoin}蓝币领取成功`)
if ($.isNode()) {
await notify.sendNotify(`${$.name} - 账号${$.index} - ${$.nickName}`, `【京东账号${$.index}】 ${$.nickName}\n【商圈PK奖励】${pkPersonPrizeInfoVO.blueCoin + pkTeamPrizeInfoVO.blueCoin}蓝币领取成功`)
}
}
} else if (businessCirclePKDetailRes && businessCirclePKDetailRes.data.bizCode === 206) {
console.log(`您暂未加入商圈,现在给您加入lxk0301的商圈`);
const joinBusinessCircleRes = await smtg_joinBusinessCircle(myCircleId);
console.log(`参加商圈结果：${JSON.stringify(joinBusinessCircleRes)}`)
if (joinBusinessCircleRes.data.bizCode !== 0) {
console.log(`您加入lxk0301的商圈失败，现在给您随机加入一个商圈`);
const BusinessCircleList = await smtg_getBusinessCircleList();
if (BusinessCircleList.data.bizCode === 0) {
const { businessCircleVOList } = BusinessCircleList.data.result;
const { circleId } = businessCircleVOList[randomNumber(0, businessCircleVOList.length)];
const joinBusinessCircleRes = await smtg_joinBusinessCircle(circleId);
console.log(`随机加入商圈结果：${JSON.stringify(joinBusinessCircleRes)}`)
}
}
} else {
console.log(`访问商圈详情失败：${JSON.stringify(businessCirclePKDetailRes)}`);
}
}
//我的货架
async function myProductList() {
const shelfListRes = await smtg_shelfList();
if (shelfListRes.data.bizCode === 0) {
const { shelfList } = shelfListRes.data.result;
console.log(`\n货架数量:${shelfList && shelfList.length}`)
for (let item of shelfList) {
console.log(`\nshelfId/name : ${item.shelfId}/${item.name}`);
console.log(`货架等级 level ${item.level}/${item.maxLevel}`);
console.log(`上架状态 groundStatus ${item.groundStatus}`);
console.log(`解锁状态 unlockStatus ${item.unlockStatus}`);
console.log(`升级状态 upgradeStatus ${item.upgradeStatus}`);
if (item.unlockStatus === 0) {
console.log(`${item.name}不可解锁`)
} else if (item.unlockStatus === 1) {
console.log(`${item.name}可解锁`);
await smtg_unlockShelf(item.shelfId);
} else if (item.unlockStatus === 2) {
console.log(`${item.name}已经解锁`)
}
if (item.groundStatus === 1) {
console.log(`${item.name}可上架`);
const productListRes = await smtg_shelfProductList(item.shelfId);
if (productListRes.data.bizCode === 0) {
const { productList } = productListRes.data.result;
if (productList && productList.length > 0) {
// 此处限时商品未分配才会出现
let limitTimeProduct = [];
for (let item of productList) {
if (item.productType === 2) {
limitTimeProduct.push(item);
}
}
if (limitTimeProduct && limitTimeProduct.length > 0) {
//上架限时商品
await smtg_ground(limitTimeProduct[0].productId, item.shelfId);
} else {
await smtg_ground(productList[productList.length - 1].productId, item.shelfId);
}
} else {
console.log("无可上架产品");
await unlockProductByCategory(item.shelfId.split('-')[item.shelfId.split('-').length - 1])
}
}
} else if (item.groundStatus === 2 || item.groundStatus === 3) {
if (item.productInfo.productType === 2) {
console.log(`[${item.name}][限时商品]`)
} else if (item.productInfo.productType === 1){
console.log(`[${item.name}]`)
} else {
console.log(`[${item.name}][productType:${item.productInfo.productType}]`)
}
}
}
}
}
//根据类型解锁一个商品,货架可上架商品时调用
async function unlockProductByCategory(category) {
const smtgProductListRes = await smtg_productList();
if (smtgProductListRes.data.bizCode === 0) {
let productListByCategory = [];
const { productList } = smtgProductListRes.data.result;
for (let item of productList) {
if (item['unlockStatus'] === 1 && item['shelfCategory'].toString() === category) {
productListByCategory.push(item);
}
}
if (productListByCategory && productListByCategory.length > 0) {
console.log(`待解锁的商品数量:${productListByCategory.length}`);
await smtg_unlockProduct(productListByCategory[productListByCategory.length - 1]['productId']);
} else {
console.log("该类型商品暂时无法解锁");
}
}
}
//升级货架和商品
async function upgrade() {
superMarketUpgrade = $.getdata('jdSuperMarketUpgrade') ? $.getdata('jdSuperMarketUpgrade') : superMarketUpgrade;
if ($.isNode() && process.env.SUPERMARKET_UPGRADE) {
superMarketUpgrade = process.env.SUPERMARKET_UPGRADE;
}
if (`${superMarketUpgrade}` === 'false') {
console.log(`\n自动升级: 您设置的是关闭自动升级\n`);
return
}
console.log(`\n*************开始检测升级商品，如遇到商品能解锁，则优先解锁***********`)
console.log('目前没有平稳升级,只取倒数几个商品进行升级,普通货架取倒数4个商品,冰柜货架取倒数3个商品,水果货架取倒数2个商品')
const smtgProductListRes = await smtg_productList();
if (smtgProductListRes.data.bizCode === 0) {
let productType1 = [], shelfCategory_1 = [], shelfCategory_2 = [], shelfCategory_3 = [];
const { productList } = smtgProductListRes.data.result;
for (let item of productList) {
if (item['productType'] === 1) {
productType1.push(item);
}
}
for (let item2 of productType1) {
if (item2['shelfCategory'] === 1) {
shelfCategory_1.push(item2);
}
if (item2['shelfCategory'] === 2) {
shelfCategory_2.push(item2);
}
if (item2['shelfCategory'] === 3) {
shelfCategory_3.push(item2);
}
}
shelfCategory_1 = shelfCategory_1.slice(-4);
shelfCategory_2 = shelfCategory_2.slice(-3);
shelfCategory_3 = shelfCategory_3.slice(-2);
const shelfCategorys = shelfCategory_1.concat(shelfCategory_2).concat(shelfCategory_3);
console.log(`\n商品名称 归属货架 目前等级 解锁状态 可升级状态`)
for (let item of shelfCategorys) {
console.log(` ${item["name"].length<3?item["name"]+`\xa0`:item["name"]} ${item['shelfCategory'] === 1 ? '普通货架' : item['shelfCategory'] === 2 ? '冰柜货架' : item['shelfCategory'] === 3 ? '水果货架':'未知货架'} ${item["unlockStatus"] === 0 ? '---' : item["level"]+'级'} ${item["unlockStatus"] === 0 ? '未解锁' : '已解锁'} ${item["upgradeStatus"] === 1 ? '可以升级' : item["upgradeStatus"] === 0 ? '不可升级':item["upgradeStatus"]}`)
}
shelfCategorys.sort(sortSyData);
for (let item of shelfCategorys) {
if (item['unlockStatus'] === 1) {
console.log(`\n开始解锁商品：${item['name']}`)
await smtg_unlockProduct(item['productId']);
break;
}
if (item['upgradeStatus'] === 1) {
console.log(`\n开始升级商品：${item['name']}`)
await smtg_upgradeProduct(item['productId']);
break;
}
}
}
console.log('\n**********开始检查能否升级货架***********');
const shelfListRes = await smtg_shelfList();
if (shelfListRes.data.bizCode === 0) {
const { shelfList } = shelfListRes.data.result;
let shelfList_upgrade = [];
for (let item of shelfList) {
if (item['upgradeStatus'] === 1) {
shelfList_upgrade.push(item);
}
}
console.log(`待升级货架数量${shelfList_upgrade.length}个`);
if (shelfList_upgrade && shelfList_upgrade.length > 0) {
shelfList_upgrade.sort(sortSyData);
console.log("\n可升级货架名 等级 升级所需金币");
for (let item of shelfList_upgrade) {
console.log(` [${item["name"]}] ${item["level"]}/${item["maxLevel"]} ${item["upgradeCostGold"]}`);
}
console.log(`开始升级[${shelfList_upgrade[0].name}]货架，当前等级${shelfList_upgrade[0].level}，所需金币${shelfList_upgrade[0].upgradeCostGold}\n`);
await smtg_upgradeShelf(shelfList_upgrade[0].shelfId);
}
}
}
async function manageProduct() {
console.log(`安排上货(单价最大商品)`);
const shelfListRes = await smtg_shelfList();
if (shelfListRes.data.bizCode === 0) {
const { shelfList } = shelfListRes.data.result;
console.log(`我的货架数量:${shelfList && shelfList.length}`);
let shelfListUnlock = [];//可以上架的货架
for (let item of shelfList) {
if (item['groundStatus'] === 1 || item['groundStatus'] === 2) {
shelfListUnlock.push(item);
}
}
for (let item of shelfListUnlock) {
const productListRes = await smtg_shelfProductList(item.shelfId);//查询该货架可以上架的商品
if (productListRes.data.bizCode === 0) {
const { productList } = productListRes.data.result;
let productNow = [], productList2 = [];
for (let item1 of productList) {
if (item1['groundStatus'] === 2) {
productNow.push(item1);
}
if (item1['productType'] === 1) {
productList2.push(item1);
}
}
// console.log(`productNow${JSON.stringify(productNow)}`)
// console.log(`productList2${JSON.stringify(productList2)}`)
if (productList2 && productList2.length > 0) {
productList2.sort(sortTotalPriceGold);
// console.log(productList2)
if (productNow && productNow.length > 0) {
if (productList2.slice(-1)[0]['productId'] === productNow[0]['productId']) {
console.log(`货架[${item.shelfId}]${productNow[0]['name']}已上架\n`)
continue;
}
}
await smtg_ground(productList2.slice(-1)[0]['productId'], item['shelfId'])
}
}
}
}
}
async function limitTimeProduct() {
const smtgProductListRes = await smtg_productList();
if (smtgProductListRes.data.bizCode === 0) {
const { productList } = smtgProductListRes.data.result;
let productList2 = [];
for (let item of productList) {
if (item['productType'] === 2 && item['groundStatus'] === 1) {
//未上架并且限时商品
console.log(`出现限时商品[${item.name}]`)
productList2.push(item);
}
}
if (productList2 && productList2.length > 0) {
for (let item2 of productList2) {
const { shelfCategory } = item2;
const shelfListRes = await smtg_shelfList();
if (shelfListRes.data.bizCode === 0) {
const { shelfList } = shelfListRes.data.result;
let shelfList2 = [];
for (let item3 of shelfList) {
if (item3['shelfCategory'] === shelfCategory && (item3['groundStatus'] === 1 || item3['groundStatus'] === 2)) {
shelfList2.push(item3['shelfId']);
}
}
if (shelfList2 && shelfList2.length > 0) {
const groundRes = await smtg_ground(item2['productId'], shelfList2.slice(-1)[0]);
if (groundRes.data.bizCode === 0) {
console.log(`限时商品上架成功`);
message += `【限时商品】上架成功\n`;
}
}
}
}
} else {
console.log(`限时商品已经上架或暂无限时商品`);
}
}
}
//=============================================脚本使用到的京东API=====================================
function updatePkActivityId(url = 'https://raw.githubusercontent.com/lxk0301/updateTeam/master/jd_updateTeam.json') {
return new Promise(resolve => {
//https://cdn.jsdelivr.net/gh/lxk0301/updateTeam@master/jd_updateTeam.json
//https://raw.githubusercontent.com/lxk0301/updateTeam/master/jd_updateTeam.json
$.get({url}, async (err, resp, data) => {
try {
if (err) {
console.log(`${JSON.stringify(err)}`)
// console.log(`${$.name} API请求失败，请检查网路重试`)
} else {
$.updatePkActivityIdRes = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp)
} finally {
resolve();
}
})
})
}
function updatePkActivityIdCDN(url = 'http://elemhb.cn:9991/jd_updateTeam.json') {
return new Promise(async resolve => {
//https://cdn.jsdelivr.net/gh/lxk0301/updateTeam@master/jd_updateTeam.json
//https://raw.githubusercontent.com/lxk0301/updateTeam/master/jd_updateTeam.json
const headers = {
"User-Agent": "Mozilla/5.0 (iPhone; CPU iPhone OS 13_2_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/13.0.3 Mobile/15E148 Safari/604.1 Edg/87.0.4280.88"
}
$.get({ url, headers }, async (err, resp, data) => {
try {
if (err) {
console.log(`${JSON.stringify(err)}`)
console.log(`${$.name} API请求失败，请检查网路重试`)
} else {
$.updatePkActivityIdRes = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp)
} finally {
resolve();
}
})
await $.wait(3000)
resolve();
})
}
function smtgDoShopTask(taskId, itemId) {
return new Promise((resolve) => {
const body = {
"taskId": taskId
}
if (itemId) {
body.itemId = itemId;
}
$.get(taskUrl('smtg_doShopTask', body), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtgObtainShopTaskPrize(taskId) {
return new Promise((resolve) => {
const body = {
"taskId": taskId
}
$.get(taskUrl('smtg_obtainShopTaskPrize', body), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtgQueryShopTask() {
return new Promise((resolve) => {
$.get(taskUrl('smtg_queryShopTask'), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtgSignList() {
return new Promise((resolve) => {
$.get(taskUrl('smtg_signList'), (err, resp, data) => {
try {
// console.log('ddd----ddd', data)
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtgHome() {
return new Promise((resolve) => {
$.get(taskUrl('smtg_home'), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
if (data.code === 0 && data.data.success) {
const { result } = data.data;
const { shopName, totalGold, totalBlue } = result;
$.circleStatus = result.circleStatus;
subTitle = shopName;
message += `【总金币】${totalGold}个\n`;
message += `【总蓝币】${totalBlue}个\n`;
}
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
//查询商圈任务列表
function smtgQueryPkTask() {
return new Promise( (resolve) => {
$.get(taskUrl('smtg_queryPkTask'), async (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
if (data.code === 0) {
if (data.data.bizCode === 0) {
const { taskList } = data.data.result;
console.log(`\n 商圈任务 状态`)
for (let item of taskList) {
if (item.taskStatus === 1) {
if (item.prizeStatus === 1) {
//任务已做完，但未领取奖励， 现在为您领取奖励
await smtgObtainPkTaskPrize(item.taskId);
} else if (item.prizeStatus === 0) {
console.log(`[${item.title}] 已做完 ${item.finishNum}/${item.targetNum}`);
}
} else {
console.log(`[${item.title}] 未做完 ${item.finishNum}/${item.targetNum}`)
if (item.content) {
const { itemId } = item.content[item.type];
console.log('itemId', itemId)
await smtgDoPkTask(item.taskId, itemId);
}
}
}
} else {
console.log(`${data.data.bizMsg}`)
}
}
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
//PK邀请好友
function smtgDoAssistPkTask(code) {
return new Promise((resolve) => {
$.get(taskUrl('smtg_doAssistPkTask', {"inviteCode": code}), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtgReceiveCoin(type) {
return new Promise((resolve) => {
const body = {
"type": type
}
$.get(taskUrl('smtg_receiveCoin', body), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
//领取PK任务做完后的奖励
function smtgObtainPkTaskPrize(taskId) {
return new Promise((resolve) => {
$.get(taskUrl('smtg_obtainPkTaskPrize', {"taskId": taskId}), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtgDoPkTask(taskId, itemId) {
return new Promise((resolve) => {
$.get(taskUrl('smtg_doPkTask', {"taskId": taskId, "itemId": itemId}), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtg_joinPkTeam(teamId, inviteCode, sharePkActivityId) {
teamId = "eU9Yar-xYvQv-G6Ew3BG3g_1609172689106";
inviteCode = "U9Yar-xYvQv-G6Ew3BG3g";
console.log(teamId)
console.log(inviteCode)
console.log(sharePkActivityId)
return new Promise((resolve) => {
$.get(taskUrl('smtg_joinPkTeam', { teamId, inviteCode, "channel": "3", sharePkActivityId }), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);
}
})
})
}
function smtg_getTeamPkDetailInfo() {
return new Promise((resolve) => {
$.get(taskUrl('smtg_getTeamPkDetailInfo'), (err, resp, data) => {
try {
if (err) {
console.log('\n京小超: API查询请求失败 ‼️‼️')
console.log(JSON.stringify(err));
} else {
data = JSON.parse(data);
}
} catch (e) {
$.logErr(e, resp);
} finally {
resolve(data);