招标采购-列表页.py 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
  1. # -*- coding: utf-8 -*-
  2. """
  3. Created on 2025-05-19
  4. ---------
  5. @summary: 友云采
  6. ---------
  7. @author: lzz
  8. """
  9. import feapder
  10. from items.spider_item import BidingListItem
  11. from collections import namedtuple
  12. from feapder.utils.tools import timestamp_to_date
  13. import execjs
  14. class ZtbpcFeapder(feapder.BiddingListSpider):
  15. def start_callback(self):
  16. self.site = "友云采"
  17. Menu = namedtuple('Menu', ['channel', 'code', 'crawl_page'])
  18. self.menus = [
  19. Menu('招标采购', 'a_yyc_zbcg', 1),
  20. ]
  21. self.headers = {
  22. "Accept": "application/json, text/plain, */*",
  23. "Accept-Language": "zh-CN,zh;q=0.9,en;q=0.8",
  24. "Connection": "keep-alive",
  25. "Referer": "https://yc.yonyoucloud.com/opportunity/opportunity?type=1",
  26. "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/133.0.0.0 Safari/537.36",
  27. }
  28. def start_requests(self):
  29. for menu in self.menus:
  30. start_url = "https://yc.yonyoucloud.com/trade-opportunity/logout/opportunity/queryNoLoginOpportunityList"
  31. yield feapder.Request(url=start_url, item=menu._asdict(), page=1)
  32. def download_midware(self, request):
  33. with open('./yyc_headers.js','r') as fr:
  34. ex_js = fr.read()
  35. ctx = execjs.compile(ex_js)
  36. rid = ctx.call('rid')
  37. page = request.page
  38. params = {
  39. "comprehensive": "1",
  40. "type": "1",
  41. "pageSize": "20",
  42. "pageIndex": f"{page}",
  43. "_rid": f"{rid}"
  44. }
  45. request.headers = self.headers
  46. request.params = params
  47. def parse(self, request, response):
  48. menu = request.item
  49. info_list = response.json.get('data').get('list')
  50. for info in info_list:
  51. hid = info.get('idStr')
  52. href = f"https://yc.yonyoucloud.com/opportunity/buyOfferDetail/{hid}"
  53. title = info.get('billName').strip()
  54. publish_time = timestamp_to_date(int(str(info.get('publishTime'))[:10]))
  55. area = "全国" # 省份
  56. city = "" # 城市
  57. district = "" # 区县
  58. list_item = BidingListItem() # 存储数据的管道
  59. list_item.href = href # 标书链接
  60. list_item.channel = menu.get("channel") # 最上方定义的抓取栏目 (编辑器定的)
  61. list_item.spidercode = menu.get("code") # 最上方定义的爬虫code(编辑器定的)
  62. list_item.title = title # 标题
  63. list_item.publishtime = publish_time # 标书发布时间
  64. list_item.site = self.site
  65. list_item.area = area or "全国" # 省份 默认:全国
  66. list_item.city = city # 城市 默认 为空
  67. list_item.district = district # 区县 默认 为空
  68. list_item.unique_key = ('href',)
  69. list_item.parse = "self.detail_get" # 详情页回调方法
  70. list_item.deal_detail = [] # 抽取正文xpath
  71. list_item.proxies = False
  72. list_item.parse_url = href # 详情页请求地址
  73. yield list_item
  74. # 翻页
  75. request = self.infinite_pages(request, response)
  76. yield request
  77. if __name__ == "__main__":
  78. ZtbpcFeapder(redis_key="lzz:yyc_zhbgg").start()