diff --git a/点点赚_api_1.0.py b/点点赚_api.py similarity index 93% rename from 点点赚_api_1.0.py rename to 点点赚_api.py index e8a9a68..9eaed80 100644 --- a/点点赚_api_1.0.py +++ b/点点赚_api.py @@ -1,496 +1,504 @@ -# --------------------------------注释区-------------------------------- -# 入口:https://168750027-1257141735.cos-website.ap-nanjing.myqcloud.com/index.html?pid=16345 -# -# -# 需抓取数据: -# * 填写自动过检的api接口 本地 内网ip:5000 非本地自行进行穿透 -# * 登录多少个账号就跑多少个账号 -# -# -# 抓取请求头中的user-agent填入yuanshen_useragent 无论多少个号都只填一个即可!!!! -# -# 变量名:yuanshen_api -# -# 填支付宝账号#姓名到 yuanshen_ddz_alipay 即可自动提现 -withdraw_points = 10000 #提现积分阈值 10000=1r -# --------------------------------祈求区-------------------------------- -# _ooOoo_ -# o8888888o -# 88" . "88 -# (| -_- |) -# O\ = /O -# ____/`---'\____ -# . ' \\| |// `. -# / \\||| : |||// \ -# / _||||| -:- |||||- \ -# | | \\\ - /// | | -# | \_| ''\---/'' | | -# \ .-\__ `-` ___/-. / -# ___`. .' /--.--\ `. . __ -# ."" '< `.___\_<|>_/___.' >'"". -# | | : `- \`.;`\ _ /`;.`/ - ` : | | -# \ \ `-. \_ __\ /__ _/ .-` / / -# ======`-.____`-.___\_____/___.-`____.-'====== -# `=---=' -# -# ............................................. -# 佛祖保佑 永无BUG -# 佛祖镇楼 BUG辟邪 -# --------------------------------代码区-------------------------------- - - -import requests -import time -import os -import json -import hashlib -import random -import re -import logging -import sys -import string -from base64 import b64encode -import base64 -import uuid -from urllib.parse import urlparse, parse_qs,quote -logging.basicConfig(level=logging.INFO, format='[%(levelname)s] ===> %(message)s') -code = "点点赚_api版" -ver = "1.0" -envname = "yuanshen_api" - -debug = False #debug模式 开启即从脚本内部获取环境变量 -debugcookie = "127.0.0.1:5000" #debug模式cookie - -is_bulletin = True #公告开关 -is_toulu = False #偷撸公告开关 -is_with_sleep = False #是否开启随机延时 - - -class env(): - """ - env模块,获取cookie并转成列表,统计时间,提示脚本开始结束,检测一些配置,try except异常处理 - :param args: 传递给env的参数 - :param kwargs: 传递给env的关键字参数 - :return: Null - - Powered by huaji - """ - def __init__(self, *args, **kwargs): - self.cookie = None - self.env_ver = '1.5' #版本号 - self.split_chars = ['@', '&', '\n'] #分隔符 - self.identifiers = ['Powered By Huaji', 'QQ Group:901898186', 'yuanshen'] #标识符 - def check_file(self): - file_path = __file__ - try: - - with open(file_path, 'r', encoding='utf-8') as file: - content = file.read() - - results = {} - - # 批量检查每个标识符 - for identifier in self.identifiers: - if identifier in content: - results[identifier] = True - else: - results[identifier] = False - logging.error(f"文件可能被恶意篡改,请勿修改文件内容") - - all_identifiers_present = all(results.values()) - if not all_identifiers_present: - logging.error(f"文件可能被恶意篡改,请勿修改文件内容") - self.force_exit() - - except Exception as e: - print(f"读取文件时发生错误: {e}") - self.force_exit() - - def split_cookies(self): - """根据多个分隔符分割cookie""" - for sep in self.split_chars: - if sep in self.cookie: - return self.cookie.split(sep) - return [self.cookie] - - def scmain(self): - apiurl = 'http://' + self.cookies[0] - r = requests.get(apiurl + '/getallwx').json() - for i, cookie in enumerate(r, 1): - print(f"--------开始第{i}个账号--------") - main = yuanshen(cookie,apiurl) - main.main() - print(f"--------第{i}个账号执行完毕--------") - - - - def force_exit(self,code=0): - exit() - print("Warning: 篡改你妈") - os._exit(code) # 强制退出程序 - sys.exit(code) # 正常退出 - import ctypes - while True: - ctypes.string_at(114514) - ctypes.string_at(1919810) - ctypes.string_at(666666) - print("Warning: 篡改你妈") - - - def run(self): - if not os.getenv(envname) and not debug: - logging.warning(f"请先设置环境变量[{envname}]") - self.force_exit() - - self.cookie = os.getenv(envname, "") - - if debug: - self.cookie = debugcookie - if is_bulletin: - try: - print(requests.get("https://gitee.com/HuaJiB/yuanshen34/raw/master/pubilc.txt").text, "\n\n\n") - except: - logging.error("网络异常,链接公告服务器失败(gitee)，请检查网络") - self.force_exit() - if is_toulu: - try: - txt = ''' -此为滑稽的偷撸本本 如你不在滑稽的小群却意外通过某种渠道获得了该脚本 -请联系QQ3487934983 提供证据后 你将代替泄露人员获得该群位置 -======================================================= - ''' - print(txt*5) - except: - self.force_exit() - if is_with_sleep: - random_time = random.randint(10,60) - logging.info(f"随机延时[{random_time}]秒") - time.sleep(random_time) - - self.cookies = self.split_cookies() - account_count = len(self.cookies) - logging.info(f"一共获取到{account_count}个账号") - print(f"=========🔔开始执行[{code}][{ver}]=========\n") - - - start_time = time.time() - if debug: - self.scmain() - else: - try: - self.scmain() - except Exception as e: - logging.error(f"脚本执行出错: {e}") - end_time = time.time() - - execution_time = end_time - start_time - - print(f"\n============🔔脚本[{code}]执行结束============") - print(f"本次脚本总运行时间: [{execution_time:.2f}] 秒") - self.force_exit() - - def main(self): - self.check_file() - self.run() - - def random_str(self,charset="all", length=8, to_upper=False,to_lower=False): - if charset == "all": #包含大小写字母和数字 - chars = string.ascii_letters + string.digits - elif charset == "letters": #大小写字母 - chars = string.ascii_letters - elif charset == "digits": - chars = string.digits - elif charset == "lowercase": #小写字母 - chars = string.ascii_lowercase - elif charset == "uuid": - return str(uuid.uuid4()) - elif charset == "uuid_str": - return str(uuid.uuid4()).replace("-", "") - elif charset != '' and charset is not None: - chars = charset - - - random_string = ''.join(random.choice(chars) for _ in range(length)) - - if to_upper: - return random_string.upper() - elif to_lower: - return random_string.lower() - else: - return random_string - - def aes_encrypt(self,data): - from Crypto.Cipher import AES - from Crypto.Util.Padding import pad, unpad - from binascii import hexlify, unhexlify - key = self.key.encode('utf-8') - iv = self.iv.encode('utf-8') - cipher = AES.new(key, AES.MODE_CBC, iv) - padded_plaintext = pad(data.encode('utf-8'), AES.block_size) - ciphertext = cipher.encrypt(padded_plaintext) - encrypted_base64 = b64encode(ciphertext).decode('utf-8') - - return encrypted_base64 - - - - -def retry_(max_retries=3, retry_delay=1): - def decorator(func): - def wrapper(*args, **kwargs): - retries = 0 - while retries < max_retries: - try: - return func(*args, **kwargs) - except requests.exceptions.RequestException as e: - retries += 1 - if retries < max_retries: - logging.info(f"发生错误:将在{retry_delay}秒后重试") - time.sleep(retry_delay) - else: - logging.info("已超过最大重试次数!") - raise - return wrapper - return decorator -class yuanshen: - def __init__(self,cookie,apiurl) -> None: - self.biz = ['MzA4MjQ5NDMwNg==','MzI2OTA0NzQ5OA==','MzU4OTQ3MDc0Mg=='] - self.apiurl = apiurl - self.Wxid = cookie['Wxid'] - self.bz = cookie['wxname'] - logging.info(f'[{self.bz}]开始运行') - - - def extract_url(self,url): - # 解析URL - parsed_url = urlparse(url) - full_domain = parsed_url.netloc - query_params = url.split('?')[1] - - - if not query_params: - query_params = None - - return full_domain, query_params - - def push(self): - url = f"{self.apiurl}/zdgjc" - data = {"url":self.acturl} - r = requests.post(url,json=data).json() - logging.info(f"遇到检测文章:推送结果[{r}]") - - @retry_(max_retries=3, retry_delay=1) - def getreadurl(self): - url = f"http://{self.baseurl}/index/mob/get_read_qr.html" - r = requests.get(url,headers=self.headers,cookies=self.cookie).json() - if r['code'] == 1: - url_pattern = r"http[s]?://[^\s]+" - urls = re.findall(url_pattern, r['web_url']) - self.domain,self.readcode = self.extract_url(urls[0]) - if urls: - logging.info(f"获取到阅读链接: [{self.domain}][{self.readcode}]") - self.readh = { - "Host": f"{self.domain}", - "Connection": "keep-alive", - "Content-Length": "47", - "Accept": "*/*", - "X-Requested-With": "XMLHttpRequest", - "User-Agent": ua, - "Content-Type": "application/x-www-form-urlencoded; charset=UTF-8", - "Origin": f"http://{self.domain}", - "Referer": f"http://{self.domain}/?{self.readcode}", - "Accept-Encoding": "gzip, deflate", - "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" -} - return True - else: - logging.warning("❌️未获取到阅读链接") - return False - else: - logging.warning(f"❌️未获取到阅读链接[{r}]") - return False - @retry_(max_retries=3, retry_delay=1) - def read(self): - url = f"http://{self.domain}/index/index/get_article.html" - url2 = f"http://{self.domain}/index/index/auth_record.html" - - while True: - data = { - 'code': self.readcode, - 'uid':self.uid - } - r = requests.post(url,headers=self.readh,data=data,timeout=10).json() - if r['code'] == 1: - self.acturl = r["data"]["info"]["link2"] - rid = int(r['data']['info']['rid']) - logging.info(f"获取文章成功: [{r['msg']}]") - if 'addtime' not in r['data']['info']: - logging.info("遇到检测文章 推送ing...") - self.push() - time.sleep(random.randint(18,28)) - else: - time.sleep(random.randint(9,18)) - else: - logging.warning(f"❌️获取文章失败: [{r}]") - break - - data = { - 'rid': rid, - 'time_is_gou':1 - } - r = requests.post(url2,headers=self.readh,data=data,timeout=10).json() - if r['code'] == 1: - logging.info(f"第[{r['txt']}]篇文章阅读成功") - else: - logging.warning(f"❌️阅读文章失败: [{r['msg']}]") - if '完成' in r['msg']: - url = f"http://{self.domain}/index/index/read_result.html" - data = { - 'code':self.readcode - } - r = requests.post(url,headers=self.readh,data=data,timeout=10).json() - if r['code'] == 1: - logging.info(f"🔔结束阅读成功: [{r['msg']}]") - else: - logging.warning(f"❌️结束阅读失败: [{r}]") - break - - time.sleep(random.randint(2,5)) - - def userinfo(self): - url = f'http://{self.baseurl}/index/mob/index.html' - r = requests.get(url,headers=self.headers2,cookies=self.cookie) - if r.status_code == 200: - match = re.search(r'(?<=可用积分：)\d+', r.text) - if match: - points = int(match.group()) - logging.info(f"🔔当前账号剩余积分:[{points}]=[{points/10000}]元💵") - else: - logging.warning("❌️没有获取到积分❌️") - if points > withdraw_points: - url = f'http://{self.baseurl}/index/mob/tixian.html' - r = requests.get(url,headers=self.headers2,cookies=self.cookie,allow_redirects= False) - loginurl = r.headers['Location'] - data = {'Wxid':self.Wxid,'url':loginurl} - url = requests.post(self.apiurl+'/loginbyweb2',json=data).json()['url'] - code = url.split('code=')[1].split('&')[0] - state = url.split('state=')[1] - logging.info(f"🔔获取提现链接成功: [{url}]") - url = f'http://{self.baseurl}/index/mob/fa_tx.html' - wi_po = int(str(points)[:-3] + '000') - wi_money = int(points/10000) - alipays = os.getenv('yuanshen_ddz_alipay') - if not alipays: - logging.warning('没有配置支付宝账号') - return - alipays = alipays.split('#') - data = { - "code": code, - "money": wi_money, - "kou_credit": wi_po, - "tx_type": "2", - "ali_name":alipays[1], - "ali_account": alipays[0] -} - r = requests.post(url,headers=self.headers2,data=data,cookies=self.cookie).json() - logging.info(f'提现结果[{r}]') - else: - logging.info('不提现') - - - def login(self): - - url = 'http://sx.shuxiangby.cn/index/mob/index?cos=1&pid=16345' - h = { - "Host": "sx.shuxiangby.cn", - "Connection": "keep-alive", - "Upgrade-Insecure-Requests": "1", - "User-Agent": "Mozilla/5.0 (Linux; Android 14; 23113RKC6C Build/UKQ1.230804.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/130.0.6723.73 Mobile Safari/537.36 XWEB/1300057 MMWEBSDK/20240301 MMWEBID/98 MicroMessenger/8.0.48.2580(0x28003035) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64", - "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/wxpic,image/tpg,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7", - "X-Requested-With": "com.tencent.mm", - "Accept-Encoding": "gzip, deflate", - "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7", -} - r = requests.get(url,headers=h,allow_redirects= False) - loginurl = r.headers['Location'] - data = {'Wxid':self.Wxid,'url':loginurl} - url = requests.post(self.apiurl+'/loginbyweb',json=data).json()['url']#http://sx.shuxiangby.cn/index/mob/auth2.html?cos=1&pid=16345&code=011NZQ1w3OGAO33Ac44w3MxDwL2NZQ1S&state=STATE - print(url) - r = requests.get(url,headers=h,allow_redirects= False) - loginurl = r.headers['Location']#http://41521229395.auth.dianqu33.cn/index/mob/auth.html?cos=1&pid=16345&code=011NZQ1w3OGAO33Ac44w3MxDwL2NZQ1S&state=STATE - print(loginurl) - domain = urlparse(loginurl).netloc - h = { - "Host": domain, - "Connection": "keep-alive", - "Upgrade-Insecure-Requests": "1", - "User-Agent": "Mozilla/5.0 (Linux; Android 14; 23113RKC6C Build/UKQ1.230804.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/130.0.6723.73 Mobile Safari/537.36 XWEB/1300057 MMWEBSDK/20240301 MMWEBID/98 MicroMessenger/8.0.48.2580(0x28003035) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64", - "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/wxpic,image/tpg,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7", - "X-Requested-With": "com.tencent.mm", - "Accept-Encoding": "gzip, deflate", - "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" -} - r = requests.get(loginurl,headers=h,allow_redirects= False) - self.cookie = r.headers['Set-Cookie'] - self.baseurl = f'{random_11_digits()}.sx.shuxiangby.cn' - self.uid = self.cookie.split('uid=')[1].split(';')[0] - user_openid = self.cookie.split('user_openid=')[1].split(';')[0] - PHPSESSID = self.cookie.split('PHPSESSID=')[1].split(';')[0] - self.cookie = {'uid':self.uid,'user_openid':user_openid,'PHPSESSID':PHPSESSID} - logging.info('登录成功') - self.headers = { - "Host": self.baseurl, - "Connection": "keep-alive", - "Accept": "*/*", - "User-Agent": ua, - "X-Requested-With": "XMLHttpRequest", - "Referer": f"http://{self.baseurl}/index/mob/index.html", - "Accept-Encoding": "gzip, deflate", - "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" -} - - self.headers2 = { - "Host": self.baseurl, - "Connection": "keep-alive", - "Upgrade-Insecure-Requests": "1", - "User-Agent": ua, - "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/wxpic,image/tpg,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7", - "X-Requested-With": "com.tencent.mm", - "Referer": f"http://{self.baseurl}/index/mob/mine.html", - "Accept-Encoding": "gzip, deflate", - "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" -} - - - - - - def main(self): - self.login() - if self.getreadurl(): - print("="*30) - time.sleep(random.randint(3,5)) - self.read() - time.sleep(random.randint(3,5)) - print("="*30) - self.userinfo() - - - - -def random_11_digits(): - first_digit = random.randint(1, 9) - num = str(first_digit) - for i in range(10): - num += str(random.randint(0, 9)) - return num - - -if __name__ == '__main__': - ua = os.getenv('yuanshen_useragent') - #ua = 'Mozilla/5.0 (Linux; Android 14; 23113RKC6C Build/UKQ1.230804.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/126.0.6478.188 Mobile Safari/537.36 XWEB/1260117 MMWEBSDK/20240301 MMWEBID/4020 MicroMessenger/8.0.48.2580(0x28003035) WeChat/arm64 Weixin Android Tablet NetType/WIFI Language/zh_CN ABI/arm64' - if not ua: - logging.info("❌你还没有设置user_agent,请设置环境变量:yuanshen_useragent") - exit() - +# --------------------------------注释区-------------------------------- +# 入口:https://168750027-1257141735.cos-website.ap-nanjing.myqcloud.com/index.html?pid=16345 +# +# +# 需抓取数据: +# * 填写自动过检的api接口 本地 内网ip:5000 非本地自行进行穿透 +# * 登录多少个账号就跑多少个账号 +# +# +# 抓取请求头中的user-agent填入yuanshen_useragent 无论多少个号都只填一个即可!!!! +# +# 变量名:yuanshen_api +# +# 填支付宝账号#姓名到 yuanshen_ddz_alipay 即可自动提现 +withdraw_points = 10000 #提现积分阈值 10000=1r +# --------------------------------祈求区-------------------------------- +# _ooOoo_ +# o8888888o +# 88" . "88 +# (| -_- |) +# O\ = /O +# ____/`---'\____ +# . ' \\| |// `. +# / \\||| : |||// \ +# / _||||| -:- |||||- \ +# | | \\\ - /// | | +# | \_| ''\---/'' | | +# \ .-\__ `-` ___/-. / +# ___`. .' /--.--\ `. . __ +# ."" '< `.___\_<|>_/___.' >'"". +# | | : `- \`.;`\ _ /`;.`/ - ` : | | +# \ \ `-. \_ __\ /__ _/ .-` / / +# ======`-.____`-.___\_____/___.-`____.-'====== +# `=---=' +# +# ............................................. +# 佛祖保佑 永无BUG +# 佛祖镇楼 BUG辟邪 +# --------------------------------代码区-------------------------------- + + +import requests +import time +import os +import json +import hashlib +import random +import re +import logging +import sys +import string +from base64 import b64encode +import base64 +import uuid +from urllib.parse import urlparse, parse_qs,quote +logging.basicConfig(level=logging.INFO, format='[%(levelname)s] ===> %(message)s') +code = "点点赚_api版" +ver = "1.1" +envname = "yuanshen_api" + +debug = False #debug模式 开启即从脚本内部获取环境变量 +debugcookie = "127.0.0.1:5000" #debug模式cookie + +is_bulletin = True #公告开关 +is_toulu = False #偷撸公告开关 +is_with_sleep = False #是否开启随机延时 + + +class env(): + """ + env模块,获取cookie并转成列表,统计时间,提示脚本开始结束,检测一些配置,try except异常处理 + :param args: 传递给env的参数 + :param kwargs: 传递给env的关键字参数 + :return: Null + + Powered by huaji + """ + def __init__(self, *args, **kwargs): + self.cookie = None + self.env_ver = '1.5' #版本号 + self.split_chars = ['@', '&', '\n'] #分隔符 + self.identifiers = ['Powered By Huaji', 'QQ Group:901898186', 'yuanshen'] #标识符 + def check_file(self): + file_path = __file__ + try: + + with open(file_path, 'r', encoding='utf-8') as file: + content = file.read() + + results = {} + + # 批量检查每个标识符 + for identifier in self.identifiers: + if identifier in content: + results[identifier] = True + else: + results[identifier] = False + logging.error(f"文件可能被恶意篡改,请勿修改文件内容") + + all_identifiers_present = all(results.values()) + if not all_identifiers_present: + logging.error(f"文件可能被恶意篡改,请勿修改文件内容") + self.force_exit() + + except Exception as e: + print(f"读取文件时发生错误: {e}") + self.force_exit() + + def split_cookies(self): + """根据多个分隔符分割cookie""" + for sep in self.split_chars: + if sep in self.cookie: + return self.cookie.split(sep) + return [self.cookie] + + def scmain(self): + apiurl = 'http://' + self.cookies[0] + r = requests.get(apiurl + '/getallwx').json() + for i, cookie in enumerate(r, 1): + print(f"--------开始第{i}个账号--------") + main = yuanshen(cookie,apiurl) + main.main() + print(f"--------第{i}个账号执行完毕--------") + + + + def force_exit(self,code=0): + exit() + print("Warning: 篡改你妈") + os._exit(code) # 强制退出程序 + sys.exit(code) # 正常退出 + import ctypes + while True: + ctypes.string_at(114514) + ctypes.string_at(1919810) + ctypes.string_at(666666) + print("Warning: 篡改你妈") + + + def run(self): + if not os.getenv(envname) and not debug: + logging.warning(f"请先设置环境变量[{envname}]") + self.force_exit() + + self.cookie = os.getenv(envname, "") + + if debug: + self.cookie = debugcookie + if is_bulletin: + try: + print(requests.get("https://gitee.com/HuaJiB/yuanshen34/raw/master/pubilc.txt").text, "\n\n\n") + except: + logging.error("网络异常,链接公告服务器失败(gitee)，请检查网络") + self.force_exit() + if is_toulu: + try: + txt = ''' +此为滑稽的偷撸本本 如你不在滑稽的小群却意外通过某种渠道获得了该脚本 +请联系QQ3487934983 提供证据后 你将代替泄露人员获得该群位置 +======================================================= + ''' + print(txt*5) + except: + self.force_exit() + if is_with_sleep: + random_time = random.randint(10,60) + logging.info(f"随机延时[{random_time}]秒") + time.sleep(random_time) + + self.cookies = self.split_cookies() + account_count = len(self.cookies) + logging.info(f"一共获取到{account_count}个账号") + print(f"=========🔔开始执行[{code}][{ver}]=========\n") + + + start_time = time.time() + if debug: + self.scmain() + else: + try: + self.scmain() + except Exception as e: + logging.error(f"脚本执行出错: {e}") + end_time = time.time() + + execution_time = end_time - start_time + + print(f"\n============🔔脚本[{code}]执行结束============") + print(f"本次脚本总运行时间: [{execution_time:.2f}] 秒") + self.force_exit() + + def main(self): + self.check_file() + self.run() + + def random_str(self,charset="all", length=8, to_upper=False,to_lower=False): + if charset == "all": #包含大小写字母和数字 + chars = string.ascii_letters + string.digits + elif charset == "letters": #大小写字母 + chars = string.ascii_letters + elif charset == "digits": + chars = string.digits + elif charset == "lowercase": #小写字母 + chars = string.ascii_lowercase + elif charset == "uuid": + return str(uuid.uuid4()) + elif charset == "uuid_str": + return str(uuid.uuid4()).replace("-", "") + elif charset != '' and charset is not None: + chars = charset + + + random_string = ''.join(random.choice(chars) for _ in range(length)) + + if to_upper: + return random_string.upper() + elif to_lower: + return random_string.lower() + else: + return random_string + + def aes_encrypt(self,data): + from Crypto.Cipher import AES + from Crypto.Util.Padding import pad, unpad + from binascii import hexlify, unhexlify + key = self.key.encode('utf-8') + iv = self.iv.encode('utf-8') + cipher = AES.new(key, AES.MODE_CBC, iv) + padded_plaintext = pad(data.encode('utf-8'), AES.block_size) + ciphertext = cipher.encrypt(padded_plaintext) + encrypted_base64 = b64encode(ciphertext).decode('utf-8') + + return encrypted_base64 + +from functools import wraps + + +def retry(exceptions = Exception, tries=5, delay=2, backoff=2): + """ + 简单的重试 module，如果重试失败则抛出错误。 + """ + def decorator(func): + @wraps(func) + def wrapper(*args, **kwargs): + # 每次调用时初始化独立的重试计数和延迟时间 + _tries, _delay = tries, delay + while _tries > 1: + try: + return func(*args, **kwargs) + except exceptions as e: + print(f"发生错误:[{e}], Retrying in {_delay} seconds ...") + time.sleep(_delay) + _tries -= 1 + _delay *= backoff + # 最后一次尝试 + return func(*args, **kwargs) + return wrapper + return decorator + +class yuanshen: + def __init__(self,cookie,apiurl) -> None: + self.biz = ['MzA4MjQ5NDMwNg==','MzI2OTA0NzQ5OA==','MzU4OTQ3MDc0Mg=='] + self.apiurl = apiurl + self.Wxid = cookie['Wxid'] + self.bz = cookie['wxname'] + logging.info(f'[{self.bz}]开始运行') + + + def extract_url(self,url): + # 解析URL + parsed_url = urlparse(url) + full_domain = parsed_url.netloc + query_params = url.split('?')[1] + + + if not query_params: + query_params = None + + return full_domain, query_params + + def push(self): + url = f"{self.apiurl}/zdgjc" + data = {"url":self.acturl} + r = requests.post(url,json=data).json() + logging.info(f"遇到检测文章:推送结果[{r}]") + + @retry() + def getreadurl(self): + url = f"http://{self.baseurl}/index/mob/get_read_qr.html" + r = requests.get(url,headers=self.headers,cookies=self.cookie).json() + if r['code'] == 1: + url_pattern = r"http[s]?://[^\s]+" + urls = re.findall(url_pattern, r['web_url']) + self.domain,self.readcode = self.extract_url(urls[0]) + if urls: + logging.info(f"获取到阅读链接: [{self.domain}][{self.readcode}]") + self.readh = { + "Host": f"{self.domain}", + "Connection": "keep-alive", + "Content-Length": "47", + "Accept": "*/*", + "X-Requested-With": "XMLHttpRequest", + "User-Agent": ua, + "Content-Type": "application/x-www-form-urlencoded; charset=UTF-8", + "Origin": f"http://{self.domain}", + "Referer": f"http://{self.domain}/?{self.readcode}", + "Accept-Encoding": "gzip, deflate", + "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" +} + return True + else: + logging.warning("❌️未获取到阅读链接") + return False + else: + logging.warning(f"❌️未获取到阅读链接[{r}]") + return False + @retry() + def read(self): + url = f"http://{self.domain}/index/index/get_article.html" + url2 = f"http://{self.domain}/index/index/auth_record.html" + + while True: + data = { + 'code': self.readcode, + 'uid':self.uid + } + r = requests.post(url,headers=self.readh,data=data,timeout=10).json() + if r['code'] == 1: + self.acturl = r["data"]["info"]["link2"] + rid = int(r['data']['info']['rid']) + logging.info(f"获取文章成功: [{r['msg']}]") + if 'addtime' not in r['data']['info']: + logging.info("遇到检测文章 推送ing...") + self.push() + time.sleep(random.randint(18,28)) + else: + time.sleep(random.randint(9,18)) + else: + logging.warning(f"❌️获取文章失败: [{r}]") + break + + data = { + 'rid': rid, + 'time_is_gou':1 + } + r = requests.post(url2,headers=self.readh,data=data,timeout=10).json() + if r['code'] == 1: + logging.info(f"第[{r['txt']}]篇文章阅读成功") + else: + logging.warning(f"❌️阅读文章失败: [{r['msg']}]") + if '完成' in r['msg']: + url = f"http://{self.domain}/index/index/read_result.html" + data = { + 'code':self.readcode + } + r = requests.post(url,headers=self.readh,data=data,timeout=10).json() + if r['code'] == 1: + logging.info(f"🔔结束阅读成功: [{r['msg']}]") + else: + logging.warning(f"❌️结束阅读失败: [{r}]") + break + + time.sleep(random.randint(2,5)) + + def userinfo(self): + url = f'http://{self.baseurl}/index/mob/index.html' + r = requests.get(url,headers=self.headers2,cookies=self.cookie) + if r.status_code == 200: + match = re.search(r'(?<=可用积分：)\d+', r.text) + if match: + points = int(match.group()) + logging.info(f"🔔当前账号剩余积分:[{points}]=[{points/10000}]元💵") + else: + logging.warning("❌️没有获取到积分❌️") + if points > withdraw_points: + url = f'http://{self.baseurl}/index/mob/tixian.html' + r = requests.get(url,headers=self.headers2,cookies=self.cookie,allow_redirects= False) + loginurl = r.headers['Location'] + data = {'Wxid':self.Wxid,'url':loginurl} + url = requests.post(self.apiurl+'/loginbyweb2',json=data).json()['url'] + code = url.split('code=')[1].split('&')[0] + state = url.split('state=')[1] + logging.info(f"🔔获取提现链接成功: [{url}]") + url = f'http://{self.baseurl}/index/mob/fa_tx.html' + wi_po = int(str(points)[:-3] + '000') + wi_money = int(points/10000) + alipays = os.getenv('yuanshen_ddz_alipay') + if not alipays: + logging.warning('没有配置支付宝账号') + return + alipays = alipays.split('#') + data = { + "code": code, + "money": wi_money, + "kou_credit": wi_po, + "tx_type": "2", + "ali_name":alipays[1], + "ali_account": alipays[0] +} + r = requests.post(url,headers=self.headers2,data=data,cookies=self.cookie).json() + logging.info(f'提现结果[{r}]') + else: + logging.info('不提现') + + + def login(self): + + url = 'http://sx.shuxiangby.cn/index/mob/index?cos=1&pid=16345' + h = { + "Host": "sx.shuxiangby.cn", + "Connection": "keep-alive", + "Upgrade-Insecure-Requests": "1", + "User-Agent": "Mozilla/5.0 (Linux; Android 14; 23113RKC6C Build/UKQ1.230804.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/130.0.6723.73 Mobile Safari/537.36 XWEB/1300057 MMWEBSDK/20240301 MMWEBID/98 MicroMessenger/8.0.48.2580(0x28003035) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64", + "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/wxpic,image/tpg,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7", + "X-Requested-With": "com.tencent.mm", + "Accept-Encoding": "gzip, deflate", + "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7", +} + r = requests.get(url,headers=h,allow_redirects= False) + loginurl = r.headers['Location'] + data = {'Wxid':self.Wxid,'url':loginurl} + url = requests.post(self.apiurl+'/loginbyweb',json=data).json()['url']#http://sx.shuxiangby.cn/index/mob/auth2.html?cos=1&pid=16345&code=011NZQ1w3OGAO33Ac44w3MxDwL2NZQ1S&state=STATE + print(url) + r = requests.get(url,headers=h,allow_redirects= False) + loginurl = r.headers['Location']#http://41521229395.auth.dianqu33.cn/index/mob/auth.html?cos=1&pid=16345&code=011NZQ1w3OGAO33Ac44w3MxDwL2NZQ1S&state=STATE + print(loginurl) + domain = urlparse(loginurl).netloc + h = { + "Host": domain, + "Connection": "keep-alive", + "Upgrade-Insecure-Requests": "1", + "User-Agent": "Mozilla/5.0 (Linux; Android 14; 23113RKC6C Build/UKQ1.230804.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/130.0.6723.73 Mobile Safari/537.36 XWEB/1300057 MMWEBSDK/20240301 MMWEBID/98 MicroMessenger/8.0.48.2580(0x28003035) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64", + "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/wxpic,image/tpg,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7", + "X-Requested-With": "com.tencent.mm", + "Accept-Encoding": "gzip, deflate", + "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" +} + r = requests.get(loginurl,headers=h,allow_redirects= False) + self.cookie = r.headers['Set-Cookie'] + self.baseurl = f'{random_11_digits()}.sx.shuxiangby.cn' + self.uid = self.cookie.split('uid=')[1].split(';')[0] + user_openid = self.cookie.split('user_openid=')[1].split(';')[0] + PHPSESSID = self.cookie.split('PHPSESSID=')[1].split(';')[0] + self.cookie = {'uid':self.uid,'user_openid':user_openid,'PHPSESSID':PHPSESSID} + logging.info('登录成功') + self.headers = { + "Host": self.baseurl, + "Connection": "keep-alive", + "Accept": "*/*", + "User-Agent": ua, + "X-Requested-With": "XMLHttpRequest", + "Referer": f"http://{self.baseurl}/index/mob/index.html", + "Accept-Encoding": "gzip, deflate", + "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" +} + + self.headers2 = { + "Host": self.baseurl, + "Connection": "keep-alive", + "Upgrade-Insecure-Requests": "1", + "User-Agent": ua, + "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/wxpic,image/tpg,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7", + "X-Requested-With": "com.tencent.mm", + "Referer": f"http://{self.baseurl}/index/mob/mine.html", + "Accept-Encoding": "gzip, deflate", + "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" +} + + + + + + def main(self): + try: + self.login() + if self.getreadurl(): + print("="*30) + time.sleep(random.randint(3,5)) + self.read() + time.sleep(random.randint(3,5)) + print("="*30) + self.userinfo() + except Exception as e: + logging.error(f'发生错误：{e}') + + + + +def random_11_digits(): + first_digit = random.randint(1, 9) + num = str(first_digit) + for i in range(10): + num += str(random.randint(0, 9)) + return num + + +if __name__ == '__main__': + ua = os.getenv('yuanshen_useragent') + #ua = 'Mozilla/5.0 (Linux; Android 14; 23113RKC6C Build/UKQ1.230804.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/126.0.6478.188 Mobile Safari/537.36 XWEB/1260117 MMWEBSDK/20240301 MMWEBID/4020 MicroMessenger/8.0.48.2580(0x28003035) WeChat/arm64 Weixin Android Tablet NetType/WIFI Language/zh_CN ABI/arm64' + if not ua: + logging.info("❌你还没有设置user_agent,请设置环境变量:yuanshen_useragent") + exit() + env().main() \ No newline at end of file