┌─────────────────────────────────────────────────────────────────────────────────┐
│              สเปกตรัมความเป็นอิสระของ AI: จากมนุษย์เต็มรูปแบบไปสู่ Agent เต็มรูปแบบ       │
├─────────────────────────────────────────────────────────────────────────────────┤
│                                                                                 │
│  มนุษย์เป็นผู้นำ                            Agent เป็นอิสระเต็มรูปแบบ               │
│  ┌─────────────────┐    ┌─────────────────┐    ┌─────────────────┐            │
│  │                 │    │                 │    │                 │            │
│  │   AI เป็นเครื่องมือ │───▶│  Human-in-Loop │───▶│ AI เป็น Agent   │            │
│  │                 │    │                 │    │                 │            │
│  └─────────────────┘    └─────────────────┘    └─────────────────┘            │
│       2020-2023            2024-2026+           2027+ (เลือก)                      │
│                                                                                 │
│  • มนุษย์เริ่มต้น          • AI เสนอ            • AI ดำเนินการ                     │
│  • AI ช่วยเหลือ          • มนุษย์อนุมัติ         • มนุษย์ตรวจสอบ                   │
│  • มนุษย์ตัดสินใจ         • ร่วมมือกัน          • จัดการข้อยกเว้น                │
│                                                                                 │
│  สถานะปัจจุบัน:          รูปแบบที่เกิดขึ้น:        สถานะเป้าหมาย:                   │
│  ChatGPT, Copilot        n8n + AI + HITL        อิสระภายใต้การกำกับดูแล          │
│                                                                                 │
└─────────────────────────────────────────────────────────────────────────────────┘

// Workflow: AI Content Approval Pipeline
// Nodes: Webhook → AI Agent → Approval Request → Condition → Execute/Publish

// Node 1: Webhook Trigger (รับคำขอเนื้อหา)
{
  "name": "คำขอเนื้อหา",
  "type": "n8n-nodes-base.webhook",
  "webhookUri": "https://your-n8n.com/webhook/content-approval",
  "responseMode": "responseNode"
}

// Node 2: AI Content Generation (OpenAI/Claude)
{
  "name": "สร้างเนื้อหา",
  "type": "@n8n/n8n-nodes-langchain.agent",
  "options": {
    "options": {
      "systemMessage": "คุณเป็นนักเขียนเนื้อหามืออาชีพ...",
      "temperature": 0.7
    }
  },
  "prompt": "={{ $json.query }}"
}

// Node 3: เก็บ Approval ที่รอดำเนินการ (ฐานข้อมูล)
{
  "name": "สร้างบันทึกการอนุมัติ",
  "type": "n8n-nodes-base.postgres",
  "operation": "insert",
  "table": "content_approvals",
  "columns": {
    "content_id": "={{ $json.id }}",
    "content": "={{ $json.generated_content }}",
    "status": "รอดำเนินการ",
    "requested_by": "={{ $json.user }}",
    "created_at": "={{ $now }}"
  }
}

// Node 4: ส่งคำขออนุมัติ (Slack/Email)
{
  "name": "ขอการอนุมัติ",
  "type": "n8n-nodes-base.slack",
  "operation": "post",
  "channel": "content-approvers",
  "text": "📝 เนื้อหาใหม่ต้องการการอนุมัติ",
  "blocks": [
    {
      "type": "section",
      "text": {
        "type": "mrkdwn",
        "text": "*เนื้อหาพร้อมสำหรับการตรวจสอบ*\n{{ $json.content_preview }}"
      }
    },
    {
      "type": "actions",
      "elements": [
        {
          "type": "button",
          "text": { "type": "plain_text", "text": "✅ อนุมัติ" },
          "action_id": "approve_content",
          "value": "{{ $json.content_id }}"
        },
        {
          "type": "button",
          "text": { "type": "plain_text", "text": "❌ ปฏิเสธ" },
          "action_id": "reject_content",
          "value": "{{ $json.content_id }}"
        },
        {
          "type": "button",
          "text": { "type": "plain_text", "text": "✏️ แก้ไข" },
          "action_id": "edit_content",
          "url": "https://cms.example.com/edit/{{ $json.content_id }}"
        }
      ]
    }
  ]
}

// Node 5: รอการตอบกลับการอนุมัติ
{
  "name": "รอการอนุมัติ",
  "type": "n8n-nodes-base.wait",
  "waitType": "webhook",
  "webhookSuffix": "approval-response",
  "continue": "receiveWebhook"
}

// Node 6: ประมวลผลการตัดสินใจอนุมัติ
{
  "name": "การตัดสินใจอนุมัติ",
  "type": "n8n-nodes-base.if",
  "conditions": {
    "string": [
      { "value1": "={{ $json.action }}", "value2": "approved" }
    ]
  }
}

