Super_Employee/wubatongcheng.py

# 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