import { Request, Response } from "express";
import { logger } from "../utils/logger";
import { AuthenticatedRequest } from "../types/auth";
import { ApiResponse } from "../types/common";
import { Client } from "pg";
import { PrismaClient } from "@prisma/client";
import config from "../config/environment";
import { AdminService } from "../services/adminService";
import { EncryptUtil } from "../utils/encryptUtil";

const prisma = new PrismaClient();

/**
 * 관리자 메뉴 목록 조회
 */
export async function getAdminMenus(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    logger.info("=== 관리자 메뉴 목록 조회 시작 ===");

    // 현재 로그인한 사용자의 회사 코드와 로케일 가져오기
    const userCompanyCode = req.user?.companyCode || "ILSHIN";
    const userLang = (req.query.userLang as string) || "ko";

    logger.info(`사용자 회사 코드: ${userCompanyCode}`);
    logger.info(`사용자 로케일: ${userLang}`);

    const paramMap = {
      userCompanyCode,
      userLang,
      SYSTEM_NAME: "PLM",
    };

    const menuList = await AdminService.getAdminMenuList(paramMap);

    logger.info(`관리자 메뉴 조회 결과: ${menuList.length}개`);
    if (menuList.length > 0) {
      logger.info("첫 번째 메뉴:", menuList[0]);
    }

    const response: ApiResponse<any[]> = {
      success: true,
      message: "관리자 메뉴 목록 조회 성공",
      data: menuList,
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("관리자 메뉴 목록 조회 중 오류 발생:", error);

    const response: ApiResponse<null> = {
      success: false,
      message: "관리자 메뉴 목록 조회 중 오류가 발생했습니다.",
      error: {
        code: "ADMIN_MENU_LIST_ERROR",
        details: error instanceof Error ? error.message : "Unknown error",
      },
    };

    res.status(500).json(response);
  }
}

/**
 * 사용자 메뉴 목록 조회
 */
export async function getUserMenus(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    logger.info("=== 사용자 메뉴 목록 조회 시작 ===");

    // 현재 로그인한 사용자의 회사 코드와 로케일 가져오기
    const userCompanyCode = req.user?.companyCode || "ILSHIN";
    const userLang = (req.query.userLang as string) || "ko";

    logger.info(`사용자 회사 코드: ${userCompanyCode}`);
    logger.info(`사용자 로케일: ${userLang}`);

    const paramMap = {
      userCompanyCode,
      userLang,
      SYSTEM_NAME: "PLM",
    };

    const menuList = await AdminService.getUserMenuList(paramMap);

    logger.info(`사용자 메뉴 조회 결과: ${menuList.length}개`);
    if (menuList.length > 0) {
      logger.info("첫 번째 메뉴:", menuList[0]);
    }

    const response: ApiResponse<any[]> = {
      success: true,
      message: "사용자 메뉴 목록 조회 성공",
      data: menuList,
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("사용자 메뉴 목록 조회 중 오류 발생:", error);

    const response: ApiResponse<null> = {
      success: false,
      message: "사용자 메뉴 목록 조회 중 오류가 발생했습니다.",
      error: {
        code: "USER_MENU_LIST_ERROR",
        details: error instanceof Error ? error.message : "Unknown error",
      },
    };

    res.status(500).json(response);
  }
}

/**
 * 메뉴 정보 조회
 */
export async function getMenuInfo(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { menuId } = req.params;
    logger.info(`=== 메뉴 정보 조회 시작 - menuId: ${menuId} ===`);

    const menuInfo = await AdminService.getMenuInfo(menuId);

    if (!menuInfo) {
      const response: ApiResponse<null> = {
        success: false,
        message: "메뉴를 찾을 수 없습니다.",
        error: {
          code: "MENU_NOT_FOUND",
          details: `Menu ID: ${menuId}`,
        },
      };
      res.status(404).json(response);
      return;
    }

    const response: ApiResponse<any> = {
      success: true,
      message: "메뉴 정보 조회 성공",
      data: menuInfo,
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("메뉴 정보 조회 중 오류 발생:", error);

    const response: ApiResponse<null> = {
      success: false,
      message: "메뉴 정보 조회 중 오류가 발생했습니다.",
      error: {
        code: "MENU_INFO_ERROR",
        details: error instanceof Error ? error.message : "Unknown error",
      },
    };

    res.status(500).json(response);
  }
}

/**
 * GET /api/admin/users
 * 사용자 목록 조회 API
 * 기존 Java AdminController.getUserList() 포팅
 */
