#!/usr/bin/env python3 # -*- coding: utf-8 -* ''' 项目名称: JD-Script / 测试 Author: Curtin 功能： Date: 2022/1/11 下午20:10 TG交流 https://t.me/topstyle996 TG频道 https://t.me/TopStyle2021 cron: 20 0,6,12,15,20 10-28 1 * new Env('会员邀新赢万元礼包1.10-1.28') 活动入口：https://lzdz1-isv.isvjcloud.com/dingzhi/majorsuit/memberday/activity/1131759?activityId=dz2112100001448501&shareUuid=666fa61fec9a40aeb6b9368895a331eb&adsource=null&shareuserid4minipg=wqdHuFdMJj0bcG7ysk0r8mwklxRrP5C78lmKjh9Mn4avAmNuF4i+OHS9NlRdtagP&shopid=1000014485&sid=a5733e7cb49561529aac98f4366b2f4e&un_area= ''' 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) # 是否发送通知, 关闭通知：export kk_vip_isNotice="false" isNotice = "true" if "isNotice" in os.environ: if len(os.environ["kk_vip_isNotice"]) > 1: isNotice = os.environ["kk_vip_isNotice"] UserAgent = '' activityId='dz2112100001448501' activityshopid='1000014485' random_num = random.randint(1000000, 9999999) master_shareUuid = '666fa61fec9a40aeb6b9368895a331eb' master_shareuserid4minipg = 'wqdHuFdMJj0bcG7ysk0r8mwklxRrP5C78lmKjh9Mn4avAmNuF4i+OHS9NlRdtagP' # url activityContent_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/zyinvite/active/activityContent' checkOpenCard_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/zyinvite/active/checkOpenCard' getUserInfo_url = 'https://lzdz1-isv.isvjcloud.com/wxActionCommon/getUserInfo' accessLogWithAD_url = 'https://lzdz1-isv.isvjcloud.com/common/accessLogWithAD' saveTask_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/zyinvite/active/saveTask' drawContent_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/taskact/common/drawContent' getMyPing_url = 'https://lzdz1-isv.isvjcloud.com/customer/getMyPing' buildheaders_url = f'https://lzdz1-isv.isvjcloud.com/dingzhi/majorsuit/memberday/activity/{random_num}?activityId={activityId}&' insertCrmPageVisit_url = 'https://lzdz1-isv.isvjcloud.com/crm/pageVisit/insertCrmPageVisit' startDraw_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/zyinvite/active/startDraw' getDrawRecordHasCoupon_url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/taskact/common/getDrawRecordHasCoupon' isvObfuscator_body = 'body={"url":"https:\/\/lzdz1-isv.isvjcloud.com","id":""}&build=167874&client=apple&clientVersion=10.2.4&d_brand=apple&d_model=iPhone14,3&ef=1&ep={"ciphertype":5,"cipher":{"openudid":"DtVwZtvvZJcmZwPtDtc5DJSmCtZvDzLsCzK2DJG2DtU1EWG5Dzc2ZK=="},"ts":1641904234}&ext={"prstate":"0"}&isBackground=N&joycious=89&lang=zh_CN&networkType=wifi&networklibtype=JDNetworkBaseAF&sign=c17e30024df17c105a79566bd5ab5e75&st=1641905385115&sv=120' countbean = {} allList= [] def printf(*args): text = '' for i in args: text += i print(text) sys.stdout.flush() ## 获取通知服务 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 = { 'J-E-H': '%7B%22ciphertype%22:5,%22cipher%22:%7B%22User-Agent%22:%22IuG0aVLeb25vBzO2Dzq2CyUyCMrfUQrlbwU7TJSmaU9JTJSmCJUkCJivCtLJY2PiZI8zBtKmAG==%22%7D,%22ts%22:1636865800,%22hdid%22:%22JM9F1ywUPwflvMIpYPok0tt5k9kW4ArJEU3lfLhxBqw=%22,%22version%22:%221.0.3%22,%22appname%22:%22com.360buy.jdmobile%22,%22ridx%22:-1%7D', 'Connection': 'keep-alive', 'Accept-Encoding': 'gzip, deflate, br', 'Content-Type': 'application/x-www-form-urlencoded', 'User-Agent': 'JD4iPhone/167863%20(iPhone;%20iOS;%20Scale/3.00)', 'Cookie': ck, 'Host': 'api.m.jd.com', 'Referer': '', 'J-E-C': '%7B%22ciphertype%22:5,%22cipher%22:%7B%22pin%22:%22TUU5TJuyTJvQTUU3TUOnTJu1TUU1TUSmTUSnTUU2TJu4TUPQTUU0TUS4TJrOTUU1TUSmTJq2TUU1TUSmTUSn%22%7D,%22ts%22:1636884564,%22hdid%22:%22JM9F1ywUPwflvMIpYPok0tt5k9kW4ArJEU3lfLhxBqw=%22,%22version%22:%221.0.3%22,%22appname%22:%22com.360buy.jdmobile%22,%22ridx%22:-1%7D', '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=' 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']) LZ_TOKEN_KEY = re.findall(r'(LZ_TOKEN_KEY=.*?;)', resp.headers['Set-Cookie'])[0] LZ_TOKEN_VALUE = re.findall(r'(LZ_TOKEN_VALUE=.*?;)', resp.headers['Set-Cookie'])[0] return LZ_TOKEN[0][0]+LZ_TOKEN[0][1], LZ_TOKEN_KEY, LZ_TOKEN_VALUE def getMyPing(shareUuid, shareuserid4minipg, cookie, token,LZ_TOKEN_KEY, LZ_TOKEN_VALUE): 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': 'https://lzdz1-isv.isvjcloud.com', 'User-Agent': userAgent(), 'Cookie': cookie, 'Host': 'lzdz1-isv.isvjcloud.com', 'Referer': f'https://lzdz1-isv.isvjcloud.com/dingzhi/majorsuit/memberday/activity/{random_num}?activityId={activityId}&shareUuid={shareUuid}&adsource=null&shareuserid4minipg={shareuserid4minipg}&shopid={activityshopid}&sid={sid}&un_area=', 'Accept-Language': 'zh-CN,zh-Hans;q=0.9', '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'] # LZ_TOKEN_KEY = re.findall(r'(LZ_TOKEN_KEY=.*?;)', resp.headers['Set-Cookie'])[0] # LZ_TOKEN_VALUE = re.findall(r'(LZ_TOKEN_VALUE=.*?;)', resp.headers['Set-Cookie'])[0] # AUTH_C_USER = re.findall(r'(AUTH_C_USER=.*?;)', resp.headers['Set-Cookie'])[0] 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_KEY+LZ_TOKEN_VALUE + AUTH_C_USER + '__jd_ref_cls=Mnpm_ComponentApplied; mba_muid=16376427422281457677509.801.1637642928827; mba_sid=801.14; __jda=60969652.16376427422281457677509.1637642742.1637642742.1637642742.1; __jdb=60969652.5.16376427422281457677509|1.1637642742; __jdc=60969652; __jdv=60969652%7Ckong%7Ct_2011739974_%7Cjingfen%7C394dd4aa2cef4f9cbf65939ceda8cc4c%7C1637577535593; pre_seq=7; pre_session=809409cbd5bb8a0fa8fff41378c1afe91b8075ad|2225', 'Cookie': LZ_TOKEN_KEY+LZ_TOKEN_VALUE, 'Host': 'lzdz1-isv.isvjcloud.com', 'Referer': f'https://lzdz1-isv.isvjcloud.com/dingzhi/zyinvite/active/activity/{random_num}?activityId={activityId}&shareUuid={shareUuid}&adsource=null&shareuserid4minipg={shareuserid4minipg}&shopid={activityshopid}&sid={sid}&un_area=19_1601_3633_63243', 'Accept-Language': 'zh-cn', 'Accept': 'application/json' } return headers, nickname, secretPin except Exception as e: # printf("建议请稍等再试~", e) return False, False, False def accessLog(headers,pin, shareUuid, shareuserid4minipg, AUTH_C_USER): sid = ''.join(random.sample('123456789abcdef123456789abcdef123456789abcdef123456789abcdef', 32)) accbody = f'venderId={activityshopid}&code=99&pin={quote(pin)}&activityId={activityId}&pageUrl=https://lzdz1-isv.isvjcloud.com/dingzhi/zyinvite/active/activity/{random_num}?activityId={activityId}&shareUuid={shareUuid}&adsource=null&shareuserid4minipg={quote(shareuserid4minipg)}&shopid={activityshopid}&sid=&un_area=&subType=app&adSource=null' url = accessLogWithAD_url resp = requests.post(url=url, headers=headers, timeout=30, data=accbody) if resp.status_code == 200: LZ_TOKEN_KEY = re.findall(r'(LZ_TOKEN_KEY=.*?;)', resp.headers['Set-Cookie'])[0] LZ_TOKEN_VALUE = re.findall(r'(LZ_TOKEN_VALUE=.*?;)', resp.headers['Set-Cookie'])[0] 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_KEY + LZ_TOKEN_VALUE + AUTH_C_USER, 'Host': 'lzdz1-isv.isvjcloud.com', 'Referer': f'https://lzdz1-isv.isvjcloud.com/dingzhi/zyinvite/active/activity/{random_num}?activityId={activityId}&shareUuid={shareUuid}&adsource=null&shareuserid4minipg={shareuserid4minipg}&shopid={activityshopid}&sid={sid}&un_area=', 'Accept-Language': 'zh-cn', 'Accept': 'application/json' # 'Content-Length': '295' } # printf('\t└accessLog ---> success') return headers else: # printf('\t└accessLog ---> error') pass def activityContent(header, pin, shareUuid, pinImg, nick): 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={shareUuid}' resp = requests.post(url=url, headers=header, data=body).json() try: # printf(json.dumps(resp, indent=4, ensure_ascii=False)) actorUuid = resp['data']['actorUuid'] shareTitle = resp['data']['shareTitle'] return actorUuid, shareTitle except: return None, None def getUserInfo(header, pin): 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 def checkOpenCard(header, actorUuid,shareUuid, pin): url = checkOpenCard_url body = f'activityId={activityId}&actorUuid={actorUuid}&shareUuid={shareUuid}&pin={quote(pin)}' resp = requests.post(url=url, headers=header, data=body).json() # printf(json.dumps(resp, indent=4, ensure_ascii=False)) openCard1 = resp['data']['openCard1'] # openCard2 = resp['data']['openCard2'] # score1 = resp['data']['score1'] # score2 = resp['data']['score2'] venderIdList=[] channelList=[] if not openCard1: cardList1 = resp['data']['cardList1'] for i in cardList1: 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) # if not openCard2: # cardList2 = resp['data']['cardList2'] # for i in cardList2: # 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 def saveTask(header, pin, actorUuid, user, shareUuid): global countbean url = saveTask_url # body = f'activityId={activityId}&pin={quote(pin)}&actorUuid={actorUuid}&taskType=2&taskValue=100015195341' body = f'activityId={activityId}&actorUuid={actorUuid}&pin={quote(pin)}&taskType=23&taskValue=&shareUuid={shareUuid}' printf("#去完关注任务~") resp = requests.post(url=url, headers=header, data=body).json() # printf(resp) if resp['result']: bean = resp['data']['addBeanNum'] # printf(f"\t☺️加购获得: {bean} 豆 ") printf(f"\t☺️关注完成") try: countbean[user] += resp['data']['addBeanNum'] except: countbean[user] = resp['data']['addBeanNum'] else: printf(f"\t😆{resp['errorMessage']}") def drawContent(header, pin): url = drawContent_url body = f'activityId={activityId}&pin={quote(pin)}' resp = requests.post(url=url, headers=header, data=body) def startDraw(header, actorUuid, pin, user,winery): global countbean try: for drawType in range(4): drawType += 1 drawContent(header, pin) sleep(1) url = startDraw_url body = f'activityId={activityId}&pin={quote(pin)}&actorUuid={actorUuid}b&winery={winery}&drawType={drawType}' resp = requests.post(url=url, headers=header, data=body) resp = resp.json() if resp['result']: if resp['data']['drawOk']: printf(f"\t☺️[{user}]抽奖获得: {resp['data']['name']} ️") else: printf(f"\t😭抽奖获得: {resp['data']['name']} ") # return True else: printf(f"\t😆{resp['errorMessage']}") return False return True except: return False # def followShop(header, actorUuid, pin, shareUuid, user): global countbean url = 'https://lzdz1-isv.isvjcloud.com/dingzhi/zyinvite/active/followShop' body = f'activityId={activityId}&pin={quote(pin)}&actorUuid={actorUuid}&taskType=23&taskValue={activityshopid}&shareUuid={shareUuid}' printf("#去完成关注任务~") resp = requests.post(url=url, headers=header, data=body).json() # printf(resp) if resp['result']: if resp['data']['sendStatus']: printf(f"\t☺️关注获得: {resp['data']['addBeanNum']} 豆️") try: countbean[user] += resp['data']['addBeanNum'] except: countbean[user] = resp['data']['addBeanNum'] else: printf(f"\t😭关注获得: {resp['data']['addBeanNum']} 豆 ") else: printf(f"\t😆{resp['errorMessage']}") def insertCrmPageVisit(header, pin, num): # url = 'https://lzdz1-isv.isvjcloud.com/crm/pageVisit/insertCrmPageVisit' url = insertCrmPageVisit_url body = f'venderId={activityshopid}&elementId=%E5%8E%BB%E5%BC%80%E{num}%8D%A15&pageId={activityId}&pin={quote(pin)}' resp = requests.post(url=url, headers=header, data=body) if resp.status_code == 200: printf(f'\t└模拟点击去开卡{num+1} ---> success') else: printf(f'\t└模拟点击去开卡{num+1} ---> error') 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: print("开卡异常，请稍后再试~") exit(3) time.sleep(1.5) 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): 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): 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']}") else: pass def getCode(): try: url = 'https://gitee.com/curtinlv/Public/raw/master/code.txt' response = requests.get(url) code = response.text if response.status_code == 200 and len(code) > 30: return code else: return 'wqdHuFdMJj0bcG7ysk0r8mwklxRrP5C78lmKjh9Mn4avAmNuF4i+OHS9NlRdtagP' except: return 'wqdHuFdMJj0bcG7ysk0r8mwklxRrP5C78lmKjh9Mn4avAmNuF4i+OHS9NlRdtagP' 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 url = 'https://gitee.com/curtinlv/Public/raw/master/kk/vip.json' try: result = gettext(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, '会员邀新赢万元年货大礼包1.10-1.28', '', f'{master_shareUuid}&{master_shareuserid4minipg}', '\nTG频道 https://t.me/TopStyle2021\n活动入口：https://lzdz1-isv.isvjcloud.com/dingzhi/majorsuit/memberday/activity/1131759?activityId=dz2112100001448501&shareUuid=666fa61fec9a40aeb6b9368895a331eb&adsource=null&shareuserid4minipg=wqdHuFdMJj0bcG7ysk0r8mwklxRrP5C78lmKjh9Mn4avAmNuF4i+OHS9NlRdtagP&shopid=1000014485&sid=a5733e7cb49561529aac98f4366b2f4e&un_area=' def getDrawRecordHasCoupon(headers, pin, actorUuid, user): try: url = getDrawRecordHasCoupon_url body = f'activityId={activityId}&pin={quote(pin)}&actorUuid={actorUuid}' resp = requests.post(url=url, headers=headers, timeout=30, data=body).json() allcount = {} if resp['result']: data = resp['data'] a = 0 for i in data: if a == 0: a = 1 allcount['id'] = user if '京豆' in i['infoName']: beanNum = re.findall(r'(\d+)', i['infoName'])[0] try: allcount[i['value'] + '京豆'] += int(beanNum) except: allcount[i['value'] + '京豆'] = int(beanNum) else: try: allcount['礼品'] += '+' + i['infoName'] except: allcount['礼品'] = i['infoName'] allList.append(allcount) except: pass def start(): global shareuserid4minipg, Masternickname, shareUuid if datetime.datetime.now() > datetime.datetime.strptime('2022-1-29', "%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}】") shareUuid = code.split("&")[0] shareuserid4minipg = code.split("&")[1] cookieList, nameList = getCk.iscookie() a = 1 for ck, user in zip(cookieList, nameList): printf(f"##☺️用户{a}【{user}】") try: cookie, LZ_TOKEN_KEY, LZ_TOKEN_VALUE = buildheaders(ck, shareUuid, shareuserid4minipg) sleep(0.2) token = isvObfuscator(ck) except: printf(f"️##😭用户{a}【{user}】获取token异常, ip有可能给限制了~") a += 1 continue sleep(0.1) try: header, nickname, pin = getMyPing(shareUuid, shareuserid4minipg, cookie, token,LZ_TOKEN_KEY, LZ_TOKEN_VALUE) except: printf(f"️##😭用户{a}【{user}】暂无法参加活动，或请检查账号cookie是否有效~") a += 1 continue sleep(0.3) try: yunMidImageUrl, pin, nickname = getUserInfo(header, pin) # sleep(0.3) # header = accessLog(header, pin, shareUuid, shareuserid4minipg, AUTH_C_USER) sleep(0.3) actorUuid, shareTitle = activityContent(header, pin, shareUuid, yunMidImageUrl, nickname) # 关注 sleep(0.3) # followShop(header, actorUuid, pin, shareUuid, user) saveTask(header, pin, actorUuid, user, shareUuid) # 加购 # sleep(0.3) # saveTask(header, pin, actorUuid, user) printf("#去完成开卡任务~") # 开卡 venderIdList, channelList = checkOpenCard(header, actorUuid, shareUuid, pin) if len(venderIdList) > 0: for i in range(8): sleep(1) insertCrmPageVisit(header, pin, i) bindWithVender(ck, venderIdList, channelList) # printf("#去抽奖~") # try: # for i in range(13): # sleep(1) # startDraw(header, actorUuid, pin, user, i+1) # except: # pass else: printf("\t😆开卡任务已完成!") if a == 1: printf(f"用户{a}[{nickname}]>助力>>[Author]{shareUuid}") shareuserid4minipg = pin shareUuid = actorUuid Masternickname = nickname Masterheader = header a += 1 print(f"[{nickname}]的助力码:{shareUuid}") continue printf(f"用户{a}[{nickname}]>>助力>>>[{Masternickname}]{shareUuid}") sleep(1) a += 1 print(f"[{nickname}]的助力码:{shareUuid}") except: a += 1 continue # 用户1抽奖 try: print("用户1抽奖") for i in range(13): sleep(1) result = startDraw(Masterheader, shareUuid, shareuserid4minipg, Masternickname, i + 1) if not result: break except: pass # end a = 1 print("\n【抽奖统计】") shareUuid = master_shareUuid shareuserid4minipg = master_shareuserid4minipg for ck, user in zip(cookieList, nameList): printf(f"##☺️用户{a}【{user}】") try: cookie, LZ_TOKEN_KEY, LZ_TOKEN_VALUE = buildheaders(ck, shareUuid, shareuserid4minipg) sleep(0.2) token = isvObfuscator(ck) except: printf(f"️##😭用户{a}【{user}】获取token异常, ip有可能给限制了~") a += 1 continue sleep(0.1) try: header, nickname, pin = getMyPing(shareUuid, shareuserid4minipg, cookie, token,LZ_TOKEN_KEY, LZ_TOKEN_VALUE) sleep(0.3) yunMidImageUrl, pin, nickname = getUserInfo(header, pin) # sleep(0.3) # header = accessLog(header, pin, shareUuid, shareuserid4minipg, AUTH_C_USER) sleep(0.3) actorUuid, shareTitle = activityContent(header, pin, shareUuid, yunMidImageUrl, nickname) except: printf(f"️##😭用户{a}【{user}】暂无法参加活动，或请检查账号cookie是否有效~") a += 1 continue if a == 1: shareUuid = actorUuid shareuserid4minipg = pin getDrawRecordHasCoupon(header, pin, actorUuid, user) a += 1 msg("*"*40) msg("### 【本次】") allbean = 0 for k in countbean: msg(f"用户[{k}], 获得京豆:{countbean[k]}") allbean += countbean[k] msg("*" * 40) msg("### 【累计】") allUserBean = 0 liwuCount = '' for c in allList: usetBean = 0 try: msg(f"用户{nameList.index(c['id'])+1} [{c['id']}]累计获得京豆:") for i in c: if i == 'id': continue msg(f"\t└{i}: {c[i]}") if '京豆' in i: usetBean += c[i] allUserBean += c[i] if '+' in i: liwuCount += c[i] msg(f"\t└累计获得京豆: {usetBean}") except: continue msg('-'*20) msg(f"本次总获得: {allbean} 京豆") msg(f"累计总获得: {allUserBean} 京豆") if liwuCount: msg(f"恭喜您获得礼物: {liwuCount}") msg("*" * 40) msg(footer) if isNotice == "true": send(hdtitle, msg_info) if __name__ == '__main__': start()