ltcy.py

"""
联通畅游 v1.0

活动入口: 某通app首页-5g新通信-某通畅游

格式 某通手机号#appid#token_online
export UNICOM_GAME_ACCOUNT_INFO=""

cron: 25 8,10 * * *
const $ = new Env("联通畅游");
"""

from time import sleep
from requests import post, get
from random import randint
from tools.tool import get_environ, timestamp
from tools.send_msg import push
from uuid import uuid4

class CUG:
    def __init__(self, phone: str, appid: str, token_online: str):
        self.phone_num = phone.rstrip("\n")
        self.appId = appid.rstrip("\n")
        self.token_online = token_online.rstrip("\n")
        default_ua = f"Mozilla/5.0 (Linux; Android {randint(8, 13)}; SM-S908U Build/TP1A.220810.014; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/{randint(95, 108)}.0.5359.128 Mobile Safari/537.36; unicom{{version:android@9.0{randint(0, 6)}00,desmobile:{self.phone_num}}};devicetype{{deviceBrand:,deviceModel:}};{{yw_code:}}"
        self.run_ua = get_environ(key="UNICOM_USERAGENT", default=default_ua, output=False)
        self.deviceId = uuid4().hex
        self.msg = ""
    def get_ecsToken(self):
        url = "https://m.client.10010.com/mobileService/onLine.htm"
        body = f"reqtime={timestamp()}&netWay=Wifi&version=android%4010.0100&deviceId={self.deviceId}&token_online={self.token_online}&provinceChanel=general&appId={self.appId}&deviceModel=SM-S908U&step=bindlist&androidId={uuid4().hex[8:24]}&deviceBrand=&flushkey=1"
        headers = {
            "content-type": "application/x-www-form-urlencoded",
            "user-agent": self.run_ua
        }
        data = post(url, headers=headers, data=body).json()
        print(data)
        self.ecs_token = data["ecs_token"]
        # print(self.ecs_token)
    def login(self):
        url = "https://game.wostore.cn/api/app//user/v2/login"
        body = {
            "identityType": "esToken",
            "code": self.ecs_token
        }
        headers = {
            "pragma": "no-cache",
            "cache-control": "no-cache",
            "accept": "application/json",
            "content-type": "application/json;charset=utf-8",
            "user-agent": self.run_ua,
            "channelid": "GAMELTAPP_90006",
            "device": "5",
            "origin": "https://web.wostore.cn",
            "x-requested-with": "com.sinovatech.unicom.ui",
            "sec-fetch-site": "same-site",
            "sec-fetch-mode": "cors",
            "sec-fetch-dest": "empty",
            "referer": "https://web.wostore.cn/",
            "accept-encoding": "gzip, deflate",
            "accept-language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7"
        }
        data = post(url, headers=headers, json=body).json()
        self.access_token = data["data"]["access_token"]
        self.headers = {
            "pragma": "no-cache",
            "cache-control": "no-cache",
            "accept": "application/json, text/plain, */*",
            "authorization": self.access_token,
            "user-agent": self.run_ua,
            "origin": "https://web.wostore.cn",
            "x-requested-with": "com.sinovatech.unicom.ui",
            "sec-fetch-site": "same-site",
            "sec-fetch-mode": "cors",
            "sec-fetch-dest": "empty",
            "referer": "https://web.wostore.cn/",
            "accept-encoding": "gzip, deflate",
            "accept-language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7"
        }

    def check_in(self):
        url = "https://game.wostore.cn/api/app/user/v2/signIn"
        data = get(url, headers=self.headers).json()
        print(data)

    def lotter(self):
        url = "https://game.wostore.cn/api/app/user/v2/benefit/lottery?id=1"
        data = get(url, headers=self.headers).json()
        print(data)

    def pay_lotter(self, lotter_id):
        if lotter_id is None:
            return
        url = f"https://game.wostore.cn/api/app/user/v2/lottery/join?id={lotter_id}"
        data = get(url, headers=self.headers).json()
        print(data)

    def get_task(self):
        """
        receiveStatus 2 为已完成
        :return:
        """
        url = "https://game.wostore.cn/api/app/user/v2/task/list"
        data = get(url, headers=self.headers).json()
        all_task_info = {}
        print(data)
        for task_info in data["data"]:
            if task_info["receiveStatus"] == 2:
                print(f"任务{task_info['taskName']}已完成 跳过领取")
                continue
            elif task_info["receiveStatus"] == 0:
                print(f"任务{task_info['taskName']}已完成 跳过领取")
                continue
            all_task_info[task_info["id"]] = task_info["productId"]
        return all_task_info

    def finish_task(self, task_id, productId):
        url = f"https://game.wostore.cn/api/app/user/v2/task/receive?productId={productId}&taskId={task_id}"
        data = get(url, headers=self.headers).json()
        print(data)
        sleep(3)

    def play_game(self):
        url = "https://game.wostore.cn/api/app/user/v2/play/save"
        body = {
            "cpGameId": f"1500019{randint(900, 999)}"
        }
        data = post(url, headers=self.headers, json=body).json()
        print(data)

    def exchange(self):
        def get_exchange():
            url = "https://game.wostore.cn/api/app/game/v2/shop/getToken"
            data = get(url, headers=self.headers).json()
            # print(data)
            return data["data"]
        url = f"https://game.wostore.cn/api/app/shop/order/product/order/mall?Authorization={get_exchange()}"
        body = {
            "productId": "803779159738716160"
        }
        data = post(url, headers=self.headers, json=body).json()
        print(data)
    def init(self):
        """
        初始化活动及查询积分
        :return:
        """
        url = "https://game.wostore.cn/api/app/user/v2/getMemberInfo"
        data = get(url, headers=self.headers).json()
        # print(data)
        return data["data"]["userIntegral"]
    def get_pay_lotter_list(self):
        """
        status
            0: 可参与
            1: 已参与
            2: 已结束
        :return:
        """
        def get_shopToken():
            url = "https://game.wostore.cn/api/app/game/v2/shop/getToken"
            data = get(url, headers=self.headers).json()
            # print(data)
            return data["data"]
        url = f"https://game.wostore.cn/api/app/shop/business/lottery/available?Authorization={get_shopToken()}"
        headers = {
            "pragma": "no-cache",
            "cache-control": "no-cache",
            "accept": "application/json",
            "user-agent": self.run_ua,
            "channelid": "GAMELTAPP_90006",
            "device": "5",
            "origin": "https://web.wostore.cn",
            "x-requested-with": "com.sinovatech.unicom.ui",
            "sec-fetch-site": "same-site",
            "sec-fetch-mode": "cors",
            "sec-fetch-dest": "empty",
            "referer": "https://web.wostore.cn/",
            "accept-encoding": "gzip, deflate",
            "accept-language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7"
        }
        data = get(url, headers=headers).json()
        # print(data)
        for lotter_info in data["data"]["list"]:
            if lotter_info["status"] == 0 and lotter_info["points"] <= 30:
                return lotter_info["id"]
        print("当前抽奖轮次已全部参加或没有符合条件的场次 跳过")
        return None
    def main(self):
        self.get_ecsToken()
        self.login()
        old_score = self.init()
        self.check_in()
        self.lotter()
        self.pay_lotter(self.get_pay_lotter_list())
        self.play_game()
        [self.finish_task(task_id, productId) for task_id, productId in self.get_task().items()]
        sleep(5)
        now_score = self.init()
        today_score = now_score - old_score
        self.msg += f"账号{self.phone_num}---本次运行获得{today_score}分, 当前共有{now_score}分\n"
        push("某通畅游", self.msg)
if __name__ == '__main__':
    unicom_game_info = get_environ("UNICOM_GAME_ACCOUNT_INFO")
    if unicom_game_info == "":
        exit(0)
    cug = CUG(*unicom_game_info.split("#"))
    cug.main()