export const getUserList = async (req: AuthenticatedRequest, res: Response) => {
  try {
    logger.info("사용자 목록 조회 요청", {
      query: req.query,
      user: req.user,
    });

    const {
      page = 1,
      countPerPage = 20,
      // 통합 검색 (전체 필드 대상)
      search,
      // 고급 검색 (개별 필드별)
      searchField,
      searchValue,
      search_sabun,
      search_companyName,
      search_deptName,
      search_positionName,
      search_userId,
      search_userName,
      search_tel,
      search_email,
      // 기존 필터
      deptCode,
      status,
    } = req.query;

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString: config.databaseUrl,
    });

    await client.connect();

    try {
      // 기본 사용자 목록 조회 쿼리
      let query = `
        SELECT 
          u.sabun,
          u.user_id,
          u.user_name,
          u.user_name_eng,
          u.dept_code,
          u.dept_name,
          u.position_code,
          u.position_name,
          u.email,
          u.tel,
          u.cell_phone,
          u.user_type,
          u.user_type_name,
          u.regdate,
          u.status,
          u.company_code,
          u.locale,
          d.dept_name as dept_name_full
        FROM user_info u
        LEFT JOIN dept_info d ON u.dept_code = d.dept_code
        WHERE 1=1
      `;

      const queryParams: any[] = [];
      let paramIndex = 1;
      let searchType = "none";

      // 검색 조건 처리
      if (search && typeof search === "string" && search.trim()) {
        // 통합 검색 (우선순위: 모든 주요 필드에서 검색)
        searchType = "unified";
        const searchTerm = search.trim();

        query += ` AND (
          UPPER(COALESCE(u.sabun, '')) LIKE UPPER($${paramIndex}) OR
          UPPER(COALESCE(u.user_type_name, '')) LIKE UPPER($${paramIndex}) OR
          UPPER(COALESCE(u.dept_name, '')) LIKE UPPER($${paramIndex}) OR
          UPPER(COALESCE(u.position_name, '')) LIKE UPPER($${paramIndex}) OR
          UPPER(COALESCE(u.user_id, '')) LIKE UPPER($${paramIndex}) OR
          UPPER(COALESCE(u.user_name, '')) LIKE UPPER($${paramIndex}) OR
          UPPER(COALESCE(u.tel, '')) LIKE UPPER($${paramIndex}) OR
          UPPER(COALESCE(u.cell_phone, '')) LIKE UPPER($${paramIndex}) OR
          UPPER(COALESCE(u.email, '')) LIKE UPPER($${paramIndex})
        )`;
        queryParams.push(`%${searchTerm}%`);
        paramIndex++;

        logger.info("통합 검색 실행", { searchTerm });
      } else if (searchField && searchValue) {
        // 단일 필드 검색
        searchType = "single";
        const fieldMap: { [key: string]: string } = {
          sabun: "u.sabun",
          companyName: "u.user_type_name",
          deptName: "u.dept_name",
          positionName: "u.position_name",
          userId: "u.user_id",
          userName: "u.user_name",
          tel: "u.tel",
          cellPhone: "u.cell_phone",
          email: "u.email",
        };

        if (fieldMap[searchField as string]) {
          if (searchField === "tel") {
            // 전화번호는 TEL과 CELL_PHONE 모두 검색
            query += ` AND (UPPER(u.tel) LIKE UPPER($${paramIndex}) OR UPPER(u.cell_phone) LIKE UPPER($${paramIndex}))`;
          } else {
            query += ` AND UPPER(${fieldMap[searchField as string]}) LIKE UPPER($${paramIndex})`;
          }
          queryParams.push(`%${searchValue}%`);
          paramIndex++;

          logger.info("단일 필드 검색 실행", { searchField, searchValue });
        }
      } else {
        // 고급 검색 (개별 필드별 AND 조건)
        const advancedSearchFields = [
          { param: search_sabun, field: "u.sabun" },
          { param: search_companyName, field: "u.user_type_name" },
          { param: search_deptName, field: "u.dept_name" },
          { param: search_positionName, field: "u.position_name" },
          { param: search_userId, field: "u.user_id" },
          { param: search_userName, field: "u.user_name" },
          { param: search_email, field: "u.email" },
        ];

        let hasAdvancedSearch = false;

        for (const { param, field } of advancedSearchFields) {
          if (param && typeof param === "string" && param.trim()) {
            query += ` AND UPPER(${field}) LIKE UPPER($${paramIndex})`;
            queryParams.push(`%${param.trim()}%`);
            paramIndex++;
            hasAdvancedSearch = true;
          }
        }

        // 전화번호 검색 (TEL 또는 CELL_PHONE)
        if (search_tel && typeof search_tel === "string" && search_tel.trim()) {
          query += ` AND (UPPER(u.tel) LIKE UPPER($${paramIndex}) OR UPPER(u.cell_phone) LIKE UPPER($${paramIndex}))`;
          queryParams.push(`%${search_tel.trim()}%`);
          paramIndex++;
          hasAdvancedSearch = true;
        }

        if (hasAdvancedSearch) {
          searchType = "advanced";
          logger.info("고급 검색 실행", {
            search_sabun,
            search_companyName,
            search_deptName,
            search_positionName,
            search_userId,
            search_userName,
            search_tel,
            search_email,
          });
        }
      }

      // 기존 필터들
      if (deptCode) {
        query += ` AND u.dept_code = $${paramIndex}`;
        queryParams.push(deptCode);
        paramIndex++;
      }

      if (status) {
        query += ` AND u.status = $${paramIndex}`;
        queryParams.push(status);
        paramIndex++;
      }

      // 정렬
      query += ` ORDER BY u.regdate DESC, u.user_name`;

      // 페이징 파라미터 제외한 카운트용 파라미터
      const countParams = [...queryParams];

      // 총 개수 조회를 위해 기존 쿼리를 COUNT로 변환
      const countQuery = query
        .replace(/SELECT[\s\S]*?FROM/i, "SELECT COUNT(*) as total FROM")
        .replace(/ORDER BY.*$/i, "");

      const countResult = await client.query(countQuery, countParams);
      const totalCount = parseInt(countResult.rows[0].total);

      // 페이징 적용
      const offset = (Number(page) - 1) * Number(countPerPage);
      query += ` LIMIT $${paramIndex} OFFSET $${paramIndex + 1}`;
      queryParams.push(Number(countPerPage), offset);

      // 사용자 목록 조회
      const result = await client.query(query, queryParams);
      const users = result.rows;

      // 디버깅: 원본 데이터베이스 조회 결과 로깅
      logger.info("=== 원본 데이터베이스 조회 결과 ===");
      logger.info("총 조회된 사용자 수:", users.length);
      if (users.length > 0) {
        logger.info("첫 번째 사용자 원본 데이터:", {
          user_id: users[0].user_id,
          user_name: users[0].user_name,
          user_name_eng: users[0].user_name_eng,
          dept_code: users[0].dept_code,
          dept_name: users[0].dept_name,
          position_code: users[0].position_code,
          position_name: users[0].position_name,
          email: users[0].email,
          tel: users[0].tel,
          cell_phone: users[0].cell_phone,
          user_type: users[0].user_type,
          user_type_name: users[0].user_type_name,
          status: users[0].status,
          company_code: users[0].company_code,
          locale: users[0].locale,
          regdate: users[0].regdate,
        });
      }

      // 응답 데이터 가공
      const processedUsers = users.map((user) => {
        // 디버깅: 각 필드별 값 확인
        const processedUser = {
          userId: user.user_id,
          userName: user.user_name,
          userNameEng: user.user_name_eng || null,
          sabun: user.sabun || null,
          deptCode: user.dept_code || null,
          deptName: user.dept_name || user.dept_name_full || null,
          positionCode: user.position_code || null,
          positionName: user.position_name || null,
          email: user.email || null,
          tel: user.tel || null,
          cellPhone: user.cell_phone || null,
          userType: user.user_type || null,
          userTypeName: user.user_type_name || null,
          status: user.status || "active",
          companyCode: user.company_code || null,
          locale: user.locale || null,
          regDate: user.regdate
            ? user.regdate.toISOString().split("T")[0]
            : null,
        };

        // 빈 문자열을 null로 변환
        Object.keys(processedUser).forEach((key) => {
          if (processedUser[key as keyof typeof processedUser] === "") {
            (processedUser as any)[key] = null;
          }
        });

        // 디버깅: 가공된 데이터 로깅
        logger.info(`사용자 ${user.user_id} 가공 결과:`, {
          원본: {
            user_id: user.user_id,
            user_name: user.user_name,
            user_name_eng: user.user_name_eng,
            dept_code: user.dept_code,
            dept_name: user.dept_name,
            position_code: user.position_code,
            position_name: user.position_name,
            email: user.email,
            tel: user.tel,
            cell_phone: user.cell_phone,
            user_type: user.user_type,
            user_type_name: user.user_type_name,
            status: user.status,
            company_code: user.company_code,
            locale: user.locale,
            regdate: user.regdate,
          },
          가공후: processedUser,
        });

        return processedUser;
      });

      const response = {
        success: true,
        data: processedUsers,
        total: totalCount,
        searchType, // 검색 타입 정보 (unified, single, advanced, none)
        pagination: {
          page: Number(page),
          limit: Number(countPerPage),
          totalPages: Math.ceil(totalCount / Number(countPerPage)),
        },
        message: "사용자 목록 조회 성공",
      };

      logger.info("사용자 목록 조회 성공", {
        totalCount,
        returnedCount: processedUsers.length,
        searchType,
        currentPage: Number(page),
        countPerPage: Number(countPerPage),
      });

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("사용자 목록 조회 실패", { error });
    res.status(500).json({
      success: false,
      message: "사용자 목록 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * GET /api/admin/user-locale
 * 사용자 로케일 조회 API
 */
export const getUserLocale = async (
  req: AuthenticatedRequest,
  res: Response
): Promise<void> => {
  try {
    logger.info("사용자 로케일 조회 요청", {
      query: req.query,
      user: req.user,
    });

    if (!req.user?.userId) {
      res.status(400).json({
        success: false,
        message: "사용자 정보가 없습니다.",
      });
      return;
    }

    // 데이터베이스에서 사용자 로케일 조회
    const prisma = (await import("../config/database")).default;

    const userInfo = await prisma.user_info.findFirst({
      where: {
        user_id: req.user.userId,
      },
      select: {
        locale: true,
      },
    });

    let userLocale = "en"; // 기본값

    if (userInfo?.locale) {
      userLocale = userInfo.locale;
      logger.info("데이터베이스에서 사용자 로케일 조회 성공", {
        userId: req.user.userId,
        locale: userLocale,
      });
    } else {
      logger.info("사용자 로케일이 설정되지 않음, 기본값 사용", {
        userId: req.user.userId,
        defaultLocale: userLocale,
      });
    }

    const response = {
      success: true,
      data: userLocale,
      message: "사용자 로케일 조회 성공",
    };

    logger.info("사용자 로케일 조회 성공", {
      userLocale,
      userId: req.user.userId,
      fromDatabase: !!userInfo?.locale,
    });

    res.status(200).json(response);
  } catch (error) {
    logger.error("사용자 로케일 조회 실패", { error });
    res.status(500).json({
      success: false,
      message: "사용자 로케일 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * 사용자 로케일 설정
 */
export const setUserLocale = async (
  req: AuthenticatedRequest,
  res: Response
): Promise<void> => {
  try {
    logger.info("사용자 로케일 설정 요청", {
      body: req.body,
      user: req.user,
    });

    if (!req.user?.userId) {
      res.status(400).json({
        success: false,
        message: "사용자 정보가 없습니다.",
      });
      return;
    }

    const { locale } = req.body;

    if (!locale || !["ko", "en", "ja", "zh"].includes(locale)) {
      res.status(400).json({
        success: false,
        message: "유효하지 않은 로케일입니다. (ko, en, ja, zh 중 선택)",
      });
      return;
    }

    // 데이터베이스에 사용자 로케일 저장
    const prisma = (await import("../config/database")).default;

    await prisma.user_info.update({
      where: {
        user_id: req.user.userId,
      },
      data: {
        locale: locale,
      },
    });

    logger.info("사용자 로케일을 데이터베이스에 저장 완료", {
      locale,
      userId: req.user.userId,
    });

    const response = {
      success: true,
      data: locale,
      message: "사용자 로케일 설정 성공",
    };

    logger.info("사용자 로케일 설정 성공", {
      locale,
      userId: req.user.userId,
    });

    res.status(200).json(response);
  } catch (error) {
    logger.error("사용자 로케일 설정 실패", { error });
    res.status(500).json({
      success: false,
      message: "사용자 로케일 설정 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * GET /api/admin/companies
 * 회사 목록 조회 API
 * 기존 Java AdminController의 회사 목록 조회 기능 포팅
 */
export const getCompanyList = async (
  req: AuthenticatedRequest,
  res: Response
) => {
  try {
    logger.info("회사 목록 조회 요청", {
      query: req.query,
      user: req.user,
    });

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 회사 목록 조회 쿼리
      const query = `
        SELECT 
          company_code,
          company_name,
          status,
          writer,
          regdate,
          'company' as data_type
        FROM company_mng 
        WHERE status = 'active' OR status IS NULL
        ORDER BY company_name
      `;

      const result = await client.query(query);
      const companies = result.rows;

      // 프론트엔드에서 기대하는 응답 형식으로 변환
      const response = {
        success: true,
        data: companies.map((company) => ({
          company_code: company.company_code,
          company_name: company.company_name,
          status: company.status || "active",
          writer: company.writer,
          regdate: company.regdate
            ? company.regdate.toISOString()
            : new Date().toISOString(),
          data_type: company.data_type,
        })),
        message: "회사 목록 조회 성공",
      };

      logger.info("회사 목록 조회 성공", {
        totalCount: companies.length,
        companies: companies.map((c) => ({
          code: c.company_code,
          name: c.company_name,
        })),
      });

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("회사 목록 조회 실패", { error });
    res.status(500).json({
      success: false,
      message: "회사 목록 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * 다국어 언어 목록 조회 (더미 데이터)
 */
export async function getLanguageList(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    logger.info("다국어 언어 목록 조회 요청");

    // 더미 데이터 반환
    const languages = [
      {
        langCode: "KR",
        langName: "한국어",
        langNative: "한국어",
        isActive: "Y",
      },
      {
        langCode: "EN",
        langName: "English",
        langNative: "English",
        isActive: "Y",
      },
      {
        langCode: "JP",
        langName: "日本語",
        langNative: "日本語",
        isActive: "Y",
      },
      { langCode: "CN", langName: "中文", langNative: "中文", isActive: "Y" },
    ];

    const response: ApiResponse<any[]> = {
      success: true,
      message: "언어 목록 조회 성공",
      data: languages,
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("언어 목록 조회 실패:", error);
    res.status(500).json({
      success: false,
      message: "언어 목록 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 다국어 키 목록 조회
 */
export async function getLangKeyList(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    logger.info("다국어 키 목록 조회 요청", {
      query: req.query,
      user: req.user,
    });

    // 실제 데이터베이스에서 데이터 조회
    const client = new Client({
      host: process.env.DB_HOST || "localhost",
      port: parseInt(process.env.DB_PORT || "5432"),
      database: process.env.DB_NAME || "ilshin",
      user: process.env.DB_USER || "postgres",
      password: process.env.DB_PASSWORD || "postgres",
    });

    await client.connect();

    try {
      const query = `
        SELECT 
          key_id as "keyId",
          company_code as "companyCode",
          menu_name as "menuName",
          lang_key as "langKey",
          description,
          is_active as "isActive",
          created_date as "createdDate",
          created_by as "createdBy",
          updated_date as "updatedDate",
          updated_by as "updatedBy"
        FROM multi_lang_key_master
        ORDER BY company_code, menu_name, lang_key
      `;

      const result = await client.query(query);
      const langKeys = result.rows.map((row) => ({
        ...row,
        createdDate: row.createdDate
          ? new Date(row.createdDate).toISOString()
          : undefined,
        updatedDate: row.updatedDate
          ? new Date(row.updatedDate).toISOString()
          : undefined,
      }));

      // 프론트엔드에서 기대하는 응답 형식으로 변환
      const response: ApiResponse<any[]> = {
        success: true,
        message: "다국어 키 목록 조회 성공",
        data: langKeys,
      };

      logger.info("다국어 키 목록 조회 성공", {
        totalCount: langKeys.length,
        response: response,
      });

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("다국어 키 목록 조회 실패:", error);
    res.status(500).json({
      success: false,
      message: "다국어 키 목록 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 다국어 텍스트 목록 조회 (더미 데이터)
 */
export async function getLangTextList(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { keyId } = req.params;
    logger.info(`다국어 텍스트 목록 조회 요청: keyId = ${keyId}`);

    // 더미 데이터 반환
    const langTexts = [
      {
        textId: 1,
        keyId: parseInt(keyId),
        langCode: "KR",
        langText: "사용자 관리",
        isActive: "Y",
      },
      {
        textId: 2,
        keyId: parseInt(keyId),
        langCode: "EN",
        langText: "User Management",
        isActive: "Y",
      },
      {
        textId: 3,
        keyId: parseInt(keyId),
        langCode: "JP",
        langText: "ユーザー管理",
        isActive: "Y",
      },
    ];

    const response: ApiResponse<any[]> = {
      success: true,
      message: "다국어 텍스트 목록 조회 성공",
      data: langTexts,
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("다국어 텍스트 목록 조회 실패:", error);
    res.status(500).json({
      success: false,
      message: "다국어 텍스트 목록 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 다국어 텍스트 저장 (더미 데이터)
 */
export async function saveLangTexts(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { keyId } = req.params;
    const textData = req.body;
    logger.info(`다국어 텍스트 저장 요청: keyId = ${keyId}`, { textData });

    // 더미 응답
    const response: ApiResponse<any> = {
      success: true,
      message: "다국어 텍스트 저장 성공",
      data: { savedCount: textData.length },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("다국어 텍스트 저장 실패:", error);
    res.status(500).json({
      success: false,
      message: "다국어 텍스트 저장 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 다국어 키 저장 (더미 데이터)
 */
export async function saveLangKey(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const keyData = req.body;
    logger.info("다국어 키 저장 요청", { keyData });

    // 더미 응답
    const response: ApiResponse<any> = {
      success: true,
      message: "다국어 키 저장 성공",
      data: { keyId: Math.floor(Math.random() * 1000) + 1 },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("다국어 키 저장 실패:", error);
    res.status(500).json({
      success: false,
      message: "다국어 키 저장 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 다국어 키 수정 (더미 데이터)
 */
export async function updateLangKey(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { keyId } = req.params;
    const keyData = req.body;
    logger.info(`다국어 키 수정 요청: keyId = ${keyId}`, { keyData });

    // 더미 응답
    const response: ApiResponse<any> = {
      success: true,
      message: "다국어 키 수정 성공",
      data: { keyId: parseInt(keyId) },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("다국어 키 수정 실패:", error);
    res.status(500).json({
      success: false,
      message: "다국어 키 수정 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 다국어 키 삭제 (더미 데이터)
 */
export async function deleteLangKey(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { keyId } = req.params;
    logger.info(`다국어 키 삭제 요청: keyId = ${keyId}`);

    // 더미 응답
    const response: ApiResponse<any> = {
      success: true,
      message: "다국어 키 삭제 성공",
      data: { deletedKeyId: parseInt(keyId) },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("다국어 키 삭제 실패:", error);
    res.status(500).json({
      success: false,
      message: "다국어 키 삭제 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 다국어 키 상태 토글 (더미 데이터)
 */
export async function toggleLangKeyStatus(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { keyId } = req.params;
    logger.info(`다국어 키 상태 토글 요청: keyId = ${keyId}`);

    // 더미 응답
    const response: ApiResponse<any> = {
      success: true,
      message: "다국어 키 상태 토글 성공",
      data: "활성화",
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("다국어 키 상태 토글 실패:", error);
    res.status(500).json({
      success: false,
      message: "다국어 키 상태 토글 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 언어 저장 (더미 데이터)
 */
export async function saveLanguage(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const langData = req.body;
    logger.info("언어 저장 요청", { langData });

    // 더미 응답
    const response: ApiResponse<any> = {
      success: true,
      message: "언어 저장 성공",
      data: { langCode: langData.langCode },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("언어 저장 실패:", error);
    res.status(500).json({
      success: false,
      message: "언어 저장 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 언어 수정 (더미 데이터)
 */
export async function updateLanguage(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { langCode } = req.params;
    const langData = req.body;
    logger.info(`언어 수정 요청: langCode = ${langCode}`, { langData });

    // 더미 응답
    const response: ApiResponse<any> = {
      success: true,
      message: "언어 수정 성공",
      data: { langCode },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("언어 수정 실패:", error);
    res.status(500).json({
      success: false,
      message: "언어 수정 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 언어 상태 토글 (더미 데이터)
 */
export async function toggleLanguageStatus(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { langCode } = req.params;
    logger.info(`언어 상태 토글 요청: langCode = ${langCode}`);

    // 더미 응답
    const response: ApiResponse<any> = {
      success: true,
      message: "언어 상태 토글 성공",
      data: "활성화",
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("언어 상태 토글 실패:", error);
    res.status(500).json({
      success: false,
      message: "언어 상태 토글 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 메뉴 저장 (추가/수정)
 */
export async function saveMenu(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const menuData = req.body;
    logger.info("메뉴 저장 요청", { menuData, user: req.user });

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    // 실제 데이터베이스에 저장
    const query = `
      INSERT INTO menu_info (
        objid, menu_type, parent_obj_id, menu_name_kor, menu_name_eng, 
        seq, menu_url, menu_desc, writer, regdate, status, 
        system_name, company_code, lang_key, lang_key_desc
      ) VALUES (
        $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15
      ) RETURNING *
    `;

    const values = [
      Date.now(), // objid
      menuData.menuType || null, // menu_type
      menuData.parentObjId || null, // parent_obj_id
      menuData.menuNameKor, // menu_name_kor
      menuData.menuNameEng || null, // menu_name_eng
      menuData.seq || null, // seq
      menuData.menuUrl || null, // menu_url
      menuData.menuDesc || null, // menu_desc
      req.user?.userId || "admin", // writer
      new Date(), // regdate
      menuData.status || "active", // status
      menuData.systemName || "PLM", // system_name
      menuData.companyCode || "*", // company_code
      menuData.langKey || null, // lang_key
      menuData.langKeyDesc || null, // lang_key_desc
    ];

    const result = await client.query(query, values);
    const savedMenu = result.rows[0];

    await client.end();

    logger.info("메뉴 저장 성공", { savedMenu });

    const response: ApiResponse<any> = {
      success: true,
      message: "메뉴가 성공적으로 저장되었습니다.",
      data: {
        objid: savedMenu.objid,
        menuNameKor: savedMenu.menu_name_kor,
        menuNameEng: savedMenu.menu_name_eng,
        menuUrl: savedMenu.menu_url,
        menuDesc: savedMenu.menu_desc,
        status: savedMenu.status,
        writer: savedMenu.writer,
        regdate: savedMenu.regdate,
      },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("메뉴 저장 실패:", error);
    res.status(500).json({
      success: false,
      message: "메뉴 저장 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 메뉴 수정
 */
export async function updateMenu(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { menuId } = req.params;
    const menuData = req.body;
    logger.info(`메뉴 수정 요청: menuId = ${menuId}`, {
      menuData,
      user: req.user,
    });

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    // 실제 데이터베이스에서 메뉴 수정
    const query = `
      UPDATE menu_info 
      SET 
        menu_type = $1,
        parent_obj_id = $2,
        menu_name_kor = $3,
        menu_name_eng = $4,
        seq = $5,
        menu_url = $6,
        menu_desc = $7,
        status = $8,
        system_name = $9,
        company_code = $10,
        lang_key = $11,
        lang_key_desc = $12
      WHERE objid = $13
      RETURNING *
    `;

    const values = [
      menuData.menuType ? BigInt(menuData.menuType) : null, // menu_type
      menuData.parentObjId ? BigInt(menuData.parentObjId) : null, // parent_obj_id
      menuData.menuNameKor, // menu_name_kor
      menuData.menuNameEng || null, // menu_name_eng
      menuData.seq ? BigInt(menuData.seq) : null, // seq
      menuData.menuUrl || null, // menu_url
      menuData.menuDesc || null, // menu_desc
      menuData.status || "active", // status
      menuData.systemName || "PLM", // system_name
      menuData.companyCode || "*", // company_code
      menuData.langKey || null, // lang_key
      menuData.langKeyDesc || null, // lang_key_desc
      BigInt(menuId), // objid (WHERE 조건)
    ];

    const result = await client.query(query, values);

    if (result.rowCount === 0) {
      await client.end();
      res.status(404).json({
        success: false,
        message: "수정할 메뉴를 찾을 수 없습니다.",
      });
      return;
    }

    const updatedMenu = result.rows[0];
    await client.end();

    logger.info("메뉴 수정 성공", { updatedMenu });

    const response: ApiResponse<any> = {
      success: true,
      message: "메뉴가 성공적으로 수정되었습니다.",
      data: {
        objid: updatedMenu.objid.toString(),
        menuNameKor: updatedMenu.menu_name_kor,
        menuNameEng: updatedMenu.menu_name_eng,
        menuUrl: updatedMenu.menu_url,
        menuDesc: updatedMenu.menu_desc,
        status: updatedMenu.status,
        writer: updatedMenu.writer,
        regdate: updatedMenu.regdate,
      },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("메뉴 수정 실패:", error);
    res.status(500).json({
      success: false,
      message: "메뉴 수정 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 메뉴 삭제
 */
export async function deleteMenu(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const { menuId } = req.params;
    logger.info(`메뉴 삭제 요청: menuId = ${menuId}`, { user: req.user });

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    // 실제 데이터베이스에서 메뉴 삭제
    const query = `
      DELETE FROM menu_info 
      WHERE objid = $1
      RETURNING *
    `;

    const result = await client.query(query, [BigInt(menuId)]);

    if (result.rowCount === 0) {
      await client.end();
      res.status(404).json({
        success: false,
        message: "삭제할 메뉴를 찾을 수 없습니다.",
      });
      return;
    }

    const deletedMenu = result.rows[0];
    await client.end();

    logger.info("메뉴 삭제 성공", { deletedMenu });

    const response: ApiResponse<any> = {
      success: true,
      message: "메뉴가 성공적으로 삭제되었습니다.",
      data: {
        objid: deletedMenu.objid.toString(),
        menuNameKor: deletedMenu.menu_name_kor,
        menuNameEng: deletedMenu.menu_name_eng,
        menuUrl: deletedMenu.menu_url,
        menuDesc: deletedMenu.menu_desc,
        status: deletedMenu.status,
        writer: deletedMenu.writer,
        regdate: deletedMenu.regdate,
      },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("메뉴 삭제 실패:", error);
    res.status(500).json({
      success: false,
      message: "메뉴 삭제 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 메뉴 일괄 삭제
 */
export async function deleteMenusBatch(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    const menuIds = req.body as string[];
    logger.info("메뉴 일괄 삭제 요청", { menuIds, user: req.user });

    if (!Array.isArray(menuIds) || menuIds.length === 0) {
      res.status(400).json({
        success: false,
        message: "삭제할 메뉴 ID 목록이 필요합니다.",
      });
      return;
    }

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    let deletedCount = 0;
    let failedCount = 0;
    const deletedMenus: any[] = [];
    const failedMenuIds: string[] = [];

    // 각 메뉴 ID에 대해 삭제 시도
    for (const menuId of menuIds) {
      try {
        const query = `
          DELETE FROM menu_info 
          WHERE objid = $1
          RETURNING *
        `;

        const result = await client.query(query, [BigInt(menuId)]);

        if (result.rowCount && result.rowCount > 0) {
          deletedCount++;
          deletedMenus.push(result.rows[0]);
        } else {
          failedCount++;
          failedMenuIds.push(menuId);
        }
      } catch (error) {
        logger.error(`메뉴 삭제 실패 (ID: ${menuId}):`, error);
        failedCount++;
        failedMenuIds.push(menuId);
      }
    }

    await client.end();

    logger.info("메뉴 일괄 삭제 완료", {
      total: menuIds.length,
      deletedCount,
      failedCount,
      deletedMenus,
      failedMenuIds,
    });

    const response: ApiResponse<any> = {
      success: true,
      message: `메뉴 일괄 삭제 완료: ${deletedCount}개 삭제, ${failedCount}개 실패`,
      data: {
        deletedCount,
        failedCount,
        total: menuIds.length,
        deletedMenus,
        failedMenuIds,
      },
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("메뉴 일괄 삭제 실패:", error);
    res.status(500).json({
      success: false,
      message: "메뉴 일괄 삭제 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * 회사 목록 조회 (실제 데이터베이스에서)
 */
export async function getCompanyListFromDB(
  req: AuthenticatedRequest,
  res: Response
): Promise<void> {
  try {
    logger.info("회사 목록 조회 요청 (DB)", { user: req.user });

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    // company_mng 테이블에서 회사 목록 조회
    const query = `
      SELECT 
        company_code,
        company_name,
        writer,
        regdate,
        status
      FROM company_mng 
      ORDER BY regdate DESC
    `;

    const result = await client.query(query);
    const companies = result.rows;

    await client.end();

    logger.info("회사 목록 조회 성공 (DB)", { count: companies.length });

    const response: ApiResponse<any> = {
      success: true,
      message: "회사 목록 조회 성공",
      data: companies,
      total: companies.length,
    };

    res.status(200).json(response);
  } catch (error) {
    logger.error("회사 목록 조회 실패 (DB):", error);
    res.status(500).json({
      success: false,
      message: "회사 목록 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
}

/**
 * GET /api/admin/departments
 * 부서 목록 조회 API
 * 기존 Java AdminController의 부서 목록 조회 기능 포팅
 */
export const getDepartmentList = async (
  req: AuthenticatedRequest,
  res: Response
) => {
  try {
    logger.info("부서 목록 조회 요청", {
      query: req.query,
      user: req.user,
    });

    const { companyCode, status, search } = req.query;

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 부서 목록 조회 쿼리
      let query = `
        SELECT 
          dept_code,
          parent_dept_code,
          dept_name,
          master_sabun,
          master_user_id,
          location,
          location_name,
          regdate,
          data_type,
          status,
          sales_yn,
          company_name
        FROM dept_info
        WHERE 1=1
      `;

      const queryParams: any[] = [];
      let paramIndex = 1;

      // 회사 코드 필터
      if (companyCode) {
        query += ` AND company_name = $${paramIndex}`;
        queryParams.push(companyCode);
        paramIndex++;
      }

      // 상태 필터
      if (status) {
        query += ` AND status = $${paramIndex}`;
        queryParams.push(status);
        paramIndex++;
      }

      // 검색 조건
      if (search) {
        query += ` AND (
          dept_name ILIKE $${paramIndex} OR 
          dept_code ILIKE $${paramIndex} OR
          location_name ILIKE $${paramIndex}
        )`;
        queryParams.push(`%${search}%`);
        paramIndex++;
      }

      // 정렬 (상위 부서 먼저, 그 다음 부서명 순)
      query += ` ORDER BY 
        CASE WHEN parent_dept_code IS NULL OR parent_dept_code = '' THEN 0 ELSE 1 END,
        dept_name`;

      const result = await client.query(query, queryParams);
      const departments = result.rows;

      // 부서 트리 구조 생성
      const deptMap = new Map();
      const rootDepartments: any[] = [];

      // 모든 부서를 맵에 저장
      departments.forEach((dept) => {
        deptMap.set(dept.dept_code, {
          deptCode: dept.dept_code,
          deptName: dept.dept_name,
          parentDeptCode: dept.parent_dept_code,
          masterSabun: dept.master_sabun,
          masterUserId: dept.master_user_id,
          location: dept.location,
          locationName: dept.location_name,
          regdate: dept.regdate ? dept.regdate.toISOString() : null,
          dataType: dept.data_type,
          status: dept.status || "active",
          salesYn: dept.sales_yn,
          companyName: dept.company_name,
          children: [],
        });
      });

      // 부서 트리 구조 생성
      departments.forEach((dept) => {
        const deptNode = deptMap.get(dept.dept_code);

        if (dept.parent_dept_code && deptMap.has(dept.parent_dept_code)) {
          // 상위 부서가 있으면 children에 추가
          const parentDept = deptMap.get(dept.parent_dept_code);
          parentDept.children.push(deptNode);
        } else {
          // 상위 부서가 없으면 루트 부서로 추가
          rootDepartments.push(deptNode);
        }
      });

      const response = {
        success: true,
        data: {
          departments: rootDepartments,
          flatList: departments.map((dept) => ({
            deptCode: dept.dept_code,
            deptName: dept.dept_name,
            parentDeptCode: dept.parent_dept_code,
            masterSabun: dept.master_sabun,
            masterUserId: dept.master_user_id,
            location: dept.location,
            locationName: dept.location_name,
            regdate: dept.regdate ? dept.regdate.toISOString() : null,
            dataType: dept.data_type,
            status: dept.status || "active",
            salesYn: dept.sales_yn,
            companyName: dept.company_name,
          })),
        },
        message: "부서 목록 조회 성공",
        total: departments.length,
      };

      logger.info("부서 목록 조회 성공", {
        totalCount: departments.length,
        rootCount: rootDepartments.length,
      });

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("부서 목록 조회 실패", { error });
    res.status(500).json({
      success: false,
      message: "부서 목록 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * GET /api/admin/users/:userId
 * 사용자 상세 조회 API
 * 기존 Java AdminController의 사용자 상세 조회 기능 포팅
 */
export const getUserInfo = async (req: AuthenticatedRequest, res: Response) => {
  try {
    const { userId } = req.params;
    logger.info(`사용자 상세 조회 요청 - userId: ${userId}`, {
      user: req.user,
    });

    if (!userId) {
      res.status(400).json({
        success: false,
        message: "사용자 ID가 필요합니다.",
        error: {
          code: "USER_ID_REQUIRED",
          details: "userId parameter is required",
        },
      });
      return;
    }

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 사용자 상세 정보 조회 쿼리
      const query = `
        SELECT 
          u.sabun,
          u.user_id,
          u.user_name,
          u.user_name_eng,
          u.user_name_cn,
          u.dept_code,
          u.dept_name,
          u.position_code,
          u.position_name,
          u.email,
          u.tel,
          u.cell_phone,
          u.user_type,
          u.user_type_name,
          u.regdate,
          u.status,
          u.end_date,
          u.fax_no,
          u.partner_objid,
          u.rank,
          u.locale,
          u.company_code,
          u.data_type,
          d.dept_name as dept_name_full,
          d.parent_dept_code,
          d.location,
          d.location_name,
          d.sales_yn,
          d.company_name as dept_company_name
        FROM user_info u
        LEFT JOIN dept_info d ON u.dept_code = d.dept_code
        WHERE u.user_id = $1
      `;

      const result = await client.query(query, [userId]);

      if (result.rows.length === 0) {
        res.status(404).json({
          success: false,
          message: "사용자를 찾을 수 없습니다.",
          error: {
            code: "USER_NOT_FOUND",
            details: `User ID: ${userId}`,
          },
        });
        return;
      }

      const user = result.rows[0];

      // 응답 데이터 가공
      const userInfo = {
        sabun: user.sabun,
        userId: user.user_id,
        userName: user.user_name,
        userNameEng: user.user_name_eng,
        userNameCn: user.user_name_cn,
        deptCode: user.dept_code,
        deptName: user.dept_name || user.dept_name_full,
        positionCode: user.position_code,
        positionName: user.position_name,
        email: user.email,
        tel: user.tel,
        cellPhone: user.cell_phone,
        userType: user.user_type,
        userTypeName: user.user_type_name,
        regdate: user.regdate ? user.regdate.toISOString() : null,
        status: user.status || "active",
        endDate: user.end_date ? user.end_date.toISOString() : null,
        faxNo: user.fax_no,
        partnerObjid: user.partner_objid,
        rank: user.rank,
        locale: user.locale,
        companyCode: user.company_code,
        dataType: user.data_type,
        // 부서 정보
        deptInfo: {
          deptCode: user.dept_code,
          deptName: user.dept_name || user.dept_name_full,
          parentDeptCode: user.parent_dept_code,
          location: user.location,
          locationName: user.location_name,
          salesYn: user.sales_yn,
          companyName: user.dept_company_name,
        },
      };

      const response = {
        success: true,
        data: userInfo,
        message: "사용자 상세 정보 조회 성공",
      };

      logger.info("사용자 상세 정보 조회 성공", {
        userId,
        userName: user.user_name,
      });

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("사용자 상세 정보 조회 실패", {
      error,
      userId: req.params.userId,
    });
    res.status(500).json({
      success: false,
      message: "사용자 상세 정보 조회 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * POST /api/admin/users/check-duplicate
 * 사용자 ID 중복 체크 API
 * 기존 Java AdminController의 checkDuplicateUserId 기능 포팅
 */
export const checkDuplicateUserId = async (
  req: AuthenticatedRequest,
  res: Response
) => {
  try {
    const { userId } = req.body;
    logger.info(`사용자 ID 중복 체크 요청 - userId: ${userId}`, {
      user: req.user,
    });

    if (!userId) {
      res.status(400).json({
        success: false,
        message: "사용자 ID가 필요합니다.",
        error: {
          code: "USER_ID_REQUIRED",
          details: "userId is required",
        },
      });
      return;
    }

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 사용자 ID 중복 체크 쿼리
      const query = `
        SELECT COUNT(*) as count
        FROM user_info
        WHERE user_id = $1
      `;

      const result = await client.query(query, [userId]);
      const count = parseInt(result.rows[0].count);

      const isDuplicate = count > 0;

      const response = {
        success: true,
        data: {
          isDuplicate,
          count,
          message: isDuplicate
            ? "이미 사용 중인 사용자 ID입니다."
            : "사용 가능한 사용자 ID입니다.",
        },
        message: "사용자 ID 중복 체크 완료",
      };

      logger.info("사용자 ID 중복 체크 완료", {
        userId,
        isDuplicate,
        count,
      });

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("사용자 ID 중복 체크 실패", {
      error,
      userId: req.body?.userId,
    });
    res.status(500).json({
      success: false,
      message: "사용자 ID 중복 체크 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * POST /api/admin/users
 * 사용자 등록/수정 API
 * 기존 Java AdminController의 saveUserInfo 기능 포팅
 */
/**
 * GET /api/admin/users/:userId/history
 * 사용자 변경이력 조회 API
 * 기존 Java AdminController.getUserHistory() 포팅
 */
export const getUserHistory = async (
  req: AuthenticatedRequest,
  res: Response
) => {
  try {
    const { userId } = req.params;
    const { page = 1, countPerPage = 10 } = req.query;

    logger.info(`사용자 변경이력 조회 요청 - userId: ${userId}`, {
      page,
      countPerPage,
      user: req.user,
    });

    if (!userId) {
      res.status(400).json({
        success: false,
        message: "사용자 ID가 필요합니다.",
        error: {
          code: "USER_ID_REQUIRED",
          details: "userId parameter is required",
        },
      });
      return;
    }

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 페이징 계산
      const currentPage = Number(page);
      const pageSize = Number(countPerPage);
      const pageStart = (currentPage - 1) * pageSize + 1;
      const pageEnd = currentPage * pageSize;

      // 전체 건수 조회 쿼리 (기존 backend와 동일한 로직)
      const countQuery = `
        SELECT
          CEIL(TOTAL_CNT::float / $1)::integer AS MAX_PAGE_SIZE,
          TOTAL_CNT
        FROM (
          SELECT 
            COUNT(1) AS TOTAL_CNT
          FROM user_info_history
          WHERE user_id = $2
        ) A
      `;

      const countResult = await client.query(countQuery, [pageSize, userId]);
      const countData = countResult.rows[0] || {
        total_cnt: 0,
        max_page_size: 1,
      };

      // 변경이력 목록 조회 쿼리 (기존 backend와 동일한 로직)
      const historyQuery = `
        SELECT 
          A.*
        FROM (
          SELECT 
            A.*, 
            ROW_NUMBER() OVER (ORDER BY RM DESC) AS RNUM
          FROM (
            SELECT
              T.*,
              ROW_NUMBER() OVER (ORDER BY regdate) AS RM,
              (SELECT user_name FROM user_info UI WHERE T.writer = UI.user_id) AS writer_name,
              TO_CHAR(T.regdate, 'YYYY-MM-DD HH24:MI:SS') AS reg_date_title
            FROM 
              user_info_history T
            WHERE user_id = $1
          ) A
          WHERE 1=1
        ) A
        WHERE 1=1
        AND RNUM::integer <= $2
        AND RNUM::integer >= $3
        ORDER BY RM DESC
      `;

      const historyResult = await client.query(historyQuery, [
        userId,
        pageEnd,
        pageStart,
      ]);

      // 응답 데이터 가공
      const historyList = historyResult.rows.map((row) => ({
        sabun: row.sabun || "",
        userId: row.user_id || "",
        userName: row.user_name || "",
        deptCode: row.dept_code || "",
        deptName: row.dept_name || "",
        userTypeName: row.user_type_name || "",
        historyType: row.history_type || "",
        writer: row.writer || "",
        writerName: row.writer_name || "",
        regDate: row.regdate,
        regDateTitle: row.reg_date_title || "",
        status: row.status || "",
        rowNum: row.rnum,
      }));

      logger.info(
        `사용자 변경이력 조회 완료 - userId: ${userId}, 조회건수: ${historyList.length}, 전체: ${countData.total_cnt}`
      );

      const response: ApiResponse<any[]> = {
        success: true,
        data: historyList,
        total: Number(countData.total_cnt),

        pagination: {
          page: currentPage,
          limit: pageSize,
          total: Number(countData.total_cnt),
          totalPages: Number(countData.max_page_size),
        },
      };

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("사용자 변경이력 조회 중 오류 발생", error);

    const response: ApiResponse<null> = {
      success: false,
      message: "사용자 변경이력 조회 중 오류가 발생했습니다.",
      error: {
        code: "USER_HISTORY_FETCH_ERROR",
        details: error instanceof Error ? error.message : "Unknown error",
      },
    };

    res.status(500).json(response);
  }
};

/**
 * PATCH /api/admin/users/:userId/status
 * 사용자 상태 변경 API (부분 수정)
 * 기존 Java AdminController.changeUserStatus() 포팅
 */
export const changeUserStatus = async (
  req: AuthenticatedRequest,
  res: Response
) => {
  try {
    const { userId } = req.params;
    const { status } = req.body;

    logger.info("사용자 상태 변경 요청", { userId, status, user: req.user });

    // 필수 파라미터 검증
    if (!userId || !status) {
      res.status(400).json({
        result: false,
        msg: "사용자 ID와 상태는 필수입니다.",
      });
      return;
    }

    // 상태 값 검증
    if (!["active", "inactive"].includes(status)) {
      res.status(400).json({
        result: false,
        msg: "유효하지 않은 상태값입니다. (active, inactive만 허용)",
      });
      return;
    }

    const client = new Client({
      connectionString: config.databaseUrl,
    });

    try {
      await client.connect();

      // 1. 사용자 존재 여부 확인
      const userCheckResult = await client.query(
        "SELECT user_id, user_name, status FROM user_info WHERE user_id = $1",
        [userId]
      );

      if (userCheckResult.rows.length === 0) {
        res.status(404).json({
          result: false,
          msg: "사용자를 찾을 수 없습니다.",
        });
        return;
      }

      const currentUser = userCheckResult.rows[0];

      // 2. 상태 변경 쿼리 실행
      let updateQuery = `
        UPDATE user_info 
        SET status = $1
      `;

      const queryParams = [status];

      // active/inactive에 따른 END_DATE 처리
      if (status === "inactive") {
        updateQuery += `, end_date = NOW()`;
      } else if (status === "active") {
        updateQuery += `, end_date = NULL`;
      }

      updateQuery += ` WHERE user_id = $2`;
      queryParams.push(userId);

      const updateResult = await client.query(updateQuery, queryParams);

      if (updateResult.rowCount && updateResult.rowCount > 0) {
        // 3. 사용자 이력 저장 (선택적)
        try {
          await client.query(
            `
            INSERT INTO user_info_history 
            (user_id, user_name, dept_code, dept_name, user_type_name, history_type, writer, reg_date, status, sabun)
            VALUES ($1, $2, '', '', '', '사용자 상태 변경', $3, NOW(), $4, '')
          `,
            [
              userId,
              currentUser.user_name || userId,
              req.user?.userId || "system",
              status,
            ]
          );
        } catch (historyError) {
          logger.warn("사용자 이력 저장 실패", {
            error: historyError,
            userId,
            status,
          });
          // 이력 저장 실패는 치명적이지 않으므로 계속 진행
        }

        logger.info("사용자 상태 변경 성공", {
          userId,
          oldStatus: currentUser.status,
          newStatus: status,
          updatedBy: req.user?.userId,
        });

        res.json({
          result: true,
          msg: `사용자 상태가 ${status === "active" ? "활성" : "비활성"}으로 변경되었습니다.`,
        });
      } else {
        res.status(400).json({
          result: false,
          msg: "사용자 상태 변경에 실패했습니다.",
        });
      }
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("사용자 상태 변경 중 오류 발생", {
      error,
      userId: req.params.userId,
      status: req.body.status,
    });
    res.status(500).json({
      result: false,
      msg: "시스템 오류가 발생했습니다.",
    });
  }
};

export const saveUser = async (req: AuthenticatedRequest, res: Response) => {
  try {
    const userData = req.body;
    logger.info("사용자 저장 요청", { userData, user: req.user });

    // 필수 필드 검증
    const requiredFields = ["userId", "userName", "userPassword"];
    for (const field of requiredFields) {
      if (!userData[field] || userData[field].trim() === "") {
        res.status(400).json({
          success: false,
          message: `${field}는 필수 입력 항목입니다.`,
          error: {
            code: "REQUIRED_FIELD_MISSING",
            details: `Required field: ${field}`,
          },
        });
        return;
      }
    }

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 기존 사용자 확인
      const checkQuery = `
        SELECT user_id FROM user_info WHERE user_id = $1
      `;
      const checkResult = await client.query(checkQuery, [userData.userId]);
      const isUpdate = checkResult.rows.length > 0;

      if (isUpdate) {
        // 기존 사용자 수정
        const updateQuery = `
          UPDATE user_info SET
            user_name = $1,
            user_name_eng = $2,
            user_password = $3,
            dept_code = $4,
            dept_name = $5,
            position_code = $6,
            position_name = $7,
            email = $8,
            tel = $9,
            cell_phone = $10,
            user_type = $11,
            user_type_name = $12,
            sabun = $13,
            company_code = $14,
            status = $15,
            locale = $16
          WHERE user_id = $17
        `;

        const updateValues = [
          userData.userName,
          userData.userNameEng || null,
          await EncryptUtil.encrypt(userData.userPassword), // 비밀번호 암호화
          userData.deptCode || null,
          userData.deptName || null,
          userData.positionCode || null,
          userData.positionName || null,
          userData.email || null,
          userData.tel || null,
          userData.cellPhone || null,
          userData.userType || null,
          userData.userTypeName || null,
          userData.sabun || null,
          userData.companyCode || null,
          userData.status || "active",
          userData.locale || null,
          userData.userId,
        ];

        await client.query(updateQuery, updateValues);
        logger.info("사용자 정보 수정 완료", { userId: userData.userId });
      } else {
        // 새 사용자 등록
        const insertQuery = `
          INSERT INTO user_info (
            user_id, user_name, user_name_eng, user_password, dept_code, dept_name,
            position_code, position_name, email, tel, cell_phone, user_type,
            user_type_name, sabun, company_code, status, locale, regdate
          ) VALUES (
            $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18
          )
        `;

        const insertValues = [
          userData.userId,
          userData.userName,
          userData.userNameEng || null,
          await EncryptUtil.encrypt(userData.userPassword), // 비밀번호 암호화
          userData.deptCode || null,
          userData.deptName || null,
          userData.positionCode || null,
          userData.positionName || null,
          userData.email || null,
          userData.tel || null,
          userData.cellPhone || null,
          userData.userType || null,
          userData.userTypeName || null,
          userData.sabun || null,
          userData.companyCode || null,
          userData.status || "active",
          userData.locale || null,
          new Date(),
        ];

        await client.query(insertQuery, insertValues);
        logger.info("새 사용자 등록 완료", { userId: userData.userId });
      }

      const response = {
        success: true,
        result: true,
        message: isUpdate
          ? "사용자 정보가 수정되었습니다."
          : "사용자가 등록되었습니다.",
        data: {
          userId: userData.userId,
          isUpdate,
        },
      };

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("사용자 저장 실패", { error, userData: req.body });
    res.status(500).json({
      success: false,
      result: false,
      message: "사용자 저장 중 오류가 발생했습니다.",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * POST /api/admin/companies
 * 회사 등록 API
 * 기존 Java AdminController의 회사 등록 기능 포팅
 */
export const createCompany = async (
  req: AuthenticatedRequest,
  res: Response
): Promise<void> => {
  try {
    logger.info("회사 등록 요청", {
      body: req.body,
      user: req.user,
    });

    const { company_name } = req.body;

    // 필수 입력값 검증
    if (!company_name || !company_name.trim()) {
      res.status(400).json({
        success: false,
        message: "회사명을 입력해주세요.",
        errorCode: "COMPANY_NAME_REQUIRED",
      });
      return;
    }

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 회사명 중복 체크
      const duplicateCheckQuery = `
        SELECT COUNT(*) as count
        FROM company_mng 
        WHERE company_name = $1
      `;

      const duplicateResult = await client.query(duplicateCheckQuery, [
        company_name.trim(),
      ]);

      if (parseInt(duplicateResult.rows[0].count) > 0) {
        res.status(400).json({
          success: false,
          message: "이미 등록된 회사명입니다.",
          errorCode: "COMPANY_NAME_DUPLICATE",
        });
        return;
      }

      // 회사 코드 생성 (COMPANY_1, COMPANY_2, ...)
      const codeQuery = `
        SELECT COALESCE(MAX(CAST(SUBSTRING(company_code FROM 9) AS INTEGER)), 0) + 1 as next_number
        FROM company_mng 
        WHERE company_code LIKE 'COMPANY_%'
      `;

      const codeResult = await client.query(codeQuery);
      const nextNumber = codeResult.rows[0].next_number;
      const companyCode = `COMPANY_${nextNumber}`;

      // 회사 정보 저장
      const insertQuery = `
        INSERT INTO company_mng (
          company_code, 
          company_name, 
          writer, 
          regdate, 
          status
        ) VALUES ($1, $2, $3, $4, $5)
        RETURNING *
      `;

      const writer = req.user
        ? `${req.user.userName}(${req.user.userId})`
        : "시스템";
      const insertValues = [
        companyCode,
        company_name.trim(),
        writer,
        new Date(),
        "active",
      ];

      const insertResult = await client.query(insertQuery, insertValues);
      const createdCompany = insertResult.rows[0];

      logger.info("회사 등록 성공", {
        companyCode: createdCompany.company_code,
        companyName: createdCompany.company_name,
        writer: createdCompany.writer,
      });

      const response = {
        success: true,
        message: "회사가 성공적으로 등록되었습니다.",
        data: {
          company_code: createdCompany.company_code,
          company_name: createdCompany.company_name,
          writer: createdCompany.writer,
          regdate: createdCompany.regdate,
          status: createdCompany.status,
        },
      };

      res.status(201).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("회사 등록 실패", { error, body: req.body });
    res.status(500).json({
      success: false,
      message: "회사 등록 중 오류가 발생했습니다.",
      errorCode: "COMPANY_CREATE_ERROR",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * PUT /api/admin/companies/:companyCode
 * 회사 정보 수정 API
 */
export const updateCompany = async (
  req: AuthenticatedRequest,
  res: Response
): Promise<void> => {
  try {
    const { companyCode } = req.params;
    const { company_name, status } = req.body;

    logger.info("회사 정보 수정 요청", {
      companyCode,
      body: req.body,
      user: req.user,
    });

    // 필수 입력값 검증
    if (!company_name || !company_name.trim()) {
      res.status(400).json({
        success: false,
        message: "회사명을 입력해주세요.",
        errorCode: "COMPANY_NAME_REQUIRED",
      });
      return;
    }

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 회사명 중복 체크 (자기 자신 제외)
      const duplicateCheckQuery = `
        SELECT COUNT(*) as count
        FROM company_mng 
        WHERE company_name = $1 AND company_code != $2
      `;

      const duplicateResult = await client.query(duplicateCheckQuery, [
        company_name.trim(),
        companyCode,
      ]);

      if (parseInt(duplicateResult.rows[0].count) > 0) {
        res.status(400).json({
          success: false,
          message: "이미 등록된 회사명입니다.",
          errorCode: "COMPANY_NAME_DUPLICATE",
        });
        return;
      }

      // 회사 정보 수정
      const updateQuery = `
        UPDATE company_mng 
        SET company_name = $1, status = $2
        WHERE company_code = $3
        RETURNING *
      `;

      const updateValues = [
        company_name.trim(),
        status || "active",
        companyCode,
      ];

      const updateResult = await client.query(updateQuery, updateValues);

      if (updateResult.rows.length === 0) {
        res.status(404).json({
          success: false,
          message: "해당 회사를 찾을 수 없습니다.",
          errorCode: "COMPANY_NOT_FOUND",
        });
        return;
      }

      const updatedCompany = updateResult.rows[0];

      logger.info("회사 정보 수정 성공", {
        companyCode: updatedCompany.company_code,
        companyName: updatedCompany.company_name,
        status: updatedCompany.status,
      });

      const response = {
        success: true,
        message: "회사 정보가 수정되었습니다.",
        data: {
          company_code: updatedCompany.company_code,
          company_name: updatedCompany.company_name,
          writer: updatedCompany.writer,
          regdate: updatedCompany.regdate,
          status: updatedCompany.status,
        },
      };

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("회사 정보 수정 실패", { error, body: req.body });
    res.status(500).json({
      success: false,
      message: "회사 정보 수정 중 오류가 발생했습니다.",
      errorCode: "COMPANY_UPDATE_ERROR",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * DELETE /api/admin/companies/:companyCode
 * 회사 삭제 API
 */
export const deleteCompany = async (
  req: AuthenticatedRequest,
  res: Response
): Promise<void> => {
  try {
    const { companyCode } = req.params;

    logger.info("회사 삭제 요청", {
      companyCode,
      user: req.user,
    });

    // PostgreSQL 클라이언트 생성
    const client = new Client({
      connectionString:
        process.env.DATABASE_URL ||
        "postgresql://postgres:postgres@localhost:5432/ilshin",
    });

    await client.connect();

    try {
      // 회사 존재 여부 확인
      const checkQuery = `
        SELECT company_code, company_name
        FROM company_mng 
        WHERE company_code = $1
      `;

      const checkResult = await client.query(checkQuery, [companyCode]);

      if (checkResult.rows.length === 0) {
        res.status(404).json({
          success: false,
          message: "해당 회사를 찾을 수 없습니다.",
          errorCode: "COMPANY_NOT_FOUND",
        });
        return;
      }

      // 회사 삭제
      const deleteQuery = `
        DELETE FROM company_mng 
        WHERE company_code = $1
      `;

      await client.query(deleteQuery, [companyCode]);

      logger.info("회사 삭제 성공", {
        companyCode,
        companyName: checkResult.rows[0].company_name,
      });

      const response = {
        success: true,
        message: "회사가 삭제되었습니다.",
        data: {
          company_code: companyCode,
          company_name: checkResult.rows[0].company_name,
        },
      };

      res.status(200).json(response);
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("회사 삭제 실패", { error });
    res.status(500).json({
      success: false,
      message: "회사 삭제 중 오류가 발생했습니다.",
      errorCode: "COMPANY_DELETE_ERROR",
      error: error instanceof Error ? error.message : "Unknown error",
    });
  }
};

/**
 * POST /api/admin/users/reset-password
 * 사용자 비밀번호 초기화 API
 * 기존 Java AdminController.resetUserPassword() 포팅
 */
export const updateProfile = async (
  req: AuthenticatedRequest,
  res: Response
) => {
  try {
    const userId = req.user?.userId;
    if (!userId) {
      res.status(401).json({
        result: false,
        error: {
          code: "TOKEN_MISSING",
          details: "인증 토큰이 필요합니다.",
        },
      });
      return;
    }

    const {
      userName,
      userNameEng,
      userNameCn,
      email,
      tel,
      cellPhone,
      photo,
      locale,
    } = req.body;

    // 사용자 정보 업데이트
    const updateData: any = {};
    if (userName !== undefined) updateData.user_name = userName;
    if (userNameEng !== undefined) updateData.user_name_eng = userNameEng;
    if (userNameCn !== undefined) updateData.user_name_cn = userNameCn;
    if (email !== undefined) updateData.email = email;
    if (tel !== undefined) updateData.tel = tel;
    if (cellPhone !== undefined) updateData.cell_phone = cellPhone;
    if (photo !== undefined) updateData.photo = photo;
    if (locale !== undefined) updateData.locale = locale;

    // 업데이트할 데이터가 없으면 에러
    if (Object.keys(updateData).length === 0) {
      res.status(400).json({
        result: false,
        error: {
          code: "NO_DATA",
          details: "업데이트할 데이터가 없습니다.",
        },
      });
      return;
    }

    // 데이터베이스 업데이트
    await prisma.user_info.update({
      where: { user_id: userId },
      data: updateData,
    });

    // 업데이트된 사용자 정보 조회
    const updatedUser = await prisma.user_info.findUnique({
      where: { user_id: userId },
      select: {
        user_id: true,
        user_name: true,
        user_name_eng: true,
        user_name_cn: true,
        dept_code: true,
        dept_name: true,
        position_code: true,
        position_name: true,
        email: true,
        tel: true,
        cell_phone: true,
        user_type: true,
        user_type_name: true,
        photo: true,
        locale: true,
      },
    });

    res.json({
      result: true,
      message: "프로필이 성공적으로 업데이트되었습니다.",
      data: updatedUser,
    });
  } catch (error) {
    console.error("프로필 업데이트 오류:", error);
    res.status(500).json({
      result: false,
      error: {
        code: "UPDATE_FAILED",
        details: "프로필 업데이트 중 오류가 발생했습니다.",
      },
    });
  }
};

export const resetUserPassword = async (
  req: AuthenticatedRequest,
  res: Response
) => {
  try {
    const { userId, newPassword } = req.body;

    logger.info("비밀번호 초기화 요청", { userId, user: req.user });

    // 입력값 검증
    if (!userId || !userId.trim()) {
      res.status(400).json({
        result: false,
        msg: "사용자 ID가 필요합니다.",
      });
      return;
    }

    if (!newPassword || !newPassword.trim()) {
      res.status(400).json({
        success: false,
        result: false,
        message: "새 비밀번호가 필요합니다.",
        msg: "새 비밀번호가 필요합니다.",
      });
      return;
    }

    // 비밀번호 길이 검증 (최소 4자)
    if (newPassword.length < 4) {
      res.status(400).json({
        success: false,
        result: false,
        message: "비밀번호는 최소 4자 이상이어야 합니다.",
        msg: "비밀번호는 최소 4자 이상이어야 합니다.",
      });
      return;
    }

    const client = new Client({ connectionString: config.databaseUrl });
    try {
      await client.connect();

      // 1. 사용자 존재 여부 확인
      const userCheckResult = await client.query(
        "SELECT user_id, user_name FROM user_info WHERE user_id = $1",
        [userId]
      );

      if (userCheckResult.rows.length === 0) {
        res.status(404).json({
          success: false,
          result: false,
          message: "사용자를 찾을 수 없습니다.",
          msg: "사용자를 찾을 수 없습니다.",
        });
        return;
      }

      const currentUser = userCheckResult.rows[0];

      // 2. 비밀번호 암호화 (기존 Java 로직과 동일)
      let encryptedPassword: string;
      try {
        // EncryptUtil과 동일한 암호화 사용
        const crypto = require("crypto");
        const keyName = "ILJIAESSECRETKEY";
        const algorithm = "aes-128-ecb";

        // AES-128-ECB 암호화
        const cipher = crypto.createCipher(algorithm, keyName);
        let encrypted = cipher.update(newPassword, "utf8", "hex");
        encrypted += cipher.final("hex");
        encryptedPassword = encrypted.toUpperCase();
      } catch (encryptError) {
        logger.error("비밀번호 암호화 중 오류 발생", {
          error: encryptError,
          userId,
        });
        res.status(500).json({
          success: false,
          result: false,
          message: "비밀번호 암호화 중 오류가 발생했습니다.",
          msg: "비밀번호 암호화 중 오류가 발생했습니다.",
        });
        return;
      }

      // 3. 비밀번호 업데이트 실행
      const updateResult = await client.query(
        "UPDATE user_info SET user_password = $1 WHERE user_id = $2",
        [encryptedPassword, userId]
      );

      if (updateResult.rowCount && updateResult.rowCount > 0) {
        // 4. 이력 저장 (선택적)
        try {
          const writer = req.user?.userId || "system";
          await client.query(
            `
            INSERT INTO user_info_history 
            (sabun, user_id, user_name, dept_code, dept_name, user_type_name, history_type, writer, regdate, status)
            VALUES ('', $1, $2, '', '', '', '비밀번호 초기화', $3, NOW(), '')
          `,
            [userId, currentUser.user_name || userId, writer]
          );
        } catch (historyError) {
          logger.warn("비밀번호 초기화 이력 저장 실패", {
            error: historyError,
            userId,
          });
          // 이력 저장 실패해도 비밀번호 초기화는 성공으로 처리
        }

        logger.info("비밀번호 초기화 성공", {
          userId,
          updatedBy: req.user?.userId,
        });

        res.json({
          success: true,
          result: true,
          message: "비밀번호가 성공적으로 초기화되었습니다.",
          msg: "비밀번호가 성공적으로 초기화되었습니다.",
        });
      } else {
        res.status(400).json({
          success: false,
          result: false,
          message: "사용자 정보를 찾을 수 없거나 비밀번호 변경에 실패했습니다.",
          msg: "사용자 정보를 찾을 수 없거나 비밀번호 변경에 실패했습니다.",
        });
      }
    } finally {
      await client.end();
    }
  } catch (error) {
    logger.error("비밀번호 초기화 중 오류 발생", {
      error,
      userId: req.body.userId,
    });
    res.status(500).json({
      success: false,
      result: false,
      message: "비밀번호 초기화 중 시스템 오류가 발생했습니다.",
      msg: "비밀번호 초기화 중 시스템 오류가 발생했습니다.",
    });
  }
};