diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..7c0d512 --- /dev/null +++ b/.gitignore @@ -0,0 +1,3 @@ +.claude/ +.vscode/ +__pycache__/ diff --git a/README.md b/README.md index 5072a3a..a67795a 100644 --- a/README.md +++ b/README.md @@ -33,7 +33,9 @@ │ ├── sign_day_sign ............... 执行签到 │ ├── sign_task_center ............ 任务中心(自动完成任务并领取奖励) │ ├── sign_do_task_from_list ...... 执行任务中心任务 -│ └── sign_get_task_reward ........ 领取任务奖励 +│ ├── sign_get_task_reward ........ 领取任务奖励 +│ ├── sign_month_reward ........... 月签到连签礼奖励 +│ └── sign_coupon_exchange ........ 话费红包兑换话费券 │ │ │ ├── [天天领现金 TTLXJ] │ ├── ttlxj_task .................. 领现金任务入口 @@ -58,7 +60,8 @@ │ ├── market_watering ............. 执行浇花 │ ├── market_raffle_task .......... 抽奖任务(可选展示奖池信息) │ ├── market_validate_captcha ..... 人机验证处理 -│ └── market_raffle ............... 执行抽奖 +│ ├── market_raffle ............... 执行抽奖 +│ └── market_privilege_task ....... 优享权益每日领取 │ │ │ ├── [新疆专区 Xinjiang] │ ├── xj_task ..................... 新疆任务入口(含归属地校验) @@ -118,6 +121,7 @@ - **奖池信息展示**: 抽奖完成后展示今日奖池信息（显示任意中奖率>0的奖品） - **人机验证处理**: 抽奖触发人机验证时自动处理并继续抽奖 - **浇花任务**: 支持多次浇花直到完成目标次数 +- **优享权益**: 每日自动领取一款优享权益（优先惊喜权益） - **全局奖池查询**: 多账号只查询一次奖池，共享结果 ### 云手机活动 @@ -128,6 +132,8 @@ ### 签到区-任务中心 - **任务自动完成**: 自动浏览任务页面并完成任务 - **奖励自动领取**: 任务完成后自动领取奖励 +- **月签到奖励**: 自动检查并领取每月连签礼奖励 +- **话费券兑换**: 支持使用话费红包兑换话费券（可配置兑换面额） ### 联通安全管家 - **每日签到**: 自动完成安全管家签到任务 @@ -186,6 +192,15 @@ export chinaUnicomCookie="token1@token2@token3" ```python SHOW_PRIZE_POOL = True # 是否显示权益超市奖品池信息 + +# 话费券兑换配置 (需要在抢兑时间段内: 10:00-14:00, 18:00-22:00) +EXCHANGE_COUPON_CONFIG = { + "1元话费券": False, # 100积分, 满20元可用 + "3元话费券": False, # 300积分, 满30元可用 + "5元话费券": True, # 500积分, 满50元可用 + "10元话费券": True, # 1000积分, 满100元可用 + "18元话费券": False, # 1800积分, 满200元可用 +} ``` ### 4. 运行脚本 diff --git a/中国联通.py b/中国联通.py index dddafc0..3a44589 100644 --- a/中国联通.py +++ b/中国联通.py @@ -41,6 +41,35 @@ WOCARE_SIGN_KEY = "f4cd4ffeb5554586acf65ba7110534f5" WOCARE_CHANNEL_TYPE = "wocareMBHServiceLife1" WOCARE_VERSION = "1" +# ==================== Coupon Exchange Config (话费券兑换配置) ==================== +# True=开启兑换, False=关闭兑换 +# 注意: 需要在抢兑时间段内才能兑换 (通常为 10:00-14:00, 18:00-22:00) +EXCHANGE_COUPON_CONFIG = { + "1元话费券": False, # 100积分, 满20元可用 + "3元话费券": False, # 300积分, 满30元可用 + "5元话费券": True, # 500积分, 满50元可用 + "10元话费券": True, # 1000积分, 满100元可用 + "18元话费券": False, # 1800积分, 满200元可用 +} + +# 话费券产品映射表 (名称 -> product_id) +COUPON_PRODUCT_MAP = { + "1元话费券": "25122309441216995", + "3元话费券": "25122309482612026", + "5元话费券": "25122309512816188", + "10元话费券": "25122309543215732", + "18元话费券": "25122310293512803", +} + +# 话费券积分需求表 (名称 -> 需要积分数, 积分=话费红包*100) +COUPON_POINTS_REQUIRED = { + "1元话费券": 100, # 需要1元话费红包 + "3元话费券": 300, # 需要3元话费红包 + "5元话费券": 500, # 需要5元话费红包 + "10元话费券": 1000, # 需要10元话费红包 + "18元话费券": 1800, # 需要18元话费红包 +} + # ==================== Global Market Raffle State ==================== # 全局奖池状态，多账号共享，只查询一次 @@ -149,6 +178,10 @@ market_raffle_state = MarketRaffleState() # ==================== Utils ==================== +# 全局打印锁，防止异步并发时日志输出混乱 +_print_lock = asyncio.Lock() + + class Logger: def __init__(self, prefix=""): self.prefix = prefix @@ -156,7 +189,13 @@ class Logger: def log(self, message, notify=False): timestamp = datetime.now().strftime("%H:%M:%S") prefix_str = f"[{self.prefix}] " if self.prefix else "" - print(f"[{timestamp}] {prefix_str}{message}") + # 使用 print 的 flush 参数确保立即输出并换行 + print(f"[{timestamp}] {prefix_str}{message}", flush=True) + + async def log_async(self, message, notify=False): + """异步日志，使用锁防止并发输出混乱""" + async with _print_lock: + self.log(message, notify) class HttpClient: @@ -402,6 +441,7 @@ class CustomUserService: await self.sign_get_telephone(is_initial=True) await self.sign_task_center() await self.sign_get_telephone(is_initial=False) + await self.sign_coupon_exchange() async def sign_get_telephone(self, is_initial=False): try: @@ -906,6 +946,7 @@ class CustomUserService: await self.market_share_task() # 分享小红书任务，获取额外抽奖机会 await self.market_watering_task() await self.market_raffle_task() + await self.market_privilege_task() # 优享权益领取 async def market_login(self): target_url = "https://contact.bol.wo.cn/" @@ -1118,6 +1159,203 @@ class CustomUserService: self.logger.log(f"权益超市抽奖异常: {str(e)}") return False + async def market_privilege_task(self): + """优享权益: 每日领取一款权益""" + try: + if not self.market_token: + return + + # 获取当前日期 + now = datetime.now() + current_time = f"{now.year}-{now.month}-{now.day}" + + # 获取活动详情 + res = await self.http.request( + "POST", + "https://backward.bol.wo.cn/prod-api/promotion/activity/roll/getActivitiesDetail", + headers={ + "Authorization": f"Bearer {self.market_token}", + "Content-Type": "application/json", + "Referer": "https://contact.bol.wo.cn/", + }, + json={ + "majorId": 3, + "subCodeList": ["YOUCHOICEONE"], + "currentTime": current_time, + "withUserStatus": 1, + }, + ) + + result = res["result"] + if not result or result.get("code") != 200: + self.logger.log(f"优享权益: 获取活动详情失败 {result.get('msg', '')}") + return + + data_list = result.get("data", []) + if not data_list: + return + + activity = data_list[0] + user_available_times = activity.get("userAvailableTimes", 0) + + if user_available_times <= 0: + self.logger.log("优享权益: 今日已领取") + return + + detail_list = activity.get("detailList", []) + if not detail_list: + return + + # 筛选有库存的权益 + available_items = [ + item for item in detail_list if int(item.get("leftQuantity", 0)) > 0 + ] + + if not available_items: + self.logger.log("优享权益: 所有权益均无库存") + return + + # 分类: 惊喜权益 vs 普通权益 + surprise_items = [ + item for item in available_items if item.get("isSurprise") == 1 + ] + normal_items = [ + item for item in available_items if item.get("isSurprise") != 1 + ] + + # 按sort降序排列 (sort越大可能价值越高) + surprise_items.sort(key=lambda x: int(x.get("sort", 0)), reverse=True) + normal_items.sort(key=lambda x: int(x.get("sort", 0)), reverse=True) + + # 从活动中获取 activityId 和 activityCode + activity_id = activity.get("activityId") + activity_code = activity.get("activityCode", "YOUCHOICEONE") + + # 优先尝试惊喜权益 + for item in surprise_items: + product_name = item.get("productName", "") + product_id = item.get("id") + product_code = item.get("productCode", "") + is_unlock = item.get("isUnlock") + channel_id = item.get("channelId") + account_type = item.get("accountType", "4") + + # 惊喜权益需要先解锁 + if is_unlock == 0: + unlock_success = await self._unlock_surprise_privilege( + product_id, activity_code + ) + if not unlock_success: + self.logger.log(f"优享权益: [{product_name}] 解锁失败") + continue + + # 尝试领取 + receive_success = await self._receive_privilege( + activity_id, + product_id, + product_code, + channel_id, + account_type, + current_time, + ) + if receive_success: + self.logger.log( + f"优享权益: [{product_name}] 领取成功!", notify=True + ) + return + else: + self.logger.log(f"优享权益: [{product_name}] 领取失败") + + # 如果惊喜权益都失败了，尝试普通权益 + for item in normal_items: + product_name = item.get("productName", "") + product_id = item.get("id") + product_code = item.get("productCode", "") + channel_id = item.get("channelId") + account_type = item.get("accountType", "4") + + receive_success = await self._receive_privilege( + activity_id, + product_id, + product_code, + channel_id, + account_type, + current_time, + ) + if receive_success: + self.logger.log( + f"优享权益: [{product_name}] 领取成功!", notify=True + ) + return + else: + self.logger.log(f"优享权益: [{product_name}] 领取失败") + + self.logger.log("优享权益: 所有权益领取失败") + + except Exception as e: + self.logger.log(f"优享权益异常: {str(e)}") + + async def _unlock_surprise_privilege(self, product_id, activity_code): + """解锁惊喜权益""" + try: + timestamp = int(time.time() * 1000) + res = await self.http.request( + "POST", + "https://backward.bol.wo.cn/prod-api/promotion/activity/roll/unlock/surpriseInterest", + headers={ + "Authorization": f"Bearer {self.market_token}", + "Content-Type": "application/json", + "Referer": "https://contact.bol.wo.cn/", + }, + json={ + "timeVerRan": timestamp, + "mobile": self.mobile, + "id": product_id, + "activityId": activity_code, + }, + ) + + result = res["result"] + return result and result.get("code") == 200 + + except Exception: + return False + + async def _receive_privilege( + self, + activity_id, + product_id, + product_code, + channel_id, + account_type, + current_time, + ): + """领取权益""" + try: + res = await self.http.request( + "POST", + "https://backward.bol.wo.cn/prod-api/promotion/activity/roll/receiveRights", + headers={ + "Authorization": f"Bearer {self.market_token}", + "Content-Type": "application/json", + "Referer": "https://contact.bol.wo.cn/", + }, + json={ + "channelId": channel_id, + "activityId": activity_id, + "productId": product_id, + "productCode": product_code, + "currentTime": current_time, + "accountType": account_type, + }, + ) + + result = res["result"] + return result and result.get("code") == 200 + + except Exception: + return False + # ==================== Xinjiang (xj) ==================== async def xj_task(self): if "新疆" not in self.province: @@ -1452,7 +1690,7 @@ class CustomUserService: async def sign_task_center(self): """签到区-任务中心: 获取任务列表、执行任务、领取奖励""" try: - for i in range(30): # 最多循环30次，防止死循环 + for i in range(20): # 最多循环20次，防止死循环 res = await self.http.request( "GET", "https://activity.10010.com/sixPalaceGridTurntableLottery/task/taskList", @@ -1505,9 +1743,235 @@ class CustomUserService: break + # 检查月签到奖励 + await self.sign_month_reward() + except Exception as e: self.logger.log(f"签到区-任务中心异常: {str(e)}") + async def sign_month_reward(self): + """签到区-月签到奖励: 检查并领取每月连签礼奖励""" + try: + res = await self.http.request( + "GET", + "https://activity.10010.com/sixPalaceGridTurntableLottery/floor/getMonthSign", + headers={"Referer": "https://img.client.10010.com/"}, + ) + + result = res["result"] + code = str(result.get("code", "")) if result else "" + + if code != "0000": + return + + task_list = result.get("data", {}).get("taskList", []) + + for task in task_list: + task_status = str(task.get("taskStatus", "")) + # taskStatus: 2=已领取, 1=待领取, 0=不可领取 + if task_status == "1": + task_id = task.get("taskId", "") + task_name = task.get("taskName", "") + id_ = task.get("id", "") + + if task_id and id_: + reward_res = await self.http.request( + "GET", + "https://activity.10010.com/sixPalaceGridTurntableLottery/task/getTaskReward", + params={ + "taskId": task_id, + "taskType": "30", + "id": id_, + }, + headers={"Referer": "https://img.client.10010.com/"}, + ) + + reward_result = reward_res["result"] + reward_code = ( + str(reward_result.get("code", "")) if reward_result else "" + ) + + if reward_code == "0000": + data = reward_result.get("data", {}) + if str(data.get("code", "")) == "0000": + prize_name = data.get("prizeName", "") + prize_name_red = data.get("prizeNameRed", "") + self.logger.log( + f"签到区-月签奖励: [{task_name}] {prize_name}{prize_name_red}", + notify=True, + ) + + await asyncio.sleep(1) + + except Exception: + pass + + async def sign_coupon_exchange(self): + """签到区-话费券兑换: 根据配置尝试兑换话费券""" + try: + # 检查是否有任何启用的兑换配置 + enabled_coupons = [ + name for name, enabled in EXCHANGE_COUPON_CONFIG.items() if enabled + ] + if not enabled_coupons: + return + + # 获取奖品列表 + prize_list = await self._get_coupon_prize_list() + if not prize_list: + return + + # 获取当前话费红包积分 (积分 = 话费红包 * 100) + current_points = int(self.initial_telephone_amount * 100) + + # 遍历启用的话费券配置 + for coupon_name in enabled_coupons: + product_id = COUPON_PRODUCT_MAP.get(coupon_name) + if not product_id: + continue + + # 在奖品列表中查找对应商品 + prize_info = self._find_prize_in_list(prize_list, product_id) + if not prize_info: + continue + + # 检查是否已兑换过 (buttonDTO.name = "面额已参与兑换") + button_dto = prize_info.get("buttonDTO") + if button_dto and button_dto.get("name") == "面额已参与兑换": + self.logger.log(f"签到区-话费券: [{coupon_name}] 今日已兑换") + continue + + # 检查库存 (无库存直接略过，不显示) + stock_surplus = int(prize_info.get("stockSurplus", 0)) + if stock_surplus <= 0: + continue + + # 检查积分是否达到兑换门槛 + required_points = COUPON_POINTS_REQUIRED.get(coupon_name, 0) + if current_points < required_points: + self.logger.log( + f"签到区-话费券: [{coupon_name}] 积分不足 (需要{required_points}, 当前{current_points})" + ) + continue + + # 执行兑换 (连续尝试3次) + for attempt in range(3): + await self._do_coupon_exchange( + product_id, prize_info.get("type_code", "21003_01") + ) + await asyncio.sleep(0.5) + + # 等待并验证兑换结果 + await asyncio.sleep(1) + new_prize_list = await self._get_coupon_prize_list() + if new_prize_list: + new_prize_info = self._find_prize_in_list( + new_prize_list, product_id + ) + if new_prize_info: + # 检查是否出现 buttonDTO 字段 (表示已兑换成功) + new_button_dto = new_prize_info.get("buttonDTO") + if ( + new_button_dto + and new_button_dto.get("name") == "面额已参与兑换" + ): + self.logger.log( + f"签到区-话费券: [{coupon_name}] 兑换成功!", notify=True + ) + else: + self.logger.log(f"签到区-话费券: [{coupon_name}] 兑换失败") + else: + self.logger.log(f"签到区-话费券: [{coupon_name}] 验证失败") + + await asyncio.sleep(1) + + except Exception as e: + self.logger.log(f"签到区-话费券兑换异常: {str(e)}") + + async def _get_coupon_prize_list(self): + """获取话费券奖品列表""" + try: + res = await self.http.request( + "POST", + "https://act.10010.com/SigninApp/new_convert/prizeList", + headers={ + "Referer": "https://img.client.10010.com/", + "Content-Type": "application/x-www-form-urlencoded", + }, + data="", + ) + + result = res["result"] + status = str(result.get("status", "")) if result else "" + + if status != "0000": + return None + + # 提取当前有效时段的奖品列表 + tab_items = result.get("data", {}).get("datails", {}).get("tabItems", []) + for tab in tab_items: + # 找到当前有效的时段 (defaultShowList=true 且 state="抢兑中") + if tab.get("defaultShowList") and tab.get("state") == "抢兑中": + return tab.get("timeLimitQuanListData", []) + + return None + + except Exception: + return None + + def _find_prize_in_list(self, prize_list, product_id): + """在奖品列表中查找指定商品""" + for prize in prize_list: + if prize.get("product_id") == product_id: + return prize + return None + + async def _do_coupon_exchange(self, product_id, type_code): + """执行话费券兑换""" + try: + # Step 1: 获取兑换 UUID + uuid_res = await self.http.request( + "POST", + "https://act.10010.com/SigninApp/convert/prizeConvert", + headers={ + "Referer": "https://img.client.10010.com/", + "Content-Type": "application/x-www-form-urlencoded", + }, + data=f"product_id={product_id}&typeCode={type_code}", + ) + + uuid_result = uuid_res["result"] + uuid_status = str(uuid_result.get("status", "")) if uuid_result else "" + + if uuid_status != "0000": + return False + + uuid = uuid_result.get("data", {}).get("uuid", "") + if not uuid: + return False + + # Step 2: 执行兑换 + exchange_res = await self.http.request( + "POST", + "https://act.10010.com/SigninApp/convert/prizeConvertResult", + headers={ + "Referer": "https://img.client.10010.com/", + "Content-Type": "application/x-www-form-urlencoded", + }, + data=f"uuid={uuid}", + ) + + exchange_result = exchange_res["result"] + exchange_status = ( + str(exchange_result.get("status", "")) if exchange_result else "" + ) + + # 注意: 即使返回失败也可能实际成功，需要通过库存验证 + return exchange_status == "0000" + + except Exception: + return False + async def sign_do_task_from_list(self, task): """执行签到区任务""" try: