using Bro.Common.Base;
using Bro.Common.Helper;
using Bro.Common.Interface;
using Bro.Common.Model;
using Bro.M135.Common;
using HalconDotNet;
using Microsoft.VisualBasic;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Sunny.UI;
using System.Data;
using System.Data.SqlTypes;
using System.Diagnostics;
using System.Net;
using System.Text;
using System.Text.Encodings.Web;
using System.Windows.Forms;
using System.Xml.Linq;
using static System.Net.Mime.MediaTypeNames;
using static System.Net.WebRequestMethods;
using static System.Windows.Forms.VisualStyles.VisualStyleElement.Tab;

namespace Bro.M141.Process
{
    public partial class M141Process
    {
        Dictionary<string, List<double>> dicdate = new Dictionary<string, List<double>>();
        ManualResetEvent set1 = new ManualResetEvent(false);
        ManualResetEvent set2 = new ManualResetEvent(false);

        [ProcessMethod("ImageCheck", "ImageCheckOperation", "通用图片检测操作", InvokeType.TestInvoke)]
        public ResponseMessage ImageCheckOperation(IOperationConfig config, IDevice invokeDevice, IDevice sourceDevice)
        {

            ResponseMessage msg = new ResponseMessage();

            if (config is IImageCheckOperationConfig opConfig)
            {

                var results = opConfig.Products.Select(u =>
                {
                    DetectResult result = new DetectResult();
                    result.PID = u.PID;
                    result.Specs = GetSpecListFromConfigSelection(opConfig.SpecCollection);
                    return result;
                }).ToList();

                msg.DataObj = results;


                var tool = GetHalconTool(null, "", opConfig.AlgorithemPath);
                Tuple<bool, Dictionary<string, HTuple>, Dictionary<string, HObject>, string, int> ret = null;


                if (opConfig.BDstate)
                {
                    List<double> bdlist = M141Config.BDCollection.FirstOrDefault(u => u.CameraId == opConfig.ExecuteDevice && u.CheckIndex == opConfig.BDindex)?.BDList;
                    if (bdlist == null)
                    {
                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"未找到标定配置，序号{opConfig.BDindex}");
                        return msg;
                    }
                    ret = tool.RunProcedure(new Dictionary<string, HTuple>() { { "INPUT_CalibrationData", bdlist.ToArray() } }, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);
                }
                else
                {
                    ret = tool.RunProcedure(null, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);
                }


                //var ret = tool.RunProcedure(null, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);

                if (!ret.Item1)
                {
                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"脚本{opConfig.AlgorithemPath}运行异常，{ret.Item4}");
                }
                else
                {
                    //for (int i = 1; i <= 2; i++)
                    //{
                    //    var p = opConfig.Products.FirstOrDefault(u => u.SEQUENCE.EndsWith(i.ToString()));
                    //    if (p != null)
                    //    {
                    //        var pResult = results.FirstOrDefault(u => u.PID == p.PID);
                    //        var datas = ret.Item2[$"OUTPUT_Results_{i}"].HTupleToDouble();

                    //        LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"当前脚本结果OUTPUT_Results_{i}：{string.Join(",", datas.Select(u => u.ToString("f3")))}");

                    //        if (pResult != null && datas.Count > 0)
                    //        {
                    //            FillSpecResults(pResult.PID, pResult.Specs, datas);
                    //        }
                    //    }
                    //}

                    opConfig.Products.ForEach(p =>
                    {
                        var pResult = results.FirstOrDefault(u => u.PID == p.PID);

                        string i = p.SEQUENCE[p.SEQUENCE.Length - 1].ToString();
                        var datas = ret.Item2[$"OUTPUT_Results_{i}"].HTupleToDouble();

                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"当前脚本结果OUTPUT_Results_{i}：{string.Join(",", datas.Select(u => u.ToString("f3")))}");

                        if (pResult != null && datas.Count > 0)
                        {
                            FillSpecResults(pResult.PID, pResult.Specs, datas, p.SEQUENCE);
                        }
                    });
                }
            }

            return msg;
        }

        [ProcessMethod("ImageCheck", "ImageCheckOperation2", "通用图片检测操作,数据交互输出", InvokeType.TestInvoke)]
        public ResponseMessage ImageCheckOperationOUT(IOperationConfig config, IDevice invokeDevice, IDevice sourceDevice)
        {
            ResponseMessage msg = new ResponseMessage();

            if (config is IImageCheckOperationConfig opConfig)
            {
                var results = opConfig.Products.Select(u =>
                {
                    DetectResult result = new DetectResult();
                    result.PID = u.PID;
                    result.Specs = GetSpecListFromConfigSelection(opConfig.SpecCollection);
                    return result;
                }).ToList();

                msg.DataObj = results;


                var tool = GetHalconTool(null, "", opConfig.AlgorithemPath);
                Tuple<bool, Dictionary<string, HTuple>, Dictionary<string, HObject>, string, int> ret = null;



                if (opConfig.BDstate)
                {
                    List<double> bdlist = M141Config.BDCollection.FirstOrDefault(u => u.CameraId == opConfig.ExecuteDevice && u.CheckIndex == opConfig.BDindex)?.BDList;
                    if (bdlist == null)
                    {
                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"未找到标定配置，序号{opConfig.BDindex}");
                        return msg;
                    }
                    ret = tool.RunProcedure(new Dictionary<string, HTuple>() { { "INPUT_CalibrationData", bdlist.ToArray() } }, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2", "OUTPUT_TransmitData" }, null);
                }
                else
                {
                    ret = tool.RunProcedure(null, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2", "OUTPUT_TransmitData" }, null);
                }


                //var ret = tool.RunProcedure(null, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);

                if (!ret.Item1)
                {
                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"脚本{opConfig.AlgorithemPath}运行异常，{ret.Item4}");
                }
                else
                {
                    //for (int i = 1; i <= 2; i++)
                    //{
                    //    var p = opConfig.Products.FirstOrDefault(u => u.SEQUENCE.EndsWith(i.ToString()));
                    //    if (p != null)
                    //    {
                    //        var pResult = results.FirstOrDefault(u => u.PID == p.PID);
                    //        var datas = ret.Item2[$"OUTPUT_Results_{i}"].HTupleToDouble();

                    //        LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"当前脚本结果OUTPUT_Results_{i}：{string.Join(",", datas.Select(u => u.ToString("f3")))}");

                    //        if (pResult != null && datas.Count > 0)
                    //        {
                    //            FillSpecResults(pResult.PID, pResult.Specs, datas);
                    //        }
                    //    }
                    //}

                    opConfig.Products.ForEach(p =>
                    {
                        var pResult = results.FirstOrDefault(u => u.PID == p.PID);
                        string i = p.SEQUENCE[p.SEQUENCE.Length - 1].ToString();
                        var datas = ret.Item2[$"OUTPUT_Results_{i}"].HTupleToDouble();
                        dicdate[i] = ret.Item2["OUTPUT_TransmitData"].HTupleToDouble();

                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"数据交互输出{i}  {string.Join(",", dicdate[i])}");
                        if (i == "1")
                        {
                            set1.Set();
                        }
                        else
                        {
                            set2.Set();
                        }

                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"当前脚本结果OUTPUT_Results_{i}：{string.Join(",", datas.Select(u => u.ToString("f3")))}");

                        if (pResult != null && datas.Count > 0)
                        {
                            FillSpecResults(pResult.PID, pResult.Specs, datas, p.SEQUENCE);
                        }
                    });
                }
            }

            return msg;
        }

        [ProcessMethod("ImageCheck", "ImageCheckOperation3", "通用图片检测操作,数据交互输入,不清数据", InvokeType.TestInvoke)]
        public ResponseMessage ImageCheckOperationIN1(IOperationConfig config, IDevice invokeDevice, IDevice sourceDevice)
        {
            ResponseMessage msg = new ResponseMessage();

            if (config is IImageCheckOperationConfig opConfig)
            {
                var results = opConfig.Products.Select(u =>
                {
                    DetectResult result = new DetectResult();
                    result.PID = u.PID;
                    result.Specs = GetSpecListFromConfigSelection(opConfig.SpecCollection);
                    return result;
                }).ToList();

                msg.DataObj = results;


                var tool = GetHalconTool(null, "", opConfig.AlgorithemPath);
                Tuple<bool, Dictionary<string, HTuple>, Dictionary<string, HObject>, string, int> ret = null;


                string index = "1";
                opConfig.Products.ForEach(p =>
                {
                    index = p.SEQUENCE[p.SEQUENCE.Length - 1].ToString();
                });

                if (dicdate[index].Count == 0)
                {
                    if (index == "1")
                    {
                        set1.Reset();
                        set1.WaitOne(3000);
                    }
                    else
                    {
                        set2.Reset();
                        set2.WaitOne(3000);
                    }
                }
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"数据交互输入{index}  {string.Join(",", dicdate[index])}");
                double[] tem = dicdate[index].ToArray();


                if (opConfig.BDstate)
                {
                    List<double> bdlist = M141Config.BDCollection.FirstOrDefault(u => u.CameraId == opConfig.ExecuteDevice && u.CheckIndex == opConfig.BDindex)?.BDList;
                    if (bdlist == null)
                    {
                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"未找到标定配置，序号{opConfig.BDindex}");
                        return msg;
                    }


                    ret = tool.RunProcedure(new Dictionary<string, HTuple>() { { "INPUT_TransmitData", tem }, { "INPUT_CalibrationData", bdlist.ToArray() } }, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);

                }
                else
                {
                    ret = tool.RunProcedure(new Dictionary<string, HTuple>() { { "INPUT_TransmitData", tem } }, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);
                }





                ret = tool.RunProcedure(new Dictionary<string, HTuple>() { { "INPUT_TransmitData", tem } }, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);

                //var ret = tool.RunProcedure(null, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);

                if (!ret.Item1)
                {
                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"脚本{opConfig.AlgorithemPath}运行异常，{ret.Item4}");
                }
                else
                {
                    //for (int i = 1; i <= 2; i++)
                    //{
                    //    var p = opConfig.Products.FirstOrDefault(u => u.SEQUENCE.EndsWith(i.ToString()));
                    //    if (p != null)
                    //    {
                    //        var pResult = results.FirstOrDefault(u => u.PID == p.PID);
                    //        var datas = ret.Item2[$"OUTPUT_Results_{i}"].HTupleToDouble();

                    //        LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"当前脚本结果OUTPUT_Results_{i}：{string.Join(",", datas.Select(u => u.ToString("f3")))}");

                    //        if (pResult != null && datas.Count > 0)
                    //        {
                    //            FillSpecResults(pResult.PID, pResult.Specs, datas);
                    //        }
                    //    }
                    //}

                    opConfig.Products.ForEach(p =>
                    {
                        var pResult = results.FirstOrDefault(u => u.PID == p.PID);

                        string i = p.SEQUENCE[p.SEQUENCE.Length - 1].ToString();
                        var datas = ret.Item2[$"OUTPUT_Results_{i}"].HTupleToDouble();

                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"当前脚本结果OUTPUT_Results_{i}：{string.Join(",", datas.Select(u => u.ToString("f3")))}");

                        if (pResult != null && datas.Count > 0)
                        {
                            FillSpecResults(pResult.PID, pResult.Specs, datas, p.SEQUENCE);
                        }
                    });
                }
            }

            return msg;
        }

        [ProcessMethod("ImageCheck", "ImageCheckOperation4", "通用图片检测操作,数据交互输入,清数据", InvokeType.TestInvoke)]
        public ResponseMessage ImageCheckOperationIN2(IOperationConfig config, IDevice invokeDevice, IDevice sourceDevice)
        {
            ResponseMessage msg = new ResponseMessage();

            if (config is IImageCheckOperationConfig opConfig)
            {
                var results = opConfig.Products.Select(u =>
                {
                    DetectResult result = new DetectResult();
                    result.PID = u.PID;
                    result.Specs = GetSpecListFromConfigSelection(opConfig.SpecCollection);
                    return result;
                }).ToList();

                msg.DataObj = results;


                var tool = GetHalconTool(null, "", opConfig.AlgorithemPath);
                Tuple<bool, Dictionary<string, HTuple>, Dictionary<string, HObject>, string, int> ret = null;

                string index = "1";
                opConfig.Products.ForEach(p =>
                {
                    index = p.SEQUENCE[p.SEQUENCE.Length - 1].ToString();

                });

                if (dicdate[index].Count == 0)
                {
                    if (index == "1")
                    {
                        set1.Reset();
                        set1.WaitOne(3000);
                    }
                    else
                    {
                        set2.Reset();
                        set2.WaitOne(3000);
                    }
                }
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"数据交互输入{index}  {string.Join(",", dicdate[index])}");
                double[] tem = dicdate[index].ToArray();




                if (opConfig.BDstate)
                {
                    List<double> bdlist = M141Config.BDCollection.FirstOrDefault(u => u.CameraId == opConfig.ExecuteDevice && u.CheckIndex == opConfig.BDindex)?.BDList;
                    if (bdlist == null)
                    {
                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"未找到标定配置，序号{opConfig.BDindex}");
                        return msg;
                    }


                    ret = tool.RunProcedure(new Dictionary<string, HTuple>() { { "INPUT_TransmitData", tem }, { "INPUT_CalibrationData", bdlist.ToArray() } }, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);

                }
                else
                {
                    ret = tool.RunProcedure(new Dictionary<string, HTuple>() { { "INPUT_TransmitData", tem } }, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);
                }
                //ret = tool.RunProcedure(new Dictionary<string, HTuple>() { { "INPUT_TransmitData", tem } }, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);

                dicdate[index].Clear();

                //var ret = tool.RunProcedure(null, new Dictionary<string, HalconDotNet.HObject>() { { "INPUT_Image", opConfig.ImageSet.HImage } }, new List<string>() { "OUTPUT_Results_1", "OUTPUT_Results_2" }, null);

                if (!ret.Item1)
                {
                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"脚本{opConfig.AlgorithemPath}运行异常，{ret.Item4}");
                }
                else
                {
                    //for (int i = 1; i <= 2; i++)
                    //{
                    //    var p = opConfig.Products.FirstOrDefault(u => u.SEQUENCE.EndsWith(i.ToString()));
                    //    if (p != null)
                    //    {
                    //        var pResult = results.FirstOrDefault(u => u.PID == p.PID);
                    //        var datas = ret.Item2[$"OUTPUT_Results_{i}"].HTupleToDouble();

                    //        LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"当前脚本结果OUTPUT_Results_{i}：{string.Join(",", datas.Select(u => u.ToString("f3")))}");

                    //        if (pResult != null && datas.Count > 0)
                    //        {
                    //            FillSpecResults(pResult.PID, pResult.Specs, datas);
                    //        }
                    //    }
                    //}

                    opConfig.Products.ForEach(p =>
                    {
                        var pResult = results.FirstOrDefault(u => u.PID == p.PID);

                        string i = p.SEQUENCE[p.SEQUENCE.Length - 1].ToString();
                        var datas = ret.Item2[$"OUTPUT_Results_{i}"].HTupleToDouble();

                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"当前脚本结果OUTPUT_Results_{i}：{string.Join(",", datas.Select(u => u.ToString("f3")))}");

                        if (pResult != null && datas.Count > 0)
                        {
                            FillSpecResults(pResult.PID, pResult.Specs, datas, p.SEQUENCE);
                        }
                    });
                }
            }

            return msg;
        }


        protected List<ISpec> GetSpecListFromConfigSelection(List<SpecSelector> specSelectors)
        {
            List<ISpec> specList = new List<ISpec>();
            specSelectors.ForEach(u =>
            {
                var spec = M141Config.SpecCollection.FirstOrDefault(s => s.Code == u.SpecCode);
                if (spec != null)
                {
                    var temp = spec.Copy<Spec>();
                    temp.ActualValue = null;
                    temp.MeasureResult = null;
                    specList.Add(temp);
                }
            });
            return specList;
        }

        protected void FillSpecResults(string pid, List<ISpec> detectSpec, List<double> results, string SEQUENCE)
        {
            detectSpec.ForEach(s =>
            {
                if (!s.IsEnabled)
                    return;

                if (results.Count > s.OutputIndex)
                {
                    s.ActualValue = results[s.OutputIndex];
                    if (s.IsEnableCompensation && s.CompensationValue.Count > 1)
                    {
                        string index1 = SEQUENCE.Split('_')[SEQUENCE.Split('_').Count() - 1];
                        if (index1 == "2")
                        {
                            s.ActualValue += s.CompensationValue[1];
                        }
                        else
                        {
                            s.ActualValue += s.CompensationValue[0];
                        }
                    }



                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"产品{pid}检测项{s.Code}赋值{s.GetMeasureValueStr()}，结果{s.GetMeasureResultStr()}");
                }
                else
                {
                    s.ActualValue = null;
                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"产品{pid}检测项{s.Code}未能赋值，结果{s.GetMeasureResultStr()}");
                }
            });
        }

        protected List<ISpec> GenerateSpecByMeasureItems(List<MeasureItemBind> measureItems)
        {
            List<ISpec> measureSpecs = new List<ISpec>();

            measureItems.ForEach(m =>
            {
                var originSpec = M141Config.SpecCollection.FirstOrDefault(u => u.Code == m.SpecCode);
                if (originSpec == null)
                {
                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"{m.SpecCode}设置的检测标准未能在配置中获取");
                    return;
                }

                if (m.IsSubscribeSpecForPoints)
                {
                    int index = 0;
                    m.MeasurePointNameCollection.ForEach(mp =>
                    {
                        var spec_p = originSpec.Copy<Spec>();
                        spec_p.Code = mp.MeasurePointName;
                        spec_p.OutputIndex = index;

                        measureSpecs.Add(spec_p);

                        index++;
                    });
                }
                else
                {
                    var spec = originSpec.Copy<Spec>();
                    if (!string.IsNullOrWhiteSpace(m.FAIName))
                    {
                        spec.Code = m.FAIName;
                    }
                    measureSpecs.Add(spec);
                }
            });

            return measureSpecs;
        }

        DateTime? _ct = null;
        [ProcessMethod("", "ProductDataUpload", "产品数据上传", InvokeType.TestInvoke)]
        public ResponseMessage ProductDataUpload(IOperationConfig config, IDevice invokeDevice, IDevice sourceDevice)
        {
            ResponseMessage msg = new ResponseMessage();

            var triggerDatas = config.TriggerStr.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
            string inputSequence = triggerDatas[triggerDatas.Length - 1];

            var productList = new List<int>() { 1, 2 }.Select(u =>
            {
                string sequence = $"{inputSequence}_{u}";
                return FindProductBySequence(sequence, true);
            }).ToList();

            string replyData = "#,UpData";

            int waitInterval = 300;
            int repeatTime = /*M141Config.DetectTimeout / waitInterval+*/2;

            do
            {
                if (productList.All(p => !string.IsNullOrWhiteSpace(p.Result)))
                {
                    break;
                }
                else
                {
                    Thread.Sleep(waitInterval);
                    repeatTime--;
                }

                if (repeatTime < 0)
                {
                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{string.Join(",", productList.Select(u => u.PID))}检测获取汇总结果超时，使用当前结果");
                    break;
                }
            } while (true);


            var Defaultclass = M141Config.DefectClassCollection.FirstOrDefault(u => u.IsDefault);
            productList.ForEach(p =>
            {
                if (Defaultclass == null)
                {
                    replyData += $",{(string.IsNullOrEmpty(p.Result) ? "NG" : p.Result)}";
                    if (string.IsNullOrEmpty(p.Result))
                    {
                        p.Result = "NG";
                    }
                }
                else
                {
                    replyData += $",{(string.IsNullOrEmpty(p.Result) ? Defaultclass.ClassName : p.Result)}";

                    if (string.IsNullOrEmpty(p.Result))
                    {
                        p.Result = Defaultclass.ClassName;
                    }
                }

                var specList = p.Details.SelectMany(u => u.ResultList.SelectMany(r => r.Specs)).ToList();
                p.Details.SelectMany(u => u.SpecList).ToList().ForEach(s =>
                {
                    if (!specList.Any(u => u.Code == s.Code))
                    {
                        specList.Add(s);
                    }
                });

                List<Pointdata> Pointdatas11 = new List<Pointdata>();

                foreach (var item in specList)
                {
                    try
                    {
                        Pointdatas11.Add(new Pointdata()
                        {
                            Code = item.Code,
                            Value = Convert.ToDouble(item.GetMeasureValueStr()),
                            Stand = item.StandardValue,
                            Min = item.StandardValue - item.Tolrenance_Negative,
                            Max = item.StandardValue + item.Tolrenance_Positive,
                            ispoint = false,
                        });
                    }
                    catch
                    {

                    }
                }
                M141Codelist.Add(Pointdatas11);

                HandleProductStatistc(p);
            });

            if (!M141Config.IsEnabelMESUpload)
            {
                replyData += ",OK";
            }
            else
            {
                int mesres = UploadProductDataToMES(productList);
                if (mesres == 0)
                {
                    replyData += $",OK";
                }
                else
                {
                    if (M141Config.MESProjectCode.ToUpper().Contains("AOI2"))
                    {
                        if (mesres == 3)
                        {
                            replyData += $",OK";
                        }
                        else
                        {
                            replyData += $",NG";
                        }
                    }
                    else
                    {
                        replyData += $",NG{mesres.ToString()}";
                    }
                }
            }


            productList.ForEach(p =>
            {
                replyData += $",{(p.SN.ToLower().Contains("read") ? "No Read" : p.SN)}";
            });

            ReplyTcpData("All", config.TriggerSource, replyData);


            //保存压缩图
            productList.ForEach(p =>
            {
                SaveZip(p.PID, p.Result);
            });



            //if (M141Config.IsEnableOEEDataUpload)
            //{
            //    productList.ForEach(p =>
            //    {
            //        OEEDataUpload(M141Config.OEEConfig_WorkPlace, p.SN, p.Details.SelectMany(u => u.ResultList).ToList());
            //    });
            //}

            return msg;
        }

        string _csvHead = "";
        List<string> _specHeadList = null;
        List<string> _positionList = new List<string>();
        private void UpdateProductResult(ProductModel p, out bool isOK)
        {
            isOK = false;

        
            int waitTimes = 1;
            if (p.Details.Any(u => u.IsDone == false) && waitTimes > 0)
            {
                //var pDB = _manager_P_Product.QueryProductByPID(p.PID);

                //for (int i = 0; i < p.Details.Count; i++)
                //{
                //    if (!p.Details[i].IsDone)
                //    {
                //        var correspondingDetail = pDB?.Details.FirstOrDefault(u => u.PositionName == p.Details[i].PositionName);
                //        if (correspondingDetail?.IsDone ?? false)
                //        {
                //            p.Details[i] = correspondingDetail;
                //        }
                //    }
                //}
                waitTimes--;
            }

            if (waitTimes == 0)
            {
                var unfinishedPositions = p.Details.Where(u => u.IsDone == false).Select(u => u.PositionName).ToList();
                if (unfinishedPositions.Count > 0)
                {
                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"产品{string.Join(",", unfinishedPositions)}站点结果未完成");
                }
            }

            p.InitialDetailSpecs();
            var resultList = p.Details.SelectMany(u => u.ResultList).ToList();
            resultList.ForEach(u => u.SetResult());
            var defects = resultList.GetDefectDescList();

            var ngSpecCodes = p.Details.SelectMany(u => u.SpecList ?? new List<Spec>()).Where(u => u.MeasureResult != true).Select(u => u.Code);

            var ngDefectDescList = p.Details.SelectMany(u => u.DefectList ?? new List<string>()).ToList();

            defects.AddRange(ngSpecCodes);
            defects.AddRange(ngDefectDescList);

            if (p.Details.Any(u => !u.IsDone))
            {
                defects.Add("TBD");
            }
            defects = defects.Distinct().ToList();

            isOK = defects.Count <= 0;

            UpdateDefectAsync(defects);
            var defectClass = GetDefectClassFromDefectList(defects);
            UpdateResult(DateTime.Now, p.SN, defectClass.ClassName, "");

            //产品序号+1
            Interlocked.Increment(ref _productIndex);

            List<ISpec> specList = new List<ISpec>();
            specList.AddRange(p.Details.SelectMany(u => u.SpecList).ToList().ConvertAll(u => (ISpec)u));
            specList.AddRange(p.Details.SelectMany(u => u.ResultList.SelectMany(d => d.Specs)));

            //ReplyRealTimeData(p.DataTag as List<ContourPoint>, specList);

            p.Result = defectClass.ClassName;
            p.EndTime = DateTime.Now;

            LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"产品{p.PID} {p.SEQUENCE} {p.SN}检测结果{p.Result}，缺陷明细：{string.Join(",", defects)}");
            //}
            //catch (Exception e)
            //{
            //    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, e.ToString());
            //}
        }

        private void ReplyRealTimeData(List<ContourPoint>? contourPoints, List<ISpec> specList)
        {
            if (contourPoints != null && contourPoints.Count > 0)
            {
                M141Config.RealTimeDataModels.ForEach(r =>
                {
                    if (!r.IsEnabled)
                        return;

                    List<string> selectPoints = new List<string>();
                    r.DataDetails.ForEach(u =>
                    {
                        var point = contourPoints.FirstOrDefault(c => c.Name == u.PointName);
                        if (point != null)
                        {
                            double pValue = 0;
                            switch (u.EdgeSelect)
                            {
                                case ContourEdge.X:
                                    pValue = point.ActualX;
                                    break;
                                case ContourEdge.Y:
                                    pValue = point.ActualY;
                                    break;
                            }

                            if (pValue > u.ValidRangeMin && pValue < u.ValidRangeMax)
                            {
                                selectPoints.Add($"{point.Name.Replace(' ', '-').Replace('_', '-')}-{u.EdgeSelect.ToString()}:{pValue.ToString("f3")}");
                            }
                        }
                    });

                    if (selectPoints.Count == r.DataDetails.Count)
                    {
                        string reply = r.DataHead + ",";
                        reply += $"{string.Join(",", selectPoints)},Count:{_productIndex}*\r\n";
                        _realTimeServer.WriteAndRead(reply, out _, out _);
                    }
                });
            }

            if (specList != null && specList.Count > 0)
            {
                M141Config.RealTimeDataModels.ForEach(r =>
                {
                    if (!r.IsEnabled)
                        return;

                    List<string> selectPoints = new List<string>();
                    r.DataDetails.ForEach(u =>
                    {
                        var spec = specList.FirstOrDefault(s => s.Code == u.SpecCode);
                        if (spec != null)
                        {
                            double pValue = spec.ActualValue ?? -999;
                            if (pValue > u.ValidRangeMin && pValue < u.ValidRangeMax)
                            {
                                selectPoints.Add($"{spec.Code.Replace(' ', '-').Replace('_', '-')}{u.SpecAfter}:{pValue.ToString("f3")}");
                                //selectPoints.Add($"{u.EdgeSelect.ToString()}:{pValue.ToString("f3")}");
                            }
                        }
                    });

                    if (selectPoints.Count == r.DataDetails.Count)
                    {
                        string reply = r.DataHead + ",";
                        reply += $"{string.Join(",", selectPoints)},Count:{_productIndex}*\r\n";
                        _realTimeServer.WriteAndRead(reply, out _, out _);
                    }
                });
            }

        }

        private void UpdateProductResultAsync(ProductModel p)
        {
            UpdateProductResult(p, out bool isOK);

            //_taskFactory.StartNew(() =>
            //{
            //    if (M141Config.IsEnableOEEDataUpload)
            //    {
            //        OEEDataUpload(M141Config.OEEConfig_WorkPlace, p.SN, p.Details.SelectMany(u => u.ResultList).ToList());
            //    }
            //});

            _taskFactory.StartNew(() =>
            {
                if (string.IsNullOrWhiteSpace(_csvHead))
                {
                    _csvHead = p.GetCSVHead(ref _specHeadList, ref _positionList);
                }
                CSVRecordAsync($"ProductRecord_{DateTime.Now.ToString("yyyyMMdd")}.csv", p.GetCSVData(_specHeadList, _positionList), _csvHead);
                //_manager_P_Product.UpdateProductResult(p.ID, p.PID, p.SN, p.Result);
            });

            //return await _taskFactory.StartNew(() =>
            // {
            //     UpdateProductResult(p, out bool isOK);
            //     return isOK;
            // });
        }

        [ProcessMethod("", "UploadDataToMES", "上传信息至MES", InvokeType.TestInvoke)]
        public ResponseMessage UploadDataToMES(IOperationConfig config, IDevice executeDevice, IDevice sourceDevice)
        {
            ResponseMessage msg = new ResponseMessage();
            try
            {
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"MES上传信息：{config.TriggerStr}");
                //MESService.WSTESTSoapClient client = new MESService.WSTESTSoapClient(MESService.WSTESTSoapClient.EndpointConfiguration.WSTESTSoap, M141Config.MESUploadURL);
                //string reply = client.aoidataX2966aoi3Insert(config.TriggerStr);
                HttpPost(M141Config.MESUploadURL, config.TriggerStr, out string reply, out StatusCode_en encode);


                LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"MES反馈信息：{reply}\r\n{JsonConvert.SerializeObject(encode)}");
                XDocument doc = XDocument.Parse(reply);
                foreach (XElement element in doc.Root.Elements())
                {
                    reply = element.Value;
                }

                msg.DataStr = reply;
                Mes_re jObj = JsonConvert.DeserializeObject<Mes_re>(reply);


                msg.Result = jObj.code; /*== 1000 ? 1 : -1;*/

                if (msg.Result == 1003)
                {
                    if (jObj.msg.Contains("导通测试"))
                    {
                        msg.Result = 4;
                    }
                    else
                    {
                        msg.Result = 1;
                    }
                }
            }
            catch (Exception ex)
            {
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"上传信息至{M141Config.MESUploadURL}异常，{ex.GetExceptionMessage()}");
                msg.Result = -1;
            }
            return msg;
        }

        public bool HttpPost(string url, string postDataStr, out string Result, out StatusCode_en ResultStatus)
        {
            if (M141Config.MESProjectCode.ToUpper().Contains("3221AOI1"))
            {
                postDataStr = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\r\n<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">\r\n  <soap:Body>\r\n    <X3221_AOI1_Upload xmlns=\"http://tempuri.org/\">\r\n      <json>" + postDataStr + "</json>\r\n    </X3221_AOI1_Upload>\r\n  </soap:Body>\r\n</soap:Envelope>";
            }
           else if (M141Config.MESProjectCode.ToUpper().Contains("3221AOI2"))
            {
                postDataStr = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\r\n<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">\r\n  <soap:Body>\r\n    <X3221_AOI2_Upload xmlns=\"http://tempuri.org/\">\r\n      <json>" + postDataStr + "</json>\r\n    </X3221_AOI2_Upload>\r\n  </soap:Body>\r\n</soap:Envelope>";
            }
            else if (M141Config.MESProjectCode.ToUpper().Contains("3221AOI3B"))
            {
                postDataStr = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\r\n<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">\r\n  <soap:Body>\r\n    <X3221_AOI3B_Upload xmlns=\"http://tempuri.org/\">\r\n      <json>" + postDataStr + "</json>\r\n    </X3221_AOI3B_Upload>\r\n  </soap:Body>\r\n</soap:Envelope>";
            }
            else if (M141Config.MESProjectCode.ToUpper().Contains("3221AOI3"))
            {
                postDataStr = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\r\n<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">\r\n  <soap:Body>\r\n    <X3221_AOI3_Upload xmlns=\"http://tempuri.org/\">\r\n      <json>" + postDataStr + "</json>\r\n    </X3221_AOI3_Upload>\r\n  </soap:Body>\r\n</soap:Envelope>";
            }
            else if (M141Config.MESProjectCode.ToUpper().Contains("3222AOI2"))
            {
                postDataStr = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\r\n<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">\r\n  <soap:Body>\r\n    <X3222_AOI2_Upload xmlns=\"http://tempuri.org/\">\r\n      <json>" + postDataStr + "</json>\r\n    </X3222_AOI2_Upload>\r\n  </soap:Body>\r\n</soap:Envelope>";
            }
            else if (M141Config.MESProjectCode.ToUpper().Contains("3222AOI3"))
            {
                postDataStr = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\r\n<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">\r\n  <soap:Body>\r\n    <X3222_AOI3_Upload xmlns=\"http://tempuri.org/\">\r\n      <json>" + postDataStr + "</json>\r\n    </X3222_AOI3_Upload>\r\n  </soap:Body>\r\n</soap:Envelope>";
            }

            bool flag = false;
            Result = string.Empty;
            ResultStatus = new StatusCode_en();
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            HttpWebResponse response;
            try
            {
                request.Timeout = 2000;//连接MES超时不超过2S
                byte[] bytesToPost = System.Text.Encoding.UTF8.GetBytes(postDataStr); //转换为bytes数据
                request.Method = "POST";
                request.ContentType = "text/xml; charset=utf-8";
                //request.ContentLength = bytesToPost.Length;

                //                POST / CYWebService.asmx / X3221_AOI2_Upload HTTP / 1.1
                //Host: 10.8.0.66
                //Content - Type: application / x - www - form - urlencoded
                //Content - Length: length

                //json = string

                //request.ContentType = "application/json";

                //request.Headers["Authorization"] = "09a2815ab6814ea3a87166d2bf866085"; //客供
                //request.Headers["Content-MD5"] = "c69fac58411218a8f4a7b1f8e00cf791";//MD5解析
                request.Accept = "*/*";
                CookieContainer cookie = new CookieContainer();
                request.CookieContainer = cookie;
                #region 其他没有设置的参数
                //request.ContentLength = Encoding.UTF8.GetByteCount(postDataStr);//添加长度后写入流后关闭不了,可能流方式不同问题
                //request.Referer = "";
                //request.Accept = "Accept:text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8";
                //request.Headers["Accept-Language"] = "zh-CN,zh;q=0.";
                //request.Headers["Accept-Charset"] = "GBK,utf-8;q=0.7,*;q=0.3";
                //request.UserAgent = "User-Agent:Mozilla/5.0 (Windows NT 5.1) AppleWebKit/535.1 (KHTML, like Gecko) Chrome/14.0.835.202 Safari/535.1";
                //request.KeepAlive = true;
                //Stream myRequestStream = request.GetRequestStream();
                //StreamWriter myStreamWriter = new StreamWriter(myRequestStream, Encoding.GetEncoding("gb2312"));           
                //myStreamWriter.Write(bytesToPost);
                //myStreamWriter.Flush();
                //myStreamWriter.Close();
                #endregion
                Stream stream = request.GetRequestStream();
                byte[] bs = System.Text.Encoding.UTF8.GetBytes(postDataStr);
                stream.Write(bs, 0, bs.Length);
                stream.Flush();
                stream.Close();
                response = (HttpWebResponse)request.GetResponse();

                ResultStatus = new StatusCode_en
                {
                    StatusCode = (int)response.StatusCode,
                    StatusCodeDiscribe = response.StatusDescription,
                };
                response.Cookies = cookie.GetCookies(response.ResponseUri);
                Stream myResponseStream = response.GetResponseStream();
                //获取全部返回值XML字符串
                StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.GetEncoding("utf-8"));
                Result = myStreamReader.ReadToEnd();
                flag = true;
            }
            catch (WebException ex)
            {
                //response = (HttpWebResponse)ex.Response;//有些异常如操作超时，对象会为空，想要详细数据不建议加判断
                ResultStatus = new StatusCode_en
                {
                    ErrDiscribe = ex.Message
                };
                flag = false;
            }
            return flag;
        }

        public class StatusCode_en//结果合集
        {
            /// <summary>
            /// 状态码，如404
            /// </summary>
            public int StatusCode { get; set; }
            /// <summary>
            /// 状态描述，如NotFound
            /// </summary>
            public string StatusCodeDiscribe { get; set; }
            /// <summary>
            /// 错误描述，如
            /// </summary>
            public string ErrDiscribe { get; set; }
        }

        public class Mes_re//结果合集
        {

            public int code { get; set; }

            public string msg { get; set; }

            public object value { get; set; }

            public object data { get; set; }
        }



        [ProcessMethod("", "CheckProductSNByMES", "检测产品条码（前站结果）", InvokeType.TestInvoke)]
        public ResponseMessage CheckProductSNByMES(IOperationConfig config, IDevice executeDevice, IDevice sourceDevice)
        {
            ResponseMessage msg = new ResponseMessage();
            try
            {
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"MES检测条码：{config.TriggerStr}");

                MESService.WSTESTSoapClient client = new MESService.WSTESTSoapClient(MESService.WSTESTSoapClient.EndpointConfiguration.WSTESTSoap, M141Config.MESUploadURL);

                Stopwatch sw = new Stopwatch();
                sw.Start();
                string reply = client.checkaoidataX2966aoi3Insert(config.TriggerStr);
                msg.DataStr = reply;

                sw.Stop();
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"MES检测条码{config.TriggerSource}，反馈信息：{reply}，耗时：{sw.ElapsedMilliseconds}ms");

                JObject jObj = JsonConvert.DeserializeObject<JObject>(reply);
                msg.Result = jObj.Value<string>("msg") == "OK" ? 1 : -1;
            }
            catch (Exception ex)
            {
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"检测条码信息至{M141Config.MESUploadURL}异常，{ex.GetExceptionMessage()}");
                msg.Result = -1;
            }
            return msg;
        }

    }
}