┌─────────────────────────────────────────────────────────────────────────────┐
│                    การพัฒนา n8n MCP Server                                    │
├─────────────────────────────────────────────────────────────────────────────┤
│                                                                              │
│  ก่อน 4 พฤษภาคม 2026                       หลัง 4 พฤษภาคม 2026                │
│                                                                              │
│  ┌──────────────────┐                    ┌──────────────────┐            │
│  │  รัน Workflows   │                    │  สร้าง Workflows │            │
│  │  ที่มีอยู่       │                    │  ตั้งแต่เริ่มต้น │            │
│  │  ─────────────── │                    │  ────────────────│            │
│  │  • รัน workflows │                    │  • สร้าง nodes   │            │
│  │  • ส่งพารามิเตอร์│                    │  • เชื่อม flows  │            │
│  │  • รับผลลัพธ์  │                    │  • กำหนดค่า      │            │
│  │                  │                    │    parameters     │            │
│  └──────────────────┘                    │  • ตั้งค่า       │            │
│                                           │    credentials   │            │
│  จำกัดการรัน                               │  • เพิ่มการ       │            │
│  สิ่งที่สร้างไว้แล้ว                      │    จัดการข้อผิด  │            │
│                                           │    พลาด          │            │
│                                           │  • เพิ่มเงื่อนไข │            │
│                                           │  • สร้าง loops   │            │
│                                           │  • เพิ่มการ       │            │
│                                           │    scheduling    │            │
│                                           └──────────────────┘            │
│                                                                              │
│  "รัน workflow นี้"                       "สร้าง workflow ที่..."           │
│                                                                              │
└─────────────────────────────────────────────────────────────────────────────┘

// ลำดับการสนทนา MCP
const mcpWorkflow = {
  // 1. ผู้ใช้อธิบายสิ่งที่ต้องการ
  userPrompt: "สร้าง Workflow ที่ตรวจสอบร้านค้า Shopify ของฉันสำหรับคำสั่งซื้อใหม่, 
              ตรวจสอบสต็อกใน Airtable และส่งการแจ้งเตือน Slack หากสต็อกต่ำกว่า 10 ชิ้น
              เพิ่มการจัดการข้อผิดพลาดและรันทุก 15 นาที",
  
  // 2. Claude วิเคราะห์ความต้องการ
  claudeAnalysis: {
    triggers: ["Shopify webhook หรือ polling"],
    การดำเนินการ: ["ดึงข้อมูลคำสั่งซื้อ", "คิวรี่ Airtable", "ตรวจสอบ threshold", "ส่ง Slack"],
    การจัดการข้อผิดพลาด: ["Retry logic", "การแจ้งเตือน fallback"],
    scheduling: "ทุก 15 นาที"
  },
  
  // 3. Claude เรียกใช้ MCP Tools เพื่อสร้าง
  mcpCalls: [
    { tool: "create_node", params: { type: "n8n-nodes-base.shopifyTrigger", ... } },
    { tool: "create_node", params: { type: "n8n-nodes-base.airtable", ... } },
    { tool: "create_node", params: { type: "n8n-nodes-base.if", ... } },
    { tool: "create_node", params: { type: "n8n-nodes-base.slack", ... } },
    { tool: "connect_nodes", params: { from: "node1", to: "node2" } },
    // ... การเรียกอื่นๆ
  ],
  
  // 4. n8n ส่งคืน Workflow ที่สร้างเสร็จ
  result: "Workflow JSON สมบูรณ์พร้อม nodes ที่กำหนดค่าทั้งหมด"
};

// ใน n8n Settings → MCP Server
{
  "enabled": true,
  "port": 5678,
  "auth": {
    "type": "apiKey",
    "apiKey": "your-n8n-api-key"
  },
  "workflowBuilding": {
    "enabled": true,
    "allowNodeCreation": true,
    "allowConnectionModification": true,
    "allowedNodeTypes": ["all"], // หรือจำกัดเฉพาะบางประเภท
    "maxNodesPerWorkflow": 50
  }
}

// ~/Library/Application Support/Claude/claude_desktop_config.json (macOS)
// หรือเทียบเท่าบนระบบปฏิบัติการของคุณ
{
  "mcpServers": {
    "n8n": {
      "command": "npx",
      "args": [
        "-y",
        "@n8n/mcp-server"
      ],
      "env": {
        "N8N_API_KEY": "your-n8n-api-key",
        "N8N_HOST": "http://localhost:5678",
        "N8N_MCP_WORKFLOW_BUILDING": "true"
      }
    }
  }
}

