@@ -36,13 +36,12 @@ var __generator = (this && this.__generator) || function (thisArg, body) {
36
36
}
37
37
} ;
38
38
exports . __esModule = true ;
39
- exports . jdpingou = exports . obj2str = exports . wechat_app_msg = exports . randomWord = exports . getShareCodePool = exports . getshareCodeHW = exports . randomNumString = exports . o2s = exports . resetHosts = exports . randomString = exports . exceptCookie = exports . h5st = exports . getJxToken = exports . decrypt = exports . requestAlgo = exports . getRandomNumberByRange = exports . wait = exports . requireConfig = exports . getFarmShareCode = exports . getBeanShareCode = exports . TotalBean = void 0 ;
39
+ exports . jdpingou = exports . obj2str = exports . wechat_app_msg = exports . randomWord = exports . getShareCodePool = exports . getshareCodeHW = exports . randomNumString = exports . o2s = exports . resetHosts = exports . randomString = exports . exceptCookie = exports . getJxToken = exports . requestAlgo = exports . getRandomNumberByRange = exports . wait = exports . requireConfig = exports . getFarmShareCode = exports . getBeanShareCode = exports . TotalBean = void 0 ;
40
40
var axios_1 = require ( "axios" ) ;
41
41
var ts_md5_1 = require ( "ts-md5" ) ;
42
- var date_fns_1 = require ( "date-fns" ) ;
43
42
var dotenv = require ( "dotenv" ) ;
44
43
var fs_1 = require ( "fs" ) ;
45
- var CryptoJS = require ( 'crypto-js' ) ;
44
+ var sendNotify_1 = require ( "./sendNotify" ) ;
46
45
dotenv . config ( ) ;
47
46
var fingerprint , token = '' , enCryptMethodJD ;
48
47
var USER_AGENTS = [
@@ -149,30 +148,74 @@ function getFarmShareCode(cookie) {
149
148
} ) ;
150
149
}
151
150
exports . getFarmShareCode = getFarmShareCode ;
152
- function requireConfig ( index ) {
153
- if ( index === void 0 ) { index = - 1 ; }
151
+ function requireConfig ( ) {
154
152
return __awaiter ( this , void 0 , void 0 , function ( ) {
155
- var cookiesArr , jdCookieNode ;
153
+ var cookiesArr , jdCookieNode , keys , i , cookie , username ;
156
154
return __generator ( this , function ( _a ) {
157
- cookiesArr = [ ] ;
158
- jdCookieNode = require ( './jdCookie.js' ) ;
159
- Object . keys ( jdCookieNode ) . forEach ( function ( item ) {
160
- if ( jdCookieNode [ item ] ) {
161
- cookiesArr . push ( jdCookieNode [ item ] ) ;
162
- }
163
- } ) ;
164
- console . log ( "\u5171" . concat ( cookiesArr . length , "\u4E2A\u4EAC\u4E1C\u8D26\u53F7\n" ) ) ;
165
- if ( index != - 1 ) {
166
- return [ 2 /*return*/ , [ cookiesArr [ index ] ] ] ;
167
- }
168
- else {
169
- return [ 2 /*return*/ , cookiesArr ] ;
155
+ switch ( _a . label ) {
156
+ case 0 :
157
+ cookiesArr = [ ] ;
158
+ jdCookieNode = require ( './jdCookie.js' ) ;
159
+ keys = Object . keys ( jdCookieNode ) ;
160
+ i = 0 ;
161
+ _a . label = 1 ;
162
+ case 1 :
163
+ if ( ! ( i < keys . length ) ) return [ 3 /*break*/ , 6 ] ;
164
+ cookie = jdCookieNode [ keys [ i ] ] ;
165
+ return [ 4 /*yield*/ , checkCookie ( cookie ) ] ;
166
+ case 2 :
167
+ if ( ! _a . sent ( ) ) return [ 3 /*break*/ , 3 ] ;
168
+ cookiesArr . push ( cookie ) ;
169
+ return [ 3 /*break*/ , 5 ] ;
170
+ case 3 :
171
+ username = decodeURIComponent ( jdCookieNode [ keys [ i ] ] . match ( / p t _ p i n = ( [ ^ ; ] * ) / ) [ 1 ] ) ;
172
+ console . log ( 'Cookie失效' , username ) ;
173
+ return [ 4 /*yield*/ , ( 0 , sendNotify_1 . sendNotify ) ( 'Cookie失效' , '【京东账号】' + username ) ] ;
174
+ case 4 :
175
+ _a . sent ( ) ;
176
+ _a . label = 5 ;
177
+ case 5 :
178
+ i ++ ;
179
+ return [ 3 /*break*/ , 1 ] ;
180
+ case 6 :
181
+ console . log ( "\u5171" . concat ( cookiesArr . length , "\u4E2A\u4EAC\u4E1C\u8D26\u53F7\n" ) ) ;
182
+ return [ 2 /*return*/ , cookiesArr ] ;
170
183
}
171
- return [ 2 /*return*/ ] ;
172
184
} ) ;
173
185
} ) ;
174
186
}
175
187
exports . requireConfig = requireConfig ;
188
+ function checkCookie ( cookie ) {
189
+ return __awaiter ( this , void 0 , void 0 , function ( ) {
190
+ var data , e_1 ;
191
+ return __generator ( this , function ( _a ) {
192
+ switch ( _a . label ) {
193
+ case 0 : return [ 4 /*yield*/ , wait ( 1000 ) ] ;
194
+ case 1 :
195
+ _a . sent ( ) ;
196
+ _a . label = 2 ;
197
+ case 2 :
198
+ _a . trys . push ( [ 2 , 4 , , 5 ] ) ;
199
+ return [ 4 /*yield*/ , axios_1 [ "default" ] . get ( "https://api.m.jd.com/client.action?functionId=GetJDUserInfoUnion&appid=jd-cphdeveloper-m&body=" . concat ( encodeURIComponent ( JSON . stringify ( { "orgFlag" : "JD_PinGou_New" , "callSource" : "mainorder" , "channel" : 4 , "isHomewhite" : 0 , "sceneval" : 2 } ) ) , "&loginType=2&_=" ) . concat ( Date . now ( ) , "&sceneval=2&g_login_type=1&callback=GetJDUserInfoUnion&g_ty=ls" ) , {
200
+ headers : {
201
+ 'authority' : 'api.m.jd.com' ,
202
+ 'user-agent' : 'Mozilla/5.0 (iPhone; CPU iPhone OS 10_3_1 like Mac OS X) AppleWebKit/603.1.30 (KHTML, like Gecko) Version/10.0 Mobile/14E304 Safari/602.1' ,
203
+ 'referer' : 'https://home.m.jd.com/' ,
204
+ 'cookie' : cookie
205
+ }
206
+ } ) ] ;
207
+ case 3 :
208
+ data = ( _a . sent ( ) ) . data ;
209
+ data = JSON . parse ( data . match ( / G e t J D U s e r I n f o U n i o n \( ( .* ) \) / ) [ 1 ] ) ;
210
+ return [ 2 /*return*/ , data . retcode === '0' ] ;
211
+ case 4 :
212
+ e_1 = _a . sent ( ) ;
213
+ return [ 2 /*return*/ , false ] ;
214
+ case 5 : return [ 2 /*return*/ ] ;
215
+ }
216
+ } ) ;
217
+ } ) ;
218
+ }
176
219
function wait ( timeout ) {
177
220
return new Promise ( function ( resolve ) {
178
221
setTimeout ( resolve , timeout ) ;
@@ -241,44 +284,6 @@ function generateFp() {
241
284
i += e [ Math . random ( ) * e . length | 0 ] ;
242
285
return ( i + Date . now ( ) ) . slice ( 0 , 16 ) ;
243
286
}
244
- function getQueryString ( url , name ) {
245
- var reg = new RegExp ( "(^|&)" + name + "=([^&]*)(&|$)" , "i" ) ;
246
- var r = url . split ( '?' ) [ 1 ] . match ( reg ) ;
247
- if ( r != null )
248
- return decodeURIComponent ( r [ 2 ] ) ;
249
- return '' ;
250
- }
251
- function decrypt ( stk , url , appId ) {
252
- var timestamp = ( ( 0 , date_fns_1 . format ) ( new Date ( ) , 'yyyyMMddhhmmssSSS' ) ) ;
253
- var hash1 ;
254
- if ( fingerprint && token && enCryptMethodJD ) {
255
- hash1 = enCryptMethodJD ( token , fingerprint . toString ( ) , timestamp . toString ( ) , appId . toString ( ) , CryptoJS ) . toString ( CryptoJS . enc . Hex ) ;
256
- }
257
- else {
258
- var random = '5gkjB6SpmC9s' ;
259
- token = "tk01wcdf61cb3a8nYUtHcmhSUFFCfddDPRvKvYaMjHkxo6Aj7dhzO+GXGFa9nPXfcgT+mULoF1b1YIS1ghvSlbwhE0Xc" ;
260
- fingerprint = 9686767825751161 ;
261
- var str = "" . concat ( token ) . concat ( fingerprint ) . concat ( timestamp ) . concat ( appId ) . concat ( random ) ;
262
- hash1 = CryptoJS . SHA512 ( str , token ) . toString ( CryptoJS . enc . Hex ) ;
263
- }
264
- var st = '' ;
265
- stk . split ( ',' ) . map ( function ( item , index ) {
266
- st += "" . concat ( item , ":" ) . concat ( getQueryString ( url , item ) ) . concat ( index === stk . split ( ',' ) . length - 1 ? '' : '&' ) ;
267
- } ) ;
268
- var hash2 = CryptoJS . HmacSHA256 ( st , hash1 . toString ( ) ) . toString ( CryptoJS . enc . Hex ) ;
269
- return encodeURIComponent ( [ "" . concat ( timestamp . toString ( ) ) , "" . concat ( fingerprint . toString ( ) ) , "" . concat ( appId . toString ( ) ) , "" . concat ( token ) , "" . concat ( hash2 ) ] . join ( ";" ) ) ;
270
- }
271
- exports . decrypt = decrypt ;
272
- function h5st ( url , stk , params , appId ) {
273
- if ( appId === void 0 ) { appId = 10032 ; }
274
- for ( var _i = 0 , _a = Object . entries ( params ) ; _i < _a . length ; _i ++ ) {
275
- var _b = _a [ _i ] , key = _b [ 0 ] , val = _b [ 1 ] ;
276
- url += "&" . concat ( key , "=" ) . concat ( val ) ;
277
- }
278
- url += '&h5st=' + decrypt ( stk , url , appId ) ;
279
- return url ;
280
- }
281
- exports . h5st = h5st ;
282
287
function getJxToken ( cookie , phoneId ) {
283
288
if ( phoneId === void 0 ) { phoneId = '' ; }
284
289
function generateStr ( input ) {
@@ -356,7 +361,7 @@ function randomWord(n) {
356
361
exports . randomWord = randomWord ;
357
362
function getshareCodeHW ( key ) {
358
363
return __awaiter ( this , void 0 , void 0 , function ( ) {
359
- var shareCodeHW , i , data , e_1 ;
364
+ var shareCodeHW , i , data , e_2 ;
360
365
return __generator ( this , function ( _a ) {
361
366
switch ( _a . label ) {
362
367
case 0 :
@@ -377,7 +382,7 @@ function getshareCodeHW(key) {
377
382
}
378
383
return [ 3 /*break*/ , 6 ] ;
379
384
case 4 :
380
- e_1 = _a . sent ( ) ;
385
+ e_2 = _a . sent ( ) ;
381
386
console . log ( "getshareCodeHW Error, Retry..." ) ;
382
387
return [ 4 /*yield*/ , wait ( getRandomNumberByRange ( 2000 , 6000 ) ) ] ;
383
388
case 5 :
@@ -394,7 +399,7 @@ function getshareCodeHW(key) {
394
399
exports . getshareCodeHW = getshareCodeHW ;
395
400
function getShareCodePool ( key , num ) {
396
401
return __awaiter ( this , void 0 , void 0 , function ( ) {
397
- var shareCode , i , data , e_2 ;
402
+ var shareCode , i , data , e_3 ;
398
403
return __generator ( this , function ( _a ) {
399
404
switch ( _a . label ) {
400
405
case 0 :
@@ -416,7 +421,7 @@ function getShareCodePool(key, num) {
416
421
}
417
422
return [ 3 /*break*/ , 6 ] ;
418
423
case 4 :
419
- e_2 = _a . sent ( ) ;
424
+ e_3 = _a . sent ( ) ;
420
425
console . log ( "getShareCodePool Error, Retry..." ) ;
421
426
return [ 4 /*yield*/ , wait ( getRandomNumberByRange ( 2000 , 6000 ) ) ] ;
422
427
case 5 :
0 commit comments