WCSNet6.git - Gitblit

			@@ -13,17 +13,18 @@
			public static bool boOffline = false;
			//自刷新
			public static bool boRefresh = false;
			//演示模式
			public static bool boDemo = 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>();
			@@ -33,6 +34,15 @@
			{
			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()
			{
			@@ -41,6 +51,7 @@
			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;
			}
			/// <summary>
			/// 初始化PLC连接
			@@ -48,9 +59,12 @@
			public static void Init()
			{
			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)
			.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);
			@@ -64,7 +78,7 @@
			var plc = new PLCUtil(modPlc);
			listPlcUtil.Add(plc);
			}
			_plcHubContext.Clients.All.UpdateService(new PLCServiceModel()
			HubUtil.UpdateService(new PLCServiceModel()
			{
			BoRunningState = boRunningState,
			BoOffline = boOffline,
			@@ -142,10 +156,10 @@
			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)
			{
			@@ -210,14 +224,14 @@
			{
			//连接状态变更通知前端
			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);
			@@ -270,15 +284,15 @@
			{
			//报警点位
			var listAlarm = listAlarmInfo.Where(s => s.PlcIP == modUtil.PlcIP.ToString()).ToList();
			Console.WriteLine("报警点位数：" + listAlarm.Count);
			//Console.WriteLine("报警点位数：" + listAlarm.Count);
			var listaddress = new Dictionary<string, PLCDataTypeEnum>();
			foreach (var modAlarm in listAlarm)
			{
			listaddress.Add(modAlarm.AlarmCode, PLCDataTypeEnum.Bit);
			}
			Console.WriteLine($"读取点位{listaddress.Count}个");
			//Console.WriteLine($"读取点位{listaddress.Count}个");
			var result = modUtil.GetPlcBatchDBValue(listaddress);
			Console.WriteLine("err" + result.Err);
			//Console.WriteLine("err" + result.Err);
			var listPulish = new List<WcsAlarmInfo>();
			//测试报警
			//foreach (var modAlarm in listAlarm)
			@@ -288,7 +302,7 @@
			foreach (var item in result.Value)
			{
			var value = Convert.ToBoolean(item.Value);
			Console.WriteLine(item.Key + "+" + value);
			//Console.WriteLine(item.Key + "+" + value);
			var modAlarm = listAlarm.FirstOrDefault(s => s.AlarmCode == item.Key);
			if (value && modAlarm.Status == YesNoEnum.N)
			{
			@@ -316,7 +330,7 @@
			listLog.Add(modLog);
			}
			_db.Insertable(listLog).ExecuteCommand();
			_plcHubContext.Clients.All.PublicAlarm(listPulish);
			HubUtil.PublicAlarm(listPulish);
			}
			}
			catch (Exception ex)
			@@ -392,7 +406,7 @@
			StationNum = modDevice.StationNum,
			BoxHeight = modDevice.BoxHeight
			};
			_plcHubContext.Clients.All.PublicPosition(modInfo);
			HubUtil.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			}
			}
			@@ -405,7 +419,7 @@
			modDevice.BoHaveItem = value;
			//下发状态
			var modInfo = new PlcPositionInfo() { Type = modPlc.Type, StationNum = modDevice.StationNum, BoHaveItem = value };
			_plcHubContext.Clients.All.PublicPosition(modInfo);
			HubUtil.PublicPosition(modInfo);
			UpdatePosition(modInfo);
			}
			}
			@@ -415,7 +429,7 @@
			}
			}
			}
			Thread.Sleep(1000);
			Thread.Sleep(300);
			}
			catch (Exception ex)
			{