// Claude คิดผ่านความต้องการ:
const workflowDesign = {
  nodes: [
    {
      name: "Gmail Trigger",
      type: "n8n-nodes-base.gmailTrigger",
      parameters: {
        event: "messageReceived",
        filters: {
          subjectContains: ["Lead:"]
        }
      }
    },
    {
      name: "ดึงข้อมูล Lead",
      type: "n8n-nodes-base.function",
      parameters: {
        functionCode: `
          const email = $input.first().json;
          const body = email.body;
          
          // แยกวิเคราะห์ชื่อและบริษัทจากอีเมล
          const nameMatch = body.match(/Name:\s*(.+)/i);
          const companyMatch = body.match(/Company:\s*(.+)/i);
          
          return [{
            json: {
              name: nameMatch ? nameMatch[1].trim() : null,
              company: companyMatch ? companyMatch[1].trim() : null,
              email: email.from,
              subject: email.subject,
              receivedAt: email.date
            }
          }];
        `
      }
    },
    {
      name: "ตรวจสอบฟิลด์ที่จำเป็น",
      type: "n8n-nodes-base.if",
      parameters: {
        conditions: {
          boolean: [
            {
              value1: "={{ $json.name }}",
              operation: "isNotEmpty"
            }
          ]
        }
      }
    },
    {
      name: "สร้าง HubSpot Contact",
      type: "n8n-nodes-base.hubspot",
      parameters: {
        resource: "contact",
        operation: "create",
        additionalFields: {
          email: "={{ $json.email }}",
          firstname: "={{ $json.name.split(' ')[0] }}",
          lastname: "={{ $json.name.split(' ').slice(1).join(' ') }}",
          company: "={{ $json.company }}"
        }
      },
      credentials: "hubspot-api"
    },
    {
      name: "จัดการข้อมูลที่ขาดหาย",
      type: "n8n-nodes-base.slack",
      parameters: {
        channel: "#leads-processing",
        text: "อีเมล Lead ขาดฟิลด์ที่จำเป็น ต้องตรวจสอบด้วยตนเอง"
      }
    },
    {
      name: "ตัวจัดการข้อผิดพลาด",
      type: "n8n-nodes-base.slack",
      parameters: {
        channel: "#errors",
        text: "การสร้าง HubSpot Contact ล้มเหลว: {{ $json.error }}"
      }
    }
  ],
  connections: {
    "Gmail Trigger": {
      main: [[{ node: "ดึงข้อมูล Lead", type: "main", index: 0 }]]
    },
    "ดึงข้อมูล Lead": {
      main: [[{ node: "ตรวจสอบฟิลด์ที่จำเป็น", type: "main", index: 0 }]]
    },
    "ตรวจสอบฟิลด์ที่จำเป็น": {
      main: [
        [{ node: "สร้าง HubSpot Contact", type: "main", index: 0 }],
        [{ node: "จัดการข้อมูลที่ขาดหาย", type: "main", index: 0 }]
      ]
    },
    "สร้าง HubSpot Contact": {
      main: [[{ node: "ตัวจัดการข้อผิดพลาด", type: "error", index: 0 }]]
    }
  }
};

// Claude เลือกประเภท Node ที่ดีที่สุดอย่างชาญฉลาดตามบริบท
function selectOptimalNode(requirement) {
  const nodeMapping = {
    // สำหรับ HTTP APIs พร้อม Auth ที่ซับซ้อน
    "REST API กับ OAuth": "httpRequest", // พร้อมประเภท Credential
    
    // สำหรับการดำเนินการฐานข้อมูล
    "PostgreSQL query": "postgres",
    "MongoDB aggregation": "mongoDb",
    "MySQL insert": "mySql",
    
    // สำหรับการส่งข้อความ
    "ส่งข้อความ Slack": "slack",
    "ส่งการแจ้งเตือน Discord": "discord",
    "ส่งอีเมลผ่าน SMTP": "sendEmail",
    
    // สำหรับการดำเนินการไฟล์
    "อ่าน CSV": "readBinaryFiles" + "spreadsheetFile",
    "เขียนลง S3": "s3",
    "อัปโหลด FTP": "ftp",
    
    // สำหรับ AI/ML
    "จำแนกด้วย OpenAI": "openAi",
    "สรุปข้อความ": "openAi" + "anthropic",
    "ดึง entities": "openAi" + "googleCloudNaturalLanguage",
    
    // สำหรับการตั้งเวลา
    "รันทุกชั่วโมง": "scheduleTrigger",
    "Webhook trigger": "webhook",
    "Manual trigger": "manualTrigger"
  };
  
  // ส่งคืน Node ที่เหมาะสมที่สุดพร้อมการกำหนดค่าที่เหมาะสมที่สุด
  return nodeMapping[requirement] || suggestCustomNode(requirement);
}

