WCSNet6.git - Gitblit

			@@ -2,6 +2,7 @@
			using DocumentFormat.OpenXml.Drawing;
			using Furion.Logging;
			using Microsoft.AspNetCore.SignalR;
			using System;

			namespace WCS.Application;
			public static class PLCTaskAction
			@@ -42,21 +43,18 @@
			/// </summary>
			public static void Init()
			{
			if (listPlcUtil.Count != 0)
			cts.Cancel();
			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)
			{
			cts.Cancel();
			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)
			{
			modPlcUtil.Close();
			}
			listPlcUtil.Clear();
			modPlcUtil.Close();
			}
			listPlcUtil.Clear();
			foreach (var modPlc in listPlc)
			{
			var plc = new PLCUtil(modPlc);
			@@ -74,6 +72,7 @@
			/// </summary>
			public static void StartRead()
			{
			Console.WriteLine("开启读取plc线程");
			foreach (var modPlc in listPlc)
			{
			Task.Run(() =>
			@@ -97,16 +96,33 @@
			var modPlcUtil = listPlcUtil.FirstOrDefault(s => s != null && s.PlcId == modPlc.Id);
			if (modPlcUtil == null)
			{
			Console.WriteLine($"连接plc{modPlc.IP}");
			modPlcUtil = new PLCUtil(modPlc);
			listPlcUtil.Add(modPlcUtil);
			if (modPlcUtil.Connected)
			Console.WriteLine($"连接plc{modPlc.IP}成功");
			}
			var listDevice = listPlcDevice.Where(s => s.PlcId == _modplc.Id && s.DeviceType == DeviceTypeEnum.Business).ToList();
			if (!modPlcUtil.Connected)
			{
			Thread.Sleep(10000);
			modPlcUtil.Open();
			continue;
			}
			var listDevice = listPlcDevice
			.Where(s => s.PlcId == _modplc.Id && s.DeviceType == DeviceTypeEnum.Business)
			.WhereIF(modPlc.Type == PLCTypeEnum.ConveyorLine, s => s.Level == DeviceLevelEnum.Station)
			.WhereIF(modPlc.Type == PLCTypeEnum.StackingMachine, s => s.Level == DeviceLevelEnum.DB)
			.ToList();

			//循环读设备
			foreach (var modDevice in listDevice.Where(s => s.Level == DeviceLevelEnum.DB))
			foreach (var modDevice in listDevice)
			{
			var (result, value) = modPlcUtil.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.PlcPos);
			//if (!result.IsSucceed)
			// Console.WriteLine($"{modPlc.IP}错误{modDevice.DbNumber}.{modDevice.PlcPos}："+result.Err);
			if (result.IsSucceed)
			{
			//Console.WriteLine($"{modPlc.IP}读取{modDevice.DbNumber}.{modDevice.PlcPos}的值为：{value}");
			//无流程跳出
			if (value == 0)
			continue;
			@@ -119,16 +135,17 @@
			//这里触发值变更事件
			//DeviceValueChangeEvent?.Invoke(dto, EventArgs.Empty);
			}
			else
			else if (!modPlcUtil.Connected)
			{
			//删除当前连接下一次循环重新连接
			Console.WriteLine("连接断开...");
			modPlcUtil.Close();
			listPlcUtil.Remove(modPlcUtil);
			//Console.WriteLine($"连接断开...{modPlc.IP}");
			//重新打开连接
			modPlcUtil.Open();
			//if (modPlcUtil.Connected)
			// Console.WriteLine($"重连成功...{modPlc.IP}");
			}
			}

			Thread.Sleep(3000);
			Thread.Sleep(10000);
			}
			catch (OperationCanceledException)
			{
			@@ -152,9 +169,9 @@
			{
			try
			{
			Console.WriteLine("连接状态线程");
			while (true)
			{

			//取消线程关闭PLC连接
			if (cts.Token.IsCancellationRequested)
			{
			@@ -174,16 +191,22 @@
			modPlc.IsConn = false;
			else
			modPlc.IsConn = modPlcUtil.Connected;
			if (sysCacheService.ExistKey("PLCCONN" + modPlc.Id))
			if (sysCacheService.ExistKey("PLCCONN:" + modPlc.Id))
			{
			var cachePlc = sysCacheService.Get<WcsPlc>("PLCCONN" + modPlc.Id);
			var cachePlc = sysCacheService.Get<WcsPlc>("PLCCONN:" + modPlc.Id);
			if (cachePlc.IsConn != modPlc.IsConn)
			{
			//连接状态变更通知前端
			Console.WriteLine($"通知前端变更{modPlc.Text} {modPlc.IsConn}");
			_plcHubContext.Clients.All.PublicPlcConn(modPlc);
			}
			sysCacheService.Set("PLCCONN:" + modPlc.Id, modPlc);
			}
			sysCacheService.Set("PLCCONN" + modPlc.Id, modPlc);
			else
			{
			sysCacheService.Set("PLCCONN:" + modPlc.Id, modPlc);
			_plcHubContext.Clients.All.PublicPlcConn(modPlc);
			}
			}
			Thread.Sleep(1000);
			}
			@@ -231,37 +254,67 @@
			}
			foreach (var modUtil in listPlcUtil)
			{
			//报警点位
			var listAlarm = listAlarmInfo.Where(s => s.PlcIP == modUtil.PlcId.ToString());
			foreach (var modAlarm in listAlarm)
			try
			{
			(var result, var value) = modUtil.GetPlcDBValue(PLCDataTypeEnum.Bit, modAlarm.AlarmCode, "");
			if (result.IsSucceed)
			//报警点位
			var listAlarm = listAlarmInfo.Where(s => s.PlcIP == modUtil.PlcIP.ToString()).ToList();
			Console.WriteLine("报警点位数：" + listAlarm.Count);
			var listaddress = new Dictionary<string, PLCDataTypeEnum>();
			foreach (var modAlarm in listAlarm)
			{
			//假设不为0就算报警
			if (Convert.ToBoolean(value) && modAlarm.Status == YesNoEnum.N)
			listaddress.Add(modAlarm.AlarmCode, PLCDataTypeEnum.Bit);
			break;
			}
			Console.WriteLine($"读取点位{listaddress.Count}个");
			var result = modUtil.GetPlcBatchDBValue(listaddress);
			Console.WriteLine("err" + result.Err);
			var listPulish = new List<WcsAlarmInfo>();
			//测试报警
			//foreach (var modAlarm in listAlarm)
			//{
			// result.Value.Add(modAlarm.AlarmCode, true);
			//}
			foreach (var item in result.Value)
			{
			var value = Convert.ToBoolean(item.Value);
			Console.WriteLine(item.Key + "+" + value);
			var modAlarm = listAlarm.FirstOrDefault(s => s.AlarmCode == item.Key);
			if (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>());
			listPulish.Add(modAlarm);
			}
			//取消报警
			else if (Convert.ToBoolean(value) && modAlarm.Status == YesNoEnum.Y)
			else if (value && modAlarm.Status == YesNoEnum.Y)
			{
			modAlarm.AlarmTime = null;
			modAlarm.Status = YesNoEnum.N;
			_db.Updateable(modAlarm).ExecuteCommand();
			listPulish.Add(modAlarm);
			}
			}
			if (listPulish.Count > 0)
			{
			_db.Updateable(listPulish).ExecuteCommand();
			var listLog = new List<WcsAlarmLog>();
			foreach (var mod in listPulish.Where(s => s.Status == YesNoEnum.Y))
			{
			WcsAlarmLog modLog = mod.Adapt<WcsAlarmLog>();
			modLog.Id = 0;
			listLog.Add(modLog);
			}
			_db.Insertable(listLog).ExecuteCommand();
			_plcHubContext.Clients.All.PublicAlarm(listPulish);
			}
			}
			catch (Exception ex)
			{
			Console.WriteLine(ex.Message);
			}

			}
			Thread.Sleep(1000);
			Thread.Sleep(10000);
			}
			}, cts.Token);
			}
			@@ -270,6 +323,7 @@
			/// </summary>
			public static void StartWatchPosition()
			{
			Console.WriteLine("开启位置监控");
			Task.Run(() =>
			{
			while (true)
			@@ -290,7 +344,7 @@
			foreach (var modPlcUtil in listPlcUtil)
			{
			if (modPlcUtil == null)
			break;
			continue;
			var listDevice = listPlcDevice.Where(s => s.PlcId == modPlcUtil.PlcId && s.DeviceType == DeviceTypeEnum.Show).ToList();
			foreach (var modDevice in listDevice)
			{