using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using TSA_V.Common;
using TSA_V.DeviceLibrary;

namespace TSA_V.LoadCSVLibrary
{
    public class CSVBomManager : CSVReaderBase
    {

        /// <summary>
        /// 所有的位置集合，key=位置
        /// </summary>
        public static Dictionary<string, List< ComponetInfo>> allComMap = new Dictionary<string, List<ComponetInfo>>();

        public static List<ComponetInfo> GetComList(string bomName)
        {
            if (allComMap.ContainsKey(bomName))
            {
                return new List<ComponetInfo>(allComMap[bomName] );
            }
            else
            {
                string fileName = getFilePath(bomName);
                if (File.Exists(fileName))
                {
                    List<ComponetInfo> list = ReadFile(fileName); 
                    allComMap.Add(bomName, list);
                    return list;
                }
            }
            return null;
        }

        public static bool BomNameIsExists(string bomName)
        {
            if (allComMap.ContainsKey(bomName))
            {
                return true;
            } 
            return false;
        }

        public static void LoadAllCom()
        {

            allComMap = new Dictionary<string, List<ComponetInfo>>();
            string appPath = Application.StartupPath;
            string filePath = appPath + ConfigAppSettings.GetValue(Setting_Init.ComPath_Config);
            if (!Directory.Exists(filePath))
            {
                Directory.CreateDirectory(filePath);
            }
            //加载所有数据
            string[] fileList = Directory.GetFiles(filePath);
            if (fileList.Length <= 0)
            {
                return;
            }
            foreach (string fileName in fileList)
            {
                try
                {
                    string extension = Path.GetExtension(fileName); //-->.xml
                    if (extension.ToLower().Equals(".csv"))
                    {
                        string bomName = Path.GetFileNameWithoutExtension(fileName); //-->BenXHCMS 
                        List<ComponetInfo> list = ReadFile(fileName);
                        if (list.Count > 0)
                        {
                            allComMap.Add(bomName, list);
                        }
                    }
                }
                catch (Exception ex)
                {
                    LogUtil.error("加载出错：" + ex.ToString());
                }
            }
        }