// เมื่อเชื่อมต่อ Shopify กับ Airtable Claude สร้าง:
const dataMapping = {
  // แหล่งที่มา: โครงสร้างคำสั่งซื้อ Shopify
  shopifyFields: {
    "order_id": "id",
    "customer_email": "customer.email",
    "line_items": "line_items",
    "total_price": "total_price",
    "created_at": "created_at"
  },
  
  // เป้าหมาย: ฟิลด์ Airtable
  airtableMapping: {
    "Order ID": "={{ $json.id }}",
    "Customer Email": "={{ $json.customer.email }}",
    "Product Name": "={{ $json.line_items[0].name }}",
    "SKU": "={{ $json.line_items[0].sku }}",
    "Quantity": "={{ $json.line_items[0].quantity }}",
    "Total": "={{ $json.total_price }}",
    "Order Date": "={{ $json.created_at }}",
    "Status": "={{ $json.financial_status }}"
  }
};

// Claude เพิ่มการจัดการข้อผิดพลาดที่ครอบคลุมโดยอัตโนมัติ
const errorHandling = {
  // การกำหนดค่า Retry
  retry: {
    maxRetries: 3,
    retryInterval: 5000,
    backoff: "exponential",
    retryOn: ["ETIMEDOUT", "ECONNRESET", 429, 503]
  },
  
  // Error branching
  errorNodes: [
    {
      type: "slack",
      channel: "#workflow-errors",
      condition: "error",
      message: "Workflow {{ $workflow.name }} ล้มเหลวที่ Node {{ $node.name }}: {{ $json.error.message }}"
    },
    {
      type: "httpRequest",
      url: "https://statuspage.io/api/v2/incidents",
      method: "POST",
      condition: "critical_error",
      body: {
        incident: {
          name: "Automation Failure: {{ $workflow.name }}",
          status: "investigating"
        }
      }
    }
  ],
  
  // Continue on error สำหรับเส้นทางที่ไม่สำคัญ
  continueOnFail: {
    enabled: true,
    fallbackOutput: "error_branch"
  }
};

// Prompt: "สร้าง content pipeline ที่รับหัวข้อ blog,
// ใช้ AI เพื่อค้นคว้าและเขียน SEO optimize สร้างรูปภาพ
// และเผยแพร่บน WordPress พร้อมการโปรโมท Social Media"

