交易网-建设工程-中标通知书-列表页.py 3.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. # -*- coding: utf-8 -*-
  2. """
  3. Created on 2025-06-04
  4. ---------
  5. @summary: 济宁市公共资源交易网
  6. ---------
  7. @author: lzz
  8. """
  9. import feapder
  10. from items.spider_item import MgpListItem
  11. from collections import namedtuple
  12. from html import unescape
  13. class Feapder(feapder.BiddingListSpider):
  14. def start_callback(self):
  15. Menu = namedtuple('Menu', ['channel', 'code', 'tid', 'crawl_page'])
  16. self.site = "济宁市公共资源交易网"
  17. self.menus = [
  18. Menu('建设工程-中标通知书', 'sd_jnsggzyjyw_jsgc_zbtzs_py', '531000', 1),
  19. ]
  20. self.headers = {
  21. "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7",
  22. "Accept-Language": "zh-CN,zh;q=0.9,en;q=0.8",
  23. "Connection": "keep-alive",
  24. "Upgrade-Insecure-Requests": "1",
  25. "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",
  26. }
  27. def start_requests(self):
  28. for menu in self.menus:
  29. start_url = "https://jnggzy.jnzbtb.cn:4430/JiNing/Posts"
  30. yield feapder.Request(url=start_url, item=menu._asdict(), page=1, proxies=False)
  31. def download_midware(self, request):
  32. page = request.page
  33. menu = request.item
  34. tid = menu.get('tid')
  35. params = {
  36. "cat": tid,
  37. "pn": f"{page}"
  38. }
  39. request.params = params
  40. request.headers = self.headers
  41. def parse(self, request, response):
  42. menu = request.item
  43. info_list = response.xpath('//ul[@class="list-group"]/li')
  44. for info in info_list:
  45. href = info.xpath('./a/@href').extract_first("").strip()
  46. title = unescape("".join(info.xpath('./a/text()').extract()).strip())
  47. create_time = info.xpath('./span/text()').extract_first("").strip()
  48. area = "山东" # 省份
  49. city = "济宁市" # 城市
  50. list_item = MgpListItem() # 存储数据的管道
  51. list_item.href = href # 标书链接
  52. list_item.unique_key = ('title', 'href')
  53. list_item.channel = menu.get("channel") # 最上方定义的抓取栏目 (编辑器定的)
  54. list_item.spidercode = menu.get("code") # 最上方定义的爬虫code(编辑器定的)
  55. list_item.title = title # 标题
  56. list_item.site = self.site
  57. list_item.publishtime = create_time
  58. list_item.area = area # 城市默认:全国
  59. list_item.city = city # 城市 默认为空
  60. list_item.parse = "self.detail_get" # 详情页回调方法
  61. list_item.deal_detail = ['//div[@class="card-body"]']
  62. list_item.proxies = False
  63. list_item.parse_url = href
  64. yield list_item
  65. # 无限翻页
  66. request = self.infinite_pages(request, response)
  67. yield request
  68. if __name__ == "__main__":
  69. Feapder(redis_key="lzz:jnsggzyjyw_lzzqgg").start()