"use client"

import { z } from "zod"
import { createShipbuildingImportItem } from "../../service" // 아이템 생성 서버 액션

const SHIP_TYPES = ['A-MAX', 'S-MAX', 'LNGC', 'VLCC', 'CONT'] as const;

// 아이템 데이터 검증을 위한 Zod 스키마
const itemSchema = z.object({
  itemCode: z.string().min(1, "아이템 코드는 필수입니다"),
  workType: z.enum(["기장", "전장", "선실", "배관", "철의"], {
    required_error: "기능(공종)은 필수입니다",
  }),
  itemList: z.string().nullable().optional(),
});

interface ProcessResult {
  successCount: number;
  errorCount: number;
  errors?: Array<{ row: number; message: string }>;
}

/**
 * Excel 파일에서 가져온 조선 아이템 데이터 처리하는 함수
 */
export async function processFileImport(
  jsonData: Record<string, unknown>[],
  progressCallback?: (current: number, total: number) => void
): Promise<ProcessResult> {
  // 결과 카운터 초기화
  let successCount = 0;
  let errorCount = 0;
  const errors: Array<{ row: number; message: string }> = [];
  
  // 빈 행 등 필터링
  const dataRows = jsonData.filter(row => {
    // 빈 행 건너뛰기
    if (Object.values(row).every(val => !val)) {
      return false;
    }
    return true;
  });
  
  // 데이터 행이 없으면 빈 결과 반환
  if (dataRows.length === 0) {
    return { successCount: 0, errorCount: 0 };
  }
  
  // 각 행에 대해 처리
  for (let i = 0; i < dataRows.length; i++) {
    const row = dataRows[i];
    const rowIndex = i + 1; // 사용자에게 표시할 행 번호는 1부터 시작
    
    // 진행 상황 콜백 호출
    if (progressCallback) {
      progressCallback(i + 1, dataRows.length);
    }
    
    try {
      // 필드 매핑 (한글/영문 필드명 모두 지원)
      const itemCode = row["아이템 코드"] || row["itemCode"] || "";
      const workType = row["기능(공종)"] || row["workType"] || "";
      const itemList = row["아이템 리스트"] || row["itemList"] || null;
      
      // 데이터 정제
      const cleanedRow = {
        itemCode: typeof itemCode === 'string' ? itemCode.trim() : String(itemCode).trim(),
        workType: typeof workType === 'string' ? workType.trim() : String(workType).trim(),
        itemList: itemList ? (typeof itemList === 'string' ? itemList : String(itemList)) : null,
      };
      
      // 데이터 유효성 검사
      const validationResult = itemSchema.safeParse(cleanedRow);
      
      if (!validationResult.success) {
        const errorMessage = validationResult.error.errors.map(
          err => `${err.path.join('.')}: ${err.message}`
        ).join(', ');
        
        errors.push({ row: rowIndex, message: errorMessage });
        errorCount++;
        continue;
      }
      
      // 선종 데이터 처리
      const shipTypeEntries = SHIP_TYPES.map(type => ({
        type,
        value: row[type] ? String(row[type]).toUpperCase() === 'O' : false
      })).filter(entry => entry.value);
      console.log('shipTypeEntries:', shipTypeEntries);

      // 선종이 없는 경우에 "option" 값을 사용
      if (shipTypeEntries.length === 0) {
        // "option" 값으로 아이템 생성
        const result = await createShipbuildingImportItem({
          itemCode: cleanedRow.itemCode,
          itemName: "기술영업", // 기본값 사용
          workType: cleanedRow.workType as "기장" | "전장" | "선실" | "배관" | "철의",
          shipTypes: { "OPTION": true },
          description: null,
          itemList: cleanedRow.itemList,
        });
        
        if (result.success || !result.error) {
          successCount++;
        } else {
          errors.push({
            row: rowIndex,
            message: `OPTION: ${result.message || result.error || "알 수 없는 오류"}`
          });
          errorCount++;
        }
      } else {
        // 각 선종에 대해 아이템 생성
        for (const { type } of shipTypeEntries) {
          const result = await createShipbuildingImportItem({
            itemCode: cleanedRow.itemCode,
            itemName: "기술영업", // 기본값 사용
            workType: cleanedRow.workType as "기장" | "전장" | "선실" | "배관" | "철의",
            shipTypes: { [type]: true },
            description: null,
            itemList: cleanedRow.itemList,
          });
          
          if (result.success || !result.error) {
            successCount++;
          } else {
            errors.push({
              row: rowIndex,
              message: `${type}: ${result.message || result.error || "알 수 없는 오류"}`
            });
            errorCount++;
          }
        }
      }
    } catch (error) {
      console.error(`${rowIndex}행 처리 오류:`, error);
      errors.push({
        row: rowIndex,
        message: error instanceof Error ? error.message : "알 수 없는 오류"
      });
      errorCount++;
    }
    
    // 비동기 작업 쓰로틀링
    if (i % 5 === 0) {
      await new Promise(resolve => setTimeout(resolve, 10));
    }
  }
  
  // 처리 결과 반환
  return {
    successCount,
    errorCount,
    errors: errors.length > 0 ? errors : undefined
  };
}