const contentPipeline = {
  trigger: {
    type: "manualTrigger",
    parameters: {
      topic: "string",
      targetKeywords: "array",
      tone: "professional" // หรือ casual, technical
    }
  },
  
  nodes: [
    // ขั้นตอนที่ 1: ค้นคว้า
    {
      name: "ค้นคว้า Topic",
      type: "anthropic",
      model: "claude-3-7-sonnet-20250219",
      prompt: `ค้นคว้าหัวข้อ "{{ $json.topic }}" อย่างละเอียด 
               หาสถิติสำคัญ ความเห็นผู้เชี่ยวชาญ และเทรนด์ปัจจุบัน
               ส่งคืนข้อมูลที่มีโครงสร้างพร้อมแหล่งที่มา`
    },
    
    // ขั้นตอนที่ 2: สร้าง outline
    {
      name: "สร้าง Outline",
      type: "openAi",
      model: "gpt-5.5",
      prompt: `สร้าง blog outline โดยละเอียดสำหรับ "{{ $json.topic }}" 
               โดยรวม: {{ $json.researchPoints }}
               รวมหัวข้อ H2 และ H3 keywords เป้าหมาย: {{ $json.targetKeywords }}`,
      outputFormat: "structured"
    },
    
    // ขั้นตอนที่ 3: เขียน content (ส่วนแบบขนาน)
    {
      name: "เขียนบทนำ",
      type: "anthropic",
      dependsOn: "outline",
      prompt: "เขียนบทนำที่น่าสนใจจาก outline ส่วนที่ 1"
    },
    {
      name: "เขียนส่วนเนื้อหา",
      type: "openAi",
      parallel: true,
      iterations: "outline.sectionCount",
      prompt: "เขียนเนื้อหาโดยละเอียดสำหรับแต่ละส่วน outline"
    },
    {
      name: "เขียนบทสรุป",
      type: "anthropic",
      dependsOn: "ส่วนเนื้อหา",
      prompt: "เขียนบทสรุป CTA ที่แข็งแกร่ง"
    },
    
    // ขั้นตอนที่ 4: SEO optimization
    {
      name: "SEO Optimization",
      type: "customNode",
      action: "optimizeContent",
      parameters: {
        minWordCount: 1500,
        keywordDensity: "2-3%",
        readabilityScore: "8th-grade",
        addMetaDescription: true,
        optimizeImages: true
      }
    },
    
    // ขั้นตอนที่ 5: สร้าง featured image
    {
      name: "สร้างรูปภาพ",
      type: "openAi",
      model: "dall-e-3",
      prompt: "สร้าง Featured Image: {{ $json.seoOptimized.excerpt }}"
    },
    
    // ขั้นตอนที่ 6: เผยแพร่บน WordPress
    {
      name: "เผยแพร่ Post",
      type: "wordpress",
      action: "createPost",
      title: "={{ $json.seoOptimized.title }}",
      content: "={{ $json.seoOptimized.fullContent }}",
      featuredImage: "={{ $json.generatedImage.url }}",
      categories: ["{{ $json.topicCategory }}"],
      tags: "={{ $json.targetKeywords }}",
      status: "draft" // หรือ publish
    },
    
    // ขั้นตอนที่ 7: โปรโมท Social
    {
      name: "จัดคิว Social Posts",
      type: "buffer",
      posts: [
        { platform: "twitter", text: "={{ $json.social.twitter }}" },
        { platform: "linkedin", text: "={{ $json.social.linkedin }}" },
        { platform: "facebook", text: "={{ $json.social.facebook }}" }
      ]
    },
    
    // ขั้นตอนที่ 8: แจ้งเตือน
    {
      name: "แจ้งทีม",
      type: "slack",
      channel: "#content",
      message: "✅ Blog post ใหม่พร้อม: {{ $json.seoOptimized.title }}\nPreview: {{ $json.wordpress.previewUrl }}"
    }
  ]
};

// Prompt: "สร้าง workflow กระทบยอดการเงินอัตโนมัติ
// ที่จับคู่การชำระเงิน Stripe กับใบแจ้งหนี้ QuickBooks ระบุความแตกต่าง
// และสร้างรายงานรายวัน"

