import apiClient from './index.js' /** * 通用的获取所有分页数据的函数 * @param {Function} apiCall - API调用函数 * @param {Object} params - 查询参数 * @returns {Promise} 所有页面的数据数组 */ const fetchAllPages = async (apiCall, params = {}) => { let allData = [] let page = 1 let hasNext = true console.log('Starting to fetch all pages for API call...') while (hasNext) { try { const currentParams = { ...params, page, page_size: 100 } // 每页100条,减少请求次数 console.log(`Fetching page ${page} with params:`, currentParams) const response = await apiCall(currentParams) if (response && response.results) { // 分页格式响应 allData = [...allData, ...response.results] hasNext = !!response.next console.log(`Page ${page}: Got ${response.results.length} items, total so far: ${allData.length}, hasNext: ${hasNext}`) } else if (Array.isArray(response)) { // 非分页格式响应(向后兼容) allData = response hasNext = false console.log('Non-paginated response detected, got all data at once:', allData.length, 'items') } else { console.log('Unexpected response format, stopping pagination') hasNext = false } page++ // 安全检查:防止无限循环 if (page > 100) { console.warn('Reached maximum page limit (100), stopping pagination') break } } catch (error) { console.error(`Error fetching page ${page}:`, error) throw error } } console.log(`Finished fetching all pages. Total items: ${allData.length}`) return allData } /** * 单页API调用函数(内部使用) * @param {Object} params - 查询参数(包含分页参数) * @returns {Promise} API响应 */ const getTasksPage = async (params = {}) => { const response = await apiClient.get('/api/tasks/', { params }) return response.data } /** * 获取所有作业任务 * @param {Object} params - 查询参数 * @param {number} params.student_id - 学生ID * @param {number} params.subject_id - 学科ID * @param {number} params.term_id - 学期ID * @returns {Promise} 作业任务列表(完整数据,已处理分页) */ export const getTasks = async (params = {}) => { try { // 构建查询参数,过滤掉null和undefined值 const queryParams = {} if (params.student_id) queryParams.student_id = params.student_id if (params.subject_id) queryParams.subject_id = params.subject_id if (params.term_id) queryParams.term_id = params.term_id console.log('Tasks API request params:', queryParams) // 使用通用分页函数获取所有数据 const allTasks = await fetchAllPages(getTasksPage, queryParams) console.log('Tasks API final result:', { totalCount: allTasks.length, sampleData: allTasks.slice(0, 3) // 显示前3条数据作为样例 }) return allTasks } catch (error) { console.error('Failed to fetch tasks:', error) throw error } } /** * 根据ID获取作业任务 * @param {number} taskId - 作业任务ID * @returns {Promise} 作业任务详情 */ export const getTaskById = async (taskId) => { try { const response = await apiClient.get(`/api/tasks/${taskId}/`) console.log('Task detail API response:', response.data) return response.data } catch (error) { console.error('Failed to fetch task detail:', error) throw error } } /** * 创建新的作业任务 * @param {Object} taskData - 作业任务数据 * @returns {Promise} 创建的作业任务 */ export const createTask = async (taskData) => { try { const response = await apiClient.post('/api/tasks/', taskData) console.log('Create task API response:', response.data) return response.data } catch (error) { console.error('Failed to create task:', error) throw error } } /** * 更新作业任务 * @param {number} taskId - 作业任务ID * @param {Object} taskData - 更新的作业任务数据 * @returns {Promise} 更新后的作业任务 */ export const updateTask = async (taskId, taskData) => { try { const response = await apiClient.patch(`/api/tasks/${taskId}/`, taskData) console.log('Update task API response:', response.data) return response.data } catch (error) { console.error('Failed to update task:', error) throw error } } /** * 删除作业任务 * @param {number} taskId - 作业任务ID * @returns {Promise} 删除结果 */ export const deleteTask = async (taskId) => { try { const response = await apiClient.delete(`/api/tasks/${taskId}/`) console.log('Delete task API response:', response.data) return response.data } catch (error) { console.error('Failed to delete task:', error) throw error } }