From 6b68425fc633b7d0daee7a43806ee7498998a40f Mon Sep 17 00:00:00 2001 From: wxw <Administrator@DESKTOP-5BIMHQ3> Date: 星期三, 11 九月 2024 14:44:14 +0800 Subject: [PATCH] Merge branch 'master' into wxw --- Admin.NET/WCS.Application/PLC/PLCService.cs | 462 ++++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 436 insertions(+), 26 deletions(-) diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs index b9af4a9..15c6b70 100644 --- a/Admin.NET/WCS.Application/PLC/PLCService.cs +++ b/Admin.NET/WCS.Application/PLC/PLCService.cs @@ -1,60 +1,470 @@ 锘� +using DocumentFormat.OpenXml.Bibliography; +using Elastic.Clients.Elasticsearch.Tasks; +using Furion.Logging; using IoTClient; +using Microsoft.AspNetCore.SignalR; +using RazorEngine.Compilation.ImpromptuInterface.Dynamic; +using SKIT.FlurlHttpClient.Wechat.TenpayV3.ExtendedSDK.Global.Models; +using System.Data; namespace WCS.Application; public static class PLCService { + private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId); + private static readonly IHubContext<TaskLogHub, ITaskLogHub> _taskLogHubContext; + + static PLCService() + { + _taskLogHubContext = App.GetService<IHubContext<TaskLogHub, ITaskLogHub>>(); + } public static void OnChangeEvent(object sender, EventArgs e) { - var mod = sender as WcsDeviceDto; - Console.WriteLine("PLC鍊间负" + mod.Value); - switch (mod.Type) + try { - case PLCTypeEnum.StackingMachine: - if (mod.Value == 820) + var mod = sender as WcsDeviceDto; + Console.WriteLine("PLC鍊间负" + mod.Value); + switch (mod.Type) + { + case PLCTypeEnum.StackingMachine: + StackingMachine(mod); + break; + case PLCTypeEnum.ConveyorLine: + ConveyorLine(mod); + break; + case PLCTypeEnum.AGV: + AGV(mod); + break; + case PLCTypeEnum.PalletMachine: + PalletMachine(mod); + break; + default: + break; + } + } + catch (Exception ex) + { + Log.Error(ex.Message, ex); + } + } + /// <summary> + /// 璺烘満涓氬姟澶勭悊 + /// </summary> + /// <param name="modDevice"></param> + private static async void StackingMachine(WcsDeviceDto modDevice) + { + var plcConn = modDevice.PLCUtil; + switch (modDevice.Value.ToString()) + { + case "820": + // 璺烘満绌洪棽锛岃幏鍙栧嚭搴撲换鍔°�佺Щ搴撲换鍔� { - //娴嬭瘯鍐欏叆830 - var result = mod.PLCUtil.SetPlcDBValue(mod.PosType.Value, mod.DbNumber, mod.PlcPos, "830"); - //鍐欏叆鏄惁鎴愬姛 - if (result.IsSucceed) + // 鑾峰彇浠诲姟淇℃伅 + var modTask = _db.Queryable<WcsTask>().OrderBy(m=>m.CreateTime).OrderBy(m=>m.Levels,OrderByType.Desc) + .First(s => s.Status == TaskStatusEnum.Wait && (s.TaskType == TaskTypeEnum.Out || s.TaskType == TaskTypeEnum.Move) + && s.StartRoadway == modDevice.StationNum); + if (modTask == null) { + break; + } + // 鏍规嵁鐩爣鍦板潃鍜屽贩閬撹幏鍙栨斁璐у伐浣嶅搴旂殑鎺掑垪灞� + PlcTaskInfo taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, modTask.TaskType.ToString(), + modTask.StartRoadway, modTask.EndRoadway); + + // 鐩爣宸ヤ綅涓嶄负null锛岄渶鍏堝垽鏂斁璐у伐浣嶆槸鍚︾┖闂� + if (!string.IsNullOrEmpty(taskInfo.EndStation)) + { + // 鎵撳紑瀵瑰簲鐨勮緭閫佺嚎杩炴帴 + var plcConveyorConn = PLCTaskAction.listPlcConn.First(m => m.PlcIP == taskInfo.Ip); + if (plcConveyorConn.Connected) + { + // 鑾峰彇鏀捐揣宸ヤ綅閰嶇疆淇℃伅 + var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == taskInfo.EndStation + && m.DeviceType == DeviceTypeEnum.Business); + + var (result, value) = plcConveyorConn.GetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.PlcPos); + if (result.IsSucceed) + { + if (value.ToString() != "720") // 720:鏀捐揣绌轰綅绌洪棽锛屽彲鏀捐揣 + { + Log.Error(string.Format("浠诲姟鍙�:{0}:鏀捐揣宸ヤ綅鍗犵敤锛岀◢鍚庢墽琛屻��", modTask.TaskNo)); + break; + } + } + else + { + break; + } + } + else + { + break; + } + } + + // 鑾峰彇杞崲鍚庣殑璧峰鎺掑垪灞� + PlcTaskInfo startTaskInfo = PLCCommon.GetEndPai(modTask.StartLocate.Substring(1, 2), + modTask.StartLocate.Substring(0, 2), modTask.StartLocate.Substring(4, 2), + modTask.StartLocate.Substring(6, 2)); + + // 缁橮LC鍐欏叆浠诲姟鏁版嵁 + var listResult = new List<Result>(); + // 浠诲姟鍙锋墭鐩樺彿 + var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "浠诲姟鍙�"); + listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo)); + var modPosPalletNo = modDevice.listStation.FirstOrDefault(s => s.Text == "鎵樼洏鐮�"); + listResult.Add(plcConn.SetPlcDBValue(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo)); + // 璧峰鎺掑垪灞� + var modPosRow = modDevice.listStation.FirstOrDefault(s => s.Text == "鍙栬揣鎺�"); + listResult.Add(plcConn.SetPlcDBValue(modPosRow.PosType, modDevice.DbNumber, modPosRow.PlcPos, startTaskInfo.EndPai)); + var modPosColumn = modDevice.listStation.FirstOrDefault(s => s.Text == "鍙栬揣鍒�"); + listResult.Add(plcConn.SetPlcDBValue(modPosColumn.PosType, modDevice.DbNumber, modPosColumn.PlcPos, startTaskInfo.EndLie)); + var modPosStorey = modDevice.listStation.FirstOrDefault(s => s.Text == "鍙栬揣灞�"); + listResult.Add(plcConn.SetPlcDBValue(modPosStorey.PosType, modDevice.DbNumber, modPosStorey.PlcPos, startTaskInfo.EndCeng)); + // 鐩爣鏀捐揣宸ヤ綅(鍥哄畾鎺掑垪灞�) + var modPosEndRow = modDevice.listStation.FirstOrDefault(s => s.Text == "鏀捐揣鎺�"); + listResult.Add(plcConn.SetPlcDBValue(modPosEndRow.PosType, modDevice.DbNumber, modPosEndRow.PlcPos, taskInfo.EndPai)); + var modPosEndColumn = modDevice.listStation.FirstOrDefault(s => s.Text == "鏀捐揣鍒�"); + listResult.Add(plcConn.SetPlcDBValue(modPosEndColumn.PosType, modDevice.DbNumber, modPosEndColumn.PlcPos, taskInfo.EndLie)); + var modPosEndStorey = modDevice.listStation.FirstOrDefault(s => s.Text == "鏀捐揣灞�"); + listResult.Add(plcConn.SetPlcDBValue(modPosEndStorey.PosType, modDevice.DbNumber, modPosEndStorey.PlcPos, taskInfo.EndCeng)); + + // 鏄惁鍐欏叆鎴愬姛 + if (listResult.All(s => s.IsSucceed)) + { + // 鍐欏叆璺烘満浠诲姟涓嬪彂瀹屾垚 + plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "830"); + + // 灏嗙Щ搴撲换鍔″緟鎵ц鏀逛负姝e湪鎵ц + _db.Updateable<WcsTask>() + .SetColumns(s => s.Status == TaskStatusEnum.Doing) + .Where(s => s.Id == modTask.Id) + .ExecuteCommand(); + + WcsTaskMonitor modInsertTaskMonitor; + if (string.IsNullOrEmpty(taskInfo.EndStation)) + { + // 鍚屽贩閬撶Щ搴� + modInsertTaskMonitor = new WcsTaskMonitor() + { + TaskNo = modTask.TaskNo, + PlcId = modDevice.Id, + PlcName = modDevice.Text, + InteractiveMsg = $"鍐欏叆鎸囦护锛歿modTask.StartLocate}鍌ㄤ綅====銆媨modTask.EndLocate}鍌ㄤ綅銆�", + PalletNo = modTask.PalletNo, + Status = TaskStatusEnum.Complete, + StartLocat = modTask.StartLocate, + EndLocat = modTask.EndLocate, + }; + } + else + { + // 鍑哄簱浠诲姟 璺ㄥ贩閬撶Щ搴� + modInsertTaskMonitor = new WcsTaskMonitor() + { + TaskNo = modTask.TaskNo, + PlcId = modDevice.Id, + PlcName = modDevice.Text, + InteractiveMsg = $"鍐欏叆鎸囦护锛歿modTask.StartLocate}鍌ㄤ綅====銆媨taskInfo.EndStation}宸ヤ綅銆�", + PalletNo = modTask.PalletNo, + Status = TaskStatusEnum.Complete, + StartLocat = modTask.StartLocate, + EndLocat = modTask.EndLocate, + }; + } + + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + //淇敼led灞忎俊鎭� + //LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.EndLocate, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿modTask.StartLocate}", "鎵樼洏鍙�:" + modTask.PalletNo); } } - else if (mod.Value == 840) + break; + case "840": + // 鍙栬揣瀹屾垚 { - //娴嬭瘯鎵归噺璇诲彇 - Dictionary<string, PLCDataTypeEnum> listaddress = new Dictionary<string, PLCDataTypeEnum>(); - foreach (var modStation in mod.listStation) - { - listaddress.Add(modStation.PlcPos, modStation.PosType.Value); - } - var result = mod.PLCUtil.GetPlcBatchDBValue(listaddress); - if (!result.IsSucceed) - { - if (result.Value.Count > 0)//鏈夐敊璇殑涔熸湁鎴愬姛鐨� - { + // 鑾峰彇璺烘満鐐逛綅閰嶇疆 + var modPosTask = modDevice.listStation.FirstOrDefault(m => m.Text == "浠诲姟鍙�"); + var (res, val) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosTask.PlcPos); + var modPosEndStation = modDevice.listStation.FirstOrDefault(m => m.Text == "鐩殑宸ヤ綅"); + var (endStationRes, endStation) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosTask.PlcPos); + if (res.IsSucceed) + { + // 鑾峰彇浠诲姟淇℃伅 + string tasknoVal = val.ToString(); + var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == true); + if (modTask == null) + { + Log.Error(string.Format("PLC鎺у埗瀛�840:鏈壘鍒板搴旂殑浠诲姟銆�")); + break; + } + // 璁板綍浠诲姟鏄庣粏 + var modInsertTaskMonitor = new WcsTaskMonitor() + { + TaskNo = modTask.TaskNo, + PlcId = modDevice.Id, + PlcName = modDevice.Text, + PalletNo = modTask.PalletNo, + Status = TaskStatusEnum.Complete, + StartLocat = modTask.StartLocate, + }; + + if (modTask.TaskType == TaskTypeEnum.In) + { + // 鑾峰彇璺烘満璧峰宸ヤ綅鐐逛綅閰嶇疆,璇诲彇璧峰宸ヤ綅 + var modPosStartStation = modDevice.listStation.FirstOrDefault(m => m.Text == "璧峰宸ヤ綅"); + var (startStationRes, startStationVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosStartStation.PlcPos); + if (startStationRes.IsSucceed) + { + // 鏍规嵁宸ヤ綅鍙疯幏鍙栧搴旂殑杈撻�佺嚎IP + PlcTaskInfo taskInfo = PLCCommon.GetPlcIp(startStationVal); + var plcConveyorConn = PLCTaskAction.listPlcConn.First(m => m.PlcIP == taskInfo.Ip); + if (plcConveyorConn.Connected) + { + // 鍚戝彇璐у伐浣嶅啓鍏ユ祦绋嬪瓧640 鍙栬揣宸插畬鎴� + var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == startStationVal + && m.DeviceType == DeviceTypeEnum.Business && m.IsDelete == true); + var retc = plcConveyorConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "640"); + var modcTaskMonitor = new WcsTaskMonitor() + { + TaskNo = modTask.TaskNo, + PlcId = ConveyorMod.Id, + PlcName = ConveyorMod.Text, + PalletNo = modTask.PalletNo, + Status = TaskStatusEnum.Complete, + StartLocat = startStationVal, + EndLocat = modTask.EndLocate // 鐩爣鍌ㄤ綅鍦板潃 + }; + if (!retc.IsSucceed) + { + modcTaskMonitor.InteractiveMsg = string.Format("杈撻�佺嚎鍙栬揣宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚640澶辫触绛夊緟鍦ㄦ鍐欏叆", startStationVal); + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + break; + } + + modcTaskMonitor.InteractiveMsg = string.Format("杈撻�佺嚎鍙栬揣宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚640鎴愬姛", startStationVal); + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modcTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTaskMonitor(modcTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + } + + // 鍐欏叆娴佺▼鎺у埗瀛� + var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "850"); + if (!ret.IsSucceed) + { + break; // 鍐欏叆澶辫触璺冲嚭绛夊緟鍐嶆鍐欏叆 + } + + modInsertTaskMonitor.InteractiveMsg = string.Format("杈撻�佺嚎鍙栬揣宸ヤ綅锛歿0}璺烘満鍙栬揣瀹屾垚850鎴愬姛", startStationVal); + modInsertTaskMonitor.EndLocat = modTask.EndLocate; // 鐩爣鍌ㄤ綅鍦板潃 + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + } + } + else if (modTask.TaskType == TaskTypeEnum.Out) + { + // 鍐欏叆娴佺▼鎺у埗瀛� + var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "850"); + if (!ret.IsSucceed) + { + break; // 鍐欏叆澶辫触璺冲嚭绛夊緟鍐嶆鍐欏叆 + } + + // 璁板綍浠诲姟鏄庣粏 + modInsertTaskMonitor.InteractiveMsg = string.Format("鍌ㄤ綅鍦板潃锛歿0}鍙栬揣瀹屾垚", modTask.StartLocate); + modInsertTaskMonitor.EndLocat = endStation; // 鏀捐揣宸ヤ綅 + } + else + { + // 鍐欏叆娴佺▼鎺у埗瀛� + var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "850"); + if (!ret.IsSucceed) + { + break; // 鍐欏叆澶辫触璺冲嚭绛夊緟鍐嶆鍐欏叆 + } + + modInsertTaskMonitor.InteractiveMsg = string.Format("鍌ㄤ綅鍦板潃锛歿0}鍙栬揣瀹屾垚", modTask.StartLocate); + modInsertTaskMonitor.EndLocat = endStation; // 鐩爣鍌ㄤ綅 + } + + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + //淇敼led灞忎俊鎭� + //LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.EndLocate, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿modTask.StartLocate}", "鎵樼洏鍙�:" + modTask.PalletNo); + } + } + break; + case "860": + { + // 鑾峰彇璺烘満鐐逛綅閰嶇疆 + var modPos860Task = modDevice.listStation.FirstOrDefault(m => m.Text == "浠诲姟鍙�"); + var (res, val) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPos860Task.PlcPos); + // 鏍规嵁浠诲姟鍙疯幏鍙栦换鍔′俊鎭� + if (res.IsSucceed) + { + string tasknoVal = val.ToString(); + var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == true); + if (modTask == null) + { + Log.Error(string.Format("璺烘満鎺у埗瀛�860:鏈壘鍒板搴旂殑浠诲姟銆�")); + break; + } + + switch (modTask.TaskType) + { + case TaskTypeEnum.In: + { + var res870 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "870"); + if (!res870.IsSucceed) + { + Log.Error(string.Format("璺烘満鎺у埗瀛�860鍐欏叆870澶辫触!")); + break; + } + + // 鏀瑰彉浠诲姟鐘舵�� + modTask.Status = TaskStatusEnum.Complete; + modTask.FinishDate = DateTime.Now; + _db.Updateable(modTask).ExecuteCommand(); + + if (modTask.Origin == "WMS") + { + // 鍙嶉WMS + var requestMode = new TaskRequest() + { + TaskNo = modTask.TaskNo, + PalletNo = modTask.PalletNo, + TaskType = "1", + TaskStatus = TaskStatusEnum.Complete + }; + + // 姝ゅ娣诲姞璋冪敤WMS鎺ュ彛 liudl + } + + // 姝ゅ娣诲姞涓嶇┖璺戜笟鍔� + } + break; + case TaskTypeEnum.Out: // 鍑哄簱浠诲姟 + { + + } + break; + case TaskTypeEnum.Move: // 绉诲簱浠诲姟 + { + + } + break; + default: break; } } } - else if (mod.Value == 860) + break; + case "841": { } break; - case PLCTypeEnum.ConveyorLine: + case "843": + { + } break; - case PLCTypeEnum.AGV: - break; - case PLCTypeEnum.PalletMachine: + case "861": + { + } break; default: break; } } + /// <summary> + /// 杈撻�佺嚎涓氬姟澶勭悊 + /// </summary> + /// <param name="modDevice"></param> + private static void ConveyorLine(WcsDeviceDto modDevice) + { + } + /// <summary> + /// AGV涓氬姟澶勭悊 + /// </summary> + /// <param name="modDevice"></param> + private static void AGV(WcsDeviceDto modDevice) + { + + } + /// <summary> + /// 鍙犳墭鏈轰笟鍔″鐞� + /// </summary> + /// <param name="modDevice"></param> + private static void PalletMachine(WcsDeviceDto modDevice) + { + + } + + private static void Test(WcsDeviceDto modDevice) + { + //鍐欐娴嬭瘯璇籹tring + var (res, val) = modDevice.PLCUtil.GetPlcDBValue(PLCDataTypeEnum.String, "DB100", "64"); + Console.WriteLine("DB100.64----" + val); + //娴嬭瘯鎵归噺璇诲彇 + Dictionary<string, PLCDataTypeEnum> listaddress = new Dictionary<string, PLCDataTypeEnum>(); + foreach (var modStation in modDevice.listStation) + { + listaddress.Add(modStation.PlcPos, modStation.PosType); + } + var result = modDevice.PLCUtil.GetPlcBatchDBValue(listaddress); + if (result.Value.Count > 0) + { + foreach (var value in result.Value) + { + Console.WriteLine("鍦板潃" + value.Key + "----鍊�" + value, value); + } + } + if (!result.IsSucceed) + { + foreach (var err in result.ErrList) + { + Console.WriteLine(err); + } + if (result.Value.Count > 0)//鏈夐敊璇殑涔熸湁鎴愬姛鐨� + { + + } + } + if (modDevice.Value == 820) + { + //娴嬭瘯鍐欏叆830 + //var result = mod.PLCUtil.SetPlcDBValue(mod.PosType.Value, mod.DbNumber, mod.PlcPos, "830"); + ////鍐欏叆鏄惁鎴愬姛 + //if (result.IsSucceed) + //{ + + //} + } + else if (modDevice.Value == 840) + { + + } + else if (modDevice.Value == 860) + { + + } + } + + + } -- Gitblit v1.8.0