const reconciliationWorkflow = {
  trigger: {
    type: "scheduleTrigger",
    cron: "0 9 * * *" // ทุกวันเวลา 9 โมงเช้า
  },
  
  nodes: [
    // ดึงธุรกรรม Stripe ของเมื่อวาน
    {
      name: "ดึงการชำระเงิน Stripe",
      type: "stripe",
      operation: "getAll",
      resource: "charge",
      parameters: {
        created: {
          gte: "={{ DateTime.now().minus({days: 1}).toISODate() }}",
          lte: "={{ DateTime.now().toISODate() }}"
        }
      }
    },
    
    // ดึงใบแจ้งหนี้ QuickBooks
    {
      name: "ดึงใบแจ้งหนี้ QB",
      type: "quickbooks",
      operation: "query",
      query: "SELECT * FROM Invoice WHERE TxnDate >= '{{ $date.yesterday }}'"
    },
    
    // แปลงข้อมูลสำหรับการเปรียบเทียบ
    {
      name: "Normalize ข้อมูล",
      type: "function",
      code: `
        const stripe = $input.json.stripe.map(p => ({
          id: p.id,
          amount: p.amount / 100,
          currency: p.currency,
          customer: p.customer,
          date: p.created,
          source: 'stripe'
        }));
        
        const qb = $input.json.quickbooks.map(i => ({
          id: i.Id,
          amount: i.TotalAmt,
          currency: i.CurrencyRef.value,
          customer: i.CustomerRef.value,
          date: i.TxnDate,
          source: 'quickbooks'
        }));
        
        return [{ json: { stripe, qb }}];
      `
    },
    
    // Matching algorithm
    {
      name: "จับคู่ธุรกรรม",
      type: "function",
      code: `
        const { stripe, qb } = $input.json;
        const matches = [];
        const unmatched = [];
        
        stripe.forEach(payment => {
          const match = qb.find(invoice => 
            Math.abs(invoice.amount - payment.amount) < 0.01 &&
            invoice.customer === payment.customer
          );
          
          if (match) {
            matches.push({ payment, invoice: match, status: 'matched' });
          } else {
            unmatched.push({ ...payment, status: 'unmatched' });
          }
        });
        
        return [{ json: { matches, unmatched, summary: {
          totalStripe: stripe.length,
          totalQB: qb.length,
          matched: matches.length,
          unmatched: unmatched.length
        }}}];
      `
    },
    
    // สร้างรายงาน
    {
      name: "สร้างรายงาน",
      type: "spreadsheetFile",
      operation: "write",
      fileName: "reconciliation_{{ DateTime.now().toFormat('yyyy-MM-dd') }}.csv",
      columns: [
        { name: "วันที่", value: "={{ $json.date }}" },
        { name: "Stripe ID", value: "={{ $json.payment.id }}" },
        { name: "QB ID", value: "={{ $json.invoice.id }}" },
        { name: "จำนวนเงิน", value: "={{ $json.payment.amount }}" },
        { name: "สถานะ", value: "={{ $json.status }}" }
      ]
    },
    
    // แจ้งเตือนรายการที่ไม่ตรงกัน
    {
      name: "ตรวจสอบ Unmatched",
      type: "if",
      conditions: {
        number: [{
          value1: "={{ $json.summary.unmatched }}",
          operation: "greaterThan",
          value2: "0"
        }]
      }
    },
    
    {
      name: "ส่ง Alert",
      type: "slack",
      channel: "#finance",
      text: "⚠️ Reconciliation Alert: {{ $json.summary.unmatched }} รายการไม่ตรงกัน",
      blocks: [
        {
          type: "section",
          text: "รายการไม่ตรงกันต้องตรวจสอบด้วยตนเอง",
          accessory: {
            type: "button",
            text: "ดูรายงาน",
            url: "{{ $json.reportUrl }}"
          }
        }
      ]
    }
  ]
};

✅ ดี: "สร้าง workflow ที่ตรวจสอบ RSS feed สำหรับบทความที่มี 'AI automation'
   สรุปด้วย Claude และโพสต์สรุปพร้อมลิงก์ต้นฉบับบน Slack
   รันทุก 30 นาที เพิ่มการจัดการข้อผิดพลาดสำหรับ RSS fetch"

❌ ไม่ดี: "ทำ workflow สำหรับ RSS"

✅ ดี: "สร้าง customer onboarding workflow: Trigger เมื่อ user ใหม่ signup ใน Stripe
   สร้าง Trello card ด้วยรายละเอียดของพวกเขา ส่ง welcome email ผ่าน SendGrid
   พร้อม content ที่ปรับแต่งตามแผน tier ของพวกเขา
   และเพิ่มพวกเขาเข้า Mailchimp segment ที่เหมาะสม
   จัดการกรณีที่ email bounce"

❌ ไม่ดี: "Customer workflow"

## Pre-Production Checklist

### ความปลอดภัย
- [ ] Credentials กำหนดค่าอย่างถูกต้อง (ไม่ hardcoded)
- [ ] API Keys เก็บใน n8n credential store
- [ ] ข้อมูล sensitive ถูก mask ใน logs
- [ ] Webhook endpoints ใช้ authentication

### การจัดการข้อผิดพลาด
- [ ] API calls ทั้งหมดมี retry logic
- [ ] Timeout ตั้งค่าอย่างเหมาะสม
- [ ] การแจ้งเตือนข้อผิดพลาดถูกกำหนดค่า
- [ ] Fallback paths มีสำหรับข้อผิดพลาดสำคัญ

### การไหลของข้อมูล
- [ ] Input validation มีอยู่
- [ ] Data transformations ถูกต้อง
- [ ] ไม่มี infinite loops ที่เป็นไปได้
- [ ] Memory usage ถูก optimize (ไม่มี datasets ขนาดใหญ่ใน memory)

