From f71e3adac5cd2f48efa2c320a77dcb6c1edcd181 Mon Sep 17 00:00:00 2001 From: zjk2017 <2548836866@qq.com> Date: Wed, 7 Aug 2024 21:41:10 +0800 Subject: [PATCH] =?UTF-8?q?Delete=20tianyi/=E8=A7=82mei=E6=97=A5=E6=9C=AC.?= =?UTF-8?q?py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tianyi/观mei日本.py | 851 -------------------------------------------- 1 file changed, 851 deletions(-) delete mode 100644 tianyi/观mei日本.py diff --git a/tianyi/观mei日本.py b/tianyi/观mei日本.py deleted file mode 100644 index 7f32f57..0000000 --- a/tianyi/观mei日本.py +++ /dev/null @@ -1,851 +0,0 @@ -""" -观美日本-资生堂的小程序 -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()