CRM에 통화 기록 남기기: 전화번호로 고객 매칭하고 요약 붙이기

export KAT_API_KEY="콘솔에서 발급받은 키"

curl -s -X POST "https://studio-gateway.zerocall.kr/webhook" \
  -H "x-api-key: $KAT_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"eventType":"CALL_COMPLETED","url":"https://crm-sync.example.com/webhook/call-completed"}'

// phone.js — 국내 전화번호 정규화
function normalizeKrPhone(raw) {
  if (!raw) return null;
  let d = String(raw).replace(/\D/g, ''); // 숫자만 남기기
  if (d.startsWith('82') && d.length >= 10) {
    // +82 10-1234-5678 → 01012345678, +82 2-123-4567 → 021234567
    d = d.slice(2);
    if (!d.startsWith('0')) d = '0' + d;
  }
  return d.length >= 8 ? d : null; // 1588-0000 같은 8자리 대표번호까지 허용
}

function pickNumbers(call) {
  const customer = call.isInbound ? call.fromNumber : call.toNumber;
  const ours = call.isInbound ? call.toNumber : call.fromNumber;
  return { customer: normalizeKrPhone(customer), ours: normalizeKrPhone(ours) };
}

module.exports = { normalizeKrPhone, pickNumbers };

// crm-adapter.js — 사용하는 CRM의 API로 채워 넣는 부분
module.exports = {
  // 정규화된 번호로 고객 목록을 찾는다: [{ id, name, lastActivityAt }]
  async findContactsByPhone(phone) {
    return [];
  },
  // 매칭되는 고객이 없을 때 리드(잠재 고객)를 만든다: { id }
  async createLead({ phone, source }) {
    return { id: 'lead-id' };
  },
  // externalId가 같은 활동이 있으면 갱신, 없으면 생성한다
  async upsertActivity({ externalId, contactId, subject, body, fields, occurredAt }) {},
};

// match.js
async function matchContact(crm, phone) {
  if (!phone) return { contactId: null, matchType: 'NO_NUMBER' };
  const found = await crm.findContactsByPhone(phone);
  if (found.length === 1) return { contactId: found[0].id, matchType: 'EXACT' };
  if (found.length > 1) {
    const latest = [...found].sort((a, b) =>
      String(b.lastActivityAt || '').localeCompare(String(a.lastActivityAt || '')))[0];
    return { contactId: latest.id, matchType: 'MULTIPLE', candidates: found.map((c) => c.id) };
  }
  const lead = await crm.createLead({ phone, source: 'KAT Cloud 통화' });
  return { contactId: lead.id, matchType: 'NEW_LEAD' };
}

module.exports = { matchContact };

// activity.js
const TAG = { AI: 'AI 응대', DIRECT: '직원 응대', AI_TO_DIRECT: 'AI→직원 연결', UNKNOWN: '확인 불가' };

function transcriptText(call) {
  const lines = [];
  for (const t of call.sttAI || []) {
    lines.push(`[AI 구간 ${t.timestamp}s] ${t.role === 'agent' ? 'AI' : '고객'}: ${t.text}`);
  }
  for (const t of call.sttDirect || []) {
    lines.push(`[직원 구간 ${t.timestamp}s] ${t.role === 'agent' ? '직원' : '고객'}: ${t.text}`);
  }
  return lines.join('\n');
}

function buildActivity(call, match) {
  const direction = call.isInbound ? '수신' : '발신';
  return {
    externalId: `katcloud:${call.callHistoryId}`, // 같은 통화는 같은 활동으로 upsert
    contactId: match.contactId,
    subject: `[${direction} 통화] ${TAG[call.tag] || '확인 불가'} · ${call.duration || 0}초`,
    body: [
      `요약: ${call.summary || '(요약 없음)'}`,
      '',
      '대화 내역',
      transcriptText(call) || '(대화 내역 없음)',
    ].join('\n'),
    fields: {
      direction,
      status: call.status,
      tag: call.tag,
      durationSec: call.duration,
      matchType: match.matchType,
      candidates: match.candidates || [],
    },
    occurredAt: call.startedAt,
  };
}

module.exports = { buildActivity };

// server.js — Node.js 18+, Express 4
const express = require('express');
const crm = require('./crm-adapter');
const { pickNumbers } = require('./phone');
const { matchContact } = require('./match');
const { buildActivity } = require('./activity');

const app = express();
app.use(express.json({ limit: '2mb' })); // STT 배열이 길 수 있다

app.post('/webhook/call-completed', (req, res) => {
  res.sendStatus(200); // KAT Cloud 웹훅 타임아웃은 10초

  const { eventType, data } = req.body || {};
  if (eventType !== 'CALL_COMPLETED' || !data?.callHistoryId) return;

  setImmediate(async () => {
    try {
      const { customer } = pickNumbers(data);
      const match = await matchContact(crm, customer);
      await crm.upsertActivity(buildActivity(data, match));
    } catch (err) {
      console.error('[crm-sync]', data.callHistoryId, err); // 재처리 대기열에 넣는다
    }
  });
});

app.listen(process.env.PORT || 3000);

curl -s "https://studio-gateway.zerocall.kr/call-history/8f3f8fd9-7ab8-4a26-b523-4f8eb7d38b85?groupId=1" \
  -H "x-api-key: $KAT_API_KEY"