mirror of
https://jihulab.com/spiritlhl/qinglong_auto_tools.git
synced 2026-06-05 21:07:21 +08:00
1122 lines
54 KiB
Python
1122 lines
54 KiB
Python
#!/usr/bin/env python3
|
||
# -*- coding: utf-8 -*-
|
||
#author:fugui
|
||
|
||
from typing import Text
|
||
import urllib.request
|
||
import ssl
|
||
import json
|
||
import os
|
||
import sys
|
||
import datetime
|
||
|
||
#定义11点 用于开启server 酱推送
|
||
global d_time0,d_time1,d_time2,n_time
|
||
d_time0 = datetime.datetime.strptime(str(datetime.datetime.now().date()) + '11:00', '%Y-%m-%d%H:%M')
|
||
|
||
|
||
n_time = datetime.datetime.now()
|
||
|
||
|
||
#定义抢大额红包时间段d_time3和d_time4和d_time5和d_time6之间 ，d_time4提前11分钟意在防止下午红包池提前10分钟关闭和脚本抢大额红包有些地区到最后一刻10元以上红包都有剩余导致脚本报错，
|
||
# 若到最后一刻会自动放弃监测，抢所拥有的必中符的面值保底
|
||
###默认 抢大额(15元以上) 时间段为下午17:00点到16:49分和晚上21:00到23点59分 不建议进行更改
|
||
##以下默认中午试图抢大额红包 前提是道具库存中有10元以上必中符！！！！！！！！！
|
||
|
||
global d_time3,d_time4,d_time5,d_time6
|
||
|
||
d_time3 = datetime.datetime.strptime(str(datetime.datetime.now().date()) + '17:00', '%Y-%m-%d%H:%M')
|
||
d_time4 = datetime.datetime.strptime(str(datetime.datetime.now().date()) + '20:49', '%Y-%m-%d%H:%M')
|
||
|
||
d_time5 = datetime.datetime.strptime(str(datetime.datetime.now().date()) + '21:00', '%Y-%m-%d%H:%M')
|
||
d_time6 = datetime.datetime.strptime(str(datetime.datetime.now().date()) + '23:59', '%Y-%m-%d%H:%M')
|
||
|
||
|
||
#d_time6定义几点前不使用必中符,注意是不使用！！！若时间定义为17:00点,也就是17:00点之前的抽奖不会使用必中符,优先级高于自定义的大额抢红包时间,以节约道具库中的有效的必中符
|
||
##若d_time6定义为11:00点，则代表不对使用必中符时间进行限制，切记不能删除d_time7，若不需限制，只需将d_time7时间改为11:00,注意是英文的冒号
|
||
global d_time7
|
||
d_time7 = datetime.datetime.strptime(str(datetime.datetime.now().date()) + '11:00', '%Y-%m-%d%H:%M')
|
||
|
||
|
||
#关闭ssl校验，用于抓包调试请求
|
||
ssl._create_default_https_context = ssl._create_unverified_context
|
||
|
||
#定义短期(半年以上)不会变的量
|
||
parActivityId="Gh1tkq-wvFU2xEP_ZPzHPQ"
|
||
wm_ctype="mtandroid"
|
||
#以下portraitId参数含义未知，用于每日浏览天天神卷30s后可领30豆的请求
|
||
portraitId=498
|
||
|
||
### 定义红包豆攒到多少数量才会执行兑换必中符脚本，以免一直兑换减5元的必中符
|
||
setexchangedou = 1800
|
||
|
||
|
||
|
||
#定义精简通用请求头部
|
||
head={"Host": "i.waimai.meituan.com","User-Agent":"MeituanGroup/11.9.208","x-requested-with": "XMLHttpRequest","content-type":"application/x-www-form-urlencoded"}
|
||
#定义美团外卖服务器地址
|
||
baseurl=r"https://i.waimai.meituan.com"
|
||
#定义 pushPlus 的webhook地址，用于企业微信等渠道的推送，默认为空，若采用企业微信，请手动填写
|
||
global webhook
|
||
webhook = ""
|
||
|
||
#定义全局变量并初始化 以下初始化赋值的变量不要改！！！！
|
||
global propIdforuse
|
||
showPriceNumber = "1"
|
||
wm_latitude =1.0
|
||
wm_longitude=1.0
|
||
token =""
|
||
propId=1
|
||
exchangeCoinNumber=1.0
|
||
serverkey=""
|
||
pushPlusToken = ""
|
||
yesornot = ""
|
||
yesornot2 = ""
|
||
propIdforuse =2
|
||
letfdou=0
|
||
counttime=0
|
||
cwd = os.path.dirname(os.path.realpath(__file__))
|
||
|
||
##############################################################################
|
||
##标记这四类红包数量不为空，用来在有10元以上必中符时循环判断红包池余量抢购大额元红包，若您不需该功能，请自行将下一行的1改为0
|
||
eight = ten = fifteen = thirty =fifty=1
|
||
##############################################################################
|
||
# eight_left= 10
|
||
################################################################################
|
||
#若在您自定义的抢大额红包时间段中，您无法通过10元以上必中符抢到任何红包！！，则请将下面两行数值改大些，如改成10左右的数字
|
||
ten_left=0
|
||
fifteen_left=0
|
||
thirty_left=0
|
||
fifty_left=0
|
||
|
||
|
||
#将print内容同步写到output.txt文件
|
||
class Logger(object):
|
||
def __init__(self, fileN='Default.log'):
|
||
self.terminal = sys.stdout
|
||
self.log = open(fileN, 'w+',encoding='utf-8')
|
||
|
||
def write(self, message):
|
||
'''print实际相当于sys.stdout.write'''
|
||
self.terminal.write(message)
|
||
self.log.write(message)
|
||
|
||
def flush(self):
|
||
pass
|
||
|
||
|
||
|
||
|
||
|
||
|
||
###获取serverkey
|
||
def getserverkey():
|
||
global yesornot
|
||
global serverkey
|
||
if os.path.exists(str(cwd)+r"/serverkey.txt"):
|
||
# file1 = open(r"./token.txt", mode='r',encoding="UTF-8")
|
||
# token = file1.readline()
|
||
# file1.close
|
||
if os.path.getsize(str(cwd)+r"/serverkey.txt")!=0:
|
||
yesornot = "y"
|
||
else:
|
||
yesornot = "n"
|
||
return -1
|
||
else:
|
||
while True:
|
||
try:
|
||
|
||
print("请选择是否开启server酱推送!\n")
|
||
yesornot=input("是否开启server酱推送(y/n):\n")
|
||
if type(yesornot)==str and yesornot=='y':
|
||
print("获取serverkey请访问:https://sct.ftqq.com/\n")
|
||
serverkey=input("请输入serverkey:\n")
|
||
except:
|
||
pass
|
||
if type(yesornot)==str and (yesornot =="n" or yesornot=='y'):
|
||
break
|
||
file =open(str(cwd)+r"/serverkey.txt", mode='w+',encoding="UTF-8")
|
||
file.write(serverkey)
|
||
file.close
|
||
|
||
|
||
###获取pushPlusToken
|
||
def getpushPlusToken():
|
||
global yesornot2
|
||
global pushPlusToken
|
||
if os.path.exists(str(cwd)+r"/pushPlusToken.txt"):
|
||
# file1 = open(r"./token.txt", mode='r',encoding="UTF-8")
|
||
# token = file1.readline()
|
||
# file1.close
|
||
if os.path.getsize(str(cwd)+r"/pushPlusToken.txt")!=0:
|
||
yesornot2 = "y"
|
||
else:
|
||
yesornot2 = "n"
|
||
return -1
|
||
else:
|
||
while True:
|
||
try:
|
||
|
||
print("请选择是否开启pushPlus推送\n")
|
||
yesornot2=input("是否开启pushPlus推送(y/n):\n")
|
||
if type(yesornot2)==str and yesornot2=='y':
|
||
print("获取pushPlusToken请访问:https://www.pushplus.plus/\n")
|
||
pushPlusToken=input("请输入pushPlusToken:\n")
|
||
except:
|
||
pass
|
||
if type(yesornot2)==str and (yesornot2 =="n" or yesornot2=='y'):
|
||
break
|
||
file =open(str(cwd)+r"/pushPlusToken.txt", mode='w+',encoding="UTF-8")
|
||
file.write(pushPlusToken)
|
||
file.close
|
||
|
||
|
||
|
||
|
||
|
||
#获取token
|
||
def gettoken():
|
||
if os.path.exists(str(cwd)+r"/token.txt"):
|
||
file1 = open(str(cwd)+r"/token.txt", mode='r',encoding="UTF-8")
|
||
token = file1.readline()
|
||
file1.close
|
||
return token
|
||
else:
|
||
while True:
|
||
|
||
try:
|
||
print("获取token方法参考readme.md!\n")
|
||
token=input("请输入token:\n")
|
||
except:
|
||
pass
|
||
if type(token)==str and token !="":
|
||
break
|
||
file =open(str(cwd)+r"/token.txt", mode='w+',encoding="UTF-8")
|
||
file.write(token)
|
||
file.close
|
||
return token
|
||
|
||
#获取经纬度函数并存入当前目录文本(美团活动为随机地点固定半年以上,各地大额红包概率可能不同，若长期小额，可尝试换地址或换号)
|
||
def getlatlongitude():
|
||
if os.path.exists(str(cwd)+r"/wm_latitudewm_longitude.txt"):
|
||
return -1
|
||
else:
|
||
while True:
|
||
|
||
try:
|
||
print("若您不知道🙏限时抢红包开放城市，可试各地省会,如成都(30657401,104065827)\n")
|
||
wm_latitude=eval(input("请输入去除小数点的纬度(如30657401):\n"))
|
||
wm_longitude=eval(input("请输入去除小数点的经度(如104065827):\n"))
|
||
except:
|
||
pass
|
||
if type(wm_latitude)==int and type(wm_longitude)==int :
|
||
break
|
||
file =open(str(cwd)+r"/wm_latitudewm_longitude.txt", mode='w+',encoding="UTF-8")
|
||
file.write(str(wm_latitude)+"\n"+str(wm_longitude))
|
||
file.close
|
||
|
||
#定义一个云端查询必中符库中所有的propId 和needNumber 的函数，并传给getpropId_Coninnumber()函数作为用户输入参考提示
|
||
def myredbean(token):
|
||
wm_latitude = 1
|
||
wm_longitude = 1
|
||
print("开始执行从美团接口查询propid 和 needNumber参数脚本:\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+str(token)+"&userPortraitId="+str(portraitId)
|
||
url_drawlottery = baseurl+r"/cfeplay/playcenter/batchgrabred/myRedBean"
|
||
request =urllib.request.Request(url_drawlottery,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
cent = 1
|
||
if(result2["code"]==0 and result2["subcode"]==0 and len(result2["data"]["propExchangeRuleInfos"])):
|
||
for k in result2["data"]["propExchangeRuleInfos"]:
|
||
print("第%d类必中符 所需设置propId参数为%d\t所需红包豆数量为:%d\t总量为%d\n"%(cent,k["propId"],k["needNumber"],k["amount"]))
|
||
cent=cent+1
|
||
print("一般这几类必中符金额依次为5元 8元 15元,大概率使用后兑换到20-5，25-8,40-15的红包，建议选择面值最大的一类,即propId填5,所需豆子数量填1800即可\n脚本会自动从设定的面值去尝试兑换，逐级尝试面值，直到兑换成功，所以推荐设置默认兑换15面值的必中符\n注意填写的propId和所需豆子数之间是上方的一一对应关系，错误对应将导致兑换失败!\n")
|
||
elif (result2["code"]==1 and result2["subcode"]==-1):
|
||
print("%s,原因:输入token失效或错误 请继续运行程序并输入，脚本将在运行一遍后自动删除异常配置文件!!\n"%(result2["msg"]))
|
||
else:
|
||
print("请求接口失效或参数异常，建议🙏重置参数!\n")
|
||
sys.exit(0)
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
#定义获得需要兑换的必中符道具类型和兑换所需的豆子
|
||
def getpropId_Coinnumber(token):
|
||
if os.path.exists(str(cwd)+r"/propId_Coinnumbe.txt"):
|
||
return -1
|
||
else:
|
||
while True:
|
||
myredbean(token)
|
||
try:
|
||
propId=eval(input("请输入所需要兑换道具的propId(推荐填写5):\n"))
|
||
exchangeCoinNumber=eval(input("请输入propId对应某类必中符所需的豆子数量(推荐填写1800):\n"))
|
||
except:
|
||
pass
|
||
if type(propId)==int and type(exchangeCoinNumber)==int :
|
||
if propId == 2 or propId == 4 or propId == 5:
|
||
if exchangeCoinNumber ==500 or exchangeCoinNumber ==1000 or exchangeCoinNumber ==1800 :
|
||
break
|
||
file =open(str(cwd)+r"/propId_Coinnumbe.txt", mode='w+',encoding="UTF-8")
|
||
file.write(str(propId)+"\n"+str(exchangeCoinNumber))
|
||
file.close
|
||
|
||
#定义从文本文件中获取存入变量的函数,第二次运行时不用输入，若需改变经纬度和token，则直接删除文件即可
|
||
def getVar():
|
||
if not os.path.exists(str(cwd)+r"/wm_latitudewm_longitude.txt"):
|
||
print("程序运行中配置文件异常,文件或者权限异常,已自动为您停止程序!\n")
|
||
# os.remove(str(cwd)+r"/wm_latitudewm_longitude.txt")
|
||
# os.remove(str(cwd)+r"/token.txt")
|
||
# os.remove(str(cwd)+r"/propId_Coinnumbe.txt")
|
||
# os.remove(str(cwd)+r"/serverkey.txt")
|
||
# os.remove(str(cwd)+r"/pushPlusToken.txt")
|
||
sys.exit(0)
|
||
file1 = open(str(cwd)+r"/wm_latitudewm_longitude.txt", mode='r',encoding="UTF-8")
|
||
wm_latitude = int(file1.readline())
|
||
wm_longitude = int(file1.readline())
|
||
file1.close()
|
||
|
||
file2 = open(str(cwd)+r"/token.txt", mode='r',encoding="UTF-8")
|
||
if not os.path.exists(str(cwd)+r"/token.txt"):
|
||
print("程序运行中配置文件异常,文件或者权限异常,已自动为您停止程序!\n")
|
||
# os.remove(str(cwd)+r"/wm_latitudewm_longitude.txt")
|
||
# os.remove(str(cwd)+r"/token.txt")
|
||
# os.remove(str(cwd)+r"/propId_Coinnumbe.txt")
|
||
# os.remove(str(cwd)+r"/serverkey.txt")
|
||
# os.remove(str(cwd)+r"/pushPlusToken.txt")
|
||
sys.exit(0)
|
||
token = file2.readline()
|
||
file2.close()
|
||
|
||
if not os.path.exists(str(cwd)+r"/propId_Coinnumbe.txt"):
|
||
print("程序运行中配置文件异常,文件或者权限异常,已自动为您停止程序!\n")
|
||
# os.remove(str(cwd)+r"/wm_latitudewm_longitude.txt")
|
||
# os.remove(str(cwd)+r"/token.txt")
|
||
# os.remove(str(cwd)+r"/propId_Coinnumbe.txt")
|
||
# os.remove(str(cwd)+r"/serverkey.txt")
|
||
# os.remove(str(cwd)+r"/pushPlusToken.txt")
|
||
sys.exit(0)
|
||
file3 = open(str(cwd)+r"/propId_Coinnumbe.txt", mode='r',encoding="UTF-8")
|
||
propId = int(file3.readline())
|
||
exchangeCoinNumber = int(file3.readline())
|
||
file3.close()
|
||
|
||
|
||
return wm_latitude,wm_longitude,token,propId,exchangeCoinNumber
|
||
|
||
|
||
##获得pushPlusToken
|
||
def pushPlusTokenvar():
|
||
global pushPlusToken
|
||
if not os.path.exists(str(cwd)+r"/pushPlusToken.txt"):
|
||
print("程序运行中配置文件异常,文件或者权限异常,已自动为您停止程序!\n")
|
||
# os.remove(str(cwd)+r"/wm_latitudewm_longitude.txt")
|
||
# os.remove(str(cwd)+r"/token.txt")
|
||
# os.remove(str(cwd)+r"/propId_Coinnumbe.txt")
|
||
# os.remove(str(cwd)+r"/serverkey.txt")
|
||
# os.remove(str(cwd)+r"/pushPlusToken.txt")
|
||
sys.exit(0)
|
||
file = open(str(cwd)+r"/pushPlusToken.txt", mode='r',encoding="UTF-8")
|
||
pushPlusToken = file.readline()
|
||
file.close()
|
||
return pushPlusToken
|
||
|
||
|
||
|
||
##获得serverkey
|
||
def serverkeyvar():
|
||
global serverkey
|
||
if not os.path.exists(str(cwd)+r"/serverkey.txt"):
|
||
print("程序运行中配置文件异常,文件或者权限异常,已自动为您停止程序!\n")
|
||
# os.remove(str(cwd)+r"/wm_latitudewm_longitude.txt")
|
||
# os.remove(str(cwd)+r"/token.txt")
|
||
# os.remove(str(cwd)+r"/propId_Coinnumbe.txt")
|
||
# os.remove(str(cwd)+r"/serverkey.txt")
|
||
# os.remove(str(cwd)+r"/pushPlusToken.txt")
|
||
sys.exit(0)
|
||
file = open(str(cwd)+r"/serverkey.txt", mode='r',encoding="UTF-8")
|
||
serverkey = file.readline()
|
||
file.close()
|
||
return serverkey
|
||
|
||
|
||
#定义获取batchId的函数
|
||
def getbatchId(token):
|
||
global expire
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行获取batchId脚本:**\n")
|
||
try:
|
||
datas = "parActivityId="+parActivityId+"&wm_ctype="+wm_ctype+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+token
|
||
url_getbatchId = baseurl+r"/cfeplay/playcenter/batchgrabred/corepage"
|
||
request =urllib.request.Request(url_getbatchId,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
# print(result2)
|
||
# print(result2["code"])
|
||
if(result2["code"]==0):
|
||
if "batchId" in result2["data"]:
|
||
expire = 1
|
||
print("batchId:%s\n"%(result2["data"]["batchId"]))
|
||
return result2["data"]["batchId"]
|
||
else:
|
||
expire =2
|
||
print("获取batchId失败👀，当前非限时抢红包时间段,无法进行下一步，但已为您签到完毕🙏!\n")
|
||
|
||
elif (result2["code"]==1):
|
||
print("%s,接口需提交的token参数已改变👀,请重新运行一遍脚本！\n"%(result2["msg"]))
|
||
# os.remove(str(cwd)+r"/wm_latitudewm_longitude.txt")
|
||
# os.remove(str(cwd)+r"/token.txt")
|
||
# os.remove(str(cwd)+r"/propId_Coinnumbe.txt")
|
||
# os.remove(str(cwd)+r"/serverkey.txt")
|
||
# os.remove(str(cwd)+r"/pushPlusToken.txt")
|
||
|
||
else:
|
||
print("获取batchId错误👀，请检查网络，否则为接口失效！\n")
|
||
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
|
||
print("脚本执行失败👀，错误代码为%s\n"%(e.code))
|
||
|
||
|
||
|
||
#定义每天七次签到领豆的函数，需传入获取的token
|
||
def signForBeans(token):
|
||
print("**开始执行签到领豆脚本:** \n")
|
||
datas = "token="+token
|
||
url_signforbeans = baseurl+r"/cfeplay/playcenter/batchgrabred/drawPoints/v2"
|
||
request =urllib.request.Request(url_signforbeans,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
# print(result2)
|
||
# print(result2["code"])
|
||
if(result2["code"]==0):
|
||
print("👴%s\n"%(result2["msg"]))
|
||
elif (result2["code"]==1):
|
||
print("👴未到领取时间或已经领取完了(每天可领7次,每次间隔需半小时\n)！")
|
||
elif (result2["code"]==7):
|
||
print("token已失效，请检查是否已自动删除所有配置文件，若未自动删除，请手动🙏删除所有配置文件并重新运行脚本，最后温馨提示:建议接入server酱通知！\n")
|
||
else:
|
||
print("请求接口失效或网络不佳，请稍后再试!\n")
|
||
|
||
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
|
||
#def 限时抢红包函数
|
||
def drawlottery(batchId,token,propIdforuse):
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行限时抢天天神券脚本🧧:**\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+token+"&batchId="+batchId+"&isShareLink=true"+"&propType=1"+"&propId="+str(propIdforuse)
|
||
url_drawlottery = baseurl+r"/cfeplay/playcenter/batchgrabred/drawlottery"
|
||
request =urllib.request.Request(url_drawlottery,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
# print(result2)
|
||
# print(result2["code"])
|
||
if(result2["code"]==0):
|
||
print("领取成功!\n提示信息:%s\n红包属性:%s\n使用限制:%s\n红包价值:%s\n红包立即生效时间:%s\n红包剩余有效期:%s分钟\n"%(result2["msg"],result2["data"]["name"],result2["data"]["priceLimitdesc"],result2["data"]["showTitle"],result2["data"]["endTimeDesc"],str(float(result2["data"]["leftTime"])/60000)))
|
||
global showPriceNumber
|
||
showPriceNumber = result2["data"]["showPriceNumber"]
|
||
if int(showPriceNumber)<500:
|
||
print("**当前红包面值为%d元，小于5元，👴将自动执行小额红包转红包豆脚本!!**\n"%(int(showPriceNumber)/100))
|
||
else:
|
||
print("**当前红包面值为%d元，大于等于5元，👴将不会执行小额红包转红包豆脚本!!**\n"%(int(showPriceNumber)/100))
|
||
elif (result2["code"]==1 and result2["subcode"]==3):
|
||
print("%s😅\n"%(result2["msg"]))
|
||
elif(result2["code"]==1 and result2["subcode"]==-1):
|
||
print("token错误或已失效,%s\n"%(result2["msg"]))
|
||
elif (result2["code"]==7):
|
||
print("token已失效，请手动🙏删除所有自动生成的配置文件，并建议接入server酱通知！\n")
|
||
else:
|
||
print("请求接口失效或参数异常，请稍后再试!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
|
||
#定义接受红包函数，获得红包小于5元时，不执行此函数，并调用redtobean函数自动将红包转为红包豆，若两个函数都不执行，在抢红包成功5分钟左右红包会自动发放到账户
|
||
def acceptRed(batchId,token):
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行发放天天神券🧧到红包库脚本:**\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+token+"&batchId="+batchId
|
||
url_acceptRed = baseurl+r"/cfeplay/playcenter/batchgrabred/acceptRed"
|
||
request =urllib.request.Request(url_acceptRed,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
# print(result2)
|
||
# print(result2["code"])
|
||
if(result2["code"]==0):
|
||
print("*👴抢到的红包已经领取成功啦，快去使用吧!*\n")
|
||
elif (result2["code"]==1):
|
||
print("%s\n"%(result2["msg"]))
|
||
elif (result2["code"]==7):
|
||
print("token已失效，请手动🙏删除所有自动生成的配置文件，并建议接入server酱通知！\n")
|
||
else:
|
||
print("请求接口失效或参数异常，请稍后再试!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
|
||
print(e,"reason")
|
||
|
||
#定义红包转红包豆函数，将小于5元的红包转为红包豆
|
||
def redtobean(batchId,token):
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**默认尝试执行面值小于5元🧧自动转红包豆脚本:**\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+token+"&batchId="+batchId
|
||
url_drawlottery = baseurl+r"/cfeplay/playcenter/batchgrabred/redToBean"
|
||
request =urllib.request.Request(url_drawlottery,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
# print(result2)
|
||
# print(result2["code"])
|
||
if(result2["code"]==0):
|
||
print("👴小额红包转红包豆成功!\n")
|
||
elif (result2["code"]==1 and result2["subcode"]==12):
|
||
# print("%s😅\n"%(result2["msg"]))
|
||
print("没有待转换的红包😅\n")
|
||
elif (result2["code"]==7):
|
||
print("token已失效，请手动🙏删除所有自动生成的配置文件，并建议接入server酱通知！\n")
|
||
else:
|
||
print("请求接口失效或参数异常，请稍后再试!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
|
||
print(e,"reason")
|
||
|
||
|
||
|
||
|
||
#查询已领取到的天天神券
|
||
def querymyreward(token):
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行查询已领天天神券🧧脚本:**\n")
|
||
datas = "parActivityId="+parActivityId+"&token="+token
|
||
url_querymyreward = baseurl+r"/cfeplay/playcenter/batchgrabred/myreward"
|
||
request =urllib.request.Request(url_querymyreward,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
# print(result2)
|
||
# print(result2["code"])
|
||
if(result2["code"]==0 and len(result2["data"]["myawardInfos"])):
|
||
print("👴开始遍历红包库:\n")
|
||
print("红包库详细信息:\n")
|
||
print("红包库中共有%d个红包\n"%(len(result2["data"]["myawardInfos"])))
|
||
cent=0
|
||
count = 0
|
||
isover15=0
|
||
for k in result2["data"]["myawardInfos"]:
|
||
if not k["status"]:
|
||
print("**第%d个红包有效!!!!**\n红包属性:%s\n使用限制:%s\n红包价值:%s元\n红包剩余有效期%s分钟\n"%(cent+1,k["name"],k["priceLimitdesc"],k["showPriceNumberYuan"],str(float(k["leftTime"])/60000)))
|
||
if(int(k["showPriceNumberYuan"])>15):
|
||
isover15 =1
|
||
print("\n")
|
||
else:
|
||
count=count+1
|
||
if cent == 0:
|
||
print("**过期红包详情:**\n")
|
||
|
||
cent=cent+1
|
||
if(propIdforuse!=5):
|
||
print("总计已领取%d个红包,其中已过期%d个😅,有效%d个\n"%(cent,count,cent-count))
|
||
else:
|
||
if isover15==1:
|
||
print("恭喜你领取大额限时红包,具体价值如上所示!!总计已领取%d个红包,其中已过期%d个😅,有效%d个\n"%(cent,count,cent-count))
|
||
print("\n")
|
||
elif (result2["code"]==1):
|
||
print("%s\n"%(result2["msg"]))
|
||
elif (result2["code"]==7):
|
||
print("token已失效，请手动🙏删除所有自动生成的配置文件，并建议接入server酱通知！\n")
|
||
else:
|
||
print("请求接口失效或参数异常，请稍后再试!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
|
||
print(e,"reason")
|
||
|
||
|
||
#获取每日浏览天天神券奖励的30豆
|
||
def sendTaskRedBean(token):
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行领取每日30豆的脚本:**\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+token+"&portraitId="+str(portraitId)
|
||
url_sendTaskRedBean = baseurl+r"/cfeplay/playcenter/batchgrabred/sendTaskRedBean"
|
||
request =urllib.request.Request(url_sendTaskRedBean,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
if(result2["status"]==0):
|
||
print("%s\n今天领取成功%d个红包豆，请明日再来！\n"%(result2["msg"],result2["sendBeanCount"]))
|
||
elif (result2["status"]==1):
|
||
print("您今日已领取过😅,%s\n"%(result2["msg"]))
|
||
elif (result2["status"]==-1):
|
||
print("portraitId已失效,%s\n"%(result2["msg"]))
|
||
else:
|
||
print("请求接口失效或参数异常，请稍后再试!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
|
||
#定义每日签到得必中符函数
|
||
def doAction(token):
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行每日签到领必中符🧧的脚本:**\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+token+"&action=SiginInGetProp"
|
||
url_doaction = baseurl+r"/cfeplay/playcenter/batchgrabred/doAction"
|
||
request =urllib.request.Request(url_doaction,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
if(result2["code"]==0 and result2["data"]["signDays"]!=0):
|
||
print("签到%s\n,截止今日这周已签到%d天"%(result2["msg"],result2["data"]["signDays"]))
|
||
elif (result2["code"]==0 and result2["data"]["signDays"]==0):
|
||
print("您今日已签到，请明天再来!")
|
||
elif (result2["code"]==7):
|
||
print("参数异常或接口已失效")
|
||
else:
|
||
print("请求接口失效或参数异常，请稍后再试!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
|
||
#查看道具库中的必中符记录
|
||
def querymyProps(token):
|
||
global propIdforuse
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行查询道具库中必中符🧧详情的脚本:**\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+token
|
||
url_querymyprops = baseurl+r"/cfeplay/playcenter/batchgrabred/myProps"
|
||
request =urllib.request.Request(url_querymyprops,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
if(result2["code"]==0 and len(result2["data"])):
|
||
print("👴开始遍历道具库:\n")
|
||
print("道具库详细信息:\n")
|
||
print("红包库中共有%d个必中符道具\n"%(len(result2["data"])))
|
||
cent=0
|
||
count = 0
|
||
for k in result2["data"]:
|
||
if k["status"]==1:
|
||
print("第%d个必中符道具有效!!!!\n必中符道具id号:%s\n必中符道具属性:%s\n过期时间:%s\n"%(cent+1,k["recordNo"],k["propName"],k["expireTime"]))
|
||
if cent==0:
|
||
propIdforuse = k["propId"]
|
||
print("\n")
|
||
else:
|
||
count=count+1
|
||
cent=cent+1
|
||
if (count!=0):
|
||
print("总计%d个必中符道具,已过期%d个😅,有效%d个\n"%(cent,count,cent-count))
|
||
if ((cent-count)!=0):
|
||
print("**注意:每天中午抢红包🧧时将自动为您使用道具库中第一个道具!!** ")
|
||
else:
|
||
print(" **注意:道具库无有效道具，无法使用必中符,下次抢红包将使用默认参数抢红包(拼手气😅)!!** ")
|
||
|
||
print("\n")
|
||
elif (result2["code"]==7):
|
||
print("参数异常或接口已失效，请手动🙏删除所有自动生成的配置文件，并建议接入server酱通知！")
|
||
else:
|
||
print("必中符道具库为空，👴未帮您领取过道具!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
#已废弃，直接发送兑换请求即可，不在兑换时间段 subcode 为13
|
||
#定义运行时是否能兑换豆子成必中符,目前一直为14点至16点，故不定义此函数，采取每天14点至16点运行此程序时直接尝试兑换
|
||
#若需自行获取当前时间段是否可换豆子为道具，则post以下请求即可
|
||
# POST /cfeplay/playcenter/batchgrabred/canExchangeCheck HTTP/1.1
|
||
# Host: i.waimai.meituan.com
|
||
# Content-Length: 82
|
||
# User-Agent:MeituanGroup/11.9.208
|
||
# x-requested-with: XMLHttpRequest
|
||
# content-type: application/x-www-form-urlencoded
|
||
|
||
|
||
# parActivityId=Gh1tkq-wvFU2xEP_ZPzHPQ&wm_latitude=30657401&wm_longitude=104065827
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
#定义豆子兑换成必中符函数:
|
||
def exchange(token):
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
wm_actual_latitude = str(wm_latitude)
|
||
wm_actual_longitude =str(wm_longitude)
|
||
propId = getVar()[3]
|
||
exchangeCoinNumber = getVar()[4]
|
||
print("**开始执行每日豆子兑换必中符脚本**:\n")
|
||
while(1):
|
||
datas = "wm_actual_longitude="+wm_actual_longitude+"&wm_actual_latitude="+wm_actual_latitude+"&exchangeRuleId=&propId="+str(propId)+"&exchangeCoinNumber="+str(exchangeCoinNumber)+"&parActivityId="+parActivityId+"&wm_ctype="+wm_ctype+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+token
|
||
url_exchange = baseurl+r"/cfeplay/playcenter/batchgrabred/exchange"
|
||
request =urllib.request.Request(url_exchange,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
if(result2["code"]==0 and result2["subcode"]==0):
|
||
print("%s,您设置的红包豆兑换指定额度的必中符成功!!!请查看下方道具库详情!😄\n"%(result2["msg"]))
|
||
break
|
||
elif (result2["code"]==1 and result2["subcode"]==13):
|
||
print("%s\n"%(result2["msg"]))
|
||
break
|
||
elif (result2["code"]==1 and result2["subcode"]==-1):
|
||
print("%s,您现在的红包豆不足以兑换此类必中符或者此类必中符已被抢完!\n正尝试兑换*次一等级*必中符\n"%(result2["msg"]))
|
||
if(propId ==5):
|
||
propId =4
|
||
break
|
||
elif (result2["code"]==7):
|
||
print("参数异常或接口已失效\n")
|
||
else:
|
||
print("请求接口失效或参数异常，请稍后再试!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀,准备退出程序，错误代码为:%s\n"%(e.code))
|
||
if hasattr(e,"reason"):
|
||
print("脚本执行失败👀,准备退出程序,错误代码为:%s\n"%(e.reason))
|
||
|
||
###定义查询豆子详情的函数
|
||
def myRedBeanRecords(token):
|
||
global leftdou
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行查询豆子变化详情参数脚本**:\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+str(token)+"&userPortraitId="+str(portraitId)+"&pageNum=1"
|
||
url_myredbeanRecords = baseurl+r"/cfeplay/playcenter/batchgrabred/myRedBeanRecords"
|
||
request =urllib.request.Request(url_myredbeanRecords,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=10)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
cent=1
|
||
if(result2["code"]==0 and result2["subcode"]==0 and len(result2["data"]["redBeanRecordInfos"])):
|
||
leftdou= result2["data"]["totalObtainAmount"]-result2["data"]["usedAmount"]-result2["data"]["expiredAmount"]
|
||
print("**总获得红包豆:%d,已使用红包豆:%d,已过期红包豆:%d,剩余可用红包豆:%d**\n"%(result2["data"]["totalObtainAmount"],result2["data"]["usedAmount"],result2["data"]["expiredAmount"],leftdou))
|
||
for k in result2["data"]["redBeanRecordInfos"]:
|
||
print("exchangeTime:%s\texchangeMessage:%s\texchangeNumber:%s\n"%(k["exchangeTime"],k["exchangeMessage"],k["exchangeNumber"]))
|
||
cent=cent+1
|
||
if(cent>5):
|
||
break
|
||
print("*只显示最近五条红包豆的变化* \n")
|
||
elif (result2["code"]==1 and result2["subcode"]==-1):
|
||
print("%s\n"%(result2["msg"]))
|
||
else:
|
||
print("请求接口失效或参数异常，建议🙏重置参数!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
|
||
|
||
|
||
#定义查询红包池函数
|
||
def queryredpool(token):
|
||
global counttime
|
||
wm_latitude = getVar()[0]
|
||
wm_longitude = getVar()[1]
|
||
print("**开始执行查询红包池详情脚本:**\n")
|
||
datas = "parActivityId="+parActivityId+"&wm_latitude="+str(wm_latitude)+"&wm_longitude="+str(wm_longitude)+"&token="+str(token)+"&wm_ctype="+wm_ctype
|
||
url_myredbeanRecords = baseurl+r"/cfeplay/playcenter/batchgrabred/corepage"
|
||
request =urllib.request.Request(url_myredbeanRecords,headers=head,data=datas.encode("utf-8"),method="POST")
|
||
try:
|
||
global eight,ten,fifteen,thirty,fifty,ten_left,fifteen_left,thirty_left,fifty_left
|
||
response = urllib.request.urlopen(request)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
|
||
if(result2["code"]==0 and result2["subcode"]==0 and len(result2["data"]["awardInfos"])):
|
||
for k in result2["data"]["awardInfos"]:
|
||
if"leftStock" not in k:
|
||
print("该地区没有红包池，脚本异常退出！")
|
||
# if (round(float(k["showPriceNumberYuan"]))==8 and k["leftStock"]==eight_left):
|
||
# eight = 0
|
||
if (round(float(k["showPriceNumberYuan"]))==10 and k["leftStock"]==ten_left):
|
||
ten = 0
|
||
if (round(float(k["showPriceNumberYuan"]))==15 and k["leftStock"]==fifteen_left):
|
||
fifteen = 0
|
||
if (round(float(k["showPriceNumberYuan"]))==30 and k["leftStock"]==thirty_left):
|
||
thirty = 0
|
||
if (round(float(k["showPriceNumberYuan"]))==50 and k["leftStock"]==fifty_left):
|
||
fifty = 0
|
||
if counttime <3:
|
||
print("*红包池中%s元总量:%d张,已被领取:%d张,剩余%d张*\n"%(k["showPriceNumberYuan"],k["totalStock"],k["sendStock"],k["leftStock"]))
|
||
counttime =counttime +1
|
||
elif (result2["code"]==1 and result2["subcode"]==-1):
|
||
print("token失效,导致获取活动信息失败！%s\n"%(result2["msg"]))
|
||
else:
|
||
print("红包池未开放，等待中!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
#定义pushPlus的消息推送函数
|
||
def pushPlus():
|
||
global webhook
|
||
pushPlusToken = pushPlusTokenvar()
|
||
if not os.path.exists(str(cwd)+r"/output.txt"):
|
||
print("output.txt文件异常,推送退出！🙌")
|
||
return -1
|
||
file4= open(str(cwd)+r"/output.txt", mode='r',encoding="UTF-8")
|
||
message = str(file4.read())
|
||
|
||
file4.close
|
||
|
||
pushurl="https://www.pushplus.plus/send"
|
||
head_server ={"Host": "www.pushplus.plus","User-Agent":"Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.81 Mobile Safari/537.36","content-type":"application/x-www-form-urlencoded"}
|
||
print("**开始执行pushPlus推送脚本:**\n")
|
||
datas=bytes(urllib.parse.urlencode({"title":"天天神券推送","content":message,"token":pushPlusToken,"template":"markdown","channel":"wechat","webhook":webhook,"callbackUrl":""}),encoding="UTF-8")
|
||
request =urllib.request.Request(pushurl,headers=head_server,data=datas,method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=30)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
if(result2["code"]==200) :
|
||
print("pushPlus消息推送成功!\n\n")
|
||
else:
|
||
print("请求接口失效或参数异常，建议重置参数!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
#定义server 酱的消息推送函数
|
||
def serverjiang():
|
||
serverkey = serverkeyvar()
|
||
if not os.path.exists(str(cwd)+r"/output.txt"):
|
||
print("output.txt文件异常,推送退出！🙌")
|
||
return -1
|
||
file4= open(str(cwd)+r"/output.txt", mode='r',encoding="UTF-8")
|
||
message = str(file4.read())
|
||
file4.close
|
||
pushurl="https://sctapi.ftqq.com/"
|
||
head_server ={"Host": "sctapi.ftqq.com","User-Agent":"Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.81 Mobile Safari/537.36","content-type":"application/x-www-form-urlencoded"}
|
||
url_serverkey = pushurl+serverkey+".send"
|
||
print("**开始执行server酱推送脚本:**\n")
|
||
datas=bytes(urllib.parse.urlencode({"title":"天天神券推送","desp":message,"channel":""}),encoding="UTF-8")
|
||
request =urllib.request.Request(url_serverkey,headers=head_server,data=datas,method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=30)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
if(result2["code"]==0) :
|
||
pushid = result2["data"]["pushid"]
|
||
readkey = result2["data"]["readkey"]
|
||
url_checkurl = pushurl+"push?id="+pushid+"&readkey="+readkey
|
||
request2 = urllib.request.Request(url_checkurl,headers=head_server,data=datas)
|
||
try:
|
||
response2 = urllib.request.urlopen(request2,timeout=30)
|
||
text=json.loads(response2.read().decode("utf-8"))
|
||
if(text["data"]["title"] =="天天神券推送"):
|
||
print("server酱推送成功😄！请在移动设备端查看\n")
|
||
else:
|
||
print("server酱推送失败👀，请检查serverkey是否正确！\n")
|
||
|
||
except urllib.error.URLError as e2:
|
||
if hasattr(e2,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e2.code)
|
||
if hasattr(e2,"reason"):
|
||
print(e2,"reason")
|
||
else:
|
||
print("请求接口失效或参数异常，建议重置参数!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
|
||
#定义pushPlus的消息推送函数
|
||
def pushPlusforexpire():
|
||
global webhook
|
||
pushPlusToken = pushPlusTokenvar()
|
||
if not os.path.exists(str(cwd)+r"/output.txt"):
|
||
print("output.txt文件异常,推送退出！🙌")
|
||
return -1
|
||
message = "### 尊敬的天天神券脚本用户: ###\n\n**若您收到此推送,则代表您之前部署在服务器上的美团网页cookie 由于请求过快被拉黑或者使用时间过长到期!**\n\n **若您想继续使用本脚本服务，还请按照[readme.md](https://github.com/fuguiKz/meituan-shenquan)手动获取cookie并覆盖原配置文件进行更新!**\n\n"
|
||
|
||
|
||
pushurl="https://www.pushplus.plus/send"
|
||
head_server ={"Host": "www.pushplus.plus","User-Agent":"Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.81 Mobile Safari/537.36","content-type":"application/x-www-form-urlencoded"}
|
||
print("**开始执行pushPlus推送脚本:**\n")
|
||
datas=bytes(urllib.parse.urlencode({"title":"token失效告警","content":message,"token":pushPlusToken,"template":"markdown","channel":"wechat","webhook":webhook,"callbackUrl":""}),encoding="UTF-8")
|
||
request =urllib.request.Request(pushurl,headers=head_server,data=datas,method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=30)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
if(result2["code"]==200) :
|
||
print("pushPlus消息推送成功!\n\n")
|
||
else:
|
||
print("请求接口失效或参数异常，疑似用户取消关注，建议重置参数!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
|
||
|
||
|
||
#定义server 酱的消息推送函数
|
||
def serverjiangforexpire():
|
||
serverkey = serverkeyvar()
|
||
if not os.path.exists(str(cwd)+r"/output.txt"):
|
||
print("output.txt文件异常,推送退出！🙌")
|
||
return -1
|
||
message = "### 尊敬的天天神券脚本用户: ###\n\n**若您收到此推送,则代表您之前部署在服务器上的美团网页cookie 由于请求过快被拉黑或者使用时间过长到期!**\n\n **若您想继续使用本脚本服务，还请按照[readme.md](https://github.com/fuguiKz/meituan-shenquan)手动获取cookie并覆盖原配置文件进行更新!**\n\n"
|
||
pushurl="https://sctapi.ftqq.com/"
|
||
head_server ={"Host": "sctapi.ftqq.com","User-Agent":"Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.81 Mobile Safari/537.36","content-type":"application/x-www-form-urlencoded"}
|
||
url_serverkey = pushurl+serverkey+".send"
|
||
print("**开始执行server酱推送脚本:**\n")
|
||
datas=bytes(urllib.parse.urlencode({"title":"token失效告警","desp":message,"channel":""}),encoding="UTF-8")
|
||
request =urllib.request.Request(url_serverkey,headers=head_server,data=datas,method="POST")
|
||
try:
|
||
response = urllib.request.urlopen(request,timeout=30)
|
||
result = response.read().decode("utf-8")
|
||
result2 = json.loads(result)
|
||
if(result2["code"]==0) :
|
||
pushid = result2["data"]["pushid"]
|
||
readkey = result2["data"]["readkey"]
|
||
url_checkurl = pushurl+"push?id="+pushid+"&readkey="+readkey
|
||
request2 = urllib.request.Request(url_checkurl,headers=head_server,data=datas)
|
||
try:
|
||
response2 = urllib.request.urlopen(request2,timeout=30)
|
||
text=json.loads(response2.read().decode("utf-8"))
|
||
if(text["data"]["title"] =="token失效告警"):
|
||
print("server酱推送成功😄！请在移动设备端查看\n")
|
||
else:
|
||
print("server酱推送失败👀，请检查serverkey是否正确！\n")
|
||
|
||
except urllib.error.URLError as e2:
|
||
if hasattr(e2,"code"):
|
||
print("脚本执行失败👀，错误代码如下:\n")
|
||
print(e2.code)
|
||
if hasattr(e2,"reason"):
|
||
print(e2,"reason")
|
||
else:
|
||
print("请求接口失效或参数异常，建议重置参数!\n")
|
||
except urllib.error.URLError as e:
|
||
if hasattr(e,"code"):
|
||
print("脚本执行失败，错误代码如下:\n")
|
||
print(e.code)
|
||
if hasattr(e,"reason"):
|
||
print(e,"reason")
|
||
|
||
|
||
|
||
|
||
|
||
def main():
|
||
global propIdforuse
|
||
temp = sys.stdout
|
||
print("本脚本提供pushPlus、serverkey这两种推送方式,可以二选一或者全选，首次运行脚本请依次选择是否开启对应推送!\n由于server酱每日免费限额5条,若需开启推送,请首选pushPlus!\n")
|
||
getpushPlusToken()
|
||
getserverkey()
|
||
token = gettoken()
|
||
getlatlongitude()
|
||
getpropId_Coinnumber(token)
|
||
sys.stdout = Logger(str(cwd)+r'/output.txt')
|
||
print("脚本启动时间:%s\n"%(n_time))
|
||
token = getVar()[2]
|
||
signForBeans(token)
|
||
queryredpool(token)
|
||
batchId = getbatchId(token)
|
||
if expire ==0:
|
||
# print (yesornot)
|
||
# print (yesornot2)
|
||
if yesornot =="y":
|
||
serverjiangforexpire()
|
||
if yesornot2 =="y":
|
||
pushPlusforexpire()
|
||
sys.exit(0)
|
||
if expire ==2:
|
||
sys.exit(0)
|
||
|
||
doAction(token)
|
||
myRedBeanRecords(token)
|
||
if leftdou >=setexchangedou:
|
||
exchange(token)
|
||
else:
|
||
print("您当前红包豆为%d未满预设的%d数量，不会执行红包豆兑换必中符脚本，多攒几天豆子再来吧!\n"%(leftdou,setexchangedou))
|
||
querymyProps(token)
|
||
#定义bool类型变量判断当前时间段是不是自定义的大额抢红包时间段
|
||
istimeforbig1= (n_time <=d_time4) and(n_time>=d_time3)
|
||
istimeforbig2= (n_time <=d_time6) and(n_time>=d_time4)
|
||
if n_time > d_time7:
|
||
if istimeforbig1:
|
||
if propIdforuse ==5:
|
||
print("**当前符合抢30元以上大额红包的条件**\n")
|
||
print("**正使用15元必中符为您尝试抢30元以上的红包**\n")
|
||
##拥有15块以上的必中符，先等待着试图抢30,要是15没了，就直接去抢30的红包，或许有可能抢到50
|
||
while fifteen ==1 :
|
||
if not istimeforbig1:
|
||
print("*👴尽力了，等到红包池要关闭了都未等到15元以上大额红包被抢完，开始保底15元，注意查收！*\n")
|
||
break
|
||
if(thirty ==1 and fifty ==1):
|
||
print("*15有剩余，30元已被抢完，50元已被抢完，跳出监测，正在为您抢保底15元红包!*\n")
|
||
break
|
||
queryredpool(token)
|
||
|
||
|
||
if istimeforbig2 :
|
||
if propIdforuse ==5:
|
||
print("**当前符合抢30元以上大额红包的条件**\n")
|
||
print("**正使用15元必中符为您尝试抢30元以上的红包**\n")
|
||
##拥有15块以上的必中符，先等待着试图抢30,要是15没了，就直接去抢30的红包，或许有可能抢到50
|
||
while fifteen ==1 :
|
||
if not istimeforbig2 :
|
||
print("*👴尽力了，等到红包池要关闭了都未等到15元以上大额红包被抢完，开始保底15元，注意查收！*\n")
|
||
break
|
||
if(thirty ==1 and fifty ==1):
|
||
print("*15有剩余，30元已被抢完，50元已被抢完，跳出监测，正在为您抢保底15元红包!*\n")
|
||
break
|
||
queryredpool(token)
|
||
|
||
if istimeforbig1:
|
||
if propIdforuse ==3:
|
||
print("**当前符合抢30元以上大额红包的条件**\n")
|
||
print("**正使用10元必中符为您尝试抢30元以上的红包**\n")
|
||
##拥有10块以上的必中符，先等待着试图抢30,要是10和15都没了，就直接去抢30的红包，或许有可能抢到50
|
||
|
||
while fifteen ==1 :
|
||
if(thirty ==1 and fifty ==1 ):
|
||
print("&15有剩余，30元已被抢完，50元已被抢完，跳出监测，正在为您抢保底15元红包！*\n")
|
||
break
|
||
if(br ==1):
|
||
break
|
||
if not istimeforbig1:
|
||
print("*👴尽力了，等到红包池要关闭了都未等到15元以上大额红包被抢完，开始保底15元，注意查收！*\n")
|
||
break
|
||
if ten ==0 :
|
||
queryredpool(token)
|
||
while ten ==1:
|
||
if not istimeforbig1:
|
||
br = 1
|
||
print("*👴尽力了，等到红包池要关闭了都未等到任意大额红包被抢完，开始保底10元，注意查收！*\n")
|
||
queryredpool(token)
|
||
|
||
if istimeforbig2:
|
||
if propIdforuse ==3:
|
||
print("**当前符合抢30元以上大额红包的条件**\n")
|
||
print("**正使用10元必中符为您尝试抢30元以上的红包**\n")
|
||
##拥有10块以上的必中符，先等待着试图抢30,要是10和15都没了，就直接去抢30的红包，或许有可能抢到50
|
||
|
||
while fifteen ==1 :
|
||
if(thirty ==1 and fifty ==1 ):
|
||
print("&15有剩余，30元已被抢完，50元已被抢完，跳出监测，正在为您抢保底15元红包！*\n")
|
||
break
|
||
if(br ==1):
|
||
break
|
||
if not istimeforbig2:
|
||
print("*👴尽力了，等到红包池要关闭了都未等到15元以上大额红包被抢完，开始保底15元，注意查收！*\n")
|
||
break
|
||
if ten ==0 :
|
||
queryredpool(token)
|
||
while ten ==1:
|
||
if not istimeforbig2:
|
||
br = 1
|
||
print("*👴尽力了，等到红包池要关闭了都未等到任意大额红包被抢完，开始保底10元，注意查收！*\n")
|
||
queryredpool(token)
|
||
|
||
|
||
|
||
|
||
|
||
if n_time < d_time7 :
|
||
propIdforuse =1
|
||
drawlottery(batchId,token,propIdforuse)
|
||
|
||
if(int(showPriceNumber)<500):
|
||
redtobean(batchId,token)
|
||
else:
|
||
acceptRed(batchId,token)
|
||
querymyreward(token)
|
||
sendTaskRedBean(token)
|
||
querymyProps(token)
|
||
myRedBeanRecords(token)
|
||
sys.stdout = temp
|
||
if(yesornot2 == "y"):
|
||
pushPlus()
|
||
else:
|
||
print("您已默认关闭pushPlus推送!若需开启,请将pushPlusToken 填入本脚本目录下的pushPlusToken.txt文本中!\n")
|
||
|
||
if(yesornot == "y"):
|
||
if n_time>d_time0:
|
||
serverjiang()
|
||
else:
|
||
print("当前时间段非抢红包时间,默认关闭server酱推送以节约server酱每日5条推送的限额！")
|
||
else:
|
||
print("您已默认关闭server酱推送!若需开启,请将serverkey 填入本脚本目录下的serverkey.txt文本中!\n")
|
||
|
||
|
||
|
||
if __name__ == "__main__":
|
||
main() |