        private static string getFilePath(string bomName)
        {
            string appPath = Application.StartupPath;
            string filePath = appPath + ConfigAppSettings.GetValue(Setting_Init.ComPath_Config);
            return filePath + bomName + ".csv";
        }
        /// <summary>
        /// 添加一个csv文件的数据到位置集合中
        /// </summary>
        /// <param name="filePath">cvs文件路径+文件名</param>  
        /// <returns></returns>
        public static List<ComponetInfo> ReadFile(string filePath)
        {
            System.Type type = typeof(ComponetInfo);
            List<ComponetInfo> comList = new List<ComponetInfo>();
            Dictionary<string, List<string>> proTitleMap = getProAttributeMaps(typeof(ComponetInfo));

            //List<string> cvsTitleList = new List<string>(proTitleMap.Values);
            List<string> propertyList = new List<string>(proTitleMap.Keys);

            string[] lines = ReadCSVFile(filePath);
            int index = 0;
            Dictionary<string, int> propIndexMap = new Dictionary<string, int>();
            foreach (var line in lines)
            { 
                var newLine = line.Replace("\"", "");
                var array = newLine.Split(Spilt_Char);
                if (index == 0)
                {
                    propIndexMap = GetProTitleIndex(newLine, proTitleMap);
                }
                else
                {
                    try
                    {
                        if (array.Length >= propIndexMap.Count)
                        {
                            //if (array.Length > 0 && array[0].Equals(""))
                            //{
                            //    continue;
                            //}
                            var bllIns = type.Assembly.CreateInstance(type.FullName);
                            //取得属性集合
                            PropertyInfo[] props = type.GetProperties();

                            int listIndex = 0;

                            foreach (string proName in propertyList)
                            {
                                if (propIndexMap.ContainsKey(proName))
                                {
                                    int titIndex = propIndexMap[proName];
                                    string value = array[titIndex];
                                    //string proName = propertyList[listIndex];
                                    PropertyInfo prop = props.First(c => c.Name == proName);//获取同名属性
                                    if (prop != null)
                                    {
                                        string typeName = prop.PropertyType.Name;
                                        //判断值是否为空
                                        if (value.Equals("") && (typeName.ToUpper().Equals("INT32") || typeName.ToUpper().Equals("DOUBLE")))
                                        {
                                            value = "0";
                                        }
                                        //如果属性存在
                                        prop.SetValue(bllIns, Convert.ChangeType(value, prop.PropertyType), null);//赋值****在这里需要考虑类型问题 
                                    }
                                }
                                listIndex++;
                            }
                            ComponetInfo com = (ComponetInfo)bllIns;
                            com.Id = index + 1;
                            com.PositionNum = GetPositionNum(com.PositionNum);
                            if (String.IsNullOrEmpty(com.PositionNum) || String.IsNullOrEmpty(com.PN))
                            {
                                LOGGER.Error("读取csv，index=" + index + "，数据不完整，跳过数据，line=" + line);
                                continue;
                            }
                            comList.Add(com);
                        }
                        else
                        {
                            LOGGER.Error("读取csv，index=" + index + ",数据格式不匹配！，line=" + line);
                        }
                    }
                    catch (Exception ex)
                    {
                        LOGGER.Debug("CSV 读取行【" + line + "】行转换失败");
                    }
                }
                index++;
            }

            return comList;
        }
        public static string GetPositionNum(string configPosition )
        {
            TSAVPosition p = CSVPositionReader<TSAVPosition>.GetPositonByNum(configPosition);
            if (p != null)
            {
                return p.PositionNum;
            }
            return "";
        }
        public static bool UpdateComponet(string bomName, ComponetInfo com)
        {
            if (!allComMap.ContainsKey(bomName))
            {
                return false;
            }
            List<ComponetInfo> oldList = allComMap[bomName];
            for (int index = 0; index < oldList.Count; index++)
            {
                if (oldList[index].IsSameCom(com))
                {
                    oldList[index] = com;
                    break;
                }
            }

            if (SaveBomToFile(bomName, oldList))
            {
                allComMap[bomName] = oldList;
                return true;
            }

            return false;
        }

        public static bool SaveBomToFile(string bomName, List<ComponetInfo> positionList)
        {
            string filePath = getFilePath(bomName);
            System.Type type = typeof(ComponetInfo); 
            Dictionary<string, List<string>> proTitleMap = getProAttributeMaps(typeof(ComponetInfo));
           
            List<string> propertyList = new List<string>(proTitleMap.Keys);
            Dictionary<string, int> propIndexMap = new Dictionary<string, int>();
            string[] lines = new string[positionList.Count + 1];
            if (File.Exists(filePath))
            { 
                string[] readLines = ReadCSVFile(filePath);
                foreach (var line in readLines)
                {
                    lines[0] = line;
                    var array = line.Split(',');
                    propIndexMap = GetProTitleIndex(line, proTitleMap);
                    break;
                }
            }
            else
            {
                string line = "";
                propIndexMap = new Dictionary<string, int>();
                int proIndex = 0;
                   foreach(string pro in propertyList)
                {
                    List<string> csvList = proTitleMap[pro];
                    string title = csvList[0];
                    propIndexMap.Add(pro, proIndex);
                    line += title + ",";
                    proIndex++;
                }

                lines[0] = line;

            }
            int index = 1;

            foreach (ComponetInfo position in positionList)
            {
                string newValue = ObjToString(position, propIndexMap);
                lines[index] = newValue;
                index++;
            }

            return WriteCSVFile(filePath, lines);
        }

     

        private static string ObjToString(ComponetInfo position, Dictionary<string, int> propIndexMap)
        {
            //取得属性集合
            PropertyInfo[] props = typeof(ComponetInfo).GetProperties(); 
            List<string> propertyList = new List<string>(propIndexMap.Keys);
            String[] array = new String[propIndexMap.Count];

            foreach (string proName in propertyList)
            {
                PropertyInfo prop = props.First(c => c.Name == proName);//获取同名属性
                if (prop != null)
                {//如果属性存在
                    string value = prop.GetValue(position, null).ToString();
                    int index = propIndexMap[proName];
                    array[index] = value;
                }
            }

            string newStr = "";
            foreach (string str in array)
            {
                newStr += str + Spilt_Char;
            }
            return newStr;
        }
         
