Cách Xây Dựng Quy Trình Tạo Dẫn B2B Thông Minh với n8n và Scrapeless

"Các công ty phần mềm" "khách hàng doanh nghiệp" nhân viên:50-200
"Các công ty marketing" "dịch vụ B2B" "chuyển đổi số"
"Các công ty khởi nghiệp SaaS" "Series A" "được đầu tư mạo hiểm"
"Các công ty sản xuất" "giải pháp số" ISO

[
  {
    "markdown": "# Trang Chủ Công Ty\n\nChào mừng đến với công ty của chúng tôi...",
    "metadata": {
      "title": "Tên Công Ty - Trang Chủ",
      "description": "Mô tả công ty",
      "sourceURL": "https://company.com"
    }
  }
]

console.log("=== ĐANG XỬ LÝ DỮ LIỆU TRÌNH THU THẬP SCRAPELESS ===");

try {
  // Dữ liệu đến dưới dạng một mảng
  const crawlerDataArray = $json;
  
  console.log("Loại dữ liệu:", typeof crawlerDataArray);
  console.log("Có phải là mảng:", Array.isArray(crawlerDataArray));
  console.log("Độ dài mảng:", crawlerDataArray?.length || 0);
  
  // Kiểm tra xem mảng có rỗng không
  if (!Array.isArray(crawlerDataArray) || crawlerDataArray.length === 0) {
    console.log("❌ Dữ liệu thu thập rỗng hoặc không hợp lệ");
    return {
      url: "không xác định",
      company_name: "Không có Dữ liệu",
      content: "",
      error: "Phản hồi thu thập rỗng",
      processing_failed: true,
      skip_reason: "Không có dữ liệu được trả về từ trình thu thập"
    };
  }
  
  // Lấy phần tử đầu tiên từ mảng
  const crawlerResponse = crawlerDataArray[0];
  
  // Trích xuất nội dung markdown
  const markdownContent = crawlerResponse?.markdown || "";
  
  // Trích xuất metadata (nếu có)
  const metadata = crawlerResponse?.metadata || {};
  
  // Thông tin cơ bản
  const sourceURL = metadata.sourceURL || metadata.url || extractURLFromContent(markdownContent);
  const companyName = metadata.title || metadata.ogTitle || extractCompanyFromContent(markdownContent);
  const description = metadata.description || metadata.ogDescription || "";
  
  console.log(`Đang xử lý: ${companyName}`);
  console.log(`URL: ${sourceURL}`);
  console.log(`Độ dài nội dung: ${markdownContent.length} ký tự`);
  
  // Xác minh chất lượng nội dung

if (!markdownContent || markdownContent.length < 100) {
    return {
      url: sourceURL,
      company_name: companyName,
      content: "",
      error: "Nội dung từ trình thu thập không đủ",
      processing_failed: true,
      raw_content_length: markdownContent.length,
      skip_reason: "Nội dung quá ngắn hoặc trống"
    };
  }
  
  // Làm sạch và cấu trúc nội dung markdown
  let cleanedContent = cleanMarkdownContent(markdownContent);
  
  // Trích xuất thông tin liên hệ
  const contactInfo = extractContactInformation(cleanedContent);
  
  // Trích xuất các phần quan trọng của doanh nghiệp
  const businessSections = extractBusinessSections(cleanedContent);
  
  // Xây dựng nội dung cho Claude AI
  const contentForAI = buildContentForAI({
    companyName,
    sourceURL,
    description,
    businessSections,
    contactInfo,
    cleanedContent
  });
  
  // Đánh giá chất lượng nội dung
  const contentQuality = assessContentQuality(cleanedContent, contactInfo);
  
  const result = {
    url: sourceURL,
    company_name: companyName,
    content: contentForAI,
    raw_content_length: markdownContent.length,
    processed_content_length: contentForAI.length,
    extracted_emails: contactInfo.emails,
    extracted_phones: contactInfo.phones,
    content_quality: contentQuality,
    metadata_info: {
      has_title: !!metadata.title,
      has_description: !!metadata.description,
      site_name: metadata.ogSiteName || "",
      page_title: metadata.title || ""
    },
    processing_timestamp: new Date().toISOString(),
    processing_status: "THÀNH CÔNG"
  };
  
  console.log(`✅ Xử lý thành công ${companyName}`);
  return result;
  
} catch (error) {
  console.error("❌ Lỗi khi xử lý dữ liệu từ trình thu thập:", error);
  return {
    url: "không xác định",
    company_name: "Lỗi xử lý",
    content: "",
    error: error.message,
    processing_failed: true,
    processing_timestamp: new Date().toISOString()
  };
}

