FlaskProject/spiders/hengbang/baojia/hb_modelserach.py

import json

import requests
from spiders.hengbang.guishu.hb_config import *
token=''
headerss=''
def check_login():
    username = 'SXXN000010'
    global token
    token = str(redis_conn.hget('hengbang_' + username, 'token'), 'utf8')
    if token == '':
        token = '用户名、密码错误'
    else:
        global headerss
        headerss = {
            "Content-Type": "application/json;charset=UTF-8",
            'Authorization': token,
            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/104.0.0.0 Safari/537.36'
        }
        params = {
            'proposalno': '',
            'licenseno': '',
            'carowner': '',
            'insuredcname': '',
            'insrntcname': '',
            'apptime': '',
            'creator': username,
            'pageNo': '0',
            'pageSize': '8',
        }
        response = requests.get('https://car.hbins.com.cn/new-insure/api/carInsureMain/list', params=params,
                                headers=headerss)
        if '登录失效' in response.text:
            get_userinfo(username)
            check_login()

def get_carinfo(x):
    model =x
    url = "https://car.hbins.com.cn/backstage/api/car-model/vague"
    params = {
        "modelCName": model,
        "licenseNo": "",
        "vinCode": "",
        "cimodelCode": "",
        "modelCodes": "",
        "pageNo": "0",
        "pageSize": "50",
    }
    response = requests.get(url, headers=headerss, params=params)
    if response.json().get('content'):
        content=[]
        for i in response.json().get('content'):
            if i.get('exhaustScale'):
                displacement=str(int(i.get('exhaustScale'))/1000)
            else:
                displacement=''
            content.append(
                {
                    "modelCode": i.get('modelCode'),
                    "modelName": i.get('modelCName'),
                    "brandCN":  i.get('carBrand'),
                    "series": i.get('familyName'),
                    "importFlag": i.get('vehicleClass'),
                    "ratedPassengerCapacity": i.get('seatCount'),
                    "displacement": displacement,
                    "marketYear": i.get('carYear'),
                    "replacementValue":  i.get('purchasePriceNotTax'),
                    "vehicleDescription": i.get('remark'),
                    "refCode1": '',
                    "refCode2": '',
                    "gearboxType": i.get('transmissiontType'),
                    "remark": i.get('remark'),
                    "fuelType": "",
                    "fuelTypeCode":   i.get('energyType') if i.get('energyType') else '0',
                    "energyTypes": i.get('energyType') if i.get('energyType') else '0',
                    "wholeWeight": '',
                    "powerScale": i.get('power'),
                    "vehicleJingyo": '',
                    "vehicleSeatMax": "0",
                    "vehicleSeatMin": "0"
            }
            )
        return {
            'code':200,
            'content':content
        }




    else:
        return {
            'code': 400,
            'content': []
        }
def main(x):
    check_login()
    if token!='用户名、密码错误':
        return get_carinfo(x)
    else:
        return {
            'code': 400,
            'message':'用户名、密码错误'
        }



if __name__ == '__main__':
    aa=main('东南DN7156M4轿车')
    print(aa.get('content'))