n8n blueprint para inmobiliaria: WhatsApp + CRM + listings IA con Qdrant y Ollama

  Lead entra por WhatsApp (CTA en anuncios, web, FB ads)
        │
        ▼
  ┌────────────────────────────────────────────────┐
  │ n8n flujo 1: Atención al cliente WhatsApp      │
  │   Webhook WA ─► extract intent ─► routing      │
  │        ├─ "busco casa"  ─► flow-search         │
  │        ├─ "cuánto cuesta X" ─► flow-price      │
  │        ├─ "quiero visitar" ─► flow-schedule    │
  │        └─ otros ─► flow-handoff                │
  └────────────────────────────────────────────────┘
        │
        ▼
  ┌────────────────────────────────────────────────┐
  │ flow-search                                    │
  │   ├─ parse query ─► slots {ciudad, rango, recámaras, tipo}
  │   ├─ Qdrant.search híbrido sobre propiedades   │
  │   ├─ rerank top-20 → 5                         │
  │   └─ enviar tarjetas WA con imagen + enlace    │
  └────────────────────────────────────────────────┘
        │
        ▼
  ┌────────────────────────────────────────────────┐
  │ flow-schedule                                  │
  │   ├─ MCP calendar.find_slot                    │
  │   ├─ confirm slot con usuario                  │
  │   ├─ create_event + add to CRM                 │
  │   └─ confirmar por WhatsApp + Email agent      │
  └────────────────────────────────────────────────┘
        │
        ▼
  ┌────────────────────────────────────────────────┐
  │ n8n flujo 2: Indexación automática             │
  │   Cron 30min ─► consulta CRM / Google Sheet    │
  │     ├─ nuevas propiedades ─► Ollama describe   │
  │     ├─ embed y upsert a Qdrant                 │
  │     └─ publicar a canales (web, portal, FB)    │
  └────────────────────────────────────────────────┘
        │
        ▼
  ┌────────────────────────────────────────────────┐
  │ n8n flujo 3: Recalificación de leads (semanal) │
  │   Cron domingo 22:00 ─► leer CRM contactos     │
  │     ├─ LLM scoring ─► hot/warm/cold            │
  │     ├─ a hot → seq 3 mensajes WA               │
  │     ├─ a warm → seq email                      │
  │     └─ métricas a Langfuse                     │
  └────────────────────────────────────────────────┘

services:
  n8n:
    image: n8nio/n8n:1.70
    restart: unless-stopped
    environment:
      DB_TYPE: postgresdb
      DB_POSTGRESDB_HOST: langfuse-db
      DB_POSTGRESDB_DATABASE: n8n
      DB_POSTGRESDB_USER: lf
      DB_POSTGRESDB_PASSWORD: ${LF_DB_PASSWORD}
      N8N_ENCRYPTION_KEY: ${N8N_ENCRYPTION_KEY}
      N8N_HOST: n8n.${DOMAIN}
      WEBHOOK_URL: https://n8n.${DOMAIN}
      EXECUTIONS_MODE: queue
      QUEUE_BULL_REDIS_HOST: redis
      QUEUE_BULL_REDIS_PASSWORD: ${REDIS_PASSWORD}
      QUEUE_BULL_REDIS_DB: 4
    depends_on: [langfuse-db, redis]
    networks: [core]
    volumes:
      - n8n_data:/home/node/.n8n

{
  "nodes": [
    {
      "type": "n8n-nodes-base.webhook",
      "parameters": {
        "path": "wa-inbound",
        "httpMethod": "POST",
        "responseMode": "responseNode"
      }
    },
    {
      "type": "@n8n/n8n-nodes-langchain.agent",
      "name": "Intent Router",
      "parameters": {
        "systemPrompt": "Eres un clasificador de intent para una inmobiliaria. Clasifica el mensaje en: search, price, schedule, contact_agent, other. Devuelve JSON {intent: string, slots: object}",
        "model": "litellm/claude-haiku",
        "temperature": 0
      }
    },
    {
      "type": "n8n-nodes-base.switch",
      "parameters": {
        "rules": [
          {"value": "search", "output": 0},
          {"value": "price", "output": 1},
          {"value": "schedule", "output": 2},
          {"value": "contact_agent", "output": 3}
        ]
      }
    }
  ]
}

const { city, bedrooms, max_price, property_type } = $json.slots;

const filter = {
  must: [
    { key: "city", match: { value: city } },
    { key: "bedrooms", range: { gte: bedrooms || 1 } },
    { key: "price", range: { lte: max_price || 100000000 } },
  ]
};

const embeddedQuery = await $('Embedder').first().json.embedding;

const body = {
  vector: embeddedQuery,
  filter,
  limit: 20,
  with_payload: true,
};

return body;

// node: "Rerank"
const items = $input.all();
const query = $('Webhook').first().json.text;

const pairs = items.map(i => ({ query, text: i.payload.description }));
const resp = await $helpers.httpRequest({
  method: "POST",
  url: "http://ollama:11434/api/generate",
  body: {
    model: "bge-reranker:v2-m3",
    stream: false,
    input: pairs,
  },
  json: true,
});

return resp.scores
  .map((s, i) => ({ ...items[i], score: s }))
  .sort((a, b) => b.score - a.score)
  .slice(0, 5);

// node: "Generate Description"
const prop = $json;

const prompt = `Eres un redactor inmobiliario en español mexicano.
Genera una descripción de 80-120 palabras, tono cálido y profesional, para este listado:
Tipo: ${prop.type}
Colonia: ${prop.neighborhood}
Ciudad: ${prop.city}
Recámaras: ${prop.bedrooms}
Baños: ${prop.bathrooms}
m²: ${prop.m2}
Precio: ${prop.price}
Amenidades: ${prop.amenities.join(", ")}

Reglas:
- No exageres. No uses superlativos huecos.
- Menciona 2 diferenciadores concretos.
- Termina con un CTA suave.
- Nada de emojis.`;

const resp = await $helpers.httpRequest({
  method: "POST",
  url: "http://ollama:11434/api/generate",
  body: { model: "llama3.3:8b-instruct-q4_K_M", prompt, stream: false },
  json: true,
});
return { ...prop, description: resp.response.trim() };

// node: "Embed & Upsert to Qdrant"
const emb = await embed(prop.description + " " + prop.title);
await qdrant.upsert("properties", [{
  id: prop.id,
  vector: emb,
  payload: {
    title: prop.title,
    description: prop.description,
    city: prop.city,
    bedrooms: prop.bedrooms,
    bathrooms: prop.bathrooms,
    price: prop.price,
    url: prop.url,
    images: prop.images,
    indexed_at: new Date().toISOString(),
  }
}]);

Dado el perfil del contacto y su historial de interacciones:
{contact_json}

Último intercambio:
{last_messages}

Clasifica como hot / warm / cold y devuelve JSON {score, reason, next_action}.