# --------------------------------注释区-------------------------------- # 入口:http://ghpuy2w5.imedq.cn?mid=1786918&r=6uv9umK5&e=1731916630 # # 需抓取数据: # * 填写穿透出来的api接口 # # 抓取请求头中的user-agent填入yuanshen_useragent 无论多少个号都只填一个即可!!!! # # 变量名:yuanshen_api # qj = True #23-26篇强制推送 开启True 关闭False # 如需自动提现 填写wxpusher的apptoken到 yuanshen_apptoken # 使用接受推送的微信号关注你自己的主题填写uid到 yuanshen_wxpusheruid # uid 可以在wxpusher微信公众号 下方我的-我的uid找到 # 不需可不填 # # !!!!因自己填写错误导致口令被盗或丢失一概不负责!!! # !!!!因自己填写错误导致口令被盗或丢失一概不负责!!! # !!!!因自己填写错误导致口令被盗或丢失一概不负责!!! # !!!!因自己填写错误导致口令被盗或丢失一概不负责!!! # !!!!因自己填写错误导致口令被盗或丢失一概不负责!!! # --------------------------------祈求区-------------------------------- # _ooOoo_ # o8888888o # 88" . "88 # (| -_- |) # O\ = /O # ____/`---'\____ # . ' \\| |// `. # / \\||| : |||// \ # / _||||| -:- |||||- \ # | | \\\ - /// | | # | \_| ''\---/'' | | # \ .-\__ `-` ___/-. / # ___`. .' /--.--\ `. . __ # ."" '< `.___\_<|>_/___.' >'"". # | | : `- \`.;`\ _ /`;.`/ - ` : | | # \ \ `-. \_ __\ /__ _/ .-` / / # ======`-.____`-.___\_____/___.-`____.-'====== # `=---=' # # ............................................. # 佛祖保佑 永无BUG # 佛祖镇楼 BUG辟邪 # --------------------------------代码区-------------------------------- from functools import wraps import requests import time import os import json import hashlib import random import logging from urllib.parse import urlparse, parse_qs,quote,unquote import sys import string from base64 import b64encode import uuid from datetime import datetime,timedelta import re from notify import send logging.basicConfig(level=logging.INFO, format='[%(levelname)s] ===> %(message)s') code = "叮叮联盟_api版" ver = "1.9" envname = "yuanshen_api" msg = "" debug = False #debug模式 开启即从脚本内部获取环境变量 debugcookie = "127.0.0.1:5000" #debug模式cookie is_bulletin = False #公告开关 is_toulu = False #偷撸公告开关 is_with_sleep = False #是否开启随机延时 def get_sm(): global bizlist try: url = "https://api.huaji.asia/read_api/biz_ddlm.txt" r = requests.get(url) if r.status_code == 200: logging.info(f"联网获取检测文章列表成功") bizlist = r.text.split(",") else: logging.error("联网获取检测文章列表失败！") bizlist = [] except: logging.error("联网获取检测文章列表失败！") bizlist = [] 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 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): get_sm() 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}] 秒") send(f"运行脚本：{code}", f"{msg}") 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 class yuanshen: def __init__(self,cookie,apiurl) -> None: self.apiurl = apiurl self.Wxid = cookie['Wxid'] self.bz = cookie['wxname'] logging.info(f'[{self.bz}]开始运行') def get_f(self): if os.path.exists(f'ddlm.json'): j = json.load(open('ddlm.json','r')) for i in j: if i['Wxid'] == self.Wxid: return i['f'] return None else: return None def login(self): f = self.get_f() if not f: f = env().random_str(charset='1234567abcdef',length=32, to_lower=True) if os.path.exists('ddlm.json'): with open('ddlm.json', 'r', encoding='utf-8') as file: d = json.load(file) else: d = [] d.append({'Wxid': self.Wxid, 'f': f}) with open('ddlm.json', 'w', encoding='utf-8') as file: json.dump(d, file, indent=4) headers = { "Host": "api.jiudingliliang.com", "Connection": "keep-alive", "Content-Length": "28", "F-RTYFGHVBN": "", "Authorization": "Bearer", "sec-ch-ua-platform": "\"Android\"", "sec-ch-ua": "\"Chromium\";v=\"130\", \"Android WebView\";v=\"130\", \"Not?A_Brand\";v=\"99\"", "sec-ch-ua-mobile": "?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/4020 MicroMessenger/8.0.48.2580(0x28003035) WeChat/arm64 Weixin Android Tablet NetType/WIFI Language/zh_CN ABI/arm64", "X-NIUBILITY-Y": "", "Content-Type": "application/json", "Accept": "*/*", "Origin": "http://9henipq.ewr919.top", "X-Requested-With": "com.tencent.mm", "Sec-Fetch-Site": "cross-site", "Sec-Fetch-Mode": "cors", "Sec-Fetch-Dest": "empty", "Referer": "http://9henipq.ewr919.top/", "Accept-Encoding": "gzip, deflate, br, zstd", "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" } url = 'https://api.jiudingliliang.com/login/get-auth-url' data = {"route":"","mid":"1786918"} r = requests.post(url,json=data,headers=headers).json() if r['code'] == 10000: url = r['result']['url'] data = {'Wxid':self.Wxid,'url':url} url = requests.post(self.apiurl+'/loginbyweb',json=data).json()['url'] #print(url) h = { "sec-ch-ua": "\"Chromium\";v=\"130\", \"Android WebView\";v=\"130\", \"Not?A_Brand\";v=\"99\"", "sec-ch-ua-mobile": "?1", "sec-ch-ua-platform": "\"Android\"", "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", "sec-fetch-site": "none", "sec-fetch-mode": "navigate", "sec-fetch-user": "?1", "sec-fetch-dest": "document", "accept-encoding": "gzip, deflate, br, zstd", "accept-language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7", "priority": "u=0, i" } r = requests.get(url,headers=h,allow_redirects=False) #print(r.headers) token = r.headers['Location'].split('token=')[1] domain = urlparse(r.headers['Location']).netloc h = { 'User-Agent': ua, # 'Accept-Encoding': 'gzip, deflate, br, zstd', 'Content-Type': 'application/json', 'F-RTYFGHVBN':'', 'Authorization': f'Bearer {token}', 'sec-ch-ua-platform': '"Android"', 'sec-ch-ua': '"Chromium";v="130", "Android WebView";v="130", "Not?A_Brand";v="99"', 'sec-ch-ua-mobile': '?1', 'Origin': f'http://{domain}', 'X-Requested-With': 'com.tencent.mm', 'Sec-Fetch-Site': 'cross-site', 'Sec-Fetch-Mode': 'cors', 'Sec-Fetch-Dest': 'empty', 'Referer': f'http://{domain}/', 'Accept-Language': 'zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7', } r = requests.post('https://api.jiudingliliang.com/domain/use',headers=h).json() print(r) data = { 'scene': 'INDEX', } url = 'https://api.jiudingliliang.com/domain/pool' r = requests.post(url,json=data,headers=h).json() doamin2 = r["result"]["host"] self.h = { '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/4020 MicroMessenger/8.0.48.2580(0x28003035) WeChat/arm64 Weixin Android Tablet NetType/WIFI Language/zh_CN ABI/arm64', 'F-RTYFGHVBN': f, 'Authorization': f'Bearer {token}', 'sec-ch-ua-platform': '"Android"', 'sec-ch-ua': '"Chromium";v="130", "Android WebView";v="130", "Not?A_Brand";v="99"', 'sec-ch-ua-mobile': '?1', 'Origin': f'{doamin2}', 'X-Requested-With': 'com.tencent.mm', 'Sec-Fetch-Site': 'cross-site', 'Sec-Fetch-Mode': 'cors', 'Sec-Fetch-Dest': 'empty', 'Referer': f'{doamin2}/', 'Accept-Language': 'zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7', } r = requests.post('https://api.jiudingliliang.com/user/info',json={},headers=self.h).json() if r['code'] == 10000: logging.info(f'登录成功') self.h['X-NIUBILITY-Y'] = r["result"]["uok"] logging.info(f'登录成功') else: logging.info(f'获取阅读入口失败[{r}]') @retry() def get_readtime(self,url): h = { 'accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7', 'accept-language': 'zh-CN,zh;q=0.9', 'cache-control': 'no-cache', # 'cookie': 'RK=x93V1EQnnk; ptcz=70105284a73b47db6aa5f48a05337a8cd84e98de7bd26d75975059126646db21; pac_uid=0_ZkHRNfy6PMhrH; ua_id=SyF8Nc7qjhUZ6RH8AAAAAHO013VXlTF21GY7ajzLLgs=; _clck=19reoir|1|fpg|0; wxuin=27186344812218; eas_sid=x1Y7v2y759E6j1a811G6q158d0; qq_domain_video_guid_verify=08d525e64ffa56c3; _qimei_uuid42=18a1b130e12100363fb639c628b466967c0e1ac0aa; pgv_pvid=6915337851; _qimei_fingerprint=3c42962857167cc55475bb65b2331f0b; _qimei_h38=fded42463fb639c628b4669602000006018a1b; o_cookie=3487934983; _qimei_q32=ec50b72a0f5a646accacf4393f1271f2; _qimei_q36=9e46147a2ab8bee5904ab74e30001741890c; rewardsn=; wxtokenkey=777', 'pragma': 'no-cache', 'priority': 'u=0, i', 'sec-ch-ua': '"Chromium";v="130", "Google Chrome";v="130", "Not?A_Brand";v="99"', 'sec-ch-ua-mobile': '?0', 'sec-ch-ua-platform': '"Windows"', 'sec-fetch-dest': 'document', 'sec-fetch-mode': 'navigate', 'sec-fetch-site': 'none', 'sec-fetch-user': '?1', 'upgrade-insecure-requests': '1', 'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/130.0.0.0 Safari/537.36', } r = requests.get(url,headers=h).text match = re.search(r"var createTime = '(.+?)';", r) if match: date_string = (match.group(1)) date = datetime.strptime(date_string, "%Y-%m-%d %H:%M") half_year_ago = datetime.now() - timedelta(days=30) if date > half_year_ago: return False,date_string else: return True,date_string @retry() def getread(self): url = 'https://api.jiudingliliang.com/task/read-batch' data = {"u": 1} r = requests.post(url,json=data,headers=self.h).json() if r['code'] == 10000: logging.info(f'获取阅读入口成功') print(r) #http://agifh.liliangda.cn?route=/pages/read/read&bn=2409211329003132289067&token=p5wP0pTb9eMHHJjf1fy133qF8tiaE0_k7jJzJRBtBXc&k=15G8EuNiZKx4b9W9SjgmmVJL60Tm0e_SNCQtW5IVdFdpYVsSHoL_UHd9btHBIunG j = urlparse(r["result"]["qrcode"]); self.domain, p = j.netloc, parse_qs(j.query); self.k = p.get('k')[0] if p.get('k') else '' self.readh = { "Host": "api.jiudingliliang.com", "Connection": "keep-alive", "Content-Length": "28", "sec-ch-ua": "\"Not/A)Brand\";v=\"8\", \"Chromium\";v=\"126\", \"Android WebView\";v=\"126\"", "sec-ch-ua-mobile": "?1", "User-Agent":ua, "Authorization": "Bearer", "Content-Type": "application/json", "X-NIUBILITY-Y": "", "F-RTYFGHVBN":self.h['F-RTYFGHVBN'], "sec-ch-ua-platform": "\"Android\"", "Accept": "*/*", "Origin": f"http://{self.domain}", "X-Requested-With": "com.tencent.mm", "Sec-Fetch-Site": "cross-site", "Sec-Fetch-Mode": "cors", "Sec-Fetch-Dest": "empty", "Referer": f"http://{self.domain}/", "Accept-Encoding": "gzip, deflate, br, zstd", "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7" } return True else: logging.error(f'获取阅读入口失败[{r}]') return False def tuisong(self): # 发送消息到wxpusher url = f"{self.apiurl}/zdgjc" data = {"url":self.read_url} r = requests.post(url,json=data).json() logging.info(f"遇到检测文章:推送结果[{r}]") @retry() def read(self): now = 0 while True: data = {"k":self.k} url = 'https://api.jiudingliliang.com/task/read-article' r = requests.post(url,json=data,headers=self.readh).json() if r['code'] == 10000: self.read_url = r["result"]["articleUrl"] thisnum = r["result"]["readingNumber"] va, date_string = self.get_readtime(self.read_url) logging.info(f'获取文章成功[{self.read_url}],发布时间[{date_string}]') j = urlparse(self.read_url.replace('\\','')) biz = parse_qs(j.query).get('__biz', [''])[0] if '__biz' in parse_qs(j.query) else '' if 'biz' not in self.read_url or biz in bizlist or va: self.tuisong() time.sleep(random.randint(20,25)) elif thisnum in [23, 24, 25, 26] and qj: logging.info('触发强检') self.tuisong() time.sleep(random.randint(20,25)) else: time.sleep(random.randint(8,10)) k = r["result"]["k"] else: logging.error(f'获取文章失败[{r}]') break url = 'https://api.jiudingliliang.com/task/read-article-completed' data = {'k':k} r = requests.post(url,json=data,headers=self.readh).json() if r['code'] == 10000: now = r["result"]["readingNumber"] all = r["result"]["totalReading"] logging.info(f'第[{now}/{all}]篇文章阅读成功') if now == all: logging.info("本轮阅读完成") break self.k = r["result"]["k"] else: logging.error(f'阅读失败[{r}]') break @retry() def userinfo(self): url = 'https://api.jiudingliliang.com/user/info' r = requests.post(url,json={},headers=self.h).json() if r['code'] == 10000: name = r["result"]["nickname"] m = int(float(r["result"]["balanceCash"])) logging.info(f'当前账号[{name}]余额[{m}]') global msg msg+=f"\n----\n微信账号：{name}\n账户余额：{m}" url = 'https://api.jiudingliliang.com/user/withdraw' r = requests.post(url,headers=self.h,json={}).json() if r['code'] == 10000: lessmoney = r["result"]["transfer"][0]["m"] if m >= lessmoney: msg+="\n恭喜，可以提现啦🎉" send(code+"可提现通知📢📢📢",f"微信账户[{name}]\n余额:{m} 元\n") if True: if m >= lessmoney: url = 'https://api.jiudingliliang.com/user/transfer' data = {'amount':lessmoney, 'type':'alipay'} r = requests.post(url,json=data,headers=self.h).json() logging.info(r) if r['code'] == 10000: logging.info(f'提现成功[{r}]') kl = r["result"]["alipay_kl"] send(code+"支付宝口令提现成功通知✅✅✅\n请及时到支付宝兑换口令红包！！！",f"微信账户[{name}]\n支付宝口令：{kl}") data = { "appToken":appToken, "content":f'叮叮联盟提现成功,口令[{kl}]', "summary":f'叮叮联盟提现成功,口令[{kl}]', "contentType":1, "uids":[ uid ], "verifyPayType":0 } r = requests.post('https://wxpusher.zjiecode.com/api/send/message',json=data).json() if r['code'] == 1000: logging.info('通知已发送') else: logging.error('通知发送失败') else: logging.error(f'提现失败[{r}]') else: logging.info(f'余额不足，跳过提现') else: logging.info(f'未设置wxpusher信息,跳过提现') else: logging.error(f'获取用户信息失败[{r}]') def main(self): try: self.login() if self.getread(): print('='*30) self.read() else: logging.error('获取阅读入口失败') self.userinfo() except Exception as e: logging.error(f'发生错误[{e}]') if __name__ == '__main__': ua = os.getenv("yuanshen_useragent") if not ua: logging.info("不填ua玩你妹妹\n"*999) exit() appToken = '' topicIds = '' if not appToken or not topicIds: appToken = os.getenv('yuanshen_apptoken') uid = os.getenv('yuanshen_wxpusheruid') if not appToken or not uid: logging.error("❌你还没有设置推送,请设置环境变量:yuanshen_wxpusheruid 和 yuanshen_apptoken") appToken = None uid = None env().main()