aivfo-tl-3.0/ivf_tl_operate_2.0/control/ivf_tl_Com/SerialBin.cs

using DBEntity;
using ivf_tl_CameraHelper;
using IvfTl.Control.Entity;
using IvfTl.Control.Entity.GlobalEnums;
using IvfTl.Control.Entity.InitEntitys;
using ivf_tl_SerialHelper.Util;
using IvfTl.Hardware.Impl;
using NetTaste;
using Newtonsoft.Json;
using System.IO.Ports;

namespace ivf_tl_Com
{
    /// <summary>
    /// 开机获取串口信息
    /// </summary>
    public class SerialBin
    {
        public event Action<string, LogEnum> TLLogEvent;

        public event Action<Exception, string, string, LogEnum> ExceptionLogEvent;

        public event Action<int, DateTime, string, LogEnum> HouseLogEvent;


        public Dictionary<int, string> CCDidSn = new Dictionary<int, string>();

        public List<HouseInitData> SerialModels = new List<HouseInitData>();

        public List<HouseEEPROInfo> HouseEEPROInfos = new List<HouseEEPROInfo>();

        private List<string> errorlist = new List<string>();

        /// <summary>结构化坏舱清单(与 errorlist 并存,errorlist 仅日志兼容)。</summary>
        public List<HouseFault> Faults { get; } = new List<HouseFault>();

        public int TLNum = -1;

        public int dayLighting = -1;

        private object lockObject = new object();

        /// <summary>
        /// 获取相机对应的ccdid
        /// </summary>
        public List<string> UpdataCamera()
        {
            try
            {
                CCDidSn.Clear();
                Task[] tasks = new Task[10];
                for (int i = 0; i < 10; i++)
                {
                    int ccdid = i;
                    tasks[ccdid] = Task.Run(() =>
                    {
                        GetCameraSn(ccdid);
                    });
                }
                Task.WaitAll(tasks);
                return errorlist;
            }
            catch (Exception ex)
            {
                ExceptionLogEvent?.Invoke(ex, "获取ccdid异常", null, LogEnum.RunException);
                lock (lockObject)
                {
                    errorlist.Add($"获取ccdid异常");
                }
                return errorlist;
            }
        }

