| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586 | 
							- """
 
- Author renyupeng
 
- coding=utf-8
 
- @Time    : 2023/2/7 2:34 下午
 
- @Site    :
 
- @File    : ReturnPromoterInfoSpider.py
 
- @Software: PyCharm
 
- @contact: renyupeng@c-top.com.cn
 
- @Tel 1501435553
 
- """
 
- import json
 
- import random
 
- import redis
 
- import requests
 
- from utils.cookie_update import cookie_update
 
- from utils.mysql_helper import insert
 
- from utils.mysql_utils import MysqlUtils
 
- from utils.mysql_utils_pro import MysqlProUtils
 
- from utils.send_feishu_msg import SendFeiShuMsg
 
- class ReturnPromoterInfoSpider:
 
-     def __init__(self):
 
-         self.conn = MysqlUtils()
 
-     @staticmethod
 
-     def PromoterInfoSpiderHandler(promoterId, cookie):
 
-         url = 'https://cps.kwaixiaodian.com/distribute/pc/seller/promoter/info?promoterId={promoterId}&type=1'.format(
 
-             promoterId=promoterId)
 
-         headers = {'User-Agent': 'Mozilla/5.0',
 
-                    'Cookie': cookie}
 
-         try:
 
-             rep = requests.get(url=url, headers=headers)
 
-             print(rep.text, '----------')
 
-             if json.loads(rep.text)["result"] != 1:
 
-                 errItem = {"result": json.loads(rep.text)["result"]}
 
-                 return json.dumps(errItem)
 
-             else:
 
-                 data = json.loads(rep.text)["data"]
 
-                 print(data, '----data------')
 
-                 returnItem = {
 
-                     "city": data["addressInfo"]["city"],
 
-                     "province": data["addressInfo"]["province"],
 
-                     "fanNum": data["fanNum"],
 
-                     "promoterHeadImgUrl": data["promoterHeadImgUrl"],
 
-                     "promoterNickName": data["promoterNickName"],
 
-                     "totalSale": data["promoteBaseInfo"]["totalSale"],
 
-                     "avgVideoSales": data["promoteBaseInfo"]["avgVideoSales"],
 
-                     "videoSales": data["promoteBaseInfo"]["videoSales"]
 
-                 }
 
-                 returnItemJson = json.dumps(returnItem)
 
-                 print(returnItemJson, '----returnItemJson-----')
 
-                 return returnItemJson
 
-         except Exception as e:
 
-             SendFeiShuMsg.send_robot_msg(
 
-                 'ReturnPromoterInfoSpider {promoterId}请求错误请检查cookie{e}'.format(promoterId=promoterId, e=e))
 
-     @staticmethod
 
-     def PromoterUpdate(promoterId, cookie):
 
-         url = 'https://cps.kwaixiaodian.com/distribute/pc/seller/promoter/info?promoterId={promoterId}&type=1'.format(
 
-             promoterId=promoterId)
 
-         headers = {'User-Agent': 'Mozilla/5.0',
 
-                    'Cookie': cookie}
 
-         try:
 
-             rep = requests.get(url=url, headers=headers)
 
-             print(rep, '--------rep--------')
 
-             if json.loads(rep.text)["result"] != 1:
 
-                 errItem = {"result": json.loads(rep.text)["result"]}
 
-                 return json.dumps(errItem)
 
-             else:
 
-                 data = json.loads(rep.text)["data"]
 
-                 avgVideoSales = data["promoteBaseInfo"]["avgVideoSales"]
 
-                 videoSales = data["promoteBaseInfo"]["videoSales"]
 
-                 sql = "update ruixuan.promoter_info  set videoSales= '{videoSales}' , avgVideoSales='{avgVideoSales}' where promoter_id={promoter_id}".format(
 
-                     videoSales=videoSales,
 
-                     avgVideoSales=avgVideoSales, promoter_id=promoterId
 
-                 )
 
-                 MysqlProUtils().Operate(sql=sql)
 
-         except Exception as e:
 
-             SendFeiShuMsg.send_robot_msg(
 
-                 'PromoterUpdate {promoterId}请求错误请检查cookie{e}'.format(promoterId=promoterId, e=e))
 
 
  |