using DBHelper;
using Npgsql;
using VECV_WebApi.Common;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace VECV_WebApi.Models.Udan
{
    class ConsolidateReportRepository
    {

        /// <summary>
        ///  This is used to get Datatable by Stored Procedure name.
        /// </summary>
        /// <param name="spName">Stored Procedure name</param>
        /// <returns></returns>
        WriteInFile clsWriteInFile = new WriteInFile();
        public DataSet GetDataTableFromSP(string spName, ref TextWriter tw)
        {
            string Description = "Method Name :ConsolidateReportRepository.GetDataTableFromSP ,Stored Procedure run Sucessfully : " + spName;
            DataSet ds = new DataSet();
            try
            {
                ds = NpgSqlHelper.ExecuteDataset(GlobalConstants.ConnectionString, CommandType.StoredProcedure, spName);
            }
            catch (Exception Ex)
            {
                Description = "Stored Procedure Contain Error : " + spName + ", Error : " + Ex.Message;
                clsWriteInFile.WriteInTextFile(ref tw, Description);
            }
            return ds;
        }

        public void UpdateConsolidatedReportStatus(List<string> TicketArray, ref TextWriter tw)
        {
            string Description = "Method Name : ConsolidateReportRepository.UpdateConsolidatedReportStatus , Stored Procedure run Sucessfully : " + System.Configuration.ConfigurationManager.AppSettings["usp_update_consolidate_records_status"];
            try
            {
                string result = string.Join(",", TicketArray.ToArray());
                NpgsqlParameter[] nSqlParam = new NpgsqlParameter[1];
                nSqlParam[0] = new NpgsqlParameter("ticket_array", result);
                NpgSqlHelper.ExecuteNonQuery(GlobalConstants.ConnectionString, CommandType.StoredProcedure, System.Configuration.ConfigurationManager.AppSettings["usp_update_consolidate_records_status"], nSqlParam);
            }
            catch (Exception Ex)
            {
                Description = "Stored Procedure Contain Error : " + System.Configuration.ConfigurationManager.AppSettings["usp_update_consolidate_records_status"] + ", Error : " + Ex.Message;
                clsWriteInFile.WriteInTextFile(ref tw, Description);
            }

        }

    }
}