diff --git a/胖乖生活.py b/胖乖生活.py
new file mode 100644
index 0000000..c8d94e1
--- /dev/null
+++ b/胖乖生活.py
@@ -0,0 +1,1074 @@
+"""
+ * 胖乖生活
+ * 设置变量 PGSH_TOKEN,多号使用&隔开，青龙直接新建变量即可 
+ * ck格式1:token#备注
+ * ck格式2: token
+ * 代理开关变量名：pg_dl，True为开启代理模式，False为关闭，默认为False
+ * 代理变量名：pg_dlurl，代理地址是动态代理api接口，一次性提取一个，选择txt格式，\r\n或者\n模式都可以
+ * 并发开关变量名：pg_bf，True为开启并发模式，False为关闭，默认为False
+ * 并发数量变量名：pg_bfsum，并发几个就写几个，默认为3
+ * 推送开关变量名：pg_ts，True为开启推送，False为关闭，默认为False
+ * 推送变量名1：WxPusher：pg_WxPusher_token是你的WxPusher的推送组的token，pg_WxPusher_uid是你的WxPusher该推送组的用户uid，推送给谁就填写谁的，填写一个即可
+ * 推送变量名2：pushplus：pg_pushplus_token是你的pushplus的token
+ * Top: 上面两个推送配置哪个就使用哪个推送，两个都配置的话就两个都进行推送
+ * 数据库地址变量名：pg_ckurl，保证打开数据库里面是ck，并使用&隔开，或者ck#备注，并使用&隔开
+ * 不填备注默认使用隐私格式手机号作为用户名，否则使用填写的备注作为用户名
+ * 出现False就是任务已完成或者不可完成
+ * 推荐携趣，注册实名每天免费1k，地址：https://www.xiequ.cn/
+ * cron：0 * * * *    务必使用此cron，无需担心黑号
+"""
+
+##############################
+
+ck = ""  # 本地环境ck，环境变量存在此处不生效
+ckurl1 = ""  # 数据库地址，适配部分群友要求
+jh = False  # 聚合ck模式，开启即所有环境模式ck都生效，都会合成为一个ck列表，关闭则优先处理环境变量，默认为True，False为关闭
+
+#############################
+# -----运行模式配置区，自行配置------
+
+bf1 = False  # True开启并发，False关闭并发
+bfsum1 = 3  # 并发数,开启并发模式生效
+
+# -------推送配置区，自行填写-------
+
+ts1 = False  # True开启推送，False关闭推送
+
+# -------代理配置区，自行填写-------
+
+dl1 = False  # True开启代理，False关闭代理
+dl_url = ""  # 代理池api
+
+# -----代理时间配置区，秒为单位------
+
+dl_sleep = 30  # 代理切换时间
+qqtime = 6  # 请求超时时间
+
+# -----时间配置区，默认即可------
+
+a = "6"
+b = "22"  # 表示6-22点之间才执行任务
+
+#############################
+# ---------勿动区----------
+
+# 已隐藏乾坤于此区域
+
+###########################
+# ---------代码块---------
+
+import requests
+import time
+import random
+import string
+import os
+import json
+import hashlib
+import threading
+from functools import partial
+from urllib.parse import urlparse
+from datetime import datetime, timedelta
+from concurrent.futures import ThreadPoolExecutor, as_completed
+from urllib3.exceptions import InsecureRequestWarning
+
+dl = os.environ.get('pg_dl', dl1)
+proxy_api_url = os.environ.get('pg_dlurl', dl_url)
+bf = os.environ.get('pg_bf', bf1)
+bfsum = os.environ.get('pg_bfsum', bfsum1)
+ts = os.environ.get('pg_ts', ts1)
+ckurl = os.environ.get('pg_ckurl', ckurl1)
+WxPusher_uid = os.environ.get('pg_WxPusher_uid')
+WxPusher_token = os.environ.get('pg_WxPusher_token')
+pushplus_token = os.environ.get('pg_pushplus_token')
+
+# def check_yl():
+#     lb = ['requests', 'urllib3']
+#     for yl in lb:
+#         try:
+#             subprocess.check_call(["pip", "show", yl], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+#         except subprocess.CalledProcessError:
+#             print(f"{yl} 未安装，开始安装...")
+#             subprocess.check_call(["pip", "install", yl, "-i", "https://pypi.tuna.tsinghua.edu.cn/simple"], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+#             print(f"{yl} 安装完成")
+# check_yl()
+
+v = '9.9.9.'
+
+global_proxy = {
+    'http': None,
+    'https': None
+}
+
+
+def start_dlapi():
+    dlstart = threading.Thread(target=get_proxy, args=(stop_event,))
+    dlstart.start()
+
+
+stop_event = threading.Event()
+
+
+
+def get_proxy(stop_event):
+    global global_proxy, ipp
+    a = 0
+    while not stop_event.is_set():
+        a += 1
+        response = requests.get(proxy_api_url)
+        if response.status_code == 200:
+            proxy1 = response.text.strip()
+            if "白名单" not in proxy1:
+                print(f'✅第{a}次获取代理成功: {proxy1}')
+                ipp = proxy1.split(':')[0]
+                global_proxy = {
+                    'http': proxy1,
+                    'https': proxy1,
+                }
+                start_time = time.time()
+                while time.time() - start_time < dl_sleep:
+                    if ip():
+                        print("✅代理检测通过,可以使用")
+                        time.sleep(2)
+                    else:
+                        print(f'❎当前ip不可用，第{a}次重新获取！')
+                        break
+                continue
+            else:
+                print(f"请求代理池: {proxy1}")
+                print("响应中存在白名单字样，结束运行")
+                os._exit(0)
+        else:
+            print(f'❎第{a}次获取代理失败！重新获取！')
+            time.sleep(dl_sleep)
+            continue
+
+
+def ip():
+    try:
+        if global_proxy:
+            r = requests.get('http://httpbin.org/ip', proxies=global_proxy, timeout=10, verify=False)
+        else:
+            r = requests.get('http://httpbin.org/ip')
+        if r.status_code == 200:
+            ip = r.json()["origin"]
+            print(f"当前IP: {ip}")
+            return ip
+        else:
+            print(f"❎查询ip失败")
+            return None
+    except requests.RequestException as e:
+        print(f"❎查询ip错误")
+        return None
+    except Exception as e:
+        print(f"❎查询ip错误")
+        return None
+
+
+def p(p):
+    if len(p) == 11:
+        return p[:3] + '****' + p[7:]
+    else:
+        return p
+
+
+class PGSH:
+    def __init__(self, cki):
+        self.msg = None
+        self.messages = []
+        self.title = None
+        self.phone = None
+        self.token = cki.split('#')[0]
+        self.cook = cki
+        self.total_amount = 0
+        self.id = None
+        self.hd = {
+            'User-Agent': "okhttp/3.14.9",
+            'Accept': 'application/json, text/plain, */*',
+            'Version': "1.57.2",
+            'Content-Type': "application/x-www-form-urlencoded;charset=UTF-8",
+            'Authorization': self.token,
+            'channel': "android_app"
+        }
+        self.hd1 = {
+            'User-Agent': "okhttp/3.14.9",
+            'Connection': "Keep-Alive",
+            'Accept-Encoding': "gzip",
+            'Authorization': self.token,
+            'Version': "1.57.2",
+            'channel': "android_app",
+            'phoneBrand': "Redmi",
+            'Content-Type': "application/x-www-form-urlencoded;charset=UTF-8"
+        }
+        self.listUrl = 'https://userapi.qiekj.com/task/list'
+        self.phone_url = 'https://userapi.qiekj.com/user/info'
+        self.check_url = 'https://userapi.qiekj.com/user/balance'
+        self.rcrw_url = 'https://userapi.qiekj.com/task/completed'
+        self.sign_url = 'https://userapi.qiekj.com/signin/doUserSignIn'
+        self.jrjf_url = "https://userapi.qiekj.com/integralRecord/pageList"
+        self.dkbm_url = 'https://userapi.qiekj.com/markActivity/doApplyTask'
+        self.dkbm_url1 = 'https://userapi.qiekj.com/markActivity/doMarkTask'
+        self.shop_url = 'https://userapi.qiekj.com/integralUmp/rewardIntegral'
+        self.jtjl_url = 'https://userapi.qiekj.com/ladderTask/applyLadderReward'
+        self.dkbm_url2 = "https://userapi.qiekj.com/markActivity/markTaskReward"
+        self.bmcodeurl = 'https://userapi.qiekj.com/markActivity/queryMarkTaskByStartTime'
+
+    # 签名
+    def sg(self, y):
+        timestamp = str(int(time.time() * 1000))
+        parsed_url = urlparse(y)
+        path = parsed_url.path
+        data = f"appSecret=nFU9pbG8YQoAe1kFh+E7eyrdlSLglwEJeA0wwHB1j5o=&channel=android_app&timestamp={timestamp}&token={self.token}&version=1.57.2&{path}"
+        data1 = f"appSecret=Ew+ZSuppXZoA9YzBHgHmRvzt0Bw1CpwlQQtSl49QNhY=&channel=alipay&timestamp={timestamp}&token={self.token}&{path}"
+        sign = hashlib.sha256(data.encode()).hexdigest()
+        sign1 = hashlib.sha256(data1.encode()).hexdigest()
+        return sign, sign1, timestamp
+
+
+    # 检测token有效性
+    def name(self):
+        try:
+            data = {'token': self.token}
+            if dl:
+                re = requests.post(self.phone_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
+                                   verify=False).json()
+            else:
+                re = requests.post(self.phone_url, data=data, headers=self.hd).json()
+            code = re['code']
+            if code == 0:
+                try:
+                    if "#" in self.cook:
+                        self.phone = self.cook.split('#')[1]
+                    else:
+                        self.phone = p(re['data']['phone'])
+                except:
+                    print(f'[账号{i + 1}] Cookie异常')
+                    exit(0)
+                self.id = re["data"]["id"]
+                sign, sign1, timestamp = self.sg(self.check_url)
+                self.hd['sign'] = sign
+                self.hd['timestamp'] = timestamp
+                if dl:
+                    r = requests.post(self.check_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
+                                      verify=False).json()
+                else:
+                    r = requests.post(self.check_url, data=data, headers=self.hd).json()
+                coin_code = r['code']
+                balance = r['data']['integral'] if coin_code == 0 else 'N/A'
+                print(f"[{self.phone}] ✅登录成功！积分余额: {balance}")
+                return self.phone
+            else:
+                msg = re["msg"]
+                print(f"[账号{i + 1}] ❎登录失败==> {msg}")
+                return False
+        except Exception as e:
+            print("❎请求出现错误")
+            return False
+
+    # 签到
+    def sign(self, max_retries=3):
+        retries = 0
+        while retries < max_retries:
+            try:
+                data = {'activityId': '600001', 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.sign_url)
+                self.hd['sign'] = sign
+                self.hd['timestamp'] = timestamp
+                if dl:
+                    re = requests.post(self.sign_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
+                                       verify=False).json()
+                else:
+                    re = requests.post(self.sign_url, data=data, headers=self.hd).json()
+
+                msg = re['msg']
+                print(f"[{self.phone}] ✅签到==> {msg}")
+                break
+            except Exception as e:
+                retries += 1
+                print(f"❎签到错误,重试次数: {retries}/{max_retries}")
+                if retries >= max_retries:
+                    print("❎达到最大重试次数，跳过该任务")
+                    break
+                time.sleep(1)
+
+    # 浏览商品
+    def shop(self):
+        for t in range(6):
+            try:
+                b1 = string.ascii_lowercase + string.digits
+                item_code = ''.join(random.choice(b1) for _ in range(6))
+                data = {'itemCode': item_code, 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.shop_url)
+                self.hd['sign'] = sign
+                self.hd['timestamp'] = timestamp
+                if dl:
+                    re = requests.post(self.shop_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
+                                       verify=False).json()
+                else:
+                    re = requests.post(self.shop_url, data=data, headers=self.hd).json()
+                q = re["data"]
+                if q is not None:
+                    amount = re["data"]["rewardIntegral"]
+                    print(f"[{self.phone}] ✅第{t + 1}次浏览商品成功,获得==> {amount}!")
+                else:
+                    print(f"[{self.phone}] ❎第{t + 1}次浏览商品失败==> {q}")
+                    break
+            except Exception as error:
+                print("❎浏览商品出现错误")
+                continue
+            if dl:
+                time.sleep(2)
+            else:
+                time.sleep(6)
+
+    # 支付宝广告任务
+    def zfbgg(self):
+        for t in range(11):
+            try:
+                data = {'taskType': "9", 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.rcrw_url)
+                hd1 = {
+                    'User-Agent': "Dalvik/2.1.0 (Linux; U; Android 13; MEIZU 20 Build/TKQ1.221114.001) Chrome/105.0.5195.148 MYWeb/0.11.0.240407200246 UWS/3.22.2.9999 UCBS/3.22.2.9999_220000000000 Mobile Safari/537.36 NebulaSDK/1.8.100112 Nebula AlipayDefined(nt:WIFI,ws:1080|1862|2.8125) AliApp(AP/10.5.88.8000) AlipayClient/10.5.88.8000 Language/zh-Hans useStatusBar/true isConcaveScreen/true NebulaX/1.0.0 DTN/2.0",
+                    'Connection': "Keep-Alive",
+                    'Accept-Encoding': "gzip",
+                    'Content-Type': "application/x-www-form-urlencoded",
+                    'Accept-Charset': "UTF-8",
+                    'channel': "alipay",
+                    'sign': sign1,
+                    'x-release-type': "ONLINE",
+                    'version': "",
+                    'timestamp': timestamp
+                }
+                if dl:
+                    response = requests.post(self.rcrw_url, data=data, headers=hd1, proxies=global_proxy, timeout=10,
+                                             verify=False).json()
+                else:
+                    response = requests.post(self.rcrw_url, data=data, headers=hd1).json()
+                msg = response["data"]
+                if msg:
+                    print(f"[{self.phone}] ✅第{t + 1}次支付宝广告==> {msg}")
+                else:
+                    print(f"[{self.phone}] ❎第{t + 1}次支付宝广告失败==> {msg}")
+                    break
+            except Exception as error:
+                print("❎支付宝广告出现错误")
+                continue
+            if dl:
+                time.sleep(2)
+            else:
+                time.sleep(6)
+
+    # 看视频赚积分
+    def kspzjf(self):
+        for t in range(6):
+            try:
+                data = {'taskType': "2", 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.rcrw_url)
+                self.hd['sign'] = sign
+                self.hd['timestamp'] = timestamp
+                if dl:
+                    response = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy,
+                                             timeout=10, verify=False).json()
+                else:
+                    response = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
+                msg = response["data"]
+                if msg:
+                    print(f"[{self.phone}] ✅第{t + 1}次看视频赚积分==> {msg}")
+                else:
+                    print(f"[{self.phone}] ❎第{t + 1}次看视频赚积分失败==> {msg}")
+                    break
+            except Exception as error:
+                print("❎看视频赚积分出现错误")
+                continue
+            if dl:
+                time.sleep(2)
+            else:
+                time.sleep(6)
+
+    # 看广告赚积分
+    def kggzjf(self):
+        for t in range(9):
+            try:
+                data = {'taskCode': '18893134-715b-4307-af1c-b5737c70f58d', 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.rcrw_url)
+                self.hd['sign'] = sign
+                self.hd['timestamp'] = timestamp
+                if dl:
+                    res = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
+                                        verify=False).json()
+                else:
+                    res = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
+                msg = res['data']
+                if msg:
+                    print(f'[{self.phone}] ✅第{t + 1}次看广告赚积分==> {msg}')
+                else:
+                    print(f'[{self.phone}] ❎第{t + 1}次看广告赚积分失败==> {msg}')
+                    break
+            except Exception as e:
+                print("❎看广告赚积分出现错误")
+                continue
+            if dl:
+                time.sleep(2)
+            else:
+                time.sleep(6)
+
+    # 不知名任务
+    def ycrw(self):
+        for t in range(9):
+            try:
+                data = {'taskCode': '15eb1357-b2d9-442f-a19f-dbd9cdc996cb', 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.rcrw_url)
+                self.hd['sign'] = sign
+                self.hd['timestamp'] = timestamp
+                if dl:
+                    re = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
+                                       verify=False).json()
+                else:
+                    re = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
+                msg = re['data']
+                if msg:
+                    print(f'[{self.phone}] ✅第{t + 1}次看广告赚积分==> {msg}')
+                else:
+                    print(f'[{self.phone}] ❎第{t + 1}次看广告赚积分失败==> {msg}')
+                    break
+            except Exception as e:
+                print("❎不知名任务出现错误")
+                continue
+            if dl:
+                time.sleep(2)
+            else:
+                time.sleep(6)
+
+    # 大鹅积分
+    def dejf(self):
+        for t in range(10):
+            try:
+                data = {'taskCode': '5', 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.rcrw_url)
+                self.hd['sign'] = sign
+                self.hd['timestamp'] = timestamp
+                if dl:
+                    re = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
+                                       verify=False).json()
+                else:
+                    re = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
+                msg = re['data']
+                if msg:
+                    print(f'[{self.phone}] ✅第{t + 1}次大鹅积分当钱花==> {msg}')
+                else:
+                    print(f'[{self.phone}] ❎第{t + 1}次大鹅积分当钱花==> {msg}')
+                    break
+            except Exception as e:
+                print("❎大鹅积分当钱花出现错误")
+                continue
+            if dl:
+                time.sleep(2)
+            else:
+                time.sleep(6)
+
+    # 遍历日常
+    def rcrw(self):
+        try:
+            data = {'token': self.token}
+            sign, sign1, timestamp = self.sg(self.listUrl)
+            self.hd['sign'] = sign
+            self.hd['timestamp'] = timestamp
+            response = requests.post(self.listUrl, data=data, headers=self.hd).json()
+            code = response.get('code', -1)
+            if code == 0:
+                tasks = response.get('data', {}).get('items', [])
+                if tasks:
+                    print(f'[{self.phone}] ✅获取到{len(tasks)}个日常任务')
+                    for item in tasks:
+                        title = item["title"]
+                        id1 = item["taskCode"]
+                        data = {'taskCode': id1, 'token': self.token}
+                        sign, sign1, timestamp = self.sg(self.rcrw_url)
+                        self.hd['sign'] = sign
+                        self.hd['timestamp'] = timestamp
+                        if dl:
+                            time.sleep(2)
+                        else:
+                            time.sleep(6)
+                        if dl:
+                            response1 = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy,
+                                                      timeout=10, verify=False).json()
+                        else:
+                            response1 = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
+                        data1 = response1.get("data", {})
+                        if data1:
+                            print(f'[{self.phone}] ✅完成日常任务[{title}]成功==> {data1}')
+                        else:
+                            print(f'[{self.phone}] ❎完成日常任务[{title}]失败==> {data1}')
+                        if dl:
+                            time.sleep(2)
+                        else:
+                            time.sleep(6)
+                else:
+                    print("❎获取任务列表为空!")
+            else:
+                print("❎获取任务列表失败!")
+        except requests.RequestException as e:
+            print(f"❎网络请求错误: {e}")
+        except Exception as e:
+            print(f"❎遍历日常出现错误: {e}")
+
+    # 领取阶梯奖励
+    def jtjl(self):
+        try:
+            url = "https://userapi.qiekj.com/ladderTask/ladderTaskForDay"
+            params = {
+                'token': self.token
+            }
+            sign, sign1, timestamp = self.sg(url)
+            self.hd1['sign'] = sign
+            self.hd1['timestamp'] = timestamp
+            if dl:
+                r = requests.get(url, params=params, headers=self.hd1, proxies=global_proxy, timeout=10,
+                                 verify=False).json()
+            else:
+                r = requests.get(url, params=params, headers=self.hd1).json()
+            if r['code'] == 0:
+                reward_list = [item['rewardCode'] for item in r['data']['ladderRewardList']]
+                for rewar in reward_list:
+                    try:
+                        url1 = "https://userapi.qiekj.com/ladderTask/applyLadderReward"
+                        data = {'rewardCode': rewar, 'token': self.token}
+                        sign, sign1, timestamp = self.sg(url1)
+                        self.hd1['sign'] = sign
+                        self.hd1['timestamp'] = timestamp
+                        if dl:
+                            r1 = requests.post(url1, data=data, headers=self.hd1, proxies=global_proxy, timeout=10,
+                                               verify=False).json()
+                        else:
+                            r1 = requests.post(url1, data=data, headers=self.hd1).json()
+                        if r1["code"] == 0:
+                            reward = r1["data"]["reward"]
+                            print(f'[{self.phone}] ✅领取任务id[{rewar}]成功==> {reward}')
+                        else:
+                            print(f'[{self.phone}] ❎领取任务id[{rewar}]失败==> {r1["msg"]}')
+                        if dl:
+                            time.sleep(2)
+                        else:
+                            time.sleep(6)
+                    except Exception as e:
+                        print("❎领取阶梯奖励出现错误")
+                        continue
+            else:
+                print("获取任务列表失败!")
+        except Exception as e:
+            print("获取阶梯奖励列表出现错误")
+
+    # 时间段奖励
+    def timejl(self, max_retries=3):
+        retries = 0
+        while retries < max_retries:
+            try:
+                url = "https://userapi.qiekj.com/timedBenefit/applyRewardForTimeBenefit"
+                params = {
+                    'token': self.token
+                }
+                sign, sign1, timestamp = self.sg(url)
+                self.hd1['sign'] = sign
+                self.hd1['timestamp'] = timestamp
+
+                if dl:
+                    r = requests.get(url, params=params, headers=self.hd1, proxies=global_proxy, timeout=10,
+                                     verify=False).json()
+                else:
+                    r = requests.get(url, params=params, headers=self.hd1).json()
+                if r["code"] == 0:
+                    print(f'[{self.phone}] ✅领取时间段奖励成功==> {r["data"]["rewardNum"]}')
+                    break
+                else:
+                    print(f'[{self.phone}] ❎领取时间段奖励失败==> {r["msg"]}')
+                    break
+            except Exception as e:
+                retries += 1
+                print(f"❎完成时间段任务出现错误: {e}. 重试次数: {retries}/{max_retries}")
+                if retries >= max_retries:
+                    print("❎达到最大重试次数，跳过该任务")
+                    break
+                time.sleep(1)
+
+    # 打卡报名
+    def dkbm(self):
+        try:
+            ti = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+            data = {'startTime': ti, 'token': self.token}
+            sign, sign1, timestamp = self.sg(self.bmcodeurl)
+            self.hd1['sign'] = sign
+            self.hd1['timestamp'] = timestamp
+            if dl:
+                r = requests.post(self.bmcodeurl, data=data, headers=self.hd1, proxies=global_proxy, timeout=10,
+                                  verify=False).json()
+            else:
+                r = requests.post(self.bmcodeurl, data=data, headers=self.hd1).json()
+            code = r['code']
+            if code == 0:
+                try:
+                    code1 = r['data']['taskCode']
+                    data = {'taskCode': code1, 'token': self.token}
+                    sign, sign1, timestamp = self.sg(self.dkbm_url)
+                    self.hd1['sign'] = sign
+                    self.hd1['timestamp'] = timestamp
+                    time.sleep(2)
+                    if dl:
+                        r1 = requests.post(self.dkbm_url, data=data, headers=self.hd1, proxies=global_proxy, timeout=10,
+                                           verify=False).json()
+                    else:
+                        r1 = requests.post(self.dkbm_url, data=data, headers=self.hd1).json()
+                    code2 = r1['code']
+                    data1 = r1["data"]
+                    msg = r1["msg"]
+                    if code2 == 0:
+                        print(f"[{self.phone}] ✅打卡报名成功==> {data1}")
+                    else:
+                        print(f"[{self.phone}] ❎打卡报名失败==> {msg}")
+                except Exception as e:
+                    print("❎打卡报名出现错误")
+            else:
+                print(f"获取code失败!{r}")
+        except Exception as e:
+            print("获取打卡报名id出现错误")
+
+    # 领取瓜分资格
+    def gfjf(self):
+        try:
+            current_datetime = datetime.now()
+            yesterday_datetime = current_datetime - timedelta(days=1)
+            yesterday_now = yesterday_datetime.replace(hour=current_datetime.hour, minute=current_datetime.minute,
+                                                       second=current_datetime.second,
+                                                       microsecond=current_datetime.microsecond)
+            k = yesterday_now.strftime("%Y-%m-%d %H:%M:%S")
+            data = {"startTime": k, "token": self.token}
+            sign, sign1, timestamp = self.sg(self.bmcodeurl)
+            self.hd1['sign'] = sign
+            self.hd1['timestamp'] = timestamp
+            if dl:
+                r = requests.post(self.bmcodeurl, headers=self.hd1, data=data).json()
+            else:
+                r = requests.post(self.bmcodeurl, headers=self.hd1, data=data).json()
+            if r['code'] == 0:
+                code1 = r['data']['taskCode']
+                data1 = {'taskCode': code1, 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.dkbm_url1)
+                self.hd1['sign'] = sign
+                self.hd1['timestamp'] = timestamp
+                time.sleep(2)
+                if dl:
+                    r1 = requests.post(self.dkbm_url1, headers=self.hd1, data=data1).json()
+                else:
+                    r1 = requests.post(self.dkbm_url1, headers=self.hd1, data=data1).json()
+                print(f"[{self.phone}] 领取瓜分资格==> {r1['msg']}")
+                return code1
+            else:
+                print(f"❎获取taskCode失败! {r}")
+                return None
+        except Exception as e:
+            print(f"领取瓜分资格出现错误")
+
+    # 瓜分积分
+    def gfjf1(self, max_retries=3):
+        retries = 0
+        while retries < max_retries:
+            try:
+                data1 = {'taskCode': self.gfjf(), 'token': self.token}
+                sign, sign1, timestamp = self.sg(self.dkbm_url2)
+                self.hd1['sign'] = sign
+                self.hd1['timestamp'] = timestamp
+                req = requests.post(self.dkbm_url2, headers=self.hd1, data=data1).json()
+                a1 = req['data']
+                print(f"[{self.phone}] ✅报名瓜分成功==> {a1}")
+                break
+            except Exception as e:
+                retries += 1
+                print(f"❎报名瓜分错误,重试次数: {retries}/{max_retries}")
+                if retries >= max_retries:
+                    print("❎达到最大重试次数，跳过该任务")
+                    break
+                time.sleep(1)
+
+    def xieru(self, rw, dk):
+        try:
+            new_data = {
+                "pgid": str(self.id)
+            }
+            if not os.path.exists("./pgsh.json"):
+                with open("./pgsh.json", "w") as file:
+                    json.dump({}, file)
+            with open("./pgsh.json", "r") as file:
+                try:
+                    data = json.load(file)
+                except json.decoder.JSONDecodeError:
+                    data = {}
+            if rw == 1 and new_data["pgid"] in data and data[new_data["pgid"]]["rw"] == 1:
+                print("任务记录已存在。")
+                return False
+            elif dk == 1 and new_data["pgid"] in data and data[new_data["pgid"]]["dk"] == 1:
+                print("打卡记录已存在。")
+                return False
+            else:
+                if rw == 1:
+                    data[new_data["pgid"]] = {"rw": 1, "dk": 0}
+                elif dk == 1:
+                    data[new_data["pgid"]] = {"rw": 1, "dk": 1}
+            with open("./pgsh.json", "w") as file:
+                json.dump(data, file)
+            print("✅写入记录文件成功。")
+            return True
+        except Exception as e:
+            print(f"❎写入记录文件出现错误，初始化文件内容")
+            with open("./pgsh.json", "w") as file:
+                json.dump({}, file)
+
+    # 读取指定值是否存在
+    def duqu(self, aa, rw, dk):
+        try:
+            if not os.path.exists("./pgsh.json"):
+                with open("./pgsh.json", "w") as file:
+                    json.dump({}, file)
+
+            with open("./pgsh.json", "r") as file:
+                try:
+                    data = json.load(file)
+                except json.decoder.JSONDecodeError:
+                    data = {}
+            if rw == 1:
+                if str(aa) in data:
+                    return data[str(aa)]["rw"]
+                else:
+                    return False
+            elif dk == 1:
+                if str(aa) in data:
+                    return data[str(aa)]["dk"]
+                else:
+                    return False
+        except Exception as e:
+            print(f"读取记录文件出现错误,初始化文件内容")
+            with open("./pgsh.json", "w") as file:
+                json.dump({}, file)
+
+    # 今日积分
+    def jrjf(self, i, token1):
+        token = token1.split('#')[0]
+        try:
+            hd1 = {
+                'User-Agent': "okhttp/3.14.9",
+                'Accept': 'application/json, text/plain, */*',
+                'Version': "1.57.2",
+                'Content-Type': "application/x-www-form-urlencoded;charset=UTF-8",
+                'Authorization': token,
+                'channel': "android_app"
+            }
+            data = {'token': token}
+            sign, sign1, timestamp = self.sg(self.phone_url)
+            self.hd['sign'] = sign
+            self.hd['timestamp'] = timestamp
+            r = requests.post(self.phone_url, data=data, headers=hd1).json()
+            if r['code'] == 0:
+                try:
+                    sign, sign1, timestamp = self.sg(self.check_url)
+                    self.hd['sign'] = sign
+                    self.hd['timestamp'] = timestamp
+                    r1 = requests.post(self.check_url, data=data, headers=hd1).json()
+                    coin_code = r1['code']
+                    balance = r1['data']['integral'] if coin_code == 0 else 'N/A'
+                except Exception as e:
+                    print(f"获取积分失败: {e}")
+                    balance = 'N/A'
+
+                try:
+                    phone = p(r['data']['phone'])
+                    data = {
+                        'page': (None, '1'),
+                        'pageSize': (None, '100'),
+                        'type': (None, '100'),
+                        'receivedStatus': (None, '1'),
+                        'token': (None, token),
+                    }
+                    hd = {
+                        'User-Agent': 'Mozilla/5.0 (Linux; Android 14; 23117RK66C Build/UKQ1.230804.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/118.0.0.0 Mobile Safari/537.36 AgentWeb/5.0.0 UCBrowser/11.6.4.950 com.qiekj.QEUser',
+                        'Accept': 'application/json, text/plain, */*',
+                        'channel': 'android_app',
+                    }
+                    re_response = requests.post(self.jrjf_url, headers=hd, files=data).json()
+                    current_date = datetime.now().strftime('%Y-%m-%d')
+                    total_amount = 0
+                    for item in re_response['data']['items']:
+                        received_date = item['receivedTime'][:10]
+                        if received_date == current_date:
+                            total_amount += item['amount']
+                    print(f"[{phone}] ✅今日获得积分: {total_amount}")
+                    return {
+                        '序号': i + 1,
+                        '用户': phone,
+                        'arg1': balance,
+                        'arg2': total_amount
+                    }
+                except Exception as e:
+                    print(f"[账号{i + 1}] ❎查询当日积分出现错误: {e}")
+                    return {
+                        '序号': i + 1,
+                        '用户': i + 1,
+                        'arg1': f"❎",
+                        'arg2': f"❎"
+                    }
+            else:
+                print(f"[账号{i + 1}] ❎登录失败: {r['msg']}")
+                return {
+                    '序号': i + 1,
+                    '用户': i + 1,
+                    'arg1': f"{r['msg']}",
+                    'arg2': f"{r['msg']}"
+                }
+        except requests.exceptions.RequestException as e:
+            print(f"[账号{i + 1}] ❎网络请求错误: {e}")
+            return {
+                '序号': i + 1,
+                '用户': i + 1,
+                'arg1': f"❎",
+                'arg2': f"❎"
+            }
+        except Exception as e:
+            print(f"[账号{i + 1}] ❎查询当日积分出现错误: {e}")
+            return {
+                '序号': i + 1,
+                '用户': i + 1,
+                'arg1': f"❎",
+                'arg2': f"❎"
+            }
+
+    def jf(self):
+        try:
+            msg_list = []
+            print(f"======开始查询所有账号当日收益======")
+            for n, yy in enumerate(cookies):
+                msg = self.jrjf(n, yy)
+                msg_list.append(msg)
+            sorted_data = sorted(msg_list, key=lambda x: x['序号'])
+            table_content = ''
+            for row in sorted_data:
+                table_content += f"<tr><td style='border: 1px solid #ccc; padding: 6px;'>{row['序号']}</td><td style='border: 1px solid #ccc; padding: 6px;'>{row['用户']}</td><td style='border: 1px solid #ccc; padding: 6px;'>{row['arg1']}</td><td style='border: 1px solid #ccc; padding: 6px;'>{row['arg2']}</td></tr>"
+
+            self.msg = f"<table style='border-collapse: collapse;'><tr style='background-color: #f2f2f2;'><th style='border: 1px solid #ccc; padding: 8px;'>🆔</th><th style='border: 1px solid #ccc; padding: 8px;'>用户名</th><th style='border: 1px solid #ccc; padding: 8px;'>总积分</th><th style='border: 1px solid #ccc; padding: 8px;'>今日积分</th></tr>{table_content}</table>"
+            if ts:
+                self.send_msg()
+        except Exception as e:
+            print(f"查询所有账号当日收益出现错误: {e}")
+        if int(b) <= now_time or now_time <= 1:
+            with open("./pgsh.json", "w") as file:
+                json.dump({}, file)
+            print("已重置文件内容")
+
+    def send_msg(self):
+        if 'WxPusher_token' in os.environ and os.environ['WxPusher_token'] is not None:
+            self.WxPusher_ts()
+        if 'PUSH_PLUS_TOKEN' in os.environ and os.environ['PUSH_PLUS_TOKEN'] is not None:
+            self.pushplus_ts()
+        else:
+            print("❎推送失败，未配置推送")
+
+    def WxPusher_ts(self):
+        try:
+            url = 'https://wxpusher.zjiecode.com/api/send/message'
+            params = {
+                'appToken': WxPusher_token,
+                'content': self.msg,
+                'summary': '胖乖生活',
+                'contentType': 3,
+                'uids': [WxPusher_uid]
+            }
+            re = requests.post(url, json=params)
+            msg = re.json().get('msg', None)
+            print(f'WxPusher推送结果：{msg}\\\n')
+        except Exception as e:
+            print(f"WxPusher推送出现错误: {e}")
+
+    def pushplus_ts(self):
+        try:
+            url = 'https://www.pushplus.plus/send/'
+            data = {
+                "token": pushplus_token,
+                "title": '胖乖生活',
+                "content": self.msg
+            }
+            re = requests.post(url, json=data)
+            msg = re.json().get('msg', None)
+            print(f'pushplus推送结果：{msg}\\\n')
+        except Exception as e:
+            print(f"pushplus推送出现错误: {e}")
+
+    def start(self):
+        if self.name():
+            print("-----执行领取时间段奖励-----")
+            self.timejl()
+            if int(a) <= now_time < int(b):
+                print("--------滴滴车发车，坐稳了--------\\\n")
+                if self.duqu(self.id, 1, 0) == 0:
+                    print("-----开始执行签到-----")
+                    self.sign()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----先遍历个日常，防止漏网之鱼-----")
+                    self.rcrw()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----开始执行支付宝看广告-----")
+                    self.zfbgg()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----开始执行赚大鹅积分-----")
+                    self.dejf()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----开始执行看视频赚积分-----")
+                    self.kspzjf()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----开始执行看广告赚积分-----")
+                    self.kggzjf()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----开始执行浏览商品赚积分-----")
+                    self.shop()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----开始执行隐藏任务-----")
+                    self.ycrw()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----开始执行打卡报名-----")
+                    self.dkbm()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----开始执行领取瓜分资格-----")
+                    self.gfjf()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----执行领取阶梯奖励----")
+                    self.jtjl()
+                    if dl:
+                        time.sleep(2)
+                    else:
+                        time.sleep(6)
+                    print("-----任务执行完毕，记录id-----")
+                    self.xieru(1, 0)
+                else:
+                    print("当前账号已执行过任务，跳过执行")
+            else:
+                print(f"当前时间非{int(a)}-{int(b)}，跳过今日任务")
+            if 14 <= now_time <= 16:
+                print("-----开始执行瓜分打卡积分-----")
+                if self.duqu(self.id, 0, 1) == 0:
+                    self.gfjf1()
+                    self.xieru(0, 1)
+                else:
+                    print("当前账号已执行过任务，跳过执行")
+            else:
+                print(f"当前时间非14-16，跳过瓜分打卡积分")
+
+
+if __name__ == '__main__':
+    print(f"当前版本: {v}")
+    print("TL库:https://github.com/3288588344/toulu.git")
+    print("QQ频道：98do10s246")
+    print("微信机器人:kckl6688")
+    print("tg频道：https://t.me/TLtoulu")
+    requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)
+    print = partial(print, flush=True)
+    if jh:
+        print("当前聚合ck模式，所有模式ck生效")
+        ck1 = []
+        if 'PGSH_TOKEN' in os.environ:
+            ck1.append(os.environ.get('PGSH_TOKEN'))
+        if ckurl != "":
+            r = requests.get(ckurl)
+            ck1.append(r.text.strip())
+        if ck != "":
+            ck1.append(ck)
+        if not ck1:
+            print("变量为空，请设置其中一个变量后再运行")
+            exit(-1)
+        cookie = '&'.join(ck1)
+    else:
+        if 'PGSH_TOKEN' in os.environ:
+            cookie = os.environ.get('PGSH_TOKEN')
+        else:
+            print("环境变量中不存在[PGSH_TOKEN],启用本地或数据库地址模式")
+            if ckurl != "":
+                r = requests.get(ckurl)
+                cookie = r.text.strip()
+            else:
+                cookie = ck
+        if cookie == "":
+            print("本地及数据库地址变量为空，请设置其中一个变量后再运行")
+            exit(-1)
+    cookies = cookie.split("&")
+    print(f"胖乖生活共获取到 {len(cookies)} 个账号")
+    now_time = datetime.now().hour
+    if dl:
+        start_dlapi()
+    i = 1
+    if bf:
+        print("✅开启并发模式")
+        if dl:
+            print("✅开启代理模式")
+            with ThreadPoolExecutor(max_workers=int(bfsum)) as executor:
+                futures = [executor.submit(PGSH(ck).start) for ck in cookies]
+                for i, future in enumerate(as_completed(futures)):
+                    print(f"======执行第{i + 1}个账号======")
+                    future.result()
+            stop_event.set()
+            time.sleep(2)
+            PGSH(ck).jf()
+        else:
+            print("❎未开启代理模式")
+            with ThreadPoolExecutor(max_workers=int(bfsum)) as executor:
+                futures = [executor.submit(PGSH(ck).start) for ck in cookies]
+                for i, future in enumerate(as_completed(futures)):
+                    print(f"======执行第{i + 1}个账号======")
+            time.sleep(2)
+            PGSH(ck).jf()
+    else:
+        print("✅常规运行模式")
+        if dl:
+            print("✅开启代理模式")
+            for i, ck in enumerate(cookies):
+                print(f"======开始第{i + 1}个账号======")
+                now_time = datetime.now().hour
+                PGSH(ck).start()
+                print("2s后进行下一个账号")
+                time.sleep(2)
+            stop_event.set()
+            time.sleep(2)
+            PGSH(ck).jf()
+        else:
+            print("❎未开启代理模式")
+            for i, ck in enumerate(cookies):
+                print(f"======开始第{i + 1}个账号======")
+                now_time = datetime.now().hour
+                PGSH(ck).start()
+                print("2s后进行下一个账号")
+                time.sleep(2)
+            time.sleep(2)
+            PGSH(ck).jf()