1

z8018

2025-03-12 17e4c7e3e7b3ef60d9da6de3b2a39a14a53c38a0

 WIDESEAWCS_Server/WIDESEAWCS_QuartzJob/QuartzNet/QuartzNetExtension.cs

@@ -41,7 +41,7 @@
        /// 启动程序自动开启调度服务
        /// </summary>
        /// <returns></returns>
        public async Task StartAsync()
        public virtual async Task StartAsync()
        {
            try
            {
@@ -51,6 +51,8 @@
                deviceInfos.ForEach(x =>
                {
                    if (!Storage.Devices.Exists(d => d.DeviceCode == x.DeviceCode))
                    {
                        try
                    {
                        #region 连接PLC
                        // 加载程序集
@@ -62,8 +64,10 @@
                        // 调用连接方法
                        bool? connectResult = (bool)type.InvokeMember("Connect", BindingFlags.Default | BindingFlags.InvokeMethod, null, obj, new object[] { });
                        // 判断连接结果
                        if (connectResult ?? false) ConsoleHelper.WriteSuccessLine(x.DeviceCode + "连接成功"); else ConsoleHelper.WriteErrorLine(x.DeviceCode + "连接失败");
                            if (connectResult ?? false) ConsoleHelper.WriteSuccessLine(type.Name + x.DeviceCode + "连接成功"); else ConsoleHelper.WriteErrorLine(type.Name + x.DeviceCode + "连接失败");
                        #endregion



                        #region 实例化设备对象
                        List<DeviceProDTO> devicePros = x.ProtocolList.Select(d => new DeviceProDTO
@@ -107,6 +111,11 @@

                        Storage.Devices.Add((IDevice)deviceInstance);
                    }
                        catch (Exception ex)
                        {
                            Console.WriteLine("调度服务开启异常" + ex.ToString());
                        }
                    }
                    else
                    {
                        x.Device = Storage.Devices.FirstOrDefault(d => d.DeviceCode == x.DeviceCode);