using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Transactions;

namespace bnhtrade.Core.Data.Database.Sku
{
    public class ReadSku : Connection
    {
        private SqlWhereBuilder sqlWhere = new SqlWhereBuilder();

        public ReadSku()
        {
        }

        public List<Model.Sku.Sku> BySkuNumber(List<string> skuNumberList)
        {
            var returnList = new List<Model.Sku.Sku>();

            if (!skuNumberList.Any())
            {
                return returnList;
            }

            // build the sql string
            string sqlString = @"
                SELECT
                    skuSkuNumber
                    ,skuAmazonFNSKU
                    ,skuActive
                FROM tblSku
                WHERE ";

            sqlWhere.Init();
            sqlWhere.In("skuSkuNumber", skuNumberList);
            sqlString += sqlWhere.SqlWhereString;

            using (SqlConnection conn = new SqlConnection(SqlConnectionString))
            {
                conn.Open();

                using (SqlCommand cmd = new SqlCommand(sqlString, conn))
                {
                    sqlWhere.AddParametersToSqlCommand(cmd);

                    using (var reader = cmd.ExecuteReader())
                    {
                        while (reader.Read())
                        {
                            var sku = new Model.Sku.Sku();

                            sku.SkuNumber = reader.GetString(0);
                            if (!reader.IsDBNull(1)) { sku.AmazonFNSKU = reader.GetString(1); }
                            sku.IsActive = reader.GetBoolean(2);

                            returnList.Add(sku);
                        }
                    }
                }
            }

            return returnList;
        }
    }
}