From 6eb8d6015059b3e0059ba479c108c1cab2e5f133 Mon Sep 17 00:00:00 2001 From: chengsc <Demo@DESKTOP-CPA90BF> Date: 星期四, 31 十月 2024 09:40:50 +0800 Subject: [PATCH] 修改问题 --- Admin.NET/WCS.Application/PLC/PLCService.cs | 921 ++++++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 773 insertions(+), 148 deletions(-) diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs index 74c5438..c34b5ad 100644 --- a/Admin.NET/WCS.Application/PLC/PLCService.cs +++ b/Admin.NET/WCS.Application/PLC/PLCService.cs @@ -1,5 +1,7 @@ 锘� +using Dm.filter; using DocumentFormat.OpenXml.Bibliography; +using DocumentFormat.OpenXml.Drawing.Charts; using Elastic.Clients.Elasticsearch.Tasks; using Furion.Logging; using IoTClient; @@ -12,10 +14,13 @@ using System.Reflection.Emit; using WCS.Application.Entity; using WCS.Application.Util; +using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinExpressIntracityUpdateStoreRequest.Types; +using static SKIT.FlurlHttpClient.Wechat.Api.Models.NontaxInsertBillRequest.Types.CardExtra.Types.BillCard.Types; namespace WCS.Application; public static class PLCService { + private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId); public static void OnChangeEvent(object sender, EventArgs e) @@ -35,8 +40,8 @@ case PLCTypeEnum.AGV: AGV(mod); // AGV璋冨害 break; - case PLCTypeEnum.RobotPalletizer: - RobotPalletizer(mod); // 鐮佸灈鏈哄櫒浜� + case PLCTypeEnum.BoxConveyorLine: + BoxConveyorLine(mod); // 鐮佸灈鏈哄櫒浜� break; case PLCTypeEnum.StackingRobot: PalletMachine(mod); @@ -57,41 +62,67 @@ private static void StackingMachine(WcsDeviceDto modDevice) { var plcConn = modDevice.PLCUtil; + string ledText = ""; switch (modDevice.Value.ToString()) { case "820": // 璺烘満绌洪棽锛岃幏鍙栧嚭搴撲换鍔°�佺Щ搴撲换鍔� { // 鑾峰彇浠诲姟淇℃伅 - var modTask = _db.Queryable<WcsTask>().OrderBy(m => m.CreateTime).OrderBy(m => m.Levels, OrderByType.Desc) + var modTask = _db.Queryable<WcsTask>().OrderBy(m => m.Levels, OrderByType.Asc).OrderBy(m => m.CreateTime) .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, ((int)modTask.TaskType).ToString(), - modTask.StartRoadway, modTask.EndRoadway); - - // 鐩爣宸ヤ綅涓嶄负null锛岄渶鍏堝垽鏂斁璐у伐浣嶆槸鍚︾┖闂� - if (!string.IsNullOrEmpty(taskInfo.EndStation)) + //鍒ゆ柇鍑哄簱閿佸畾鏄惁鎵撳紑 + if (PLCTaskAction.boOutLock) { - // 鎵撳紑瀵瑰簲鐨勮緭閫佺嚎杩炴帴 - 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); + break;//鍑哄簱閿佸畾鎵撳紑鍒欎笉鎵ц鍑哄簱浠诲姟 + } - var (result, value) = plcConveyorConn.GetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.PlcPos); - if (result.IsSucceed) + PlcTaskInfo taskInfo = new PlcTaskInfo(); + if (modTask.TaskType == TaskTypeEnum.Move) + { + taskInfo = PLCCommon.GetEndPai(modTask.EndRoadway.Substring(1, 2), modTask.EndLocate.Substring(2, 2), + modTask.EndLocate.Substring(0, 2), modTask.EndLocate.Substring(4, 2), + modTask.EndLocate.Substring(6, 2)); + + } + else + { + // 鏍规嵁鐩爣鍦板潃鍜屽贩閬撹幏鍙栨斁璐у伐浣嶅搴旂殑鎺掑垪灞� + taskInfo = PLCCommon.GetCTaskInfo(modTask.EndLocate, ((int)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) { - if (value.ToString() != "720") // 720:鏀捐揣绌轰綅绌洪棽锛屽彲鏀捐揣 + // 鑾峰彇鏀捐揣宸ヤ綅閰嶇疆淇℃伅 + 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) { - Log.Error(string.Format("浠诲姟鍙�:{0}:鏀捐揣宸ヤ綅鍗犵敤锛岀◢鍚庢墽琛屻��", modTask.TaskNo)); + if (value.ToString() != "720") // 720:鏀捐揣绌轰綅绌洪棽锛屽彲鏀捐揣 + { + Log.Error(string.Format("浠诲姟鍙�:{0}:鏀捐揣宸ヤ綅鍗犵敤锛岀◢鍚庢墽琛屻��", modTask.TaskNo)); + break; + } + else if (value.ToString() == "720") + { + // 鑻ョ┖闂叉彁鍓嶅崰鐢ㄦ宸ヤ綅锛屽悓宸ヤ綅鍑哄叆鍏敤鍙� 鏀惧紑姝ょ▼搴� + // var ret = plcConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "730"); + } + } + else + { break; } } @@ -99,10 +130,6 @@ { break; } - } - else - { - break; } } @@ -181,8 +208,15 @@ _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); //涓嬪彂浠诲姟鏃ュ織 HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + //淇敼led灞忎俊鎭� - //LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.EndLocate, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿modTask.StartLocate}", "鎵樼洏鍙�:" + modTask.PalletNo); + var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == taskInfo.EndStation && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business); + ledText += $"浠诲姟绫诲瀷:{modTask.TaskType.GetDescription()}\n\n"; + ledText += $"浠诲姟鍙�:{modTask.TaskNo}\n"; + ledText += $"鎵樼洏鍙�:{modTask.PalletNo}\n\n"; + ledText += $"璧峰浣�:{modTask.StartRoadway + " " + modTask.StartLocate}\n"; + ledText += $"鐩爣浣�:{modTask.EndRoadway + " " + modTask.EndLocate}"; + LedDisplay(ledDevice.LedIP, ledText); } } break; @@ -249,22 +283,23 @@ modcTaskMonitor.InteractiveMsg = string.Format("宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚:640", startStationVal); // 鎻掑叆浜や簰鏃ュ織 _db.Insertable(modcTaskMonitor).ExecuteCommand(); - } - var retc = plcConveyorConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "640"); + var retc = plcConveyorConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "640"); - if (!retc.IsSucceed) - { - modcTaskMonitor.InteractiveMsg = string.Format("宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚640澶辫触", startStationVal); - // 鎻掑叆浜や簰鏃ュ織 - _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); + if (!retc.IsSucceed) + { + modcTaskMonitor.InteractiveMsg = string.Format("宸ヤ綅锛歿0},鍐欏叆鍙栬揣瀹屾垚640澶辫触", startStationVal); + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + break; + } + //涓嬪彂浠诲姟鏃ュ織 HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); - break; } - //涓嬪彂浠诲姟鏃ュ織 - HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); } // 璇诲彇wcs鎺у埗瀛� @@ -334,8 +369,6 @@ HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); } - //淇敼led灞忎俊鎭� - //LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.EndLocate, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿modTask.StartLocate}", "鎵樼洏鍙�:" + modTask.PalletNo); } } break; @@ -349,7 +382,7 @@ { string tasknoVal = val.ToString(); var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == false); - if (modTask == null) + if (modTask == null) { Log.Error(string.Format("璺烘満鎺у埗瀛�860:鏈壘鍒板搴旂殑浠诲姟銆�")); break; @@ -400,7 +433,7 @@ } else { - Log.Error(string.Format("浠诲姟鍙嶉澶辫触锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg)); + Log.Error(string.Format("c锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg)); } } // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆� @@ -412,8 +445,16 @@ HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>()); // led鏄剧ず鍐呭 - LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.StartLocate, "鍏ュ簱瀹屾垚 " + $"浠诲姟瀹屾垚:{modTask.TaskNo}", "鎵樼洏鍙�:" + modTask.PalletNo); + var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modTask.StartLocate && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business); + ledText += $"鍏ュ簱瀹屾垚\n\n"; + ledText += $"浠诲姟鍙�:{modTask.TaskNo}\n"; + ledText += $"鎵樼洏鍙�:{modTask.PalletNo}\n\n"; + + ledText += $"璧峰浣�:{modTask.StartRoadway + " " + modTask.StartLocate}\n"; + ledText += $"鐩爣浣�:{modTask.EndRoadway + " " + modTask.EndLocate}"; + + LedDisplay(ledDevice.LedIP, ledText); // 姝ゅ娣诲姞涓嶇┖璺戜笟鍔� } break; @@ -479,13 +520,6 @@ //涓嬪彂浠诲姟鏃ュ織 HubUtil.PublicTaskMonitor(modcTaskMonitor.Adapt<WcsTaskMonitorOutput>()); - // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆� - var taskModel = _db.Queryable<WcsTask>().First(w => w.TaskNo == modTask.TaskNo); - modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskModel.StartLocate).Select(s => s.LedIP).First(); - - // led鏄剧ず鍐呭 - LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modDevice.StationNum, "鍑哄簱涓� ", "鎵樼洏鍙�:" + modTask.PalletNo); - break; } } @@ -497,21 +531,22 @@ case TaskTypeEnum.Move: // 绉诲簱浠诲姟 { var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "浠诲姟鍙�"); - var result = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo); + var result = plcConn.SetPlcDBValue(modPosTask.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"); + result = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "870"); if (!result.IsSucceed) { - Log.Error($"{modDevice.Text}鎺у埗瀛楀啓鍏�30澶辫触"); + Log.Error($"{modDevice.Text}鎺у埗瀛楀啓鍏�870澶辫触"); break; } // 鏀瑰彉浠诲姟鐘舵�� modTask.Status = TaskStatusEnum.Complete; modTask.FinishDate = DateTime.Now; + modTask.Levels = 999; _db.Updateable(modTask).ExecuteCommand(); //涓嬪彂浠诲姟鏃ュ織 HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>()); @@ -533,8 +568,8 @@ { TaskNo = modTask.TaskNo, PalletNo = modTask.PalletNo, - TaskType = TaskTypeEnum.Move.ToString(), - TaskStatus = TaskStatusEnum.Complete.ToString() + TaskType = ((int)TaskTypeEnum.Move).ToString(), + TaskStatus = ((int)TaskStatusEnum.Complete).ToString() }; HttpService httpService = new HttpService(); var modResponseTask = httpService.RequestTask(requestMode).Result; @@ -542,7 +577,10 @@ { modcTaskMonitor.InteractiveMsg = "浠诲姟瀹屾垚锛岃繑鍥炵粰WMS浠诲姟瀹屾垚"; //淇敼鍌ㄤ綅淇℃伅 浠诲姟绫诲瀷 鎵ц鐘舵�� 璧峰浣嶇疆 鐩爣浣嶇疆 - + } + else + { + Log.Error(string.Format("浠诲姟鍙嶉澶辫触锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg)); } } // 鎻掑叆浜や簰鏃ュ織 @@ -694,7 +732,7 @@ } } /// <summary> - /// 鍫嗗灈鏈轰笉绌鸿窇 + /// 涓嶇┖璺� /// </summary> /// <param name="modTask">鎿嶄綔瀹屾垚鐨勪换鍔�</param> /// <param name="plcConn">plc杩炴帴</param> @@ -860,6 +898,11 @@ var plcConn = modDevice.PLCUtil; // 鑾峰彇妤煎眰鏁癱eshi var louCeng = PLCCommon.GetRoadwayByStationNew(modDevice.StationNum); + if (louCeng == "") + { + return; + } + var ledText = ""; switch (modDevice.Value.ToString()) { case "320": @@ -867,11 +910,7 @@ // 鐢宠宸烽亾 string strMsg = ""; string taskModel = ""; - // 鍒ゆ柇鏄惁婕旂ず妯″紡 - if (PLCTaskAction.boDemo) - { - taskModel = "1";// 婕旂ず妯″紡 - } + // 鑾峰彇宸ヤ綅鎵樼洏鐮佷俊鎭� var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "鎵樼洏鐮�"); var (res, palletVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos); @@ -879,6 +918,52 @@ { break; } + var modPosEndLocat = modDevice.listStation.FirstOrDefault(s => s.Text == "鐩殑宸ヤ綅"); + + + //鍒ゆ柇鍏ュ簱閿佸畾鏄惁鎵撳紑 + if (PLCTaskAction.boEnterLock) + { + var (res350, palletVal350) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos); + if (res350.IsSucceed && palletVal350 != "350") + { + ledText += $"鐢宠鍏ュ簱澶辫触\n\n"; + ledText += $"鎵樼洏鍙�:{palletVal}\n"; + ledText += $"鍏ュ簱浠诲姟宸查攣瀹氾紝璇疯В閿佸悗閲嶈瘯!\n"; + LedDisplay(modDevice.LedIP, ledText); + } + + // 鍐欏叆杈撻�佺嚎閫�鍥炴寚浠� + var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, modDevice.StationNum); + if (ret.IsSucceed) + { + plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "350"); + } + + break; + } + + if (palletVal == null) + { + var (res350, palletVal350) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos); + if (res350.IsSucceed && palletVal350 != "350") + { + ledText += $"鐢宠鍏ュ簱澶辫触\n\n"; + ledText += $"鎵樼洏鍙�:{palletVal}\n"; + ledText += $"鎵弿鎵樼洏鍙峰け璐�!\n"; + LedDisplay(modDevice.LedIP, ledText); + } + + // 鍐欏叆杈撻�佺嚎閫�鍥炴寚浠� + var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, modDevice.StationNum); + if (ret.IsSucceed) + { + plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "350"); + } + + break; + } + var http = new HttpService(); string TaskNo = "", EndLocate = ""; strMsg = http.RequestRoadWay(palletVal, modDevice.StationNum, taskModel, louCeng, ref EndLocate, ref TaskNo); @@ -913,20 +998,48 @@ // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈� HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); // led鏄剧ず鍐呭 - LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modDevice.StationNum, "鐢宠鍏ュ簱 " + $"鐩爣宸烽亾锛歿EndLocate}", "鎵樼洏鍙�:" + palletVal); + try + { + ledText += $"浠诲姟绫诲瀷:{taskInfo.TaskType.GetDescription()}\n\n"; + + ledText += $"浠诲姟鍙�:{taskInfo.TaskNo}\n"; + ledText += $"鎵樼洏鍙�:{taskInfo.PalletNo}\n\n"; + + ledText += $"璧峰浣�:{taskInfo.StartRoadway + " " + taskInfo.StartLocate}\n"; + ledText += $"鐩爣浣�:{taskInfo.EndRoadway + " " + taskInfo.EndLocate}"; + LedDisplay(modDevice.LedIP, ledText); + + } + catch (Exception ex) + { + Log.Error(ex.Message); + } + } } else { - // 鐢宠宸烽亾澶辫触锛丩ED鏄剧ず - Log.Error(string.Format($"鐢宠宸烽亾澶辫触:{strMsg},璇诲啓plc閿欒")); + var (res350, palletVal350) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos); + if (res350.IsSucceed && palletVal350 != "350") + { + ledText += $"鐢宠鍏ュ簱澶辫触\n\n"; + ledText += $"鎵樼洏鍙�:{palletVal}\n"; + ledText += $"{strMsg}\n"; + LedDisplay(modDevice.LedIP, ledText); + } + + // 鍐欏叆杈撻�佺嚎閫�鍥炴寚浠� + var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, modDevice.StationNum); + if (ret.IsSucceed) + { + plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "350"); + } } } break; case "330": { - // 鍐欏叆浠诲姟 鎵樼洏绉诲姩 340 // 鑾峰彇宸ヤ綅鎵樼洏鐮佷俊鎭� @@ -943,6 +1056,11 @@ { // 姝ゆ墭鐩樻病鏈夊搴旂殑杞Щ浠诲姟 led鏄剧ず break; + } + //鍒ゆ柇鍏ュ簱閿佸畾鏄惁鎵撳紑 + if (PLCTaskAction.boEnterLock) + { + break;//鍏ュ簱閿佸畾鎵撳紑鍒欎笉鎵ц鍏ュ簱浠诲姟 } // 鑾峰彇宸烽亾鍙e叆搴撳伐浣� @@ -999,8 +1117,6 @@ // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈� HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); - // led鏄剧ず鍐呭 - LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modDevice.StationNum, "鍏ュ簱涓� " + $"鐩爣宸烽亾锛歿endLocatVlue}", "鎵樼洏鍙�:" + palletVal); } } @@ -1065,14 +1181,25 @@ // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈� HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); - // led鏄剧ず鍐呭 - LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modDevice.StationNum, "鍏ュ簱涓� " + $"鐢宠鍌ㄤ綅鍦板潃:{strMsg}", "鎵樼洏鍙�:" + palletVal); + + var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business); + ledText += $"浠诲姟绫诲瀷:{taskInfo.TaskType.GetDescription()}\n\n"; + ledText += $"浠诲姟鍙�:{taskInfo.TaskNo}\n"; + ledText += $"鎵樼洏鍙�:{taskInfo.PalletNo}\n\n"; + ledText += $"璧峰浣�:{taskInfo.StartRoadway + " " + taskInfo.StartLocate}\n"; + ledText += $"鐩爣浣�:{taskInfo.EndRoadway + " " + taskInfo.EndLocate}"; + LedDisplay(modDevice.LedIP, ledText); } } else { // 鐢宠鍌ㄤ綅澶辫触锛丩ED鏄剧ず Log.Error(string.Format($"鐢宠鍌ㄤ綅澶辫触:{strMsg},璇诲啓plc閿欒")); + // led鏄剧ず鍐呭 + var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business); + ledText += $"鐢宠鍏ュ簱澶辫触\n\n"; + ledText += $"{strMsg}\n"; + LedDisplay(modDevice.LedIP, ledText); } } @@ -1120,6 +1247,7 @@ break; } + // 杞崲鐩爣宸ヤ綅鎺掑垪灞� 03010301 var paiVal = PLCCommon.GetDjAdress(modTask.EndRoadway.Substring(1, 2), endLocate.Substring(0, 2), endLocate.Substring(6, 2)); string pai = paiVal.ToString(); string lie = int.Parse(endLocate.Substring(2, 2)).ToString(); @@ -1216,8 +1344,8 @@ #endregion } break; - #region 鍑哄簱浜や簰 + #region 鍑哄簱浜や簰 case "420": { #region 鎵樼洏鍒拌揪鎷i�夊伐浣�/鍑哄簱鍙� @@ -1255,10 +1383,18 @@ // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆� var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == modInsertTaskMonitor.TaskNo); - modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.StartLocate).Select(s => s.LedIP).First(); + modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.EndLocate).Select(s => s.LedIP).First(); // led鏄剧ず鍐呭 - LedDisplay(modDevice.LedIP, "鍒拌揪宸ヤ綅:" + modDevice.StationNum, "鍑哄簱瀹屾垚 " + $"鍌ㄤ綅鍦板潃锛歿modInsertTaskMonitor.StartLocat}", "鎵樼洏鍙�:" + palletVal); + // 鏍规嵁鐩爣宸ヤ綅鍙疯幏鍙栧搴旂殑LEDIP鍦板潃 + var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business && m.PlcId == modDevice.PlcId); + + ledText += $"鍑哄簱瀹屾垚\n\n"; + ledText += $"浠诲姟鍙�:{taskInfo.TaskNo}\n"; + ledText += $"鎵樼洏鍙�:{taskInfo.PalletNo}\n\n"; + ledText += $"璧峰浣�:{taskInfo.StartRoadway + " " + taskInfo.StartLocate}\n"; + ledText += $"鐩爣浣�:{taskInfo.EndRoadway + " " + taskInfo.EndLocate}"; + LedDisplay(ledDevice.LedIP, ledText); } // 鍙嶉WMS鍑哄簱瀹屾垚 //TaskReques taskReques = new TaskReques(); @@ -1293,6 +1429,7 @@ // 鏀瑰彉浠诲姟鐘舵�� modTask.Status = TaskStatusEnum.Complete; modTask.FinishDate = DateTime.Now; + modTask.Levels = 999; _db.Updateable(modTask).ExecuteCommand(); HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>()); // 鎻掑叆浠诲姟鏄庣粏 @@ -1301,7 +1438,7 @@ TaskNo = modTask.TaskNo, PlcId = modDevice.Id, PlcName = modDevice.Text, - InteractiveMsg = $"鍐欏叆鎸囦护450锛歿modDevice.StationNum}鎷i�夊畬鎴�,鎵樼洏绂诲紑宸ヤ綅", + InteractiveMsg = $"鍐欏叆鎸囦护450锛歿modDevice.StationNum}鍑哄簱瀹屾垚", PalletNo = palletVal, Status = TaskStatusEnum.Complete, StartLocat = starVal.ToString(), @@ -1335,13 +1472,116 @@ // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈� HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); // led鏄剧ず鍐呭 - modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == modTask.StartLocate).Select(s => s.LedIP).First(); - LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.StartLocate, $"鎷i�夊畬鎴愶紝鎵樼洏绂诲紑宸ヤ綅", "鎵樼洏鍙�:" + modTask.PalletNo); + var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business && m.PlcId == modDevice.PlcId); + + ledText += $"鍑哄簱瀹屾垚\n\n"; + ledText += $"浠诲姟鍙�:{modTask.TaskNo}\n"; + ledText += $"鎵樼洏鍙�:{modTask.PalletNo}\n\n"; + ledText += $"璧峰浣�:{modTask.StartRoadway + " " + modTask.StartLocate}\n"; + ledText += $"鐩爣浣�:{modTask.EndRoadway + " " + modTask.EndLocate}"; + LedDisplay(ledDevice.LedIP, ledText); } #endregion } break; + #endregion + + #region 鍙┖鎵樼洏璺� + case "50": + // plc鐢宠绌烘墭 + { + // 闃叉閲嶅鍙┖鎵樿泛 + var (res, palletVal) = plcConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos); + if (palletVal != 0) + { + break; + } + + // 璋冪敤WMS绌烘墭鍑哄簱鎺ュ彛锛岃繑鍥炲嚭搴撲换鍔″瓨鍏ュ嚭搴撹〃 + var strMsg = ""; + var http = new HttpService(); + strMsg = http.IssuePlnOutHouseWcs("1", "205"); + if (!strMsg.Contains("-1")) + { + // 鍐欏叆plc娴佺▼瀛�60 + var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "60"); + } + else + { + // 鐢宠宸烽亾澶辫触锛丩ED鏄剧ず + Log.Error(string.Format($"宸ヤ綅鍙凤細{modDevice.StationNum}鐢宠绌烘墭璺哄け璐�:{strMsg};")); + } + } + break; + case "80": + // 绌烘墭鐩樿泛宸插埌浣� + { + // 璋冪敤wms浠诲姟鍑哄簱浠诲姟瀹屾垚 + // 鑾峰彇璺烘満鐐逛綅閰嶇疆 + var modPosTask = modDevice.listStation.FirstOrDefault(m => m.Text == "浠诲姟鍙�"); + var (res, val) = plcConn.GetPlcDBValue(modPosTask.PosType, 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 == false); + if (modTask == null) + { + //Log.Error(string.Format($"宸ヤ綅鍙凤細{modDevice.StationNum}绌烘墭鐩樺埌杈撅紝鏈壘鍒板搴旂殑浠诲姟!浠诲姟鍙穥tasknoVal};")); + break; + } + // 鍐欏叆plc娴佺▼瀛�90 + var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "90"); + if (ret.IsSucceed) + { + // 鏀瑰彉浠诲姟鐘舵�� + modTask.Status = TaskStatusEnum.Complete; + modTask.FinishDate = DateTime.Now; + modTask.Levels = 999; + _db.Updateable(modTask).ExecuteCommand(); + + HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>()); + var modTaskMonitor = 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 TaskRequestWMS() + { + TaskNo = modTask.TaskNo, + PalletNo = modTask.PalletNo, + TaskType = ((int)TaskTypeEnum.Out).ToString(), + TaskStatus = ((int)TaskStatusEnum.Complete).ToString() + }; + HttpService httpService = new HttpService(); + var modResponseTask = httpService.RequestTask(requestMode).Result; + if (modResponseTask.StatusCode == 0) + { + modTaskMonitor.InteractiveMsg = "浠诲姟瀹屾垚锛岃繑鍥炵粰WMS浠诲姟瀹屾垚"; + } + else + { + Log.Error(string.Format("浠诲姟鍙嶉澶辫触锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg)); + } + } + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modTaskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + } + } + } + break; #endregion default: break; @@ -1387,58 +1627,51 @@ } /// <summary> - /// 鐮佸灈鏈哄櫒浜轰笟鍔″鐞� + /// 浠剁杈撻�佸拰鐮佸灈鏈哄櫒浜轰笟鍔″鐞� 閰嶇疆鐨勬槸浠剁杈撻�� /// </summary> /// <param name="modDevice"></param> - private static void RobotPalletizer(WcsDeviceDto modDevice) + private static async void BoxConveyorLine(WcsDeviceDto modDevice) { var plcConn = modDevice.PLCUtil; - switch (modDevice.Value.ToString()) + + if (modDevice.DbNumber == "DB101") { - case "1": - // 涓绘壂鐢宠鍒嗛亾 wcs鍐欏叆2 - { - - var taskModel = ""; - // 鍒ゆ柇鏄惁婕旂ず妯″紡 - if (PLCTaskAction.boDemo) + // 涓绘壂浜や簰娴佺▼ + switch (modDevice.Value.ToString()) + { + case "1": + // 涓绘壂鐢宠鍒嗛亾 wcs鍐欏叆2 { - // 婕旂ず妯″紡 - taskModel = "1"; - - // 鐩存帴 - } - else - { - // 閫氶亾鍙� - var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "閫氶亾鍙�"); - - // 璇诲彇plc绠辩爜 - var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "绠辩爜"); - var (res, boxNo) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modBoxNo.PlcPos); - if (string.IsNullOrWhiteSpace(boxNo.ToString())) + // 鍒ゆ柇鏄惁婕旂ず妯″紡 true锛氭紨绀烘ā寮� false:鐢熶骇妯″紡 + if (PLCTaskAction.boDemo) { - // 绠辩爜涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙� - var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0"); + // 閫氶亾鍙� + var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "閫氶亾鍙�"); + + // 婕旂ず妯″紡鐩存帴鍐欏叆1鍒嗛亾 + var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "1"); if (ret.IsSucceed) { // 鍐欏叆娴佺▼鎺у埗瀛� 2 var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2"); - if (retVal.IsSucceed) + if (!retVal.IsSucceed) { - Log.Error("绠辩爜涓簄ull杩涜鍓旈櫎"); + Log.Error("婕旂ず妯″紡鍐欏叆鍒嗛亾鍙峰け璐�!"); break; } } } - else + else { - // 鏍规嵁绠辩爜鑾峰彇绠卞唴淇℃伅 - string boxNoVal = boxNo.ToString(); - var boxInfo = _db.Queryable<WcsBoxInfo>().First(w => w.IsDelete == false && w.BoxNo == boxNoVal && string.IsNullOrEmpty(w.PalletNo)); - if (boxInfo == null) + // 閫氶亾鍙� + var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "閫氶亾鍙�"); + + // 璇诲彇plc绠辩爜 + var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "绠辩爜"); + var (res, boxNo) = plcConn.GetPlcDBValue(modBoxNo.PosType, modDevice.DbNumber, modBoxNo.PlcPos); + if (string.IsNullOrWhiteSpace(boxNo.ToString())) { - // 绠变俊鎭负null鍐欏叆鍓旈櫎閫氶亾鍙� + // 绠辩爜涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙� var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0"); if (ret.IsSucceed) { @@ -1446,59 +1679,380 @@ var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2"); if (retVal.IsSucceed) { - Log.Error("绠辩爜涓簄ull鎴栧凡缁戝畾鎵樼洏锛岃繘琛屽墧闄ゃ��"); - break; - } - } - } - // 鏍规嵁绠卞唴鍝佺鍙疯幏鍙栫爜韬茬粦瀹氬伐浣嶅強瀵瑰簲鐨勫垎閬撳彿 - var checkTaskInfo = _db.Queryable<WcsCheckTask>().First(w => w.SkuNo == boxInfo.SkuNo && w.SkuName == boxInfo.SkuName && w.LotNo == boxInfo.LotNo); - if (checkTaskInfo == null) - { - // 缁戝畾淇℃伅涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙� - var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0"); - if (ret.IsSucceed) - { - // 鍐欏叆娴佺▼鎺у埗瀛� 2 - var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2"); - if (retVal.IsSucceed) - { - Log.Error("绠辩爜鏈粦瀹氬垎鎷d换鍔★紝杩涜鍓旈櫎銆�"); + Log.Error("绠辩爜涓簄ull杩涜鍓旈櫎"); break; } } } else { - // 涓巔lc浜や簰鍐欏叆鍒嗛亾鍙峰拰娴佺▼鎺у埗瀛� - var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, checkTaskInfo.RoboatNo); - if (ret.IsSucceed) + // 鏍规嵁绠辩爜鑾峰彇绠卞唴淇℃伅 + string boxNoVal = boxNo.ToString(); + var boxInfo = _db.Queryable<WcsBoxInfo>().First(w => w.IsDelete == false && w.BoxNo == boxNoVal && string.IsNullOrEmpty(w.PalletNo)); + if (boxInfo == null) { - // 鍐欏叆娴佺▼鎺у埗瀛� 2 - var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2"); - if (retVal.IsSucceed) + // 绠变俊鎭负null鍐欏叆鍓旈櫎閫氶亾鍙� + var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0"); + if (ret.IsSucceed) { - break; + // 鍐欏叆娴佺▼鎺у埗瀛� 2 + var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2"); + if (retVal.IsSucceed) + { + Log.Error("绠辩爜涓簄ull鎴栧凡缁戝畾鎵樼洏锛岃繘琛屽墧闄ゃ��"); + break; + } } } - } + // 鏍规嵁绠卞唴鍝佺鍙疯幏鍙栫爜韬茬粦瀹氬伐浣嶅強瀵瑰簲鐨勫垎閬撳彿 + var checkTaskInfo = _db.Queryable<WcsCheckTask>().First(w => w.SkuNo == boxInfo.SkuNo && w.SkuName == boxInfo.SkuName && w.LotNo == boxInfo.LotNo); + if (checkTaskInfo == null) + { + // 缁戝畾淇℃伅涓簄ull鍐欏叆鍓旈櫎閫氶亾鍙� + var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0"); + if (ret.IsSucceed) + { + // 鍐欏叆娴佺▼鎺у埗瀛� 2 + var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2"); + if (retVal.IsSucceed) + { + Log.Error("绠辩爜鏈粦瀹氬垎鎷d换鍔★紝杩涜鍓旈櫎銆�"); + break; + } + } + } + else + { + // 涓巔lc浜や簰鍐欏叆鍒嗛亾鍙峰拰娴佺▼鎺у埗瀛� + var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, checkTaskInfo.LineNo); + if (ret.IsSucceed) + { + // 鍐欏叆娴佺▼鎺у埗瀛� 2 + var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2"); + if (retVal.IsSucceed) + { + break; + } + } + } + } } } - } - break; - case "230": - // 娉ㄩ噴2 - { + break; + default: break; + } + } + else + { + // 鎻掔爜浜や簰 + switch (modDevice.Value.ToString()) + { + case "1": + // 鎵樼洏鏉$爜鍙 + { + // 鑾峰彇鎵樼洏鏉$爜閰嶇疆 + var modPalletNo = modDevice.listStation.FirstOrDefault(m => m.Text == "鎵樼洏鏉$爜"); + // 璇诲彇PLC鎵樼洏鏉$爜鍙� + var (res, palletVal) = plcConn.GetPlcDBValue(modPalletNo.PosType, modDevice.DbNumber, modPalletNo.PlcPos); + string palletNo = palletVal.ToString(); + if (string.IsNullOrEmpty(palletNo)) + { + Log.Error(string.Format("{0}锛岃鍙栫殑鎵樼洏鍙蜂负null", modDevice.Text)); + break; + } - } - break; - case "240": - { + // 鏍规嵁宸ヤ綅鍙峰皢鎵樼洏鍙蜂繚瀛樺湪鍒嗛亾琛� + var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false); + if (checkTaskMedel == null) + { + Log.Error(string.Format("鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栧垎閬撳け璐�!", modDevice.StationNum)); + break; + } + checkTaskMedel.PalletNo = palletNo; + var rowCount = _db.Updateable(checkTaskMedel).ExecuteCommand(); + if (rowCount > 0 ) + { + // plc鍐欏叆璇诲彇鎴愬姛琛ㄧず 2 + var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2"); + if (retVal.IsSucceed) + { + // liudl 姝ゅ闇�娣诲姞 + // 閫氱煡鍒嗘嫞鐮佸灈椤垫洿鏂� + } + } + } + break; + case "20": + // 鐢宠鎻掔爜 + { + // 鑾峰彇鎵樼洏鏉$爜閰嶇疆 + var modAddCode = modDevice.listStation.FirstOrDefault(m => m.Text == "鎻掔爜缁撴灉"); + // 鍒ゆ柇鏄惁婕旂ず妯″紡 true锛氭紨绀烘ā寮� false:鐢熶骇妯″紡 + if (PLCTaskAction.boDemo) + { + // 婕旂ず妯″紡鐩存帴鍐欏叆鎻掔爜缁撴灉 1锛氭垚鍔� + var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "1"); + break; + } + else + { + // 鑾峰彇绠辨潯鐮� + // 鑾峰彇绠辨潯鐮侀厤缃� + var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "绠辨潯鐮�"); + var (res, boxVal) = plcConn.GetPlcDBValue(modBoxNo.PosType, modDevice.DbNumber, modBoxNo.PlcPos); + string boxNo = boxVal.ToString(); + if (string.IsNullOrEmpty(boxNo)) + { + Log.Error($"鐮佸灈宸ヤ綅{modDevice.StationNum}锛岀鐮佷负null鎻掔爜澶辫触!璇蜂汉宸ュ己鍒剁粨鎵广��" ); + // 鍐欏叆鎻掑叆缁撴灉 2锛氭彃鐮佸け璐� + var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2"); + + break; + } + // 楠岃瘉绠辩爜琛ㄦ槸鍚﹀瓨鍦ㄦ绠辩爜 + var boxInfo = _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.BoxNo == boxNo).ToList(); + if (boxInfo.Count == 0) + { + Log.Error($"鐮佸灈宸ヤ綅{modDevice.StationNum}锛岀鐮亄boxNo}涓嶅瓨鍦�!璇蜂汉宸ュ己鍒剁粨鎵广��"); + // 鍐欏叆鎻掑叆缁撴灉 2锛氭彃鐮佸け璐� + var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2"); + break; + } + // 鑾峰彇褰撳墠鍒嗛亾鎵樼洏鍙� + var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false); + if (checkTaskMedel == null) + { + Log.Error(string.Format("鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栧垎閬撳け璐�!", modDevice.StationNum)); + break; + } + string palletNo = checkTaskMedel.PalletNo; + if (string.IsNullOrEmpty(palletNo)) + { + Log.Error(string.Format("鑾峰彇鐮佸灈宸ヤ綅{0}涓婄殑鎵樼洏鍙峰け璐ワ紒",modDevice.StationNum)); + break; + } + // 淇敼鎻掔爜琛� + foreach (WcsBoxInfo item in boxInfo) + { + item.PalletNo = palletNo; + item.UpdateTime = DateTime.Now; + } - } - break; - default: break; - } + var rowCount = _db.Updateable(boxInfo).ExecuteCommand(); + if (rowCount > 0) + { + // 鎻掔爜鎴愬姛 + var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "1"); + + //鏄惁缁撴壒绠� + if (boxInfo[0].EndLotFlag == "1" && retVal.IsSucceed) + { + // 瑙﹀彂缁撴壒 瑙g粦鍒嗛亾 + AutoEndLot(boxInfo[0].LotNo, plcConn, "0"); + } + } + else + { + // 鎻掔爜澶辫触 + Log.Error($"绠辩爜{boxNo};鐮佸灈宸ヤ綅{modDevice.StationNum}锛屾彃鐮佸け璐ワ紝璇峰己鍒剁粨鎵�"); + var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2"); + if (retVal.IsSucceed) + { + // 瑙﹀彂缁撴壒 涓嶈В缁戝垎閬� + AutoEndLot(boxInfo[0].LotNo, plcConn, "1"); + } + } + } + } + break; + case "40": + // 璇锋眰缁勬墭锛岀敵璇峰叆搴� + { + // 鏍规嵁宸ヤ綅鍙凤紝鑾峰彇鎵樼洏鍙� + var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false); + // 鏍规嵁宸ヤ綅鍙疯幏鍙� 鎵樼洏绾胯宸ヤ綅鍙风殑閰嶇疆淇℃伅 + var numModel = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business && m.PlcId != modDevice.PlcId); + var posModel = PLCTaskAction.plcPositions.First(m => m.DeviceId == numModel.Id && m.Text == "鐩殑宸ヤ綅" && m.IsDelete == false); + if (checkTaskMedel == null) + { + Log.Error(string.Format("缁勬墭澶辫触鏍规嵁鐮佸灈宸ヤ綅{0}锛岃幏鍙栨墭鐩樺彿澶辫触!", modDevice.StationNum)); + + // 鍐欏叆浜や簰宸ヤ綅鐩爣鍦板潃 + var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234"); + if (retVal.IsSucceed) + { + // 鍐欏叆缁勬墭鍥炲娴佺▼瀛� + retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50"); + } + break; + } + + // 鐮佸灈宸ヤ綅鎵樼洏鍙� + string palletNo = checkTaskMedel.PalletNo; + + // 鏄惁婕旂ず妯″紡 + if (PLCTaskAction.boDemo) + { + // 鐩存帴绠眞ms鐢宠宸烽亾 + var http = new HttpService(); + string TaskNo = "", EndLocate = ""; + string strMsg = http.RequestRoadWay(palletNo, modDevice.StationNum, "1", "2", ref EndLocate, ref TaskNo); + if (strMsg.Contains("-1")) + { + Log.Error(string.Format("鐢宠宸烽亾澶辫触锛岀爜鍨涘伐浣峽0};鍘熷洜{1}", modDevice.StationNum, strMsg)); + break; + } + else + { + // 鑾峰彇鍏ュ簱浠诲姟淇℃伅 + var taskModel = _db.Queryable<WcsTask>().First(m => m.TaskNo == TaskNo && m.IsDelete == false && (m.Status == TaskStatusEnum.Wait || m.Status == TaskStatusEnum.Doing)); + if (taskModel != null) + { + // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅 + string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2"); + + var listResult = new List<Result>(); + + // 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅銆佷换鍔″彿锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅} + listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue)); // 鐩爣宸ヤ綅 + var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟鍙�" && s.IsDelete == false); + listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo)); + var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟绫诲瀷" && s.IsDelete == false); + var taskTypeStr = (int)taskModel.TaskType; + listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString())); + + if (listResult.All(s => s.IsSucceed)) + { + // 鍐欏叆缁勬墭鍥炲娴佺▼瀛� + var retVal1 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50"); + if (retVal1.IsSucceed) + { + // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц + taskModel.Status = TaskStatusEnum.Doing; + _db.Updateable(taskModel).ExecuteCommand(); + + // 鎻掑叆浠诲姟鏄庣粏 + var modInsertTaskMonitor = new WcsTaskMonitor() + { + TaskNo = TaskNo, + PlcId = modDevice.Id, + PlcName = modDevice.Text, + InteractiveMsg = $"鍐欏叆鎸囦护50锛氱敵璇峰贩閬撴垚鍔�", + PalletNo = palletNo, + Status = TaskStatusEnum.Complete, + StartLocat = modDevice.StationNum, + EndLocat = strMsg, + }; + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); + // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈� + HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + } + } + + //// 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅} + //var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue); + //if (retVal.IsSucceed) + //{ + // // 鍐欏叆鐮佸灈浜や簰-缁勬墭鍥炲娴佺▼瀛� + // retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50"); + + // // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц + // taskModel.Status = TaskStatusEnum.Doing; + // _db.Updateable(taskModel).ExecuteCommand(); + //} + } + } + } + else + { + // 鏍规嵁鎵樼洏鍙凤紝灏嗙粍鎵樹俊鎭彃鍏oxinfolog琛� 骞跺垹闄oxinfo琛ㄦ暟鎹� + var boxInfoList = await _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.PalletNo == palletNo).ToListAsync(); + if (boxInfoList.Count <= 0) + { + Log.Error(string.Format("鐢宠宸烽亾澶辫触锛岀爜鍨涘伐浣峽0}锛岀鐮佷俊鎭笉瀛樺湪", modDevice.StationNum)); + + // 鍐欏叆浜や簰宸ヤ綅鐩爣鍦板潃 + var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234"); + if (retVal.IsSucceed) + { + // 鍐欏叆缁勬墭鍥炲娴佺▼瀛� + retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50"); + } + break; + } + string sqlStr = $"insert into WCSBoxInfoLog select * from WCSBoxInfo where IsDelete=0 and PalletNo='{palletNo}'"; + int insertCount = _db.Ado.ExecuteCommand(sqlStr); + if (insertCount > 0) + { + // 缁勬墭鎴愬姛鍚庡皢淇℃伅瀛樺埌log琛� + string sqlStr2 = $"delete from WCSBoxInfoLog where IsDelete=0 and PalletNo='{palletNo}'"; + _db.Ado.ExecuteCommand(sqlStr2); + } + // 鍚慦MS鐢宠宸烽亾 + var http = new HttpService(); + string TaskNo = "", EndLocate = ""; + string strMsg = http.BindRequestRoadWay(checkTaskMedel.OrderNo,palletNo, checkTaskMedel.BoxCount.ToDecimal(),"0", checkTaskMedel.SkuNo, checkTaskMedel.LotNo, "","", boxInfoList, + modDevice.StationNum, "1", "2", ref EndLocate, ref TaskNo); + if (strMsg.Contains("-1")) + { + Log.Error(string.Format("鐢宠宸烽亾澶辫触锛岀爜鍨涘伐浣峽0};鍘熷洜{1}", modDevice.StationNum, strMsg)); + break; + } + else + { + // 鑾峰彇鍏ュ簱浠诲姟淇℃伅 + var taskModel = _db.Queryable<WcsTask>().First(m => m.TaskNo == TaskNo && m.IsDelete == false && m.Status == TaskStatusEnum.Wait); + if (taskModel != null) + { + // 鑾峰彇鍏ュ簱鍙栬揣宸ヤ綅 + string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2"); + + var listResult = new List<Result>(); + // 鍐欏叆鎵樼洏杈撻�佺嚎鐮佸灈宸ヤ綅 鐩殑宸ヤ綅銆佷换鍔″彿锛屽啓鍏ヤ氦浜掓祦绋嬬粍鎵樻垚鍔� 鎵ц鍏ュ簱{鑻ラ渶瑕佸彲浠ュ啓鍏ヤ换鍔″彿绛夌瓑鍏朵粬淇℃伅} + listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue)); // 鐩爣宸ヤ綅 + var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟鍙�" && s.IsDelete == false); + listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo)); + var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "浠诲姟绫诲瀷" && s.IsDelete == false); + var taskTypeStr = (int)taskModel.TaskType; + listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString())); + + if (listResult.All(s => s.IsSucceed)) + { + // 鍐欏叆缁勬墭鍥炲娴佺▼瀛� + var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50"); + if (retVal.IsSucceed) + { + // 灏嗗叆搴撲换鍔$敱姝e湪鎵ц鏀逛负姝e湪鎵ц + taskModel.Status = TaskStatusEnum.Doing; + _db.Updateable(taskModel).ExecuteCommand(); + + // 鎻掑叆浠诲姟鏄庣粏 + var modInsertTaskMonitor = new WcsTaskMonitor() + { + TaskNo = TaskNo, + PlcId = modDevice.Id, + PlcName = modDevice.Text, + InteractiveMsg = $"鍐欏叆鎸囦护50锛氱敵璇峰贩閬撴垚鍔�", + PalletNo = palletNo, + Status = TaskStatusEnum.Complete, + StartLocat = modDevice.StationNum, + EndLocat = strMsg, + }; + // 鎻掑叆浜や簰鏃ュ織 + _db.Insertable(modInsertTaskMonitor).ExecuteCommand(); + // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈� + HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>()); + } + } + } + } + } + } + break; + default:break; + } + } } /// <summary> @@ -1534,7 +2088,78 @@ LedDll Led = new LedDll(); Led.LEDstr(ip, top, content, foot); } - catch { } + catch (Exception ex) + { + Log.Error(ex.Message); + } + } + /// <summary> + /// LED淇℃伅灞曠ず + /// </summary> + /// <param name="ip"></param> + /// <param name="text"></param> + private static void LedDisplay(string ip,string text) + { + try + { + LedDll Led = new LedDll(); + Led.ConsoleLeds(ip, text); + // 璁剧疆瀹炰緥 + //Led.ConsoleLeds("10.18.51.238", $"浠诲姟绫诲瀷:{TaskTypeEnum.Move.GetDescription()}\n\n浠诲姟鍙�:TK2024102100001\n鎵樼洏鍙�:LN000145\n\n璧峰浣�:033\n鐩爣浣�:R01-02010102"); + } + catch (Exception ex) + { + Log.Error(ex.Message); + } + } + + /// <summary> + /// 鑷姩缁撴壒 + /// </summary> + /// <param name="lotNo">鎵规鍙�</param> + /// <param name="plcConn">Plc杩炴帴</param> + /// <param name="status">鏄惁瑙g粦鍒嗛亾 0锛氳В缁� 1锛氱粦瀹�</param> + private static void AutoEndLot(string lotNo,PLCUtil plcConn,string status) + { + try + { + if (string.IsNullOrWhiteSpace(lotNo)) + { + Console.WriteLine("鎵规鍙蜂负nul"); + } + var checkTaskList = _db.Queryable<WcsCheckTask>().Where(w => w.LotNo == lotNo && w.Status == "1").ToList(); + if (checkTaskList.Count <= 0) + { + Console.WriteLine("鏈壘鍒板垎閬撶粦瀹氫俊鎭�"); + } + foreach (var item in checkTaskList) + { + #region#缁橮LC鍐欏叆缁撴壒鎵规鍙� + var ret = plcConn.SetPlcDBValue(item.PosTypeLot, item.DbNumber, item.PosLot, "1"); + if (ret.IsSucceed) + { + //鍐欏叆娴佺▼瀛楁垚鍔熷悗鏇存柊鍒嗘嫞浠诲姟 liudl 鏈�鍚庝竴鎵樼洏鐢宠瀹屽叆搴撴墠鍙竻绌� + //item.OrderNo = ""; + //item.TaskNo = ""; + //item.LotNo = ""; + //item.SkuNo = ""; + //item.SkuName = ""; + //item.BoxType = ""; + //item.Qty = 0; + //item.PZNo = ""; + item.Status = status; // 缁戝畾鍒嗛亾 0锛氳В缁� 1锛氱粦瀹� + + //鏇存柊鍒嗘嫞浠诲姟 + _db.Updateable(item).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync(); + } + #endregion + } + } + catch (Exception ex) + { + Log.Error(ex.Message); + throw; + } } private static void Test(WcsDeviceDto modDevice) -- Gitblit v1.8.0