// ========== CÁC HÀM TIỆN ÍCH ==========

function extractURLFromContent(content) {
  // Cố gắng trích xuất URL từ nội dung markdown
  const urlMatch = content.match(/https?:\/\/[^\s\)]+/);
  return urlMatch ? urlMatch[0] : "không xác định";
}

function extractCompanyFromContent(content) {
  // Cố gắng trích xuất tên công ty từ nội dung
  const titleMatch = content.match(/^#\s+(.+)$/m);
  if (titleMatch) return titleMatch[1];
  
  // Tìm kiếm email để trích xuất miền
  const emailMatch = content.match(/@([a-zA-Z0-9.-]+\.[a-zA-Z]{2,})/);
  if (emailMatch) {
    const domain = emailMatch[1].replace('www.', '');
    return domain.split('.')[0].charAt(0).toUpperCase() + domain.split('.')[0].slice(1);
  }
  
  return "Công ty không xác định";
}

function cleanMarkdownContent(markdown) {
  return markdown
    // Xóa các phần tử điều hướng
    .replace(/^\[Bỏ qua nội dung\].*$/gmi, '')
    .replace(/^\[.*\]\(#.*\)$/gmi, '')
    // Xóa các liên kết markdown nhưng giữ lại văn bản
    .replace(/\[([^\]]+)\]\([^)]+\)/g, '$1')
    // Xóa hình ảnh và base64
    .replace(/!\[([^\]]*)\]\([^)]*\)/g, '')
    .replace(/<Base64-Image-Removed>/g, '')
    // Xóa các đề cập đến cookie/riêng tư
    .replace(/.*?(cookie|chính sách bảo mật|điều khoản dịch vụ).*?\n/gi, '')
    // Làm sạch các khoảng trắng
    .replace(/\s+/g, ' ')
    // Xóa nhiều dòng trống
    .replace(/\n\s*\n\s*\n/g, '\n\n')
    .trim();
}

