8
n8n 中文网amn8n.com

LeadFusion - AI线索丰富工作流

中级

这是一个Content Creation, Multimodal AI领域的自动化工作流，包含 13 个节点。主要使用 If, Code, Hubspot, Pipedrive, Agent 等节点。 基于GPT-4o的AI线索评分与丰富（从Mailchimp到HubSpot和Pipedrive）

前置要求
  • •HubSpot API Key
  • •OpenAI API Key

使用的节点 (13)

If
Code
Hubspot
Pipedrive
StickyNote
Agent
MailchimpTrigger
LmChatOpenAi

分类

内容创作
多模态 AI
工作流预览
可视化展示节点连接关系，支持缩放和平移
React Flow
导出工作流
复制以下 JSON 配置到 n8n 导入，即可使用此工作流
{
  "meta": {
    "templateCredsSetupCompleted": false
  },
  "name": "LeadFusion - AI 线索丰富工作流",
  "tags": [],
  "nodes": [
    {
      "id": "61b4b6d1-48c9-485a-be3a-86ce40129b82",
      "name": "📩 Mailchimp 订阅者触发器",
      "type": "n8n-nodes-base.mailchimpTrigger",
      "position": [
        -416,
        272
      ],
      "webhookId": "auto-generated",
      "parameters": {
        "list": "YOUR_MAILCHIMP_LIST_ID",
        "events": [
          "subscribe"
        ],
        "sources": [
          "admin"
        ]
      },
      "credentials": {
        "mailchimpApi": {
          "id": "MAILCHIMP_CREDENTIAL_ID",
          "name": "Mailchimp Account"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "02f90776-c4f6-498d-9b59-a3adf441aec0",
      "name": "📊 提取订阅者数据",
      "type": "n8n-nodes-base.code",
      "position": [
        -192,
        272
      ],
      "parameters": {
        "jsCode": "// n8n Code node (JavaScript)\nconst output = [];\n\nfor (const item of items) {\n  const data = item.json;\n\n  const firstName = data[\"data[merges][FNAME]\"] || \"\";\n  const lastName = data[\"data[merges][LNAME]\"] || \"\";\n\n  output.push({\n    email: data[\"data[email]\"] || \"\",\n    firstName,\n    lastName,\n    fullName: `${firstName} ${lastName}`.trim(),\n    tags: [],\n    listId: data[\"data[list_id]\"] || \"\",\n    subscribedAt: new Date(data[\"fired_at\"]).toISOString()\n  });\n}\n\nreturn output.map(o => ({ json: o }));"
      },
      "typeVersion": 2
    },
    {
      "id": "b5a3ce32-5793-442e-bbe3-4c6fd44c6779",
      "name": "🤖 线索丰富 AI",
      "type": "@n8n/n8n-nodes-langchain.agent",
      "position": [
        32,
        272
      ],
      "parameters": {
        "text": "=You are an expert lead enrichment AI. Based on the provided email and name, enrich the lead with likely professional information and provide a lead score.  \n\nInput:  \nEmail: {{ $json.email }}  \nName: {{ $json.fullName }}  \n\nOutput:  \nRespond only in valid JSON format with the following keys:  \n- company  \n- jobTitle  \n- industry  \n- linkedinUrl  \n- intent  \n- leadScore (1-100, based on email domain and name quality)  \n- confidence (1-100, accuracy of enrichment guess)",
        "options": {},
        "promptType": "define"
      },
      "typeVersion": 2.2
    },
    {
      "id": "85488739-d25a-4b83-8116-0c42f8638869",
      "name": "🧠 OpenAI 模型",
      "type": "@n8n/n8n-nodes-langchain.lmChatOpenAi",
      "position": [
        96,
        496
      ],
      "parameters": {
        "model": {
          "__rl": true,
          "mode": "list",
          "value": "gpt-4o-mini"
        },
        "options": {}
      },
      "credentials": {
        "openAiApi": {
          "id": "OPENAI_CREDENTIAL_ID",
          "name": "OpenAI Account"
        }
      },
      "typeVersion": 1.2
    },
    {
      "id": "91ef7930-18a9-4fe8-855c-8f486d527934",
      "name": "🔎 解析与合并丰富数据",
      "type": "n8n-nodes-base.code",
      "position": [
        384,
        272
      ],
      "parameters": {
        "jsCode": "// Parse OpenAI response and merge with original subscriber data\nconst item = $input.first();\n\n// Fallback: take current input if node not found\nlet subscriberData = {};\ntry {\n  subscriberData = $node['Extract Subscriber Data']?.json || item.json;\n} catch (e) {\n  subscriberData = item.json;\n}\n\nlet enrichedData = {\n  company: 'Unknown Company',\n  jobTitle: 'Unknown Role',\n  industry: 'Unknown Industry',\n  linkedinUrl: '',\n  intent: 'General interest',\n  leadScore: 50,\n  confidence: 30\n};\n\n// Try to parse OpenAI response (already JSON)\ntry {\n  const openaiResponse = item.json;\n  let content = openaiResponse.output || openaiResponse;\n\n  if (typeof content === 'string') {\n    content = content.replace(/```json|```/g, '').trim();\n    content = JSON.parse(content);\n  }\n\n  enrichedData = { ...enrichedData, ...content };\n} catch (error) {\n  // Parsing failed – keep defaults\n}\n\nconst finalData = {\n  ...subscriberData,\n  ...enrichedData,\n  enrichedAt: new Date().toISOString()\n};\n\nreturn { json: finalData };"
      },
      "typeVersion": 2
    },
    {
      "id": "c9240bca-e758-4e90-8c89-39a57a50fa8b",
      "name": "💎 高价值线索检查",
      "type": "n8n-nodes-base.if",
      "position": [
        608,
        80
      ],
      "parameters": {
        "options": {},
        "conditions": {
          "options": {
            "version": 1,
            "leftValue": "",
            "caseSensitive": true,
            "typeValidation": "strict"
          },
          "combinator": "and",
          "conditions": [
            {
              "id": "condition-1",
              "operator": {
                "type": "number",
                "operation": "gte"
              },
              "leftValue": "={{ $json.leadScore }}",
              "rightValue": 70
            }
          ]
        }
      },
      "typeVersion": 2
    },
    {
      "id": "3374813d-ee35-4f65-9ac7-c2c257897996",
      "name": "📊 HubSpot 联系人同步",
      "type": "n8n-nodes-base.hubspot",
      "position": [
        608,
        416
      ],
      "parameters": {
        "email": "={{ $('📊 Extract Subscriber Data').item.json.email }}",
        "options": {},
        "authentication": "appToken",
        "additionalFields": {
          "industry": "={{ $json.industry }}",
          "jobTitle": "={{ $json.jobTitle }}",
          "lastName": "={{ $('📊 Extract Subscriber Data').item.json.lastName }}",
          "firstName": "={{ $('📊 Extract Subscriber Data').item.json.firstName }}",
          "companyName": "={{ $json.company }}"
        }
      },
      "credentials": {
        "hubspotAppToken": {
          "id": "HUBSPOT_CREDENTIAL_ID",
          "name": "HubSpot Account"
        }
      },
      "typeVersion": 2,
      "continueOnFail": true
    },
    {
      "id": "8c30c26c-1374-446e-979c-e99d1b41a10a",
      "name": "👤 Pipedrive 人员创建",
      "type": "n8n-nodes-base.pipedrive",
      "position": [
        608,
        608
      ],
      "parameters": {
        "name": "={{ $('📊 Extract Subscriber Data').item.json.fullName }}",
        "resource": "person",
        "additionalFields": {
          "email": [
            "={{ $('📊 Extract Subscriber Data').item.json.email }}"
          ]
        }
      },
      "credentials": {
        "pipedriveApi": {
          "id": "PIPEDRIVE_CREDENTIAL_ID",
          "name": "Pipedrive Account"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "4047aced-ec20-4d6b-9173-1062fa71a06e",
      "name": "💼 创建高价值交易",
      "type": "n8n-nodes-base.pipedrive",
      "position": [
        832,
        80
      ],
      "parameters": {
        "title": "=High Value Lead - {{ $('📊 Extract Subscriber Data').item.json.fullName }}",
        "person_id": null,
        "associateWith": "person",
        "additionalFields": {
          "value": "={{ Math.round($json.leadScore * 10) }}",
          "status": "open",
          "currency": "USD"
        }
      },
      "credentials": {
        "pipedriveApi": {
          "id": "PIPEDRIVE_CREDENTIAL_ID",
          "name": "Pipedrive Account"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "1e8ea15c-3d79-4c75-acdb-9ea1b71a7feb",
      "name": "便签",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -480,
        -112
      ],
      "parameters": {
        "color": 5,
        "width": 448,
        "height": 896,
        "content": "## 1. 线索捕获与订阅者数据提取"
      },
      "typeVersion": 1
    },
    {
      "id": "49498336-18bc-408d-92e2-4c06ce6f6f56",
      "name": "便签1",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -16,
        -112
      ],
      "parameters": {
        "color": 3,
        "width": 528,
        "height": 896,
        "content": "## 2. AI 驱动的线索丰富"
      },
      "typeVersion": 1
    },
    {
      "id": "9d037fa7-614b-413f-a166-0c30efcd6b7a",
      "name": "便签2",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        528,
        -112
      ],
      "parameters": {
        "color": 4,
        "width": 480,
        "height": 368,
        "content": "## 3. 线索资格评定与评分"
      },
      "typeVersion": 1
    },
    {
      "id": "b3befa0e-e2c3-4c49-98db-8276134f2478",
      "name": "便签3",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        528,
        272
      ],
      "parameters": {
        "width": 480,
        "height": 512,
        "content": "## 4. CRM 同步与交易创建"
      },
      "typeVersion": 1
    }
  ],
  "active": false,
  "pinData": {},
  "settings": {
    "executionOrder": "v1"
  },
  "connections": {
    "🧠 OpenAI Model": {
      "ai_languageModel": [
        [
          {
            "node": "🤖 Lead Enrichment AI",
            "type": "ai_languageModel",
            "index": 0
          }
        ]
      ]
    },
    "🤖 Lead Enrichment AI": {
      "main": [
        [
          {
            "node": "🔎 Parse & Merge Enrichment",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "📊 HubSpot Contact Sync": {
      "main": [
        []
      ]
    },
    "💎 High-Value Lead Check": {
      "main": [
        [
          {
            "node": "💼 Create High-Value Deal",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "👤 Pipedrive Person Create": {
      "main": [
        []
      ]
    },
    "📊 Extract Subscriber Data": {
      "main": [
        [
          {
            "node": "🤖 Lead Enrichment AI",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "🔎 Parse & Merge Enrichment": {
      "main": [
        [
          {
            "node": "💎 High-Value Lead Check",
            "type": "main",
            "index": 0
          },
          {
            "node": "📊 HubSpot Contact Sync",
            "type": "main",
            "index": 0
          },
          {
            "node": "👤 Pipedrive Person Create",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "📩 Mailchimp Subscriber Trigger": {
      "main": [
        [
          {
            "node": "📊 Extract Subscriber Data",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}
常见问题

如何使用这个工作流？

复制上方的 JSON 配置代码，在您的 n8n 实例中创建新工作流并选择「从 JSON 导入」，粘贴配置后根据需要修改凭证设置即可。

这个工作流适合什么场景？

中级 - 内容创作, 多模态 AI

需要付费吗？

本工作流完全免费，您可以直接导入使用。但请注意，工作流中使用的第三方服务（如 OpenAI API）可能需要您自行付费。

相关工作流推荐

AI驱动的WordPress内容工作流
使用OpenAI GPT自动化从PostgreSQL到WordPress的博客发布
If
Code
Postgres
+5
12 节点Avkash Kakdiya
内容创作
12 - 智能潜在客户信息增强器
基于AI的潜在客户信息增强：从Typeform和Calendly到HubSpot CRM
If
Code
Merge
+6
13 节点Avkash Kakdiya
AI 摘要总结
15 - LeadFlow 自动化
使用OpenAI GPT-4O、HubSpot、Slack和Google Sheets自动化Gmail潜在客户跟进
If
Set
Code
+7
14 节点Avkash Kakdiya
AI 摘要总结
09 - 潜在客户档案增强器
自动化潜在客户信息丰富与个性化外联：HubSpot、Phantombuster和GPT
If
Set
Code
+11
30 节点Avkash Kakdiya
客户培育
13 - SmartScore 智能评分引擎
Typeform到HubSpot：GPT-4o-mini AI增强评分潜在客户
If
Code
Hubspot
+6
17 节点Avkash Kakdiya
AI 摘要总结
Linear Bug 自动路由
使用 GPT-4-mini 分类实现 Linear 问题自动路由
If
Linear
Switch
+4
17 节点Avkash Kakdiya
内容创作
工作流信息
难度等级
中级
节点数量13
分类2
节点类型8
难度说明

适合有一定经验的用户，包含 6-15 个节点的中等复杂度工作流

作者
Avkash Kakdiya

Avkash Kakdiya

@itechnotion

🚀 Founder of iTechNotion — we build custom AI-powered automation workflows for startups, agencies, and founders. 💡 Specializing in agentic AI systems, content automation, sales funnels, and digital workers. 🔧 14+ years in tech | Building scalable no-code/low-code solutions using n8n, OpenAI, and other API-first tools. 📬 Let’s automate what slows you down.

外部链接
在 n8n.io 查看 →

分享此工作流