From b21e1e39e70f1c0415e8fb83cdfe619f4c938219 Mon Sep 17 00:00:00 2001 From: dylan <58234511@qq.com> Date: Fri, 23 Jun 2023 16:43:24 +0800 Subject: [PATCH] 1 --- jd_health_exchange.py | 443 ------------------------------------------ 1 file changed, 443 deletions(-) delete mode 100644 jd_health_exchange.py diff --git a/jd_health_exchange.py b/jd_health_exchange.py deleted file mode 100644 index 5734e1d..0000000 --- a/jd_health_exchange.py +++ /dev/null @@ -1,443 +0,0 @@ -#!/bin/env python3 -# -*- coding: utf-8 -* -''' -Date: 2022-03-04 -cron: 5 0 0 * * * jd_health_exchange.py -new Env('健康社区兑换京豆'); -''' -#如果不想兑换京豆，ENV设置： export heath_noexchage='x' -# x填写数字，x对应cookies中第几个账号，如果中间有黑号，黑号不算。多个账号不兑换用&隔开，例如2&3&4 -heath_noexchage='' - -##############默认保留20W积分，18W积分才兑换20京豆############ -###想保留其他分数，ENV设置： export least='xxx' -least = 200000 - -# 20京豆id为4 -id = '4' - - -#每秒点击兑换次数...适当调整，手机会发烫 -#ENV设置： export dd_thread=30 -dd_thread = '10' - -UserAgent = '' - -import requests -import time,datetime -import requests,re,os,sys,random,json -from urllib.parse import quote, unquote -import threading -import urllib3 -#urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning) - -requests.packages.urllib3.disable_warnings() - - - - -today = datetime.datetime.now().strftime('%Y-%m-%d') -tomorrow=(datetime.datetime.now() + datetime.timedelta(days=1)).strftime('%Y-%m-%d') -starttime = '23:59:58.00000000' - -pwd = os.path.dirname(os.path.abspath(__file__)) + os.sep -path = pwd + "env.sh" - -script_name = '健康社区兑换-Python' - -jd_host='https://api.m.jd.com/' - -functionId='' - -body = '{}' - -uuid = '' - - -def printT(s): - print("[{0}]: {1}".format(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"), s)) - sys.stdout.flush() - -def getEnvs(label): - try: - if label == 'True' or label == 'yes' or label == 'true' or label == 'Yes': - return True - elif label == 'False' or label == 'no' or label == 'false' or label == 'No': - return False - except: - pass - try: - if '.' in label: - return float(label) - elif '&' in label: - return label.split('&') - elif '@' in label: - return label.split('@') - else: - return int(label) - except: - return label - - - -class getJDCookie(object): - - - # 检测cookie格式是否正确 - def getUserInfo(self, ck, pinName, userNum): - url = 'https://me-api.jd.com/user_new/info/GetJDUserInfoUnion?orgFlag=JD_PinGou_New&callSource=mainorder&channel=4&isHomewhite=0&sceneval=2&sceneval=2&callback=GetJDUserInfoUnion' - headers = { - 'Cookie': ck, - 'Accept': '*/*', - 'Connection': 'close', - 'Referer': 'https://home.m.jd.com/myJd/home.action', - 'Accept-Encoding': 'gzip, deflate, br', - 'Host': 'me-api.jd.com', - 'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/14.0.2 Mobile/15E148 Safari/604.1', - 'Accept-Language': 'zh-cn' - } - try: - resp = requests.get(url=url, verify=False, headers=headers, timeout=60).text - r = re.compile(r'GetJDUserInfoUnion.*?\((.*?)\)') - result = r.findall(resp) - userInfo = json.loads(result[0]) - nickname = userInfo['data']['userInfo']['baseInfo']['nickname'] - return ck, nickname - except Exception: - context = f"账号{userNum}【{pinName}】Cookie 已失效！请重新获取。" - printT(context) - return ck, False - - def iscookie(self): - """ - :return: cookiesList,userNameList,pinNameList - """ - cookiesList = [] - userNameList = [] - pinNameList = [] - if 'pt_key=' in cookies and 'pt_pin=' in cookies: - r = re.compile(r"pt_key=.*?pt_pin=.*?;", re.M | re.S | re.I) - result = r.findall(cookies) - if len(result) >= 1: - printT("您已配置{}个账号".format(len(result))) - u = 1 - for i in result: - r = re.compile(r"pt_pin=(.*?);") - pinName = r.findall(i) - pinName = unquote(pinName[0]) - # 获取账号名 - #ck, nickname = self.getUserInfo(i, pinName, u) - #if nickname != False: - cookiesList.append(i) - #userNameList.append(nickname) - pinNameList.append(pinName) - #else: - # u += 1 - # continue - #u += 1 - if len(cookiesList) > 0: - return cookiesList, userNameList, pinNameList - else: - printT("没有可用Cookie，已退出") - exit(3) - else: - printT("cookie 格式错误！...本次操作已退出") - exit(4) - else: - printT("cookie 格式错误！...本次操作已退出") - exit(4) -getCk = getJDCookie() -#getCk.getCookie() - -# 获取v4环境 特殊处理 -try: - with open(v4f, 'r', encoding='utf-8') as v4f: - v4Env = v4f.read() - r = re.compile(r'^export\s(.*?)=[\'\"]?([\w\.\-@#&=_,\[\]\{\}\(\)]{1,})+[\'\"]{0,1}$', - re.M | re.S | re.I) - r = r.findall(v4Env) - curenv = locals() - for i in r: - if i[0] != 'JD_COOKIE': - curenv[i[0]] = getEnvs(i[1]) -except: - pass - -############## 在pycharm测试ql环境用，实际用下面的代码运行 ######### -# with open(path, "r+", encoding="utf-8") as f: -# ck = f.read() -# if "JD_COOKIE" in ck: -# # r = re.compile (r"pt_key=.*?pt_pin=.*?;", re.M | re.S | re.I) -# # cookies = r.findall (ck) -# # cookies = cookies[0] -# # print(cookies) -# cookies = ck -# printT ("已获取并使用ck环境 Cookie") -######################################################################## - - -if "JD_COOKIE" in os.environ: - if len (os.environ["JD_COOKIE"]) > 1: - cookies = os.environ["JD_COOKIE"] - # temporary = cookies.split ('&') - # cookies = temporary[0] - printT ("已获取并使用Env环境 Cookie") - -if "heath_noexchage" in os.environ: - heath_noexchage = os.environ["heath_noexchage"] - printT(f"已获取并使用Env环境 heath_noexchage:{heath_noexchage}") - -if "least" in os.environ: - least = getEnvs(os.environ["least"]) - printT(f"已获取并使用Env环境 least:{least}") - - -heath_noexchage_list = heath_noexchage.split('&') - -def userAgent(): - """ - 随机生成一个UA - :return: jdapp;iPhone;9.4.8;14.3;xxxx;network/wifi;ADID/201EDE7F-5111-49E8-9F0D-CCF9677CD6FE;supportApplePay/0;hasUPPay/0;hasOCPay/0;model/iPhone13,4;addressid/2455696156;supportBestPay/0;appBuild/167629;jdSupportDarkMode/0;Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1 - """ - if not UserAgent: - uuid = ''.join(random.sample('123456789abcdef123456789abcdef123456789abcdef123456789abcdef', 40)) - addressid = ''.join(random.sample('1234567898647', 10)) - iosVer = ''.join( - random.sample(["14.5.1", "14.4", "14.3", "14.2", "14.1", "14.0.1", "13.7", "13.1.2", "13.1.1"], 1)) - iosV = iosVer.replace('.', '_') - iPhone = ''.join(random.sample(["8", "9", "10", "11", "12", "13"], 1)) - ADID = ''.join(random.sample('0987654321ABCDEF', 8)) + '-' + ''.join( - random.sample('0987654321ABCDEF', 4)) + '-' + ''.join(random.sample('0987654321ABCDEF', 4)) + '-' + ''.join( - random.sample('0987654321ABCDEF', 4)) + '-' + ''.join(random.sample('0987654321ABCDEF', 12)) - return f'jdapp;iPhone;10.0.4;{iosVer};{uuid};network/wifi;ADID/{ADID};supportApplePay/0;hasUPPay/0;hasOCPay/0;model/iPhone{iPhone},1;addressid/{addressid};supportBestPay/0;appBuild/167629;jdSupportDarkMode/0;Mozilla/5.0 (iPhone; CPU iPhone OS {iosV} like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1' - else: - return UserAgent -def difftime(): - heard={ - 'User-Agent':'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/108.0.0.0 Safari/537.36', - } - url="https://wq.jd.com/mcoss/servertime/getservertime?_=1664872855968&sceneval=2&g_login_type=1&callback=cb8216634&g_ty=ls&appCode=msc588d6d5" - resp=requests.get(url,headers=heard).text - res=re.match('.*\"serverTime\":\"(.*)\".*',resp).group(1) - sertime=int(time.mktime(time.strptime(res, '%Y/%m/%d %H:%M:%S'))*1000) - loctime=int(time.time()*1000) - return loctime-sertime -## 获取通知服务 -class msg(object): - def __init__(self, m=''): - self.str_msg = m - self.message() - def message(self): - global msg_info - printT(self.str_msg) - try: - msg_info = "{}\n{}".format(msg_info, self.str_msg) - except: - msg_info = "{}".format(self.str_msg) - sys.stdout.flush() #这代码的作用就是刷新缓冲区。 - # 当我们打印一些字符时，并不是调用print函数后就立即打印的。一般会先将字符送到缓冲区，然后再打印。 - # 这就存在一个问题，如果你想等时间间隔的打印一些字符，但由于缓冲区没满，不会打印。就需要采取一些手段。如每次打印后强行刷新缓冲区。 - 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: - printT("加载通知服务失败~") - else: - self.getsendNotify() - try: - from sendNotify import send - except: - printT("加载通知服务失败~") - ################### -msg().main() - - -def listcookie(): #将JDCookies.txt的cookies变成list[] - if 'pt_key=' in cookies and 'pt_pin=' in cookies: - r = re.compile(r"pt_key=.*?pt_pin=.*?;" , re.M | re.S | re.I) #r"" 的作用是去除转义字符. - result = r.findall(cookies) #输出为list列表 - if len(result) == 1: - return result - elif len(result)>1: - return result - else: - print("cookie 格式错误！...本次操作已退出") - exit(1) - else: - print("cookie 格式错误！...本次操作已退出") - exit(9) - -def setHeaders(cookie): - try: - r = re.compile(r"pt_pin=(.*?);") #指定一个规则：查找pt_pin=与;之前的所有字符,但pt_pin=与;不复制。r"" 的作用是去除转义字符. - userName = r.findall(cookie) #查找pt_pin=与;之前的所有字符，并复制给r，其中pt_pin=与;不复制。 - #print (userName) - userName = unquote(userName[0]) #r.findall(cookie)赋值是list列表，这个赋值为字符串 - #print(userName) - except Exception as e: - print(e,"cookie格式有误！") - exit(2) - headers = { - 'Origin': 'https://h5.m.jd.com', - 'Cookie': cookie, - 'Connection': 'keep-alive', - 'Accept': 'application/json, text/plain, */*', - 'Referer': 'https://h5.m.jd.com/', - 'Content-Type': 'application/x-www-form-urlencoded', - 'User-Agent': userAgent(), - 'Accept-Encoding': 'gzip, deflate', - 'Accept-Language': 'zh-cn' - } - return headers,userName - -#返回符合条件的ck list -def checkUser(cookies): - global goodsid, mid_time,afternoon_time - if isinstance(cookies,list): #isinstance() 函数来判断一个对象是否是一个已知的类型，类似 type()。此方法为：判断cookies是否为list[]列表，是返回True，否返回False - pass - elif isinstance(cookies,str): #判断cookies是否为str字符串，是返回True，否返回False - cookies = listcookie() - else: - print("cookie 类型有误") - exit(2) - cookieList=[] - #print(cookies) - user_num=1 - for i in cookies: - headers,userName = setHeaders(i) - try: - total_exchangePoints = cheak_points('jdhealth_getHomeData','{}',headers) - title,exchangePoints,bizMsg,bizCode = jdhealth_getCommodities('jdhealth_getCommodities','',headers) - if user_num == 1: - printT("您已设置兑换的商品：【{0}豆】 需要{1}积分".format(title, exchangePoints)) - print("********** 检测符合兑换要求的账号 ********** ") - if int(total_exchangePoints) > least: - total_exchangePoints = int(total_exchangePoints) - if not str(user_num) in heath_noexchage_list: - cookieList.append(i) #将够钱兑换的账号保存下来给cookieList[]，其余不够钱的账号剔除在外，不执行兑换 - printT(f"账号{user_num}:【{userName}】积分:{total_exchangePoints}...yes") - else: - total_exchangePoints = int (total_exchangePoints) - printT(f"账号{user_num}:【{userName}】积分:{total_exchangePoints}...no") - except Exception as e: - #printT(f"账号{user_num}:【{userName}】，该用户异常，查不到商品关键词【{Coupon}】，或者cookies已过期") - msg(f"账号{user_num}:【{userName}】，该用户异常，查不到商品id【{id}】") - # if '异常' in msg_info: - # send (script_name, msg_info) - # if len (cookies) == 1: - #exit (0) - user_num+=1 - if len (cookieList) > 0: - printT ("共有{0}个账号符合兑换条件".format (len (cookieList))) - return cookieList - else: - printT ("没有账号符合兑换要求，退出执行") - exit(0) -#查询总分 -def cheak_points(functionId,body,headers): - url = jd_host + '?' +'functionId=' + functionId + '&body=' + body + '&client=wh5&clientVersion=1.0.0&' + 'uuid=' + uuid - try: - respon = requests.post(url=url, verify=False, headers=headers) - result=respon.json() - #print(result) - total_exchangePoints = result['data']['result']['userScore'] #兑换所需分数 - return float(total_exchangePoints) - except Exception as e: - print(e) - -#查询 -def jdhealth_getCommodities(functionId,body,headers): - url = jd_host + '?' +'functionId=' + functionId + '&body=' + body + '&client=wh5&clientVersion=1.0.0&' + 'uuid=' + uuid - try: - respon = requests.post(url=url, verify=False, headers=headers) - result=respon.json() - title = result['data']['result']['jBeans'][3]['title'] - exchangePoints = result['data']['result']['jBeans'][3]['exchangePoints'] #兑换所需分数 - bizMsg = result['data']['bizMsg'] - bizCode = result['data']['bizCode'] - return title,exchangePoints,bizMsg,bizCode - except Exception as e: - print(e) - -#兑换 -def jdhealth_exchange(functionId,body,headers): - url = jd_host + '?' +'functionId=' + functionId + '&body=' + body + '&client=wh5&clientVersion=1.0.0&' + 'uuid=' + uuid - try: - respon = requests.post(url=url, verify=False, headers=headers) - result=respon.json() - #title = result['data']['result']['jingBeanNum'] - #userScore = result['data']['result']['userScore'] #剩余积分 - bizMsg = result['data']['bizMsg'] - bizCode = result['data']['bizCode'] - success = result['data']['success'] - if bizMsg == 'success' or bizCode == '0' : - printT("{0}...恭喜兑换成功！".format(bizMsg)) - return 0 - else: - printT(f"\t{bizMsg}" + ',兑换失败') #f 表达式----可以解析任意的数据类型。 \t表示空4格，相当于tab。 - return 999 - except Exception as e: - print(e) - -def start(): - print (f"############# 开始############ ") - cookiesList, userNameList, pinNameList = getCk.iscookie () - cookies1 = checkUser (cookiesList) # 将够钱兑换的账号保存下来给cookies，其余不够钱的账号剔除在外，不执行兑换 - final = 1 - diff=difftime() - tomorrow=datetime.date.today() + datetime.timedelta(days=1) - tomorrow=int(time.mktime(time.strptime(str(tomorrow), '%Y-%m-%d'))*1000) - print((tomorrow - int(time.time()*1000) + diff)/1000) - time.sleep((tomorrow - int(time.time()*1000) + diff)/1000) - while True: - print (f"\n【准备开始...】\n") - user_num = 1 - for i in cookies1: - headers, userName = setHeaders (i) - final = jdhealth_exchange ('jdhealth_exchange','{"commodityType":2,"commodityId":"4"}',headers) - user_num += 1 - if final == 0: - last_points = cheak_points ('jdhealth_getHomeData','',headers) - title, exchangePoints, bizMsg, bizCode = jdhealth_getCommodities ('jdhealth_getCommodities', '{}',headers) - # printT (f"账号{user_num}:【{userName}】剩余积分:{last_integration}...") - msg (f"账号{user_num}:【{userName}】成功兑换【{title}豆】，剩余积分:{last_points}...") - - elif final == 999: - pass - if user_num > len(cookies1): - break -if __name__ == '__main__': - print("脚本默认兑换20豆，18W分以上才兑换，具体修改教程可看脚本开头注释") - print ("\t\t【{}】".format (script_name)) - start () - if '成功兑换' in msg_info: - send (script_name, msg_info) \ No newline at end of file