전화 → 액션플랜 자동화
AI 영업비서 최적 구현 계획

00 현재 상태 — 이미 있는 것

기존 mobile/telinfo (Flutter) 가 상당 부분을 구현해 둠. 이 위에 파이프라인을 얹는다.

01 전체 아키텍처

단말 OS 제약을 우회하는 두 플로우. 받은 전화는 단말이 만든 녹음을 끌어오고, 부재중은 단말/서버에서 즉시 응답한다.

📞 받은 전화 → 액션플랜

📵 부재중 → 자동 SMS

기술 스택 결정

02 핵심 블로커 해결 — 갤럭시 녹음폴더 접근

telinfo가 이미 부딪힌 "/Recordings/Call/ 일반 권한 read 불가". 이게 받은 전화 기능의 사활을 가른다.

// telinfo: SAF 영속권한 획득 + 신규 녹음 스캔 (의사코드)
final treeUri = await saf.openDocumentTree();           // 1회: /Recordings/Call 선택
await saf.takePersistableUriPermission(treeUri);        // 재부팅 내성
prefs.setString('callDirUri', treeUri.toString());

// WorkManager 주기 작업 (15분) — 업로드 안 된 새 파일만 diff
final files = await saf.listFiles(treeUri);
final fresh = files.where((f) => !uploaded.contains(f.id) && f.name.endsWith('.m4a'));
for (final f in fresh) {
  final callId = await api.uploadRecording(f, matchByTimestamp: callLog);  // 통화로그와 시각 매칭
  uploaded.add(f.id);
}

03 데이터 모델 (Drizzle / Postgres)

영속·공유 엔티티는 Postgres SSOT. 신규 PK는 UUIDv7, 조회는 keyset.

// elysia-server/src/db/schema/calls.ts
export const calls = pgTable('calls', {
  id: uuid().default(sql`uuidv7()`).primaryKey(),
  workspaceId: uuid().notNull().references(() => workspaces.id),
  contactId: uuid().references(() => contacts.id),     // 매칭된 거래처
  direction: text({ enum: ['inbound','outbound','missed'] }).notNull(),
  peerNumber: text().notNull(),
  startedAt: timestamp().notNull(),
  durationSec: integer(),
  recordingS3Key: text(),                               // 녹음 있을 때만
  status: text({ enum: ['uploaded','transcribing','analyzing','done','failed'] }).notNull(),
  createdAt: timestamp().defaultNow(),
});

export const transcripts = pgTable('transcripts', {
  id: uuid().default(sql`uuidv7()`).primaryKey(),
  callId: uuid().notNull().references(() => calls.id),
  provider: text().default('rtzr'),
  fullText: text(),
  segments: jsonb(),        // [{speaker, start, end, text}] 화자라벨
  confidence: real(),
});

export const actionPlans = pgTable('action_plans', {
  id: uuid().default(sql`uuidv7()`).primaryKey(),
  callId: uuid().notNull().references(() => calls.id),
  summary: text(),
  customerNeeds: jsonb(),    // 추출된 고객 니즈
  dealStage: text(),         // 딜 단계 추론
  nextActions: jsonb(),      // [{action, dueDate, priority}]
  createdAt: timestamp().defaultNow(),
});

export const autoReplyLogs = pgTable('auto_reply_logs', {
  id: uuid().default(sql`uuidv7()`).primaryKey(),
  workspaceId: uuid().notNull(),
  peerNumber: text().notNull(),
  message: text().notNull(),
  channel: text({ enum: ['device_sms','alimtalk','sms_fallback'] }).notNull(),
  sentAt: timestamp().defaultNow(),
});

04 STT → 액션플랜 파이프라인 (BullMQ)

업로드 후 비동기 2단계 잡. 각 단계 실패는 BullMQ retry·backoff. 진행률은 SSE로 모바일에 푸시.

// elysia-server/src/services/call-analysis.service.ts (핵심만)
// 1) 리턴제로 배치 STT (화자분리)
const stt = await rtzr.transcribe({
  audioUrl: s3.signedUrl(call.recordingS3Key),
  config: { diarization: { enable: true, speakers: 2 }, language: 'ko' },
});

// 2) Gemini 액션플랜 (구조화 출력)
const plan = await gemini.generate({
  model: settings.get('call-analysis'),   // agent-model-settings SSOT
  systemPrompt: SALES_ANALYSIS_PROMPT,           // 영업 도메인: 니즈·딜단계·이의제기·next step
  input: formatSpeakerLabeled(stt.segments),     // "[상담원] … [고객] …"
  responseSchema: ActionPlanSchema,              // summary, customerNeeds, dealStage, nextActions[]
});

// 3) 저장 + SSE 푸시
await db.insert(actionPlans).values({ callId: call.id, ...plan });
redis.publish(`call:${call.id}`, { status: 'done' });

05 부재중 자동 SMS

MVP는 Android 단말 직접 발송(무료·즉시), 제품화·iOS 대응은 050/070 착신전환 + 서버.

// telinfo: 부재중 감지 → 자동 SMS
Telephony.instance.listenIncomingSms; // 권한
// PhoneState 부재중 이벤트 / call_log 폴링
if (call.type == CallType.missed &&
    settings.autoReplyEnabled) {
  await Telephony.instance.sendSms(
    to: call.number,
    message: settings.autoReplyText, // "현재 출장중…"
  );
  api.logAutoReply(call.number, 'device_sms');
}

06 구현 단계 (DAG)

위상정렬 레이어. 같은 레이어는 병렬 가능, *=Critical Path, [S≤50 / M≤150 / L≤300 LOC].

07 리스크 & 대응

08 MVP 범위 & 일정