import { prisma } from '@/libs/prisma'
import { NextRequest, NextResponse } from 'next/server'
import { loggerWrapper } from '@/libs/api-wrapper'

type SuperPerson = {
  storeId: string
  salesOfficeCd: string
  fromEmail: string
  toEmail: string
}

async function getSubmissionAdmin(request: NextRequest): Promise<NextResponse> {
  try {
    const { searchParams } = new URL(request.url)
    const id = searchParams.get('id')

    const query = `
      OPEN SYMMETRIC KEY SYMMETRICKEY DECRYPTION BY CERTIFICATE CERTI_QSPJP;
      SELECT
        MCSA.STORE_ID
        , BCL.CODE AS SALES_OFFICE_CD
        , REF_CHR1 AS FROM_E_MAIL
        , REF_CHR2 AS TO_E_MAIL
      FROM MS_CUST_STOREID_ADDITNL MCSA WITH(NOLOCK)
      LEFT OUTER JOIN IF_PERSON_OFFICE_MAPPING IPOM WITH(NOLOCK)
      ON MCSA.KAM_ID = IPOM.LIFNR
        AND IF_STS = 'R'
        AND VKBUR IS NOT NULL
        AND VKBUR != ''
      INNER JOIN BC_COMM_L BCL WITH(NOLOCK)
      ON BCL.CODE = IPOM.VKBUR
        AND BCL.HEAD_CD = '103200'
        AND BCL.DEL_YN = 'N'
      WHERE MCSA.COMP_CD = '5200'
        AND MCSA.STORE_ID = 'A03'
        AND MCSA.DEL_YN = 'N'
      ;
      CLOSE SYMMETRIC KEY SYMMETRICKEY;
    `
    const suitable: SuperPerson[] = await prisma.$queryRawUnsafe(query)

    return NextResponse.json({ message: 'Hello, world!' })
  } catch (error) {
    console.error('❌ 데이터 조회 중 오류가 발생했습니다:', error)
    return NextResponse.json({ error: '데이터 조회 중 오류가 발생했습니다' }, { status: 500 })
  }
}

export const GET = loggerWrapper(getSubmissionAdmin)