using System;
using System.Collections.Generic;
using System.Data;
using System.IO;
using System.Linq;

namespace IStation.DAL
{
    /// <summary>
    /// 监测月数据集
    /// </summary>	
    public partial class MonitorDataSet
    {
        /// <summary>
        /// 日期文件夹信息类
        /// </summary>
        private class DateFolderInfo
        {
            public string FullName { get; set; }
            public int Year { get; set; }
            public int Month { get; set; }
        }

        #region DateFolderInfo
        /// <summary>
        /// 查询年月
        /// </summary> 
        private bool GetYearMonth(string folderPath, out int year, out int month)
        {
            year = month = 0;
            if (!Directory.Exists(folderPath))
                return false;

            var name = Path.GetFileName(folderPath);
            var strList = name.Split(SettingsD.File.FileNameSpacer);
            if (strList.Length != 2)
                return false;
            if (!int.TryParse(strList[0], out year))
            {
                return false;
            }
            if (!int.TryParse(strList[1], out month))
            {
                return false;
            }
            return true;
        }

        /// <summary>
        /// 查询日期文件夹信息列表
        /// </summary> 
        private List<DateFolderInfo> GetDateFolderInfoList(string monitorDataFolderPath)
        {
            if (!Directory.Exists(monitorDataFolderPath))
                return default;
            var directories = Directory.GetDirectories(monitorDataFolderPath);
            if (directories == null || directories.Count() < 1)
                return default;

            var list = new List<DateFolderInfo>(directories.Count());
            foreach (var directory in directories)
            {
                if (!GetYearMonth(directory, out int year, out int month))
                    continue;
                var info = new DateFolderInfo
                {
                    FullName = directory,
                    Year = year,
                    Month = month
                };
                list.Add(info);
            }
            if (list.Count > 0)
            {
                list = list.OrderBy(x => x.Year).ThenBy(x => x.Month).ToList();
            }
            return list;
        }

        #endregion

        /// <summary>
        /// 监测月数据集文件夹信息类
        /// </summary>
        private class MonitorDataSetFolderInfo
        {
            public string FullName { get; set; }
            public long MonitorPointID { get; set; }
            public int Year { get; set; }
            public int Month { get; set; }
        }

        #region MonitorDataSetFolderInfo
        /// <summary>
        /// 查询监测记录文件夹信息
        /// </summary> 
        private List<MonitorDataSetFolderInfo> GetMonitorDataSetFolderInfoList(string dateFolderPath)
        {
            if (!Directory.Exists(dateFolderPath))
                return default;
            if (!GetYearMonth(dateFolderPath, out int year, out int month))
                return default;
            var directories = Directory.GetDirectories(dateFolderPath);
            if (directories == null || directories.Count() < 1)
                return default;

            var infoList = new List<MonitorDataSetFolderInfo>(directories.Count());
            foreach (var directory in directories)
            {
                var name = Path.GetFileName(directory);
                if (long.TryParse(name, out long Id))
                {
                    var info = new MonitorDataSetFolderInfo
                    {
                        FullName = directory,
                        Year = year,
                        Month = month,
                        MonitorPointID = Id
                    };
                    infoList.Add(info);
                }
            }
            return infoList;
        }

        /// <summary>
        /// 查询监测记录文件夹信息
        /// </summary> 
        private List<MonitorDataSetFolderInfo> GetMonitorDataSetFolderInfoList(long monitorDataSourcesId, int year, int month)
        {
            var dateFolderInfo = GetYearMonthFolder(monitorDataSourcesId, year, month);
            var directories = Directory.GetDirectories(dateFolderInfo);
            if (directories == null || directories.Count() < 1)
                return default;

            var infoList = new List<MonitorDataSetFolderInfo>();
            foreach (var directory in directories)
            {
                var name = Path.GetFileName(directory);
                if (long.TryParse(name, out long Id))
                {
                    var info = new MonitorDataSetFolderInfo
                    {
                        FullName = directory,
                        Year = year,
                        Month = month,
                        MonitorPointID = Id
                    };
                    infoList.Add(info);
                }
            }
            return infoList;
        }

