224 lines
11 KiB
Python
224 lines
11 KiB
Python
# main_script.py
|
||
import requests
|
||
import json
|
||
from UserDefined import wubatongcheng_poststate, wubatongcheng_clientid, wubatongcheng_Search, deviceName, \
|
||
wubatongcheng_cityid, wubatongcheng_Chatstate, wubatongcheng_postnumber
|
||
from system import successful_deliveries, wubatongcheng_SearchUrl, wubatongcheng_PostUrl, wubatongcheng_Chat
|
||
|
||
|
||
def run_wubatongcheng_script():
|
||
# 初始化变量
|
||
wubatongcheng_successCount = 0
|
||
wubatongcheng_errorCount = 0
|
||
wubatongcheng_findCount = 0
|
||
page = 1
|
||
# 请求头
|
||
wubatongcheng_headers = {
|
||
'User-Agent': "okhttp/3.11.0",
|
||
'Connection': "Keep-Alive",
|
||
'Accept-Encoding': "gzip,deflate",
|
||
'net-msg-id': "",
|
||
'x-microservice-name': "APMS",
|
||
'apkbus': "",
|
||
'coordinateType': "10",
|
||
'official': "true",
|
||
'xxzl-cid': "",
|
||
'ua': "21051182C",
|
||
'uuid': "",
|
||
'dirname': "sz",
|
||
'productorid': "1",
|
||
'jumpextra': "{\"spm\":\"\",\"utm_source\":\"\"}",
|
||
'marketchannelid': "1366",
|
||
'osv': "14",
|
||
'58clientid': wubatongcheng_clientid,
|
||
'brand': "Xiaomi",
|
||
'apn': "WIFI",
|
||
'deny': "1.875",
|
||
'firstopentime': "",
|
||
'netType': "wifi",
|
||
'rnsoerror': "-1",
|
||
'switchrecommend': "",
|
||
'version': "13.10.2",
|
||
'jumppid': "",
|
||
'push': "0",
|
||
'homemodel': "normal",
|
||
'currentcid': "",
|
||
'buildtime': "",
|
||
'bangbangid': "",
|
||
'xxwxtoken': "",
|
||
'cid': wubatongcheng_cityid,
|
||
'ajkAuthTicket': "",
|
||
'xxzlsid': "",
|
||
'scale': "1",
|
||
'guestImei': "",
|
||
'platform': "android",
|
||
'openudid': "",
|
||
'manufacturer': deviceName,
|
||
'id58': "",
|
||
'PPU': "",
|
||
'sh': "2500",
|
||
'osarch': "arm64-v8a",
|
||
'xxzlcid': "",
|
||
'webua': "Mozilla/5.0 (Linux; U; Android 14; "+deviceName+" Build/UQ1A.240105.004.A1; wv) AppleWebKit/534.30 (KHTML, like Gecko) Version/4.0 Chrome/55.0.2883.91 Mobile Safari/534.30",
|
||
'bundle': "com.wuba",
|
||
'uniqueid': "",
|
||
'totalsize': "",
|
||
'xxaqrid': "",
|
||
'xxwxtokenp': "",
|
||
'product': "58app",
|
||
'sw': "",
|
||
'os': "android",
|
||
'vlocalid': "",
|
||
'r': "",
|
||
'xxzl_deviceid': "",
|
||
'xxzl_smartid': "",
|
||
'xxzl_cid': "",
|
||
'58ua': "58app",
|
||
'clinkid': "",
|
||
'maptype': "2",
|
||
'tp': "",
|
||
'channelid': "",
|
||
'jobreferer': "",
|
||
'bgtype': "58app",
|
||
'ZPBEntryLogType': "",
|
||
'xxzlbbid': "",
|
||
'xxzlxxid': "",
|
||
'zpbpubver': "2.10.0",
|
||
'gsparam': ""
|
||
}
|
||
while True:
|
||
wubatongcheng_Search['page'] = str(page) # 设置当前页码
|
||
# response = requests.get(yizhanchi_SearchUrl, params=yizhanchi_Search, headers=headers)
|
||
# 发送 GET 请求
|
||
wubatongcheng_SearchResponse = requests.get(wubatongcheng_SearchUrl, params=wubatongcheng_Search, headers=wubatongcheng_headers)
|
||
# payload = json.dumps(wubatongcheng_Search)
|
||
# wubatongcheng_SearchResponse = requests.post(wubatongcheng_SearchUrl, data=payload, headers=wubatongcheng_headers)
|
||
# print(wubatongcheng_SearchResponse.text)
|
||
|
||
# 检查请求是否成功
|
||
if wubatongcheng_SearchResponse.status_code == 200:
|
||
# data = wubatongcheng_SearchResponse.json()
|
||
|
||
try:
|
||
data = wubatongcheng_SearchResponse.json()
|
||
items = data['jobList']['data']
|
||
|
||
if wubatongcheng_successCount>=wubatongcheng_postnumber:
|
||
break
|
||
if not items:
|
||
break
|
||
|
||
|
||
uuid_list = [item['infoID'] for item in items]
|
||
company_list = [item['qyname'] for item in items]
|
||
job_list = [item['title'] for item in items]
|
||
salary_desc_list = [item['xinzi'] for item in items]
|
||
attraction_list = [item['signsList'] for item in items]
|
||
city_list = [item['quyu'] for item in items]
|
||
|
||
print("------------58同城-------------")
|
||
print("在58同城平台找到以下岗位，即将为您投递:")
|
||
print("---------------------------------")
|
||
|
||
for uuid, company, job, salary_desc, attraction, city in zip(uuid_list, company_list, job_list, salary_desc_list, attraction_list, city_list):
|
||
attraction_str = json.dumps(attraction, ensure_ascii=False)
|
||
# group_items = group_data['msg']['resume']
|
||
# deliver_able_list = [item['deliver_able'] for item in group_items]
|
||
# group_list = [item['group_uuid'] for item in group_items]
|
||
|
||
# deliver_able_online = deliver_able_list[0] if len(deliver_able_list) > 0 else False
|
||
# deliver_able_local = deliver_able_list[1] if len(deliver_able_list) > 1 else False
|
||
wubatongcheng_findCount=wubatongcheng_findCount + 1
|
||
print(f"------------第{wubatongcheng_findCount}家-------------")
|
||
print(f"UUID: {uuid}")
|
||
print(f"公司: {company}")
|
||
print(f"城市: {city}")
|
||
print(f"岗位: {job}")
|
||
print(f"薪资: {salary_desc}")
|
||
print(f"福利: {attraction_str}")
|
||
# print(f"在线简历投递状态: {'可投递' if deliver_able_online else '不可投递'}")
|
||
# print(f"本地简历投递状态: {'可投递' if deliver_able_local else '不可投递'}")
|
||
print("-------------Result---------------")
|
||
# usegroup = None # 初始化 usegroup
|
||
|
||
# if (wubatongcheng_poststate == 1 and deliver_able_online) or (wubatongcheng_poststate == 2 and not deliver_able_local and deliver_able_online):
|
||
# usegroup = group_list[0]
|
||
# elif (wubatongcheng_poststate == 1 and not deliver_able_online and deliver_able_local) or (wubatongcheng_poststate == 2 and deliver_able_local):
|
||
# usegroup = group_list[1]
|
||
# elif (wubatongcheng_poststate == 0 and (deliver_able_online or deliver_able_local)):
|
||
# usegroup = None
|
||
if (wubatongcheng_Chatstate==1):
|
||
wubatongcheng_Chatpayload = "infoId=57464116683181&scene=job_detail&tjfrom=app_list_search_mxn__143164519225947239129717587__723395933378117632__tegptplus__I%2CL__4____null__eyJyIjp7InNwbSI6IiIsImluZm9pZCI6IjU3NDY0MTE2NjgzMTgxIiwic2xvdCI6ImFwcF9saXN0X3NlYXJjaF9teG4iLCJ0eXBlIjoidGVncHRwbHVzIiwic2lkIjoiMTQzMTY0NTE5MjI1OTQ3MjM5MTI5NzE3NTg3IiwidXRtIjoiIiwiY2lkIjoiMTM2NiJ9LCJ0IjoxLCJ2IjoxLCJ3Ijp7InNsb3RfZnJvbSI6ImFwcF9taWRkbGVfc2VhcmNoIn19&platform=3"
|
||
wubatongcheng_ChatResponse = requests.post(wubatongcheng_Chat, data=wubatongcheng_Chatpayload, headers=wubatongcheng_headers)
|
||
data = wubatongcheng_ChatResponse.json()
|
||
wubatongcheng_wubatongcheng_Chatstate = data['message']
|
||
if wubatongcheng_wubatongcheng_Chatstate == '成功'and wubatongcheng_poststate==0:
|
||
wubatongcheng_successCount += 1
|
||
delivery_info = {
|
||
"UUID": uuid,
|
||
"公司": company,
|
||
"城市": city,
|
||
"岗位": job,
|
||
"薪资": salary_desc,
|
||
"福利": attraction_str,
|
||
# "投递来自": "在线简历" if usegroup == group_list[0] else "本地简历"
|
||
}
|
||
successful_deliveries.append(delivery_info)
|
||
elif wubatongcheng_poststate==0:
|
||
wubatongcheng_errorCount += 1
|
||
if (wubatongcheng_poststate==1):
|
||
wubatongcheng_Postpayload = {
|
||
"infoId="+uuid+"&os=android&pt=0&ceping=0&format=json&wechat=0&aiScene=4&ct=4&resumeId=&completeResume=0&deliverySource=8&v=1&curVer=13.10.2&downloadApp=0&appId=1&tjfrom=&synYingcai=0&sidDict="
|
||
}
|
||
|
||
|
||
wubatongcheng_PostResponse = requests.post(wubatongcheng_PostUrl, data=wubatongcheng_Postpayload, headers=wubatongcheng_headers)
|
||
try:
|
||
data = wubatongcheng_PostResponse.json()
|
||
wubatongcheng_wubatongcheng_poststate = data['result']
|
||
if wubatongcheng_wubatongcheng_poststate == 'ok':
|
||
wubatongcheng_successCount += 1
|
||
delivery_info = {
|
||
"UUID": uuid,
|
||
"公司": company,
|
||
"城市": city,
|
||
"岗位": job,
|
||
"薪资": salary_desc,
|
||
"福利": attraction_str,
|
||
# "投递来自": "在线简历" if usegroup == group_list[0] else "本地简历"
|
||
}
|
||
successful_deliveries.append(delivery_info)
|
||
except Exception as e:
|
||
print("58同城中没有相关工作，请尝试放宽筛选")
|
||
print(f"错误信息: {e}")
|
||
wubatongcheng_errorCount += 1
|
||
# print(wubatongcheng_wubatongcheng_poststate)
|
||
else:
|
||
if wubatongcheng_poststate == 0:
|
||
print("您未开启58同城投递，本次投递跳过")
|
||
# elif wubatongcheng_poststate in [1, 2]:
|
||
|
||
# print("您已投递过该公司,本次投递跳过")
|
||
# wubatongcheng_Groupid = {'inuuid': uuid}
|
||
|
||
# wubatongcheng_GroupResponse = requests.get(wubatongcheng_GroupUrl, params=wubatongcheng_Groupid, headers=wubatongcheng_headers)
|
||
|
||
# if wubatongcheng_GroupResponse.status_code == 200:
|
||
# group_data = wubatongcheng_GroupResponse.json()
|
||
|
||
|
||
|
||
# except KeyError as e:
|
||
# print(f"获取投递状态数据失败: {e}")
|
||
# else:
|
||
# print(f"投递状态请求失败，HTTP状态码: {wubatongcheng_GroupResponse.status_code}")
|
||
except Exception as e:
|
||
print("58同城中没有相关工作，请尝试放宽筛选")
|
||
print(f"错误信息: {e}")
|
||
|
||
else:
|
||
print(f"请求失败，HTTP状态码: {wubatongcheng_SearchResponse.status_code}")
|
||
page += 1
|
||
|
||
return wubatongcheng_findCount, wubatongcheng_successCount, wubatongcheng_errorCount
|