WCSNet6.git - Gitblit

			@@ -1,27 +1,41 @@
			using Admin.NET.Core.Service;
			using DocumentFormat.OpenXml.Drawing;
			using Furion.Logging;
			using Microsoft.AspNetCore.SignalR;

			namespace WCS.Application;
			public static class PLCTaskAction
			{
			private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);
			//服务运行状态
			public static bool boRunningState = false;
			//脱机模式
			public static bool boOffline = false;
			//自刷新
			public static bool boRefresh = false;

			private static List<WcsPlc> listPlc;
			private static List<WcsDevice> listPlcDevice;
			private static List<WcsPosition> listPlcStation;
			public static List<PlcPositionInfo> listPositionInfo = new List<PlcPositionInfo>();

			private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);
			private static readonly SysCacheService sysCacheService = App.GetRequiredService<SysCacheService>();
			private static readonly IHubContext<PlcHub, IPlcHub> _plcHubContext = App.GetService<IHubContext<PlcHub, IPlcHub>>();

			private static List<WcsPlc> listPlc = new List<WcsPlc>();
			private static List<WcsDevice> listPlcDevice = new List<WcsDevice>();
			private static List<WcsPosition> listPlcStation = new List<WcsPosition>();
			private static List<WcsAlarmInfo> listAlarmInfo = new List<WcsAlarmInfo>();

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

			private static CancellationTokenSource cts = new CancellationTokenSource();//取消线程标识
			//对外公布连接状态
			public static List<PLCUtil> listPlcConn
			{
			get { return listPlcUtil; }
			}
			public static event EventHandler DeviceValueChangeEvent;
			static PLCTaskAction()
			{
			//订阅事件
			DeviceValueChangeEvent += PLCService.OnChangeEvent;

			listPlc = _db.Queryable<WcsPlc>().ToList();
			listPlcDevice = _db.Queryable<WcsDevice>().ToList();
			listPlcStation = _db.Queryable<WcsPosition>().ToList();
			}
			/// <summary>
			/// 初始化PLC连接
			@@ -31,9 +45,10 @@
			if (listPlcUtil.Count != 0)
			{
			cts.Cancel();
			listPlc = _db.Queryable<WcsPlc>().ToList();
			listPlc = _db.Queryable<WcsPlc>().Where(s => s.Type == PLCTypeEnum.StackingMachine \|\| s.Type == PLCTypeEnum.ConveyorLine \|\| s.Type == PLCTypeEnum.BoxConveyorLine).ToList();
			listPlcDevice = _db.Queryable<WcsDevice>().ToList();
			listPlcStation = _db.Queryable<WcsPosition>().ToList();
			listAlarmInfo = _db.Queryable<WcsAlarmInfo>().ToList();
			//等待几秒钟，把已有线程取消掉再连接
			Thread.Sleep(5000);
			foreach (var modPlcUtil in listPlcUtil)
			@@ -48,7 +63,11 @@
			listPlcUtil.Add(plc);
			}
			cts = new CancellationTokenSource();
			boRunningState = true;
			StartRead();
			ConnectionStatus();
			StartWatchAlarm();
			StartWatchPosition();
			}
			/// <summary>
			/// 开启读取plc线程
			@@ -67,19 +86,21 @@
			{
			foreach (var modPlcUtil in listPlcUtil)
			{
			modPlcUtil.Close();
			if (modPlcUtil != null && modPlcUtil.Connected)
			modPlcUtil.Close();
			}
			throw new OperationCanceledException();
			break;
			//throw new OperationCanceledException();
			}
			try
			{
			var modPlcUtil = listPlcUtil.FirstOrDefault(s => s.PlcId == modPlc.Id);
			var modPlcUtil = listPlcUtil.FirstOrDefault(s => s != null && s.PlcId == modPlc.Id);
			if (modPlcUtil == null)
			{
			modPlcUtil = new PLCUtil(modPlc);
			listPlcUtil.Add(modPlcUtil);
			}
			var listDevice = listPlcDevice.Where(s => s.PlcId == _modplc.Id).ToList();
			var listDevice = listPlcDevice.Where(s => s.PlcId == _modplc.Id && s.DeviceType == DeviceTypeEnum.Business).ToList();
			//循环读设备
			foreach (var modDevice in listDevice.Where(s => s.Level == DeviceLevelEnum.DB))
			{
			@@ -94,9 +115,9 @@
			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();
			dto.listDevice = listDevice.Where(s => s.StationNum == modDevice.StationNum && s.Level == DeviceLevelEnum.Station).ToList();
			//这里触发值变更事件
			DeviceValueChangeEvent?.Invoke(dto, EventArgs.Empty);
			//DeviceValueChangeEvent?.Invoke(dto, EventArgs.Empty);
			}
			else
			{
			@@ -121,11 +142,230 @@
			}, cts.Token);
			}
			}

			/// <summary>
			/// 连接状态线程
			/// </summary>
			public static void ConnectionStatus()
			{
			Task.Run(() =>
			{
			try
			{
			while (true)
			{

			//取消线程关闭PLC连接
			if (cts.Token.IsCancellationRequested)
			{
			foreach (var modPlcUtil in listPlcUtil)
			{
			if (modPlcUtil != null && modPlcUtil.Connected)
			modPlcUtil.Close();
			}
			break;
			//throw new OperationCanceledException();
			}
			//获取每个PLC连接状态
			foreach (var modPlc in listPlc)
			{
			var modPlcUtil = listPlcUtil.FirstOrDefault(s => s.PlcId == modPlc.Id);
			if (modPlcUtil == null)
			modPlc.IsConn = false;
			else
			modPlc.IsConn = modPlcUtil.Connected;
			if (sysCacheService.ExistKey("PLCCONN" + modPlc.Id))
			{
			var cachePlc = sysCacheService.Get<WcsPlc>("PLCCONN" + modPlc.Id);
			if (cachePlc.IsConn != modPlc.IsConn)
			{
			//连接状态变更通知前端
			_plcHubContext.Clients.All.PublicPlcConn(modPlc);
			}
			}
			sysCacheService.Set("PLCCONN" + modPlc.Id, modPlc);
			}
			Thread.Sleep(1000);
			}
			}
			catch (OperationCanceledException)
			{
			sysCacheService.RemoveByPrefixKey("PLCCONN");
			Console.WriteLine("中止线程");
			}
			catch (Exception ex)
			{
			Log.Error(ex.Message, ex);
			}

			});

			}

			/// <summary>
			/// 开启报警监控
			/// </summary>
			public static void StartWatchAlarm()
			{
			Task.Run(() =>
			{
			var listPlc = listAlarmInfo.GroupBy(s => new { s.PlcIP, s.PlcPort }).ToList();
			List<PLCUtil> listPlcUtil = new List<PLCUtil>();
			int i = 0;
			foreach (var modPlc in listPlc)
			{
			listPlcUtil.Add(new PLCUtil(new WcsPlc() { Id = i++, IP = modPlc.Key.PlcIP, Port = modPlc.Key.PlcPort, PLCType = PLCEnum.S7_1500 }));
			}
			while (true)
			{
			//取消线程关闭PLC连接
			if (cts.Token.IsCancellationRequested)
			{
			foreach (var modPlcUtil in listPlcUtil)
			{
			if (modPlcUtil != null && modPlcUtil.Connected)
			modPlcUtil.Close();
			}
			break;
			//throw new OperationCanceledException();
			}
			foreach (var modUtil in listPlcUtil)
			{
			//报警点位
			var listAlarm = listAlarmInfo.Where(s => s.PlcIP == modUtil.PlcId.ToString());
			foreach (var modAlarm in listAlarm)
			{
			(var result, var value) = modUtil.GetPlcDBValue(PLCDataTypeEnum.Bit, modAlarm.AlarmCode, "");
			if (result.IsSucceed)
			{
			//假设不为0就算报警
			if (Convert.ToBoolean(value) && modAlarm.Status == YesNoEnum.N)
			{
			//修改报警状态同时记录报警日志
			modAlarm.AlarmTime = DateTime.Now;
			modAlarm.Status = YesNoEnum.Y;
			_db.Updateable(modAlarm).ExecuteCommand();
			WcsAlarmLog modLog = modAlarm.Adapt<WcsAlarmLog>();
			_db.Insertable(modLog).ExecuteCommand();
			//下发报警状态
			_plcHubContext.Clients.All.PublicAlarm(modAlarm.Adapt<WcsAlarmInfoOutput>());
			}
			//取消报警
			else if (Convert.ToBoolean(value) && modAlarm.Status == YesNoEnum.Y)
			{
			modAlarm.AlarmTime = null;
			modAlarm.Status = YesNoEnum.N;
			_db.Updateable(modAlarm).ExecuteCommand();
			}
			}
			}

			}
			Thread.Sleep(1000);
			}
			}, cts.Token);
			}
			/// <summary>
			/// 开启位置监控
			/// </summary>
			public static void StartWatchPosition()
			{
			Task.Run(() =>
			{
			while (true)
			{
			//取消线程关闭PLC连接
			if (cts.Token.IsCancellationRequested)
			{
			foreach (var modPlcUtil in listPlcUtil)
			{
			if (modPlcUtil != null && modPlcUtil.Connected)
			modPlcUtil.Close();
			}
			break;
			//throw new OperationCanceledException();
			}
			try
			{
			foreach (var modPlcUtil in listPlcUtil)
			{
			if (modPlcUtil == null)
			break;
			var listDevice = listPlcDevice.Where(s => s.PlcId == modPlcUtil.PlcId && s.DeviceType == DeviceTypeEnum.Show).ToList();
			foreach (var modDevice in listDevice)
			{
			var modPlc = listPlc.FirstOrDefault(s => s.Id == modDevice.PlcId);
			(var result, var value) = modPlcUtil.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.PlcPos);
			if (result.IsSucceed)
			{
			if (modPlc.Type == PLCTypeEnum.ConveyorLine)
			{
			//假设不为0就算有东西
			if (value != 0 && !modDevice.BoHaveItem)
			{
			modDevice.BoHaveItem = true;
			//下发状态
			var modInfo = new PlcPositionInfo() { StationNum = modDevice.StationNum, BoHaveItem = true };
			_plcHubContext.Clients.All.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			}
			else if (value == 0 && modDevice.BoHaveItem)
			{
			modDevice.BoHaveItem = false;
			//下发状态
			var modInfo = new PlcPositionInfo()
			{
			StationNum = modDevice.StationNum,
			BoHaveItem = false,
			Type = modPlc.Type,
			};
			_plcHubContext.Clients.All.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			}
			}
			else if (modPlc.Type == PLCTypeEnum.StackingMachine)
			{
			//todo:这里的高度可能需要前端展示值和plc的值进行一个换算
			var BoxHeight = Convert.ToInt32(value);
			if (value != 0 && modDevice.BoxHeight != BoxHeight)
			{
			modDevice.BoxHeight = BoxHeight;
			//下发状态
			var modInfo = new PlcPositionInfo() { StationNum = modDevice.StationNum, BoxHeight = BoxHeight };
			_plcHubContext.Clients.All.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			}
			}
			}

			}
			}
			}
			catch (Exception)
			{

			}
			}
			});
			}
			private static void UpdatePosition(PlcPositionInfo modInfo)
			{
			var modTemp = listPositionInfo.FirstOrDefault(s => s.StationNum == modInfo.StationNum);
			if (modTemp == null)
			{
			listPositionInfo.Add(modInfo);
			}
			else
			{
			modTemp.BoHaveItem = modInfo.BoHaveItem;
			}
			}
			/// <summary>
			/// 停止服务
			/// </summary>
			public static void Stop()
			{
			cts.Cancel();
			boRunningState = false;
			}
			}