mirror of https://github.com/KingRan/KR.git
364 lines
16 KiB
Python
364 lines
16 KiB
Python
#!/bin/env python3
|
||
# -*- coding: utf-8 -*
|
||
'''
|
||
|
||
感谢CurtinLV提供的其他脚本供我参考
|
||
感谢aburd ch大佬的指导抓包
|
||
项目名称:jd_health_exchange.py
|
||
Author: 一风一燕
|
||
功能：健康兑换
|
||
Date: 2021-12-19
|
||
cron: 1 0 0 * * * jd_health_exchange.py
|
||
new Env('健康兑换');
|
||
|
||
2022-1-7 updata:兑换改版，更新脚本
|
||
|
||
2022-1-9 updata:
|
||
更新多线程兑换，对于exchange_jkd_numb=4的人更加友好。
|
||
|
||
|
||
****************滴滴出行APP*******************
|
||
|
||
|
||
【教程】：
|
||
|
||
青龙变量exchange_jkd_numb="1"的话，兑换100健康豆，1福利金
|
||
青龙变量exchange_jkd_numb="2"的话，兑换5000健康豆，50福利金
|
||
青龙变量exchange_jkd_numb="3"的话，兑换10000健康豆，100福利金
|
||
青龙变量exchange_jkd_numb="4"的话，兑换150000健康豆，150福利金
|
||
|
||
需要自行用手机抓取Didi_jifen_token。
|
||
在青龙变量中添加变量Didi_jifen_token
|
||
多个账号时，Didi_jifen_token，用&隔开，例如Didi_jifen_token="xxxxx&xxxx"
|
||
|
||
手机抓包后，手动点击多看多赚，签到一次后，查看URL，https://res.xiaojukeji.com/sigma/api/step/sign/v2?wsgsig=
|
||
再查看表头，ticket就是需要抓的变量了
|
||
|
||
在青龙变量中添加变量Didi_jifen_token="xxxx",xxx就是上面抓的ticker复制下来就OK了
|
||
|
||
|
||
|
||
cron时间填写：1 0 0 * * *
|
||
|
||
|
||
'''
|
||
|
||
|
||
Didi_jifen_token = ''
|
||
exchange_jkd_numb = 2
|
||
total_exchange = 5000
|
||
FLJ = 50
|
||
'''
|
||
|
||
|
||
=================================以下代码不懂不要随便乱动=================================
|
||
|
||
|
||
'''
|
||
tokens = ''
|
||
account = 1
|
||
|
||
try:
|
||
import requests
|
||
import json,sys,os,re
|
||
import time,datetime
|
||
from urllib.parse import quote, unquote
|
||
import threading
|
||
except Exception as e:
|
||
print(e)
|
||
|
||
requests.packages.urllib3.disable_warnings()
|
||
|
||
|
||
pwd = os.path.dirname(os.path.abspath(__file__)) + os.sep
|
||
path = pwd + "env.sh"
|
||
today = datetime.datetime.now().strftime('%Y-%m-%d')
|
||
tomorrow=(datetime.datetime.now() + datetime.timedelta(days=1)).strftime('%Y-%m-%d')
|
||
|
||
#开始抢兑时间
|
||
starttime='00:01:00.00000000'
|
||
#结束时间
|
||
endtime='00:01:20.00000000'
|
||
|
||
qgtime = '{} {}'.format (today, starttime)
|
||
qgendtime = '{} {}'.format (today, endtime)
|
||
|
||
|
||
|
||
|
||
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
|
||
|
||
############## 在pycharm测试ql环境用，实际用下面的代码运行 #########
|
||
|
||
# with open(path, "r+", encoding="utf-8") as f:
|
||
# ck = f.read()
|
||
# tokens = ck
|
||
# if "Didi_jifen_token" in ck:
|
||
# r = re.compile (r'Didi_jifen_token="(.*?)"', re.M | re.S | re.I)
|
||
# tokens = r.findall(ck)
|
||
# tokens = tokens[0].split ('&')
|
||
# if len (tokens) == 1:
|
||
# Didi_jifen_token = tokens[0]
|
||
# tokens = ''
|
||
# # print(tokens)
|
||
# # tokens = cookies[3]
|
||
# else:
|
||
# pass
|
||
# printT ("已获取并使用ck环境 token")
|
||
|
||
########################################################################
|
||
|
||
if "Didi_jifen_token" in os.environ:
|
||
print(len (os.environ["Didi_jifen_token"]))
|
||
if len (os.environ["Didi_jifen_token"]) > 319:
|
||
tokens = os.environ["Didi_jifen_token"]
|
||
tokens = tokens.split ('&')
|
||
# tokens = tokens.split ('&')
|
||
# cookies = temporary[0]
|
||
printT ("已获取并使用Env环境Didi_jifen_token")
|
||
else:
|
||
Didi_jifen_token = os.environ["Didi_jifen_token"]
|
||
else:
|
||
print("检查变量Didi_jifen_token是否已填写")
|
||
|
||
if "exchange_jkd_numb" in os.environ:
|
||
exchange_jkd_numb = os.environ["exchange_jkd_numb"]
|
||
if exchange_jkd_numb == '1':
|
||
total_exchange = 100
|
||
FLJ = 1
|
||
elif exchange_jkd_numb == '2':
|
||
total_exchange = 5000
|
||
FLJ = 50
|
||
elif exchange_jkd_numb == '3':
|
||
total_exchange = 10000
|
||
FLJ = 100
|
||
elif exchange_jkd_numb == '4':
|
||
total_exchange = 15000
|
||
FLJ = 150
|
||
else:
|
||
printT (f"环境变量exchange_jkd_numb填写错误")
|
||
exit(0)
|
||
printT (f"已获取并使用Env环境exchange_jkd_numb，兑换{FLJ}福利金，需要{total_exchange}健康豆")
|
||
else:
|
||
print("变量exchange_jkd_numb未填写，默认兑换500福利金，需要5000健康豆")
|
||
|
||
## 获取通知服务
|
||
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()
|
||
|
||
|
||
#获取xpsid
|
||
def get_xpsid():
|
||
try:
|
||
url = f'https://v.didi.cn/p/DpzAd35?appid=10000&lang=zh-CN&clientType=1&trip_cityid=21&datatype=101&imei=99d8f16bacaef4eef6c151bcdfa095f0&channel=102&appversion=6.2.4&trip_country=CN&TripCountry=CN&lng=113.812538&maptype=soso&os=iOS&utc_offset=480&access_key_id=1&deviceid=99d8f16bacaef4eef6c151bcdfa095f0&phone=UCvMSok42+5+tfafkxMn+A==&model=iPhone11&lat=23.016271&origin_id=1&client_type=1&terminal_id=1&sig=8503d986c0349e40ea10ff360f75d208c78c989a'
|
||
heards = {
|
||
"user-agent": f"Mozilla/5.0 (iPhone; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 didi.passenger/6.2.4 FusionKit/1.2.20 OffMode/0",
|
||
}
|
||
response = requests.head (url=url, headers=heards, verify=False) #获取响应请求头
|
||
result = response.headers['Location'] #获取响应请求头
|
||
# print(result)
|
||
r = re.compile (r'root_xpsid=(.*?)&appid', re.M | re.S | re.I)
|
||
xpsid = r.findall (result)
|
||
xpsid = xpsid[0]
|
||
print(xpsid)
|
||
return xpsid
|
||
except Exception as e:
|
||
print(e)
|
||
msg("获取xpsid失败，可能是表达式错误")
|
||
|
||
|
||
#兑换福利金
|
||
def exchange(Didi_jifen_token,xpsid,account,exchange_jkd_numb):
|
||
flag2 = 0
|
||
flag3 = 0
|
||
url2 = r'https://res.xiaojukeji.com/sigma/api/coin/exchange?wsgsig=dd03-874lYEiaW6E3VTgICTc9U%2FXEkxU6r1QcAIfA%2FhQDkxU5U574bTzeUAtbVME5UTgaGPb2X9XbVxdJkHs0AHDb%2FVm0hO51WOKcDx7AWAvg%2F1FIWTbGDY0fh9vbh69E'
|
||
url3 = r'https://res.xiaojukeji.com/sigma/api/coin/exchange?wsgsig=dd03-m4G1HNtCTeCohKleO1Nzf3igzlsPlyLbPLKTAvv9zlsO%2FuY3vOsYdJiBoFCO%2FKh9pS%2Bkg3mBoVmyqoEGPHJxA3C2pVDwhoTHRHfud3tevejx%2FNUFzHjTB%2Bvcv%2Fgv'
|
||
heards = {
|
||
"Host": "res.xiaojukeji.com",
|
||
"Accept":"application/json, text/plain, */*",
|
||
"Content-Type": "application/json",
|
||
"Origin": "https://page.udache.com",
|
||
"Accept-Encoding": "gzip, deflate, br",
|
||
"Connection":"keep-alive",
|
||
"Accept-Language": "zh-CN,zh-Hans;q=0.9",
|
||
"ticket":f"{Didi_jifen_token}",
|
||
"User-Agent": f"Mozilla/5.0 (iPhone; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 didi.passenger/6.2.4 FusionKit/1.2.20 OffMode/0",
|
||
"Referer": "https://page.udache.com/",
|
||
# "Content-Length": "1013"
|
||
}
|
||
data2 = r'{"xbiz":"240300","prod_key":"","xpsid":"6da937105bd14a54a450a08bcdbe7430","dchn":"DpzAd35","xoid":"31685f47-0baa-4c2e-8636-ebff93f65c4a","uid":"281474990465673","xenv":"passenger","xspm_from":"","xpsid_root":"6da937105bd14a54a450a08bcdbe7430","xpsid_from":"409c8422dcdb4449a3598102f1008ca3","xpsid_share":"","version":1,"source_from":"app","city_id":21,"env":{"ticket":"teo9SzpY2n5ivDQiGC0WeayO8BC5UI9gF3vBKuu5bEAkzDmOAkEMQNG7_Nhq2bW5yunkc4cZaJakkEBELe6OaPKntzGVIC-6KMI0woSZCFNVFWYmzOtILRdrPY0szEJYK70WrzkJsxL8_CL8ESD8E6lb8TKGllabZ-FIDGElNh635_2wEvoSTnul7rZXZwLLtWvvzbUhXL7l9cPfAQAA__8=","cityId":"21","longitude":113.81221218532986,"latitude":23.016388346354166,"newAppid":10000,"isHitButton":true,"ddfp":"99d8f16bacaef4eef6c151bcdfa095f0","deviceId":"99d8f16bacaef4eef6c151bcdfa095f0","appVersion":"6.2.4","userAgent":"Mozilla/5.0 (iPhone; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 didi.passenger/6.2.4 FusionKit/1.2.20 OffMode/0","fromChannel":"1"},"type":4,"extra_number":2}'
|
||
data3 = r'{"xbiz":"240300","prod_key":"ut-walk-bonus","xpsid":"8135e26398034cb1aeede503aef54f26","dchn":"aXxR1oB","xoid":"ba403e62-5f97-4b65-a213-b389f7ed0792","uid":"281474990465673","xenv":"passenger","xspm_from":"","xpsid_root":"8135e26398034cb1aeede503aef54f26","xpsid_from":"43f880c6cfae43d1a77a6ad37bfbea94","xpsid_share":"","version":1,"source_from":"app","city_id":21,"env":{"ticket":"w-8z4gvdnylZ3fDWaIPcqhm3n2fux0T3k8oIR9valmskzDmOAkEMQNG7_Nhq2eVanU4-d5iBZkkKCUTU4u6IJn96G1MJfNFFEaYRJsxEmKqqMJ2wVkaqnq32NFyYmbCah3b3PIRZCH5-Ef4IEP6J1C23PIbmWmpz4UiYCSux8bg974eV0Jdw2i9zbft1JjAvXXuvTSvC5XteP_wdAAD__w==","cityId":"21","longitude":113.81221218532986,"latitude":23.016388346354166,"newAppid":10000,"isHitButton":true,"ddfp":"99d8f16bacaef4eef6c151bcdfa095f0","deviceId":"99d8f16bacaef4eef6c151bcdfa095f0","appVersion":"6.2.4","userAgent":"Mozilla/5.0 (iPhone; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 didi.passenger/6.2.4 FusionKit/1.2.20 OffMode/0","fromChannel":"1"},"type":4,"extra_number":3}'
|
||
# print(data)
|
||
printT("抢兑换开始时间为：{}".format (qgtime))
|
||
printT (f"正在等待兑换时间，请勿终止退出...")
|
||
try:
|
||
while True:
|
||
nowtime = datetime.datetime.now ().strftime ('%Y-%m-%d %H:%M:%S.%f8')
|
||
if nowtime > qgtime:
|
||
if exchange_jkd_numb == '2':
|
||
response = requests.post (url=url2, headers=heards,verify=False,data=data2)
|
||
# print(response.text)
|
||
result = response.json()
|
||
print(result)
|
||
errmsg = result['errmsg']
|
||
if errmsg == 'success':
|
||
msg("【账号{0}】已兑换{1}健康豆，获得福利金{2}".format(account,total_exchange,FLJ))
|
||
flag2 = 1
|
||
break
|
||
elif "代币兑换错误" in errmsg:
|
||
print("【账号{0}】今日兑换【50】福利金可能已达上限".format(account))
|
||
if flag2 == 1:
|
||
break
|
||
elif exchange_jkd_numb == '3':
|
||
response = requests.post (url=url3, headers=heards, verify=False, data=data3)
|
||
result = response.json ()
|
||
print (result)
|
||
errmsg = result['errmsg']
|
||
if errmsg == 'success':
|
||
msg ("【账号{0}】已兑换{1}健康豆，获得福利金{2}".format (account, total_exchange, FLJ))
|
||
flag3 = 1
|
||
break
|
||
elif "代币兑换错误" in errmsg:
|
||
print ("【账号{0}】今日兑换【100】福利金可能已达上限".format(account))
|
||
if flag3 == 1:
|
||
break
|
||
elif exchange_jkd_numb == '4':
|
||
response = requests.post (url=url2, headers=heards, verify=False, data=data2)
|
||
result = response.json ()
|
||
print (result)
|
||
errmsg = result['errmsg']
|
||
if errmsg == 'success':
|
||
msg ("【账号{0}】已兑换5000健康豆，获得福利金50".format (account))
|
||
flag2 = 1
|
||
elif "代币兑换错误" in errmsg:
|
||
print ("【账号{0}】今日兑换【50福利金】可能已达上限".format(account))
|
||
response = requests.post (url=url3, headers=heards, verify=False, data=data3)
|
||
result = response.json ()
|
||
print (result)
|
||
errmsg = result['errmsg']
|
||
if errmsg == 'success':
|
||
msg ("【账号{0}】已兑换10000健康豆，获得福利金100".format (account))
|
||
flag3 = 1
|
||
elif "代币兑换错误" in errmsg:
|
||
print ("【账号{0}】今日兑换【100福利金】可能已达上限".format(account))
|
||
|
||
if nowtime > qgendtime:
|
||
if flag2 == 0 and flag3 == 0:
|
||
msg ("【账号{0}】脚本执行完毕，兑换失败".format (account))
|
||
break
|
||
elif flag2 == 1 and flag3 == 1:
|
||
msg("【账号{0}】脚本执行完毕，共获得福利金150".format(account))
|
||
break
|
||
elif flag2 == 0 and flag3 == 1:
|
||
msg ("【账号{0}】脚本执行完毕，共获得福利金100".format(account))
|
||
break
|
||
elif flag2 == 1 and flag3 == 0:
|
||
msg ("【账号{0}】脚本执行完毕，共获得福利金50".format(account))
|
||
break
|
||
except Exception as e:
|
||
print (e)
|
||
|
||
|
||
if __name__ == '__main__':
|
||
print("============脚本只支持青龙新版=============\n")
|
||
print("具体教程以文本模式打开文件，查看顶部教程\n")
|
||
print("============执行滴滴多走多赚兑换脚本==============")
|
||
# print(Didi_jifen_token)
|
||
if Didi_jifen_token != '':
|
||
xpsid = get_xpsid ()
|
||
exchange (Didi_jifen_token, xpsid, account, exchange_jkd_numb)
|
||
elif tokens == '' :
|
||
print("检查变量Didi_jifen_token是否已填写")
|
||
elif len(tokens) > 1 :
|
||
account = 1
|
||
ttt = []
|
||
for i in tokens: #同时遍历两个list，需要用ZIP打包
|
||
xpsid = get_xpsid ()
|
||
thread = threading.Thread(target=exchange, args=(i, xpsid, account, exchange_jkd_numb))
|
||
ttt.append (thread)
|
||
thread.start ()
|
||
account += 1
|
||
for thread in ttt:
|
||
thread.join ()
|
||
if "已兑换" in msg_info:
|
||
send("滴滴多走多赚兑换", msg_info)
|
||
elif "过期" in msg_info:
|
||
send("滴滴多走多赚兑换", msg_info)
|