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

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, Cast(((WeightValue/Quantity)* .4536) as decimal(18,4)) as WeightValue, ActualUnitCostMonetaryAmount, TotalUnitValueMonetaryAmount, AmazonShipmentReferenceId FROM [Clientes.Amazon.Invoice.Detail] WHERE IdHeader = @id AND SightLine=1 Order BY Partida`)
    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 = {
  getAmazonInvoiceDetail: getAmazonInvoiceDetail,
  getAmazonInvoiceShipmentInfo: getAmazonInvoiceShipmentInfo,
  getAmazonInvoiceHeader: getAmazonInvoiceHeader
}