### Monitoring
- [ ] Workflow execution logging เปิดใช้งาน
- [ ] Success/failure metrics track ได้
- [ ] Alert thresholds ถูกกำหนดค่า
- [ ] Run history retention เหมาะสม

### เอกสารประกอบ
- [ ] Workflow มีชื่อและคำอธิบายที่ถูกต้อง
- [ ] Nodes ซับซ้อนมี comments
- [ ] Credential requirements มีเอกสาร
- [ ] Business logic อธิบายไว้

// กับดักที่ 1: Hardcoded credentials
// ❌ ไม่ดี: Claude อาจสร้างสิ่งนี้
const badConfig = {
  apiKey: "sk-abc123xyz", // อย่าทำแบบนี้
  password: "supersecret"
};

// ✅ ดี: ใช้ n8n credentials
const goodConfig = {
  credentials: "my-api-service" // อ้างอิง credential ตามชื่อ
};

// กับดักที่ 2: การจัดการข้อผิดพลาดที่ขาดหาย
// ❌ ไม่ดี: ไม่มี error path
const badWorkflow = {
  nodes: ["trigger", "apiCall", "notification"]
  // เกิดอะไรขึ้นถ้า apiCall ล้มเหลว?
};

// ✅ ดี: API call ทุกครั้งมีการจัดการข้อผิดพลาด
const goodWorkflow = {
  nodes: [
    "trigger",
    { name: "apiCall", errorOutput: "errorHandler" },
    "notification",
    { name: "errorHandler", type: "slack", channel: "#errors" }
  ]
};

// กับดักที่ 3: การจัดการข้อมูลที่ไม่มีประสิทธิภาพ
// ❌ ไม่ดี: ประมวลผลทุกอย่างใน memory
const badApproach = {
  getAllData: "{{ get10000Records }}", // อย่าโหลด 10k records
  process: "{{ transformAll }}"         // ทีเดียว
};

// ✅ ดี: Batch processing
const goodApproach = {
  loop: {
    batchSize: 100,
    process: "{{ transformBatch }}",
    continueOnFail: true
  }
};

// ขั้นตอนที่ 1: Export workflow ที่มีอยู่
const existingWorkflow = await n8n.workflows.get(workflowId);

// ขั้นตอนที่ 2: อธิบายการปรับปรุงแก่ Claude
const improvementPrompt = `
  ฉันมี n8n workflow ที่มีอยู่นี้ในการประมวลผลคำสั่งซื้อ
  โครงสร้างปัจจุบัน: ${JSON.stringify(existingWorkflow, null, 2)}
  
  กรุณาสร้างใหม่ด้วยการปรับปรุงเหล่านี้:
  1. เพิ่มการจัดการข้อผิดพลาดให้ API calls ทั้งหมด
  2. ใช้การประมวลผลขนานสำหรับ operations ที่อิสระกัน
  3. เพิ่มการตรวจสอบข้อมูลก่อนเขียนลงฐานข้อมูล
  4. รวม logging ที่ครอบคลุม
  5. Optimize สำหรับ batch processing (เวอร์ชันปัจจุบันประมวลผลทีละรายการ)
`;

// ขั้นตอนที่ 3: Claude ส่งคืนเวอร์ชันที่ปรับปรุงแล้ว
const improvedWorkflow = await claude.buildWorkflow(improvementPrompt);

// ขั้นตอนที่ 4: ทดสอบ side-by-side
await testRunner.compare(existingWorkflow, improvedWorkflow);

// ขั้นตอนที่ 5: Rollout ทีละขั้น
await deployment.gradualRollout({
  newWorkflow: improvedWorkflow,
  trafficSplit: "10% ในตอนแรก ขยายตามอัตราความสำเร็จ"
});

