var config = require('../config/dbconfig')
const sql = require('mssql')

async function getRptControlDocumentosClientes() {
  try {
    let pool = await sql.connect(config)
    let reporte = await pool
      .request()
      .query("SELECT * FROM ReportesDocsSir WHERE Estatus='Activo'")
    return reporte.recordset
  } catch (error) {
    console.log(error)
  }
}

async function getNoPartesAmazon(id) {
  try {
    let pool = await sql.connect(config)
    const result = await pool
      .request()
      .input('id', id)
      .execute(`[Clientes.Amazon.Invoice.NoPartes2Excel.Get]`)
    //const NoPartesSIR = result.recordset;
    console.log(result.recordset)
    return result.recordset
  } catch (error) {
    console.log(error)
  }
}

async function getExceptionsFile4Amazon(id) {
  try {
    let pool = await sql.connect(config)
    const result = await pool
      .request()
      .input('id', id)
      .execute(`[Clientes.Amazon.Invoice.ExceptionsFile.Get]`)
    console.log(result.recordset)
    return result.recordset
  } catch (error) {
    console.log(error)
  }
}

async function getAmazonInvoiceDetail(id) {
  try {
    let pool = await sql.connect(config)
    const result = await pool
      .request()
      .input('id', id) 
      .query(`SELECT ItemId,ItemDescription, ItemQuantityUnitOfMeasure, CountryOfOrigin,Quantity,WeightValue, ActualUnitCostMonetaryAmount, TotalUnitValueMonetaryAmount   FROM [Clientes.Amazon.Invoice.Detail] WHERE IdHeader = @id`)
    console.log(result.recordset)
    return result.recordset
  } catch (error) {
    console.log(error)
  }
}

async function getAmazonInvoiceShipmentInfo(id) {
  try {
    let pool = await sql.connect(config)
    const result = await pool
      .request()
      .input('id', id)
      .query(`SELECT * FROM [Clientes.Amazon.Invoice.ShipFromAddress] WHERE IdHeader = @id and (AddressType = 'SELLER' or AddressType = 'BILLER')`)
    console.log(result.recordset)
    return result.recordset
  } catch (error) {
    console.log(error)
  }
}

async function getAmazonInvoiceHeader(id) {
  try {
    let pool = await sql.connect(config)
    const result = await pool
      .request()
      .input('id', id)
      .query(`SELECT * FROM [Clientes.Amazon.Invoice.Header] WHERE id = @id`)
    console.log(result.recordset)
    return result.recordset
  } catch (error) {
    console.log(error)
  }
}

module.exports = {
  getRptControlDocumentosClientes: getRptControlDocumentosClientes,
  getNoPartesAmazon: getNoPartesAmazon,
  getExceptionsFile4Amazon: getExceptionsFile4Amazon,
  getAmazonInvoiceDetail:  getAmazonInvoiceDetail,
  getAmazonInvoiceShipmentInfo: getAmazonInvoiceShipmentInfo,
  getAmazonInvoiceHeader: getAmazonInvoiceHeader
}