        /// <summary>
        /// 查询监测记录文件夹信息
        /// </summary> 
        private List<MonitorDataSetFolderInfo> GetMonitorDataSetFolderInfoList(DateFolderInfo dateFolderInfo)
        {
            if (dateFolderInfo == null)
                return default;
            var directories = Directory.GetDirectories(dateFolderInfo.FullName);
            if (directories == null || directories.Count() < 1)
                return default;

            var infoList = new List<MonitorDataSetFolderInfo>();
            foreach (var directory in directories)
            {
                var name = Path.GetFileName(directory);
                if (long.TryParse(name, out long Id))
                {
                    var info = new MonitorDataSetFolderInfo
                    {
                        FullName = directory,
                        Year = dateFolderInfo.Year,
                        Month = dateFolderInfo.Month,
                        MonitorPointID = Id
                    };
                    infoList.Add(info);
                }
            }
            return infoList;
        }

        #endregion


        /// <summary>
        /// 信号记录包文件信息类
        /// </summary>
        public class SignalRecordPackFileInfo
        {
            public string FullName { get; set; }
            public long MonitorPointID { get; set; }
            public long SignalID { get; set; }
            public int Year { get; set; }
            public int Month { get; set; }
        }

        #region SignalRecordPackFileInfo 

        /// <summary>
        /// 查询信号记录包文件信息
        /// </summary> 
        private List<SignalRecordPackFileInfo> GetSignalRecordPackFileInfoList(string dateFolderPath)
        {
            if (!Directory.Exists(dateFolderPath))
                return default;
            if (!GetYearMonth(dateFolderPath, out int year, out int month))
                return default;
            var monitorDirectories = Directory.GetDirectories(dateFolderPath);
            if (monitorDirectories == null || monitorDirectories.Count() < 1)
                return default;

            var infoList = new List<SignalRecordPackFileInfo>(monitorDirectories.Count());
            foreach (var monitorDirectory in monitorDirectories)
            {
                var list = GetSignalRecordPackFileInfoList(monitorDirectory, year, month);
                if (list != null && list.Any())
                {
                    infoList.AddRange(list);
                }
            }
            return infoList;
        }

        /// <summary>
        /// 查询信号记录包文件信息
        /// </summary> 
        private List<SignalRecordPackFileInfo> GetSignalRecordPackFileInfoList(string monitorDataSetFolder, int year, int month)
        {
            if (!Directory.Exists(monitorDataSetFolder))
                return default;
            var folderName = Path.GetFileName(monitorDataSetFolder);
            if (!long.TryParse(folderName, out long monitorPointId))
                return default;

            var files = Directory.GetFiles(monitorDataSetFolder);
            if (files == null || files.Count() < 1)
                return default;

            var infoList = new List<SignalRecordPackFileInfo>(files.Count());
            foreach (var filePath in files)
            {
                var name = Path.GetFileNameWithoutExtension(filePath);
                if (long.TryParse(name, out long Id))
                {
                    var info = new SignalRecordPackFileInfo
                    {
                        FullName = filePath,
                        MonitorPointID = monitorPointId,
                        SignalID = Id,
                        Year = year,
                        Month = month
                    };
                    infoList.Add(info);
                }
            }
            return infoList;
        }

        /// <summary>
        /// 查询信号记录包文件信息
        /// </summary> 
        private List<SignalRecordPackFileInfo> GetSignalRecordPackFileInfoList(MonitorDataSetFolderInfo monitorDataSetFolderInfo)
        {
            if (monitorDataSetFolderInfo == null)
                return default;
            var files = Directory.GetFiles(monitorDataSetFolderInfo.FullName);
            if (files == null || files.Count() < 1)
                return default;

            var infos = new List<SignalRecordPackFileInfo>(files.Count());
            foreach (var filePath in files)
            {
                var name = Path.GetFileNameWithoutExtension(filePath);
                if (long.TryParse(name, out long Id))
                {
                    var info = new SignalRecordPackFileInfo
                    {
                        FullName = filePath,
                        MonitorPointID = monitorDataSetFolderInfo.MonitorPointID,
                        SignalID = Id,
                        Year = monitorDataSetFolderInfo.Year,
                        Month = monitorDataSetFolderInfo.Month
                    };
                    infos.Add(info);
                }
            }
            return infos;
        }

        #endregion


        #region CsvConvert
        //To
        private string ToDsString(Model.SignalRecord record)
        {
            return $"{record.Time:yyyy-MM-dd HH:mm:ss},{record.Value}";
        }

        //from
        public Model.SignalRecord FromDsString(string dsString)
        {
            var strList = dsString.Split(',');
            if (strList.Length < 2)
                return default;
            var model = new Model.SignalRecord
            {
                Time = DateTime.Parse(strList[0]),
                Value = double.Parse(strList[1])
            };
            return model;
        }
        #endregion
    }
}