// Workflow แบบร่วมมือ: Human กำหนด business logic AI ดำเนินการรายละเอียดทางเทคนิค
const hybridApproach = {
  // Human ให้: Business requirements
  requirements: {
    trigger: "เมื่อสร้างคำสั่งซื้อใหม่",
    actions: [
      "ตรวจสอบ credit limit ลูกค้า",
      "ตรวจสอบสต็อกสินค้า",
      "สำรองสต็อกถ้ามีเพียงพอ",
      "ส่งยืนยันให้ลูกค้า",
      "แจ้ง warehouse เตรียมจัดส่ง"
    ],
    constraints: [
      "ต้องเสร็จภายใน 5 วินาที",
      "ไม่สามารถสำรองสต็อกติดลบ",
      "คำสั่งซื้อมูลค่าสูงต้องได้รับการอนุมัติจาก manager"
    ]
  },
  
  // AI สร้าง: Technical implementation
  implementation: {
    nodes: [/* สร้างโดย Claude ตาม requirements */],
    connections: [/* Data flow ที่ optimize แล้ว */],
    errorHandling: [/* Patterns ระดับ production */],
    credentials: [/* กำหนดค่าอย่างถูกต้อง */]
  },
  
  // Human review และปรับแต่ง
  review: {
    modify: "เพิ่มการแจ้งเตือน SMS สำหรับลูกค้า VIP",
    add: "สร้าง audit log entry สำหรับแต่ละ action",
    remove: "ข้ามการตรวจสอบสต็อกสำหรับสินค้าดิจิทัล"
  }
};

// โครงสร้าง workflow ที่สร้างด้วย AI
const fashionWorkflow = {
  trigger: "Shopify order webhook",
  
  parallelProcessing: {
    path1: "การตรวจสอบสต็อก + การสำรองสต็อก",
    path2: "การตรวจจับการฉ้อโกง + การให้คะแนนความเสี่ยง",
    path3: "การคำนวณค่าจัดส่ง + การสร้าง shipping label"
  },
  
  conditionalLogic: {
    highValue: "คิวการอนุมัติของ manager",
    international: "เอกสารศุลกากร",
    preorder: "Backorder workflow"
  },
  
  notifications: {
    customer: "อีเมลพร้อม Tracking",
    warehouse: "Slack พร้อม Pick list",
    accounting: "QuickBooks entry"
  }
};

// ผลลัพธ์:
// - เวลาการประมวลผล: 4 ชั่วโมง → 52 นาที
// - อัตราข้อผิดพลาด: 2.3% → 0.4%
// - เวลาพนักงานที่ประหยัดได้: 15 ชั่วโมง/สัปดาห์
// - ได้รับ ROI ใน 3 สัปดาห์

// AI-built customer success automation
const csWorkflow = {
  schedule: "ทุก 6 ชั่วโมง",
  
  dataCollection: {
    productUsage: "Mixpanel API",
    supportTickets: "Zendesk",
    billing: "Stripe",
    nps: "Typeform"
  },
  
  scoring: {
    algorithm: "Weighted health score",
    factors: ["login_frequency", "feature_adoption", "ticket_volume", "payment_history"],
    threshold: 60 // ต่ำกว่า = เสี่ยง
  },
  
  actions: {
    highRisk: [
      "สร้าง Salesforce task สำหรับ CSM",
      "ส่งอีเมล re-engagement ที่ปรับแต่ง",
      "วางแผน automated check-in call"
    ],
    champions: [
      "เชิญเข้า advocacy program",
      "ขอให้เข้าร่วม case study",
      "เสนอ referral incentives"
    ]
  },
  
  reporting: {
    dashboard: "การเปลี่ยนแปลง health score รายวัน",
    alerts: "การลดลงของ score ที่สำคัญ",
    trends: "การวิเคราะห์ cohort รายสัปดาห์"
  }
};

// ผลลัพธ์:
// - การระบุลูกค้าเสี่ยง: เร็วขึ้น 3 เท่า
// - อัตราความสำเร็จการแทรกแซง: 67%
// - ลด churn: 23%
// - เพิ่มความสามารถ CSM 40%

