From 2a8579463a6e71a8e8922329a16e0d7389ca367a Mon Sep 17 00:00:00 2001 From: zjk2017 <2548836866@qq.com> Date: Tue, 27 Aug 2024 14:51:19 +0800 Subject: [PATCH] =?UTF-8?q?Create=20=E4=B8=8A=E6=B5=B7=E5=AE=9D=E5=B1=B1.p?= =?UTF-8?q?y?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- 上海宝山.py | 273 ++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 273 insertions(+) create mode 100644 上海宝山.py diff --git a/上海宝山.py b/上海宝山.py new file mode 100644 index 0000000..649664c --- /dev/null +++ b/上海宝山.py @@ -0,0 +1,273 @@ +""" +上海宝山 +v2 修复评论 + +抓任意包请求头 token +变量名: SHBS_TOKEN + +cron: 35 13 * * * +const $ = new Env("上海宝山"); +""" +import os +import random +import re +import time +import requests +from bs4 import BeautifulSoup +from urllib3.exceptions import InsecureRequestWarning, InsecurePlatformWarning +from common import qianwen_messages, make_request, save_result_to_file +requests.packages.urllib3.disable_warnings(InsecureRequestWarning) +requests.packages.urllib3.disable_warnings(InsecurePlatformWarning) + + +class SHBS(): + name = "上海宝山" + + def __init__(self, account_info): + self.token = account_info.split('#')[0] + self.isComment = account_info.split('#')[1] + self.verify = False + self.headers = { + 'Host': 'bsapi.shmedia.tech', + 'Accept': '*/*', + 'Accept-Encoding': 'gzip, deflate, br', + 'Accept-Language': 'zh-Hans-CN;q=1', + 'token': self.token, + 'Content-Type': 'application/json; charset=utf-8', + 'deviceId': 'af223dabdc3b484c8eae7809f6da7ba6', + 'User-Agent': 'StandardApplication/6.2.7 (iPhone; iOS 16.6; Scale/3.00)', + 'Connection': 'keep-alive' + } + + def login_score(self): + json_data = {} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/points/login/add' + response = make_request(url, json_data=json_data, method='post', headers=self.headers) + # print(response) + if response and response['code'] == 0: + print("登录任务执行成功") + + def sign(self): + json_data = {} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/personal/score/sign' + response = make_request(url, json_data, 'post', self.headers) + # print(response) + if response and response['code'] == 0: + save_result_to_file("success", self.name) + print(f'✅{response["data"]["title"]}') + else: + save_result_to_file("error", self.name) + print(f'❌{response["msg"]}') + + def total_score(self): + json_data = {} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/personal/score/total' + response = make_request(url, json_data, 'post', self.headers) + if response and response['code'] == 0: + print(f'✅当前总积分：{response["data"]["score"]}') + else: + print(f'❌总积分获取失败：{response}') + + def today_score(self): + json_data = {} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/personal/score/info' + response = make_request(url, json_data, 'post', self.headers) + if response and response['code'] == 0: + print(f'✅今日新增积分：{response["data"]["todayIncreasePoint"]}') + # return response["data"]["jobs"] + else: + print(f'❌今日积分获取失败：{response}') + + def task_list(self): + json_data = {} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/personal/score/info' + response = make_request(url, json_data, 'post', self.headers) + if response and response['code'] == 0: + print("-----------------------") + print(f'🐹🐹🐹任务列表🐹🐹🐹') + print("-----------------------") + for i in response['data']['jobs']: + if "完善个人资料" in i["title"] or "填写邀请码" in i["title"]: + continue + print(f'👻{i["title"]}: {"已完成" if i["status"] == "1" else "未完成"}') + + def article_list(self): + json_data = { + 'orderBy': 'release_desc', + 'channel': { + 'id': 'f4b2dd979fe2497281660f0143df8ec2', + }, + 'pageSize': 50, + 'pageNo': 1, + } + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/news/content/list' + response = make_request(url, json_data, 'post', self.headers) + + return response["data"]["records"] + + def article_read_points_add(self): + json_data = {} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/points/read/add' + make_request(url, json_data, 'post', self.headers) + + def article_count_usage_desc(self, id): + json_data = { + 'id': id, + 'countType': 'contentRead', + } + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/common/count/usage/inc' + make_request(url, json_data, 'post', self.headers) + + def article_content(self, id): + json_data = {'id': id} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/news/content/get' + response = make_request(url, json_data, 'post', self.headers) + # print(f'article_content，{response}') + return response + + def article_read(self, id): + response = self.article_content(id) + if response and response['code'] == 0: + self.article_read_points_add() + self.article_count_usage_desc(id) + print(f'✅文章阅读成功') + else: + print(f'❌阅读失败，{response}') + + + def article_favor(self, id): + json_data = {'id': id} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/news/content/favor' + response = make_request(url, json_data, 'post', self.headers) + if response and response['code'] == 0: + print(f'✅文章收藏成功') + else: + print(f'❌收藏失败，{response}') + + def article_favor_task(self, id): + response_content = self.article_content(id) + if response_content and response_content['code'] == 0: + if response_content['data']['count']["favorite"] is False: + self.article_favor(id) + elif response_content['data']['count']["favorite"]: + print(f'已经收藏过了，不再重复收藏') + else: + print(f'❌收藏失败，{response_content}') + else: + print(f'❌获取文章失败，{response_content}') + + def article_share(self, id): + json_data = {} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/points/share/add' + response = make_request(url, json_data, 'post', self.headers) + if response and response['code'] == 0: + print(f'✅文章分享成功') + else: + print(f'❌文章分享失败，{response}') + + def video_view_task(self): + json_data = {} + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/points/video/add' + response = requests.post(url, headers=self.headers, json=json_data, verify=self.verify).json() + if response and response['code'] == 0: + print(f'✅看片儿完成+1') + else: + print(f'❌看片儿失败：{response}') + + + def get_gpt_comment(self, id): + basic_news_question = '我需要你针对下面的文章，从一个民众的角度进行评论，我希望你的输出只有评论内容，没有别的无关紧要的词语，回复格式是：芝麻开门#你的评论#， 评论语气要尽可能生活化、日常化，字数一定要限制在5-15字之间，下面是我需要你发表评论的文章内容：' + article_concent = '' + response = self.article_content(id) + #print(f'响应内容：【{response.status_code}】') + comment = '' + commentCount = 0 + if response and response['code'] == 0: + commentCount = response["data"]["count"]["commentCount"] + if commentCount <= 0: + content = response["data"]["txt"] + #print(f'content响应内容：【{content}】') + soup = BeautifulSoup(content, 'html.parser') + content_text = soup.get_text() + print(f'content响应内容：【{content_text}】') + if content_text: + message = qianwen_messages(basic_news_question, content_text) + comment = message + else: + return "加油" + return comment + + def article_comment_add(self, id, content): + json_data = { + 'displayResources': [], + 'content': content, + 'targetType': 'content', + 'targetId': id, + } + url = 'https://bsapi.shmedia.tech/media-basic-port/api/app/common/comment/add' + response = requests.post(url, headers=self.headers, json=json_data).json() + if response and response["code"] == 0: + print(f'✅文章评论成功') + else: + print(f'❌文章评论失败，{response}') + + def article_comment_task(self, id): + comment = self.get_gpt_comment(id) + if comment == '': + print(f'😢未知错误或者文章可能评论过，算了吧，下一个') + else: + parts = comment.split('#') + if len(parts) > 1: + comment = parts[1].strip() + print(f'🐌预评论内容：【{comment}】, 你没意见我就在20s后评论了哈......') + time.sleep(random.randint(20, 25)) + self.article_comment_add(id, comment) + + def gift_list(self): + # todo + print('--------------------') + print('🐹🐹🐹可兑换商品列表🐹🐹🐹') + print('--------------------') + print('😂积分太少啦，暂无商品可兑换') + + def main(self): + self.sign() + # for j in range(5): + # self.video_view_task() + # time.sleep(random.randint(20, 30)) + article_list = self.article_list() + for i in range(5): + article_id = random.choice(article_list)["id"] + print('--------------------------------------------------------------------') + print(f'🐹随机抓取到一篇文章{article_id}，开始做任务......') + self.article_read(article_id) + time.sleep(random.randint(20, 35)) + self.article_share(article_id) + time.sleep(random.randint(10, 18)) + if self.isComment == '1': + self.article_comment_task(article_id) + time.sleep(random.randint(20, 40)) + else: + print("⛔️未开启自动评论, 如要开启，请更改环境变量配置") + time.sleep(random.randint(10, 25)) + self.article_favor_task(article_id) + time.sleep(random.randint(10, 20)) + self.task_list() + self.total_score() + self.today_score() + self.gift_list() + + +if __name__ == '__main__': + env_name = 'SHBS_TOKEN' + tokenStr = os.getenv(env_name) + if not tokenStr: + print(f'⛔️未获取到ck变量：请检查变量 {env_name} 是否填写') + exit(0) + tokens = re.split(r'&', tokenStr) + print(f"上海宝山共获取到{len(tokens)}个账号") + for i, account_info in enumerate(tokens, start=1): + print(f"\n======== ▷ 第 {i} 个账号 ◁ ========") + SHBS(account_info).main() + print("\n随机等待30-60s进行下一个账号") + time.sleep(random.randint(30, 60))