(self, is_query_only=False)
| 1860 | self.log("权益超市-会员中心: 直接领奖兜底失败，跳过") |
| 1861 | |
| 1862 | def market_task(self, is_query_only=False): |
| 1863 | self.log("==== 权益超市 ====") |
| 1864 | ticket = self.market_get_ticket() |
| 1865 | if not ticket: |
| 1866 | return |
| 1867 | user_token = self.market_get_user_token(ticket) |
| 1868 | if not user_token: |
| 1869 | return |
| 1870 | if is_query_only: |
| 1871 | self.query_market_watering_status(user_token) |
| 1872 | self.query_market_raffle_records(user_token) |
| 1873 | self.query_phone_recharge_records(user_token) |
| 1874 | return |
| 1875 | mc = globalConfig.get("market_config", {}) |
| 1876 | if mc.get("run_water", True): |
| 1877 | self.market_watering_task(user_token) |
| 1878 | time.sleep(2) |
| 1879 | else: |
| 1880 | self.log("权益超市-浇水: ⏭️ 已被总开关关闭，跳过") |
| 1881 | if mc.get("run_task", True): |
| 1882 | if hasattr(self, 'ecs_token'): |
| 1883 | share_list = self.market_get_all_tasks(self.ecs_token, user_token) |
| 1884 | if share_list: |
| 1885 | self.market_do_share_list(share_list, user_token) |
| 1886 | else: |
| 1887 | self.log("权益超市: 缺 ecs_token, 跳过通用任务列表") |
| 1888 | else: |
| 1889 | self.log("权益超市-做任务: ⏭️ 已被总开关关闭，跳过") |
| 1890 | if mc.get("run_member_center", True): |
| 1891 | time.sleep(2) |
| 1892 | self.market_member_center_task(user_token) |
| 1893 | else: |
| 1894 | self.log("权益超市-会员中心: ⏭️ 已被子开关关闭，跳过") |
| 1895 | if mc.get("run_draw", True): |
| 1896 | if self.market_get_raffle(user_token): |
| 1897 | self.market_get_raffle_count(user_token) |
| 1898 | else: |
| 1899 | self.log("权益超市-抽奖: ⏭️ 已被总开关关闭，跳过") |
| 1900 | if mc.get("run_claim", False): |
| 1901 | self.log("权益超市-领奖: 自动领奖已开启") |
| 1902 | self.query_phone_recharge_records(user_token) |
| 1903 | else: |
| 1904 | self.log("权益超市-领奖: ⏭️ 未开启自动领奖") |
| 1905 | self.query_market_raffle_records(user_token) |
| 1906 | self.query_phone_recharge_records(user_token) |
| 1907 | |
| 1908 | def init_cloud_urls(self): |
| 1909 | if not hasattr(self, 'cloudDiskUrls'): |
no test coverage detected