// AI-generated reporting automation
const reportingWorkflow = {
  schedule: "ทุกวันจันทร์ 8 โมง",
  
  dataAggregation: {
    sources: [
      { platform: "Google Ads", metrics: ["impressions", "clicks", "conversions", "cost"] },
      { platform: "Facebook Ads", metrics: ["reach", "engagement", "conversions", "spend"] },
      { platform: "Google Analytics", metrics: ["sessions", "users", "bounce_rate", "revenue"] },
      { platform: "HubSpot", metrics: ["leads", "mqls", "sqls", "customers"] }
    ]
  },
  
  processing: {
    calculate: [
      "ROAS ตามช่องทาง",
      "Cost per acquisition",
      "การเปลี่ยนแปลงสัปดาห์ต่อสัปดาห์",
      "เปอร์เซ็นต์การบรรลุเป้าหมาย"
    ],
    format: "Executive Summary + Breakdown ละเอียด",
    visualize: "สร้าง Charts อัตโนมัติผ่าน QuickChart API"
  },
  
  delivery: {
    clientReports: "PDF ทางอีเมลพร้อม Custom Branding",
    internal: "Slack Summary ให้ Account Managers",
    archive: "Google Drive จัดตามลูกค้า/เดือน"
  },
  
  intelligence: {
    insights: "Performance highlights ที่สร้างด้วย AI",
    recommendations: "ข้อเสนอแนะการ optimize",
    anomalies: "Flag การเปลี่ยนแปลง metrics ที่ผิดปกติ"
  }
};

// ผลลัพธ์:
// - เวลา reporting: 40 ชั่วโมง → 2 ชั่วโมง (รีวิวเท่านั้น)
// - ความพึงพอใจลูกค้า: +34%
// - ความสามารถลูกค้าใหม่: +8 บัญชี
// - อัตราข้อผิดพลาด: เกือบศูนย์

// การปรับปรุงระยะสั้นที่คาดการณ์ไว้
const futureCapabilities = {
  // Q3 2026: Visual workflow editing
  visualEditing: {
    description: "Claude สามารถแก้ไข workflows ที่มีอยู่โดยอ้างอิง layout ภาพ",
    example: "ย้าย Slack notification node ให้ทำงานขนานกับ email node"
  },
  
  // Q4 2026: การเรียนรู้จากตัวอย่าง
  learning: {
    description: "Claude เรียนรู้ความชอบของคุณจาก workflows ที่มีอยู่",
    example: "จาก workflows ที่มีอยู่ 50 อันของคุณ ฉันจะใช้รูปแบบ error handling มาตรฐาน"
  },
  
  // Q1 2027: Natural language debugging
  debugging: {
    description: "อธิบายปัญหาเป็นภาษาไทยง่ายๆ สำหรับ AI diagnosis",
    example: "Workflow นี้บางครั้งพลาดคำสั่งซื้อในวันหยุดสุดสัปดาห์" → AI เสนอแนะการแก้ไข scheduling
  },
  
  // Q2 2027: Cross-platform optimization
  optimization: {
    description: "AI เสนอการปรับปรุงสถาปัตยกรรมทั่ว automation stack ทั้งหมด",
    example: "Setup n8n + Make + Zapier ของคุณสามารถรวมได้เพื่อลด latency 40%"
  }
};

## Readiness Checklist สำหรับ AI-Assisted Automation

### โครงสร้างพื้นฐานทางเทคนิค
- [ ] n8n instance เวอร์ชัน 1.89.0 หรือสูงกว่า
- [ ] Claude Desktop พร้อมรองรับ MCP
- [ ] API Credentials จัดระเบียบและเข้าถึงได้
- [ ] Development และ Production environments แยกกัน
- [ ] Version Control สำหรับ workflows (ความสามารถ export/import)

### ทักษะทีม
- [ ] พนักงานได้รับการฝึกอบรมพื้นฐาน n8n
- [ ] เข้าใจหลักการ Prompt Engineering
- [ ] ความรู้เกี่ยวกับรูปแบบ Error Handling
- [ ] Security Awareness สำหรับ Credential Management
- [ ] กระบวนการ Change Management สำหรับการอัปเดต workflow

### การกำกับดูแล
- [ ] กระบวนการอนุมัติ workflow กำหนดไว้
- [ ] Naming Conventions สถาปนาแล้ว
- [ ] มาตรฐานเอกสารกำหนดไว้
- [ ] Monitoring และ Alerting กำหนดค่าแล้ว
- [ ] ขั้นตอน Rollback มีเอกสาร

### วัฒนธรรม
- [ ] Executive buy-in สำหรับการพัฒนาที่ได้รับการสนับสนุนจาก AI
- [ ] ตระหนักว่า AI เสริม ไม่ใช่แทนที่ ความเชี่ยวชาญ
- [ ] ความเต็มใจในการทำซ้ำและปรับแต่ง
- [ ] ความเปิดกว้างต่อวิธีการทำงานใหม่
- [ ] ความมุ่งมั่นต่อการเรียนรู้อย่างต่อเนื่อง