import apiClient, { apiEndpoints } from './index.js'

/**
 * 通用的获取所有分页数据的函数
 * @param {Function} apiCall - API调用函数
 * @param {Object} params - 查询参数
 * @returns {Promise<Array>} 所有页面的数据数组
 */
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 getSubjectsPage = async (params = {}) => {
  const response = await apiClient.get(apiEndpoints.SUBJECTS.LIST, { params })
  return response.data
}

// Get subject list
export const getSubjects = async () => {
  try {
    console.log('Fetching all subjects with pagination support...')

    // 使用通用分页函数获取所有数据
    const allSubjects = await fetchAllPages(getSubjectsPage)

    console.log('Subjects API final result:', {
      totalCount: allSubjects.length,
      sampleData: allSubjects.slice(0, 3) // 显示前3条数据作为样例
    })

    return allSubjects
  } catch (error) {
    console.error('Failed to fetch subjects:', error)
    throw new Error(error?.response?.data?.detail || error?.message || 'Failed to fetch subjects')
  }
}

// Update subject information
export const updateSubject = async (subjectId, subjectData) => {
  try {
    // Convert data format to match API requirements
    const apiData = {
      subject_name: subjectData.subject_name || '',
      enabled_flag: subjectData.enabled_flag || 'Y',
      primary_flag: subjectData.primary_flag || 'N',
      calendar_color: subjectData.calendar_color || '',
      sort_sequence: parseInt(subjectData.sort_sequence) || 0,
      tenant_id: subjectData.tenant_id || 1,
    }

    console.log('Sending update request:', {
      subjectId,
      url: apiEndpoints.SUBJECTS.UPDATE(subjectId),
      data: apiData
    })

    const response = await apiClient.patch(apiEndpoints.SUBJECTS.UPDATE(subjectId), apiData)
    return response.data
  } catch (error) {
    console.error('API error details:', {
      status: error?.response?.status,
      statusText: error?.response?.statusText,
      data: error?.response?.data,
      headers: error?.response?.headers
    })

    const errorMessage = error?.response?.data?.detail ||
                        error?.response?.data?.message ||
                        error?.response?.data?.error ||
                        `HTTP ${error?.response?.status}: ${error?.response?.statusText}` ||
                        error.message ||
                        'Failed to update subject'
    throw new Error(errorMessage)
  }
}

// Create subject
export const createSubject = async (subjectData) => {
  try {
    // Convert data format to match API requirements
    const apiData = {
      subject_name: subjectData.subject_name || '',
      enabled_flag: subjectData.enabled_flag || 'Y',
      primary_flag: subjectData.primary_flag || 'N',
      calendar_color: subjectData.calendar_color || '',
      sort_sequence: parseInt(subjectData.sort_sequence) || 0,
      tenant_id: subjectData.tenant_id || 1,
    }

    console.log('Sending create request:', {
      url: apiEndpoints.SUBJECTS.CREATE,
      data: apiData
    })

    const response = await apiClient.post(apiEndpoints.SUBJECTS.CREATE, apiData)
    return response.data
  } catch (error) {
    console.error('API error details:', {
      status: error?.response?.status,
      statusText: error?.response?.statusText,
      data: error?.response?.data,
      headers: error?.response?.headers
    })

    const errorMessage = error?.response?.data?.detail ||
                        error?.response?.data?.message ||
                        error?.response?.data?.error ||
                        `HTTP ${error?.response?.status}: ${error?.response?.statusText}` ||
                        error.message ||
                        'Failed to create subject'
    throw new Error(errorMessage)
  }
}

// Delete subject
export const deleteSubject = async (subjectId) => {
  try {
    console.log('Sending delete request:', {
      subjectId,
      url: apiEndpoints.SUBJECTS.DELETE(subjectId)
    })

    const response = await apiClient.delete(apiEndpoints.SUBJECTS.DELETE(subjectId))
    return response.data
  } catch (error) {
    console.error('API error details:', {
      status: error?.response?.status,
      statusText: error?.response?.statusText,
      data: error?.response?.data,
      headers: error?.response?.headers
    })

    const errorMessage = error?.response?.data?.detail ||
                        error?.response?.data?.message ||
                        error?.response?.data?.error ||
                        `HTTP ${error?.response?.status}: ${error?.response?.statusText}` ||
                        error.message ||
                        'Failed to delete subject'
    throw new Error(errorMessage)
  }
}