cunkebao_v3/SuperAdmin/lib/traffic-pool-api.ts

import { apiRequest, ApiResponse } from './api-utils';

/**
 * 客户数据接口
 */
export interface Customer {
  id: number;
  companyId: number;
  avatar: string;
  nickname: string;
  wechatId: string;
  gender: string;
  region: string;
  tags: string[];
  source: string;
  companyName: string;
  ownerWechatId: string;
  ownerWechatNickname: string;
  ownerWechatAlias: string;
  ownerWechatDisplay: string;
  createTime: string;
  mobile: number;
}

export interface WechatFilterOption {
  companyId: number;
  companyName: string;
  ownerWechatId: string;
  ownerWechatNickname: string;
  ownerWechatAlias: string;
  ownerWechatDisplay: string;
  customerCount: number;
}

/**
 * 客户详情接口
 */
export interface CustomerDetail {
  source: string;
  sources?: Array<{ sourceName: string; createTime: string }>;
  journey?: Array<{ type: string; label: string; time: string }>;
  journeySlicedByOwner?: boolean;
  addTime: string | null;
  projectName: string;
  avatar: string;
  nickname: string;
  region: string;
  gender: string;
  tags: string[];
  wechatId?: string;
  ownerWechatId?: string;
  ownerWechatDisplay?: string;
  ownerWechat?: { wechatId: string; nickname: string; alias: string; avatar: string };
  rfmScore?: number;
  rfmType?: number;
  rfmTypeLabel?: string;
  totalOrderAmount?: number;
  totalOrderCount?: number;
  phone?: string;
  realName?: string;
}

/**
 * 分页响应数据类型
 */
export interface PaginatedResponse<T> {
  list: T[];
  total: number;
  page: number;
  limit: number;
}

export interface TrafficPoolListParams {
  page?: number;
  limit?: number;
  keyword?: string;
  companyId?: number;
  ownerWechatId?: string;
  gender?: string;
}

/**
 * 获取客户池列表
 */
export async function getTrafficPoolList(
  params: TrafficPoolListParams = {}
): Promise<ApiResponse<PaginatedResponse<Customer>>> {
  const {
    page = 1,
    limit = 50,
    keyword = '',
    companyId = 0,
    ownerWechatId = '',
    gender = '',
  } = params;

  const urlParams = new URLSearchParams();
  urlParams.append('page', page.toString());
  urlParams.append('limit', limit.toString());
  if (keyword) urlParams.append('keyword', keyword);
  if (companyId > 0) urlParams.append('companyId', companyId.toString());
  if (ownerWechatId) urlParams.append('ownerWechatId', ownerWechatId);
  if (gender && gender !== 'all') urlParams.append('gender', gender);
  urlParams.append('lite', '1');

  return apiRequest(`/trafficPool/list?${urlParams.toString()}`);
}

export interface TrafficPoolSummary {
  scope: "global" | "company";
  companyId?: number;
  totalCustomers: number;
  boundCustomers: number;
  unboundCustomers: number;
  pageSize: number;
  totalPages: number;
  topNormalProjects?: Array<{
    companyId: number;
    companyName: string;
    customerCount: number;
  }>;
}

export async function getTrafficPoolSummary(
  companyId: number = 0,
  limit: number = 50
): Promise<ApiResponse<TrafficPoolSummary>> {
  const q = new URLSearchParams();
  if (companyId > 0) q.append("companyId", String(companyId));
  q.append("limit", String(limit));
  return apiRequest(`/trafficPool/summary?${q.toString()}`);
}

export interface SyncDetectResult {
  companyId: number;
  wechatAccountBackfill: {
    companyId: number;
    deviceWechats: number;
    backfilled: number;
    columnPresent: boolean;
  };
  ownerWechatRepair: {
    companyId: number;
    scanned: number;
    matched: number;
    updated: number;
    pending: number;
    ownerFilledTotal: number;
    deviceWechatCount: number;
    ownerMatchedToDevice: number;
    pendingExamples: Array<{ id: number; identifier: string; phone: string }>;
  };
  reportFile: string;
  reportCsv: string;
}

export async function runWechatSyncDetect(
  companyId: number,
  limit: number = 5000
): Promise<ApiResponse<SyncDetectResult>> {
  return apiRequest("/wechat/sync-detect", "POST", { companyId, limit });
}

/**
 * 归属微信号筛选项（按项目 + 微信号 + 客资数）
 */
export async function getTrafficPoolWechatFilters(
  companyId: number = 0
): Promise<ApiResponse<{ list: WechatFilterOption[] }>> {
  const q = companyId > 0 ? `?companyId=${companyId}` : '';
  return apiRequest(`/trafficPool/wechat-filters${q}`);
}

/**
 * 批量迁移客资到目标项目
 */
export async function migrateTrafficPoolCustomers(
  poolCompanyIds: number[],
  targetProjectId: number
): Promise<ApiResponse<{ migrated: number }>> {
  return apiRequest('/trafficPool/migrate', 'POST', {
    poolCompanyIds,
    targetProjectId,
  });
}

/**
 * 获取客户详情
 */
export async function getCustomerDetail(id: string): Promise<ApiResponse<CustomerDetail>> {
  return apiRequest(`/trafficPool/detail?id=${id}`);
}