chickliu/QL_TimingScript
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🔨🐛 修复获取任务状态报错的问题

Browse Source
This commit is contained in:
liulong 2024-09-24 13:12:49 +08:00
parent 0fff1443c5
commit 961d43fb37
1 changed files with 21 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
hykb_tasks.py
View File

@ -9,9 +9,12 @@ import re
import urllib.parse import urllib.parse
from datetime import datetime from datetime import datetime
import os import os
from urllib.parse import quote_plus
import httpx import httpx
from bs4 import BeautifulSoup from bs4 import BeautifulSoup
if 'Hykb_cookie' in os.environ: if 'Hykb_cookie' in os.environ:
hykb_cookie = re.split("@", os.environ.get("Hykb_cookie")) hykb_cookie = re.split("@", os.environ.get("Hykb_cookie"))
print(f"查找到{len(hykb_cookie)}个账号") print(f"查找到{len(hykb_cookie)}个账号")
@ -20,10 +23,16 @@ else:
print("未查找到Hykb_cookie变量.") print("未查找到Hykb_cookie变量.")
exit() exit()
class AsyncHykbTasks: class AsyncHykbTasks:
def __init__(self, cookie): def __init__(self, cookie):
self.client = httpx.AsyncClient(base_url="https://huodong3.3839.com", verify=False) self.client = httpx.AsyncClient(base_url="https://huodong3.3839.com",
headers={
'User-Agent': "Mozilla/5.0 (Linux; Android 12; Redmi K30 Pro Build/SKQ1.211006.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/96.0.4664.104 Mobile Safari/537.36Androidkb/1.5.7.507(android;Redmi K30 Pro;12;1080x2356;WiFi);@4399_sykb_android_activity@",
'Content-Type': "application/x-www-form-urlencoded; charset=UTF-8",
'Origin': "https://huodong3.3839.com",
'Referer': "https://huodong3.3839.com/n/hykb/newsign/index.php?imm=0&hd_id=1416",
},
verify=False)
self.cookie = cookie self.cookie = cookie
self.items = [] self.items = []
@ -44,13 +53,17 @@ class AsyncHykbTasks:
async def get_task(self, a, hd_id_): async def get_task(self, a, hd_id_):
try: try:
payload = f"ac={a}&hd_id={hd_id_}&hd_id2={hd_id_}&t={datetime.now().strftime('%Y-%m-%d %H:%M:%S')}&r=0.{random.randint(1000000000000000, 8999999999999999)}&scookie={self.cookie}"
url = "https://huodong3.3839.com/n/hykb/newsign/ajax.php"
self.client.headers["Referer"] = f"https://huodong3.3839.com/n/hykb/newsign/index.php?imm=0&hd_id={hd_id_}"
response = await self.client.post( response = await self.client.post(
url="/n/hykb/signcard/ajax.php", url=url,
content=f"ac={a}&t={datetime.now().strftime('%Y-%m-%d %H:%M:%S')}&r=0.{random.randint(1000000000000000, 8999999999999999)}&hd_id={hd_id_}&hd_id2={hd_id_}&scookie={self.cookie}", data=payload,
) )
return response.json() response_json = response.json()
return response_json
except Exception as e: except Exception as e:
print(f"Error in get_task: {e}") print(e)
return None return None
async def process_item(self, item): async def process_item(self, item):
@ -77,7 +90,7 @@ class AsyncHykbTasks:
return True return True
async def task(self): async def task(self):
self.cookie = urllib.parse.quote(self.cookie) if "|" in self.cookie else self.cookie cookie = urllib.parse.quote(self.cookie) if "|" in self.cookie else self.cookie
await self.get_task_ids() await self.get_task_ids()
for item in self.items: for item in self.items:
@ -98,8 +111,7 @@ async def run_all_tasks(cookies):
async def main(): async def main():
ht = AsyncHykbTasks(hykb_cookie) await run_all_tasks(hykb_cookie)
await ht.task()
if __name__ == '__main__': if __name__ == '__main__':