        public static bool AddBom(string bomName, List<ComponetInfo> comList)
        {
            try
            {
                RemoveBom(bomName);
                string filePath = getFilePath(bomName);
                if (File.Exists(filePath))
                {
                    //删除原来的文件
                    File.Delete(filePath);
                    LogUtil.error("新增元器件库：" + bomName + ",发现文件【" + filePath + "】已存在，删除原来的文件");
                } 
 
                allComMap.Add(bomName, comList);
                return SaveBomToFile(bomName, comList);
            }
            catch (Exception ex)
            {
                LogUtil.error("增加元器件库出错 ：【" + bomName + "】" + ex.ToString());
                return false;
            }
        }

        public static void RemoveBom(string bomName)
        { 
            string fileName = getFilePath(bomName);
            if (allComMap.ContainsKey(bomName))
            {
                allComMap.Remove(bomName);
            }
            if (File.Exists(fileName))
            { 
                File.Delete(fileName);
            }
        }

        public static List<ComponetInfo> RemoveCom(string bomName, ComponetInfo obj)
        {
            string fileName = getFilePath(bomName);
            File.Delete(bomName);
            if (allComMap.ContainsKey(bomName))
            {
                int delIndex = -1;
                List<ComponetInfo> list = allComMap[bomName];
                for (int index = 0; index < list.Count; index++)
                {
                    if (list[index].IsSameCom(obj))
                    {
                        delIndex = index;
                        break;
                    }
                }
                if (delIndex >= 0)
                {
                    list.RemoveAt(delIndex);
                    for (int i = 0; i < list.Count; i++)
                    {
                        list[i].Id = i + 1;
                    }
                    AddBom(bomName, list);
                }
                return list;

            }

            return null;
        }
        public static List<ComponetInfo> AddCom(string bomName, ComponetInfo obj)
        {
            string fileName = getFilePath(bomName);
            File.Delete(bomName);
            if (allComMap.ContainsKey(bomName))
            {
                List<ComponetInfo> list = allComMap[bomName];
                list.Add(obj);
                for(int i = 0; i < list.Count; i++)
                {
                    list[i].Id = i + 1;
                }
                AddBom(bomName, list);
                LogUtil.info($"元器件库[{bomName}]新增元器件[{obj.TagNo}-{obj.PN}]");

                ////更新此元器件库对应的程序
                //BoardManager.AddCom(bomName, obj);

                return list;
            }

            return null;
        }
        public static ComponetInfo GetCom(string bomName, SMTPointInfo pointInfo)
        {
            if (allComMap.ContainsKey(bomName))
            {
                List<ComponetInfo> map = allComMap[bomName];
                foreach (ComponetInfo obj in map)
                {
                    if (obj.IsSameCom(pointInfo))
                    {
                        return obj;
                    }
                }
                foreach (ComponetInfo obj in map)
                {
                    if (obj.PN.Equals(pointInfo.PN))
                    {
                        return obj;
                    }
                }
            }
            return null;
        }

        public static bool canRemoveCom(string bomName, ComponetInfo obj)
        {
            List<ComponetInfo> list = CSVBomManager.GetComList(bomName);
            //已使用的元器件不能删除
            foreach (BoardInfo board in BoardManager.boardList)
            {
                if (board.bomName.Equals(bomName))
                {
                    foreach (SMTPointInfo p in board.smtList)
                    {
                        if ((!String.IsNullOrEmpty(obj.TagNo)))
                        {
                            if (p.TagNo.Equals(obj.TagNo))
                            {
                                return false;
                            }
                        }
                        else if (p.PN.Equals(obj.PN))
                        {
                            List<ComponetInfo> pnlist = (from m in list where m.Id != obj.Id && m.PN.Equals(p.PN) select m).ToList();
                            if (pnlist.Count <= 0)
                            {
                                return false;
                            }
                        }
                    }

                }
            }
            return true;
        }

