using System;

using System.IO;

using System.Collections.Generic;

using System.Data;

using System.Linq;

using System.Text;

​

namespace RPA_csv

{

    class Program

    {

        static void Main(string[] args)

        {

            string filepath = @"C:\Users\HP\Desktop\RPA.csv";

            DataTable res = ConvertCSVtoDataTable(filepath);

​

            string[] agg_group_cols = new string[] { "Ex" }; // group of columns

            string[] agg_calc_cols = new string[] { "Salary"}; // calculation of columns

​

            DataTable ss = aggrigateData(res, agg_group_cols, agg_calc_cols);

​

            string error = "k";

​

            Double result;

            Double.TryParse(error, out result);

            Console.WriteLine(result);

​

            /*

            Dictionary<string, Dictionary<string, string[]>> dictionary = new Dictionary<string, Dictionary<string, string[]>>();

            foreach (DataRow dr in res.Rows) {

                Console.WriteLine(string.Join("\t", dr.ItemArray));

                foreach(var dc in dr.ItemArray){

                }

            }

​

            var single = new Dictionary<string, string[]>();

            single.Add("ups", new string[] { "updegree", "updegreeaaa", "popup" });

            dictionary.Add("fff", single);

            */

            Console.WriteLine();

​

            Console.Read();

        }

​

        private static DataTable aggrigateData(DataTable dt, string[] agg_group_cols, string[] agg_calc_cols)

        {

            Dictionary<string, Dictionary<int, string[]>> dictionary = new Dictionary<string, Dictionary<int, string[]>>();

            Console.WriteLine("Total Columns" + dt.Columns.Count);

​

            IList<int> agg_cols_index = new List<int>();

            IList<int> agg_value_index = new List<int>();

            int index = 0;

            foreach (var dr in dt.Columns)

            {

                if (agg_group_cols.Contains(dr.ToString()))

                {

                    agg_cols_index.Add(index);

                }

                if (agg_calc_cols.Contains(dr.ToString()))

                {

                    agg_value_index.Add(index);

                }

                index++;

            }

            foreach (DataRow dr in dt.Rows)

            {

                //Create hash

                IList<string> hash_columns_value = new List<string>();

                foreach (var aci in agg_cols_index)

                {

                    hash_columns_value.Add(dr.ItemArray[aci].ToString());

                }

                string has_key = string.Join("|", hash_columns_value.ToArray());

​

                if (dictionary.ContainsKey(has_key.ToString()))

                {

                    foreach (var aci in agg_value_index)

                    {

                        float cal_val = Convert.ToInt32(dictionary[has_key.ToString()][0][aci]) + Convert.ToInt32(dr.ItemArray[aci].ToString());

                        dictionary[has_key.ToString()][0][aci] = cal_val.ToString();

                    }

                }

                else

                {

                    var single = new Dictionary<int, string[]>();

                    single.Add(0,dr.ItemArray.Cast<string>().ToArray());

                    dictionary.Add(has_key.ToString(), single);

                }

                Console.WriteLine();

            }

            foreach (string key in dictionary.Keys)

            {

                foreach (KeyValuePair<int, string[]> kvp in dictionary[key])

                {

                    Console.WriteLine(kvp.Key + " : " + string.Join("\t", kvp.Value));

                }

            }

            return dt;

        }

        public static string[] Add(string[] array, string newValue)

        {

            int newLength = array.Length + 1;

​

            string[] result = new string[newLength];

​

            for (int i = 0; i < array.Length; i++)

                result[i] = array[i];

​

            result[newLength - 1] = newValue;

​

            return result;

        }

​

        public static string[] RemoveAt(string[] array, int index)

        {

            int newLength = array.Length - 1;

​

            if (newLength < 1)

            {

                return array;//probably want to do some better logic for removing the last element

            }

            string[] result = new string[newLength];

            int newCounter = 0;

            for (int i = 0; i < array.Length; i++)

            {

                if (i == index)//it is assumed at this point i will match index once only

                {

                    continue;

                }

                result[newCounter] = array[i];

                newCounter++;

            }

​

            return result;

        }

        public static DataTable ConvertCSVtoDataTable(string strFilePath)

        {

            StreamReader sr = new StreamReader(strFilePath);

            string[] headers = sr.ReadLine().Split(',');

            DataTable dt = new DataTable();

            foreach (string header in headers)

            {

                dt.Columns.Add(header);

            }

            while (!sr.EndOfStream)

            {

                string[] rows = System.Text.RegularExpressions.Regex.Split(sr.ReadLine(), ",(?=(?:[^\"]*\"[^\"]*\")*[^\"]*$)");

                DataRow dr = dt.NewRow();

                for (int i = 0; i < headers.Length; i++)

                {

                    dr[i] = rows[i];

                }

                dt.Rows.Add(dr);

            }

            return dt;

        }

    }

}

​