// สาขา: อนุมัติ → เผยแพร่
{
  "name": "เผยแพร่เนื้อหา",
  "type": "n8n-nodes-base.httpRequest",
  "method": "POST",
  "url": "https://cms.example.com/api/publish",
  "body": {
    "content_id": "={{ $json.content_id }}",
    "approved_by": "={{ $json.approver }}",
    "approved_at": "={{ $now }}"
  }
}

// สาขา: ปฏิเสธ → แจ้งเตือน & บันทึก
{
  "name": "ตัวจัดการการปฏิเสธ",
  "type": "n8n-nodes-base.slack",
  "operation": "post",
  "channel": "content-requests",
  "text": "❌ เนื้อหาถูกปฏิเสธโดย {{ $json.approver }}: {{ $json.rejection_reason }}"
}

// Workflow: Intelligent Exception Routing

// Node 1: รับอินพุต (จากระบบ AI หรือแหล่งภายนอก)
{
  "name": "การประมวลผลอินพุต",
  "type": "n8n-nodes-base.webhook"
}

// Node 2: การคำนวณคะแนนความมั่นใจและการประเมินความเสี่ยง
{
  "name": "คำนวณความมั่นใจ",
  "type": "n8n-nodes-base.code",
  "jsCode": `
    // คำนวณคะแนนความมั่นใจแบบผสมผสาน
    const aiConfidence = $json.ai_confidence || 0;
    const patternMatch = $json.similarity_score || 0;
    const historicalAccuracy = $json.model_accuracy || 0.85;
    
    // การคำนวณความมั่นใจแบบถ่วงน้ำหนัก
    const confidenceScore = (
      aiConfidence * 0.5 +
      patternMatch * 0.3 +
      historicalAccuracy * 0.2
    );
    
    // การประเมินความเสี่ยง
    const riskFactors = [];
    if ($json.amount > 10000) riskFactors.push('มูลค่าสูง');
    if ($json.customer_tier === 'enterprise') riskFactors.push('ลูกค้า VIP');
    if ($json.is_novel_situation) riskFactors.push('กรณีใหม่');
    
    return [{
      json: {
        ...$json,
        confidence_score: confidenceScore,
        risk_factors: riskFactors,
        risk_level: riskFactors.length > 1 ? 'สูง' : riskFactors.length > 0 ? 'ปานกลาง' : 'ต่ำ',
        requires_human_review: confidenceScore < 0.8 || riskFactors.length > 0
      }
    }];
  `
}

// Node 3: การตัดสินใจการกำหนดเส้นทาง
{
  "name": "การตัดสินใจการกำหนดเส้นทาง",
  "type": "n8n-nodes-base.switch",
  "rules": {
    "rules": [
      {
        "value": "={{ $json.requires_human_review }}",
        "output": 0  // กำหนดเส้นทางไปยังมนุษย์
      },
      {
        "value": "={{ true }}",
        "output": 1  // ประมวลผลอัตโนมัติ
      }
    ]
  }
}

// เส้นทาง 0: คิวการตรวจสอบของมนุษย์
{
  "name": "สร้างตั๋ว",
  "type": "n8n-nodes-base.jira",
  "operation": "create",
  "project": "AIEX",
  "issueType": "ข้อยกเว้น",
  "summary": "ข้อยกเว้น AI: {{ $json.case_type }} - ความมั่นใจ {{ $json.confidence_score }}",
  "description": `
    *ผลการประมวลผล AI:*
    - คะแนนความมั่นใจ: {{ $json.confidence_score }}
    - ปัจจัยความเสี่ยง: {{ $json.risk_factors.join(', ') }}
    - คำแนะนำ AI: {{ $json.ai_recommendation }}
    
    *บริบท:*
    {{ JSON.stringify($json.context, null, 2) }}
    
    [ดูใน AI Dashboard](https://ai.example.com/cases/{{ $json.case_id }})
  `,
  "priority": "={{ $json.risk_level === 'สูง' ? 'สูง' : 'ปานกลาง' }}"
}

// เส้นทาง 1: ประมวลผลอัตโนมัติ
{
  "name": "ดำเนินการอัตโนมัติ",
  "type": "n8n-nodes-base.httpRequest",
  "url": "https://api.example.com/execute",
  "method": "POST",
  "body": "={{ $json }}"
}

