forked from wliustc/scripts
-
Notifications
You must be signed in to change notification settings - Fork 0
/
jd_bigwinner_exchange.py
598 lines (554 loc) · 32 KB
/
jd_bigwinner_exchange.py
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
# -*- coding:utf-8 -*-
"""
说明：默认提现和兑换红包
作者：atyvcn
指定用户只提现或者只兑换红包就在pin后面用“:”分隔，用“all”表示全部金额，参考“pin:不提现金额:不兑换红包金额”设置，多个金额用“,”
export DYJ_Pin="需要兑换的pin值多个用&"
export DYJ_NotCash="不提现的金额多个参数用&或,"
export DYJ_NotRed="不兑换红包的金额多个参数用&或,"
cron: 50 9,11,16,23 * * *
new Env('赚钱大赢家-定时兑换');
TY在原作者(doubi)基础上删减更改，优化提取
入口 京喜特价 百元生活费 赚钱大赢家
17【赚钱大赢家】海量低价好物 http:/JCFwCHKcjf3l1H复制这段话￥A8tNOCPQkw3B%↦【鯨▻𝓧𝒾特价】
"""
import os
import re
import sys
import time
import uuid
import json
import random
import logging
import requests
import traceback
from hashlib import sha1,md5
import hmac
import base64
from urllib.parse import quote_plus, unquote_plus, quote
import threading
from utils.h5st31 import h5st31
activity_name = "京喜特价-赚钱大赢家-定时兑换"
logging.basicConfig(
level=logging.INFO,
format="%(asctime)s.%(msecs)03d %(message)s",#%(levelname)s %(lineno)d
datefmt="%M:%S"
)
logger = logging.getLogger(activity_name)
index = 0
retry=3
appCode = 'ms2362fc9e'
activeId = '63526d8f5fe613a6adb48f03'
NotCash=[]
NotRed=[]
hbExchangeRuleList=[
{"id":"f7a42f19c8d17c6ff1229808ecd57292","name":"0.5元红包","exchangeStatus":1,"consumeScore":"0.50","cashoutAmount":"0.5"},
{"id":"d29967608439624bd4688e06254b6374","name":"1元红包","exchangeStatus":1,"consumeScore":"1.00","cashoutAmount":"1"},
#{"id":"c14b645cabaa332a883cc5f43a9dd2b7","name":"3元红包","exchangeStatus":1,"consumeScore":"3.00","cashoutAmount":"3"},
{"id":"006d8d0f371e247333a302627af7da00","name":"5元红包","exchangeStatus":1,"consumeScore":"5.00","cashoutAmount":"5"},
{"id":"49995b2a611f5281c06d7b227ac54e09","name":"8元红包","exchangeStatus":1,"consumeScore":"8.00","cashoutAmount":"8"},
{"id":"018300fea81b5bf3f1cad271f7bcfda7","name":"20元红包","exchangeStatus":1,"consumeScore":"20.00","cashoutAmount":"20"}
]
cashExchangeRuleList=[
{"id":"1848d61655f979f8eac0dd36235586ba","name":"0.3元现金","exchangeStatus":1,"consumeScore":"0.30","cashoutAmount":"0.3"},
{"id":"dac84c6bf0ed0ea9da2eca4694948440","name":"1元现金","exchangeStatus":1,"consumeScore":"1.00","cashoutAmount":"1"},
{"id":"53515f286c491d66de3e01f64e3810b2","name":"现金奖励3元","exchangeStatus":1,"consumeScore":"3.00","cashoutAmount":"3"},
{"id":"da3fc8218d2d1386d3b25242e563acb8","name":"8元现金","exchangeStatus":1,"consumeScore":"8.00","cashoutAmount":"8"},
{"id":"7ea791839f7fe3168150396e51e30917","name":"20元现金","exchangeStatus":1,"consumeScore":"20.00","cashoutAmount":"20"},
{"id":"02b48428177a44a4110034497668f808","name":"100元现金","exchangeStatus":1,"consumeScore":"100.00","cashoutAmount":"100"}
]
LastQueryTime=1680932241451
loop={1:True,2:True}
import json
from urllib.parse import quote
def TDEncrypt(m):
m = json.dumps(m, separators=(',', ':'))
m = quote(m)
n = ""
g = 0
s64="23IL<N01c7KvwZO56RSTAfghiFyzWJqVabGH4PQdopUrsCuX*xeBjkltDEmn89.-"
m_l=len(m)
while g < m_l:
f = ord(m[g])
g += 1
d = ord(m[g]) if g<m_l else 0
g += 1
a = ord(m[g]) if g<m_l else 0
g += 1
b = f >> 2
f = (f & 3) << 4 | d >> 4
e = (d & 15) << 2 | a >> 6
c = a & 63
if d==0:
e = c = 64
elif a==0:
c = 64
if b<64:n+=s64[b]
if f<64:n+=s64[f]
if e<64:n+=s64[e]
if c<64:n+=s64[c]
#print(n)
return n + "/"
def orderByAscII(J):
se = []
for ge in J:se.append(ge)
me = sorted(se)
ve = {}
for be in me:
ve[be] = J[be]
return ve
def getParamsValue(J):
se = ""
for pe in J:
ge = J[pe]
if isinstance(ge, dict) or isinstance(ge, list):
ge = json.dumps(ge)
if ge is not None and ge != "" and (isinstance(ge, (int, float, bool)) or isinstance(ge, str)):
se += "&" + str(ge)
return se[1:]
def getSignString(J):
J = orderByAscII(J)
J = getParamsValue(J)
key = b"xtl_sqg_mall-^&*-damai_(789)_@#$"
sign = hmac.new(key, J.encode(), md5).hexdigest()
return sign
def getTimestamp():
return int(round(time.time() * 1000))
string1 = "KLMNOPQRSTABCDEFGHIJUVWXYZabcdopqrstuvwxefghijklmnyz0123456789+/"
string2 = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/"
def get_ep(jduuid : str=''):
if not jduuid:
jduuid = ''.join(str(uuid.uuid4()).split('-'))
ts = str(getTimestamp())
return '{"hdid":"JM9F1ywUPwflvMIpYPok0tt5k9kW4ArJEU3lfLhxBqw=","ts":%s,"ridx":-1,"cipher":{"sv":"CJC=","ad":"ZWOyD2YnDNU0ENC4C2YnEK==","od":"DNS5YwG5DQSnD2YyEQHuDG==","ov":"CzC=","ud":"ZWOyD2YnDNU0ENC4C2YnEK=="},"ciphertype":5,"version":"1.2.0","appname":"com.jd.jdlite"}' % (
int(ts) - random.randint(100, 1000)), jduuid, ts
def base64Encode(string):
return base64.b64encode(string.encode("utf-8")).decode('utf-8').translate(str.maketrans(string1, string2))
def get_pin(cookie):
return unquote_plus(re.findall(r'pt_pin=([^; ]+)(?=;?)', cookie)[0])
def resetState(type=2,ac=1):
global cashExchangeRuleList,hbExchangeRuleList
i=len(cashExchangeRuleList if type==2 else hbExchangeRuleList)
while i>0:
i-=1
data=cashExchangeRuleList[i] if type==2 else hbExchangeRuleList[i]
if ac==1: ok=data['exchangeStatus']!=1
else:ok=data['exchangeStatus']==3 or data['exchangeStatus']==4
if ok:
if type==2:cashExchangeRuleList[i]['exchangeStatus']=1
else:hbExchangeRuleList[i]['exchangeStatus']=1
class Userinfo:
index = 0
def __init__(self, cookie,Not):
global index
index += 1
self.user_index = index
ep, self.uuid, st = get_ep()
#58210751877731116
try:
self.name = get_pin(cookie)
except Exception:
logger.info(f"取值错误['pt_pin']：{traceback.format_exc()}")
return
self.Not=Not
#jdltapp;android;4.8.0;;;appBuild/2384;ef/1;ep/%7B%22hdid%22%3A%22JM9F1ywUPwflvMIpYPok0tt5k9kW4ArJEU3lfLhxBqw%3D%22%2C%22ts%22%3A1675835201639%2C%22ridx%22%3A-1%2C%22cipher%22%3A%7B%22sv%22%3A%22CJC%3D%22%2C%22ad%22%3A%22ZWOyD2YnDNU0ENC4C2YnEK%3D%3D%22%2C%22od%22%3A%22DNS5YwG5DQSnD2YyEQHuDG%3D%3D%22%2C%22ov%22%3A%22CzC%3D%22%2C%22ud%22%3A%22ZWOyD2YnDNU0ENC4C2YnEK%3D%3D%22%7D%2C%22ciphertype%22%3A5%2C%22version%22%3A%221.2.0%22%2C%22appname%22%3A%22com.jd.jdlite%22%7D;Mozilla/5.0 (Linux; Android 13; 22081212C Build/TKQ1.220829.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/89.0.4389.72 MQQBrowser/6.2 TBS/046129 Mobile Safari/537.36
self.UA = f'jdltapp;android;4.6.0;;;appBuild/2374;ef/1;ep/{quote(json.dumps(ep))};Mozilla/5.0 (Linux; Android 13; 22081212C Build/TKQ1.220829.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/104.0.5112.97 Mobile Safari/537.36'
#jdltapp;android;4.9.0;;;appBuild/2394;ef/1;ep/;Mozilla/5.0 (Linux; Android 13; 22081212C Build/TKQ1.220829.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/89.0.4389.72 MQQBrowser/6.2 TBS/046141 Mobile Safari/537.36
self.cookie = cookie
self.sha = sha1(str(self.name).encode('utf-8')).hexdigest()
self.headers = {
"Host": "api.m.jd.com",
"User-Agent": self.UA,
"content-type": "text/plain",
"Accept":"*/*",
"origin": "https://wqs.jd.com",
"x-requested-with": "com.jd.jdlite",
"sec-fetch-site": "same-site",
"sec-fetch-mode": "cors",
"sec-fetch-dest": "empty",
"referer": "https://wqs.jd.com/",
"accept-encoding": "gzip, deflate, br",
"accept-language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7",
"Cookie": self.cookie + f"; appCode={appCode}; sid={self.sha}; visitkey={self.uuid}",
}
self.stockPersonDayLimit=10
self.stockPersonDayUsed=0
self.canUseCoinAmount=-1
self.valid=True
self.LastQueryTime=0
self.cashExchangeRuleList=[]
self.hbExchangeRuleList=[]
#print(self.name)
def getHome(self):
t=getTimestamp()
g={
'pin': '',
'oid': '',
'bizId': 'jx_h5_common',
'fc': '',
'mode': 'strict',
'p': 's',
'fp': '50f08d6e0c090550653030e7a8db8838',
'v': '3.1.0.0',
'f': '3',
'o': 'wqs.jd.com/sns/202210/20/make-money-shop/index.html',
'qs': f'activeId={activeId}&sid={self.sha}&un_area=',
'jsTk': '',
'qi': ''
}
a=TDEncrypt(g)
d='{"ts":{"deviceTime":1681011018608,"deviceEndTime":1681011018685},"ca":{"tdHash":"ae7bb88f7eac3baa052a6d2fd3c4eab8","contextName":"webgl,experimental-webgl","webglversion":"WebGL 1.0 (OpenGL ES 2.0 Chromium)","shadingLV":"WebGL GLSL ES 1.0 (OpenGL ES GLSL ES 1.0 Chromium)","vendor":"WebKit","renderer":"WebKit WebGL","extensions":["ANGLE_instanced_arrays","EXT_blend_minmax","EXT_color_buffer_half_float","EXT_float_blend","EXT_texture_filter_anisotropic","WEBKIT_EXT_texture_filter_anisotropic","EXT_sRGB","OES_element_index_uint","OES_fbo_render_mipmap","OES_standard_derivatives","OES_texture_float","OES_texture_float_linear","OES_texture_half_float","OES_texture_half_float_linear","OES_vertex_array_object","WEBGL_color_buffer_float","WEBGL_compressed_texture_astc","WEBGL_compressed_texture_etc","WEBGL_compressed_texture_etc1","WEBGL_debug_renderer_info","WEBGL_debug_shaders","WEBGL_depth_texture","WEBKIT_WEBGL_depth_texture","WEBGL_lose_context","WEBKIT_WEBGL_lose_context","WEBGL_multi_draw"],"wuv":"Qualcomm","wur":"Adreno (TM) 730"},"m":{"compatMode":"CSS1Compat"},"fo":["Bauhaus 93","Casual"],"n":{"vendorSub":"","productSub":"20030107","vendor":"Google Inc.","maxTouchPoints":5,"hardwareConcurrency":8,"cookieEnabled":true,"appCodeName":"Mozilla","appName":"Netscape","appVersion":"","platform":"Linux aarch64","product":"Gecko","userAgent":"","language":"zh-CN","onLine":true,"webdriver":false,"javaEnabled":false,"deviceMemory":8,"enumerationOrder":["vendorSub","productSub","vendor","maxTouchPoints","userActivation","doNotTrack","geolocation","connection","plugins","mimeTypes","webkitTemporaryStorage","webkitPersistentStorage","hardwareConcurrency","cookieEnabled","appCodeName","appName","appVersion","platform","product","userAgent","language","languages","onLine","webdriver","getBattery","getGamepads","javaEnabled","sendBeacon","vibrate","scheduling","mediaCapabilities","locks","wakeLock","usb","clipboard","credentials","keyboard","mediaDevices","storage","serviceWorker","deviceMemory","bluetooth","getUserMedia","requestMIDIAccess","requestMediaKeySystemAccess","webkitGetUserMedia","clearAppBadge","setAppBadge"]},"p":[],"w":{"devicePixelRatio":3,"screenTop":0,"screenLeft":0},"s":{"availHeight":904,"availWidth":407,"colorDepth":24,"height":904,"width":407,"pixelDepth":24},"sc":{"ActiveBorder":"rgb(255, 255, 255)","ActiveCaption":"rgb(204, 204, 204)","AppWorkspace":"rgb(255, 255, 255)","Background":"rgb(99, 99, 206)","ButtonFace":"rgb(221, 221, 221)","ButtonHighlight":"rgb(221, 221, 221)","ButtonShadow":"rgb(136, 136, 136)","ButtonText":"rgb(0, 0, 0)","CaptionText":"rgb(0, 0, 0)","GrayText":"rgb(128, 128, 128)","Highlight":"rgb(181, 213, 255)","HighlightText":"rgb(0, 0, 0)","InactiveBorder":"rgb(255, 255, 255)","InactiveCaption":"rgb(255, 255, 255)","InactiveCaptionText":"rgb(127, 127, 127)","InfoBackground":"rgb(251, 252, 197)","InfoText":"rgb(0, 0, 0)","Menu":"rgb(247, 247, 247)","MenuText":"rgb(0, 0, 0)","Scrollbar":"rgb(255, 255, 255)","ThreeDDarkShadow":"rgb(102, 102, 102)","ThreeDFace":"rgb(192, 192, 192)","ThreeDHighlight":"rgb(221, 221, 221)","ThreeDLightShadow":"rgb(192, 192, 192)","ThreeDShadow":"rgb(136, 136, 136)","Window":"rgb(255, 255, 255)","WindowFrame":"rgb(204, 204, 204)","WindowText":"rgb(0, 0, 0)"},"ss":{"cookie":true,"localStorage":true,"sessionStorage":true,"globalStorage":false,"indexedDB":true},"tz":-480,"lil":"","wil":""}'
d = json.loads(d)
d["ts"]["deviceTime"]=t
d["ts"]["deviceEndTime"]=t+77
d["n"]["appVersion"]=self.UA[self.UA.find("appBuild/")+9:]
d["n"]["userAgent"]=self.UA
d=TDEncrypt(d)
data={"d":d}
url = f'https://gia.jd.com/jsTk.do?a={a}'
headers = {
"Host": "gia.jd.com",
"User-Agent": self.UA,
"content-type": "application/x-www-form-urlencoded;charset=UTF-8",
"Accept":"*/*",
"origin": "https://wqs.jd.com",
"x-requested-with": "com.jd.jdlite",
"sec-fetch-site": "same-site",
"sec-fetch-mode": "cors",
"sec-fetch-dest": "empty",
"referer": "https://wqs.jd.com/",
"accept-encoding": "gzip, deflate, br",
"accept-language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7",
"Cookie": self.cookie + f"; appCode={appCode}; sid={self.sha}; visitkey={self.uuid}",
}
x_api_eid_token=""
try:
res = requests.post(url=url,data=data,headers=headers,proxies={},timeout=2).text
try:
res = json.loads(res)
if res['code'] == 0:#res.data
x_api_eid_token=res['data']['token']
else:
print(res)
except Exception as e:
logger.info(f"{self.name}jsTk api解析异常：{str(e)}")
except Exception as e:
logger.info(f"{self.name}jsTk api超过2s请求超时...")
if not x_api_eid_token:
print("x_api_eid_token 获取失败")
return False
t=getTimestamp()
new_h5st31=h5st31({
'appId':'638ee',
"appid": "jdlt_h5",
"clientVersion": "1.2.5",
"client": "jxh5",
"pin": self.name,
"ua":self.UA
})
new_h5st31.genAlgo()
body={"activeId":activeId,"isFirst":1,"visitChannel":1,"sceneval":2,"buid":325,"appCode":appCode,"time":t}
body["signStr"]=getSignString(body)
g=new_h5st31.getbody("makemoneyshop_home",body)
url = f'https://api.m.jd.com/api?{g}&uuid={self.uuid}&cthr=1&loginType=2&x-api-eid-token={x_api_eid_token}'
try:
res = requests.get(url=url, headers=self.headers,proxies={},timeout=2).text
try:
res = json.loads(res)
if res['code'] == 0:#res.data
del res['data']['skuList']
del res['data']['clientConf']
self.canUseCoinAmount=res['data']['canUseCoinAmount']#canUseCoinMoney
# 'exchangeRuleList': [{'id': '1848d61655f979f8eac0dd36235586ba', 'exchangeType': 2, 'name': '0.3元现金', 'images': ['//img10.360buyimg.com/mobilecms/jfs/t1/162133/4/32067/14947/635b9211E65a27b71/c0421d0e85d83caa.jpg!q70.dpg'], 'description': '', 'exchangeStatus': 4, 'consumeScore': '0.30', 'cashoutAmount': '0.3', 'orderSkuId': '', 'orderAmount': '0.00', 'attribute': ''}, {'id': 'f7a42f19c8d17c6ff1229808ecd57292', 'exchangeType': 1, 'name': '0.5元红包', 'images': ['//img10.360buyimg.com/mobilecms/jfs/t1/148557/9/31725/8098/642acbf2Fb69d750f/6b6d9fb66502e3c7.png'], 'description': '', 'exchangeStatus': 1, 'consumeScore': '0.50', 'cashoutAmount': '0.5', 'orderSkuId': '', 'orderAmount': '0.00', 'attribute': '', 'extMap': {'couponDiscount': '0.5', 'prizeLevel': 28, 'prizeType': 12, 'active': 'jxyqyl_hjc_hongbao', 'couponQuota': '0'}}, {'id': 'd29967608439624bd4688e06254b6374', 'exchangeType': 1, 'name': '1元红包', 'images': ['//img10.360buyimg.com/mobilecms/jfs/t1/99789/4/38033/8098/63fe245eFba0b7137/8cb6660a1e943cf4.png'], 'description': '', 'exchangeStatus': 3, 'consumeScore': '1.00', 'cashoutAmount': '1', 'orderSkuId': '', 'orderAmount': '0.00', 'attribute': '', 'extMap': {'couponDiscount': '1', 'prizeLevel': 24, 'prizeType': 12, 'active': 'jxyqyl_hjc_hongbao', 'couponQuota': '0'}}, {'id': '006d8d0f371e247333a302627af7da00', 'exchangeType': 1, 'name': '5元红包', 'images': ['//img10.360buyimg.com/mobilecms/jfs/t1/178803/39/33849/8098/63fe2394F2f92c78e/2859c16a38e79b74.png'], 'description': '', 'exchangeStatus': 2, 'consumeScore': '5.00', 'cashoutAmount': '5', 'orderSkuId': '', 'orderAmount': '0.00', 'attribute': '', 'extMap': {'couponDiscount': '5', 'prizeLevel': 23, 'prizeType': 12, 'active': 'jxyqyl_hjc_hongbao', 'couponQuota': '0'}}, {'id': '49995b2a611f5281c06d7b227ac54e09', 'exchangeType': 1, 'name': '8元红包', 'images': ['//img10.360buyimg.com/mobilecms/jfs/t1/150174/8/35289/8098/642ba80dF1493a495/62d8af9eba56cd43.png'], 'description': '', 'exchangeStatus': 2, 'consumeScore': '8.00', 'cashoutAmount': '8', 'orderSkuId': '', 'orderAmount': '0.00', 'attribute': '', 'extMap': {'couponDiscount': '8', 'prizeLevel': 29, 'prizeType': 12, 'active': 'jxyqyl_hjc_hongbao', 'couponQuota': '0'}}],
return True
else:
print(res)
except Exception as e:
logger.info(f"{self.name}api解析异常：{str(e)}")
except Exception as e:
logger.info(f"{self.name}api超过2s请求超时...")
return False
def Query(self):
t=getTimestamp()
body={"activeId":activeId,"visitChannel":1,"sceneval":2,"buid":325,"buid":325,"appCode":appCode,"time":t}
body["signStr"]=getSignString(body)
url = f'https://api.m.jd.com/api?functionId=makemoneyshop_exchangequery&appid=jdlt_h5&t={t}&channel=jxh5&cv=1.2.5&clientVersion=1.2.5&client=jxh5&uuid={self.uuid}&cthr=1&loginType=2&body={quote(json.dumps(body))}'
try:
res = requests.get(url=url, headers=self.headers,proxies={},timeout=2).text
try:
res = json.loads(res)
if res['code'] == 0:
self.stockPersonDayLimit=int(res['data']['stockPersonDayLimit'])#用户日库存限额
self.stockPersonDayUsed=int(res['data']['stockPersonDayUsed'])#用户今天兑换多少次
self.canUseCoinAmount = float(res['data']['canUseCoinAmount'])
logger.info(f"用户“{self.name}”余额[{self.canUseCoinAmount}]元")
if self.canUseCoinAmount<0.3:self.valid=False
self.LastQueryTime=getTimestamp()
self.cashExchangeRuleList=res['data']["cashExchangeRuleList"]
self.hbExchangeRuleList=res['data']["hbExchangeRuleList"]
return True
else:
#{"code": 147, "msg": "活动太火爆，请稍后再试！"}
logger.info(f"用户“{self.name}”查询余额失败：{res['msg']}")#json.dumps(res)
#print(res)
except Exception as e:
logger.info(f"{self.name}查询余额解析异常：{str(e)}")
except Exception as e:
logger.info(f"{self.name}查询余额超过2s请求超时...")
return False
def ExchangeList(self,exchangeType=1):#1 红包 2现金
global loop,NotCash,NotRed,cashExchangeRuleList,hbExchangeRuleList,retry
if loop[exchangeType]==False:return False
print("")
if exchangeType==1:
Tname="红包"
NowNot=list(set(NotRed+self.Not["red"]))
i=len(hbExchangeRuleList)
else:
Tname="现金"
NowNot=list(set(NotCash+self.Not["cash"]))
i=len(cashExchangeRuleList)
logger.info(f"{self.name}兑换{Tname}")
if self.stockPersonDayUsed>=self.stockPersonDayLimit:
logger.info(f"当前兑换次数已经达到上限[{self.stockPersonDayLimit}]次")
#elif 'exchangeRecordList' in res['data']:logger.info(f"已有提现进行中，请等待完成！")
else:
get=False
error=0
while i>0:#for data in cashExchangeRuleList[::-1]:#倒序
i-=1
data=hbExchangeRuleList[i] if exchangeType==1 else cashExchangeRuleList[i]
if self.stockPersonDayUsed>=self.stockPersonDayLimit:
logger.info(f"当前兑换次数已经达到上限[{self.stockPersonDayLimit}]次")
break
elif data['exchangeStatus']==1:
if self.canUseCoinAmount >= float(data['cashoutAmount']) or self.canUseCoinAmount==-1:
if float(data['cashoutAmount']) not in NowNot:
logger.info(f"当前余额[{self.canUseCoinAmount}]元,开始尝试兑换{Tname}[{data['cashoutAmount']}]")
t=getTimestamp()
body={"bizCode":"makemoneyshop","ruleId":data["id"],"sceneval":2,"buid":325,"appCode":appCode,"time":t}
body["signStr"]=getSignString(body)
#get=f'functionId=jxPrmtExchange_exchange&appid=jdlt_h5&t={t}&clientVersion=1.2.5&client=jxh5&body={quote(json.dumps(body))}'
get=self.h5st31.getbody("jxPrmtExchange_exchange",body,True)
url=f'https://api.m.jd.com/api?{get}&channel=jxh5&cv=1.2.5&uuid={self.uuid}&cthr=1&loginType=2'
proxies={}
try:
if get:time.sleep(0.2)
else:get=True
res = requests.get(url=url, headers=self.headers,proxies=proxies,timeout=2)
if res.status_code==403:
logger.info(f"{self.name}兑换{Tname}{data['cashoutAmount']}失败触发403，等待0.2s后将重试。")
error+=1
if retry>error:
i+=1
logger.info(f"等待0.2s后将重试。")
else:error=0
continue
try:
exchange = json.loads(res.text)
error_text=f"{self.name}兑换{data['cashoutAmount']}元{Tname}失败:"
if exchange['ret'] == 0:
self.stockPersonDayUsed+=1
logger.info(f"{self.name}兑换{data['cashoutAmount']}元{Tname}成功。")
if exchangeType==2:break
elif exchange['ret'] == 223:#积分不足
logger.info(f"{error_text}{exchange['msg']}")
elif int(exchange['ret']) in [224,232]:#库存不足|日库存不足
if exchangeType==1:hbExchangeRuleList[i]['exchangeStatus']=2
else:cashExchangeRuleList[i]['exchangeStatus']=2
logger.info(f"{error_text}{exchange['msg']}")
elif int(exchange['ret']) in [248,103]:#操作过快，请稍后重试|jimDB操作异常
logger.info(f"{error_text}{exchange['msg']}")
logger.info(f"等待1s，后将重试。")
i+=1
time.sleep(0.8)
elif int(exchange['ret']) in [246,604]:#达到个人日兑换上限|已有提现进行中，等待完成
logger.info(f"{error_text}{exchange['msg']}")
break
elif exchange['ret'] == 238:#兑换规则已失效
if exchangeType==1:
del hbExchangeRuleList[i]
else:
del cashExchangeRuleList[i]
else:
logger.info(f"{error_text}{exchange['ret']}:{exchange['msg']}")
except Exception as e:
logger.info(f"{error_text}解析异常：{str(e)}")
print(res.text)
get=False
error+=1
if retry>error:
i+=1
logger.info(f"将重试。")
else:error=0
except Exception as e:
logger.info(f"{error_text}超过2s请求超时...")
get=False
error+=1
if retry>error:
i+=1
logger.info(f"将重试。")
else:error=0
else:
logger.info(f"当前余额[{self.canUseCoinAmount}]元,不兑换{Tname}[{NowNot}]门槛")
if i==0:loop[exchangeType]=False
#else:logger.info(f"当前余额[{self.canUseCoinAmount}]元,不足兑换{Tname}[{data['cashoutAmount']}]元门槛")
elif data['exchangeStatus']==2:
logger.info(f"{self.name},来晚了咯{data['name']}都被抢光了")
if i==0:loop[exchangeType]=False
elif data['exchangeStatus']==3:logger.info(f"{self.name},{data['name']}已兑换")
elif data['exchangeStatus']==4:
logger.info(f"{self.name},{data['name']}已抢光")
if i==0:loop[exchangeType]=False
else:logger.info(f"{self.name}未知状态：{data}")
return True
def ExchangeListAll(self):
self.ExchangeList(2)
self.ExchangeList(1)
def main():
try:
cookies = os.environ['JD_COOKIE'].split('&')
except:
with open(os.path.join(os.path.dirname(__file__), 'cklist.txt'), 'r') as f:
cookies = f.read().split('\n')
DYJ_Pin = os.environ.get('DYJ_Pin', "")
if DYJ_Pin == "":
logger.info('您尚未设置变量 DYJ_Pin="pin1&pin2&pin3"\n指定用户只提现或者只兑换红包就在pin后面用“:”分隔，用“all”表示全部金额，参考“pin:不提现金额:不兑换红包金额”设置，多个金额用“,”')
sys.exit()
try:
DYJ_Pin = DYJ_Pin.split('&')
except:
logger.info("DYJ_Pin 变量设置错误，pin1&pin2&pin3")
sys.exit()
helpPin=[]
PinObj={}
for text in DYJ_Pin:
a=text.split(':')
pin=a[0]
helpPin.append(pin)
PinObj[pin]={"cash":[],"red":[]}
if len(a)>1 and not a[1]:PinObj[pin]["cash"]=a[1].split(',')
if len(a)>2 and not a[2]:PinObj[pin]["red"]=a[2].split(',')
#print(PinObj)
global NotCash,NotRed
NotCash = os.environ.get('DYJ_NotCash', "")
if NotCash == "":
logger.info('您尚未设置变量 DYJ_NotCash="金额1,金额2,金额3"\n默认不提现0.3和1还有3，相当于 export DYJ_NotCash="0.3,1,3"')
NotCash = "0.3,1,3"
try:
if NotCash.find("&")!=-1:NotCash = NotCash.split('&')
elif NotCash.find(",")!=-1:NotCash = NotCash.split(',')
else:NotCash = [NotCash]
logger.info(f"不提现：[{NotCash}]")
NotCash = [float(item) for item in NotCash]
except: logger.info("DYJ_NotCash 变量设置错误请参考：金额1,金额2,金额3")
NotRed = os.environ.get('DYJ_NotRed', "")
if NotRed == "":
logger.info('您尚未设置变量 DYJ_NotRed="金额1,金额2,金额3"\n默认不兑换0.3和1还有3，相当于 export DYJ_NotRed="0.3,1,3"')
NotRed = "0.3,1,3"
try:
if NotRed.find("&")!=-1:NotRed = NotRed.split('&')
elif NotRed.find(",")!=-1:NotRed = NotRed.split(',')
else:NotRed = [NotRed]
logger.info(f"不兑换：[{NotRed}]")
NotRed = [float(item) for item in NotRed]
except: logger.info("DYJ_NotRed 变量设置错误请参考：金额1,金额2,金额3")
UserList=[]
for cookie in cookies:
pin=get_pin(cookie)
if pin in helpPin:
UserList.append(Userinfo(cookie,PinObj[pin]))
if not UserList:
logger.info(f"没有找到用户:{helpPin}")
sys.exit()
Users=[]
NotUserList=helpPin
for e in UserList:
if e.name in helpPin:
Users.append(e.name)
NotUserList.remove(e.name)
if len(Users):logger.info(f"找到{len(Users)}个用户:{Users}")
if len(NotUserList):logger.info(f"没有找到{len(NotUserList)}个用户:{NotUserList}")
random.shuffle(UserList)#随机排序
print("")
logger.info(f"开始查询提现用户余额信息")
c=len(UserList)
i=0
global loop,cashExchangeRuleList,hbExchangeRuleList,LastQueryTime
current_time = getTimestamp()
for e in UserList:
i+=1
if e.getHome()==True:
print('白号')
#else:print(f'{e.name} 出错，跳过提现')
time.sleep(1)
if e.Query():
if current_time>LastQueryTime:
LastQueryTime=e.LastQueryTime
cashExchangeRuleList=e.cashExchangeRuleList
resetState(2)
hbExchangeRuleList=e.hbExchangeRuleList
resetState(1)
e.h5st31=h5st31({
'appId':'af89e',
"appid": "cs_h5",
"clientVersion": "1.2.5",
"client": "jxh5",
"pin": e.name,
"ua":e.UA
})
e.h5st31.genAlgo()
if i!=c:
if c>2:
logger.info(f"等待15秒查询下一个")
time.sleep(15)
elif c>1:
logger.info(f"等待3秒查询下一个")
time.sleep(3)
print("")
unit = 18e5
current_time = getTimestamp()
nextHourStamp = current_time - ( current_time % unit ) + unit
#nextHourStamp = current_time+1000
nextHour=time.strftime("%H:%M:%S", time.localtime(nextHourStamp/1000))
logger.info(f"开始等待{nextHour}提现")
while 1:
current_time = getTimestamp()
if current_time >= nextHourStamp:
'''if nextHour!="10:00:00":
logger.info(f"开始查询库存")
for e in UserList:
if e.Query():
if current_time>LastQueryTime:
LastQueryTime=e.LastQueryTime
cashExchangeRuleList=e.cashExchangeRuleList
resetState(2)
hbExchangeRuleList=e.hbExchangeRuleList
resetState(1)'''
print("")
logger.info(f"开始兑换")
tdList=[]
for e in UserList:
if e.valid:
if len(e.Not["cash"])==1 and e.Not["cash"][0]=='all':
e.info(f"{e.name}设置不提现")
else:tdList.append(threading.Thread(target=e.ExchangeList, args=(2,)))
if len(e.Not["red"])==1 and e.Not["red"][0]=='all':
logger.info(f"{e.name}设置不兑换红包")
else:tdList.append(threading.Thread(target=e.ExchangeList, args=(1,)))
for tdItem in tdList:
if loop[1] or loop[2]:
try:
tdItem.start()
time.sleep(0.1) #0.1 秒一个
except Exception as e:
logger.info(f'提现异常：{str(e)}')
else:
logger.info(f"最后一个也没得咯，多线程提前结束！")
break
break
#else: printf("等待开始...")
time.sleep(0.01)
#time.sleep(round(random.uniform(0.7, 1.3), 2))
if __name__ == '__main__':
main()