# -*- coding: utf-8 -*- """ new Env('爱奇艺'); """ import json import re import time from urllib.parse import unquote import hashlib import requests from utils import check class IQIYI: name = "爱奇艺" def __init__(self, check_item): self.check_item = check_item @staticmethod def parse_cookie(cookie): p00001 = re.findall(r"P00001=(.*?);", cookie)[0] if re.findall(r"P00001=(.*?);", cookie) else "" p00002 = re.findall(r"P00002=(.*?);", cookie)[0] if re.findall(r"P00002=(.*?);", cookie) else "" p00003 = re.findall(r"P00003=(.*?);", cookie)[0] if re.findall(r"P00003=(.*?);", cookie) else "" dfp = re.findall(r"dfp=(.*?);", cookie)[0] if re.findall(r"dfp=(.*?);", cookie) else "" return p00001, p00002, p00003, dfp @staticmethod def md5(data): return hashlib.md5(bytes(data, encoding="utf-8")).hexdigest() def get_sign(self, c, t, e=None): buf = [] for key, value in t.items(): buf.append("=".join([key, str(value)])) if e is not None: buf.append(e) return self.md5(c.join(buf)) return c.join(buf) @staticmethod def user_information(p00001): """ 账号信息查询 """ time.sleep(3) url = "http://serv.vip.iqiyi.com/vipgrowth/query.action" params = {"P00001": p00001} res = requests.get(url=url, params=params).json() if res["code"] == "A00000": try: res_data = res.get("data", {}) level = res_data.get("level", 0) # VIP 等级 growthvalue = res_data.get("growthvalue", 0) # 当前 VIP 成长值 distance = res_data.get("distance", 0) # 升级需要成长值 deadline = res_data.get("deadline", "非 VIP 用户") # VIP 到期时间 today_growth_value = res_data.get("todayGrowthValue", 0) # 今日成长值 msg = [ {"name": "VIP 等级", "value": level}, {"name": "当前成长", "value": growthvalue}, {"name": "今日成长", "value": today_growth_value}, {"name": "升级还需", "value": distance}, {"name": "VIP 到期", "value": deadline}, ] except Exception as e: msg = [ {"name": "账号信息", "value": str(e)}, ] print(msg) else: msg = [ {"name": "账号信息", "value": res.get("msg")}, ] return msg @staticmethod def sign(p00001): """ VIP 签到 """ url = "https://tc.vip.iqiyi.com/taskCenter/task/queryUserTask" params = {"P00001": p00001, "autoSign": "yes"} res = requests.get(url=url, params=params).json() if res["code"] == "A00000": try: cumulate_sign_days_sum = res["data"]["monthlyGrowthReward"] msg = [ {"name": "当月成长", "value": f"{cumulate_sign_days_sum}成长值"}, ] except Exception as e: print(e) msg = [{"name": "当月成长", "value": str(e)}] else: msg = [{"name": "当月成长", "value": res.get("msg")}] return msg def sign2(self, p00001, p00003): sign_date = { "agentType": "1", "agentversion": "1.0", "appKey": "basic_pcw", "authCookie": p00001, "qyid": self.md5("".join(random.sample(string.ascii_letters + string.digits, 16))), "task_code": "natural_month_sign", "timestamp": round(time.time() * 1000), "typeCode": "point", "userId": p00003, } post_date = { "natural_month_sign": { "agentType": "1", "agentversion": "1", "authCookie": p00001, "qyid": self.md5("".join(random.sample(string.ascii_letters + string.digits, 16))), "taskCode": "iQIYI_mofhr", "verticalCode": "iQIYI", } } sign = self.get_sign("|", sign_date, "UKobMjDMsDoScuWOfp6F") url = f"https://community.iqiyi.com/openApi/task/execute?{self.get_sign('&', sign_date)}&sign={sign}" header = {"Content-Type": "application/json"} res = requests.post(url, headers=header, data=json.dumps(post_date)).json() if res["code"] == "A00000": if res["data"]["code"] == "A0000": # quantity = res["data"]["data"]["rewards"][0]["rewardCount"] # 积分 # addgrowthvalue = res["data"]["data"]["rewards"][0]["rewardCount"] # 新增成长值 # continued = res["data"]["data"]["signDays"] # 签到天数 msg = [{"name": "APP 签到", "value": "签到成功"}] else: msg = [{"name": "APP 签到", "value": f"签到失败:{res['data']['msg']}"}] else: msg = [{"name": "APP 签到", "value": f"签到失败:{res['message']}"}] return msg def web_sign(self, p00001, p00003, dfp): dfp = dfp.split("@")[0] web_sign_date = { "agenttype": "1", "agentversion": "0", "appKey": "basic_pca", "appver": "0", "authCookie": p00001, "channelCode": "sign_pcw", "dfp": dfp, "scoreType": "1", "srcplatform": "1", "typeCode": "point", "userId": p00003, "user_agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/97.0.4692.71 Safari/537.36", "verticalCode": "iQIYI", } sign = self.get_sign("|", web_sign_date, "DO58SzN6ip9nbJ4QkM8H") url = f"https://community.iqiyi.com/openApi/score/add?{self.get_sign('&', web_sign_date)}&sign={sign}" res = requests.get(url).json() if res["code"] == "A00000": if res["data"][0]["code"] == "A0000": quantity = res["data"][0]["score"] continued = res["data"][0]["continuousValue"] msg = [{"name": "WEB 签到", "value": f"积分+{quantity} 累计签到{continued}天"}] else: msg = [{"name": "WEB 签到", "value": f"网页端签到失败:{res['data'][0]['message']}"}] else: msg = [{"name": "WEB 签到", "value": f"网页端签到失败:{res['message']}"}] return msg @staticmethod def query_user_task(p00001): """ 获取 VIP 日常任务 和 taskCode(任务状态) """ url = "https://tc.vip.iqiyi.com/taskCenter/task/queryUserTask" params = {"P00001": p00001} task_list = [] res = requests.get(url=url, params=params).json() if res["code"] == "A00000": for item in res["data"]["tasks"]["daily"]: task_list.append( { "name": item["name"], "taskCode": item["taskCode"], "status": item["status"], "taskReward": item["taskReward"]["task_reward_growth"], } ) return task_list @staticmethod def join_task(p00001, task_list): """ 遍历完成任务 """ url = "https://tc.vip.iqiyi.com/taskCenter/task/joinTask" params = {"P00001": p00001, "taskCode": "", "platform": "bb136ff4276771f3", "lang": "zh_CN"} for item in task_list: if item["status"] == 2: params["taskCode"] = item["taskCode"] requests.get(url=url, params=params) @staticmethod def get_task_rewards(p00001, task_list): """ 获取任务奖励 :return: 返回信息 """ url = "https://tc.vip.iqiyi.com/taskCenter/task/getTaskRewards" params = {"P00001": p00001, "taskCode": "", "platform": "bb136ff4276771f3", "lang": "zh_CN"} growth_task = 0 for item in task_list: if item["status"] == 0: params["taskCode"] = item.get("taskCode") requests.get(url=url, params=params) elif item["status"] == 4: 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"] msg = {"name": "任务奖励", "value": f"+{growth_task}成长值"} return msg @staticmethod def draw(draw_type, p00001, p00003): """ 查询抽奖次数(必),抽奖 :param draw_type: 类型。0 查询次数；1 抽奖 :param p00001: 关键参数 :param p00003: 关键参数 :return: {status, msg, chance} """ url = "https://iface2.iqiyi.com/aggregate/3.0/lottery_activity" params = { "lottery_chance": 1, "app_k": "b398b8ccbaeacca840073a7ee9b7e7e6", "app_v": "11.6.5", "platform_id": 10, "dev_os": "8.0.0", "dev_ua": "FRD-AL10", "net_sts": 1, "qyid": "2655b332a116d2247fac3dd66a5285011102", "psp_uid": p00003, "psp_cki": p00001, "psp_status": 3, "secure_v": 1, "secure_p": "GPhone", "req_sn": round(time.time() * 1000), } if draw_type == 1: del params["lottery_chance"] res = requests.get(url=url, params=params).json() if not res.get("code"): chance = int(res.get("daysurpluschance")) msg = res.get("awardName") return {"status": True, "msg": msg, "chance": chance} else: try: msg = res.get("kv", {}).get("msg") except Exception as e: print(e) msg = res["errorReason"] return {"status": False, "msg": msg, "chance": 0} def main(self): p00001, p00002, p00003, dfp = self.parse_cookie(self.check_item.get("cookie")) sign_msg = self.sign(p00001=p00001) web_sign_msg = self.web_sign(p00001=p00001, p00003=p00003, dfp=dfp) sign2_msg = self.sign2(p00001=p00001, p00003=p00003) chance = self.draw(0, p00001=p00001, p00003=p00003)["chance"] if chance: draw_msg = "" for i in range(chance): ret = self.draw(1, p00001=p00001, p00003=p00003) draw_msg += ret["msg"] + ";" if ret["status"] else "" else: draw_msg = "抽奖机会不足" task_msg = "" for one in range(6): 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")) user_name = user_info.get("user_name") user_name = user_name.replace(user_name[3:7], "****") nickname = user_info.get("nickname") except Exception as e: print(f"获取账号信息失败，错误信息: {e}") nickname = "未获取到，请检查 Cookie 中 P00002 字段" user_name = "未获取到，请检查 Cookie 中 P00002 字段" user_msg = self.user_information(p00001=p00001) msg = ( [ {"name": "用户账号", "value": user_name}, {"name": "用户昵称", "value": nickname}, ] + user_msg + sign_msg + web_sign_msg + sign2_msg + [ task_msg, {"name": "抽奖奖励", "value": draw_msg}, ] ) msg = "\n".join([f"{one.get('name')}: {one.get('value')}" for one in msg]) return msg @check(run_script_name="爱奇艺",run_script_expression="IQIYI|爱奇艺") def main(*args, **kwargs): return IQIYI(check_item=kwargs.get("value")).main() if __name__ == "__main__": main()