From bb0bde0d6a0784e5ccac7137e29336eeed81bd4d Mon Sep 17 00:00:00 2001 From: zjk2017 <2548836866@qq.com> Date: Wed, 26 Jun 2024 16:19:18 +0800 Subject: [PATCH] =?UTF-8?q?Create=20=E8=A7=82mei=E6=97=A5=E6=9C=AC.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tianyi/观mei日本.py | 851 ++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 851 insertions(+) create mode 100644 tianyi/观mei日本.py diff --git a/tianyi/观mei日本.py b/tianyi/观mei日本.py new file mode 100644 index 0000000..8573fe2 --- /dev/null +++ b/tianyi/观mei日本.py @@ -0,0 +1,851 @@ +""" +观美日本(资生堂） +cron: 5 9 * * * +new Env("观美日本(资生堂）") +fix 20240625 ArcadiaScriptPublic 频道：https://t.me/ArcadiaScript 群组：https://t.me/ArcadiaScriptPublic +修复签到失败问题 +增加打印签到信息 +更新cron + +#小程序://观美日本 +搜api.shiseidochina.cn/api/v1/app/user/login +只要openid +变量名gmsbrb +脚本作者: QGh3amllamll +版本 1.0 刚学习的py的时候写的 + +""" +import os +import requests + +import random +import json +import time +from datetime import datetime, timezone, timedelta +import sys + +# 控制变量 +enable_notification = 1 # 设置为0将不发送通知，设置为1则发送通知 + +# 只有在需要发送通知时才尝试导入notify模块 +if enable_notification == 1: + try: + from notify import send + except ModuleNotFoundError: + print("警告：未找到notify.py模块。它不是一个依赖项，请勿错误安装。程序将退出。") + sys.exit(1) + +# 封装headers的函数 + +UA="Mozilla/5.0 (Linux; Android 9; COR-AL10 Build/HUAWEICOR-AL10; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/111.0.5563.116 Mobile Safari/537.36 XWEB/5317 MMWEBSDK/20230504 MMWEBID/7516 MicroMessenger/8.0.37.2380(0x2800255B) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64 MiniProgramEnv/android" + +def get_headers(token): + headers = { + 'Host': 'gtj-api.shiseidochina.cn', + 'Connection': 'keep-alive', + 'Content-Length': '28', + 'x-shop-c': 'gtj', + 'charset': 'utf-8', + 'User-Agent': UA, + 'content-type': 'application/json;charset=UTF-8', + 'Accept-Encoding': 'gzip,compress,br,deflate', + "x-ma-c": 'ddc266d3ce1e2dde2398bcfdb71f0e78', + "x-auth-token": token, + 'Referer': 'https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html' + } + return headers + + +def login_and_get_token(openid):#获取token + url = "https://gtj-api.shiseidochina.cn/api/v1/app/user/login" + headers = { + "Connection": "keep-alive", + "x-ma-c": "ddc266d3ce1e2dde2398bcfdb71f0e78", + "xweb_xhr": "1", + "x-auth-token": "", + "x-shop-c": "gtj", + "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36 MicroMessenger/7.0.20.1781(0x6700143B) NetType/WIFI MiniProgramEnv/Windows WindowsWechat/WMPF WindowsWechat(0x63090621)XWEB/8461", + "Content-Type": "application/json;charset=UTF-8", + "Accept": "*/*", + "Sec-Fetch-Site": "cross-site", + "Sec-Fetch-Mode": "cors", + "Sec-Fetch-Dest": "empty", + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html", + "Accept-Encoding": "gzip, deflate, br", + "Accept-Language": "zh-CN,zh;q=0.9" + } + + data = { + "openid": openid, + "loginName": openid, + "loginType": "wechat-app", + "appUserType": 3, + "loginNameType": "openid", + "ext": "{\"scene\":1256}" + } + data = json.dumps(data, separators=(',', ':')) + + response = requests.post(url, headers=headers, data=data) + + if response.status_code == 200: + token = response.headers.get("x-auth-token") + #print(f'打印账号ck {token}') # Print the token + return token + else: + print(f'无法获取 openid 的令牌') + return None + + +def check_daily_tasks(token):#任务 + url = "https://gtj-api.shiseidochina.cn/api/v1/mission/group/list" + headers = { + "x-shop-c": "gtj", + "charset": "utf-8", + 'User-Agent': UA, + "content-type": "application/json;charset=UTF-8", + "x-ma-c": 'ddc266d3ce1e2dde2398bcfdb71f0e78', + "x-auth-token": token, + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html" + } + data = { + "groupName": "每日任务" + } + + response = requests.post(url, headers=headers, data=json.dumps(data)) + + if response.status_code == 200: + response_content = response.json() + + for item in response_content.get('data', []): + # print(f"任务列表 {item}") + + name = item.get('name', '') + id = item.get('id', '') + print(f"任务id: {id} 任务名称: {name} ") + + if name == '签到任务': + for action in item.get('missionActionVOList', []): + progress_id = action.get('missionCustomerProgressVO', {}).get('progressId') + if progress_id is not None: + #print('存在 progressId，表示 已经签到/完成签到') + # print('存在 签到记录，= 已经签到/完成签到') + # 在这里执行签到任务的操作 + #sbrbqd(x_ma_c, token) + print(f"完成签到 任务id: {id} 任务名称: {name}") + else: + print('不存在 progressId，执行签到任务') + # 在这里执行签到任务的操作 + sbrbqd(token,id) + + elif name == '每日阅读': + for action in item.get('missionActionVOList', []): + progress_value = action.get('missionCustomerProgressVO', {}).get('progressValue') + if progress_value >= 3.0: + print(f'每日阅读任务已完成') + """# 测试评论 + article_ids = get_article_ids(token) + if article_ids: + # 提交文章点赞统计请求并获取 limit 值和完整响应 + limit, full_response = post_article_upvote_stats( token, article_ids) + print("成功提交数据：", limit) + visit_article_urls( token, article_ids) + + """ # 测试评论 + else: + print(f'每日阅读任务未完成，准备开始') + # 在这里执行每日阅读任务的操作 + article_ids = get_article_ids(token) + if article_ids: + # 提交文章点赞统计请求并获取 limit 值和完整响应 + limit, full_response = post_article_upvote_stats( token, article_ids) + print("成功提交数据：", limit) + visit_article_urls( token, article_ids) + + # elif name == '每日分享': + # for action in item.get('missionActionVOList', []): + # progress_value = action.get('missionCustomerProgressVO', {}).get('progressValue') + # if progress_value >= 1.0: + # print(f'每日分享任务已完成') + # else: + # print(f'每日分享任务未完成，准备开始') + # # 在这里执行每日分享任务的操作 + # # 添加你的每日分享任务代码逻辑 + + + # 检查 ProgressId + """ + for action in item.get('missionActionVOList', []): + if item.get('name') in ['每日阅读', '每日分享']: + progress_id = action.get('missionCustomerProgressVO', {}).get('progressId') + if progress_id is not None: + print(f'任务 {item.get("name")}: 存在 progressId，ID为：{progress_id}') + reward_response = accept_reward(token, progress_id, name) + print(f'任务 {name} 领取奖励响应：{reward_response}') + """ + +def sbrbqd(token,id):#签到函数 + url = "https://gtj-api.shiseidochina.cn/api/v1/mission/daily/subscribe" + headers = { + "Host": "gtj-api.shiseidochina.cn", + "Connection": "keep-alive", + "x-shop-c": "gtj", + "charset": "utf-8", + "User-Agent": UA, + "content-type": "application/json;charset=UTF-8", + "Accept-Encoding": "gzip,compress,br,deflate", + "x-ma-c": 'ddc266d3ce1e2dde2398bcfdb71f0e78', + "x-auth-token": token, + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html" + } + # 定义请求数据 + data = { + "missionId": id, + "eventCode": "sign_in" + } + + # 发送POST请求 + response = requests.post(url, headers=headers, data=json.dumps(data)) + + # 检查响应状态码 + + + if response.status_code == 200: + response_content = response.json() + print(f"签到响应 {response_content}") + if response_content['statusCode'] == '100010': + if len(response_content['data']) > 0: + progress_id = response_content['data'][0] # 获取列表中的第一个元素作为progress_id + print("进度ID（progress_id）:", progress_id) + + # 构造新的URL和请求体 + accept_url = "https://gtj-api.shiseidochina.cn/api/v1/mission/accept/reward" + accept_data = { + "progressIds": [progress_id], + "missionName": "签到任务" + } + + # 发送提交任务的POST请求 + accept_response = requests.post(accept_url, headers=headers, data=json.dumps(accept_data)) + + # 检查提交任务的响应状态码 + if accept_response.status_code == 200: + accept_response_content = accept_response.json() + # 在这里处理提交任务成功的逻辑 + # 可以根据实际情况解析响应体并判断任务提交是否成功 + # 根据需求返回相应的结果或执行其他操作 + else: + print("提交任务请求失败，状态码非 200。") + else: + # 数据列表为空，直接退出当前任务 + print("数据列表为空，退出当前任务。") + return + else: + print("请求成功，但响应码非100010。") + else: + print("请求失败，状态码非 200。") + +def get_article_ids(token): # 获取文章ID的函数 + # 自定义搜索关键词的字典 + search_word_options = [ + "云", "雨", "雪", "河", "海", "星", "天空", "草", "石", "林", "火", + "鸟", "鱼", "光", "露", "松", "荷", "桥", "彩虹", "电", "夜晚", "火锅", + "面", "川", "苏", "茶", "拉面", "富士山", "京都", "东京", "奈良", + "北海道", "冲绳", "神户", "大阪", "横滨", "箱根", "金阁寺", "浅草寺", + "宫崎", "鹿儿岛", "寿司", "拉面", "天妇罗", "刺身", "和牛", "抹茶", + "味增汤", "寿司盖饭", "日式咖喱", "酱油拉面", "日式煎饼月", "花", "田", + "水", "风", "露", "雨", "光", "面", "酒", "鱼", "便", "茶", + "D", "E", "Z", "生活", "动漫", "地铁" + ] + + + # 随机选择一个搜索关键词 + + random_search_word = random.choice(search_word_options) + print(f"搜索关键词: {random_search_word}") + + url = 'https://gtj-api.shiseidochina.cn/api/v1/article/search' + headers = get_headers(token) + + # POST 请求的请求体 + + payload = { + "searchWord": random_search_word, + "templateCodes": ["backend", "frontend"], + "pageNum": 1, + "pageSize": 10 + } + + + + + """ + #指定 + random_search_w + url = 'https://gtj-api.shiseidochina.cn/api/v1/article/search' + headers = get_headers(token) + + # POST 请求的请求体 + payload = { + "templateCodes": ["frontend", "backend"], + "authorTypes": ["3", "4", "5"], + "sorts": ["ONLINE_TIME_DESC", "FAVORITE_DESC", "UP_VOTE_DESC", "SORT_DESC"], + "pageNum": 9, + "pageSize": 10 + } + """ + + + # 发送 POST 请求 + # 发送 POST 请求 + response = requests.post(url, headers=headers, json=payload) + + if response.status_code == 200: + try: + data = response.json().get('data', {}) + article_ids = [str(item['id']) for item in data.get('list', []) if len(str(item['id'])) == 7] + print(f"请求成功。文章 ID 列表： {article_ids}") + return article_ids + except ValueError as e: + print("Failed to parse the response body:", e) + else: + print(f"Request failed, status code: {response.status_code}") + + return None + + + # 封装点赞统计请求的函数 +def post_article_upvote_stats( token, article_ids):# 获取文章 ID请求的函数 + url = 'https://gtj-api.shiseidochina.cn/api/v2/article/upvote/stats' + headers = get_headers( token) + payload = json.dumps({"articleIds": article_ids}) + response = requests.post(url, headers=headers, data=payload) + response.raise_for_status() + #print(payload) + # 解析响应数据 + response_data = response.json() + + # 提取 limit 值 + limit_value = response_data.get('data', {}).get('paginator', {}).get('limit') + + # 返回 limit 值和完整的响应数据 + return limit_value, response_data + +def visit_article_urls(token, article_ids): #阅读+分享函数 + headers = { + "Host": "gtj-api.shiseidochina.cn", + "Connection": "keep-alive", + #"Content-Length": "51", + "x-shop-c": "gtj", + "charset": "utf-8", + "User-Agent": "Mozilla/5.0 (Linux; Android 9; MI 6 Build/PKQ1.190118.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/111.0.5563.116 Mobile Safari/537.36 XWEB/5317 MMWEBSDK/20230405 MMWEBID/2357 MicroMessenger/8.0.35.2360(0x2800235D) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64 MiniProgramEnv/android", + "content-type": "application/json; charset=UTF-8", + "Accept-Encoding": "gzip,compress,br,deflate", + "x-ma-c": 'ddc266d3ce1e2dde2398bcfdb71f0e78', + "x-auth-token": token, + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html" + } + + max_articles = 3 + + for article_id in article_ids[:max_articles]: + sleep_time = random.randint(1, 3) + print(f"等待 {sleep_time} 秒...") + time.sleep(sleep_time) + + url = f"https://gtj-api.shiseidochina.cn/api/v2/article/{article_id}/detail" + print("-" * 48) + print(f"本次文章ID:{article_id}") + + response = requests.get(url, headers=headers) + + if response.status_code == 200: + try: + response_content = response.json() + author_id = response_content.get("data", {}).get("authorId", "") + print(f"分享ID内容: {author_id}") + #分享 + query_url = "https://gtj-api.shiseidochina.cn/api/v1/customer/query" + query_data = {"customerId": author_id} + query_response = requests.post(query_url, headers=headers, data=json.dumps(query_data)) + if query_response.status_code == 200: + query_response_content = query_response.json() + print("提交分享ID 准备分享") + + ubt_url = "https://gtj-api.shiseidochina.cn/api/v1/ubt/event/add" + ubt_data = [{"code": "shared_article", "param": {"article": article_id}}] + #print(ubt_data) + ubt_response = requests.post(ubt_url, headers=headers, data=json.dumps(ubt_data)) + if ubt_response.status_code == 200: + ubt_response_content = ubt_response.json() + + print("分享ID成功") + else: + print("发送客户信息失败，状态码非 200。") + else: + print("查询客户信息失败，状态码非 200。") + + article_labels = response_content.get("data", {}).get("articleLabels", []) + label_names = [label.get("labelName", "") for label in article_labels] + print(f"准备提交的请求体labels内容: {label_names}") + #阅读 + post_url = "https://gtj-api.shiseidochina.cn/api/v1/article/search" + post_data = { + "labels": label_names, + "excludeIds": [article_id], + "sorts": ["UP_VOTE_DESC"], + "pageNum": 1, + "pageSize": 5 + } + post_response = requests.post(post_url, headers=headers, data=json.dumps(post_data)) + + if post_response.status_code == 200: + post_response_content = post_response.json() + print("提交labels成功/阅读成功。") + else: + print("POST 请求失败，状态码非 200。") + + # 第二次请求 + ubt_data_2 = [ + {"code": "view_article", "param": {"article": article_id}}, + {"code": "be_read_article", "param": {"article": article_id}} + ] + ubt_response_2 = requests.post(ubt_url, headers=headers, data=json.dumps(ubt_data_2)) + if ubt_response_2.status_code == 200: + ubt_response_content_2 = ubt_response_2.json() + print("二次请求成功") + #print(ubt_data_2) + else: + print("二次请求失败，状态码非 200。") + #评论 + pl_url = "https://gtj-api.shiseidochina.cn/api/v1/customer/query" + pl_data = {} + pl_response = requests.post(pl_url, headers=headers, data=json.dumps(pl_data)) + + response_json = pl_response.json() # 获取响应的JSON数据 + + # 提取所需的数据 + pic_url = response_json['data']['picUrl'] + nickname = response_json['data']['nickname'] + #print("Nickname:", nickname, "Pic URL:", pic_url) + # 提交评论 + submit_url = "https://gtj-api.shiseidochina.cn/api/v1/comment/submitArticleComment" + #article_id = 1073987 # 假设的文章ID + #comment_content = "怎样都好，只要能让他们发笑就好" + hitokoto_content = fetch_hitokoto() + print(hitokoto_content) + + + comment_data = { + "extention": article_id, + "content": hitokoto_content, + "profilePhoto": pic_url, + "nickName": nickname + } + submit_response = requests.post(submit_url, headers=headers, data=json.dumps(comment_data)) + + # 检查提交结果 + + if submit_response.ok: + print("评论提交成功") + #print(submit_response.json()) # 打印响应 + + # 将label_names中的内容作为单独的name值添加到请求体中 + #""" + tag_list = [{"name": name} for name in label_names] + print(tag_list) + request_body = json.dumps([{"groupName": "hidden", "tagList": tag_list}]) + print(request_body) + + """ + tag_list = [{"name": name} for name in label_names] + request_body = json.dumps([{"groupName": "hidden", "tagList": tag_list}], ensure_ascii=False) + print(request_body) + """ + # 访问指定的URL并发送第一次POST请求 + tag_url = "https://gtj-api.shiseidochina.cn/api/v1/customer/tag/increase/add" + tag_response_1 = requests.post(tag_url, headers=headers, data=request_body) + # 检查第一次请求的结果 + if tag_response_1.ok: + print("第一次标签增加请求成功") + print(tag_response_1.json()) + else: + print("第一次标签增加请求失败，错误代码:", tag_response_1.status_code) + + # （可选）如果需要，可以修改tag_list来发送不同的数据 + # tag_list = [{"name": another_name} for another_name in another_label_names] + # request_body = json.dumps([{"groupName": "hidden", "tagList": tag_list}]) + + # 发送第二次POST请求 + tag_response_2 = requests.post(tag_url, headers=headers, data=request_body) + # 检查第二次请求的结果 + if tag_response_2.ok: + print("第二次标签增加请求成功") + print(tag_response_2.json()) + else: + print("第二次标签增加请求失败，错误代码:", tag_response_2.status_code) + + else: + print("评论提交失败，错误代码:", submit_response.status_code) + + + except json.JSONDecodeError: + print("响应内容不是 JSON 格式，无法打印。") + else: + print("的文章ID列表。") + +""" +def plhqtxul(token):#评论 提取需要的头像 用户名 + + pl_url = "https://gtj-api.shiseidochina.cn/api/v1/customer/query" + headerspl = { + "Host": "gtj-api.shiseidochina.cn", + "Connection": "keep-alive", + "x-shop-c": "gtj", + "charset": "utf-8", + "User-Agent": "Mozilla/5.0 (Linux; Android 9; MI 6 Build/PKQ1.190118.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/111.0.5563.116 Mobile Safari/537.36 XWEB/5317 MMWEBSDK/20230405 MMWEBID/2357 MicroMessenger/8.0.35.2360(0x2800235D) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64 MiniProgramEnv/android", + "content-type": "application/json; charset=UTF-8", + "Accept-Encoding": "gzip,compress,br,deflate", + "x-ma-c": 'ddc266d3ce1e2dde2398bcfdb71f0e78', + "x-auth-token": token, + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html" + } + + pl_data = {} + response = requests.post(pl_url, headers=headerspl, data=json.dumps(pl_data)) + response_json = response.json() + + pic_url = response_json.get('data', {}).get('picUrl', None) + nickname = response_json.get('data', {}).get('nickname', None) + # 在函数内打印结果 + print("Nickname:", nickname, "Pic URL:", pic_url) + + return nickname, pic_url +""" + + + +def accept_reward(token, progress_id, name): # 领取任务奖励 + url = "https://gtj-api.shiseidochina.cn/api/v1/mission/accept/reward" + headers = { + "x-shop-c": "gtj", + "charset": "utf-8", + 'User-Agent': UA, + "content-type": "application/json;charset=UTF-8", + "x-ma-c": "ddc266d3ce1e2dde2398bcfdb71f0e78", + "x-auth-token": token, + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html" + } + data = { + "progressIds": [progress_id], + "missionName": name, + } + + response = requests.post(url, headers=headers, data=json.dumps(data)) + response_json = response.json() + + # 在这里处理响应内容 + if response_json.get("data"): + for item in response_json["data"]: + if "pointVO" in item and item["pointVO"].get("isSucceed", False): + print(f"任务 {name} 领取奖励积分：{item['pointVO']['point']}") + else: + print(f"任务 {name} 没有积分奖励") + else: + print(f"任务 {name} 领取奖励响应：{response_json}") + + return response_json + +def get_beijing_date(): # 获取北京日期的函数 + tz = timezone(timedelta(hours=8)) # 北京时间 UTC+8 + return datetime.now(tz).strftime('%Y-%m-%d') + +def query_customer_point(token):#判断今日是不是已经获取过奖励 + url = "https://gtj-api.shiseidochina.cn/api/v1/customer/point/query" + + headers = { + 'Host': 'gtj-api.shiseidochina.cn', + 'Connection': 'keep-alive', + 'x-shop-c': 'gtj', + 'charset': 'utf-8', + 'User-Agent': UA, + 'content-type': 'application/json;charset=UTF-8', + 'Accept-Encoding': 'gzip,compress,br,deflate', + 'x-ma-c': 'ddc266d3ce1e2dde2398bcfdb71f0e78', + 'x-auth-token': token, + 'Referer': 'https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html' + } + + data = {"type": "ADD", "page": 1, "pageSize": 15} + response = requests.post(url, headers=headers, json=data) + + # 这里是您之前提供的逻辑，直接放在 check_daily_progressIdtasks1 函数中 + target_date = get_beijing_date() # 获取今天的日期 + # task_status = {'每日阅读': False, '每日分享': False} + task_status = {'每日阅读': False} + + if response.status_code == 200: + response_data = response.json() + if 'data' in response_data and 'list' in response_data['data']: + your_data_list = response_data['data']['list'] + + for item in your_data_list: + if item['createTime'].startswith(target_date): + #print("奖励时间:", item['createTime'], ",完成任务:", item['reason']) + if item['reason'] in task_status: + task_status[item['reason']] = True + + # 使用更新后的 task_status + else: + print("列表没有数据['data']") + else: + print("获取数据失败-码:", response.status_code) + + # task_status 现在已经是一个更新后的字典，可以用于下面的逻辑 + for task, completed in task_status.items(): + if completed: + print(f"奖励 {task} 已获得，不运行任务奖励。") + else: + print(f"奖励 {task} 未获得，准备运行任务奖励。") + check_daily_progressIdtasks(token) + # 这里添加执行任务的代码 + + +def check_daily_progressIdtasks(token):#获取任务奖励 progressId + url = "https://gtj-api.shiseidochina.cn/api/v1/mission/group/list" + headers = { + "x-shop-c": "gtj", + "charset": "utf-8", + 'User-Agent': UA, + "content-type": "application/json;charset=UTF-8", + "x-ma-c": 'ddc266d3ce1e2dde2398bcfdb71f0e78', + "x-auth-token": token, + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html" + } + data = { + "groupName": "每日任务" + } + + response = requests.post(url, headers=headers, data=json.dumps(data)) + + if response.status_code == 200: + response_content = response.json() + """ + # 检查 ProgressId + for item in response_content.get('data', []): + for action in item.get('missionActionVOList', []): + if item.get('name') in ['每日阅读', '每日分享']: + progress_id = action.get('missionCustomerProgressVO', {}).get('progressId') + if progress_id is not None: + print(f'任务11 {item.get("name")}: 存在 progressId，ID为：{progress_id}') + # 此处需要实现 accept_reward 函数 + reward_response = accept_reward(token, progress_id, item.get("name")) + print(f'任务11 {item.get("name")} 领取奖励响应：{reward_response}') + """ + + for item in response_content.get('data', []): + for action in item.get('missionActionVOList', []): + mission_name = item.get('name') + progress_data = action.get('missionCustomerProgressVO', {}) + progress_id = progress_data.get('progressId') + + if progress_id is not None: + if mission_name == '每日阅读': + # 处理每日阅读任务 + reward_response = accept_reward(token, progress_id, item.get("name")) + break # 找到并处理了每日阅读后退出循环 + elif mission_name == '每日分享': + reward_response = accept_reward(token, progress_id, item.get("name")) + # 这里不做任何操作，或者可以添加日志记录 + pass + else: + # progressId 无效或不存在的处理 + print(f"警告：无法找到有效的 progressId，任务名称：{mission_name}") + + +def fetch_hitokoto(): #获取 一言 的内容 + # 设置句子类型为文学（d）、原创（e）、哲学（k）和诗词（i），最小长度为15 + url_hitokoto = 'https://v1.hitokoto.cn/?c=d&e=k&l&e&min_length=15' + response_hitokoto = requests.get(url_hitokoto) + if response_hitokoto.status_code == 200: + data = response_hitokoto.json() + hitokoto_content = data.get('hitokoto', None) + #print(hitokoto_content) + return hitokoto_content # 确保有这行代码 + + + +def query_customer(token):#积分 + url = "https://gtj-api.shiseidochina.cn/api/v1/customer/query" + headers = { + "x-shop-c": "gtj", + "charset": "utf-8", + "User-Agent": UA, + "content-type": "application/json;charset=UTF-8", + "Accept-Encoding": "gzip,compress,br,deflate", + "x-ma-c": "ddc266d3ce1e2dde2398bcfdb71f0e78", + "x-auth-token": token, + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html" + } + data = {} # 空的请求体 + + response = requests.post(url, headers=headers, data=json.dumps(data)) + #print(response.json()) # 打印响应体的 JSON 数据 + # 提取 availableQty 和 totalQty + response_json = response.json() # 从响应中提取 JSON 数据 + available_qty = response_json['data']['pointAccountVO']['availableQty'] + total_qty = response_json['data']['pointAccountVO']['totalQty'] + print("可用积分:", available_qty, "总积分:", total_qty) + # 返回提取的积分信息 + return { + "可用积分": available_qty, + "总积分": total_qty + } + +def check_super_tasks(token):#进阶任务 + url = "https://gtj-api.shiseidochina.cn/api/v1/mission/group/list" + headers = { + "x-shop-c": "gtj", + "charset": "utf-8", + 'User-Agent': UA, + "content-type": "application/json;charset=UTF-8", + "x-ma-c": 'ddc266d3ce1e2dde2398bcfdb71f0e78', + "x-auth-token": token, + "Referer": "https://servicewechat.com/wxbeb52e1c3bd2e11c/45/page-frame.html" + } + data = { + "groupName": "进阶任务" + } + + response = requests.post(url, headers=headers, data=json.dumps(data)) + + if response.status_code == 200: + response_content = response.json() + + for item in response_content.get('data', []): + # print(f"任务列表 {item}") + + name = item.get('name', '') + id = item.get('id', '') + print(f"任务id: {id} 任务名称: {name} ") + + # if name == '签到任务': + # for action in item.get('missionActionVOList', []): + # progress_id = action.get('missionCustomerProgressVO', {}).get('progressId') + # if progress_id is not None: + # #print('存在 progressId，表示 已经签到/完成签到') + # print('存在 签到记录，= 已经签到/完成签到') + # # 在这里执行签到任务的操作 + # #sbrbqd(x_ma_c, token) + # print(f"完成签到 任务id: {id}") + # else: + # print('不存在 progressId，执行签到任务') + # # 在这里执行签到任务的操作 + # sbrbqd(token,id) + + # elif name == '每日阅读': + # for action in item.get('missionActionVOList', []): + # progress_value = action.get('missionCustomerProgressVO', {}).get('progressValue') + # if progress_value >= 3.0: + # print(f'每日阅读任务已完成') + # """# 测试评论 + # article_ids = get_article_ids(token) + # if article_ids: + # # 提交文章点赞统计请求并获取 limit 值和完整响应 + # limit, full_response = post_article_upvote_stats( token, article_ids) + # print("成功提交数据：", limit) + # visit_article_urls( token, article_ids) + + # """ # 测试评论 + # else: + # print(f'每日阅读任务未完成，准备开始') + # # 在这里执行每日阅读任务的操作 + # article_ids = get_article_ids(token) + # if article_ids: + # # 提交文章点赞统计请求并获取 limit 值和完整响应 + # limit, full_response = post_article_upvote_stats( token, article_ids) + # print("成功提交数据：", limit) + # visit_article_urls( token, article_ids) + + if name == '优质分享': + for action in item.get('missionActionVOList', []): + progress_value = action.get('missionCustomerProgressVO', {}).get('progressValue') + if progress_value >= 1.0: + print(f'优质分享任务已完成') + else: + print(f'优质分享任务未完成，准备开始') + # # 在这里执行每日分享任务的操作 + + # # 添加你的每日分享任务代码逻辑 + + + # 检查 ProgressId + """ + for action in item.get('missionActionVOList', []): + if item.get('name') in ['每日阅读', '每日分享']: + progress_id = action.get('missionCustomerProgressVO', {}).get('progressId') + if progress_id is not None: + print(f'任务 {item.get("name")}: 存在 progressId，ID为：{progress_id}') + reward_response = accept_reward(token, progress_id, name) + print(f'任务 {name} 领取奖励响应：{reward_response}') + """ + +def main(): + openids = os.getenv('gmsbrb') + if openids is None: + print('环境变量 gmsbrb 未设置，请检查。') + return + + openid_lines = openids.split('\n') + openid_remarks = [line.split('#', 1) for line in openid_lines if line.strip()] + if not openid_remarks: + print('环境变量 gmsbrb 值格式不正确，请至少提供一个有效的 openid。') + return + + num_accounts = len(openid_remarks) + print(f'-----------本次账号运行数量：{num_accounts}-----------') + + # 存储账号的 token 和备注信息 + account_infos = [] + + for i, item in enumerate(openid_remarks): + openid = item[0] + remark = item[1] if len(item) > 1 else "无" + print(f'------账号{i+1}:---- 备注={remark}------') + token = login_and_get_token(openid) #获取token + print(f'----------每日任务------') + check_daily_tasks(token) #每日任务 + print(f'----------进阶任务 手动做吧 没写------') + check_super_tasks(token) #进阶任务 + query_customer_point(token) #判断奖励是不是已经领取 然后领 + # 将账号信息添加到列表中 + account_infos.append((token, remark)) + + #plhqtxul(token) #评论 提取需要的头像 用户名 + #fetch_hitokoto() #一言内容 + + print(f'=' * 48) + print(f'*' * 48) + print(f'=' * 48) + print(f'----------X-----X-----日----本-----积分------') + + # 初始化积分信息字符串 + points_notification_body = "🎉 积分更新通知 🎉\n\n" + + # 使用收集的账号信息打印积分，并添加到通知内容 + for i, (token, remark) in enumerate(account_infos): + account_info_str = f'------账号{i+1}:--📒-- {remark}\n' + points_info = query_customer(token) # 使用 query_customer 函数获取积分信息 + account_points_str = f'可用积分{points_info["可用积分"]}，总积分{points_info["总积分"]}\n\n' + + # 添加到积分信息字符串 + points_notification_body += account_info_str + account_points_str + + # 在此处发送通知 + try: + # print(f'{points_notification_body}') + send("观💩日本通知", points_notification_body) + except Exception as e: + print(f"发送通知时发生错误: {e}") + +if __name__ == "__main__": + main()