mirror of
https://github.com/cc892786825/qiandao.git
synced 2025-12-18 07:44:47 +08:00
394 lines
14 KiB
Python
394 lines
14 KiB
Python
|
|
import requests
|
|
import re
|
|
import time
|
|
import json
|
|
import random
|
|
import datetime
|
|
import base64
|
|
import threading
|
|
import ssl
|
|
import os
|
|
import sys
|
|
import certifi
|
|
from bs4 import BeautifulSoup
|
|
|
|
from Crypto.PublicKey import RSA
|
|
from Crypto.Cipher import PKCS1_v1_5
|
|
from Crypto.Cipher import DES3
|
|
from Crypto.Util.Padding import pad, unpad
|
|
from Crypto.Cipher import AES
|
|
from http import cookiejar
|
|
from requests.adapters import HTTPAdapter
|
|
from requests.packages.urllib3.util.ssl_ import create_urllib3_context
|
|
|
|
|
|
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
|
|
|
|
|
|
ORIGIN_CIPHERS = ('DEFAULT@SECLEVEL=1')
|
|
|
|
ip_list = []
|
|
class DESAdapter(HTTPAdapter):
|
|
def __init__(self, *args, **kwargs):
|
|
CIPHERS = ORIGIN_CIPHERS.split(':')
|
|
random.shuffle(CIPHERS)
|
|
CIPHERS = ':'.join(CIPHERS)
|
|
self.CIPHERS = CIPHERS + ':!aNULL:!eNULL:!MD5'
|
|
super().__init__(*args, **kwargs)
|
|
|
|
def init_poolmanager(self, *args, **kwargs):
|
|
context = create_urllib3_context(ciphers=self.CIPHERS)
|
|
kwargs['ssl_context'] = context
|
|
return super(DESAdapter, self).init_poolmanager(*args, **kwargs)
|
|
|
|
def proxy_manager_for(self, *args, **kwargs):
|
|
context = create_urllib3_context(ciphers=self.CIPHERS)
|
|
kwargs['ssl_context'] = context
|
|
return super(DESAdapter, self).proxy_manager_for(*args, **kwargs)
|
|
|
|
|
|
requests.packages.urllib3.disable_warnings()
|
|
ssl_context = ssl.create_default_context()
|
|
ssl_context.check_hostname = False
|
|
ssl_context.verify_mode = ssl.CERT_NONE
|
|
ssl_context.set_ciphers('DEFAULT@SECLEVEL=0')
|
|
ss = requests.session()
|
|
ss.verify = certifi.where()
|
|
ss.ssl=ssl_context
|
|
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())
|
|
yc = 0.1
|
|
wt = 0
|
|
kswt = -3
|
|
yf = datetime.datetime.now().strftime("%Y%m")
|
|
|
|
|
|
jp = {"9":{},"12":{},"13":{},"23":{}}
|
|
|
|
|
|
try:
|
|
with open('电信金豆换话费.log') as fr:
|
|
dhjl = json.load(fr)
|
|
except:
|
|
dhjl = {}
|
|
if yf not in dhjl:
|
|
dhjl[yf] = {}
|
|
|
|
|
|
wxp={}
|
|
|
|
errcode = {
|
|
"0":"兑换成功",
|
|
"412":"兑换次数已达上限",
|
|
"413":"商品被抢光",
|
|
"420":"未知错误",
|
|
"429":"请求太频繁",
|
|
"999999":"未抢到",
|
|
"410":"活动已经结束",
|
|
"Y0001":"等级不够",
|
|
"Y0002":"需要使用翼相连网络才能兑换",
|
|
"Y0003":"需要共享流量才能兑换",
|
|
"Y0004":"需要更多共享流量",
|
|
"Y0005":"等级还不够",
|
|
"E0001":"网龄不足10年"
|
|
}
|
|
|
|
|
|
# 加密参数
|
|
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 t(h):
|
|
date = datetime.datetime.now()
|
|
date_zero = datetime.datetime.now().replace(year=date.year, month=date.month, day=date.day, hour=h, minute=59, second=59)
|
|
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_para(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 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 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):
|
|
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.'
|
|
login_date = {
|
|
"headerInfos": {
|
|
"code": "userLoginNormal",
|
|
"timestamp": timestamp,
|
|
"broadAccount": "",
|
|
"broadToken": "",
|
|
"clientType": "#10.5.0#channel50#iPhone 14 Pro Max#",
|
|
"shopId": "20002",
|
|
"source": "110003",
|
|
"sourcePassword": "Sid98s",
|
|
"token": "",
|
|
"userLoginName": encode_phone(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": encode_phone(password)
|
|
}
|
|
}
|
|
}
|
|
r = ss.post('https://appgologin.189.cn:9031/login/client/userLoginNormal', json=login_date).json()
|
|
|
|
l = r['responseData']['data']['loginSuccessResult']
|
|
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
|
|
return False
|
|
|
|
def get_ticket(phone,userId,token):
|
|
r = ss.post('https://appgologin.189.cn:9031/map/clientXML',data='<Request><HeaderInfos><Code>getSingle</Code><Timestamp>'+datetime.datetime.now().strftime("%Y%m%d%H%M%S")+'</Timestamp><BroadAccount></BroadAccount><BroadToken></BroadToken><ClientType>#9.6.1#channel50#iPhone 14 Pro Max#</ClientType><ShopId>20002</ShopId><Source>110003</Source><SourcePassword>Sid98s</SourcePassword><Token>'+token+'</Token><UserLoginName>'+phone+'</UserLoginName></HeaderInfos><Content><Attach>test</Attach><FieldData><TargetId>'+encrypt(userId)+'</TargetId><Url>4a6862274835b451</Url></FieldData></Content></Request>',headers={'user-agent': 'CtClient;10.4.1;Android;13;22081212C;NTQzNzgx!#!MTgwNTg1'})
|
|
|
|
tk = re.findall('<Ticket>(.*?)</Ticket>',r.text)
|
|
if len(tk) == 0:
|
|
return False
|
|
return decrypt(tk[0])
|
|
|
|
|
|
def queryInfo(phone,s):
|
|
a = 1
|
|
while a < 2:
|
|
r = s.get('https://wapact.189.cn:9001/gateway/golden/api/queryInfo',verify=certifi.where()).json()
|
|
try:
|
|
print(f'{phone} 金豆余额是 {r["biz"]["amountTotal"]} ')
|
|
amountTotal= r["biz"]["amountTotal"]
|
|
except:
|
|
amountTotal = 0
|
|
if amountTotal< 3000:
|
|
res = s.post('http://wapact.189.cn:9000/gateway/stand/detail/exchange',json={"activityId":jdaid}).text
|
|
print(res)
|
|
time.sleep(3)
|
|
else:
|
|
return r
|
|
a += 1
|
|
return r
|
|
|
|
|
|
def exchange(phone,s,title,aid, uid):
|
|
try:
|
|
r = s.post('https://wapact.189.cn:9001/gateway/standExchange/detailNew/exchange',json={"activityId":aid})
|
|
print(f"响应码: {r.status_code}{r.text} ")
|
|
|
|
r = r.json()
|
|
if r["code"] == 0:
|
|
if r["biz"] != {} and r["biz"]["resultCode"] in errcode:
|
|
print(f'{str(datetime.datetime.now())[11:22]} {phone} 的 {title} {errcode[r["biz"]["resultCode"]]}')
|
|
|
|
if r["biz"]["resultCode"] in ["0","412"]:
|
|
if r["biz"]["resultCode"] == "0":
|
|
msg = f'{phone}的{title}兑换成功'
|
|
send(uid, msg)
|
|
if phone not in dhjl[yf][title]:
|
|
dhjl[yf][title] += "#"+phone
|
|
with open('电信金豆换话费.log', 'w') as f:
|
|
json.dump(dhjl, f, ensure_ascii=False)
|
|
else:
|
|
print(f'{str(datetime.datetime.now())[11:22]} {phone} ：没抢到')
|
|
except Exception as e:
|
|
pass
|
|
|
|
|
|
def dh(phone,s,title,aid,wt, uid):
|
|
while wt > time.time():
|
|
pass
|
|
|
|
print(f"{str(datetime.datetime.now())[11:22]} {phone} 的 {title} 开始兑换")
|
|
for cs in range(cfcs):
|
|
threading.Thread(target=exchange,args=(phone,s,title,aid, uid)).start()
|
|
|
|
|
|
def lottery(s):
|
|
for cishu in range(3):
|
|
try:
|
|
r = s.post('https://wapact.189.cn:9001/gateway/golden/api/lottery',json={"activityId":"6384b49b1e44396da4f1e4a3"})
|
|
except:
|
|
pass
|
|
time.sleep(3)
|
|
|
|
def aes_ecb_encrypt(plaintext, key):
|
|
key = key.encode('utf-8')
|
|
if len(key) not in [16, 24, 32]:
|
|
raise ValueError("密钥长度必须为16/24/32字节")
|
|
padded_data = pad(plaintext.encode('utf-8'), AES.block_size)
|
|
cipher = AES.new(key, AES.MODE_ECB)
|
|
ciphertext = cipher.encrypt(padded_data)
|
|
return base64.b64encode(ciphertext).decode('utf-8')
|
|
|
|
def ks(phone, ticket, uid):
|
|
global wt
|
|
wxp[phone] = uid
|
|
s = requests.session()
|
|
s.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"}
|
|
s.cookies.set_policy(BlockAll())
|
|
s.mount('https://', DESAdapter())
|
|
s.timeout = 30
|
|
|
|
data = aes_ecb_encrypt(json.dumps({"ticket":ticket,"backUrl":"https%3A%2F%2Fwapact.189.cn%3A9001","platformCode":"P201010301","loginType":2}), 'telecom_wap_2018')
|
|
login = ss.post('https://wapact.189.cn:9001/unified/user/login',data=data, headers={"Content-Type":"application/json;charset=UTF-8","Accept":"application/json, text/javascript, */*; q=0.01"}).json()
|
|
|
|
if login['code'] == 0:
|
|
print(phone+" 获取token成功")
|
|
s.headers["Authorization"] = "Bearer " + login["biz"]["token"]
|
|
queryInfo(phone,s)
|
|
|
|
queryBigDataAppGetOrInfo = s.get('https://waphub.189.cn/gateway/golden/goldGoods/getGoodsList??floorType=0&userType=1&page&1&order=3&tabOrder=').json()
|
|
for i in queryBigDataAppGetOrInfo["biz"]["ExchangeGoodslist"]:
|
|
if '话费' not in i["title"]:continue
|
|
if '0.5元' in i["title"] or '5元' in i["title"]:
|
|
jp["9"][i["title"]] = i["id"]
|
|
elif '1元' in i["title"] or '10元' in i["title"]:
|
|
jp["13"][i["title"]] = i["id"]
|
|
else:
|
|
jp["12"][i["title"]] = i["id"]
|
|
|
|
h = datetime.datetime.now().hour
|
|
if 11 > h > 1:
|
|
h = 9
|
|
elif 23 > h > 1:
|
|
h = 13
|
|
else:
|
|
h = 23
|
|
if len(sys.argv) ==2:
|
|
h = int(sys.argv[1])
|
|
d = jp[str(h)]
|
|
wt = t(h) + kswt
|
|
if jp["12"] != {}:
|
|
d.update(jp["12"])
|
|
wt = 0
|
|
|
|
for di in d:
|
|
if di not in dhjl[yf]:
|
|
dhjl[yf][di] = ""
|
|
if phone in dhjl[yf][di] :
|
|
print(f"{phone} 的 {di} 已经兑换过")
|
|
else:
|
|
print(f"{phone} 的 {di} 准备好")
|
|
if wt - time.time() > 20 * 60:
|
|
print("等待时间超过20分钟")
|
|
return
|
|
threading.Thread(target=dh,args=(phone,s,di,d[di],wt, uid)).start()
|
|
else:
|
|
print(f"{phone} 获取token失败{login['message']}")
|
|
|
|
|
|
START_LOG = rf'''
|
|
|
|
'''
|
|
|
|
def main():
|
|
print(START_LOG)
|
|
global wt, rs
|
|
rs = 0 # 强制关闭瑞数加密
|
|
|
|
if os.environ.get('chinaTelecomAccount')!= None:
|
|
chinaTelecomAccount = os.environ.get('chinaTelecomAccount')
|
|
else:
|
|
chinaTelecomAccount = jdhf
|
|
|
|
for i in chinaTelecomAccount.split('&'):
|
|
i = i.split('#')
|
|
phone = i[0]
|
|
password = i[1]
|
|
uid = i[-1]
|
|
ticket = False
|
|
|
|
if phone in load_token:
|
|
print(f'{phone} 正在使用缓存登录')
|
|
ticket = get_ticket(phone,load_token[phone]['userId'],load_token[phone]['token'])
|
|
|
|
if ticket == False:
|
|
print(f'{phone} 正在使用密码登录')
|
|
ticket = userLoginNormal(phone,password)
|
|
|
|
if ticket:
|
|
threading.Thread(target=ks,args=(phone, ticket, uid)).start()
|
|
time.sleep(1)
|
|
else:
|
|
print(f'{phone} 登录失败')
|
|
|
|
# 手机号@密码@wxpusheruid
|
|
jdhf = ""
|
|
# 重发次数
|
|
cfcs = 15
|
|
# wxpusher推送appToken
|
|
appToken = ""
|
|
jdaid = '60dd79533dc03d3c76bdde30'
|
|
load_token_file = 'chinaTelecom_cache.json'
|
|
try:
|
|
with open(load_token_file, 'r') as f:
|
|
load_token = json.load(f)
|
|
except:
|
|
load_token = {}
|
|
main()
|
|
|
|
|