任务日志添加SignalR实时通讯刷新数据

hwh

2024-08-28 0347d14e06fb92ff4d64fad22b73fce78de98e88

 Admin.NET/WCS.Application/PLC/PLCTaskAction.cs

@@ -1,4 +1,5 @@
using Admin.NET.Core.Service;
using Furion.Logging;
using Microsoft.AspNetCore.SignalR;

namespace WCS.Application;
public static class PLCTaskAction
@@ -7,10 +8,10 @@

    private static List<WcsPlc> listPlc;
    private static List<WcsDevice> listPlcDevice;
    private static List<WcsStation> listPlcStation;
    private static List<WcsPosition> listPlcStation;

    private static List<PLCUtil> listPlcUtil = new List<PLCUtil>();
    private static CancellationTokenSource cts = new CancellationTokenSource();//取消线程标识
    private static CancellationTokenSource cts;//取消线程标识

    public static event EventHandler DeviceValueChangeEvent;
    static PLCTaskAction()
@@ -20,7 +21,7 @@

        listPlc = _db.Queryable<WcsPlc>().ToList();
        listPlcDevice = _db.Queryable<WcsDevice>().ToList();
        listPlcStation = _db.Queryable<WcsStation>().ToList();
        listPlcStation = _db.Queryable<WcsPosition>().ToList();
    }
    /// <summary>
    /// 初始化PLC连接
@@ -32,7 +33,7 @@
            cts.Cancel();
            listPlc = _db.Queryable<WcsPlc>().ToList();
            listPlcDevice = _db.Queryable<WcsDevice>().ToList();
            listPlcStation = _db.Queryable<WcsStation>().ToList();
            listPlcStation = _db.Queryable<WcsPosition>().ToList();
            //等待几秒钟，把已有线程取消掉再连接
            Thread.Sleep(5000);
            foreach (var modPlcUtil in listPlcUtil)
@@ -80,21 +81,22 @@
                        }
                        var listDevice = listPlcDevice.Where(s => s.PlcId == _modplc.Id).ToList();
                        //循环读设备
                        foreach (var modDevice in listDevice)
                        foreach (var modDevice in listDevice.Where(s => s.Level == DeviceLevelEnum.DB))
                        {
                            var (result, value) = modPlcUtil.GetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.PlcPos);
                            var (result, value) = modPlcUtil.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.PlcPos);
                            if (result.IsSucceed)
                            {
                                if (value != 0)
                                {
                                    var dto = modDevice.Adapt<WcsDeviceDto>();
                                    dto.Value = value;
                                    dto.Type = _modplc.Type;
                                    dto.PLCUtil = modPlcUtil;
                                    dto.listStation = listPlcStation.Where(s => s.DeviceId == modDevice.Id).ToList();
                                    //这里触发值变更事件
                                    DeviceValueChangeEvent?.Invoke(dto, EventArgs.Empty);
                                }
                                //无流程跳出
                                if (value == 0)
                                    continue;
                                var dto = modDevice.Adapt<WcsDeviceDto>();
                                dto.Value = value;
                                dto.Type = _modplc.Type;
                                dto.PLCUtil = modPlcUtil;
                                dto.listStation = listPlcStation.Where(s => s.DeviceId == modDevice.Id).ToList();
                                dto.listDevice = listDevice.Where(s => s.StationNum == modDevice.StationNum).ToList();
                                //这里触发值变更事件
                                DeviceValueChangeEvent?.Invoke(dto, EventArgs.Empty);
                            }
                            else
                            {
@@ -107,9 +109,13 @@

                        Thread.Sleep(3000);
                    }
                    catch (OperationCanceledException)
                    {
                        Console.WriteLine("中止线程");
                    }
                    catch (Exception ex)
                    {

                        Log.Error(ex.Message, ex);
                    }
                }
            }, cts.Token);