using iWare_SCADA_BusinessLogical.BLL;
using iWare_SCADA_BusinessLogical.Utils;
using iWare_SCADA_Model;
using System;
using System.Collections.Generic;
using System.Data;
using System.Globalization;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Web.UI.WebControls;

namespace iWare_SCADA_BusinessLogical
{
    /// <summary>
    /// OP05 打标完成标记，读取工控机中打印二维码信息
    /// </summary>
    public class DataCaptureHandler_OP0501 : DataCaptureHandler
    {
        public static readonly DataCaptureHandler_OP0501 Instance = new DataCaptureHandler_OP0501();

        public DataCaptureHandler_OP0501()
        {
        }

        public override string WorkingProcedure
        {
            get { return _dataCaptureConfig.WorkingProcedure; }
        }

        public override string DataCapturePointCode
        {
            get { return _dataCaptureConfig.DataCapturePointCode; }
        }
        public override string DataCapturePointCname
        {
            get { return _dataCaptureConfig.DataCapturePointCname; }
        }
        public override void RefreshDataList(List<DataCaptureConfig> dataCaptureConfig)
        {

        }
        private string CheackPath(string path,int type,int time)
        {
            var directory = Path.GetDirectoryName(path);
            if (!Directory.Exists(directory))
            {
                Directory.CreateDirectory(directory);
            }
            if (!File.Exists(path))
            {
                File.Create(path).Close();
            }

            string content = "";
            // 同步来源数据
            using (StreamReader reader = new StreamReader(path))
            {
                content = reader.ReadToEnd();

                Console.WriteLine("读取的内容是：" + content);
                if (content == null || content == "")
                {
                    switch (type)
                    {
                        case 1: content = DateTimeHelper.GetDateTime().AddYears(time).ToString();break;
                        case 2: content = DateTimeHelper.GetDateTime().AddMonths(time).ToString();break;
                        case 3: content = DateTimeHelper.GetDateTime().AddDays(time).ToString();break;
                        case 4: content = DateTimeHelper.GetDateTime().AddHours(time).ToString();break;
                        case 5: content = DateTimeHelper.GetDateTime().AddMinutes(time).ToString();break;
                        case 6: content = DateTimeHelper.GetDateTime().AddSeconds(time).ToString();break;
                        default:
                            content = DateTimeHelper.GetDateTime().ToString(); break;
                    }
                    //content = DateTimeHelper.GetDateTime().AddMinutes(-10).ToString();
                }
                    
            }
            return content;
        }
        public override void DataCaptureStart()
        {
            if (IsCaptureflag)
            {
                //// plc连接
                //var plcService = PLCManger.GetSinglePLCService(_dataCaptureConfig);
                //if (plcService == null)
                //{
                //    SystemValue.lbl_Alert_OP0501 = $"{RandomHelper.GenerateRandomCode(4)} 没有找到{_dataCaptureConfig.WorkingProcedure}的PLC设备";
                //    return;
                //}
                //if (plcService != null && !plcService.IsConnected)
                //{
                //    plcService.Close();
                //    plcService.OpenService();
                //}

                while (true)
                {
                    ThreadStatusMonitor threadStatusMonitor = new ThreadStatusMonitor();
                    threadStatusMonitor.Threadcode = DataCapturePointCode;
                    threadStatusMonitor.Threadcname = DataCapturePointCname;
                    threadStatusMonitor.Threadendtime = DateTime.Now;
                    threadStatusMonitor.Threadlastmodifytime = DateTime.Now;
                    threadStatusMonitor.Threadstatue = 0;
                    threadStatusMonitor.ThreadId = Thread.CurrentThread.ManagedThreadId.ToString();
                    try
                    {
                        ////_dataCaptureConfig
                        //if (plcService == null || !plcService.IsConnected)
                        //{
                        //    SystemValue.lbl_Alert_OP0501 = $" {RandomHelper.GenerateRandomCode(4)} {_dataCaptureConfig.WorkingProcedure} PLC连接已断开，正在尝试打开!";
                        //    plcService.Close();
                        //    plcService.OpenService();
                        //    Thread.Sleep(100);
                        //    continue;
                        //}
                        //else
                        {
                            //var value = plcService.ReadValuePoint(_dataCaptureConfig.DbNumber, _dataCaptureConfig.Offset, PLCManger.GetTypeForString(_dataCaptureConfig.DataCaptureColumnType));
                            //if (SystemValue.value_OP0501.Equals("0") && value.ToString().Equals("1"))
                            {//当上一标记位0，当前获取标记为1时，
                             //触发操作,  并给静态变量赋值为1
                             //业务代码
                             //读码完成没啥业务操作，获取二维码，然后放到队列中
                                #region 从工控机获取相关二维码
                                var path = ConfigHelper.GetConfigString("WorkPeiceIDPath");//打码机打码二维码路径
                                //扫描共享目录并将新的文件扫描返回  一般节拍在15秒左右（可以确认一下）
                                //扫描修改时间在上次扫描时间之前10秒到当前时间的之间的文件
                                var dataTime = CheackPath(Environment.CurrentDirectory + "\\OP05-LastScapTime.txt",4,-10);
                                var scapEndTime = DateTimeHelper.GetDateTime();
                                var newFiles = FileHelper.DetectNewFilesCSV(path, 60, Convert.ToDateTime(dataTime), scapEndTime);


                                Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure),
                                    $"{_dataCaptureConfig.WorkingProcedure}工序读取工控机中二维码信息开始:{dataTime}");

                                foreach (System.IO.FileInfo file in newFiles)
                                {
                                    Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure),
                                        $"{_dataCaptureConfig.WorkingProcedure}工序读取工控机中二维码信息,文件名:{file.FullName}");
                                    DataTable dt = null; 
                                    dt = CSVHelper.ReadCSV(file.FullName);
                                    if (dt == null)
                                    {
                                        continue;
                                    }
                                    lock (SystemValue.lock5QRcodeList)
                                    {
                                        #region 清过期缓存
                                        try
                                        {
                                            //清过期缓存
                                            var lstRemoveKey = SystemValue.QRcodeList
                                                .Where(p => p.Value < DateTimeHelper.GetDateTime().AddMinutes(-600))
                                                .Select(p => p.Key).ToList();
                                            if (lstRemoveKey.Count > 0)
                                            {
                                                foreach (var key in lstRemoveKey) SystemValue.QRcodeList.Remove(key);
                                                Log4NetHelper.WriteInfoLog(LogType.PLCOP05, $"清除缓存数量：（{lstRemoveKey.Count}） 剩余缓存数量：（{SystemValue.QRcodeList.Count}）");
                                            }
                                        }
                                        catch (Exception ex)
                                        {
                                            Log4NetHelper.WriteErrorLog(LogType.PLCOP05, "清除告警报文ID缓存错误！", ex);
                                        }
                                        #endregion

                                        ////筛选需要处理的二维码信息
                                        //DataRow[] drArr = dt.Select(" 扫码结果='成功'");    //查询
                                        //DataTable dtNew = dt.Clone();
                                        //for (int i = 0; i < drArr.Length; i++)
                                        //{
                                        //    var now = DateTime.Now;
                                        //    var list = drArr[i]["时间"].ToString().Split(':');
                                        //    var d = new DateTime(now.Year, now.Month, now.Day, Convert.ToInt32(list[0]), Convert.ToInt32(list[1]), Convert.ToInt32(list[2]), DateTimeKind.Local);
                                        //    //and 时间> '19:19:34:547'
                                        //    if (Convert.ToDateTime(DateTime.Now.ToShortDateString() + " " +drArr[i]["时间"]).TimeOfDay> Convert.ToDateTime(DateTime.Now.ToShortDateString() + " 19:19:34:547").TimeOfDay)
                                        //        dtNew.ImportRow(drArr[i]);
                                        //    //获取到的工件号异常
                                        //    SystemValue.lbl_Alert_OP0501 = $"{_dataCaptureConfig.WorkingProcedure}工序打标完成标记，读取工控机中打印二维码信息：【" + WorkPieceID + "】长度异常，长度不等于22位";
                                        //    Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure),
                                        //        $"{_dataCaptureConfig.WorkingProcedure}工序打标完成标记，读取工控机中打印二维码信息：【" + WorkPieceID + "】长度异常，长度不等于22位");
                                        //}
                                        DataTable newDt = new DataTable();
                                        var dates = file.Name.Split('-', '.');
                                        var date = string.Format("{0:D4}-{1:D2}-{2:D2}", int.Parse(dates[0]), int.Parse(dates[1]), int.Parse(dates[2]));
                                        if (DateTimeHelper.GetDateTime().Date != Convert.ToDateTime(date) && DateTimeHelper.GetDateTime().AddDays(-1).Date != Convert.ToDateTime(date))
                                        {
                                            continue;
                                        }
                                        DataRow[] filteredRows = new DataRow[dt.Rows.Count];
                                        if (dt.Rows.Count > 0)
                                        {
                                            int j = 0;
                                            var cache = DataCache.GetCache("OP501-LastTime");
                                            DateTime? lasttime = null;
                                            if (cache != null)
                                            {
                                                lasttime = Convert.ToDateTime(cache);
                                            }

                                            Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure),
                                                $"{_dataCaptureConfig.WorkingProcedure}工序读取工控机中二维码信息,工件最新时间:{(cache==null?"无缓存":cache.ToString())}");
                                            for (int i = dt.Rows.Count - 1; i >= 0; i--)
                                            {
                                                try
                                                {
                                                    string timeValue = dt.Rows[i]["时间"].ToString();
                                                    string[] timeComponents = timeValue.Split(':');
                                                    string correctedTime = string.Format("{0:D2}:{1:D2}:{2:D2}", int.Parse(timeComponents[0]), int.Parse(timeComponents[1]), int.Parse(timeComponents[2]));
                                                    var newTime = date + " " + correctedTime;
                                                    dt.Rows[i]["时间"] = newTime;

                                                    var currrentTime = Convert.ToDateTime(dt.Rows[i]["时间"]);
                                                    if (cache == null)
                                                    {
                                                        if (j == 0)
                                                        {
                                                            lasttime = currrentTime;
                                                        }
                                                        var oldTime = DateTime.Now.AddMinutes(-10);
                                                        if (currrentTime <= oldTime)
                                                        {
                                                            break;
                                                        }
                                                        filteredRows[j] = dt.Rows[i];
                                                    }
                                                    else
                                                    {
                                                        var cacheTime = Convert.ToDateTime(cache);
                                                        if (currrentTime <= cacheTime)
                                                        {
                                                            break;
                                                        }
                                                        filteredRows[j] = dt.Rows[i];
                                                    }
                                                    if (lasttime != null && lasttime < currrentTime)
                                                    {
                                                        lasttime = currrentTime;
                                                    }
                                                    j++;
                                                }
                                                catch (Exception ex)
                                                {
                                                    SystemValue.lbl_Alert_OP0501 = $" {_dataCaptureConfig.WorkingProcedure}文件打标时间异常，请查看日志！";
                                                    Log4NetHelper.WriteErrorLog(LogType.PLCOP05, $" {_dataCaptureConfig.WorkingProcedure}文件打标时间,出现异常：", ex);
                                                }
                                            }

                                            filteredRows = filteredRows.Where(item=>item!=null).ToArray();
                                            // 设置缓存值
                                            DateTime absoluteExpiration = DateTime.Now.AddDays(30);
                                            TimeSpan slidingExpiration = TimeSpan.FromMinutes(20);
                                            if (slidingExpiration == TimeSpan.Zero)
                                            {
                                                absoluteExpiration = DateTime.Now.AddDays(30);
                                            }
                                            else
                                            {
                                                absoluteExpiration = DateTime.MaxValue;
                                            }
                                            DataCache.SetCache("OP501-LastTime", lasttime, absoluteExpiration, slidingExpiration);
                                            if (filteredRows.Count() <= 0)
                                            {
                                                return;
                                            }
                                            if (file.LastAccessTime < Convert.ToDateTime(dataTime)) continue;
                                            using (StreamWriter writer = new StreamWriter(Environment.CurrentDirectory + "\\OP05-LastScapTime.txt", false))
                                            {
                                                dataTime = file.LastAccessTime.ToString();
                                                writer.Write(dataTime);
                                            }
                                            Log4NetHelper.WriteInfoLog(LogType.PLCOP05, $"读取到{filteredRows.Count()}行数据，时间范围是{filteredRows[j-1]["时间"]}-{filteredRows[0]["时间"]}");
                                        }

                                        //// 工件号（二维码值）
                                        //string WorkPieceID = dt.Rows[0][""].ToString();
                                        //if (WorkPieceID.Length != 22)
                                        //{
                                        //    //获取到的工件号异常
                                        //    SystemValue.lbl_Alert_HMI01 = $"{_dataCaptureConfig.WorkingProcedure}工序打标完成标记，读取工控机中打印二维码信息：【" + WorkPieceID + "】长度异常，长度不等于22位";
                                        //    Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure),
                                        //        $"{_dataCaptureConfig.WorkingProcedure}工序打标完成标记，读取工控机中打印二维码信息：【" + WorkPieceID + "】长度异常，长度不等于22位");
                                        //}


                                        //SystemValue.QRcodeList.Add("", DateTimeHelper.GetDateTime());//二维码添加到列表中

                                        WorkPieceLog wplog = new WorkPieceLog();
                                        wplog.Id = Yitter.IdGenerator.YitIdHelper.NextId();
                                        wplog.WorkingProcedure = "OP05";
                                        //wplog.EquipmentID = WorkingProcedure;
                                        wplog.Remarks = "cs";
                                        wplog.MonitoringPoint = DataCapturePointCode;
                                        wplog.CreatedTime = DateTimeHelper.GetDateTime();
                                        wplog.CreatedUserName = CultureInfo.CurrentUICulture.Name;
                                        wplog.UpdatedTime = DateTimeHelper.GetDateTime();
                                        wplog.UpdatedUserName = "测试";
                                        wplog.IsDeleted = false;
                                        wplog.EquipmentID = "123";

                                        wplog.OnlineTime = DateTimeHelper.GetDateTime();//给上线时间用

                                        wplog.QualityState = 1;
                                        wplog.ProcessingDuration = 1;
                                        wplog.MachineToolState = 1;
                                        wplog.AlertType = 1;
                                        wplog.WorkPieceNumber = 1;
                                        wplog.WorkPieceOnlineTime = Convert.ToDateTime(dataTime);
                                        wplog.WorkPieceOfflineTime = Convert.ToDateTime(dataTime).AddHours(1);
                                        wplog.WorkPieceStartMachiningTime = Convert.ToDateTime(dataTime);
                                        wplog.WorkPieceEndMachiningTime = DateTime.Now.AddDays(7);
                                        wplog.KnifeEdgeNumber = 10;
                                        wplog.KnifeToolLife = 10;
                                        wplog.KnifeToolEarlyWarningLife = 3;
                                        wplog.KnifeToolSurplusLife = 10;

                                        foreach (var item in filteredRows)
                                        {
                                            Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure),
                                                   $"{_dataCaptureConfig.WorkingProcedure}工序读取工控机中二维码信息,读取工件二维码:{item["打标内容"].ToString()}");

                                            if (item == null) break;
                                            wplog.Id = Yitter.IdGenerator.YitIdHelper.NextId();
                                            wplog.WorkPieceID = item["打标内容"].ToString();
                                            wplog.OfflineTime = Convert.ToDateTime(dataTime);
                                            wplog.Remarks = item["时间"].ToString() + "|" + item["打标内容"].ToString() + "|" + item["打标内容"].ToString() + "|" + item["扫码等级"].ToString() + "|" + item["扫码结果"].ToString();
                                            WorkPieceInfoManager.ReadQRcode(wplog, PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), null, _dataCaptureConfig.IsFeedback);

