# 非青龙下在文件开头添加账号配置,
# process.env.chinaTelecomAccount = `
# 13454545457#123456
# 13454545457#456789
# `.trim();
'''
变量：chinaTelecomAccount
变量格式: 手机号#服务密码
多号创建多个变量或者换行、&隔开
'''
import os
import re
import sys
import ssl
import time
import json
import httpx
import base64
import random
import certifi
import aiohttp
import asyncio
import logging
import datetime
import requests
import binascii
from http import cookiejar
from Crypto.Cipher import AES
from Crypto.Cipher import DES3
from Crypto.PublicKey import RSA
from urllib.parse import urlparse
from Crypto.Cipher import PKCS1_v1_5
from Crypto.Util.Padding import pad, unpad
from aiohttp import ClientSession, TCPConnector
from tenacity import (
retry,
stop_after_attempt,
wait_exponential,
retry_if_exception_type
)
import pandas as pd
apptoken = ""
MAX_RETRIES = 3
RATE_LIMIT = 10
class RateLimiter:
def __init__(self, rate_limit):
self.rate_limit = rate_limit
self.tokens = rate_limit
self.updated_at = time.monotonic()
async def acquire(self):
while self.tokens < 1:
self.add_new_tokens()
await asyncio.sleep(0.1)
self.tokens -= 1
def add_new_tokens(self):
now = time.monotonic()
time_since_update = now - self.updated_at
new_tokens = time_since_update * self.rate_limit
if new_tokens > 1:
self.tokens = min(self.tokens + new_tokens, self.rate_limit)
self.updated_at = now
class AsyncSessionManager:
def __init__(self, timeout=None):
self.client = None
self.timeout = timeout or httpx.Timeout(60.0, connect=30.0, read=30.0, write=30.0)
async def __aenter__(self):
ssl_context = ssl.create_default_context(cafile=certifi.where())
ssl_context.set_ciphers('DEFAULT@SECLEVEL=1')
self.client = httpx.AsyncClient(
verify=ssl_context,
limits=httpx.Limits(max_connections=100, max_keepalive_connections=20),
timeout=self.timeout
)
return self.client
async def __aexit__(self, exc_type, exc_val, exc_tb):
if self.client:
await self.client.aclose()
async def retry_request2(session, method, url, **kwargs):
for attempt in range(MAX_RETRIES):
try:
response=await session.request(method, url, **kwargs)
return await response
except aiohttp.ClientError as e:
if attempt == MAX_RETRIES - 1:
raise
await asyncio.sleep(2 ** attempt)
async def retry_request(session, method, url, **kwargs):
for attempt in range(MAX_RETRIES):
try:
await asyncio.sleep(1)
response=await session.request(method, url, **kwargs)
return response.json()
except (aiohttp.ClientConnectionError, aiohttp.ServerTimeoutError) as e:
print(f"请求失败，第 {attempt + 1} 次重试: {e}")
if attempt == MAX_RETRIES - 1:
raise
await asyncio.sleep(2 ** attempt)
class BlockAll(cookiejar.CookiePolicy):
return_ok = set_ok = domain_return_ok = path_return_ok = lambda self, *args, **kwargs: False
netscape = True
rfc2965 = hide_cookie2 = False
def printn(m):
print(f'\n{m}')
context = ssl.create_default_context()
context.set_ciphers('DEFAULT@SECLEVEL=1')
context.check_hostname = False
context.verify_mode = ssl.CERT_NONE
class DESAdapter(requests.adapters.HTTPAdapter):
def init_poolmanager(self, *args, **kwargs):
kwargs['ssl_context'] = context
return super().init_poolmanager(*args, **kwargs)
requests.packages.urllib3.disable_warnings()
ss = requests.session()
ss.headers={"User-Agent":"Mozilla/5.0 (Linux; Android 13; 22081212C Build/TKQ1.220829.002) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/104.0.5112.97 Mobile Safari/537.36","Referer":"https://wapact.189.cn:9001/JinDouMall/JinDouMall_independentDetails.html"}
ss.mount('https://', DESAdapter())
ss.cookies.set_policy(BlockAll())
runTime = 0
lock = asyncio.Lock()
event = asyncio.Event()
ready_count = 0
diffValue = 0
# current_time = datetime.datetime.now().strftime("%Y%m%d-%H-%M-%S")
log_filename = f'.电信等级权益日志.log'
logging.basicConfig(level=logging.CRITICAL,
format='%(asctime)s -- %(message)s',
datefmt='%Y-%m-%d %H:%M:%S',
filename=log_filename,
filemode='a', encoding='utf-8')
logger = logging.getLogger(__name__)
ip_list = []
load_token_file = 'chinaTelecom_cache.json'
try:
with open(load_token_file, 'r') as f:
load_token = json.load(f)
except:
load_token = {}
key = b'1234567`90koiuyhgtfrdews'
iv = 8 * b'\0'
public_key_b64 = '''-----BEGIN PUBLIC KEY-----
MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDBkLT15ThVgz6/NOl6s8GNPofdWzWbCkWnkaAm7O2LjkM1H7dMvzkiqdxU02jamGRHLX/ZNMCXHnPcW/sDhiFCBN18qFvy8g6VYb9QtroI09e176s+ZCtiv7hbin2cCTj99iUpnEloZm19lwHyo69u5UMiPMpq0/XKBO8lYhN/gwIDAQAB
-----END PUBLIC KEY-----'''
public_key_data = '''-----BEGIN PUBLIC KEY-----
MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQC+ugG5A8cZ3FqUKDwM57GM4io6JGcStivT8UdGt67PEOihLZTw3P7371+N47PrmsCpnTRzbTgcupKtUv8ImZalYk65dU8rjC/ridwhw9ffW2LBwvkEnDkkKKRi2liWIItDftJVBiWOh17o6gfbPoNrWORcAdcbpk2L+udld5kZNwIDAQAB
-----END PUBLIC KEY-----'''
def ttt(hour,minute,second):
date = datetime.datetime.now()
date_zero = datetime.datetime.now().replace(year=date.year, month=date.month, day=date.day, hour=hour, minute=int(minute),second=int(second))
date_zero_time = int(time.mktime(date_zero.timetuple()))
return date_zero_time
def encrypt(text):
cipher = DES3.new(key, DES3.MODE_CBC, iv)
ciphertext = cipher.encrypt(pad(text.encode(), DES3.block_size))
return ciphertext.hex()
def decrypt(text):
ciphertext = bytes.fromhex(text)
cipher = DES3.new(key, DES3.MODE_CBC, iv)
plaintext = unpad(cipher.decrypt(ciphertext), DES3.block_size)
return plaintext.decode()
def b64(plaintext):
public_key = RSA.import_key(public_key_b64)
cipher = PKCS1_v1_5.new(public_key)
ciphertext = cipher.encrypt(plaintext.encode())
return base64.b64encode(ciphertext).decode()
def encrypt_para2(plaintext):
public_key = RSA.import_key(public_key_data)
cipher = PKCS1_v1_5.new(public_key)
ciphertext = cipher.encrypt(plaintext.encode())
return ciphertext.hex()
def encrypt_para(plaintext):
if not isinstance(plaintext, str):
plaintext = json.dumps(plaintext)
public_key = RSA.import_key(public_key_data)
cipher = PKCS1_v1_5.new(public_key)
ciphertext = cipher.encrypt(plaintext.encode())
return binascii.hexlify(ciphertext).decode()
def encode_phone(text):
encoded_chars = []
for char in text:
encoded_chars.append(chr(ord(char) + 2))
return ''.join(encoded_chars)
def ophone(t):
key = b'34d7cb0bcdf07523'
utf8_key = key.decode('utf-8')
utf8_t = t.encode('utf-8')
cipher = AES.new(key, AES.MODE_ECB)
ciphertext = cipher.encrypt(pad(utf8_t, AES.block_size))
return ciphertext.hex()
def get_first_three(value):
if isinstance(value, (int, float)):
return int(str(value)[:3])
elif isinstance(value, str):
if len(value) >= 11: # 如果是手机号，显示前3位和后4位
return value[:3] + value[3:7] + value[-4:] # 显示完整号码
return str(value)[:3] # 其他字符串只返回前三位
else:
raise TypeError("非数字非字符串类型无法截取前三位")
def mask_middle_four(value):
if isinstance(value, str):
if len(value) >= 11:
return value[:3] + "####" + value[-4:]
else:
raise ValueError("输入的字符串长度不足以截取中间四位")
else:
raise TypeError("输入类型错误，应为字符串")
def getApiTime(api_url):
pass
def send(uid,content):
r = requests.post('https://wxpusher.zjiecode.com/api/send/message',json={"appToken":apptoken,"content":content,"contentType":1,"uids":[uid]}).json()
return r
def userLoginNormal(phone,password):
try:
alphabet = 'abcdef0123456789'
uuid = [''.join(random.sample(alphabet, 8)),''.join(random.sample(alphabet, 4)),'4'+''.join(random.sample(alphabet, 3)),''.join(random.sample(alphabet, 4)),''.join(random.sample(alphabet, 12))]
timestamp=datetime.datetime.now().strftime("%Y%m%d%H%M%S")
loginAuthCipherAsymmertric = 'iPhone 14 15.4.' + uuid[0] + uuid[1] + phone + timestamp + password[:6] + '0$$$0.'
# 打印请求信息
print(f"\n开始登录请求 - 手机号: {get_first_three(phone)}")
r = ss.post('https://appgologin.189.cn:9031/login/client/userLoginNormal',
json={
"headerInfos": {
"code": "userLoginNormal",
"timestamp": timestamp,
"broadAccount": "",
"broadToken": "",
"clientType": "#9.6.1#channel50#iPhone 14 Pro Max#",
"shopId": "20002",
"source": "110003",
"sourcePassword": "Sid98s",
"token": "",
"userLoginName": phone
},
"content": {
"attach": "test",
"fieldData": {
"loginType": "4",
"accountType": "",
"loginAuthCipherAsymmertric": b64(loginAuthCipherAsymmertric),
"deviceUid": uuid[0] + uuid[1] + uuid[2],
"phoneNum": encode_phone(phone),
"isChinatelecom": "0",
"systemVersion": "15.4.0",
"authentication": password
}
}
},
verify=certifi.where()
).json()
# 打印响应信息
print(f"登录响应: {r}")
# 检查登录结果
if r.get('responseData', {}).get('resultCode') != '0000':
error_msg = r.get('responseData', {}).get('resultDesc', '未知错误')
print(f"登录失败 - 错误信息: {error_msg}")
return False
try:
l = r.get('responseData', {}).get('data', {}).get('loginSuccessResult')
except AttributeError:
print("登录响应格式异常")
l = None
if l:
load_token[phone] = l
with open(load_token_file, 'w') as f:
json.dump(load_token, f)
ticket = get_ticket(phone,l['userId'],l['token'])
return ticket
print(f"登录失败 - 无法获取登录成功结果")
return False
except Exception as e:
print(f"登录过程发生异常: {str(e)}")
return False
async def exchangeForDay(phone, session, runTime, rid, stime,ckvalue,jsexec):
async def delayed_conversion(delay):
await asyncio.sleep(delay)
await conversionRights(phone, rid,session,ckvalue,jsexec)
tasks = [asyncio.create_task(delayed_conversion(i * stime)) for i in range(int(runTime))]
await asyncio.gather(*tasks)
def get_ticket(phone,userId,token):
r = ss.post('https://appgologin.189.cn:9031/map/clientXML',data='getSingle'+datetime.datetime.now().strftime("%Y%m%d%H%M%S")+'#9.6.1#channel50#iPhone 14 Pro Max#20002110003Sid98s'+token+''+phone+'test'+encrypt(userId)+'4a6862274835b451',headers={'user-agent': 'CtClient;10.4.1;Android;13;22081212C;NTQzNzgx!#!MTgwNTg1'},verify=certifi.where())
tk = re.findall('(.*?)',r.text)
if len(tk) == 0:
return False
return decrypt(tk[0])
async def exchange2(session, phone, title, aid, jsexec):
printn(f"{str(datetime.datetime.now())[11:23]} {get_first_three(phone)}")
await asyncio.sleep(5) #测试网络延迟，弃用
return printn(f"{str(datetime.datetime.now())[11:23]} {get_first_three(phone)}")
async def getConversionRights(phone, aid):
pass
@retry(
stop=stop_after_attempt(1),
wait=wait_exponential(multiplier=1, min=4, max=10),
retry_error_callback=lambda retry_state: print(f"Retrying conversionRights, attempt {retry_state.attempt_number}")
)
async def conversionRights(phone, aid,SS,ckvalue,jsexec):
pass
def sync_before_sleep(retry_state, phone, SS, ticket):
pass
async def before_sleep(retry_state, phone, SS, ticket):
pass
@retry(
stop=stop_after_attempt(3),
wait=wait_exponential(multiplier=1, min=4, max=10),
retry=retry_if_exception_type((httpx.ReadTimeout, httpx.HTTPError, ZeroDivisionError)),
before_sleep=lambda retry_state: sync_before_sleep(retry_state, retry_state.args[0], retry_state.args[1], retry_state.args[2])
)
async def getLevelRightsList(phone, SS, jsexec, **kwargs):
pass
async def getSign(ticket,SS,ckvalue):
try:
response_data =await SS.get('https://wapside.189.cn:9001/jt-sign/ssoHomLogin?ticket=' + ticket,cookies=ckvalue)
response_data = response_data.json()
if response_data.get('resoultCode') == '0':
sign = response_data.get('sign')
return sign
else:
print(f"获取sign失败[{response_data.get('resoultCode')}]: {response_data}")
except Exception as e:
print(e)
return None
async def parse_cookies(ck,rsCK):
cookies = {}
for part in ck.split(';'):
part = part.strip()
if '=' in part:
key, value = part.split('=', 1)
if 'path' not in key and 'expires' not in key and 'Secure' not in key and 'SameSite' not in key:
cookies[key] = value
cookies["yiUIIlbdQT3fO"] = rsCK
return cookies
async def ascii_add_2(number_str):
transformed = ''.join(chr(ord(char) + 2) for char in number_str)
return transformed
all_results = []
async def dxTask(phone, ticket, phoneV):
global diffValue, ready_count
retry_count = 0
max_retries = 3
results = []
def format_message(msg):
"""格式化错误消息"""
if "省编码校验失败" in msg:
return "非本号省口令"
elif "券码已使用" in msg:
return "已使用"
return msg
while retry_count < max_retries:
try:
async with AsyncSessionManager() as s:
phone2V=await ascii_add_2(phone)
if 0== 0:
payload = {
"appType": "02",
"authCode": ticket,
"loginType": "1"
}
s.headers.update({
'Accept': "application/json, text/plain, */*",
'Cache-Control': "no-cache",
'appType': "02",
'userId': "",
'Content-Type': "application/json;charset=UTF-8",
'sessionKey': "",
'Origin': "https://wapact.189.cn:9001",
'Referer': "https://wapact.189.cn:9001/flcj1/",
})
response=await s.post('https://wapact.189.cn:9001/yzf1/dispatch/login', data=json.dumps(payload))
if response.status_code == 200:
print(f"账户:{get_first_three(phone)} 登录兑换任务成功")
login = response.json()
if login['success'] == True:
phone2V=await ascii_add_2(phone)
useridv=login["result"]["userId"]
sessionKey=login["result"]["sessionKey"]
if useridv:
for code in WELFARE_CODES:
print("开始兑换口令码:",code)
convertpayload = {
"userId": useridv,
"code": code,
"telephone": phone2V,
"isNewUser": "0"
}
s.headers.update({
'userId':useridv,
'sessionKey': sessionKey,
})
response=await s.post('https://wapact.189.cn:9001/yzf1/welfare/convert', data=json.dumps(convertpayload))
if response.status_code == 200:
convert=response.json()
if convert.get('success') == True:
results.append({
'phone': get_first_three(phone),
'code': code,
'status': '✓',
'message': '成功',
'time': datetime.datetime.now().strftime("%H:%M:%S")
})
else:
results.append({
'phone': get_first_three(phone),
'code': code,
'status': '✗',
'message': format_message(convert.get('errorMsg')),
'time': datetime.datetime.now().strftime("%H:%M:%S")
})
welfarelistUrl=f"https://wapact.189.cn:9001/yzf1/welfare/list?userId={useridv}&telephone={phone2V}"+"&state=0&size=100&page=0"#state=1所有完成的，state=0查看未完成
print("领取可能不及时到账,延迟5秒再去奖券查找可领取的奖品。")
await asyncio.sleep(5)
response=await s.get(welfarelistUrl)
if response.status_code == 200:
datavv=response.json()
if datavv.get('success') != True:
print("领取异常：",datavv)
return
if datavv.get('result') is not None and len(datavv['result']) > 0 and datavv['result'][0] is not None:
dataVVVVList=datavv['result']
for dataVVVV in dataVVVVList:
if dataVVVV['name'] is not None and '元' in dataVVVV['name']:
taskId = dataVVVV["id"]
print("开始领取", dataVVVV['name'])
verifypayload = {
"userId": useridv,
"id": taskId,
"telephone": phone2V,
"source": "1"
}
await asyncio.sleep(5)
try:
response = await s.post(
'https://wapact.189.cn:9001/yzf1/welfare/verify',
data=json.dumps(verifypayload)
)
if response.status_code == 200:
verify = response.json()
if verify.get('success') == True:
results.append({
'phone': get_first_three(phone),
'code': dataVVVV['name'],
'status': '✓',
'message': '成功',
'time': datetime.datetime.now().strftime("%H:%M:%S")
})
else:
results.append({
'phone': get_first_three(phone),
'code': dataVVVV['name'],
'status': '✗',
'message': format_message(verify.get('errorMsg')),
'time': datetime.datetime.now().strftime("%H:%M:%S")
})
except Exception as e:
print(f"验证请求失败: {str(e)}")
else:
print("奖券已无可领取奖品或延迟不到账稍后重试:", datavv)
else:
print("领取失败:", datavv)
break
except Exception as e:
retry_count += 1
if retry_count >= max_retries:
print(f"账号 {get_first_three(phone)} 达到最大重试次数，跳过")
break
print(f"账号 {get_first_three(phone)} 发生错误: {str(e)}, 第 {retry_count} 次重试")
await asyncio.sleep(5 * retry_count)
if results:
global all_results
all_results.extend(results)
async def get_session(session_pool):
return session_pool[random.randint(0, len(session_pool) - 1)]
async def xbkset_request(ss,url):
response=await ss.get(url)
if response.status_code == 200:
rsCK = re.findall('SESSION=([^;]+)',response.headers['Set-Cookie'])[0]
return response.json(), rsCK
else:
print("瑞数失败")
return response.json(),None
return response.json(), None
async def addVotingRecord(session,phone, ticket):
codeValue="ACTCODE20241212V8LHJF5Y"
restfulurl="https://wapact.189.cn:9001/mas-pub-web/spm/restful"
restfulurl+=f"?method=setRedisPagesJson&activityCode={codeValue}&pageId=&activityId=&phoneNum=&previewType=&subPageLinkCode=&isPreview="
session.headers.update({
'activityCode': codeValue,
'yxai': codeValue,
'ticket': ticket,
})
dataxb, SESSION = await xbkset_request(session, restfulurl)
url = "https://wapact.189.cn:9001/mas-pub-web/component/addVotingRecord"
payload = {
"groupId": 2067,
"contentId": "1b7b42c3a7824005bad832d3a2d925a5"
}
headers = {
'Host': "wapact.189.cn:9001",
'User-Agent': "CtClient;11.3.0;Android;12;Redmi K30 Pro;MDM3MzE2!#!MTMxODk",
'Accept': "application/json, text/plain, */*",
'Accept-Encoding': "gzip, deflate, br, zstd",
'Content-Type': "application/json",
'sec-ch-ua-platform': "\"Android\"",
'activityCode': "ACTCODE20241212V8LHJF5Y",
'sec-ch-ua': "\"Android WebView\";v=\"131\", \"Chromium\";v=\"131\", \"Not_A Brand\";v=\"24\"",
'sec-ch-ua-mobile': "?1",
'id': "",
'wyopenid': "",
'Content-Type': "application/json;charset=UTF-8",
'activityId': "",
'ticket': str(ticket),
'wyDataStr': "",
'masEnv': "android",
'yxai': "ACTCODE20241212V8LHJF5Y",
'wycorpId': "",
'Origin': "https://wapact.189.cn:9001",
'X-Requested-With': "com.ct.client",
'Sec-Fetch-Site': "same-origin",
'Sec-Fetch-Mode': "cors",
'Sec-Fetch-Dest': "empty",
'Accept-Language': "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7",
'Cookie': f'SESSION={SESSION}'
}
res=await session.post(url, data=json.dumps(payload), headers=headers)
if res.status_code == 200:
res = res.json()
if res.get("code") is not None:
if res.get("msg") is not None:
print("👍")
pass
time.sleep(3)
async def AI_Yun1(phone, ticket):
global diffValue, ready_count
timeout_config = httpx.Timeout(30.0, connect=60.0, read=60.0)
async with AsyncSessionManager( timeout=timeout_config) as session:
await addVotingRecord(session,phone, ticket)
await asyncio.sleep(0.1)
async def main(isTrue):
tasks = []
phone_list = PHONES.split('\n')
total_tasks = len(phone_list)
print(f"总任务数：{total_tasks}")
semaphore = asyncio.Semaphore(5)
async def wrapped_task(phone_info, ticket, phoneV):
async with semaphore:
currtime = datetime.datetime.now()
if currtime > datetime.datetime.strptime("2025-02-21 00:00:00", "%Y-%m-%d %H:%M:%S"):
pass
else:
await AI_Yun1(phone_info.split('#')[0], ticket) # 使用#分割后的手机号
await dxTask(phone_info.split('#')[0], ticket, phoneV) # 使用#分割后的手机号
for index, phoneV in enumerate(phone_list, start=1):
print(f"正在处理任务 {index}/{total_tasks}")
# 使用#分割手机号和密码
if '#' not in phoneV:
print('账号格式错误，应为: 手机号#服务密码')
continue
phone, password = phoneV.split('#')
if not phone.isdigit() or len(phone) != 11:
print(f'手机号格式错误: {phone}')
continue
if not password.isdigit() or len(password) != 6:
print(f'服务密码格式错误: {password}，应为6位数字')
continue
ticket = False
if phone in load_token:
print(f'\n{phone} 使用缓存登录')
ticket = get_ticket(phone, load_token[phone]['userId'], load_token[phone]['token'])
if not ticket:
print(f'\n{phone} 使用密码登录')
ticket = userLoginNormal(phone, password)
if ticket:
tasks.append(asyncio.create_task(wrapped_task(phoneV, ticket, load_token[phone])))
await asyncio.sleep(1)
else:
print(f'\n{phone} 登录失败')
try:
await asyncio.gather(*tasks, return_exceptions=True)
if all_results:
df = pd.DataFrame(all_results)
pd.set_option('display.max_colwidth', 30)
from tabulate import tabulate
stats_df = df.groupby('phone').agg({
'status': lambda x: f"成功:{len([s for s in x if s=='✓'])} 失败:{len([s for s in x if s=='✗'])}"
}).reset_index()
stats_df.columns = ['手机号', '统计结果']
print("\n执行结果:")
print(tabulate(df, headers='keys', tablefmt='grid', showindex=False))
print("\n统计结果:")
print(tabulate(stats_df, headers='keys', tablefmt='grid', showindex=False))
except Exception as e:
print(f"任务执行出错: {str(e)}")
WELFARE_CODE=os.environ.get('dx_kl') or "心有灵犀,绑定福利,事事如意,2025加油,草长莺飞,888,年末狂欢,年末回馈"
WELFARE_CODES = WELFARE_CODE.split(',')
# 处理账号字符串，移除空行并清理每行的空白字符
import os
# 尝试从环境变量中获取 chinaTelecomAccount
chinaTelecomAccount = os.environ.get('chinaTelecomAccount')
if not chinaTelecomAccount:
print("chinaTelecomAccount 未定义，使用默认值或退出程序")
chinaTelecomAccount = "1234567890\n9876543210\n1122334455" # 示例默认值
phone_list = [line.strip() for line in chinaTelecomAccount.split('\n') if line.strip()]
PHONES = os.environ.get('PHONES1') or '\n'.join(phone_list)
if __name__ == "__main__":
pd.set_option('display.max_columns', None)
pd.set_option('display.width', None)
pd.set_option('display.max_colwidth', None)
global timeValue, timeDiff
# print("开始等待场次时间:")
h = datetime.datetime.now().hour
# print("当前小时为: " + str(h))
random_m = random.randint(1, 59)
wttime = ttt(1, 59, 1)
if 1 + 1 == 12:
isTRUE = True
else:
isTRUE = False
if wttime > time.time():
wTime = wttime - time.time()
print("未到时间,计算后差异:" + str(wTime) + "秒")
if isTRUE:
time.sleep(wTime)
print("开始抢购")
asyncio.run(main(isTRUE))