cunkebao_v3/SuperAdmin/lib/project-workspace-api.ts

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

export interface ProjectWorkspace {
  projectId: number;
  companyId: number;
  name: string;
  status: number;
  master: any;
  deviceStats: { total: number; online: number; offline: number };
  assetStats: {
    customerTotal: number;
    totalConsumption: number;
    totalOrders: number;
    avgRfmScore: number;
    rfmDistribution: { rfmType: string; cnt: number }[];
  };
  wechatStats: { total: number; loggedIn: number; list: any[] };
  contentCount: number;
  planCount: number;
  subUserCount: number;
}

export async function getProjectWorkspace(projectId: number): Promise<ApiResponse<ProjectWorkspace>> {
  return apiRequest(`/project/workspace/${projectId}`);
}

export async function getProjectTraffic(
  projectId: number,
  page = 1,
  limit = 20,
  keyword = "",
  sortBy = "rfmScore",
): Promise<ApiResponse<{ list: any[]; total: number }>> {
  const q = new URLSearchParams({ page: String(page), limit: String(limit), sortBy });
  if (keyword) q.append("keyword", keyword);
  return apiRequest(`/project/traffic/${projectId}?${q.toString()}`);
}

export async function getProjectContentLibrary(
  projectId: number,
  page = 1,
  limit = 20,
): Promise<ApiResponse<{ list: any[]; total: number }>> {
  return apiRequest(`/project/content-library/${projectId}?page=${page}&limit=${limit}`);
}

export async function getProjectPlanScenes(projectId: number): Promise<ApiResponse<{ list: any[] }>> {
  return apiRequest(`/project/plan-scenes/${projectId}`);
}

/** 项目级场景获客开关 */
export async function updateProjectPlanSceneStatus(
  projectId: number,
  sceneId: number,
  status: number,
): Promise<ApiResponse<{ id: number; status: number }>> {
  return apiRequest(`/project/plan-scenes/update/${projectId}`, "POST", { sceneId, status });
}

/** 项目级工作台功能列表 */
export async function getProjectWorkbenchFunctions(
  projectId: number,
): Promise<ApiResponse<{ list: any[] }>> {
  return apiRequest(`/project/workbench-functions/${projectId}`);
}

/** 项目级工作台功能开关 */
export async function updateProjectWorkbenchFunctionStatus(
  projectId: number,
  functionId: number,
  status: number,
): Promise<ApiResponse<{ id: number; status: number }>> {
  return apiRequest(`/project/workbench-functions/update/${projectId}`, "POST", {
    functionId,
    status,
  });
}

export async function migrateProjectTraffic(
  projectId: number,
  poolCompanyIds: number[],
  targetProjectId: number,
): Promise<ApiResponse<{ migrated: number }>> {
  return apiRequest(`/project/traffic/migrate/${projectId}`, "POST", {
    poolCompanyIds,
    targetProjectId,
  });
}

export async function migrateProjectWechatFriends(
  projectId: number,
  payload: {
    wechatId: string;
    devices: number[];
    greeting: string;
    inherit?: boolean;
    firstMessage?: string;
  },
): Promise<ApiResponse<{ taskId: number; friendCount: number }>> {
  return apiRequest(`/project/wechat/migrate/${projectId}`, "POST", payload);
}

export async function saveProjectContentLibrary(
  projectId: number,
  payload: { id?: number; name?: string; status?: number },
): Promise<ApiResponse<{ id: number; action: string }>> {
  return apiRequest(`/project/content-library/save/${projectId}`, "POST", payload);
}

export async function migrateProjectContentLibrary(
  projectId: number,
  libraryId: number,
  targetProjectId: number,
): Promise<ApiResponse<null>> {
  return apiRequest(`/project/content-library/migrate/${projectId}`, "POST", {
    libraryId,
    targetProjectId,
  });
}