                                            threadStatusMonitor.Threadstatue = 1;
                                        }


                                    }
                                }


                                #endregion
                                var fileCount = newFiles.Cast<string>().ToList();
                                Log4NetHelper.WriteInfoLog(LogType.PLCOP05, $"扫描完成，共扫描到：（{fileCount.Count()}）个文件");
                            }
                            //SystemValue.value_OP0501 = value.ToString();
                        }   
                    }
                    catch (Exception ex)
                    {
                        SystemValue.lbl_Alert_OP0501 = $" {_dataCaptureConfig.WorkingProcedure}工序打标完成标记，读取工控机中打印二维码信息,出现异常，请查看日志！";
                        Log4NetHelper.WriteErrorLog(LogType.PLCOP05, $" {_dataCaptureConfig.WorkingProcedure}工序打标完成标记，读取工控机中打印二维码信息,出现异常：", ex);
                    }
                    finally
                    {
                        WorkPieceInfoManager.ThreadMonitor(threadStatusMonitor);
                    }
                    //线程多久执行一次（不包含业务处理时间）
                    if (!_dataCaptureConfig.DataCaptureFrequency.HasValue || _dataCaptureConfig.DataCaptureFrequency < 10)
                    {
                        Thread.Sleep(3000);
                    }
                    else
                    {
                        Thread.Sleep(_dataCaptureConfig.DataCaptureFrequency.Value);
                    }
                }
            }
            else
            {
                SystemValue.lbl_Alert_OP0501 = $"{_dataCaptureConfig.WorkingProcedure}工序打标完成标记，读取工控机中打印二维码信息，不做校验，请确认配置信息！";
                Log4NetHelper.WriteInfoLog(LogType.PLCOP05, $"{_dataCaptureConfig.WorkingProcedure}工序打标完成标记，读取工控机中打印二维码信息，不做校验，请确认配置异常");
            }















            //if (SystemValue.isStartedModel)
            //{
            //    #region 从工控机获取相关二维码


            //    //扫描共享目录并将新的文件扫描返回
            //    var newFiles = FileHelper.DetectNewFilesCSV("", 10, DateTimeHelper.GetDateTime());
            //    foreach (System.IO.FileInfo file in newFiles)
            //    {
            //        var datatable = CSVHelper.ReadCSV(file.FullName);
            //    }
            //    lock (SystemValue.lock5QRcodeList)
            //    {
            //        try
            //        {
            //            var plcService = PLCManger.GetSinglePLCService(_dataCaptureConfig);
            //            //清过期缓存
            //            var lstRemoveKey = SystemValue.QRcodeList
            //                .Where(p => p.Value < DateTimeHelper.GetDateTime().AddMinutes(-600))
            //                .Select(p => p.Key).ToList();
            //            if (lstRemoveKey.Count > 0)
            //            {
            //                foreach (var key in lstRemoveKey) SystemValue.QRcodeList.Remove(key);
            //                Log4NetHelper.WriteInfoLog(LogType.PLCOP05, $"清除缓存数量：（{lstRemoveKey.Count}） 剩余缓存数量：（{SystemValue.QRcodeList.Count}）");
            //            }
            //            WorkPieceLog wplog = new WorkPieceLog();
            //            wplog.Id = Yitter.IdGenerator.YitIdHelper.NextId();
            //            wplog.WorkingProcedure = WorkingProcedure;
            //            //wplog.EquipmentID = WorkingProcedure;
            //            wplog.Remarks = WorkingProcedure;
            //            wplog.MonitoringPoint = DataCapturePointCode;
            //            wplog.CreatedTime = DateTimeHelper.GetDateTime();
            //            wplog.CreatedUserName = DataCapturePointCode;
            //            wplog.UpdatedTime = DateTimeHelper.GetDateTime();
            //            wplog.UpdatedUserName = DataCapturePointCode;
            //            wplog.IsDeleted = false;
            //            wplog.EquipmentID= _dataCaptureConfig.EquipmentID;
            //            wplog.QualityState = (int)QualityState.OK;
            //            wplog.OnlineTime = DateTimeHelper.GetDateTime();//给上线时间用

            //            wplog.WorkPieceID = WorkPieceID;
            //            if (wplog.WorkPieceID.Length != 22)
            //            {//获取到的工件号异常
            //            }
            //            else
            //            {//获取其他配置的待采集项

            //                //foreach (var col in colConfig.Where(o => o.DataCapturePointCode == DataCapturePointCode))
            //                //{
            //                //    var valuecol = plcService.ReadValuePoint(col.DbNumber, col.Offset, col.DataCaptureColumnLength.Value, PLCManger.GetTypeForString(col.DataCaptureColumnType));
            //                //    wplog.GetType().GetProperty(col.DataCaptureColumnTabelName).SetValue(wplog, valuecol);//给动态字段赋值

            //                //}
            //            }
            //            //读取二维码后更新数据库
            //            var info = WorkPieceInfoManager.ReadQRcode(wplog, PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), plcService, _dataCaptureConfig.IsFeedback);

            //        }
            //        catch (Exception ex)
            //        {
            //            Log4NetHelper.WriteErrorLog(LogType.PLCOP05, "清除告警报文ID缓存错误！", ex);
            //        }

            //        if (SystemValue.QRcodeList.ContainsKey(WorkPieceID))
            //        {
            //            SystemValue.QRcodeList[WorkPieceID] = DateTimeHelper.GetDateTime();
            //        }
            //        else
            //        {
            //            SystemValue.QRcodeList.Add(WorkPieceID, DateTimeHelper.GetDateTime());//二维码添加到列表中
            //        }

            //    }

            //    #endregion
            //}
            //else
            //{


            //}
        }

    }
}