function extractContactInformation(content) {
  // Regex để tìm email
  const emailRegex = /[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\.[a-zA-Z]{2,}/g;
  
  // Regex để tìm số điện thoại (hỗ trợ quốc tế)
  const phoneRegex = /(?:\+\d{1,3}\s?)?\d{3}\s?\d{3}\s?\d{3,4}|\(\d{3}\)\s?\d{3}-?\d{4}/g;
  
  const emails = [...new Set((content.match(emailRegex) || [])
    .filter(email => !email.includes('example.com'))
    .slice(0, 3))];
  
  const phones = [...new Set((content.match(phoneRegex) || [])
    .filter(phone => phone.replace(/\D/g, '').length >= 9)
    .slice(0, 2))];
  
  return { emails, phones };
}

function extractBusinessSections(content) {
  const sections = {};
  
  // Tìm kiếm các phần quan trọng
  const lines = content.split('\n');
  let currentSection = '';
  let currentContent = '';
  
  for (let i = 0; i < lines.length; i++) {
    const line = lines[i].trim();
    
    // Phát hiện tiêu đề
    if (line.startsWith('#')) {
      // Lưu phần trước đó
      if (currentSection && currentContent) {
        sections[currentSection] = currentContent.trim().substring(0, 500);
      }
      
      // Phần mới
      const title = line.replace(/^#+\s*/, '').toLowerCase();
      if (title.includes('giới thiệu') || title.includes('dịch vụ') || 
          title.includes('liên hệ') || title.includes('công ty')) {
        currentSection = title.includes('giới thiệu') ? 'about' :
                        title.includes('dịch vụ') ? 'services' :
                        title.includes('liên hệ') ? 'contact' : 'company';
        currentContent = '';
      } else {
        currentSection = '';
      }
    } else if (currentSection && line) {
      currentContent += line + '\n';
    }

}
  
  // Lưu phần cuối cùng
  nếu (currentSection && currentContent) {
    sections[currentSection] = currentContent.trim().substring(0, 500);
  }
  
  return sections;
}

function buildContentForAI({ companyName, sourceURL, description, businessSections, contactInfo, cleanedContent }) {
  let aiContent = `YÊU CẦU PHÂN TÍCH CÔNG TY\n\n`;
  aiContent += `Công ty: ${companyName}\n`;
  aiContent += `Trang web: ${sourceURL}\n`;
  
  nếu (description) {
    aiContent += `Mô tả: ${description}\n`;
  }
  
  aiContent += `\nTHÔNG TIN LIÊN HỆ:\n`;
  nếu (contactInfo.emails.length > 0) {
    aiContent += `Email: ${contactInfo.emails.join(', ')}\n`;
  }
  nếu (contactInfo.phones.length > 0) {
    aiContent += `Số điện thoại: ${contactInfo.phones.join(', ')}\n`;
  }
  
  aiContent += `\nCÁC PHẦN KINH DOANH:\n`;
  cho (const [section, content] of Object.entries(businessSections)) {
    nếu (content) {
      aiContent += `\n${section.toUpperCase()}:\n${content}\n`;
    }
  }
  
  // Thêm nội dung chính (giới hạn)
  aiContent += `\nXEM TRƯỚC NỘI DUNG ĐẦY ĐỦ:\n`;
  aiContent += cleanedContent.substring(0, 2000);
  
  // Giới hạn cuối cùng cho API Claude
  return aiContent.substring(0, 6000);
}

function assessContentQuality(content, contactInfo) {
  const wordCount = content.split(/\s+/).length;
  
  return {
    word_count: wordCount,
    has_contact_info: contactInfo.emails.length > 0 || contactInfo.phones.length > 0,
    has_about_section: /about|company|who we are/gi.test(content),
    has_services_section: /services|products|solutions/gi.test(content),
    has_team_section: /team|leadership|staff/gi.test(content),
    content_richness_score: Math.min(10, Math.floor(wordCount / 50)),
    email_count: contactInfo.emails.length,
    phone_count: contactInfo.phones.length,
    estimated_quality: wordCount > 200 && contactInfo.emails.length > 0 ? "CAO" : 
                      wordCount > 100 ? "TRUNG BÌNH" : "THẤP"
  };
}

{
  "url": "https://company.com",
  "company_name": "Tên Công Ty",
  "content": "YÊU CẦU PHÂN TÍCH CÔNG TY\n\nCông ty: ...",
  "raw_content_length": 50000,
  "processed_content_length": 2500,
  "extracted_emails": ["contact@company.com"],
  "extracted_phones": ["+1-555-123-4567"],
  "content_quality": {
    "word_count": 5000,
    "has_contact_info": true,
    "estimated_quality": "CAO",
    "content_richness_score": 10
  },
  "processing_status": "THÀNH CÔNG"
}

Phân tích nội dung trang web công ty đã được xử lý này và trích xuất thông tin khách hàng B2B. Trả về CHỈ mã JSON hợp lệ:
URL Công ty: {{ $json.url }}
Tên Công Ty: {{ $json.company_name }}
Nội dung Trang Web Đã Được Xử Lý: {{ $json.content }}
Đánh giá Chất lượng Nội dung: {{ $json.content_quality }}
Thông tin liên hệ đã được trích xuất trước:
Email: {{ $json.extracted_emails }}
Số điện thoại: {{ $json.extracted_phones }}
Thông tin Metadata: {{ $json.metadata_info }}

Cấu trúc yêu cầu giúp việc lọc trở nên đáng tin cậy hơn vì Claude giờ nhận đầu vào có cấu trúc nhất quán. Điều này dẫn đến các điểm số dẫn đầu chính xác hơn và quyết định đủ điều kiện tốt hơn trong bước tiếp theo của quy trình làm việc của bạn.

## Bước 7: Phân tích phản hồi AI Claude
Trước khi lọc các khách hàng tiềm năng, chúng ta cần phân tích phản hồi JSON của Claude AI, có thể được bọc trong định dạng markdown.

1. Thêm một nút Code sau AI Agent (Claude)
2. Cấu hình để phân tích và làm sạch phản hồi JSON của Claude


![Cấu hình phân tích phản hồi Claude](https://assets.scrapeless.com/prod/posts/build-b2b-lead-generation-workflow-with-n8n/aae4593790f5f1c5d34d43ecaf354e85.png)

### Cấu hình Nút Code

```javascript
console.log("Email liên hệ:", leadData.contact_email);

// Xác thực và làm sạch dữ liệu
const cleanedLead = {
    company_name: leadData.company_name || "Không xác định",
    industry: leadData.industry || null,
    company_size: leadData.company_size || null,
    location: leadData.location || null,
    contact_email: leadData.contact_email || null,
    phone: leadData.phone || null,
    key_services: Array.isArray(leadData.key_services) ? leadData.key_services : [],
    target_market: leadData.target_market || null,
    technologies: Array.isArray(leadData.technologies) ? leadData.technologies : [],
    funding_stage: leadData.funding_stage || null,
    business_model: leadData.business_model || null,
    social_presence: leadData.social_presence || { linkedin: null, twitter: null },
    lead_score: typeof leadData.lead_score === 'number' ? leadData.lead_score : 0,
    qualification_reasons: Array.isArray(leadData.qualification_reasons) ? leadData.qualification_reasons : [],
    decision_makers: Array.isArray(leadData.decision_makers) ? leadData.decision_makers : [],
    next_actions: Array.isArray(leadData.next_actions) ? leadData.next_actions : [],
    content_insights: leadData.content_insights || {},

    // Thông tin meta để lọc
    is_qualified: leadData.lead_score >= 6 && leadData.contact_email !== null,
    has_contact_info: !!(leadData.contact_email || leadData.phone),
    processing_timestamp: new Date().toISOString(),
    claude_processing_status: "THÀNH CÔNG"
};

console.log(✅ Dẫn đầu đã được xử lý: ${cleanedLead.company_name} (Điểm: ${cleanedLead.lead_score}, Đủ điều kiện: ${cleanedLead.is_qualified}));

return cleanedLead;

} catch (error) {
console.error("❌ Lỗi phân tích phản hồi Claude:", error);
console.error("Đầu ra thô:", $json.output);

// Phản hồi lỗi có cấu trúc
return {
    company_name: "Lỗi phân tích Claude",
    industry: null,
    company_size: null,
    location: null,
    contact_email: null,
    phone: null,
    key_services: [],
    target_market: null,
    technologies: [],
    funding_stage: null,
    business_model: null,
    social_presence: { linkedin: null, twitter: null },
    lead_score: 0,
    qualification_reasons: [Lỗi phân tích Claude: ${error.message}],
    decision_makers: [],
    next_actions: ["Sửa lỗi phân tích phản hồi Claude", "Kiểm tra định dạng JSON"],
    content_insights: {},
    is_qualified: false,
    has_contact_info: false,
    processing_timestamp: new Date().toISOString(),
    claude_processing_status: "THẤT BẠI",
    parsing_error: error.message,
    raw_claude_output: $json.output || "Không nhận được đầu ra"
};
}

// Tại sao thêm phân tích phản hồi Claude?
- Xử lý Markdown: Loại bỏ định dạng json từ phản hồi của Claude
- Kiểm tra dữ liệu: Đảm bảo tất cả các trường có kiểu và giá trị mặc định đúng
- Khôi phục lỗi: Xử lý lỗi phân tích JSON một cách nhẹ nhàng
- Chuẩn bị lọc: Thêm các trường được tính toán để dễ dàng lọc
- Hỗ trợ gỡ lỗi: Ghi lại toàn diện cho việc xử lý sự cố

![Kết quả phân tích Claude](https://assets.scrapeless.com/prod/posts/build-b2b-lead-generation-workflow-with-n8n/95a71f3004d783ad6b7b825f48c382ed.png)

## Bước 8: Lọc và Kiểm soát Chất lượng Dẫn đầu
Lọc các dẫn đầu dựa trên điểm số đủ điều kiện và tính đầy đủ của dữ liệu sử dụng dữ liệu đã phân tích và xác thực.

1. Thêm một nút IF sau bộ phân tích phản hồi Claude
2. Thiết lập tiêu chí đủ điều kiện được cải tiến

![Cấu hình lọc dẫn đầu](https://assets.scrapeless.com/prod/posts/build-b2b-lead-generation-workflow-with-n8n/ad0e0cc63715193510af41fc38841a52.png)

### Cấu hình nút IF mới

Bây giờ dữ liệu đã được phân tích đúng cách, hãy sử dụng các điều kiện này trong nút IF:

**1: Thêm nhiều điều kiện**

**Điều kiện 1:**
- Trường: {{ $json.lead_score }}
- Toán tử: bằng hoặc lớn hơn
- Giá trị: 6

**Điều kiện 2:**
- Trường: {{ $json.claude_processing_status }}
- Toán tử: bằng với
- Giá trị: THÀNH CÔNG

Tùy chọn: Chuyển đổi kiểu khi cần thiết
- ĐÚNG

![Cấu hình lọc dẫn đầu](https://assets.scrapeless.com/prod/posts/build-b2b-lead-generation-workflow-with-n8n/1942aa09d81e10b991722980288346f7.png)

### Lợi ích của việc lọc

- Đảm bảo chất lượng: Chỉ những dẫn đầu đủ điều kiện mới tiến tới lưu trữ
- Tối ưu hóa chi phí: Ngăn chặn việc xử lý các dẫn đầu có chất lượng thấp
- Tính toàn vẹn của dữ liệu: Đảm bảo dữ liệu đã được phân tích là hợp lệ trước khi lưu trữ
- Khả năng gỡ lỗi: Việc phân tích thất bại được phát hiện và ghi lại

## Bước 9: Lưu trữ Dẫn đầu trong Google Sheets
Lưu trữ các dẫn đầu đủ điều kiện trong cơ sở dữ liệu Google Sheets để dễ dàng truy cập và quản lý.

1. Thêm một nút Google Sheets sau bộ lọc
2. Cấu hình để thêm dẫn đầu mới
Tuy nhiên, bạn có thể chọn quản lý dữ liệu theo cách bạn muốn.

![Cấu hình Google Sheets](https://assets.scrapeless.com/prod/posts/build-b2b-lead-generation-workflow-with-n8n/8fb4f8fbfc0448e4b0577585cbfeec2a.png)

![Cấu hình Google Sheets](https://assets.scrapeless.com/prod/posts/build-b2b-lead-generation-workflow-with-n8n/32739a965efc954f6bca1aca4e712676.png)

**Cài đặt Google Sheets:**

{
  "embeds": [
    {
      "title": "🎯 Đã tìm thấy Khách hàng Tiềm năng Đủ điều kiện Mới!",
      "description": "**{{ $json.company_name || 'Công ty Không rõ' }}** (Điểm: {{ $json.lead_score || 0 }}/10)",
      "color": 3066993,
      "fields": [
        {
          "name": "Ngành nghề",
          "value": "{{ $json.industry || 'Không được chỉ định' }}",
          "inline": true
        },
        {
          "name": "Kích thước",
          "value": "{{ $json.company_size || 'Không được chỉ định' }}",
          "inline": true
        },
        {
          "name": "Địa điểm",
          "value": "{{ $json.location || 'Không được chỉ định' }}",
          "inline": true
        },
        {
          "name": "Liên hệ",
          "value": "{{ $json.contact_email || 'Không tìm thấy email' }}",
          "inline": false
        },
        {
          "name": "Điện thoại",
          "value": "{{ $json.phone || 'Không tìm thấy điện thoại' }}",
          "inline": false
        },
        {
          "name": "Dịch vụ",
          "value": "{{ $json.key_services && $json.key_services.length > 0 ? $json.key_services.slice(0, 3).join(', ') : 'Không được chỉ định' }}",
          "inline": false
        },
        {
          "name": "Trang web",
          "value": "[Truy cập Trang web]({{ $node['Code2'].json.url || '#' }})",
          "inline": false
        },
        {
          "name": "Tại sao Đủ điều kiện",
          "value": "{{ $json.qualification_reasons && $json.qualification_reasons.length > 0 ? $json.qualification_reasons.slice(0, 2).join(' • ') : 'Đã đáp ứng các tiêu chí đủ điều kiện tiêu chuẩn' }}",
          "inline": false
        }
      ],
      "footer": {
        "text": "Được tạo bởi Quy trình Tạo Khách hàng tiềm năng n8n"
      },
      "timestamp": ""
    }
  ]
}

"Các công ty SaaS" "phần mềm B2B" "phần mềm doanh nghiệp"
"phần mềm đám mây" "API" "nhà phát triển" "mô hình đăng ký"
"phần mềm như một dịch vụ" "nền tảng" "tích hợp"

"cơ quan tiếp thị kỹ thuật số" "tiếp thị B2B" "khách hàng doanh nghiệp"
"tự động hóa tiếp thị" "tạo nhu cầu" "tạo khách hàng tiềm năng"
"cơ quan tiếp thị nội dung" "tiếp thị tăng trưởng" "tiếp thị hiệu suất"

"các công ty thương mại điện tử" "bán lẻ trực tuyến" "thương hiệu D2C"
"Cửa hàng Shopify" "WooCommerce" "nền tảng thương mại điện tử"
"thị trường trực tuyến" "thương mại kỹ thuật số" "công nghệ bán lẻ"