diff --git a/jd_bigwinner.py b/jd_bigwinner.py deleted file mode 100644 index 95aafaa..0000000 --- a/jd_bigwinner.py +++ /dev/null @@ -1,281 +0,0 @@ -# -*- 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()