elab_mvp/test/http_test.py

import requests
from mysql_db import MysqlDB
headers_1 = {'content-type': "application/json", 'Authorization': 'APP appid = 4abf1a,token = 9480295ab2e2eddb8',
             'dsNo': 'source1'}
headers_2 = {'content-type': "application/json",
             'Authorization': 'APP appid = 4abf1a,token = 9480295ab2e2eddb8',
             'dsNo': 'source2',
             'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, '
                                             'like Gecko) Chrome/86.0.4240.111 Safari/537.36',
             'Host': '101.132.43.32:5308',
             'POST': '/news/queryNewsByPage HTTP/1.1',
             'Connection': 'keep-alive',
             'Accept': 'application/json;charset=UTF-8'
             }


if __name__ == '__main__':
    import time
    mysql = MysqlDB('marketing_db')
    url = "https://api-uat3.elaber.cn/elab-marketing-content/materialLabel/markingForMaterial"
    sql_dict = {
        1: 'select a.id from house a LEFT JOIN brand_house_rlat b on a.id = b.house_id where a.status = 1 and b.status = 1 and b.brand_id = 1',
        2: 'select a.id from content_moment a LEFT JOIN brand_house_rlat b on a.house_id = b.house_id where a.status = 1 and b.status = 1 and b.brand_id = 1',
        3: 'select a.id from t_content_album a LEFT JOIN brand_house_rlat b on a.house_id = b.house_id where a.status = 1 and b.status = 1 and b.brand_id = 1',
        4: 'select a.id from content_layout a LEFT JOIN brand_house_rlat b on a.house_id = b.house_id where a.status = 1 and b.status = 1 and b.brand_id = 1'
    }
    for index in sql_dict.keys():
        house = mysql.select(sql_dict.get(index))
        count = 0
        for x in house:
            print(x[0])
            params = {
                "deleteStatus": 2,
                "materialId": x[0],
                # 物料类型，1：项目，2：视频，3：图集（图片），4：户型
                "materialType": index,
                "user": "batch20201230"
            }
            response = requests.post(url, json=params, headers=headers_1)
            print(response.text)
            time.sleep(0.5)