| New file |
| | |
|---|
| | | using Admin.NET.Core.Service; |
|---|
| | | using DocumentFormat.OpenXml.Office2010.ExcelAc; |
|---|
| | | using Furion.InstantMessaging; |
|---|
| | | using Microsoft.AspNetCore.SignalR; |
|---|
| | | using System; |
|---|
| | | using System.Collections.Generic; |
|---|
| | | using System.Linq; |
|---|
| | | using System.Text; |
|---|
| | | using System.Threading.Tasks; |
|---|
| | | |
|---|
| | | namespace WCS.Application; |
|---|
| | | |
|---|
| | | /// <summary> |
|---|
| | | /// 任务日志集线器 |
|---|
| | | /// </summary> |
|---|
| | | [MapHub("/hubs/PlcDevice")] |
|---|
| | | public class PlcDeviceHub : Hub<IPlcDeviceHub> |
|---|
| | | { |
|---|
| | | private static readonly IHubContext<PlcDeviceHub, IPlcDeviceHub> _plcDeviceHubContext = App.GetService<IHubContext<PlcDeviceHub, IPlcDeviceHub>>(); |
|---|
| | | private static readonly SysCacheService _sysCacheService = App.GetRequiredService<SysCacheService>(); |
|---|
| | | private static bool boRunningState = false; |
|---|
| | | private static CancellationTokenSource cts;//取消线程标识 |
|---|
| | | private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId); |
|---|
| | | public PlcDeviceHub() |
|---|
| | | { |
|---|
| | | } |
|---|
| | | |
|---|
| | | /// <summary> |
|---|
| | | /// 连接 |
|---|
| | | /// </summary> |
|---|
| | | /// <returns></returns> |
|---|
| | | public override async Task OnConnectedAsync() |
|---|
| | | { |
|---|
| | | var httpContext = Context.GetHttpContext(); |
|---|
| | | var userId = (httpContext.User.FindFirst(ClaimConst.UserId)?.Value).ToLong(); |
|---|
| | | _sysCacheService.Set("PlcDeviceHub:" + Context.ConnectionId, userId); |
|---|
| | | if (!boRunningState) |
|---|
| | | { |
|---|
| | | //开启读取服务线程 |
|---|
| | | boRunningState = true; |
|---|
| | | cts = new CancellationTokenSource();//取消线程标识 |
|---|
| | | StartRead(); |
|---|
| | | } |
|---|
| | | await base.OnConnectedAsync(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /// <summary> |
|---|
| | | /// 断开 |
|---|
| | | /// </summary> |
|---|
| | | /// <param name="exception"></param> |
|---|
| | | /// <returns></returns> |
|---|
| | | public override async Task OnDisconnectedAsync(Exception exception) |
|---|
| | | { |
|---|
| | | _sysCacheService.Remove("PlcDeviceHub:" + Context.ConnectionId); |
|---|
| | | //如果没有连接了 就关闭线程不读了 |
|---|
| | | if (_sysCacheService.GetKeysByPrefixKey("PlcDeviceHub").Count == 0) |
|---|
| | | { |
|---|
| | | cts.Cancel(); |
|---|
| | | boRunningState = false; |
|---|
| | | } |
|---|
| | | await base.OnDisconnectedAsync(exception); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /// <summary> |
|---|
| | | /// 开启读取plc线程 |
|---|
| | | /// </summary> |
|---|
| | | public static void StartRead() |
|---|
| | | { |
|---|
| | | Task.Run(() => |
|---|
| | | { |
|---|
| | | // 用于保存每个设备的初始状态 |
|---|
| | | var initialStates = new Dictionary<long, WcsDeviceOutput>(); |
|---|
| | | |
|---|
| | | var listPlc = _db.Queryable<WcsPlc>().Where(s => s.Type == PLCTypeEnum.StackingMachine || s.Type == PLCTypeEnum.ConveyorLine).ToList(); |
|---|
| | | var listPlcId = listPlc.Select(s => s.Id).ToList(); |
|---|
| | | var listPlcDevice = _db.Queryable<WcsDevice>().Where(s => s.DeviceType == DeviceTypeEnum.Business && listPlcId.Contains(s.PlcId)).Select<WcsDeviceOutput>().ToList(); |
|---|
| | | var listPlcDeviceId = listPlcDevice.Select(s => s.Id).ToList(); |
|---|
| | | var listPlcStation = _db.Queryable<WcsPosition>().Where(s => listPlcDeviceId.Contains(s.DeviceId)).ToList(); |
|---|
| | | while (true) |
|---|
| | | { |
|---|
| | | try |
|---|
| | | { |
|---|
| | | //获取跺机的状态 |
|---|
| | | foreach (var modDevice in listPlcDevice) |
|---|
| | | { |
|---|
| | | //取消线程 |
|---|
| | | if (cts.Token.IsCancellationRequested) |
|---|
| | | { |
|---|
| | | throw new OperationCanceledException(); |
|---|
| | | } |
|---|
| | | var modPlc = listPlc.Where(s => s.Id == modDevice.PlcId).FirstOrDefault(); |
|---|
| | | modDevice.Type = modPlc.Type; |
|---|
| | | //读取plc的值 |
|---|
| | | var modConn = PLCTaskAction.listPlcConn.FirstOrDefault(s => s != null && s.PlcId == modDevice.PlcId); |
|---|
| | | if (modConn == null) |
|---|
| | | { |
|---|
| | | modDevice.Status = false; |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | else |
|---|
| | | { |
|---|
| | | modDevice.Status = modConn.Connected; |
|---|
| | | } |
|---|
| | | if (modConn.Connected) |
|---|
| | | { |
|---|
| | | var listPosition = listPlcStation.Where(s => s.DeviceId == modDevice.Id).ToList(); |
|---|
| | | (var result, var plc) = modConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.PlcPos); |
|---|
| | | modDevice.Plc = Convert.ToString(plc); |
|---|
| | | (result, var wcs) = modConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos); |
|---|
| | | modDevice.Wcs = Convert.ToString(wcs); |
|---|
| | | //任务号 |
|---|
| | | var modPositionTask = listPosition.FirstOrDefault(s => s.Text == "任务号"); |
|---|
| | | (result, var taskNo) = modConn.GetPlcDBValue(modPositionTask.PosType, modDevice.DbNumber, modPositionTask.PlcPos, modPositionTask.StringLength); |
|---|
| | | modDevice.TaskNo = Convert.ToString(taskNo); |
|---|
| | | //任务类型 |
|---|
| | | var modPositionTaskType = listPosition.FirstOrDefault(s => s.Text == "任务类型"); |
|---|
| | | (result, var taskType) = modConn.GetPlcDBValue(modPositionTaskType.PosType, modDevice.DbNumber, modPositionTaskType.PlcPos); |
|---|
| | | modDevice.TaskType = (TaskTypeEnum)Convert.ToInt32(taskType); |
|---|
| | | //起始工位 |
|---|
| | | var modPositionStartLocatNo = listPosition.FirstOrDefault(s => s.Text == "起始工位"); |
|---|
| | | (result, var startLocatNo) = modConn.GetPlcDBValue(modPositionStartLocatNo.PosType, modDevice.DbNumber, modPositionStartLocatNo.PlcPos); |
|---|
| | | modDevice.StartLocatNo = Convert.ToString(startLocatNo); |
|---|
| | | //目的工位 |
|---|
| | | var modPositionEndLocatNo = listPosition.FirstOrDefault(s => s.Text == "目的工位"); |
|---|
| | | (result, var endLocatNo) = modConn.GetPlcDBValue(modPositionEndLocatNo.PosType, modDevice.DbNumber, modPositionEndLocatNo.PlcPos); |
|---|
| | | modDevice.EndLocatNo = Convert.ToString(endLocatNo); |
|---|
| | | //托盘码 |
|---|
| | | var modPositionPalletNo = listPosition.FirstOrDefault(s => s.Text == "托盘码"); |
|---|
| | | (result, var palletNo) = modConn.GetPlcDBValue(modPositionPalletNo.PosType, modDevice.DbNumber, modPositionPalletNo.PlcPos, modPositionPalletNo.StringLength); |
|---|
| | | modDevice.PalletNo = Convert.ToString(palletNo); |
|---|
| | | if (modPlc.Type == PLCTypeEnum.ConveyorLine) |
|---|
| | | { |
|---|
| | | //放货排 |
|---|
| | | var modPositionReleaseRow = listPosition.FirstOrDefault(s => s.Text == "放货排"); |
|---|
| | | (result, var releaseRow) = modConn.GetPlcDBValue(modPositionReleaseRow.PosType, modDevice.DbNumber, modPositionReleaseRow.PlcPos); |
|---|
| | | modDevice.ReleaseRow = Convert.ToInt32(releaseRow); |
|---|
| | | //放货列 |
|---|
| | | var modPositionReleaseCol = listPosition.FirstOrDefault(s => s.Text == "放货列"); |
|---|
| | | (result, var releaseCol) = modConn.GetPlcDBValue(modPositionReleaseCol.PosType, modDevice.DbNumber, modPositionReleaseCol.PlcPos); |
|---|
| | | modDevice.ReleaseCol = Convert.ToInt32(releaseCol); |
|---|
| | | //放货层 |
|---|
| | | var modPositionReleaseStorey = listPosition.FirstOrDefault(s => s.Text == "放货层"); |
|---|
| | | (result, var releaseStorey) = modConn.GetPlcDBValue(modPositionReleaseStorey.PosType, modDevice.DbNumber, modPositionReleaseStorey.PlcPos); |
|---|
| | | modDevice.ReleaseStorey = Convert.ToInt32(releaseStorey); |
|---|
| | | //取货排 |
|---|
| | | var modPositionPickRow = listPosition.FirstOrDefault(s => s.Text == "取货排"); |
|---|
| | | (result, var pickRow) = modConn.GetPlcDBValue(modPositionPickRow.PosType, modDevice.DbNumber, modPositionPickRow.PlcPos); |
|---|
| | | modDevice.PickRow = Convert.ToInt32(pickRow); |
|---|
| | | //取货列 |
|---|
| | | var modPositionPickCol = listPosition.FirstOrDefault(s => s.Text == "取货列"); |
|---|
| | | (result, var pickCol) = modConn.GetPlcDBValue(modPositionPickCol.PosType, modDevice.DbNumber, modPositionPickCol.PlcPos); |
|---|
| | | modDevice.PickCol = Convert.ToInt32(pickCol); |
|---|
| | | //取货层 |
|---|
| | | var modPositionPickStorey = listPosition.FirstOrDefault(s => s.Text == "取货层"); |
|---|
| | | (result, var pickStorey) = modConn.GetPlcDBValue(modPositionPickStorey.PosType, modDevice.DbNumber, modPositionPickStorey.PlcPos); |
|---|
| | | modDevice.PickStorey = Convert.ToInt32(pickStorey); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //else |
|---|
| | | //{ |
|---|
| | | // //测试 |
|---|
| | | // modDevice.TaskNo = "TK00001"; |
|---|
| | | // modDevice.TaskType = TaskTypeEnum.In; |
|---|
| | | // modDevice.Wcs = new Random().Next(1000).ToString(); |
|---|
| | | // modDevice.Plc = new Random().Next(1000).ToString(); |
|---|
| | | // modDevice.Status = true; |
|---|
| | | //} |
|---|
| | | // 比较之前的状态 |
|---|
| | | if (initialStates.TryGetValue(modDevice.Id, out var initialState)) |
|---|
| | | { |
|---|
| | | if (modDevice.Status != initialState.Status || |
|---|
| | | modDevice.Plc != initialState.Plc || |
|---|
| | | modDevice.Wcs != initialState.Wcs || |
|---|
| | | modDevice.TaskNo != initialState.TaskNo || |
|---|
| | | modDevice.TaskType != initialState.TaskType || |
|---|
| | | modDevice.StartLocatNo != initialState.StartLocatNo || |
|---|
| | | modDevice.EndLocatNo != initialState.EndLocatNo || |
|---|
| | | modDevice.PalletNo != initialState.PalletNo || |
|---|
| | | (modPlc.Type == PLCTypeEnum.ConveyorLine && |
|---|
| | | (modDevice.ReleaseRow != initialState.ReleaseRow || |
|---|
| | | modDevice.ReleaseCol != initialState.ReleaseCol || |
|---|
| | | modDevice.ReleaseStorey != initialState.ReleaseStorey || |
|---|
| | | modDevice.PickRow != initialState.PickRow || |
|---|
| | | modDevice.PickCol != initialState.PickCol || |
|---|
| | | modDevice.PickStorey != initialState.PickStorey))) |
|---|
| | | { |
|---|
| | | // 通知用户变更 |
|---|
| | | _plcDeviceHubContext.Clients.All.PublicPlcDevice(modDevice); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | initialStates[modDevice.Id] = modDevice.Adapt<WcsDeviceOutput>(); |
|---|
| | | } |
|---|
| | | Thread.Sleep(2000); |
|---|
| | | } |
|---|
| | | catch (OperationCanceledException) |
|---|
| | | { |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | catch (Exception) |
|---|
| | | { |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }, cts.Token); |
|---|
| | | } |
|---|
| | | } |
|---|
