feat: 新增北京电力交易平台爬虫
- 新增 PowerbeijingCrawler 爬虫类,支持北京电力交易平台招标信息抓取 - 目标平台:https://www.powerbeijing-ec.com,专注于北京地区电力交易招标信息 - 使用正则表达式提取招标公告,支持标题、URL和发布日期解析 - 添加完整的人类行为模拟功能(鼠标移动、滚动)降低检测风险 - 支持分页抓取,最多抓取5页数据,使用 turnPage 函数进行翻页 - 添加完整的单元测试文件,确保爬虫功能正常 - 统一的错误处理机制,单个爬虫失败不影响整体任务执行
This commit is contained in:
51
src/crawler/services/powerbeijing_target.spec.ts
Normal file
51
src/crawler/services/powerbeijing_target.spec.ts
Normal file
@@ -0,0 +1,51 @@
|
|||||||
|
import { PowerbeijingCrawler } from './powerbeijing_target';
|
||||||
|
import * as puppeteer from 'puppeteer';
|
||||||
|
|
||||||
|
// Increase timeout to 60 seconds for network operations
|
||||||
|
jest.setTimeout(60000*5);
|
||||||
|
|
||||||
|
describe('PowerbeijingCrawler Real Site Test', () => {
|
||||||
|
let browser: puppeteer.Browser;
|
||||||
|
|
||||||
|
beforeAll(async () => {
|
||||||
|
browser = await puppeteer.launch({
|
||||||
|
headless: false, // Change to false to see browser UI
|
||||||
|
args: ['--no-sandbox', '--disable-setuid-sandbox'],
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
afterAll(async () => {
|
||||||
|
if (browser) {
|
||||||
|
await browser.close();
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should visit website and list all found bid information', async () => {
|
||||||
|
console.log(`\nStarting crawl for: ${PowerbeijingCrawler.name}`);
|
||||||
|
console.log(`Target URL: ${PowerbeijingCrawler.url}`);
|
||||||
|
|
||||||
|
const results = await PowerbeijingCrawler.crawl(browser);
|
||||||
|
|
||||||
|
console.log(`\nSuccessfully found ${results.length} items:\n`);
|
||||||
|
console.log('----------------------------------------');
|
||||||
|
results.forEach((item, index) => {
|
||||||
|
console.log(`${index + 1}. [${item.publishDate.toLocaleDateString()}] ${item.title}`);
|
||||||
|
console.log(` Link: ${item.url}`);
|
||||||
|
console.log('----------------------------------------');
|
||||||
|
});
|
||||||
|
|
||||||
|
// Basic assertions to ensure crawler is working
|
||||||
|
expect(results).toBeDefined();
|
||||||
|
expect(Array.isArray(results)).toBeTruthy();
|
||||||
|
// Warn but don't fail if site returns 0 items (could be empty or changed structure)
|
||||||
|
if (results.length === 0) {
|
||||||
|
console.warn('Warning: No items found. Check if website structure has changed or if list is currently empty.');
|
||||||
|
} else {
|
||||||
|
// Check data integrity of first item
|
||||||
|
const firstItem = results[0];
|
||||||
|
expect(firstItem.title).toBeTruthy();
|
||||||
|
expect(firstItem.url).toMatch(/^https?:\/\//);
|
||||||
|
expect(firstItem.publishDate).toBeInstanceOf(Date);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
198
src/crawler/services/powerbeijing_target.ts
Normal file
198
src/crawler/services/powerbeijing_target.ts
Normal file
@@ -0,0 +1,198 @@
|
|||||||
|
import * as puppeteer from 'puppeteer';
|
||||||
|
import { Logger } from '@nestjs/common';
|
||||||
|
|
||||||
|
// 模拟人类鼠标移动
|
||||||
|
async function simulateHumanMouseMovement(page: puppeteer.Page) {
|
||||||
|
const viewport = page.viewport();
|
||||||
|
if (!viewport) return;
|
||||||
|
|
||||||
|
const movements = 5 + Math.floor(Math.random() * 5); // 5-10次随机移动
|
||||||
|
|
||||||
|
for (let i = 0; i < movements; i++) {
|
||||||
|
const x = Math.floor(Math.random() * viewport.width);
|
||||||
|
const y = Math.floor(Math.random() * viewport.height);
|
||||||
|
|
||||||
|
await page.mouse.move(x, y, {
|
||||||
|
steps: 10 + Math.floor(Math.random() * 20) // 10-30步,使移动更平滑
|
||||||
|
});
|
||||||
|
|
||||||
|
// 随机停顿 100-500ms
|
||||||
|
await new Promise(r => setTimeout(r, 100 + Math.random() * 400));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 模拟人类滚动
|
||||||
|
async function simulateHumanScrolling(page: puppeteer.Page) {
|
||||||
|
const scrollCount = 3 + Math.floor(Math.random() * 5); // 3-7次滚动
|
||||||
|
|
||||||
|
for (let i = 0; i < scrollCount; i++) {
|
||||||
|
const scrollDistance = 100 + Math.floor(Math.random() * 400); // 100-500px
|
||||||
|
|
||||||
|
await page.evaluate((distance) => {
|
||||||
|
window.scrollBy({
|
||||||
|
top: distance,
|
||||||
|
behavior: 'smooth'
|
||||||
|
});
|
||||||
|
}, scrollDistance);
|
||||||
|
|
||||||
|
// 随机停顿 500-1500ms
|
||||||
|
await new Promise(r => setTimeout(r, 500 + Math.random() * 1000));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 滚动回顶部
|
||||||
|
await page.evaluate(() => {
|
||||||
|
window.scrollTo({ top: 0, behavior: 'smooth' });
|
||||||
|
});
|
||||||
|
await new Promise(r => setTimeout(r, 1000));
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface PowerbeijingResult {
|
||||||
|
title: string;
|
||||||
|
publishDate: Date;
|
||||||
|
url: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export const PowerbeijingCrawler = {
|
||||||
|
name: '北京电力交易平台',
|
||||||
|
url: 'https://www.powerbeijing-ec.com/jncms/search/bulletin.html?dates=300&categoryId=2&tabName=%E6%8B%9B%E6%A0%87%E5%85%AC%E5%91%8A&page=1',
|
||||||
|
baseUrl: 'https://www.powerbeijing-ec.com',
|
||||||
|
|
||||||
|
async crawl(browser: puppeteer.Browser): Promise<PowerbeijingResult[]> {
|
||||||
|
const logger = new Logger('PowerbeijingCrawler');
|
||||||
|
const page = await browser.newPage();
|
||||||
|
|
||||||
|
const username = process.env.PROXY_USERNAME;
|
||||||
|
const password = process.env.PROXY_PASSWORD;
|
||||||
|
if (username && password) {
|
||||||
|
await page.authenticate({ username, password });
|
||||||
|
}
|
||||||
|
|
||||||
|
await page.evaluateOnNewDocument(() => {
|
||||||
|
Object.defineProperty(navigator, 'webdriver', { get: () => false });
|
||||||
|
Object.defineProperty(navigator, 'language', { get: () => "zh-CN"});
|
||||||
|
Object.defineProperty(navigator, 'plugins', { get: () => [1,2,3,4,5]});
|
||||||
|
});
|
||||||
|
|
||||||
|
await page.setUserAgent('Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/143.0.0.0 Safari/537.36');
|
||||||
|
await page.setViewport({ width: 1920, height: 1080 });
|
||||||
|
|
||||||
|
const allResults: PowerbeijingResult[] = [];
|
||||||
|
let currentPage = 1;
|
||||||
|
const maxPages = 5;
|
||||||
|
|
||||||
|
try {
|
||||||
|
logger.log(`Navigating to ${this.url}...`);
|
||||||
|
await page.goto(this.url, { waitUntil: 'networkidle2', timeout: 60000 });
|
||||||
|
|
||||||
|
// 模拟人类行为
|
||||||
|
logger.log('Simulating human mouse movements...');
|
||||||
|
await simulateHumanMouseMovement(page);
|
||||||
|
|
||||||
|
logger.log('Simulating human scrolling...');
|
||||||
|
await simulateHumanScrolling(page);
|
||||||
|
|
||||||
|
while (currentPage <= maxPages) {
|
||||||
|
logger.log(`Processing page ${currentPage}...`);
|
||||||
|
|
||||||
|
const content = await page.content();
|
||||||
|
const pageResults = this.extract(content);
|
||||||
|
|
||||||
|
if (pageResults.length === 0) {
|
||||||
|
logger.warn(`No results found on page ${currentPage}, stopping.`);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
allResults.push(...pageResults);
|
||||||
|
logger.log(`Extracted ${pageResults.length} items from page ${currentPage}`);
|
||||||
|
|
||||||
|
// 模拟人类行为 - 翻页前
|
||||||
|
logger.log('Simulating human mouse movements before pagination...');
|
||||||
|
await simulateHumanMouseMovement(page);
|
||||||
|
|
||||||
|
logger.log('Simulating human scrolling before pagination...');
|
||||||
|
await simulateHumanScrolling(page);
|
||||||
|
|
||||||
|
// 查找下一页按钮 - 根据网站实际结构调整选择器
|
||||||
|
// 分页结构: <a href="javascript:void(0);" onclick="turnPage(2);">下一页</a>
|
||||||
|
const nextButtonSelector = 'a[onclick*="turnPage"]';
|
||||||
|
const nextButton = await page.$(nextButtonSelector);
|
||||||
|
|
||||||
|
if (!nextButton) {
|
||||||
|
logger.log('Next page button not found. Reached end of list.');
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.log(`Navigating to page ${currentPage + 1}...`);
|
||||||
|
|
||||||
|
try {
|
||||||
|
// 点击下一页按钮,等待页面更新
|
||||||
|
await nextButton.click();
|
||||||
|
await new Promise(r => setTimeout(r, 3000)); // 等待页面加载
|
||||||
|
} catch (navError) {
|
||||||
|
logger.error(`Navigation to page ${currentPage + 1} failed: ${navError.message}`);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
currentPage++;
|
||||||
|
|
||||||
|
// 模拟人类行为 - 翻页后
|
||||||
|
logger.log('Simulating human mouse movements after pagination...');
|
||||||
|
await simulateHumanMouseMovement(page);
|
||||||
|
|
||||||
|
logger.log('Simulating human scrolling after pagination...');
|
||||||
|
await simulateHumanScrolling(page);
|
||||||
|
|
||||||
|
// Random delay between pages
|
||||||
|
const delay = Math.floor(Math.random() * (3000 - 1000 + 1)) + 1000;
|
||||||
|
await new Promise(resolve => setTimeout(resolve, delay));
|
||||||
|
}
|
||||||
|
|
||||||
|
return allResults;
|
||||||
|
|
||||||
|
} catch (error) {
|
||||||
|
logger.error(`Failed to crawl ${this.name}: ${error.message}`);
|
||||||
|
return allResults;
|
||||||
|
} finally {
|
||||||
|
await page.close();
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
extract(html: string): PowerbeijingResult[] {
|
||||||
|
const results: PowerbeijingResult[] = [];
|
||||||
|
/**
|
||||||
|
* Regex groups for powerbeijing-ec.com:
|
||||||
|
* 1: URL (href属性)
|
||||||
|
* 2: Title (title属性)
|
||||||
|
* 3: Date (发布时间,格式:2026-01-09)
|
||||||
|
*
|
||||||
|
* HTML结构示例:
|
||||||
|
* <li>
|
||||||
|
* <a href="https://www.powerbeijing-ec.com/biddingBulletin/2026-01-09/302075.html"
|
||||||
|
* title="内蒙古京隆发电有限责任公司#1、#2机组锅炉受热面、空预器、MGGH高压水冲洗招标公告">
|
||||||
|
* <h1>内蒙古京隆发电有限责任公司#1、#2机组锅炉受热面、空预器、MGGH高压水冲洗招标公告</h1>
|
||||||
|
* <div class="newsDate">
|
||||||
|
* <div>2026-01-09</div>
|
||||||
|
* </div>
|
||||||
|
* </a>
|
||||||
|
* </li>
|
||||||
|
*/
|
||||||
|
const regex = /<li>[\s\S]*?<a[^>]*href="([^"]*)"[^>]*title="([^"]*)"[^>]*>[\s\S]*?<div class="newsDate">[\s\S]*?<div>\s*(\d{4}-\d{2}-\d{2})\s*<\/div>[\s\S]*?<\/div>[\s\S]*?<\/a>[\s\S]*?<\/li>/gs;
|
||||||
|
|
||||||
|
let match;
|
||||||
|
while ((match = regex.exec(html)) !== null) {
|
||||||
|
const url = match[1]?.trim();
|
||||||
|
const title = match[2]?.trim();
|
||||||
|
const dateStr = match[3]?.trim();
|
||||||
|
|
||||||
|
if (title && url) {
|
||||||
|
results.push({
|
||||||
|
title,
|
||||||
|
publishDate: dateStr ? new Date(dateStr) : new Date(),
|
||||||
|
url: url.startsWith('http') ? url : this.baseUrl + url
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return results;
|
||||||
|
}
|
||||||
|
};
|
||||||
Reference in New Issue
Block a user