faet:列表做好了，开始做其他的

2025-07-09 16:22:13 +08:00
parent dfc1637d6a
commit 4367d5a5f3
6 changed files with 776 additions and 625 deletions
--- a/nkebao/src/api/momentsSync.ts
+++ b/nkebao/src/api/momentsSync.ts
@@ -1,26 +1,111 @@
-import { get, post } from './request';
+import { get, post, del } from './request';
+import { 
+  MomentsSyncTask, 
+  CreateMomentsSyncData, 
+  UpdateMomentsSyncData, 
+  SyncRecord,
+  ApiResponse,
+  PaginatedResponse 
+} from '@/types/moments-sync';

-export interface MomentsSyncDevice {
-  id: string;
-  name: string;
-  status: 'idle' | 'syncing' | 'success' | 'error';
-  lastSyncTime: string;
-  progress: number; // 0-100
-  log: string;
+// 获取朋友圈同步任务列表
+export async function fetchMomentsSyncTasks(): Promise<MomentsSyncTask[]> {
+  try {
+    const res = await get<ApiResponse<PaginatedResponse<MomentsSyncTask>>>('/v1/workbench/list?type=2&page=1&limit=100');
+    
+    if (res.code === 200 && res.data) {
+      return res.data.list || [];
+    }
+    return [];
+  } catch (error) {
+    console.error('获取朋友圈同步任务失败:', error);
+    return [];
+  }
 }

-export async function fetchMomentsSyncDevices(search?: string) {
-  return get('/api/moments-sync/list', search ? { params: { search } } : undefined);
+// 获取单个任务详情
+export async function fetchMomentsSyncTaskDetail(id: string): Promise<MomentsSyncTask | null> {
+  try {
+    const res = await get<ApiResponse<MomentsSyncTask>>(`/v1/workbench/detail/${id}`);
+    if (res.code === 200 && res.data) {
+      return res.data;
+    }
+    return null;
+  } catch (error) {
+    console.error('获取任务详情失败:', error);
+    return null;
+  }
 }

-export async function syncMoments(id: string) {
-  return post('/api/moments-sync/sync', { id });
+// 创建朋友圈同步任务
+export async function createMomentsSyncTask(data: CreateMomentsSyncData): Promise<ApiResponse> {
+  return post('/v1/workbench/create', {
+    ...data,
+    type: 2 // 朋友圈同步类型
+  });
 }

-export async function syncAllMoments() {
-  return post('/api/moments-sync/sync-all');
+// 更新朋友圈同步任务
+export async function updateMomentsSyncTask(data: UpdateMomentsSyncData): Promise<ApiResponse> {
+  return post('/v1/workbench/update', {
+    ...data,
+    type: 2 // 朋友圈同步类型
+  });
 }

-export async function fetchMomentsLog(id: string) {
-  return get('/api/moments-sync/log', { params: { id } });
-} 
+// 删除朋友圈同步任务
+export async function deleteMomentsSyncTask(id: string): Promise<ApiResponse> {
+  return del('/v1/workbench/delete', { params: { id } });
+}
+
+// 切换任务状态
+export async function toggleMomentsSyncTask(id: string, status: string): Promise<ApiResponse> {
+  return post('/v1/workbench/update-status', { id, status });
+}
+
+// 复制朋友圈同步任务
+export async function copyMomentsSyncTask(id: string): Promise<ApiResponse> {
+  return post('/v1/workbench/copy', { id });
+}
+
+// 获取同步记录
+export async function fetchSyncRecords(
+  workbenchId: string, 
+  page: number = 1, 
+  limit: number = 20,
+  keyword?: string
+): Promise<PaginatedResponse<SyncRecord>> {
+  try {
+    const params = new URLSearchParams({
+      workbenchId,
+      page: page.toString(),
+      limit: limit.toString()
+    });
+    
+    if (keyword) {
+      params.append('keyword', keyword);
+    }
+    
+    const res = await get<ApiResponse<PaginatedResponse<SyncRecord>>>(`/v1/workbench/sync-records?${params.toString()}`);
+    
+    if (res.code === 200 && res.data) {
+      return res.data;
+    }
+    return { list: [], total: 0, page, limit };
+  } catch (error) {
+    console.error('获取同步记录失败:', error);
+    return { list: [], total: 0, page, limit };
+  }
+}
+
+// 手动同步
+export async function syncMoments(id: string): Promise<ApiResponse> {
+  return post('/v1/workbench/sync', { id });
+}
+
+// 同步所有任务
+export async function syncAllMoments(): Promise<ApiResponse> {
+  return post('/v1/workbench/sync-all', { type: 2 });
+}
+
+export type { MomentsSyncTask, SyncRecord, CreateMomentsSyncData };