// Node 4: การจัดการคิวและการบาลานซ์โหลด
{
  "name": "มอบหมายให้ผู้เชี่ยวชาญ",
  "type": "n8n-nodes-base.postgres",
  "operation": "executeQuery",
  "query": `
    WITH available_experts AS (
      SELECT expert_id, current_load, specialization
      FROM expert_queue
      WHERE status = 'available'
      AND specialization && $1
      ORDER BY current_load ASC
      LIMIT 1
    )
    UPDATE expert_queue
    SET current_load = current_load + 1,
        assigned_case = $2
    WHERE expert_id = (SELECT expert_id FROM available_experts)
    RETURNING expert_id
  `,
  "parameters": [
    "={{ $json.risk_factors }}",
    "={{ $json.case_id }}"
  ]
}

// Node 5: การแจ้งเตือนแบบ Real-time
{
  "name": "แจ้งเตือนผู้เชี่ยวชาญ",
  "type": "n8n-nodes-base.slack",
  "operation": "post",
  "channel": "@{{ $json.expert_id }}",
  "text": "🔔 กำหนดกรณีข้อยกเว้น",
  "blocks": [
    {
      "type": "header",
      "text": { "type": "plain_text", "text": "⚠️ กรณีข้อยกเว้นต้องการความสนใจ" }
    },
    {
      "type": "section",
      "fields": [
        { "type": "mrkdwn", "text": "*รหัสกรณี:*\n{{ $json.case_id }}" },
        { "type": "mrkdwn", "text": "*ระดับความเสี่ยง:*\n{{ $json.risk_level }}" },
        { "type": "mrkdwn", "text": "*ความมั่นใจ:*\n{{ $json.confidence_score }}" },
        { "type": "mrkdwn", "text": "*เวลารอ:*\n{{ $json.queue_time }}" }
      ]
    }
  ]
}

// Workflow: Interactive AI Refinement กับการทำงานร่วมกันแบบ Real-time

// Node 1: การเชื่อมต่อ WebSocket สำหรับการสื่อสารแบบ Real-time
{
  "name": "WebSocket Handler",
  "type": "n8n-nodes-base.webhook",
  "webhookUri": "/ws/interactive-ai",
  "responseMode": "responseNode"
}

// Node 2: การจัดการเซสชัน
{
  "name": "เริ่มต้นเซสชัน",
  "type": "n8n-nodes-base.redis",
  "operation": "set",
  "key": "session:{{ $json.session_id }}",
  "value": {
    "status": "ใช้งาน",
    "iteration": 0,
    "context": [],
    "created_at": "{{ $now }}"
  },
  "expire": 3600  // 1 ชั่วโมง TTL
}

// Node 3: AI Generation กับบริบท
{
  "name": "สร้างด้วยบริบท",
  "type": "@n8n/n8n-nodes-langchain.agent",
  "prompt": `
    การทำซ้ำก่อนหน้า: {{ $json.history }}
    ความคิดเห็นปัจจุบัน: {{ $json.feedback }}
    งาน: {{ $json.task }}
    
    สร้างเวอร์ชันที่ปรับปรุงโดยรวมความคิดเห็น
  `,
  "options": {
    "systemMessage": "คุณเป็น AI Assistant ที่เรียนรู้จากความคิดเห็น..."
  }
}

// Node 4: บันทึกการทำซ้ำ
{
  "name": "บันทึกการทำซ้ำ",
  "type": "n8n-nodes-base.redis",
  "operation": "set",
  "key": "session:{{ $json.session_id }}:iteration:{{ $json.iteration }}",
  "value": {
    "output": "{{ $json.ai_output }}",
    "feedback": "{{ $json.feedback }}",
    "timestamp": "{{ $now }}"
  }
}

// Node 5: ส่งไปยังอินเทอร์เฟซผู้ใช้
{
  "name": "Push ไปยัง UI",
  "type": "n8n-nodes-base.webhook",
  "webhookUri": "/ui/update",
  "body": {
    "session_id": "{{ $json.session_id }}",
    "iteration": "{{ $json.iteration }}",
    "content": "{{ $json.ai_output }}",
    "suggestions": "{{ $json.alternatives }}",
    "changes_summary": "{{ $json.diff_from_previous }}"
  }
}

// Node 6: รอความคิดเห็นจากผู้ใช้
{
  "name": "รวบรวมความคิดเห็น",
  "type": "n8n-nodes-base.wait",
  "waitType": "webhook",
  "webhookSuffix": "user-feedback",
  "continue": "receiveWebhook"
}

// Node 7: ตรวจสอบการเสร็จสิ้น
{
  "name": "การตรวจสอบการเสร็จสิ้น",
  "type": "n8n-nodes-base.if",
  "conditions": {
    "string": [
      { "value1": "={{ $json.action }}", "value2": "approve" }
    ]
  }
}

