diff --git a/水费易.py b/水费易.py new file mode 100644 index 0000000..88fb1ce --- /dev/null +++ b/水费易.py @@ -0,0 +1,148 @@ +""" +抓包m.ipaiyun.cn域名下的ck，填到环境变量名SFYCK中 +例如: +SFYCK = 'ASP.NET_SessionId=xxxxxx; IPAI_UV=xxxx; temp_clause=1815556' +""" +import os +import requests +import asyncio +from requests.adapters import HTTPAdapter +from urllib3.util.retry import Retry +import random + +class SYFSign: + def __init__(self): + self.name = "水费易签到" + self.SFYCK = os.getenv("SFYCK", "").split("\n") + self.baseUrl = "https://m.ipaiyun.cn" + self.headers = { + 'Host': 'm.ipaiyun.cn', + 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Safari/537.36', + 'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8', + 'Origin': self.baseUrl, + 'Referer': f'{self.baseUrl}/Ipai/Home/Index?code=031sLtFa11eBTH0d0uFa1NqtY53sLtFQ&state=wxbe5b7a2bc0467240', + 'Accept-Encoding': 'gzip, deflate, br', + } + + retry_strategy = Retry( + total=3, + status_forcelist=[429, 500, 502, 503, 504], + method_whitelist=["POST", "GET"], + backoff_factor=1 + ) + self.adapter = HTTPAdapter(max_retries=retry_strategy) + self.http = requests.Session() + self.http.mount("https://", self.adapter) + + def get_proclamation(self): + primary_url = "https://github.com/3288588344/toulu/raw/refs/heads/main/tl.txt" + backup_url = "https://tfapi.cn/TL/tl.json" + + try: + response = self.http.get(primary_url, timeout=10) + if response.status_code == 200: + print("📢 公告信息") + print("=" * 45) + print(response.text) + print("=" * 45 + "\n") + print("公告获取成功，开始执行任务...\n") + return + except requests.exceptions.RequestException as e: + print(f"获取公告时发生错误: {e}, 尝试备用链接...") + + try: + response = self.http.get(backup_url, timeout=10) + if response.status_code == 200: + print("\n" + "=" * 14) + print("📢 公告信息") + print("=" * 45) + print(response.text) + print("=" * 45 + "\n") + print("公告获取成功，开始执行任务...\n") + else: + print(f"⚠️ 获取公告失败，状态码: {response.status_code}") + except requests.exceptions.RequestException as e: + print(f"⚠️ 获取公告时发生错误: {e}, 可能是网络问题或链接无效。") + + async def main(self): + self.get_proclamation() + + print(f"\n已随机分配 User-Agent\n\n{self.headers['User-Agent']}") + for index, cookie in enumerate(self.SFYCK): + if not cookie.strip(): + continue + + cookie_parts = cookie.split('#') + headers = self.headers.copy() + headers['Cookie'] = cookie_parts[0].strip() if cookie_parts else "" + member_id = cookie_parts[1].strip() if len(cookie_parts) > 1 else "" + + print(f"\n*****第[{index+1}]个{self.name}账号*****") + await self.process_account(index+1, headers, member_id) + await asyncio.sleep(2 + random.random() * 3) + + async def process_account(self, index, headers, member_id): + try: + user_info = await self.get_user_info(headers, member_id) + if user_info.get("code") != 0: + print(user_info.get("message", "获取用户信息失败")) + return + + nick_name = user_info.get("resultJson", {}).get("userMember", {}).get("nickName", "未知用户") + phone = user_info.get("resultJson", {}).get("userMember", {}).get("mobilePhone", "未知手机号") + sign_num = user_info.get("resultJson", {}).get("signNum", 0) + + print(f"{nick_name}({phone})") + + if sign_num == 0: + print("今日已签到") + else: + sign_result = await self.sign(headers, member_id) + if sign_result.get("code") == 0: + print(f"签到成功，已连续签到{sign_result.get('resultJson', {}).get('signdays', 0)}天") + else: + print(f"签到失败：{sign_result.get('message', '未知错误')}") + + points_result = await self.get_points(headers, member_id) + if points_result.get("code") == 0: + points = points_result.get("resultJson", {}).get("meberinfo", {}).get("totalIntegral", 0) + print(f"当前积分：{points}") + else: + print(f"获取积分失败：{points_result.get('message', '未知错误')}") + + except Exception as e: + print(f"处理账号{index}时发生异常：{str(e)}") + + async def get_user_info(self, headers, member_id): + try: + url = f"{self.baseUrl}/PersonalCenter/PersonalCenter/GetShopMemberDetail" + params = f"memberId={member_id}" + response = self.http.post(url, headers=headers, data=params) + return response.json() + except Exception as e: + print(f"获取用户信息时发生异常：{str(e)}") + return {"code": -1, "message": f"获取用户信息时发生异常：{str(e)}"} + + async def sign(self, headers, member_id): + try: + url = f"{self.baseUrl}/PersonalCenter/PersonalCenter/ShopMemberSign" + params = f"memberId={member_id}" + response = self.http.post(url, headers=headers, data=params) + return response.json() + except Exception as e: + print(f"签到时发生异常：{str(e)}") + return {"code": -1, "message": f"签到时发生异常：{str(e)}"} + + async def get_points(self, headers, member_id): + try: + url = f"{self.baseUrl}/PersonalCenter/PersonalCenter/GetShopMemberDetail" + params = f"memberId={member_id}" + response = self.http.post(url, headers=headers, data=params) + return response.json() + except Exception as e: + print(f"获取积分时发生异常：{str(e)}") + return {"code": -1, "message": f"获取积分时发生异常：{str(e)}"} + +if __name__ == "__main__": + task = SYFSign() + asyncio.run(task.main())