From cadb2a18458e425c62f60bfc738ee1fc517773c4 Mon Sep 17 00:00:00 2001 From: hwh <332078369@qq.com> Date: 星期三, 11 九月 2024 14:47:07 +0800 Subject: [PATCH] 堆垛机出库、移库完成 --- Admin.NET/WCS.Application/PLC/PLCService.cs | 198 ++++++++++++++++++++++++++++++++++++++++++------- Admin.NET/WCS.Application/PLC/PLCCommon.cs | 20 ++-- Admin.NET/WCS.Application/PLC/PLCTaskAction.cs | 13 ++- Admin.NET/WCS.Application/Model/TaskRequest.cs | 2 4 files changed, 187 insertions(+), 46 deletions(-) diff --git a/Admin.NET/WCS.Application/Model/TaskRequest.cs b/Admin.NET/WCS.Application/Model/TaskRequest.cs index 04fcceb..c82e69b 100644 --- a/Admin.NET/WCS.Application/Model/TaskRequest.cs +++ b/Admin.NET/WCS.Application/Model/TaskRequest.cs @@ -4,7 +4,7 @@ { public string TaskNo { get; set; } // 浠诲姟鍙� public string PalletNo { get; set; } // 鎵樼洏鍙� - public string TaskType { get; set; } // 浠诲姟绫诲瀷 + public TaskTypeEnum TaskType { get; set; } // 浠诲姟绫诲瀷 public TaskStatusEnum TaskStatus { get; set; } // 浠诲姟鐘舵�� 0 绛夊緟鎵ц 1 姝e湪鎵ц 2 鎵ц瀹屾垚 3 寮傚父缁撴潫 4 浠诲姟鍙栨秷 } public class ResponseTasks diff --git a/Admin.NET/WCS.Application/PLC/PLCCommon.cs b/Admin.NET/WCS.Application/PLC/PLCCommon.cs index 7faf0c6..b8e8b00 100644 --- a/Admin.NET/WCS.Application/PLC/PLCCommon.cs +++ b/Admin.NET/WCS.Application/PLC/PLCCommon.cs @@ -1,4 +1,5 @@ -锘縰sing Microsoft.AspNetCore.SignalR; +锘縰sing Elastic.Clients.Elasticsearch.Tasks; +using Microsoft.AspNetCore.SignalR; using RazorEngine.Compilation.ImpromptuInterface.Dynamic; using System; using System.Collections.Generic; @@ -215,33 +216,32 @@ /// </summary> /// <param name="startStation"></param> /// <returns></returns> - public static PlcTaskInfo GetPlcIp(string startStation) + public static PLCUtil GetPlcIp(string startStation) { - PlcTaskInfo taskInfo = new PlcTaskInfo(); - + string strIp = ""; var conveyList1 = new List<string>() { "147", "145", "139", "137", "129", "127", "121", "119", "111", "109", "103", "101", "093", "091", "085", "083", "075", "073", "067", "065" }; var conveyList2 = new List<string>() { "252", "254", "260", "262", "272", "272", "278", "280", "288", "290", "294", "301", "307", "309", "315", "317", "325", "327", "331", "337" }; var conveyList3 = new List<string>() { "401", "402", "405", "406", "409", "410", "413", "414", "417", "418", "421", "422", "425", "426", "429", "430", "433", "434", "437", "438" }; if (conveyList1.Contains(startStation)) { - taskInfo.Ip = "10.18.51.110"; + strIp = "10.18.51.110"; } else if (conveyList2.Contains(startStation)) { - taskInfo.Ip = "10.18.51.120"; + strIp = "10.18.51.120"; } else if (conveyList3.Contains(startStation)) { - taskInfo.Ip = "10.18.51.130"; + strIp = "10.18.51.130"; } else { - throw new Exception("宸ヤ綅鏈煡璇㈠埌"); + throw Oops.Bah("宸ヤ綅鏈煡璇㈠埌"); } - - return taskInfo; + var plcConveyorConn = PLCTaskAction.listPlcConn.First(m => m.PlcIP == strIp); + return plcConveyorConn; } /// <summary> diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs index 15c6b70..26c39e3 100644 --- a/Admin.NET/WCS.Application/PLC/PLCService.cs +++ b/Admin.NET/WCS.Application/PLC/PLCService.cs @@ -7,6 +7,7 @@ using RazorEngine.Compilation.ImpromptuInterface.Dynamic; using SKIT.FlurlHttpClient.Wechat.TenpayV3.ExtendedSDK.Global.Models; using System.Data; +using System.Reflection.Emit; namespace WCS.Application; public static class PLCService @@ -52,7 +53,7 @@ /// 璺烘満涓氬姟澶勭悊 /// </summary> /// <param name="modDevice"></param> - private static async void StackingMachine(WcsDeviceDto modDevice) + private static void StackingMachine(WcsDeviceDto modDevice) { var plcConn = modDevice.PLCUtil; switch (modDevice.Value.ToString()) @@ -61,8 +62,8 @@ // 璺烘満绌洪棽锛岃幏鍙栧嚭搴撲换鍔°�佺Щ搴撲换鍔� { // 鑾峰彇浠诲姟淇℃伅 - 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) + 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) { @@ -70,11 +71,11 @@ } // 鏍规嵁鐩爣鍦板潃鍜屽贩閬撹幏鍙栨斁璐у伐浣嶅搴旂殑鎺掑垪灞� - PlcTaskInfo taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, modTask.TaskType.ToString(), + PlcTaskInfo taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, modTask.TaskType.ToString(), modTask.StartRoadway, modTask.EndRoadway); // 鐩爣宸ヤ綅涓嶄负null锛岄渶鍏堝垽鏂斁璐у伐浣嶆槸鍚︾┖闂� - if (!string.IsNullOrEmpty(taskInfo.EndStation)) + if (!string.IsNullOrEmpty(taskInfo.EndStation)) { // 鎵撳紑瀵瑰簲鐨勮緭閫佺嚎杩炴帴 var plcConveyorConn = PLCTaskAction.listPlcConn.First(m => m.PlcIP == taskInfo.Ip); @@ -93,12 +94,12 @@ break; } } - else + else { break; } } - else + else { break; } @@ -159,7 +160,7 @@ EndLocat = modTask.EndLocate, }; } - else + else { // 鍑哄簱浠诲姟 璺ㄥ贩閬撶Щ搴� modInsertTaskMonitor = new WcsTaskMonitor() @@ -184,7 +185,7 @@ } } break; - case "840": + case "840": // 鍙栬揣瀹屾垚 { // 鑾峰彇璺烘満鐐逛綅閰嶇疆 @@ -193,11 +194,11 @@ var modPosEndStation = modDevice.listStation.FirstOrDefault(m => m.Text == "鐩殑宸ヤ綅"); var (endStationRes, endStation) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosTask.PlcPos); - if (res.IsSucceed) + if (res.IsSucceed) { // 鑾峰彇浠诲姟淇℃伅 string tasknoVal = val.ToString(); - var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == true); + 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:鏈壘鍒板搴旂殑浠诲姟銆�")); @@ -208,7 +209,7 @@ { TaskNo = modTask.TaskNo, PlcId = modDevice.Id, - PlcName = modDevice.Text, + PlcName = modDevice.Text, PalletNo = modTask.PalletNo, Status = TaskStatusEnum.Complete, StartLocat = modTask.StartLocate, @@ -219,12 +220,11 @@ // 鑾峰彇璺烘満璧峰宸ヤ綅鐐逛綅閰嶇疆,璇诲彇璧峰宸ヤ綅 var modPosStartStation = modDevice.listStation.FirstOrDefault(m => m.Text == "璧峰宸ヤ綅"); var (startStationRes, startStationVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosStartStation.PlcPos); - if (startStationRes.IsSucceed) + if (startStationRes.IsSucceed) { // 鏍规嵁宸ヤ綅鍙疯幏鍙栧搴旂殑杈撻�佺嚎IP - PlcTaskInfo taskInfo = PLCCommon.GetPlcIp(startStationVal); - var plcConveyorConn = PLCTaskAction.listPlcConn.First(m => m.PlcIP == taskInfo.Ip); - if (plcConveyorConn.Connected) + var plcConveyorConn = PLCCommon.GetPlcIp(startStationVal); + if (plcConveyorConn.Connected) { // 鍚戝彇璐у伐浣嶅啓鍏ユ祦绋嬪瓧640 鍙栬揣宸插畬鎴� var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == startStationVal @@ -240,7 +240,7 @@ StartLocat = startStationVal, EndLocat = modTask.EndLocate // 鐩爣鍌ㄤ綅鍦板潃 }; - if (!retc.IsSucceed) + if (!retc.IsSucceed) { modcTaskMonitor.InteractiveMsg = string.Format("杈撻�佺嚎鍙栬揣宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚640澶辫触绛夊緟鍦ㄦ鍐欏叆", startStationVal); // 鎻掑叆浜や簰鏃ュ織 @@ -266,7 +266,7 @@ modInsertTaskMonitor.InteractiveMsg = string.Format("杈撻�佺嚎鍙栬揣宸ヤ綅锛歿0}璺烘満鍙栬揣瀹屾垚850鎴愬姛", startStationVal); modInsertTaskMonitor.EndLocat = modTask.EndLocate; // 鐩爣鍌ㄤ綅鍦板潃 - // 鎻掑叆浜や簰鏃ュ織 + // 鎻掑叆浜や簰鏃ュ織 _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); //涓嬪彂浠诲姟鏃ュ織 _taskLogHubContext.Clients.All.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); @@ -285,7 +285,7 @@ modInsertTaskMonitor.InteractiveMsg = string.Format("鍌ㄤ綅鍦板潃锛歿0}鍙栬揣瀹屾垚", modTask.StartLocate); modInsertTaskMonitor.EndLocat = endStation; // 鏀捐揣宸ヤ綅 } - else + else { // 鍐欏叆娴佺▼鎺у埗瀛� var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "850"); @@ -328,7 +328,7 @@ case TaskTypeEnum.In: { var res870 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "870"); - if (!res870.IsSucceed) + if (!res870.IsSucceed) { Log.Error(string.Format("璺烘満鎺у埗瀛�860鍐欏叆870澶辫触!")); break; @@ -336,34 +336,172 @@ // 鏀瑰彉浠诲姟鐘舵�� modTask.Status = TaskStatusEnum.Complete; - modTask.FinishDate = DateTime.Now; + modTask.FinishDate = DateTime.Now; _db.Updateable(modTask).ExecuteCommand(); - if (modTask.Origin == "WMS") + var modcTaskMonitor = new WcsTaskMonitor() + { + TaskNo = modTask.TaskNo, + PlcId = modDevice.Id, + PlcName = modDevice.Text, + PalletNo = modTask.PalletNo, + Status = TaskStatusEnum.Complete, + StartLocat = modTask.StartLocate, + EndLocat = modTask.EndLocate, + InteractiveMsg = $"浠诲姟瀹屾垚" + }; + if (modTask.Origin == "WMS") { // 鍙嶉WMS var requestMode = new TaskRequest() { TaskNo = modTask.TaskNo, PalletNo = modTask.PalletNo, - TaskType = "1", + TaskType = TaskTypeEnum.In, TaskStatus = TaskStatusEnum.Complete }; - - // 姝ゅ娣诲姞璋冪敤WMS鎺ュ彛 liudl + HttpService httpService = new HttpService(); + var modResponseTask = httpService.RequestTask(requestMode).Result; + if (modResponseTask.StatusCode == "0") + { + modcTaskMonitor.InteractiveMsg = "浠诲姟瀹屾垚锛岃繑鍥炵粰WMS浠诲姟瀹屾垚"; + } } + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modcTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTaskMonitor(modcTaskMonitor.Adapt<WcsTaskMonitorOutput>()); // 姝ゅ娣诲姞涓嶇┖璺戜笟鍔� } break; case TaskTypeEnum.Out: // 鍑哄簱浠诲姟 - { - + { + string roadway = modTask.StartRoadway; + // 浠庡嚭搴撲换鍔¤幏鍙栨斁璐у伐浣� + string outCode = modTask.EndLocate; + // 鏍规嵁宸ヤ綅鍙疯幏鍙栧搴旂殑杈撻�佺嚎IP + var plcConveyorConn = PLCCommon.GetPlcIp(outCode); + if (plcConveyorConn.Connected) + { + // 鏍规嵁鐩爣鍦板潃鍜屽贩閬撹幏鍙栨斁璐у伐浣嶅搴旂殑鎺掑垪灞� + PlcTaskInfo taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, modTask.TaskType.ToString(), + modTask.StartRoadway, modTask.EndRoadway); + // 鏍规嵁宸ヤ綅鍙疯幏鍙栧伐浣嶄俊鎭� + var wcsDevice = PLCTaskAction.plcDevices.First(s => s.PlcId == plcConveyorConn.PlcId && s.Level == DeviceLevelEnum.Station && s.StationNum == taskInfo.EndStation); + // 璇诲彇褰撳墠宸ヤ綅鍚勫亸绉婚噺鍊� + var listPos = PLCTaskAction.plcPositions.Where(s => s.DeviceId == wcsDevice.Id).ToList(); + + // 缁橮LC鍐欏叆浠诲姟鏁版嵁 + var listResult = new List<Result>(); + //浠诲姟鍙� + var modPosTask = listPos.FirstOrDefault(s => s.Text == "浠诲姟鍙�"); + listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo)); + //浠诲姟绫诲瀷 + var modPosTaskType = listPos.FirstOrDefault(s => s.Text == "浠诲姟绫诲瀷"); + listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, modDevice.DbNumber, modPosTaskType.PlcPos, ((int)modTask.TaskType).ToString())); + //鎵樼洏鍙� + var modPosPalletNo = listPos.FirstOrDefault(s => s.Text == "鎵樼洏鐮�"); + listResult.Add(plcConn.SetPlcDBValue(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo)); + //璧峰宸ヤ綅 + var modPosLocatNo = listPos.FirstOrDefault(s => s.Text == "璧峰宸ヤ綅"); + listResult.Add(plcConn.SetPlcDBValue(modPosLocatNo.PosType, modDevice.DbNumber, modPosLocatNo.PlcPos, taskInfo.EndStation)); + // 鐩爣宸ヤ綅 + var modPosEndLocatNo = listPos.FirstOrDefault(s => s.Text == "鐩殑宸ヤ綅"); + listResult.Add(plcConn.SetPlcDBValue(modPosEndLocatNo.PosType, modDevice.DbNumber, modPosEndLocatNo.PlcPos, outCode)); + + // 鏄惁鍐欏叆鎴愬姛 + if (listResult.All(s => s.IsSucceed)) + { + var result = plcConveyorConn.SetPlcDBValue(wcsDevice.PosType, wcsDevice.DbNumber, wcsDevice.WcsPos, "740"); + + if (result.IsSucceed) + { + // 鍐欏叆璺烘満wcs鎺у埗瀛� 杩斿洖鍨涙満鎵ц瀹屾垚 + result = modDevice.PLCUtil.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "870"); + if (result.IsSucceed) + { + var modcTaskMonitor = new WcsTaskMonitor() + { + TaskNo = modTask.TaskNo, + PlcId = wcsDevice.Id, + PlcName = wcsDevice.Text, + PalletNo = modTask.PalletNo, + Status = TaskStatusEnum.Complete, + StartLocat = taskInfo.EndStation, + EndLocat = outCode, + InteractiveMsg = $"鍐欏叆鎸囦护锛氭敹鍒拌泛鏈烘斁璐у畬鎴愶紱鏀捐揣{taskInfo.EndStation}宸ヤ綅===銆媨outCode}鍑哄簱鍙�" + }; + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modcTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTaskMonitor(modcTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + break; + } + } + } + //姝ゅ娣诲姞涓嶇┖璺戜笟鍔� + } } break; case TaskTypeEnum.Move: // 绉诲簱浠诲姟 - { - + { + var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "浠诲姟鍙�"); + var result = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo); + if (!result.IsSucceed) + { + Log.Error($"{modDevice.Text}鍐欏叆浠诲姟鍙峰け璐�"); + break; + } + result = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "30"); + if (!result.IsSucceed) + { + Log.Error($"{modDevice.Text}鎺у埗瀛楀啓鍏�30澶辫触"); + break; + } + // 鏀瑰彉浠诲姟鐘舵�� + modTask.Status = TaskStatusEnum.Complete; + modTask.FinishDate = DateTime.Now; + _db.Updateable(modTask).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTask(modTask.Adapt<WcsTaskOutput>()); + + var modcTaskMonitor = new WcsTaskMonitor() + { + TaskNo = modTask.TaskNo, + PlcId = modDevice.Id, + PlcName = modDevice.Text, + PalletNo = modTask.PalletNo, + Status = TaskStatusEnum.Complete, + StartLocat = modTask.StartLocate, + EndLocat = modTask.EndLocate, + InteractiveMsg = $"浠诲姟瀹屾垚" + }; + if (modTask.Origin == "WMS") + { + // 鍙嶉WMS + var requestMode = new TaskRequest() + { + TaskNo = modTask.TaskNo, + PalletNo = modTask.PalletNo, + TaskType = TaskTypeEnum.Move, + TaskStatus = TaskStatusEnum.Complete + }; + HttpService httpService = new HttpService(); + var modResponseTask = httpService.RequestTask(requestMode).Result; + if (modResponseTask.StatusCode == "0") + { + modcTaskMonitor.InteractiveMsg = "浠诲姟瀹屾垚锛岃繑鍥炵粰WMS浠诲姟瀹屾垚"; + //淇敼鍌ㄤ綅淇℃伅 浠诲姟绫诲瀷 鎵ц鐘舵�� 璧峰浣嶇疆 鐩爣浣嶇疆 + + } + } + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modcTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + _taskLogHubContext.Clients.All.PublicTaskMonitor(modcTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + + // 姝ゅ娣诲姞涓嶇┖璺戜笟鍔� } break; default: break; @@ -466,5 +604,5 @@ } - + } diff --git a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs index c301944..d2ab908 100644 --- a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs +++ b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs @@ -23,7 +23,7 @@ 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>(); @@ -34,11 +34,14 @@ get { return listPlcUtil; } } // 浜や簰鐐归泦鍚� - public static List<WcsDevice> plcDevices + public static List<WcsDevice> plcDevices { get { return listPlcDevice; } } - + public static List<WcsPosition> plcPositions + { + get { return listPlcPosition; } + } public static event EventHandler DeviceValueChangeEvent; static PLCTaskAction() { @@ -56,7 +59,7 @@ 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(); + listPlcPosition = _db.Queryable<WcsPosition>().ToList(); listAlarmInfo = _db.Queryable<WcsAlarmInfo>().ToList(); //绛夊緟鍑犵閽燂紝鎶婂凡鏈夌嚎绋嬪彇娑堟帀鍐嶈繛鎺� //Thread.Sleep(5000); @@ -148,7 +151,7 @@ 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); -- Gitblit v1.8.0