// สาขาที่อนุมัติ: Finalize
{
  "name": "Finalize Output",
  "type": "n8n-nodes-base.code",
  "jsCode": `
    // รวบรวมการทำซ้ำทั้งหมดเป็นเอกสารสุดท้าย
    const iterations = $json.history;
    const finalVersion = $json.current_version;
    
    return [{
      json: {
        final_output: finalVersion,
        revision_history: iterations,
        total_iterations: iterations.length,
        time_to_complete: Date.now() - new Date($json.session_created).getTime(),
        approved_by: $json.user_id,
        approved_at: new Date().toISOString()
      }
    }];
  `
}

// สาขาความคิดเห็น: ดำเนินการต่อ Loop
{
  "name": "เพิ่มการทำซ้ำ",
  "type": "n8n-nodes-base.code",
  "jsCode": `
    return [{
      json: {
        ...$json,
        iteration: ($json.iteration || 0) + 1,
        feedback: $json.user_feedback
      }
    }];
  `
}
// กลับไปที่ Node 3 (สร้างด้วยบริบท)

// Workflow: Feedback Capture และ Model Improvement Pipeline

// Node 1: จับการแก้ไข
{
  "name": "เหตุการณ์การแก้ไข",
  "type": "n8n-nodes-base.webhook",
  "webhookUri": "/feedback/correction"
}

// Node 2: เก็บในฐานข้อมูล Feedback
{
  "name": "บันทึกการแก้ไข",
  "type": "n8n-nodes-base.postgres",
  "operation": "insert",
  "table": "ai_feedback",
  "columns": {
    "original_prediction": "={{ $json.ai_output }}",
    "human_correction": "={{ $json.corrected_output }}",
    "correction_type": "={{ $json.correction_category }}",
    "model_version": "={{ $json.model_version }}",
    "confidence_at_prediction": "={{ $json.confidence }}",
    "context": "={{ JSON.stringify($json.context) }}",
    "created_at": "={{ $now }}"
  }
}

// Node 3: คำนวณ Model Drift
{
  "name": "วิเคราะห์รูปแบบข้อผิดพลาด",
  "type": "n8n-nodes-base.postgres",
  "operation": "executeQuery",
  "query": `
    WITH recent_errors AS (
      SELECT correction_type, COUNT(*) as count
      FROM ai_feedback
      WHERE created_at > NOW() - INTERVAL '7 days'
      GROUP BY correction_type
    ),
    baseline AS (
      SELECT correction_type, COUNT(*) as count
      FROM ai_feedback
      WHERE created_at > NOW() - INTERVAL '30 days'
        AND created_at <= NOW() - INTERVAL '7 days'
      GROUP BY correction_type
    )
    SELECT 
      r.correction_type,
      r.count as recent_count,
      b.count as baseline_count,
      ((r.count - b.count)::float / NULLIF(b.count, 0)) as drift_percentage
    FROM recent_errors r
    LEFT JOIN baseline b ON r.correction_type = b.correction_type
    WHERE ((r.count - b.count)::float / NULLIF(b.count, 0)) > 0.2
  `
}

// Node 4: เรียกใช้ Retraining หากจำเป็น
{
  "name": "ตรวจสอบเกณฑ์ Retraining",
  "type": "n8n-nodes-base.if",
  "conditions": {
    "number": [
      { "value1": "={{ $json.length }}", "operation": "gt", "value2": 5 }
    ]
  }
}

// สาขา Retraining
{
  "name": "เรียกใช้ Model Retraining",
  "type": "n8n-nodes-base.httpRequest",
  "method": "POST",
  "url": "https://ml-ops.example.com/retrain",
  "body": {
    "model_id": "{{ $json.model_id }}",
    "new_training_data_query": "SELECT * FROM ai_feedback WHERE created_at > NOW() - INTERVAL '30 days'",
    "priority": "high"
  }
}

// Node 5: อัปเดตชุดข้อมูลการฝึกอบรม
{
  "name": "ส่งออกไปยัง Training Pipeline",
  "type": "n8n-nodes-base.s3",
  "operation": "upload",
  "bucket": "ai-training-data",
  "key": "corrections/{{ $now.format('YYYY/MM/DD') }}/{{ $json.id }}.json",
  "data": "={{ JSON.stringify($json) }}"
}

// Node 6: แจ้งทีม ML
{
  "name": "แจ้งเตือน Drift",
  "type": "n8n-nodes-base.slack",
  "condition": "={{ $json.drift_percentage > 0.3 }}",
  "operation": "post",
  "channel": "#ml-alerts",
  "text": "⚠️ ตรวจพบ Model drift: ข้อผิดพลาด {{ $json.correction_type }} เพิ่มขึ้น {{ $json.drift_percentage }}%"
}