mirror of
https://github.com/shufflewzc/faker2.git
synced 2025-04-23 02:48:44 +08:00
Create jd_bigwinner.py
This commit is contained in:
Faker
ooo
parent
355cb5ec2a
commit
96abbdc3d3
281
jd_bigwinner.py
Normal file
281
jd_bigwinner.py
Normal file
@ -0,0 +1,281 @@
|
||||
# -*- coding:utf-8 -*-
|
||||
"""
|
||||
Python 3.9.7
|
||||
作者：doubi
|
||||
日期：2022年10月30日
|
||||
注：脚本运行后会生成一个black.txt,之后如果出现车头pin找不到的情况下，请在black.txt搜索然后删除
|
||||
注意事项 pin 为助力pin 必须保证ck在里面
|
||||
作者要求 注释不能删除 否则后续不再更新
|
||||
作者授权发布KR库。搬运请完整保留注释。
|
||||
环境变量说明：
|
||||
export dyjpin="需要助力的pin值"
|
||||
|
||||
cron: 6 6 6 6 *
|
||||
new Env('赚钱大赢家');
|
||||
"""
|
||||
|
||||
import os
|
||||
import re
|
||||
import sys
|
||||
import time
|
||||
import uuid
|
||||
import json
|
||||
import random
|
||||
import logging
|
||||
import requests
|
||||
import traceback
|
||||
from hashlib import sha1
|
||||
from urllib.parse import quote_plus, unquote_plus, quote
|
||||
|
||||
activity_name = "京东极速版-赚钱大赢家"
|
||||
logging.basicConfig(
|
||||
level=logging.INFO,
|
||||
format="%(asctime)s %(levelname)s %(lineno)d %(message)s",
|
||||
datefmt="%H:%M:%S"
|
||||
)
|
||||
logger = logging.getLogger(activity_name)
|
||||
index = 0
|
||||
h5st_appid = 'd06f1'
|
||||
appCode = 'msc588d6d5'
|
||||
activeId = '63526d8f5fe613a6adb48f03'
|
||||
task_fn = ['打扫店铺']
|
||||
invite_taskId = None
|
||||
need_invite = 0
|
||||
not_tx = [0.3, 1, 3]
|
||||
black_user_file = 'black'
|
||||
|
||||
|
||||
class Userinfo:
|
||||
cookie_obj = []
|
||||
index = 0
|
||||
|
||||
def __init__(self, cookie):
|
||||
global index
|
||||
index += 1
|
||||
self.user_index = index
|
||||
self.cookie = cookie
|
||||
try:
|
||||
self.pt_pin = re.findall(r'pt_pin=(.*?);', self.cookie)[0]
|
||||
except Exception:
|
||||
logger.info(f"取值错误['pt_pin']：{traceback.format_exc()}")
|
||||
return
|
||||
self.name = unquote_plus(self.pt_pin)
|
||||
self.UA = 'jdltapp;iPhone;4.2.0;;;M/5.0;hasUPPay/0;pushNoticeIsOpen/1;lang/zh_CN;hasOCPay/0;appBuild/1217;supportBestPay/0;jdSupportDarkMode/0;ef/1;ep/%7B%22ciphertype%22%3A5%2C%22cipher%22%3A%7B%22ud%22%3A%22DtCzCNvwDzc4CwG0CWY2ZWTvENVwCJS3EJDvEWDsDNHuCNU2YJqnYm%3D%3D%22%2C%22sv%22%3A%22CJSkDy42%22%2C%22iad%22%3A%22C0DOGzumHNSjDJvMCy0nCUVOBJvLEOYjG0PNGzCmHOZNEJO2%22%7D%2C%22ts%22%3A1667286187%2C%22hdid%22%3A%22JM9F1ywUPwflvMIpYPok0tt5k9kW4ArJEU3lfLhxBqw%3D%22%2C%22version%22%3A%221.0.3%22%2C%22appname%22%3A%22com.360buy.jdmobile%22%2C%22ridx%22%3A-1%7D;Mozilla/5.0 (iPhone; CPU iPhone OS 12_7_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E126;supportJDSHWK/1'
|
||||
self.account_hot = False
|
||||
self.help_status = False
|
||||
Userinfo.cookie_obj.append(self)
|
||||
self.sha = sha1(str(self.pt_pin).encode('utf-8')).hexdigest()
|
||||
self.headers = {
|
||||
"Host": "wq.jd.com",
|
||||
"Cookie": self.cookie + f"sid={self.sha}",
|
||||
"User-Agent": self.UA,
|
||||
"Referer": f"https://wqs.jd.com/sns/202210/20/make-money-shop/guest.html?activeId={activeId}&type=sign&shareId=&__navVer=1",
|
||||
}
|
||||
self.shareUuid = ""
|
||||
self.invite_success = 0
|
||||
self.task_list = []
|
||||
self.need_help = False
|
||||
|
||||
def getData(self, task_name, shareId):
|
||||
url = f'https://wq.jd.com/makemoneyshop/{task_name}?g_ty=h5&g_tk=&appCode={appCode}&activeId={activeId}&shareId={shareId}&_stk=activeId,shareId&_ste=1&sceneval=2'
|
||||
res = requests.get(url=url, headers=self.headers, timeout=10).json()
|
||||
return res
|
||||
|
||||
def UserTask(self):
|
||||
home_res = self.getData('home', '')
|
||||
if home_res['code'] != 0:
|
||||
logger.info(f"车头账户[{self.name}]：{home_res['msg']}")
|
||||
return
|
||||
else:
|
||||
self.shareUuid = home_res['data']['shareId']
|
||||
logger.info(f"车头账户[{self.name}]：已获取助力码[{self.shareUuid}]")
|
||||
logger.info(f"车头账户[{self.name}]：当前营业币约[{home_res['data']['canUseCoinAmount']}]元")
|
||||
self.GetUserTaskStatusList()
|
||||
if self.need_help:
|
||||
logger.info(f"当前从{Userinfo.index}继续")
|
||||
for cookie in Userinfo.cookie_obj[Userinfo.index:]:
|
||||
if cookie.pt_pin == self.pt_pin:
|
||||
continue
|
||||
if cookie.account_hot:
|
||||
continue
|
||||
res = cookie.getData('guesthelp', self.shareUuid)
|
||||
if res['code'] == 147: # 火爆
|
||||
cookie.account_hot = True
|
||||
logger.info(f"工具人账户[{cookie.user_index}][{cookie.name}]：{res['msg']}")
|
||||
if res['code'] == 1007:
|
||||
logger.info(f"工具人账户[{cookie.user_index}][{cookie.name}]：{res['msg']}")
|
||||
if res['code'] == 1008:
|
||||
logger.info(f"工具人账户[{cookie.user_index}][{cookie.name}]：{res['msg']}")
|
||||
if str(res).find("助力任务已完成") > -1:
|
||||
self.reward(invite_taskId)
|
||||
if res['code'] == 0:
|
||||
self.reward(invite_taskId)
|
||||
self.invite_success += 1
|
||||
logger.info(f"工具人账户[{cookie.user_index}][{cookie.name}]：助力成功，当前助力成功{self.invite_success}次")
|
||||
|
||||
if self.invite_success >= need_invite:
|
||||
logger.info(f"车头账户[{self.name}]：助力已满")
|
||||
return self.exchange_query()
|
||||
Userinfo.index += 1
|
||||
# time.sleep(round(random.uniform(0.7, 1.3), 2))
|
||||
|
||||
else:
|
||||
return self.exchange_query()
|
||||
|
||||
def exchange_query(self):
|
||||
url = f'https://wq.jd.com/makemoneyshop/exchangequery?g_ty=h5&g_tk=&appCode={appCode}&activeId={activeId}&sceneval=2'
|
||||
res = requests.get(url=url, headers=self.headers).json()
|
||||
if res['code'] == 0:
|
||||
logger.info(f"车头账户[{self.name}]：获取微信提现信息成功")
|
||||
canUseCoinAmount = float(res['data']['canUseCoinAmount'])
|
||||
logger.info(f"车头账户[{self.name}]：当前余额[{canUseCoinAmount}]元")
|
||||
for data in res['data']['cashExchangeRuleList'][::-1]:
|
||||
if float(data['cashoutAmount']) not in not_tx:
|
||||
if canUseCoinAmount >= float(data['cashoutAmount']):
|
||||
logger.info(f"车头账户[{self.name}]：当前余额[{canUseCoinAmount}]元,符合提现规则[{data['cashoutAmount']}]门槛")
|
||||
rule_id = data['id']
|
||||
self.tx(rule_id)
|
||||
|
||||
else:
|
||||
logger.info(f"车头账户[{self.name}]：当前余额[{canUseCoinAmount}]元,不足提现[{data['cashoutAmount']}]门槛")
|
||||
else:
|
||||
logger.info(f"车头账户[{self.name}]：当前余额[{canUseCoinAmount}]元,不提现[{not_tx}]门槛")
|
||||
|
||||
def tx(self, rule_id):
|
||||
url = f'https://wq.jd.com/prmt_exchange/client/exchange?g_ty=h5&g_tk=&appCode={appCode}&bizCode=makemoneyshop&ruleId={rule_id}&sceneval=2'
|
||||
res = requests.get(url=url, headers=self.headers).json()
|
||||
if res['ret'] == 0:
|
||||
logger.info(f"车头账户[{self.name}]：提现成功")
|
||||
return True
|
||||
if res['ret'] == 232:
|
||||
logger.info(f"车头账户[{self.name}]：{res['msg']}")
|
||||
return False
|
||||
if res['ret'] == 604:
|
||||
logger.info(f"车头账户[{self.name}]：{res['msg']}")
|
||||
return True
|
||||
else:
|
||||
logger.info(f"车头账户[{self.name}]：{res}")
|
||||
|
||||
def GetUserTaskStatusList(self):
|
||||
global invite_taskId, need_invite
|
||||
url = f'https://wq.jd.com/newtasksys/newtasksys_front/GetUserTaskStatusList?g_ty=h5&g_tk=&appCode={appCode}&__t={getTime()}&source=makemoneyshop&bizCode=makemoneyshop&sceneval=2'
|
||||
res = requests.get(url=url, headers=self.headers, timeout=10).json()
|
||||
if res['ret'] == 0:
|
||||
msg = []
|
||||
for taskid, task in enumerate(res['data']['userTaskStatusList'], 1):
|
||||
taskName = task['taskName']
|
||||
reward = int(task['reward']) / 100
|
||||
taskId = task['taskId']
|
||||
configTargetTimes = task['configTargetTimes']
|
||||
status = str(task['gettaskStatus'])
|
||||
if taskName == '邀请好友打卡':
|
||||
self.invite_success = task['realCompletedTimes']
|
||||
if invite_taskId is None:
|
||||
invite_taskId = task['taskId']
|
||||
logger.info(f"已成功获取邀请好友打卡任务ID:{invite_taskId}")
|
||||
if need_invite == 0:
|
||||
need_invite = int(task['configTargetTimes'])
|
||||
if self.invite_success < need_invite:
|
||||
self.need_help = True
|
||||
logger.info(
|
||||
f"最高可邀请[{need_invite}]人,目前已邀请[{self.invite_success}]人,还需邀请[{int(need_invite) - int(self.invite_success)}]人")
|
||||
else:
|
||||
logger.info(f"最高可邀请[{need_invite}]人,目前已邀请[{self.invite_success}]人,助力已满，换号")
|
||||
|
||||
self.task_list.append(
|
||||
{
|
||||
"status": status,
|
||||
"taskName": taskName,
|
||||
"taskId": taskId,
|
||||
"configTargetTimes": configTargetTimes
|
||||
}
|
||||
)
|
||||
msg.append(
|
||||
f"{taskid} : {taskName} -- {reward}个营业币 -- {status.replace('1', '未完成').replace('2', '已完成')}")
|
||||
|
||||
print('\n'.join(msg))
|
||||
self.do_task()
|
||||
|
||||
def reward(self, taskId):
|
||||
url = f'https://wq.jd.com/newtasksys/newtasksys_front/Award?g_ty=h5&g_tk=&appCode={appCode}&__t={getTime()}&source=makemoneyshop&taskId={taskId}&bizCode=makemoneyshop&sceneval=2'
|
||||
self.headers[
|
||||
'Referer'] = f'https://wqs.jd.com/sns/202210/20/make-money-shop/index.html?activeId={activeId}&lng=118.389971&lat=24.974751&sid={self.sha}&un_area=16_1341_1343_44855'
|
||||
res = requests.get(url=url, headers=self.headers, timeout=10).json()
|
||||
if res['ret'] == 0:
|
||||
logger.info(f"车头账户[{self.name}]：领取成功")
|
||||
else:
|
||||
logger.info(f"车头账户[{self.name}]：{res['msg']}")
|
||||
|
||||
def do_task(self):
|
||||
for task in self.task_list:
|
||||
if task['taskName'] in task_fn and task['status'] != "2":
|
||||
logger.info(f"车头账户[{self.name}]：去做[{task['taskName']}]")
|
||||
self.reward(task['taskId'])
|
||||
|
||||
|
||||
def getTime():
|
||||
return int(time.time() * 1000)
|
||||
|
||||
|
||||
def black_user():
|
||||
if os.path.exists(f'{black_user_file}.txt'):
|
||||
with open(f'{black_user_file}.txt', 'r') as f:
|
||||
return f.read().split('&')
|
||||
else:
|
||||
with open(f'{black_user_file}.txt', 'a'):
|
||||
logger.info(f"文件:{black_user_file}不存在，创建")
|
||||
return []
|
||||
|
||||
|
||||
def del_black(pin):
|
||||
cookie_copy = Userinfo.cookie_obj.copy()
|
||||
for cookie in cookie_copy:
|
||||
if pin in cookie.pt_pin and pin != '':
|
||||
Userinfo.cookie_obj.remove(cookie)
|
||||
|
||||
|
||||
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')
|
||||
helpPin = os.environ.get('dyjpin', "")
|
||||
if helpPin == "":
|
||||
logger.info("您尚未填写'dyjpin'-- pin1&pin2&pin")
|
||||
sys.exit()
|
||||
try:
|
||||
helpPin = helpPin.split('&')
|
||||
except:
|
||||
logger.info("dyjpin填写格式错误，pin1&pin2&pin3")
|
||||
sys.exit()
|
||||
[Userinfo(cookie) for cookie in cookies]
|
||||
black = black_user()
|
||||
if black:
|
||||
del black[-1]
|
||||
for pin in black:
|
||||
del_black(pin)
|
||||
logger.info(f"共去除{len(black)}个黑名单pin")
|
||||
logger.info(f"当前剩余[{len(Userinfo.cookie_obj)}]个cookie可助力")
|
||||
inviterList = (
|
||||
[cookie_obj for cookie_obj in Userinfo.cookie_obj for name in helpPin if name in cookie_obj.pt_pin])
|
||||
if not inviterList:
|
||||
logger.info(f"没有找到车头:{helpPin}")
|
||||
sys.exit()
|
||||
logger.info(f"共找到[{len(inviterList)}]车头")
|
||||
for inviter in inviterList:
|
||||
logger.info(f"开启助力车头：{inviter.pt_pin}")
|
||||
inviter.UserTask()
|
||||
time.sleep(round(random.uniform(0.7, 1.3), 2))
|
||||
for cookie in Userinfo.cookie_obj:
|
||||
if cookie.account_hot:
|
||||
if cookie.pt_pin in str(black):
|
||||
continue
|
||||
if cookie.pt_pin in helpPin:
|
||||
continue
|
||||
with open(f'{black_user_file}.txt', 'a') as w:
|
||||
w.write(cookie.pt_pin + '&')
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
main()
|
||||
Loading…
Reference in New Issue
Block a user