"use server"

import { oracleKnex } from '@/lib/oracle-db/db'
import { getUserByEmployeeNumber } from '@/lib/users/service'

// 구매그룹코드 타입 정의
export interface PurchaseGroupCode {
  PURCHASE_GROUP_CODE: string // 구매그룹코드
  DISPLAY_NAME: string // 표시명 (이름_부서_퇴직/전배정보)
  EMPLOYEE_NUMBER: string // 사번
}

// 구매그룹코드 + 사용자 정보 타입
export interface PurchaseGroupCodeWithUser extends PurchaseGroupCode {
  user?: {
    id: number
    name: string
    email: string
    employeeNumber: string | null
    // 필요한 다른 사용자 필드들...
  } | null
}

// 테스트 환경용 폴백 데이터
const FALLBACK_TEST_DATA: PurchaseGroupCode[] = [
  { PURCHASE_GROUP_CODE: '12L', DISPLAY_NAME: '김철수_구매팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1001234' },
  { PURCHASE_GROUP_CODE: '32F', DISPLAY_NAME: '이영희_자재팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1002345' },
  { PURCHASE_GROUP_CODE: '45A', DISPLAY_NAME: '박민수_조달팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1003456' },
  { PURCHASE_GROUP_CODE: '67K', DISPLAY_NAME: '정수진_구매1팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1004567' },
  { PURCHASE_GROUP_CODE: '89D', DISPLAY_NAME: '최동욱_구매2팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1005678' },
  { PURCHASE_GROUP_CODE: '11B', DISPLAY_NAME: '강미라_자재관리팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1006789' },
  { PURCHASE_GROUP_CODE: '23G', DISPLAY_NAME: '윤성호_구매기획팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1007890' },
  { PURCHASE_GROUP_CODE: '56H', DISPLAY_NAME: '임지훈_조달지원팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1008901' },
  { PURCHASE_GROUP_CODE: '78M', DISPLAY_NAME: '한소희_구매운영팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1009012' },
  { PURCHASE_GROUP_CODE: '90C', DISPLAY_NAME: '오준석_전략구매팀_재직(테스트데이터 - 오라클 페칭 실패시)', EMPLOYEE_NUMBER: '1010123' },
]

/**
 * 모든 구매그룹코드 목록 조회 (Oracle에서 전체 조회, 실패 시 폴백 데이터 사용)
 * CMCTB_CDNM, CMCTB_CD 테이블에서 CD_CLF = 'MMA070' 조건으로 조회
 * 클라이언트에서 검색/필터링 수행
 */
export async function getPurchaseGroupCodes(): Promise<{
  success: boolean
  data: PurchaseGroupCode[]
  error?: string
  isUsingFallback?: boolean
}> {
  try {
    console.log('📋 [getPurchaseGroupCodes] Oracle 쿼리 시작...')

    const result = await oracleKnex.raw(`
      SELECT 
        CD.CD AS PURCHASE_GROUP_CODE,
        NM.CDNM AS DISPLAY_NAME,
        CD.USR_DF_CHAR_9 AS EMPLOYEE_NUMBER
      FROM CMCTB_CDNM NM
      JOIN CMCTB_CD CD 
        ON NM.CD_CLF = CD.CD_CLF
        AND NM.CD = CD.CD
        AND NM.CD2 = CD.CD3
      WHERE NM.CD_CLF = 'MMA070'
        AND CD.DEL_YN != 'Y'
      ORDER BY CD.CD
    `)

    // Oracle raw query의 결과는 rows 배열에 들어있음
    const rows = (result.rows || result) as Array<Record<string, unknown>>
    
    console.log(`✅ [getPurchaseGroupCodes] Oracle 쿼리 성공 - ${rows.length}건 조회`)
    
    // null 값 필터링
    const cleanedResult = rows
      .filter((item) => 
        item.PURCHASE_GROUP_CODE && 
        item.DISPLAY_NAME && 
        item.EMPLOYEE_NUMBER
      )
      .map((item) => ({
        PURCHASE_GROUP_CODE: String(item.PURCHASE_GROUP_CODE),
        DISPLAY_NAME: String(item.DISPLAY_NAME),
        EMPLOYEE_NUMBER: String(item.EMPLOYEE_NUMBER)
      }))

    console.log(`✅ [getPurchaseGroupCodes] 필터링 후 ${cleanedResult.length}건`)

    return {
      success: true,
      data: cleanedResult,
      isUsingFallback: false
    }
  } catch (error) {
    console.error('❌ [getPurchaseGroupCodes] Oracle 오류:', error)
    console.log('🔄 [getPurchaseGroupCodes] 폴백 테스트 데이터 사용 (' + FALLBACK_TEST_DATA.length + '건)')
    return {
      success: true,
      data: FALLBACK_TEST_DATA,
      isUsingFallback: true
    }
  }
}

/**
 * 구매그룹코드(들)에 사용자 정보 추가 (1개 또는 여러 개 처리)
 * @param codes - 단일 또는 배열 형태의 구매그룹코드
 * @returns 사용자 정보가 포함된 구매그룹코드 배열
 */
export async function addUsersToCodesAsync(
  codes: PurchaseGroupCode | PurchaseGroupCode[]
): Promise<PurchaseGroupCodeWithUser[]> {
  try {
    // 배열로 정규화
    const codesArray = Array.isArray(codes) ? codes : [codes]

    console.log(`👤 [addUsersToCodesAsync] ${codesArray.length}개 구매그룹코드에 대한 사용자 정보 조회 시작`)

    // 각 구매그룹코드에 대해 사용자 정보 조회
    const withUsers = await Promise.all(
      codesArray.map(async (code) => {
        console.log(`  🔍 [addUsersToCodesAsync] 사번 ${code.EMPLOYEE_NUMBER} 조회 중...`)
        const user = await getUserByEmployeeNumber(code.EMPLOYEE_NUMBER)
        
        if (user) {
          console.log(`  ✅ [addUsersToCodesAsync] 사번 ${code.EMPLOYEE_NUMBER} → 사용자 찾음: ${user.name}`)
        } else {
          console.log(`  ⚠️  [addUsersToCodesAsync] 사번 ${code.EMPLOYEE_NUMBER} → 사용자 없음`)
        }
        
        return {
          ...code,
          user: user ? {
            id: user.id,
            name: user.name,
            email: user.email,
            employeeNumber: user.employeeNumber,
          } : null
        }
      })
    )

    return withUsers
  } catch (error) {
    console.error('❌ [addUsersToCodesAsync] 오류:', error)
    const codesArray = Array.isArray(codes) ? codes : [codes]
    return codesArray.map(code => ({ ...code, user: null }))
  }
}