        private void GetCameraSn(int i)
        {
            try
            {
                int InitNumber = -1;
                int GetSnNumber = -1;
                string SnNumber = null;
                int UnInitNumber = -1;
                // M1-03 HAL: 开机枚举相机 SN 也向 HAL 借用唯一相机实例（不再 new，避免与采集端句柄争用）。
                // 注：HAL.ScanDevices 已做相同的相机 SN 枚举+CCDSN 配对，初始化后应以 HAL 发现结果为准；
                // 此处保留旧枚举作为过渡，但句柄统一交 HAL 持有（13 §④ / M1-03 步骤4 范围控制）。
                Camera Camera = (Camera)HardwareAccessLayer.Instance.GetCamera(i).RawCamera;

                for (int j = 0; j < 3; j++)
                {
                    InitNumber = Camera.Init();

                    TLLogEvent?.Invoke($"第{j + 1}次{i}号相机初始化结果:{InitNumber}", LogEnum.RunRecord);

                    if (InitNumber == 0)
                    {
                        GetSnNumber = Camera.GetNumbet();
                        SnNumber = Camera.NumBer;

                        TLLogEvent?.Invoke($"获取序列号结果:{GetSnNumber};序列号：{SnNumber}", LogEnum.RunRecord);

                        UnInitNumber = Camera.UnInit();

                        TLLogEvent?.Invoke($"第{j + 1}次{i}号相机卸载结果:{UnInitNumber}", LogEnum.RunRecord);
                        break;
                    }
                    else
                    {
                        UnInitNumber = Camera.UnInit();
                        TLLogEvent?.Invoke($"第{j + 1}次{i}号相机卸载结果:{UnInitNumber}", LogEnum.RunRecord);
                    }
                }
                if (SnNumber == null)
                {
                    lock (lockObject)
                    {
                        CCDidSn.Add(i, SnNumber);
                    }
                }
                else
                {
                    lock (lockObject)
                    {
                        if (CCDidSn.ContainsValue(SnNumber))
                        {
                            errorlist.Add($"ccdid:{i};ccdsn:{SnNumber}");
                            Faults.Add(new HouseFault
                            {
                                HouseSn = -1,
                                Type = HouseFaultType.CameraDuplicateSn,
                                Reason = $"相机SN重复 ccdid:{i};ccdsn:{SnNumber}",
                                Stage = "相机枚举",
                                At = DateTime.UtcNow
                            });
                        }
                        else
                        {
                            CCDidSn.Add(i, SnNumber);
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                ExceptionLogEvent?.Invoke(ex, $"获取{i}号相机ccdSn异常", null, LogEnum.RunException);
                lock (lockObject)
                {
                    errorlist.Add($"获取{i}号相机ccdSn异常");
                    Faults.Add(new HouseFault
                    {
                        HouseSn = -1,
                        Type = HouseFaultType.CameraReadFailed,
                        Reason = $"获取{i}号相机ccdSn异常",
                        Stage = "相机枚举",
                        At = DateTime.UtcNow
                    });
                }
            }
        }

        List<house> Houses = new List<house>();

        public List<string> Start()
        {
            try
            {
                string[] ArryPort = SerialPort.GetPortNames();
                int portNum = ArryPort.Length;
                if (portNum > 0)
                {
                    List<Task> listTask = new List<Task>();
                    for (int i = 0; i < portNum; i++)
                    {
                        string portName = ArryPort[i];
                        if (portName == "COM1" || portName == "COM2")
                        {
                            continue;
                        }
                        if (portName.Contains("COM"))
                        {
                            listTask.Add(Task.Run(() =>
                            {
                                GetHouseInfo(portName);
                            }));
                        }
                    }
                    Task.WaitAll(listTask.ToArray());
                }
                return errorlist;
            }
            catch (Exception ex)
            {
                ExceptionLogEvent?.Invoke(ex, $"获取端口信息异常", null, LogEnum.RunException);
                lock (lockObject)
                {
                    errorlist.Add($"获取端口信息异常:{ex.Message}");
                }
                return errorlist;
            }
        }

        private void GetHouseInfo(string portName)
        {
            try
            {
                //下加热板目标温度
                //仓室和缓冲瓶进气阀打开时间
                //ccdSN
                //ccdid
                HouseInitData serialModel = new HouseInitData();
                serialModel.housePort = portName;

                var custom = new CustomProtocol();
                custom.commandSource = CommandSource.GetModuleThread;
                // M1-03 HAL: 开机枚举舱信息向 HAL 借用唯一 ComBin（不再 new，杜绝与采集端同口重复 Open）。
                ComBin comBin = (ComBin)HardwareAccessLayer.Instance.GetSerial(0, portName).RawComBin;
                comBin.IsStopWhile = false;

                comBin.CommandLogEvent += HouseLogEvent;
                comBin.ErrorLogEvent += TLLogEvent;
                comBin.ExceptionLogEvent += ExceptionLogEvent;

                bool isOpenPort = comBin.OpenPort();
                TLLogEvent?.Invoke($"打开端口{portName}结果：{isOpenPort}", LogEnum.RunRecord);
                if (!isOpenPort) goto CC;
                serialModel.houseSn = comBin.ShakeHandsWait(custom);
                if (!custom.IsSuccess) goto CC;
                lock (lockObject)
                {
                    var itemModel = SerialModels.FirstOrDefault(x => x.houseSn == serialModel.houseSn);
                    if (itemModel != null)
                    {
                        errorlist.Add($"从{serialModel.housePort}串口获取到的模块号{serialModel.houseSn}和{itemModel.housePort}串口获取到的模块号{itemModel.houseSn}重复");
                        Faults.Add(new HouseFault
                        {
                            HouseSn = serialModel.houseSn,
                            Port = serialModel.housePort,
                            Type = HouseFaultType.HouseSnDuplicate,
                            Reason = $"模块号{serialModel.houseSn}在{serialModel.housePort}与{itemModel.housePort}重复",
                            Stage = "扫口握手",
                            At = DateTime.UtcNow
                        });
                        goto CC;
                    }
                }

                if (serialModel.houseSn == 11)
                {
                    TLNum = comBin.ReadTLNumWait(custom);
                    if (!custom.IsSuccess) goto CC;
                    dayLighting = comBin.ReadEEPROMLightNumWait(custom);
                    if (!custom.IsSuccess) goto CC;
                    serialModel.inletValveOpeningTime = comBin.ReadEEPROOpenIntakeTimeBufferWait(custom);
                    if (!custom.IsSuccess) goto CC;
                    serialModel.ccdSn = "-1";
                    lock (lockObject)
                    {
                        SerialModels.Add(serialModel);
                    }
                }
                else
                {
                    serialModel.temperatureLowerHeatingPlate = comBin.ReadTargetTempWait(custom);
                    if (!custom.IsSuccess) goto CC;
                    serialModel.inletValveOpeningTime = comBin.ReadEEPROOpenIntakeTimeWait(custom);
                    if (!custom.IsSuccess) goto CC;
                    serialModel.verticalMotorSpacePulse = comBin.ReadEEPROMvertMtScanPluseWait(custom);
                    if (!custom.IsSuccess) goto CC;
                    var currentCCDSN = comBin.GetCCDSNWait(custom).ToString();
                    if (!custom.IsSuccess) goto CC;
                    lock (lockObject)
                    {
                        var itemModel = SerialModels.FirstOrDefault(x => x.ccdSn == currentCCDSN);
                        if (itemModel == null)
                        {
                            if(CCDidSn.ContainsValue(currentCCDSN))
                            {
                                serialModel.ccdId = CCDidSn.FirstOrDefault(x => x.Value == currentCCDSN).Key;
                            }
                            else
                            {
                                errorlist.Add($"相机列表中不存在仓室的CCDSN{currentCCDSN}");
                                Faults.Add(new HouseFault
                                {
                                    HouseSn = serialModel.houseSn,
                                    Port = serialModel.housePort,
                                    Type = HouseFaultType.CcdSnMissing,
                                    Reason = $"相机列表中不存在仓室的CCDSN{currentCCDSN}",
                                    Stage = "扫口握手",
                                    At = DateTime.UtcNow
                                });
                            }
                           
                            serialModel.ccdSn = currentCCDSN;
                            SerialModels.Add(serialModel);
                        }
                        else
                        {
                            errorlist.Add($"从{serialModel.houseSn}号模块的{serialModel.housePort}串口获取到的{currentCCDSN}和{itemModel.ccdSn}模块{itemModel.housePort}串口的{itemModel.ccdSn}重复");
                            Faults.Add(new HouseFault
                            {
                                HouseSn = serialModel.houseSn,
                                Port = serialModel.housePort,
                                Type = HouseFaultType.CcdSnDuplicate,
                                Reason = $"舱{serialModel.houseSn}的CCDSN{currentCCDSN}与{itemModel.housePort}重复",
                                Stage = "扫口握手",
                                At = DateTime.UtcNow
                            });
                        }
                    }

                    HouseEEPROInfo houseEEPROInfo = new HouseEEPROInfo();
                    houseEEPROInfo.houseSn = serialModel.houseSn;

                    houseEEPROInfo.hwell1 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 1);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell2 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 2);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell3 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 3);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell4 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 4);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell5 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 5);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell6 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 6);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell7 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 7);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell8 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 8);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell9 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 9);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell10 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 10);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell11 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 11);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell12 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 12);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell13 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 13);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell14 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 14);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell15 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 15);
                    if (!custom.IsSuccess) goto CC;
                    houseEEPROInfo.hwell16 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 16);
                    if (!custom.IsSuccess) goto CC;
                    
                    houseEEPROInfo.eepromClearPosition = comBin.ReadEEPROMvertMtStartPulseWait(custom);
                    if (!custom.IsSuccess) goto CC;
                    lock (lockObject)
                    {
                        HouseEEPROInfos.Add(houseEEPROInfo);
                    }
                }

            CC:
                comBin.IsStop = true;
                var ClosePort = comBin.ClosePort();
                TLLogEvent?.Invoke($"关闭端口{portName}结果：{ClosePort}", LogEnum.RunRecord);
            }
            catch (Exception ex)
            {
                ExceptionLogEvent?.Invoke(ex, $"获取端口信息异常{portName}", null, LogEnum.RunException);
                lock (lockObject)
                {
                    errorlist.Add($"获取端口信息异常{portName}:{ex.Message}");
                    Faults.Add(new HouseFault
                    {
                        HouseSn = -1,
                        Port = portName,
                        Type = HouseFaultType.SerialReadException,
                        Reason = $"获取端口信息异常{portName}:{ex.Message}",
                        Stage = "扫口握手",
                        At = DateTime.UtcNow
                    });
                }
            }
        }

        /// <summary>
        /// 读取仓室E方数据
        /// </summary>
        public List<string> HousesEEPRO()
        {
            try
            {
                int num = SerialModels.Count;
                List<Task> tasks = new List<Task>();
                foreach (var item in SerialModels)
                {
                    if (item.houseSn == 11)
                    {
                        continue;
                    }
                    tasks.Add(Task.Run(() =>
                    {
                        HouseEEPRO(item);
                    }));
                }
                Task.WaitAll(tasks.ToArray());
                return errorlist;
            }
            catch (Exception ex)
            {
                ExceptionLogEvent?.Invoke(ex, $"获取仓室E方信息", null, LogEnum.RunException);
                lock (lockObject)
                {
                    errorlist.Add($"获取仓室E方信息异常:{ex.Message}");
                }
                return errorlist;
            }
        }

        private void HouseEEPRO(HouseInitData serialModel)
        {
            //1-16号水平电机位置
            //垂直电机间隔脉冲
            //E方清晰地址
            try
            {
                HouseEEPROInfo houseEEPROInfo = new HouseEEPROInfo();
                houseEEPROInfo.houseSn = serialModel.houseSn;

                var custom = new CustomProtocol();
                custom.commandSource = CommandSource.GetModuleThread;
                // M1-03 HAL: 向 HAL 借用唯一 ComBin（不再 new，杜绝与采集端同口重复 Open）。
                ComBin comBin = (ComBin)HardwareAccessLayer.Instance.GetSerial(serialModel.houseSn, serialModel.housePort).RawComBin;
                comBin.IsStopWhile = false;

                comBin.CommandLogEvent += HouseLogEvent;
                comBin.ErrorLogEvent += TLLogEvent;
                comBin.ExceptionLogEvent += ExceptionLogEvent;

                for (int i = 0; i < 3; i++)
                {
                    if (i != 0) TLLogEvent?.Invoke($"第{i + 1}次关闭端口{serialModel.housePort}结果：{comBin.ClosePort()}", LogEnum.RunRecord);
                    bool isOpenPort = comBin.OpenPort();
                    HouseLogEvent?.Invoke(serialModel.houseSn, DateTime.Now, $"[{serialModel.houseSn}][{serialModel.housePort}]打开端口结果：{isOpenPort}", LogEnum.HouseInfo);
                    if (!isOpenPort)
                    {
                        continue;
                    }

                    houseEEPROInfo.hwell1 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 1);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell2 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 2);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell3 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 3);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell4 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 4);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell5 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 5);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell6 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 6);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell7 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 7);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell8 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 8);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell9 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 9);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell10 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 10);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell11 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 11);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell12 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 12);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell13 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 13);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell14 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 14);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell15 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 15);
                    if (!custom.IsSuccess) continue;
                    houseEEPROInfo.hwell16 = comBin.ReadEEPROMhoriMtWellHorHorWait(custom, 16);
                    if (!custom.IsSuccess) continue;
                    //houseEEPROInfo.verticalMotorSpacePulse = comBin.ReadEEPROMvertMtScanPluseWait(custom);
                    //if (!custom.IsSuccess) continue;
                    houseEEPROInfo.eepromClearPosition = comBin.ReadEEPROMvertMtStartPulseWait(custom);
                    if (!custom.IsSuccess) continue;
                    lock (lockObject)
                    {
                        HouseEEPROInfos.Add(houseEEPROInfo);
                    }
                    break;
                }
                comBin.IsStop = true;
                var ClosePort = comBin.ClosePort();
                HouseLogEvent?.Invoke(serialModel.houseSn, DateTime.Now, $"[{serialModel.houseSn}][{serialModel.housePort}]关闭端口结果：{ClosePort}", LogEnum.HouseInfo);
            }
            catch (Exception ex)
            {
                ExceptionLogEvent?.Invoke(ex, $"[{serialModel.houseSn}][{serialModel.housePort}]获取仓室E方信息", null, LogEnum.RunException);
                lock (lockObject)
                {
                    errorlist.Add($"[{serialModel.houseSn}][{serialModel.housePort}]获取仓室E方信息异常:{ex.Message}");
                }
            }
        }


    }
}