#!/usr/bin/env python3 # -*- coding: utf-8 -* ''' 项目名称: JD-Script / 测试 Author: Curtin 功能：自动完成所有任务，如没完成，多跑几次，账号一助力Curtinlv，其余助力账号一 Date: 2022/1/15 05:30 TG交流 https://t.me/topstyle996 TG频道 https://t.me/TopStyle2021 cron: 20 11,20 21-29 1 * new Env('大牌好礼带回家1.21-1.29') 活动入口：https://lzdz1-isv.isvjcloud.com/dingzhi/customized/common/activity/5063373?activityId=dzlhkkkbblnt20220121&=&shareUuid=5c1e7599b34c4100bbc5b8968178591b ''' import requests import os import json import random, string import re import sys from time import sleep import datetime import time from urllib.parse import quote, unquote, quote_plus try: from jd_cookie import getJDCookie getCk = getJDCookie() except: print("请先下载依赖脚本后执行一次，\n下载链接：https://ghproxy.com/https://raw.githubusercontent.com/curtinlv/JD-Script/main/jd_tool_dl.py") sys.exit(3) g_name = '大牌好礼带回家1.21-1.29' get_url = 'https://gitee.com/curtinlv/Public/raw/master/kk/122-1.json' # 是否发送通知, 关闭通知：export kk_vip_isNotice="false" isNotice = "true" # 设置休眠最大时长 ，如60秒，export kk_vip_sleep="60" kk_vip_sleep = 10 allUserBean = {} if "isNotice" in os.environ: if len(os.environ["kk_vip_isNotice"]) > 1: isNotice = os.environ["kk_vip_isNotice"] if "kk_vip_sleep" in os.environ: if len(os.environ["kk_vip_sleep"]) > 0: kk_vip_sleep = float(os.environ["kk_vip_sleep"]) # 如果您有UA可填 UserAgent = '' activityId='dzlhkkkbblnt20220121' activityshopid='1000310642' jdActivityId='10724311' random_num = '5063373' master_shareUuid = '5c1e7599b34c4100bbc5b8968178591b' master_shareuserid4minipg = 'wqdHuFdMJj0bcG7ysk0r8mwklxRrP5C78lmKjh9Mn4avAmNuF4i+OHS9NlRdtagP' # url main_host='https://lzdz1-isv.isvjcloud.com' #1 getpin getMyPing_url = 'https://lzdz1-isv.isvjcloud.com/customer/getMyPing' #2 getUserInfo getUserInfo_url = 'https://lzdz1-isv.isvjcloud.com/wxActionCommon/getUserInfo' #3 accessLogWithAD_url = 'https://lzdz1-isv.isvjcloud.com/common/accessLogWithAD' pageUrl = 'https://lzdz1-isv.isvjcloud.com/dingzhi/customized/common/activity/' #4 活动活动详情 activityContent_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/linkgame/activity/content' #5 关注 followshop_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/opencard/follow/shop' #6 加购 addCart_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/opencard/addCart' #7 开卡 checkOpenCard_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/linkgame/checkOpenCard' # 检测开卡状态 #8 领券获取金币 sendAllCoupon_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/linkgame/sendAllCoupon' #9 获取金牌信息 list_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/linkgame/rank/list' #10 浏览 browseShops_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/opencard/browseGoods' #11 访问记录 insertCrmPageVisit_url = 'https://lzdz1-isv.isvjcloud.com/crm/pageVisit/insertCrmPageVisit' writePersonInfo_url = 'https://lzdz1-isv.isvjcloud.com/interaction/write/writePersonInfo' #12 抽奖 draw_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/opencard/draw' #13 奖品 record_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/linkgame/draw/record' #14 assist_status_url ='https://lzdz1-isv.isvjcloud.com/dingzhi/linkgame/assist/status' assist_url ='https://lzdz1-isv.isvjcloud.com/dingzhi/linkgame/assist' #15 商品 goodsCode_url= 'https://lzdz1-isv.isvjcloud.com/dingzhi/linkgame/task/opencard/info' # token isvObfuscator_body = f'body=%7B%22url%22%3A%22https%3A%5C/%5C/lzdz1-isv.isvjcloud.com%22%2C%22id%22%3A%22%22%7D&build=167874&client=apple&clientVersion=10.2.4&d_brand=apple&d_model=iPhone14%2C3&ef=1&eid=&ep=%7B%22ciphertype%22%3A5%2C%22cipher%22%3A%7B%22screen%22%3A%22CJS4DMeyDzc4%22%2C%22wifiBssid%22%3A%22%3D%22%2C%22osVersion%22%3A%22%3D%3D%22%2C%22area%22%3A%22%22%2C%22openudid%22%3A%22DtVwZtvvZJcmZwPtDtc5DJSmCtZvDzLsCzK2DJG2DtU1EWG5Dzc2ZK%3D%3D%22%2C%22uuid%22%3A%22aQf1ZRdxb2r4ovZ1EJZhcxYlVNZSZz09%22%7D%2C%22ts%22%3A1642831467%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&ext=%7B%22prstate%22%3A%220%22%7D&isBackground=N&joycious=60&lang=zh_CN&networkType=wifi&networklibtype=JDNetworkBaseAF&partner=apple&rfs=0000&scope=01&sign=1b8c6071cf4b01923fdb6c77ccfce7df&st=1642833227484&sv=112' # 获取请求头 buildheaders_url = f'https://lzdz1-isv.isvjcloud.com/dingzhi/customized/common/activity/6796577?activityId={activityId}&' def printf(*args): text = '' for i in args: text += str(i) print(text) sys.stdout.flush() def wait_time(a, b, msg=None): s1 = random.randint(a,b) s2 = random.randint(3,9) time_s = float(f'{s1}.{s2}') if msg: printf(f"{msg}\t等待时间：{time_s}s") time.sleep(time_s) ## 获取通知服务 class msg(object): def __init__(self, m): self.str_msg = m self.message() def message(self): global msg_info print(self.str_msg) try: msg_info = "{}\n{}".format(msg_info, self.str_msg) except: msg_info = "{}".format(self.str_msg) sys.stdout.flush() def getsendNotify(self, a=0): if a == 0: a += 1 try: url = 'https://gitee.com/curtinlv/Public/raw/master/sendNotify.py' response = requests.get(url) if 'curtinlv' in response.text: with open('sendNotify.py', "w+", encoding="utf-8") as f: f.write(response.text) else: if a < 5: a += 1 return self.getsendNotify(a) else: pass except: if a < 5: a += 1 return self.getsendNotify(a) else: pass def main(self): global send cur_path = os.path.abspath(os.path.dirname(__file__)) sys.path.append(cur_path) if os.path.exists(cur_path + "/sendNotify.py"): try: from sendNotify import send except: self.getsendNotify() try: from sendNotify import send except: print("加载通知服务失败~") else: self.getsendNotify() try: from sendNotify import send except: print("加载通知服务失败~") ################### msg("").main() def userAgent(): """ 随机生成一个UA :return: """ if not UserAgent: uuid = ''.join(random.sample('123456789abcdef123456789abcdef123456789abcdef123456789abcdef', 40)) iosVer = ''.join(random.sample(["14.5.1", "msg14.4", "14.3", "14.2", "14.1", "14.0.1", "13.7", "13.1.2", "13.1.1"], 1)) iPhone = ''.join(random.sample(["8", "9", "10", "11", "12", "13"], 1)) return f'jdapp;iPhone;10.0.4;{iosVer};{uuid};network/wifi;ADID/8679C062-A41A-4A25-88F1-50A7A3EEF34A;model/iPhone{iPhone},1;addressid/3723896896;appBuild/167707;jdSupportDarkMode/0' else: return UserAgent def isvObfuscator(ck): headers = { 'Connection': 'keep-alive', 'Accept-Encoding': 'gzip, deflate, br', 'Content-Type': 'application/x-www-form-urlencoded', 'User-Agent': 'JD4iPhone/167870%20(iPhone;%20iOS;%20Scale/3.00)', 'Cookie': ck, 'Host': 'api.m.jd.com', 'Referer': '', 'Accept-Language': 'zh-Hans-CN;q=1', 'Accept': '*/*' } url = 'https://api.m.jd.com/client.action?functionId=isvObfuscator' resp = requests.post(url=url, headers=headers, timeout=30, data=isvObfuscator_body).json() if resp['code'] == '0': return resp['token'] else: return '' def buildheaders(ck, shareUuid, shareuserid4minipg): sid = ''.join(random.sample('123456789abcdef123456789abcdef123456789abcdef123456789abcdef', 32)) # url = buildheaders_url + f'shareUuid={shareUuid}&adsource=null&shareuserid4minipg={shareuserid4minipg}&shopid={activityshopid}&sid={sid}&un_area=' url = f'https://lzdz1-isv.isvjcloud.com/dingzhi/customized/common/activity/{random_num}?activityId={activityId}&shareUuid={shareUuid}&adsource=null&shareuserid4minipg={shareuserid4minipg}&shopid=undefined' headers = { 'Accept-Encoding': 'gzip, deflate, br', 'Cookie': ck, 'Connection': 'keep-alive', 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8', 'Host': 'lzdz1-isv.isvjcloud.com', 'User-Agent': userAgent(), 'Accept-Language': 'zh-cn' } resp = requests.get(url, headers) LZ_TOKEN = re.findall(r'(LZ_TOKEN_KEY=.*?;).*?(LZ_TOKEN_VALUE=.*?;)', resp.headers['Set-Cookie']) return LZ_TOKEN[0][0]+LZ_TOKEN[0][1] def getMyPing(cookie, token, agin=1): sid = ''.join(random.sample('123456789abcdef123456789abcdef123456789abcdef123456789abcdef', 32)) url = getMyPing_url headers = { 'X-Requested-With': 'XMLHttpRequest', 'Connection': 'keep-alive', 'Accept-Encoding': 'gzip, deflate, br', 'Content-Type': 'application/x-www-form-urlencoded', 'Origin': main_host, 'User-Agent': userAgent(), 'Cookie': cookie, 'Host': 'lzdz1-isv.isvjcloud.com', 'Referer': buildheaders_url, 'Accept-Language': 'zh-cn', 'Accept': 'application/json' } body = f'userId={activityshopid}&token={token}&fromType=APP' resp = requests.post(url=url, headers=headers, timeout=30, data=body) try: nickname = resp.json()['data']['nickname'] secretPin = resp.json()['data']['secretPin'] headers = { 'X-Requested-With': 'XMLHttpRequest', 'Connection': 'keep-alive', 'Accept-Encoding': 'gzip, deflate, br', 'Content-Type': 'application/x-www-form-urlencoded', 'Origin': 'https://lzdz1-isv.isvjcloud.com', 'User-Agent': userAgent(), 'Cookie': cookie, 'Host': 'lzdz1-isv.isvjcloud.com', 'Referer': buildheaders_url, 'Accept-Language': 'zh-cn', 'Accept': 'application/json' } return headers, nickname, secretPin except Exception as e: # printf("建议请稍等再试~", e) if agin > 4: print(f"getMyPing {e}") return False, False, False else: wait_time(1, 2) agin += 1 return getMyPing(cookie, token, agin=agin) def accessLog(headers,pin, shareUuid, shareuserid4minipg): try: sid = ''.join(random.sample('123456789abcdef123456789abcdef123456789abcdef123456789abcdef', 32)) accbody = f'venderId={activityshopid}&code=99&pin={quote(pin)}&activityId={activityId}&pageUrl={quote(pageUrl)}{random_num}?activityId={activityId}&shareUuid={shareUuid}&adsource=null&shareuserid4minipg={quote(shareuserid4minipg)}&shopid={activityshopid}&sid=&un_area=&subType=app&adSource=null' # accbody = f'venderId={activityshopid}&code=99&pin={quote(pin)}&activityId={activityId}&pageUrl=https%3A%2F%2Flzdz1-isv.isvjcloud.com%2Fdingzhi%2Fcustomized%2Fcommon%2Factivity%3FactivityId={activityId}&sid={sid}&un_area=&subType=app&adSource=' url = accessLogWithAD_url resp = requests.post(url=url, headers=headers, timeout=30, data=accbody) if resp.status_code == 200: LZ_TOKEN = re.findall(r'(LZ_TOKEN_KEY=.*?;).*?(LZ_TOKEN_VALUE=.*?;)', resp.headers['Set-Cookie']) headers = { 'X-Requested-With': 'XMLHttpRequest', 'Connection': 'keep-alive', 'Accept-Encoding': 'gzip, deflate, br', 'Content-Type': 'application/x-www-form-urlencoded', 'Origin': 'https://lzdz1-isv.isvjcloud.com', 'User-Agent': userAgent(), 'Cookie': LZ_TOKEN[0][0] + LZ_TOKEN[0][1], 'Host': 'lzdz1-isv.isvjcloud.com', 'Referer': buildheaders_url, 'Accept-Language': 'zh-cn', 'Accept': 'application/json' } return headers else: return headers except Exception as e: printf(e) return headers def writePersonInfo(header, pin, at): try: url = writePersonInfo_url body = f'jdActivityId={jdActivityId}&pin={quote(pin)}&actionType={at}&venderId={activityshopid}&activityId={activityId}' resp = requests.post(url=url, headers=header, timeout=30, data=body) if resp.status_code == 200: pass except Exception as e: print("writePersonInfo",e) # 访问记录 def insertCrmPageVisit(header, pin,shop_value): url = insertCrmPageVisit_url body = f'venderId={activityshopid}&elementId={shop_value}&pageId={activityId}&pin={quote(pin)}' resp = requests.post(url=url, headers=header, timeout=30, data=body) if resp.status_code == 200: resp = resp.json() if resp['result']: pass # printf(f"insertCrmPageVisit ok") else: pass # assist_status def assist_status(header, pin,shareUuid, agin=1): try: url = assist_status_url body = f'activityId={activityId}&pin={quote(pin)}&shareUuid={shareUuid}' resp = requests.post(url=url, headers=header, timeout=30, data=body) if resp.status_code == 200: LZ_TOKEN = re.findall(r'(LZ_TOKEN_KEY=.*?;).*?(LZ_TOKEN_VALUE=.*?;)', resp.headers['Set-Cookie']) header['Cookie'] = LZ_TOKEN[0][0] + LZ_TOKEN[0][1] + f'AUTH_C_USER={quote(pin)};' else: pass return header except Exception as e: if agin > 6: print(f"assist {e}") return header else: wait_time(3, 10) agin += 1 return assist_status(header, pin,shareUuid, agin=agin) # 助力 def assist(header, pin,shareUuid, agin=1): try: header = assist_status(header, pin, shareUuid) url = assist_url body = f'activityId={activityId}&pin={quote(pin)}&shareUuid={shareUuid}' resp = requests.post(url=url, headers=header, timeout=30, data=body) if resp.status_code == 200: if resp.json()['result']: if resp.json()['data']['status'] == 200: printf("助力成功~") else: pass except Exception as e: if agin > 6: print(f"assist {e}") return None else: wait_time(3, 10) agin += 1 return assist(header, pin,shareUuid, agin=agin) def activityContent(header, pin, shareUuid, pinImg, nick, shareuserid4minipg, agin=1): url = activityContent_url try: pinImg = quote_plus(pinImg) except: pinImg = '' body = f'activityId={activityId}&pin={quote(pin)}&pinImg={pinImg}&nick={quote(nick)}&cjyxPin=&cjhyPin=&shareUuid=' header['Cookie'] += f'AUTH_C_USER={quote(pin)};' # header['Content-Length'] = 329 header['Referer'] = f'https://lzdz1-isv.isvjcloud.com/dingzhi/customized/common/activity/{random_num}?activityId={activityId}&shareUuid={shareUuid}&adsource=null&shareuserid4minipg={quote(shareuserid4minipg)}&shopid={activityshopid}&' try: resp = requests.post(url=url, headers=header, data=body) if resp.status_code == 200: resp = resp.json() actorUuid = resp['data']['actor']['actorUuid'] shareTitle = resp['data']['activity']['shareTitle'] score = resp['data']['actor']['score'] return actorUuid, shareTitle, score else: printf(f"activityContent req [{resp.text}]") return 0, '', 0 except Exception as e: if agin > 6: return 0, '', 0 else: # wait_time(30, 60, f"获取助力码失败，尝试重新获取{agin}") wait_time(10, 30) agin += 1 return activityContent(header, pin, shareUuid, pinImg, nick, shareuserid4minipg, agin=agin) # printf(f"activityContent {e}") def getUserInfo(header, pin, agin=1): try: url = getUserInfo_url body = 'pin=' + quote(pin) resp = requests.post(url=url, headers=header, data=body).json() yunMidImageUrl = resp['data']['yunMidImageUrl'] nickname = resp['data']['nickname'] secretPin = resp['data']['secretPin'] return yunMidImageUrl, secretPin, nickname except Exception as e: if agin > 6: printf(f"getUserInfo, {e}") return False, '', '' else: wait_time(3, 3) agin += 1 return getUserInfo(header, pin, agin=agin) def checkOpenCard(header, pin, agin=1): url = checkOpenCard_url body = f'pin={quote(pin)}&activityId={activityId}' allShopID = [] try: resp = requests.post(url=url, headers=header, data=body).json() # printf(json.dumps(resp, indent=4, ensure_ascii=False)) if resp['result']: # 检测是否完成开卡任务 allShopID openCardList = resp['data']['openCardList'] for i in openCardList: allShopID.append(i['venderId']) if resp['data']['allOpenCard']: printf("\t😆已完成开卡任务") return [], [], allShopID else: venderIdList = [] channelList = [] for i in openCardList: if i['status'] == 0: toUrl = i['toUrl'] venderId = re.findall(r'venderId=(\d+)', toUrl)[0] channel = re.findall(r'channel=(\d+)', toUrl)[0] venderIdList.append(venderId) channelList.append(channel) return venderIdList, channelList, allShopID else: printf(resp['errorMessage']) return [], [], allShopID except Exception as e: if agin > 6: printf(f"checkOpenCard, {e}") return [], [], allShopID else: wait_time(3, 3) agin += 1 return checkOpenCard(header, pin, agin=agin) # 抽奖 def draw(header, pin, actorUuid, user, agin=1): url = draw_url # body = f'activityId={activityId}&pin={quote(pin)}&{actorUuid}' body = f'activityId={activityId}&actorUuid={actorUuid}&pin={quote(pin)}' try: # printf("去抽奖！") resp = requests.post(url=url, headers=header, data=body) # printf(resp.status_code) if resp.status_code == 200: LZ_TOKEN = re.findall(r'(LZ_TOKEN_KEY=.*?;).*?(LZ_TOKEN_VALUE=.*?;)', resp.headers['Set-Cookie']) header['Cookie'] = LZ_TOKEN[0][0] + LZ_TOKEN[0][1] + f'AUTH_C_USER={quote(pin)};' # resp = resp.json() print(resp) if resp['result']: if resp['data']['drawOk']: printf(f"\t☺️[{user}]抽奖获得: {resp['data']['name']}️") else: printf(f"\t😭 没中奖~ [{resp['data']['name']}] {resp['data']['errorMessage']}") else: return None return header else: printf(f"{resp.text}") return None except Exception as e: if agin > 6: printf(f"draw, {e}") return None else: wait_time(3, 3) agin += 1 return draw(header, pin, actorUuid, user, agin=agin) # 奖品统计 def record(header, pin, actorUuid,user, agin=1): global allUserBean url = record_url body = f'activityId={activityId}&pin={quote(pin)}&{actorUuid}' try: resp = requests.post(url=url, headers=header, data=body) if resp.status_code == 200: resp = resp.json() if resp['result']: recordList = resp['data']['recordList'] if recordList: for i in recordList: if '京豆' in i['infoName']: beanNum = re.findall(r'(\d+)', i['infoName'])[0] try: allUserBean[f"{user}"] += int(beanNum) except: allUserBean[f"{user}"] = int(beanNum) else: try: allUserBean[f'{user}_yes'] += '+' + i['infoName'] except: allUserBean[f'{user}_yes'] = i['infoName'] else: printf(resp.text) except Exception as e: if agin > 6: printf(f"record, {e}") return else: wait_time(3, 3) agin += 1 return record(header, pin, actorUuid,user, agin=agin) # 关注 def followShop(header, pin, user, agin=1): try: url = followshop_url body = f'activityId={activityId}&pin={quote(pin)}' printf("#去完成关注任务~") resp = requests.post(url=url, headers=header, data=body).json() if resp['result']: printf(f"已完成关注任务") addScore = resp['data']['addScore'] addBeanNum = resp['data']['addBeanNum'] if addScore > 0: printf(f"\t☺️关注获得: {resp['data']['addScore']} 金币️") if addBeanNum > 0: printf(f"\t☺️关注获得: {resp['data']['addScore']} 京豆️") else: printf(f"\t😆{resp['errorMessage']}") except Exception as e: if agin > 6: printf(f"followShop, {e}") return else: wait_time(3, 3) agin += 1 return followShop(header, pin, user, agin=agin) # 获取浏览商品 def goodsCode(header, pin, user, agin=1): goodsCodeList = [] try: url = goodsCode_url body = f'activityId={activityId}&pin={quote(pin)}' resp = requests.post(url=url, headers=header, data=body).json() if resp['result']: addCartList = resp['data']['addCartList'] for i in addCartList: if i['status'] == 0: goodsCodeList.append(i['goodsCode']) return goodsCodeList except Exception as e: if agin > 6: printf(f"goodsCode_url, {e}") return goodsCodeList else: wait_time(3, 3) agin += 1 return goodsCode(header, pin, user, agin=agin) # 浏览 def browseShops(header, pin, shop_value, at, agin=1): try: elementId='' if at == '5': elementId = f'%E5%95%86%E5%93%81{shop_value}' elif at == '4': elementId = f'%E5%BA%97%E9%93%BA{shop_value}' insertCrmPageVisit(header, pin, elementId) writePersonInfo(header, pin, at) url = browseShops_url body = f'activityId={activityId}&pin={quote(pin)}&value={shop_value}' resp = requests.post(url=url, headers=header, data=body) if resp.status_code == 200: LZ_TOKEN = re.findall(r'(LZ_TOKEN_KEY=.*?;).*?(LZ_TOKEN_VALUE=.*?;)', resp.headers['Set-Cookie']) header['Cookie'] = LZ_TOKEN[0][0] + LZ_TOKEN[0][1] + f'AUTH_C_USER={quote(pin)};' resp = resp.json() if resp['result']: addScore = resp['data']['addScore'] addBeanNum = resp['data']['addBeanNum'] if addScore > 0: printf(f"\t☺️浏览获得: {resp['data']['addScore']} 金币️") else: printf(f"{resp}") if addBeanNum > 0: printf(f"\t☺️浏览获得: {resp['data']['addScore']} 京豆️") else: printf(f"\t😆{resp['errorMessage']}") return header else: printf(f"\t😆browseShops[{resp.text}]") return None except Exception as e: if agin > 6: printf(f"browseShops, {e}") return None else: wait_time(3, 3) agin += 1 return browseShops(header, pin, shop_value, agin=agin) # 加购 def addCart(header, pin, user, agin=1): try: url = addCart_url body = f'activityId={activityId}&pin={quote(pin)}' printf("#去完成加购任务~") resp = requests.post(url=url, headers=header, data=body).json() if resp['result']: printf(f"已完成加购任务") addScore = resp['data']['addScore'] addBeanNum = resp['data']['addBeanNum'] if addScore > 0: printf(f"\t☺️加购获得: {resp['data']['addScore']} 金币️") if addBeanNum > 0: printf(f"\t☺️加购获得: {resp['data']['addScore']} 京豆️") else: printf(f"\t😆{resp['errorMessage']}") except Exception as e: if agin > 6: printf(f"addCart {e}") return else: wait_time(10, 30) agin += 1 return addCart(header, pin, user, agin=agin) # 领券获取金币 def sendAllCoupon(header, pin, user, agin=1): try: url = sendAllCoupon_url body = f'activityId={activityId}&pin={quote(pin)}' printf("#去完成领券任务~") resp = requests.post(url=url, headers=header, data=body).json() if resp['result']: printf(f"已完成领券任务") addScore = resp['data']['addScore'] # addBeanNum = resp['data']['addBeanNum'] if addScore > 0: printf(f"\t☺️加购获得: {resp['data']['addScore']} 金币️") else: printf(f"\t😆{resp['errorMessage']}") except Exception as e: if agin > 6: printf(f"领券获取金币 {e}") return else: wait_time(10, 30) agin += 1 return sendAllCoupon(header, pin, user, agin=agin) # 获取金牌信息 def getlist(header, pin, user, agin=1): try: url = list_url scoreTotal, myRank = 0, 0 body = f'activityId={activityId}&pin={quote(pin)}' resp = requests.post(url=url, headers=header, data=body) if resp.status_code == 200: resp = resp.json() if resp['result']: scoreTotal = resp['data']['scoreTotal'] myRank = resp['data']['myRank'] return scoreTotal, myRank else: printf(f"\t😆{resp['errorMessage']}") return scoreTotal, myRank else: printf("getlist Error") return scoreTotal, myRank except Exception as e: if agin > 6: printf(f"getlist {e}") return else: wait_time(10, 30) agin += 1 return getlist(header, pin, user, agin=agin) def getShopOpenCardInfo(ck, venderId, channe, headers): url = f'https://api.m.jd.com/client.action?appid=jd_shop_member&functionId=getShopOpenCardInfo&body=%7B%22venderId%22%3A%22{venderId}%22%2C%22payUpShop%22%3Atrue%2C%22channel%22%3A{channe}%7D&client=H5&clientVersion=9.2.0&uuid=88888' sleep(0.5) # resp = requests.get(url=url, headers=headers).json() aginNum = 0 while True: resp = requests.get(url=url, headers=headers) if resp.status_code == 200: break aginNum += 1 if aginNum > 20: printf("开卡异常，请稍后再试~") break wait_time(3, 10) resp = resp.json() venderCardName = resp['result']['shopMemberCardInfo']['venderCardName'] # 店铺名称 printf(f'\t去开卡：{venderCardName}') if resp['result']['interestsRuleList']: activityId = resp['result']['interestsRuleList'][0]['interestsInfo']['activityId'] return activityId else: return None def bindWithVender(ck, venderIdList, channelList,pin,header): headers = { 'Cookie': ck, 'Accept': '*/*', 'Connection': 'keep-alive', 'Referer': 'https://shopmember.m.jd.com/', 'Accept-Encoding': 'gzip, deflate, br', 'Host': 'api.m.jd.com', 'User-Agent': userAgent(), 'Accept-Language': 'zh-CN,zh-Hans;q=0.9' } for v, c in zip(venderIdList, channelList): insertCrmPageVisit(header, pin, "%E5%85%A5%E4%BC%9A%E8%B7%B3%E8%BD%AC") wait_time(0,1) act = getShopOpenCardInfo(ck, v, c, headers) if act: bindWithVender_url = f'https://api.m.jd.com/client.action?appid=jd_shop_member&functionId=bindWithVender&body=%7B%22venderId%22%3A%22{v}%22%2C%22shopId%22%3A%22{v}%22%2C%22bindByVerifyCodeFlag%22%3A1%2C%22registerExtend%22%3A%7B%7D%2C%22writeChildFlag%22%3A0%2C%22activityId%22%3A{act}%2C%22channel%22%3A{c}%7D&client=H5&clientVersion=9.2.0&uuid=88888&' else: bindWithVender_url = f'https://api.m.jd.com/client.action?appid=jd_shop_member&functionId=bindWithVender&body=%7B%22venderId%22%3A%22{v}%22%2C%22bindByVerifyCodeFlag%22%3A1%2C%22registerExtend%22%3A%7B%7D%2C%22writeChildFlag%22%3A0%2C%22channel%22%3A{c}%7D&client=H5&clientVersion=9.2.0&uuid=88888' resp = requests.get(url=bindWithVender_url, headers=headers).json() if resp['success']: printf(f"\t\t└{resp['message']}, [{resp}]") else: pass def gettext(url): try: resp = requests.get(url, timeout=60).text if '该内容无法显示' in resp: return gettext(url) return resp except Exception as e: printf(e) def isUpdate(): global hdtitle, isEnable, readme, code, footer try: result = gettext(get_url) result = json.loads(result) hdtitle = result['title'] isEnable = result['isEnable'] readme = result['readme'] code = result['code'] footer = result['footer'] if isEnable == 0: code = code.split('#') s = random.randint(0, len(code) - 1) return True, hdtitle, readme, code[s], footer else: return False, hdtitle, readme, code, footer except: return False, f'{g_name}', '', f'{master_shareUuid}&{master_shareuserid4minipg}', 'TG频道 https://t.me/TopStyle2021\n活动入口：https://lzdz1-isv.isvjcloud.com/dingzhi/customized/common/activity/5063373?activityId=dzlhkkkbblnt20220121&=&shareUuid=5c1e7599b34c4100bbc5b8968178591b' def start(): global shareuserid4minipg, Masternickname, one_shareUuid, one_shareuserid4minipg, one_name if datetime.datetime.now() > datetime.datetime.strptime('2022-1-30', "%Y-%m-%d"): printf("活动结束\n请删掉脚本") exit(3) isok, hdtitle, readme, code, footer = isUpdate() if not isok and readme: printf(readme) exit(0) printf(f"开始：【{hdtitle}】") one_name = '仅账号一作者，其他全部助力账号一' one_shareUuid = code one_shareuserid4minipg = master_shareuserid4minipg cookieList, nameList = getCk.iscookie() a = 1 for ck, user in zip(cookieList, nameList): try: printf(f"##☺️账号{a}[{user}]，您好!") printf(f"\t└助力：[{one_name}] 助力码：{one_shareUuid}") try: cookie = buildheaders(ck, one_shareUuid, one_shareuserid4minipg) wait_time(1, 1) token = isvObfuscator(ck) except: printf(f"️##😭账号{a}【{user}】获取token异常, ip有可能给限制了~") a += 1 continue wait_time(1, 2) header, nickname, pin = getMyPing(cookie, token) if not header: if a == 1: printf(f"️##😭账号{a}【{user}】暂无法参加活动~") exit(2) else: printf(f"{user}:账号异常，不能参加活动") a += 1 continue wait_time(1, 3) # try: yunMidImageUrl, pin, nickname = getUserInfo(header, pin) if not yunMidImageUrl: if a == 1: printf(f"{user}:请检查账号是否正常~") exit(2) else: printf(f"{user}:账号异常，不能参加活动") a += 1 continue wait_time(1, 3) header = accessLog(header, pin, one_shareUuid, one_shareuserid4minipg) wait_time(1, 2) # 关注 followShop(header, pin, user) wait_time(1, 2) # 加购 addCart(header, pin, user) wait_time(2, 4) #领券获取金币 wait_time(2, 4) sendAllCoupon(header, pin, user) # 开卡 printf("#去完成开卡任务~") venderIdList, channelList, allShopID = checkOpenCard(header, pin) wait_time(1, 3) bindWithVender(ck, venderIdList, channelList, pin, header) # 浏览任务 goodsCodeList = goodsCode(header, pin, user) printf(f"#去做浏览任务") for i in goodsCodeList: wait_time(0, 1, f"浏览任务{i}") if header: header = browseShops(header, pin, i, '5') printf("\t😆已完成浏览任务") wait_time(2, 3) # printf(f"#去做底部浏览店铺任务") # for i in allShopID: # wait_time(1, 2, f"浏览任务{i}") # if header: # header = browseShops(header, pin, i, '4') # printf(f"已完成底部浏览店铺任务") # wait_time(2, 3) # 抽奖 # header = accessLog(header, pin, one_shareUuid, one_shareuserid4minipg) wait_time(1, 2) actorUuid, shareTitle, score = activityContent(header, pin, one_shareUuid, yunMidImageUrl, nickname, one_shareuserid4minipg) # printf(score) if score > 100: for i in range(int(score / 100)): wait_time(2, 4, f"点击抽奖{i+1}") if header: header = draw(header, pin, actorUuid, user) else: break if a == 1: if actorUuid == 0: printf("账号一获取助力码失败~，请重新尝试运行。") exit(1) one_shareUuid = actorUuid one_shareuserid4minipg = pin one_name = user wait_time(1, 2) printf(f"## {user} 的助力码 {actorUuid}") assist(header, pin, one_shareUuid) if not a == len(cookieList): a += 1 wait_time(kk_vip_sleep, kk_vip_sleep, "###休息一会") except Exception as e: printf(f"ERROR MAIN {e}") if a == 1: exit(0) a += 1 continue a = 1 printf("\n【收获统计】") scoreTotalList, myRankList, userList, scoreList = [],[],[],[] one_shareUuid = code one_shareuserid4minipg = master_shareuserid4minipg for ck, user in zip(cookieList, nameList): try: try: cookie = buildheaders(ck, one_shareUuid, one_shareuserid4minipg) wait_time(0, 1) token = isvObfuscator(ck) except: printf(f"️##😭账号{a}【{user}】获取token异常, ip有可能给限制了~") a += 1 continue wait_time(0, 1) header, nickname, pin = getMyPing(cookie, token) if not header: if a == 1: printf(f"️##😭账号{a}【{user}】暂无法参加活动~") exit(2) else: printf(f"{user}:账号异常，不能参加活动") a += 1 continue wait_time(0, 1) # try: wait_time(0, 1) actorUuid, shareTitle, score = activityContent(header, pin, one_shareUuid, '', nickname, one_shareuserid4minipg) # 获取金牌信息、排行榜 scoreTotal, myRank = getlist(header, pin, user) scoreTotalList.append(scoreTotal) scoreList.append(score) myRankList.append(myRank) userList.append(user) # 奖品 record(header, pin, actorUuid, user) assist(header, pin, one_shareUuid) if a == 1: one_shareUuid = actorUuid one_shareuserid4minipg = pin one_name = user a += 1 except Exception as e: printf(f"抽奖统计 {e}") a += 1 continue msg("*" * 40) allBean = 0 allJiangpin = "" n = 0 a = 1 for u in userList: try: msg(f"账号{a}[{u}] \n\t└当前金币{scoreList[n]} 累计金币{scoreTotalList[n]} 排名{myRankList[n]}") for m in allUserBean: if m == u: msg(f"\t\t└获得京豆: {allUserBean[u]}") allBean += allUserBean[u] if m == f'{u}_yes': msg(f"\t\t└获得奖品: {allUserBean[f'{u}_yes']}") allJiangpin += "+" + allUserBean[f'{u}_yes'] a += 1 n += 1 except: a += 1 n += 1 continue if allBean > 0: msg(f"总获得京豆: {allBean} ") if allJiangpin: msg(f"总获得奖品: {allJiangpin}") msg("*" * 40) msg(footer) if isNotice == "true": send(hdtitle, msg_info) if __name__ == '__main__': start()