ReturnPromoterInfoSpider.py 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. """
  2. Author renyupeng
  3. coding=utf-8
  4. @Time : 2023/2/7 2:34 下午
  5. @Site :
  6. @File : ReturnPromoterInfoSpider.py
  7. @Software: PyCharm
  8. @contact: renyupeng@c-top.com.cn
  9. @Tel 1501435553
  10. """
  11. import json
  12. import requests
  13. from utils.mysql_helper import insert
  14. from utils.mysql_utils import MysqlUtils
  15. from utils.send_feishu_msg import SendFeiShuMsg
  16. class ReturnPromoterInfoSpider:
  17. def __init__(self):
  18. self.conn = MysqlUtils()
  19. def PromoterInfoSpiderHandler(self, promoterId):
  20. url = 'https://cps.kwaixiaodian.com/distribute/pc/seller/promoter/info?promoterId={promoterId}&type=1'.format(
  21. promoterId=promoterId)
  22. sql = "select cookie from ruixuan.kuaishou_supply_chain_cookie"
  23. cookie = self.conn.QueryOne(sql)[0]
  24. headers = {'User-Agent': 'Mozilla/5.0',
  25. 'Cookie': cookie}
  26. try:
  27. rep = requests.get(url=url, headers=headers)
  28. data = json.loads(rep.text)["data"]
  29. returnItem = {
  30. "city": data["addressInfo"]["city"],
  31. "province": data["addressInfo"]["province"],
  32. "fanNum": data["fanNum"],
  33. "promoterHeadImgUrl": data["promoterHeadImgUrl"],
  34. "promoterNickName": data["promoterNickName"],
  35. "totalSale": data["promoteBaseInfo"]["totalSale"],
  36. }
  37. returnItemJson = json.dumps(returnItem)
  38. return returnItemJson
  39. except Exception as e:
  40. SendFeiShuMsg.send_robot_msg('请求错误请检查cookie'.format(e=e))