Create 太平洋汽车cookie版.py

太平洋汽车cookie版.py

@@ -0,0 +1,403 @@
+"""
+太平洋汽车cookie版
+
+变量名：tpyqc_datacookie
+格式： 账号#cookie，多号用&隔开  适用不知道密码、不能重置密码的情况
+
+定时设置：
+cron: 0 6 * * *
+const $ = new Env("太平洋汽车cookie版");
+
+---------------------------------
+20240523 每日抽奖得现金，自动抽奖自动提现
+20240604 每日抽奖活动结束，新增每日攒碎片开盲盒，可中实物、卡券
+20240706 账号全部异常了，发帖秒删行为被检测恶意刷帖了，后面申请解封能成功的话再更新
+20240919 暂时只做评论和分享，发帖TODO
+---------------------------------
+"""
+
+import os
+import random
+import re
+import time
+import requests
+from common import daily_one_word, save_result_to_file
+from sendNotify import send
+from urllib3.exceptions import InsecureRequestWarning, InsecurePlatformWarning
+
+requests.packages.urllib3.disable_warnings(InsecureRequestWarning)
+requests.packages.urllib3.disable_warnings(InsecurePlatformWarning)
+
+user_rewards_summary = []
+
+
+class TPYQC():
+    name = "太平洋汽车"
+
+    def __init__(self, account_info):
+        username,cookie = account_info.split('#')
+        self.username = username
+        # self.password = password
+        self.cookie = cookie
+        # self.account_id = account_id
+        # self.account_id = 0
+        self.msg = ''
+        # self.cookie = ''
+        # self.session_id = ''
+        self.contentIds = []
+        self.commentId = 0
+        self.lotteryCount = 0
+        self.myIsues = []
+        self.headers = {
+            'Host': 'act1.pcauto.com.cn',
+            'Accept': 'application/json, text/plain, */*',
+            'Sec-Fetch-Site': 'same-site',
+            'Accept-Language': 'zh-CN,zh-Hans;q=0.9',
+            'Accept-Encoding': 'gzip, deflate, br',
+            'Sec-Fetch-Mode': 'cors',
+            'Content-Type': 'application/json',
+            'Origin': 'https://www1.pcauto.com.cn',
+            'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 16_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148',
+            'Referer': 'https://www1.pcauto.com.cn/',
+            'Connection': 'keep-alive',
+            'Sec-Fetch-Dest': 'empty',
+            'Cookie': self.cookie
+        }
+        self.communityHeaders = {
+            'Host': 'community-gateway.pcauto.com.cn',
+            'Pc-Agent': 'PCGroup Mobile App',
+            'Version': '7.1.3',
+            'Accept': '*/*',
+            'appVersion': '7.1.3',
+            'Accept-Language': 'zh-Hans-CN;q=1',
+            'App': 'PCAUTO_INFO_IOS',
+            'platform': 'PCAUTO_INFO_IOS',
+            'traceId': '92ZF9',
+            'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 16_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148',
+            'Connection': 'keep-alive',
+            'Content-Type': 'application/json',
+            'Cookie': self.cookie
+        }
+        self.loginHeaders = {
+            'Host': 'mrobot.pcauto.com.cn',
+            'Pc-Agent': 'PCGroup Mobile App',
+            'Accept': '*/*',
+            'Version': '7.1.4',
+            'appVersion': '7.1.4',
+            'Accept-Language': 'zh-cn',
+            'App': 'PCAUTO_INFO_IOS',
+            'platform': 'PCAUTO_INFO_IOS',
+            'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 13_4_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148',
+            'Connection': 'keep-alive',
+            'Content-Type': 'application/x-www-form-urlencoded; charset=utf-8',
+        }
+
+    def login(self):
+        # data = {
+        #     'appName': 'PCAUTO_APP',
+        #     'auto_login': '90',
+        #     'password': self.password,
+        #     'username': self.username,
+        # }
+
+
+        # common_session_id = self.common_session_id
+        # self.cookie = f'common_session_id={self.session_id};'
+        self.headers['Cookie'] = self.cookie
+        self.communityHeaders['Cookie'] = self.cookie
+        print(f"账号【{self.username}】登录成功\n")
+       
+
+    # 发帖
+    def do_topic_issue(self):
+        print('开始发帖......')
+        contents = [
+            "继续, 也许一不小心中了呢",
+            "冲冲冲，梦想还是要有的",
+            "让我中一次盲盒大奖吧",
+            "坚持打卡",
+            "断断续续，该死的拖延症",
+            "坚持打卡，加油加油",
+            "断断续续好几次了"
+        ]
+        msg = ''
+        json_data = {
+            'clubTags': [
+                '799579643900329987',
+            ],
+            'content': random.choice(contents),
+            'title': '',
+            'themeTags': [
+                '804483405201802908',
+            ],
+            'images': [
+                {
+                    'url': 'http://img4.pcauto.com.cn/pcauto/images/community/20240531/20616066.jpg',
+                    'width': 1170,
+                    'height': 2097,
+                },
+            ],
+        }
+        url = 'https://community-gateway.pcauto.com.cn/app/topic/issue'
+        response = requests.post(url, headers=self.communityHeaders, json=json_data, verify=False)
+        if response and response.status_code == 200:
+            response_json = response.json()
+            if response_json['code'] == 200:
+                msg = f'✅发帖帖子【{response_json["data"]}】成功'
+            else:
+                msg = f'❌发帖失败：{response_json["msg"]}'
+        else:
+            msg = '❌发帖失败，请检查网络'
+
+        self.msg += msg
+        print(msg)
+
+    def content_list(self):
+        current_time_millis = int(time.time() * 1000)
+        params = {
+            'firstPageTime': current_time_millis,
+            'id': '1',
+            'isSuperior': 'false',
+            'orderType': '0',
+            'pageNo': '1',
+            'pageSize': '10',
+            'tagType': 'Club',
+        }
+
+    # 查贴
+    def my_issue_list(self):
+        params = {
+            'accountId': self.account_id,
+            'sessionId': self.session_id,
+            'pageNo': '1',
+            'pageSize': '10',
+        }
+        url = 'https://community-gateway.pcauto.com.cn/app/user/personContent'
+        response = requests.get(url, params=params, headers=self.communityHeaders)
+        if response and response.status_code == 200:
+            response_json = response.json()
+            if response_json['code'] == 200:
+                issue_list = response_json['data']["data"]
+                if len(issue_list) == 0:
+                    print('🐹空空如也，没有发帖')
+                    return
+                for item in issue_list:
+                    self.myIsues.append(item["issueId"])
+
+    # 删帖
+    def delete_issue(self):
+        print('🐹开始删帖......')
+        if len(self.myIsues) == 0:
+            print("🐹没有帖子可以删除")
+            return
+        print(f'🐹发现{len(self.myIsues)}篇帖子，开始删除......')
+        for issueId in self.myIsues:
+            json_data = {
+                'contentId': issueId,
+                'contentType': 'Post',
+            }
+            url = 'https://community-gateway.pcauto.com.cn/app/user/delete/content'
+            response = requests.post(url, headers=self.communityHeaders, json=json_data)
+            if response and response.status_code == 200:
+                response_json = response.json()
+                if response_json['code'] == 200:
+                    print(f'✅删除帖子【{issueId}】成功')
+                else:
+                    print(f'❌删除帖子【{issueId}失败】：{response_json["msg"]}')
+
+    # 评论
+    def do_comment(self):
+        print('🐹开始评论......')
+        contentId = 817950105482038198
+        content_ = daily_one_word()
+        contents = [
+            "今天最大的奖又是碎片",
+            "碎片碎片碎片",
+            "中奖中奖中奖",
+            "依旧空军，依旧充满希望",
+            "下次一定",
+            "我本有心向明月，奈何明月照沟渠",
+            "新的一天，新的开始",
+            "继续",
+            "继续继续继续",
+            "盲盒盲盒盲盒",
+            "坚持就是胜利",
+            "中奖率太低了",
+        ]
+        if content_ is not None and content_ != '':
+            contents.append(content_)
+
+        # print("contents=", contents)
+        content = random.choice(contents)
+        json_data = {
+            'contentId': contentId,
+            'content': content,
+            'contentType': 'Post',
+            'isForwarding': False,
+            'accountAtDTOList': [],
+        }
+        url = 'https://community-gateway.pcauto.com.cn/app/social/addComment'
+        response = requests.post(url, headers=self.communityHeaders, json=json_data)
+        if response and response.status_code == 200:
+            response_json = response.json()
+            if response_json['code'] == 200:
+                comment_id = response_json['data']['id']
+                print(f'✅评论成功, 评论ID:{comment_id}')
+                self.commentId = comment_id
+            else:
+                print(f'❌评论失败：{response_json["msg"]}')
+
+    def delete_comment(self):
+        print('🐹开始删评论......')
+        if self.commentId == 0:
+            print("🐹没有评论可以删除")
+            return
+        json_data = {
+            'id': self.commentId
+        }
+        url = 'https://community-gateway.pcauto.com.cn/app/social/delComment'
+        response = requests.post(url, headers=self.communityHeaders, json=json_data)
+        if response and response.status_code == 200:
+            response_json = response.json()
+            if response_json['code'] == 200:
+                print(f'✅删除评论{self.commentId}成功')
+            else:
+                print(f'❌删除评论{self.commentId}失败：{response_json["msg"]}')
+
+    def share_task(self):
+        print('🐹开始分享......')
+        url = 'https://community-gateway.pcauto.com.cn/app/lottery/share/record'
+        response = requests.post(url, headers=self.communityHeaders)
+        if response and response.status_code == 200:
+            response_json = response.json()
+            if response_json['code'] == 200:
+                print(f'✅分享成功')
+            else:
+                print(f'❌分享失败：{response_json["msg"]}')
+
+    def lottery(self):
+        print('🐹开始抽奖......')
+        if self.lotteryCount == 0:
+            print("❌没有抽奖次数")
+            return
+        for i in range(self.lotteryCount):
+            url = 'https://community-gateway.pcauto.com.cn/app/lottery/lottery'
+            response = requests.post(url, headers=self.communityHeaders)
+            if response and response.status_code == 200:
+                response_json = response.json()
+                if response_json['code'] == 200:
+                    print(f'✅第{i + 1}次 | {response_json["data"]["title"]} | {response_json["data"]["rewardName"]}')
+                else:
+                    print(f'❌抽奖失败：{response_json["msg"]}')
+            time.sleep(random.randint(5, 10))
+
+    def my_piece_list(self):
+        json_data = {
+            'date': None,
+            'pageNo': 1,
+            'pageSize': 10,
+        }
+        url = 'https://community-gateway.pcauto.com.cn/app/lottery/piece/list'
+        response = requests.post(url, headers=self.communityHeaders, json=json_data)
+        if response and response.status_code == 200:
+            response_json = response.json()
+            if response_json['code'] == 200:
+                remain_pieces = response_json["data"]["pieceRecordStatistic"]["remain"]
+                self.lotteryCount = remain_pieces // 3
+                print(f'✅碎片：{remain_pieces} | ✅抽奖次数：{self.lotteryCount}')
+
+    def my_reward_list(self):
+        params = {
+            'type': 'real',
+            'pageNo': '1',
+            'pageSize': '20',
+        }
+        url = 'https://community-gateway.pcauto.com.cn/app/lottery/my/reward'
+        response = requests.get(url, params=params, headers=self.communityHeaders)
+        if response and response.status_code == 200:
+            response_json = response.json()
+            if response_json['code'] == 200:
+                rewards = response_json["data"]["data"]
+                msg = f'---------🐹【{self.username}】奖品列表 🐹---------\n'
+                if len(rewards) == 0:
+                    msg += '❌还没有获得奖励'
+                else:
+                    for reward in rewards:
+                        msg += f'✅{reward["name"]}\n'
+                # 更新奖品信息字典
+                user_rewards_summary.append(msg)
+
+    def cash_lottery(self):
+        msg = '开始抽奖......\n'
+        url = 'https://act1.pcauto.com.cn/discount/api/activity/lottery'
+        data = {
+            'actId': '19',
+            'phone': f'{self.username}'
+        }
+        response = requests.post(url, headers=self.headers, json=data)
+        print(response.text)
+        response_json = response.json()
+        if response_json['code'] == 200 and response_json['data']['code'] == 0:
+            msg = f'抽奖成功, {response_json["data"]["msg"]}{response_json["data"]["amount"]}元'
+        elif response_json['code'] == 1:
+            msg = f'抽奖失败, {response_json["data"]["msg"]}'
+
+        print(msg)
+
+    def main(self):
+        self.login()
+        time.sleep(random.randint(10, 15))
+
+        # self.content_list()
+        # time.sleep(random.randint(10, 15))
+        #
+        print(f"\n======== ▷ 发帖 | 评论 | 分享 ◁ ========")
+        # TODO 发帖
+        # self.do_topic_issue()
+        # time.sleep(random.randint(10, 15))
+
+        for i in range(6):
+            self.do_comment()
+            time.sleep(random.randint(10, 15))
+
+        self.share_task()
+        time.sleep(random.randint(5, 10))
+
+        print(f"\n======== ▷ 抽奖 ◁ ========")
+        self.my_piece_list()
+        time.sleep(random.randint(5, 10))
+
+        self.lottery()
+        time.sleep(random.randint(5, 10))
+
+        # print(f"\n======== ▷ 删帖 | 删评论 ◁ ========")
+        # self.my_issue_list()
+        # time.sleep(random.randint(5, 10))
+        # self.delete_issue()
+        # time.sleep(random.randint(5, 10))
+        # self.delete_comment()
+
+        self.my_reward_list()
+        time.sleep(random.randint(5, 10))
+
+
+if __name__ == '__main__':
+    env_name = 'tpyqc_datacookie'
+    account_infos_str = os.getenv(env_name)
+    if not account_infos_str:
+        print(f'⛔️未获取到ck变量：请检查变量 {env_name} 是否填写')
+        exit(0)
+    account_infos = re.split(r'&', account_infos_str)
+    print(f"太平洋汽车共获取到{len(account_infos)}个账号")
+
+    for i, account_info in enumerate(account_infos, start=1):
+        print(f"\n======== ▷ 第 {i} 个账号 ◁ ========")
+        TPYQC(account_info).main()
+        print("\n随机等待30-60s进行下一个账号")
+        time.sleep(random.randint(10, 15))
+
+    # 奖品列表
+    for item_msg in user_rewards_summary:
+        print(item_msg)
+
+    send("太平洋汽车", user_rewards_summary)