WCSNet6.git - Gitblit

			@@ -2,7 +2,9 @@
			using DocumentFormat.OpenXml.Drawing;
			using Furion.Logging;
			using Microsoft.AspNetCore.SignalR;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
			using System;
			//using WCS.Application.Util;

			namespace WCS.Application;
			public static class PLCTaskAction
			@@ -13,16 +15,24 @@
			public static bool boOffline = false;
			//自刷新
			public static bool boRefresh = false;
			//演示模式
			public static bool boDemo = false;
			//滚筒反转
			public static bool boDrumReversal = false;
			//出库锁定
			public static bool boOutLock = false;
			//入库锁定
			public static bool boEnterLock = false;

			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 readonly SysConfigService _sysConfigService = App.GetService<SysConfigService>();

			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<WcsPosition> listPlcPosition = new List<WcsPosition>();
			private static List<WcsAlarmInfo> listAlarmInfo = new List<WcsAlarmInfo>();

			private static List<PLCUtil> listPlcUtil = new List<PLCUtil>();
			@@ -32,24 +42,44 @@
			{
			get { return listPlcUtil; }
			}
			// 交互点集合
			public static List<WcsDevice> plcDevices
			{
			get { return listPlcDevice; }
			}
			public static List<WcsPosition> plcPositions
			{
			get { return listPlcPosition; }
			}
			public static event EventHandler DeviceValueChangeEvent;
			static PLCTaskAction()
			{
			//订阅事件
			DeviceValueChangeEvent += PLCService.OnChangeEvent;
			boRunningState = _sysConfigService.GetConfigValue<bool>("sys_RunningState").Result;
			boOffline = _sysConfigService.GetConfigValue<bool>("sys_Offline").Result;
			boRefresh = _sysConfigService.GetConfigValue<bool>("sys_Refresh").Result;
			boDemo = _sysConfigService.GetConfigValue<bool>("sys_demo").Result;
			boDrumReversal = _sysConfigService.GetConfigValue<bool>("sys_DrumReversal").Result;
			boOutLock = _sysConfigService.GetConfigValue<bool>("sys_BoOutLock").Result;
			boEnterLock = _sysConfigService.GetConfigValue<bool>("sys_BoEnterLock").Result;
			}
			/// <summary>
			/// 初始化PLC连接
			/// </summary>
			public static void Init()
			{
			// var strMsg = new HttpService().RequestPackWcs("LN000001");
			cts.Cancel();
			listPlc = _db.Queryable<WcsPlc>().Where(s => s.Type == PLCTypeEnum.StackingMachine \|\| s.Type == PLCTypeEnum.ConveyorLine \|\| s.Type == PLCTypeEnum.BoxConveyorLine).ToList();
			listPlc = _db.Queryable<WcsPlc>()
			.Where(s => s.Type == PLCTypeEnum.StackingMachine \|\| s.Type == PLCTypeEnum.ConveyorLine \|\| s.Type == PLCTypeEnum.BoxConveyorLine \|\| s.Type == PLCTypeEnum.StackingRobot)
			.Where(s => s.Enable == YesNoEnum.Y)
			.ToList();
			listPlcDevice = _db.Queryable<WcsDevice>().ToList();
			listPlcStation = _db.Queryable<WcsPosition>().ToList();
			listPlcPosition = _db.Queryable<WcsPosition>().ToList();
			listAlarmInfo = _db.Queryable<WcsAlarmInfo>().ToList();
			//等待几秒钟，把已有线程取消掉再连接
			Thread.Sleep(5000);
			//Thread.Sleep(5000);
			foreach (var modPlcUtil in listPlcUtil)
			{
			modPlcUtil.Close();
			@@ -60,12 +90,20 @@
			var plc = new PLCUtil(modPlc);
			listPlcUtil.Add(plc);
			}
			cts = new CancellationTokenSource();
			boRunningState = true;
			StartRead();
			ConnectionStatus();
			StartWatchAlarm();
			StartWatchPosition();
			HubUtil.UpdateService(new PLCServiceModel()
			{
			BoRunningState = boRunningState,
			BoOffline = boOffline,
			BoRefresh = boRefresh
			});
			if (boRunningState)
			{
			cts = new CancellationTokenSource();
			StartRead();
			ConnectionStatus();
			StartWatchAlarm();
			StartWatchPosition();
			}
			}
			/// <summary>
			/// 开启读取plc线程
			@@ -104,7 +142,7 @@
			}
			if (!modPlcUtil.Connected)
			{
			Thread.Sleep(10000);
			Thread.Sleep(1000);
			modPlcUtil.Open();
			continue;
			}
			@@ -124,16 +162,16 @@
			{
			//Console.WriteLine($"{modPlc.IP}读取{modDevice.DbNumber}.{modDevice.PlcPos}的值为：{value}");
			//无流程跳出
			if (value == 0)
			if (value == 0)// && modPlc.Type!= PLCTypeEnum.BoxConveyorLine
			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.listStation = listPlcPosition.Where(s => s.DeviceId == modDevice.Id).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 if (!modPlcUtil.Connected)
			{
			@@ -145,7 +183,7 @@
			}
			}

			Thread.Sleep(10000);
			Thread.Sleep(1000);
			}
			catch (OperationCanceledException)
			{
			@@ -153,7 +191,7 @@
			}
			catch (Exception ex)
			{
			Log.Error(ex.Message, ex);
			Log.Error("读取PLC线程发生异常", ex);
			}
			}
			}, cts.Token);
			@@ -198,17 +236,17 @@
			{
			//连接状态变更通知前端
			Console.WriteLine($"通知前端变更{modPlc.Text} {modPlc.IsConn}");
			_plcHubContext.Clients.All.PublicPlcConn(modPlc);
			HubUtil.PublicPlcConn(modPlc);
			}
			sysCacheService.Set("PLCCONN:" + modPlc.Id, modPlc);
			}
			else
			{
			sysCacheService.Set("PLCCONN:" + modPlc.Id, modPlc);
			_plcHubContext.Clients.All.PublicPlcConn(modPlc);
			HubUtil.PublicPlcConn(modPlc);
			}
			}
			Thread.Sleep(1000);
			Thread.Sleep(10000);
			}
			}
			catch (OperationCanceledException)
			@@ -218,10 +256,10 @@
			}
			catch (Exception ex)
			{
			Log.Error(ex.Message, ex);
			Log.Error("连接状态线程发生异常", ex);
			}

			});
			}, cts.Token);

			}

			@@ -258,27 +296,18 @@
			{
			//报警点位
			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)
			{
			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);
			var stationNum = modAlarm.StationNum;
			if (value && modAlarm.Status == YesNoEnum.N)
			{
			//修改报警状态同时记录报警日志
			@@ -287,7 +316,7 @@
			listPulish.Add(modAlarm);
			}
			//取消报警
			else if (value && modAlarm.Status == YesNoEnum.Y)
			else if (!value && modAlarm.Status == YesNoEnum.Y)
			{
			modAlarm.AlarmTime = null;
			modAlarm.Status = YesNoEnum.N;
			@@ -304,13 +333,14 @@
			modLog.Id = 0;
			listLog.Add(modLog);
			}
			_db.Insertable(listLog).ExecuteCommand();
			_plcHubContext.Clients.All.PublicAlarm(listPulish);
			if (listLog.Count >= 0)
			_db.Insertable(listLog).ExecuteCommand();
			HubUtil.PublicAlarm(listPulish);
			}
			}
			catch (Exception ex)
			{
			Console.WriteLine(ex.Message);
			Log.Error("报警监控发生异常", ex);
			}

			}
			@@ -345,66 +375,98 @@
			{
			if (modPlcUtil == null)
			continue;
			var plcIp = modPlcUtil.PlcIP;
			var listDevice = listPlcDevice.Where(s => s.PlcId == modPlcUtil.PlcId && s.DeviceType == DeviceTypeEnum.Show).ToList();
			var modPlc = listPlc.FirstOrDefault(s => s.Id == modPlcUtil.PlcId);
			var listaddress = new Dictionary<string, PLCDataTypeEnum>();
			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)
			listaddress.Add(modDevice.DbNumber + "." + modDevice.PlcPos, modDevice.PosType);
			}
			//批量读
			var result = modPlcUtil.GetPlcBatchDBValue(listaddress);
			//测试用
			//foreach (var modDevice in listDevice)
			//{
			// if (modPlc.Type == PLCTypeEnum.StackingMachine)
			// result.Value.Add(modDevice.DbNumber + "." + modDevice.PlcPos, new Random().Next(790000));
			// else if (modPlc.Type == PLCTypeEnum.ConveyorLine)
			// result.Value.Add(modDevice.DbNumber + "." + modDevice.PlcPos, new Random().Next(2) == 0);
			//}
			foreach (var item in result.Value)
			{
			var modDevice = listDevice.FirstOrDefault(s => item.Key == (s.DbNumber + "." + s.PlcPos));
			if (modDevice == null)
			continue;
			switch (modPlc.Type)
			{
			if (modPlc.Type == PLCTypeEnum.ConveyorLine)
			{
			//假设不为0就算有东西
			if (value != 0 && !modDevice.BoHaveItem)
			case PLCTypeEnum.StackingMachine:
			{
			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()
			var value = Convert.ToInt32(item.Value);
			var height = Math.Round(value / 790000d * 200).ToInt();
			var modPosition = listPlcPosition.FirstOrDefault(s => s.DeviceId == modDevice.Id && s.Text == "目的工位");
			string EndLocat = "";
			if (modPosition != null)
			{
			StationNum = modDevice.StationNum,
			BoHaveItem = false,
			Type = modPlc.Type,
			};
			_plcHubContext.Clients.All.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			var (result2, value2) = modPlcUtil.GetPlcDBValue(modPosition.PosType, modDevice.DbNumber, modPosition.PlcPos);
			if (result2.IsSucceed)
			EndLocat = Convert.ToString(value2);
			}
			if (modDevice.BoxHeight != height \|\| modDevice.EndLocat != EndLocat)
			{
			modDevice.EndLocat = EndLocat;
			modDevice.BoxHeight = Math.Round(value / 790000d * 200).ToInt();
			var modInfo = new PlcPositionInfo()
			{
			Type = modPlc.Type,
			StationNum = modDevice.StationNum,
			BoxHeight = modDevice.BoxHeight,
			EndLocat = EndLocat,
			};
			HubUtil.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			}
			}
			}
			else if (modPlc.Type == PLCTypeEnum.StackingMachine)
			{
			//todo:这里的高度可能需要前端展示值和plc的值进行一个换算
			var BoxHeight = Convert.ToInt32(value);
			if (value != 0 && modDevice.BoxHeight != BoxHeight)
			break;
			case PLCTypeEnum.ConveyorLine:
			{
			modDevice.BoxHeight = BoxHeight;
			//下发状态
			var modInfo = new PlcPositionInfo() { StationNum = modDevice.StationNum, BoxHeight = BoxHeight };
			_plcHubContext.Clients.All.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			}
			}
			}
			var bl = false;
			int value = Convert.ToInt32(item.Value);
			if (value <= 30)
			{
			bl = false;
			}
			else
			{
			bl = true;
			}

			if (bl != modDevice.BoHaveItem)
			{
			modDevice.BoHaveItem = bl;
			var modInfo = new PlcPositionInfo() { Type = modPlc.Type, StationNum = modDevice.StationNum.PadLeft(3, '0'), BoHaveItem = bl };
			HubUtil.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			}
			}
			break;
			default:
			break;
			}
			}
			}
			Thread.Sleep(3000);
			}
			catch (Exception)
			catch (Exception ex)
			{

			Log.Error("位置监控发生异常", ex);
			}
			}
			});
			}
			private static void UpdatePosition(PlcPositionInfo modInfo)
			{
			var modTemp = listPositionInfo.FirstOrDefault(s => s.StationNum == modInfo.StationNum);
			var modTemp = listPositionInfo.FirstOrDefault(s => s.StationNum == modInfo.StationNum && modInfo.Type == s.Type);
			if (modTemp == null)
			{
			listPositionInfo.Add(modInfo);