        /// <summary>
        /// 更新元器件数量，优先用位号查找，未找到时用Pn查找
        /// </summary> 
        public static bool UpdateCount(string bomName, SMTPointInfo smtPoint, int count)
        {
            List<ComponetInfo> comList = CSVBomManager.GetComList(bomName);
            if (comList == null)
            {
                return false;
            } 

            bool updateOk = false;
           for(int i=0;i<comList.Count;i++)
            {
                if (comList[i].IsSameCom(smtPoint))
                {
                    comList[i].ComCount = count;
                    updateOk = true;
                    break;
                }  
            }

            if (!updateOk)
            {
                for (int i = 0; i < comList.Count; i++)
                {
                    if (comList[i].PN.Equals(smtPoint.PN))
                    {
                        comList[i].ComCount = count;
                        updateOk = true;
                        break;
                    }
                }
            }

            CSVBomManager.SaveBomToFile(bomName, comList);
            return true;
        }
        /// <summary>
        /// 减去此电路板使用的元器件数量
        /// </summary>
        /// <param name="currBoard"></param>
        public static bool DelUseCount(DeviceLibrary.BoardInfo currBoard, List<ComponetInfo> useComponets)
        {
            try
            {
                string bomName = currBoard.bomName;
                List<ComponetInfo> comList = CSVBomManager.GetComList(bomName);
                if (comList == null)
                {
                    return false;
                }
                //Dictionary<string, int> useCount = new Dictionary<string, int>();
                //int index = 0;
                //List<SMTPointInfo> list = currBoard.GetSmtList();
                //foreach (SMTPointInfo smt in list)
                //{
                //    if (index > maxIndex)
                //    {
                //        break;
                //    }
                //    ComponetInfo com = CSVBomManager.GetCom(BoardManager.CurrBoard.bomName, smt);
                //    if (useCount.ContainsKey(com.PN))
                //    {
                //        useCount[com.PN]++;
                //    }
                //    else
                //    {
                //        useCount.Add(com.PN, 1);
                //    }
                //    index++;
                //}
                List<ComponetInfo> newList = new List<ComponetInfo>();
                foreach (ComponetInfo obj in comList)
                { 
                    List<ComponetInfo> list = (from m in useComponets where m.Id.Equals(obj.Id) select m).ToList(); 
                    if (list.Count > 0)
                    {
                        obj.ComCount = obj.ComCount - list.Count;
                        if (obj.ComCount < 0)
                        {
                            obj.ComCount = 0;
                        }
                    }
                    newList.Add(obj); 
                }
                if (allComMap.ContainsKey(bomName))
                {
                    allComMap[bomName] = newList;
                }
                CSVBomManager.SaveBomToFile(bomName, newList);
            }
            catch (Exception ex)
            {

            }
            return true;
        }
        public static string AutoAddBomList(string bomName, List<ComponetInfo> comList)
        {
            string newBomName = bomName;
            //自动新增元器件库  
            if (CSVBomManager.BomNameIsExists(bomName))
            {
                bomName = bomName + DateTime.Now.ToString("-MM-dd-HH-mm-ss");
                if (CSVBomManager.BomNameIsExists(bomName))
                {
                    for (int i = 1; i <= 100; i++)
                    {
                        string testName = bomName + "-" + i;
                        if (!CSVBomManager.BomNameIsExists(testName))
                        {
                            bomName = testName;
                            break;
                        }
                    }
                }
            }
            Dictionary<string, ComponetInfo> comMap = new Dictionary<string, ComponetInfo>();
            foreach (ComponetInfo obj in comList)
            {
                string key = obj.PN + "-" + obj.PositionNum;
                if (comMap.ContainsKey(key))
                {
                    continue;
                }
                obj.TagNo = "";
                comMap.Add(key, obj);
            }
            List<ComponetInfo> list = new List<ComponetInfo>(comMap.Values);
            for (int i = 0; i < list.Count; i++)
            {
                list[i].Id = i + 1;
            }
            CSVBomManager.AddBom(bomName, list);

            return bomName;
        }

    }
}