Compare commits

...

4 Commits

Author SHA1 Message Date
Sitoi
5996905863 ⬆️ 升级(__version__.py):更新版本号从24.2.9到24.2.16 2024-02-16 08:54:41 +08:00
Sitoi
7b974e32b7 新增(imaotai_login.py):添加了茅台商城登录及验证码获取功能 2024-02-16 08:54:32 +08:00
Sitoi
1f7c7159a3 功能(main.py):添加对自定义商品代码的支持
♻️ 重构(main.py):更改了使用商品代码的方式,现在使用用户提供的代码,如果没有提供,则使用默认代码
2024-02-16 08:54:11 +08:00
Sitoi
4143d92266 🐛 修复(iqiyi/main.py):更改了任务列表项的键名,从"name"改为"taskTitle"
♻️ 重构(iqiyi/main.py):优化了任务状态为4时的请求逻辑,提前获取了"taskCode"
 功能(iqiyi/main.py):减少了任务执行的次数,从6次改为3次,并移除了每次执行后的延时
2024-02-16 08:53:46 +08:00
4 changed files with 186 additions and 6 deletions

View File

@ -1 +1 @@
__version__ = "24.2.9"
__version__ = "24.2.16"

View File

@ -283,6 +283,7 @@ userId: 2
userId = self.check_item.get("userid")
lat = self.check_item.get("lat")
lng = self.check_item.get("lng")
item_codes = self.check_item.get("item_codes", self.ITEM_CODES)
reserve_rule = self.check_item.get("reserve_rule", 0)
msg = [
{
@ -298,7 +299,7 @@ userId: 2
self.get_current_session_id()
self.init_headers(user_id=userId, token=token, lng=lng, lat=lat)
try:
for item in self.ITEM_CODES:
for item in item_codes:
max_shop_id = self.get_location_count(
province=province,
city=city,

View File

@ -128,7 +128,7 @@ class IQIYI(CheckIn):
for item in res["data"]["tasks"]["daily"]:
task_list.append(
{
"name": item["name"],
"taskTitle": item["taskTitle"],
"taskCode": item["taskCode"],
"status": item["status"],
"taskReward": item["taskReward"]["task_reward_growth"],
@ -172,10 +172,10 @@ class IQIYI(CheckIn):
params["taskCode"] = item.get("taskCode")
requests.get(url=url, params=params)
elif item["status"] == 4:
params["taskCode"] = item.get("taskCode")
requests.get(
url="https://tc.vip.iqiyi.com/taskCenter/task/notify", params=params
)
params["taskCode"] = item.get("taskCode")
requests.get(url=url, params=params)
elif item["status"] == 1:
growth_task += item["taskReward"]
@ -384,10 +384,9 @@ class IQIYI(CheckIn):
else:
draw_msg = "抽奖机会不足"
task_msg = ""
for _ in range(6):
for _ in range(3):
task_list = self.query_user_task(p00001=p00001)
self.join_task(p00001=p00001, task_list=task_list)
time.sleep(10)
task_msg = self.get_task_rewards(p00001=p00001, task_list=task_list)
try:
user_info = json.loads(unquote(p00002, encoding="utf-8"))

180
imaotai_login.py Normal file
View File

@ -0,0 +1,180 @@
import hashlib
import json
import time
import requests
"""
获取地点信息,这里用的高德 api,需要自己去高德开发者平台申请自己的 key
"""
AMAP_KEY = ""
SALT = "2af72f100c356273d46284f6fd1dfc08"
CURRENT_TIME = str(int(time.time() * 1000))
headers = {}
mt_version = json.loads(
requests.get("https://itunes.apple.com/cn/lookup?id=1600482450").text
)["results"][0]["version"]
header_context = """
MT-Lat: 28.499562
MT-K: 1675213490331
MT-Lng: 102.182324
Host: app.moutai519.com.cn
MT-User-Tag: 0
Accept: */*
MT-Network-Type: WIFI
MT-Token: 1
MT-Team-ID: 1
MT-Info: 028e7f96f6369cafe1d105579c5b9377
MT-Device-ID: 2F2075D0-B66C-4287-A903-DBFF6358342A
MT-Bundle-ID: com.moutai.mall
Accept-Language: en-CN;q=1, zh-Hans-CN;q=0.9
MT-Request-ID: 167560018873318465
MT-APP-Version: 1.3.7
User-Agent: iOS;16.3;Apple;?unrecognized?
MT-R: clips_OlU6TmFRag5rCXwbNAQ/Tz1SKlN8THcecBp/HGhHdw==
Content-Length: 93
Accept-Encoding: gzip, deflate, br
Connection: keep-alive
Content-Type: application/json
userId: 2
"""
# 初始化请求头
def init_headers(
user_id: str = "1", token: str = "2", lat: str = "29.83826", lng: str = "119.74375"
):
for k in header_context.strip().split("\n"):
temp_l = k.split(": ")
dict.update(headers, {temp_l[0]: temp_l[1]})
dict.update(headers, {"userId": user_id})
dict.update(headers, {"MT-Token": token})
dict.update(headers, {"MT-Lat": lat})
dict.update(headers, {"MT-Lng": lng})
dict.update(headers, {"MT-APP-Version": mt_version})
# 用高德api获取地图信息
def select_geo(i: str):
# 校验高德api是否配置
if AMAP_KEY is None:
print("!!!!请配置 AMAP_KEY (高德地图的MapKey)")
raise ValueError
resp = requests.get(
f"https://restapi.amap.com/v3/geocode/geo?key={AMAP_KEY}&output=json&address={i}"
)
geocodes: list = resp.json()["geocodes"]
return geocodes
def signature(data: dict):
keys = sorted(data.keys())
temp_v = ""
for item in keys:
temp_v += data[item]
text = SALT + temp_v + CURRENT_TIME
hl = hashlib.md5()
hl.update(text.encode(encoding="utf8"))
md5 = hl.hexdigest()
return md5
# 获取登录手机验证码
def get_vcode(mobile: str):
params = {"mobile": mobile}
md5 = signature(params)
dict.update(
params, {"md5": md5, "timestamp": CURRENT_TIME, "MT-APP-Version": mt_version}
)
responses = requests.post(
"https://app.moutai519.com.cn/xhr/front/user/register/vcode",
json=params,
headers=headers,
)
if responses.status_code != 200:
print(
f"get v_code : params : {params}, response code : {responses.status_code}, response body : {responses.text}"
)
# 执行登录操作
def login(mobile: str, v_code: str):
params = {"mobile": mobile, "vCode": v_code, "ydToken": "", "ydLogId": ""}
md5 = signature(params)
dict.update(
params, {"md5": md5, "timestamp": CURRENT_TIME, "MT-APP-Version": mt_version}
)
responses = requests.post(
"https://app.moutai519.com.cn/xhr/front/user/register/login",
json=params,
headers=headers,
)
if responses.status_code != 200:
print(
f"login : params : {params}, response code : {responses.status_code}, response body : {responses.text}"
)
dict.update(headers, {"MT-Token": responses.json()["data"]["token"]})
dict.update(headers, {"userId": responses.json()["data"]["userId"]})
return responses.json()["data"]["token"], responses.json()["data"]["userId"]
def get_location():
while 1:
location = input(
"请输入精确小区位置,例如[小区名称],为你自动预约附近的门店:"
).strip()
selects = select_geo(location)
a = 0
for item in selects:
formatted_address = item["formatted_address"]
province = item["province"]
print(f"{a} : [地区:{province},位置:{formatted_address}]")
a += 1
user_select = input("请选择位置序号,重新输入请输入[-]:").strip()
if user_select == "-":
continue
select = selects[int(user_select)]
formatted_address = select["formatted_address"]
province = select["province"]
print(f"已选择 地区:{province},[{formatted_address}]附近的门店")
return select
if __name__ == "__main__":
items = []
while 1:
init_headers()
location_select: dict = get_location()
province = location_select["province"]
city = location_select["city"]
location: str = location_select["location"]
mobile = input("输入手机号[18888888888]:").strip()
get_vcode(mobile)
code = input(f"输入 [{mobile}] 验证码[8888]:").strip()
token, userId = login(mobile, code)
item = {
"province": province,
"city": str(city),
"lat": location.split(",")[1],
"lng": location.split(",")[0],
"mobile": str(mobile),
"token": str(token),
"userid": str(userId),
"reserve_rule": 0,
"item_codes": ["10941", "10942"],
}
items.append(item)
condition = input("是否继续添加账号[y/n]:").strip()
with open("account.json", "w") as f:
f.write(json.dumps(items, ensure_ascii=False, indent=4))
if condition.lower() == "n":
break