From 9a7c4fea85f85824dddeac9e6ce6ebb75ccee679 Mon Sep 17 00:00:00 2001 From: chengsc <11752@DESKTOP-DS49RCP> Date: 星期二, 29 四月 2025 15:26:15 +0800 Subject: [PATCH] 修改问题晚上充电逻辑 --- Admin.NET/WCS.Application/PLC/PLCService.cs | 198 +++++++++++++++++++++++++++---------------------- 1 files changed, 108 insertions(+), 90 deletions(-) diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs index a25f1e5..e8a2fe2 100644 --- a/Admin.NET/WCS.Application/PLC/PLCService.cs +++ b/Admin.NET/WCS.Application/PLC/PLCService.cs @@ -170,68 +170,66 @@ int valueTaskStr = Convert.ToInt32(valueTask); //鑾峰彇浠诲姟淇℃伅 鏍规嵁 浠诲姟鍙枫�佸皬杞︾紪鍙� var carTask = _db.Queryable<WcsCarTasks>().First(m=>m.IsDelete == false && m.Status == TaskStatusEnum.Doing && m.CarTaskNo == valueTaskStr && m.CarNo == modDevice.PlcIdIP); - if (carTask == null) + if (carTask != null) { //var modRests = modDevice.listStation.FirstOrDefault(s => s.Text == "澶嶄綅"); //plcConn.SetDBValue(modRests.PosType, modRests.PlcPos, "1");//娌℃湁鎵惧埌浠诲姟 澶嶄綅 - return; - } - - var modFinshTask = _db.Queryable<WcsTask>().First(s => s.Status == TaskStatusEnum.Doing && s.Type == PLCTypeEnum.ShuttleCar && s.TaskNo == carTask.TaskNo); - if (modFinshTask == null) - { - break;//娌℃湁鏌ヨ鍒版�讳换鍔� - } - if (carTask != null && carTask.Status != TaskStatusEnum.Complete) - { - carTask.Status = TaskStatusEnum.Complete; - carTask.UpdateTime = DateTime.Now; - _db.Updateable(carTask).ExecuteCommand(); - //娣诲姞浠诲姟鏄庣粏 - var taskMonitor = new WcsTaskMonitor() - { - TaskNo = carTask.TaskNo, - PlcName = modDevice.Text, - InteractiveMsg = $"绌挎杞﹀弽棣堜换鍔″畬鎴�" - }; - _db.Insertable(taskMonitor).ExecuteCommand(); - //涓嬪彂浠诲姟鏃ュ織 - HubUtil.PublicTaskMonitor(taskMonitor.Adapt<WcsTaskMonitorOutput>()); - } - //鑾峰彇璺緞2鐨勪换鍔� 涓嬪彂 - carTaskNext = _db.Queryable<WcsCarTasks>().Where(m => m.IsDelete == false && m.TaskNo == carTask.TaskNo && m.CarNo == modDevice.PlcIdIP && m.Status <= TaskStatusEnum.Doing).OrderBy(m => m.CreateTime).First(); - //鎬讳换鍔′笅娌℃湁鍏朵粬鏈墽琛屽皬杞︾殑浠诲姟 鍙樻洿鎬讳换鍔′俊鎭� - if (carTaskNext == null && modFinshTask != null && modFinshTask.Status != TaskStatusEnum.Complete) - { - modFinshTask.Status = TaskStatusEnum.Complete; - modFinshTask.FinishDate = DateTime.Now; - _db.Updateable(modFinshTask).ExecuteCommand(); - - //鍒ゆ柇浠诲姟鏄惁鍏呯數浠诲姟,涓嬪彂寮�濮嬪厖鐢靛懡浠� - if (modFinshTask.Levels == 888) + var modFinshTask = _db.Queryable<WcsTask>().First(s => s.Status == TaskStatusEnum.Doing && s.Type == PLCTypeEnum.ShuttleCar && s.TaskNo == carTask.TaskNo); + if (modFinshTask == null) { - //鍐欏叆寮�濮嬪厖鐢� - var modCd = modDevice.listStation.FirstOrDefault(s => s.Text == "鍏呯數鍛戒护"); - plcConn.SetDBValue(modCd.PosType, modCd.PlcPos.ToString(), "2"); + break;//娌℃湁鏌ヨ鍒版�讳换鍔� + } + if (carTask != null && carTask.Status != TaskStatusEnum.Complete) + { + carTask.Status = TaskStatusEnum.Complete; + carTask.UpdateTime = DateTime.Now; + _db.Updateable(carTask).ExecuteCommand(); + //娣诲姞浠诲姟鏄庣粏 + var taskMonitor = new WcsTaskMonitor() + { + TaskNo = carTask.TaskNo, + PlcName = modDevice.Text, + InteractiveMsg = $"绌挎杞﹀弽棣堜换鍔″畬鎴�" + }; + _db.Insertable(taskMonitor).ExecuteCommand(); + //涓嬪彂浠诲姟鏃ュ織 + + HubUtil.PublicTaskMonitor(taskMonitor.Adapt<WcsTaskMonitorOutput>()); } - - //鍙嶉WMS绯荤粺 浠诲姟瀹屾垚 - //HttpService httpService = new HttpService(); - //var requestMode = new TaskRequestWMS() - //{ - // TaskNo = modFinshTask.TaskNo, - // PalletNo = modFinshTask.PalletNo, - // TaskType = ((int)modFinshTask.TaskType).ToString(), - // TaskStatus = ((int)TaskStatusEnum.Complete).ToString() - //}; - //var modResponseTask = httpService.RequestTask(requestMode).Result; - //modFinshTask.IsSuccess = TaskSuccessEnum.Success; - //_db.Updateable(modFinshTask).ExecuteCommand(); - HubUtil.PublicTask(modFinshTask.Adapt<WcsTaskOutput>()); + //鑾峰彇璺緞2鐨勪换鍔� 涓嬪彂 + carTaskNext = _db.Queryable<WcsCarTasks>().Where(m => m.IsDelete == false && m.TaskNo == carTask.TaskNo && m.CarNo == modDevice.PlcIdIP && m.Status <= TaskStatusEnum.Doing).OrderBy(m => m.CreateTime).First(); + //鎬讳换鍔′笅娌℃湁鍏朵粬鏈墽琛屽皬杞︾殑浠诲姟 鍙樻洿鎬讳换鍔′俊鎭� + if (carTaskNext == null && modFinshTask != null && modFinshTask.Status != TaskStatusEnum.Complete) + { + modFinshTask.Status = TaskStatusEnum.Complete; + modFinshTask.FinishDate = DateTime.Now; + _db.Updateable(modFinshTask).ExecuteCommand(); + //鍒ゆ柇浠诲姟鏄惁鍏呯數浠诲姟,涓嬪彂寮�濮嬪厖鐢靛懡浠� + if (modFinshTask.Levels == 888) + { + //鍐欏叆寮�濮嬪厖鐢� + var modCd = modDevice.listStation.FirstOrDefault(s => s.Text == "鍏呯數鍛戒护"); + plcConn.SetDBValue(modCd.PosType, modCd.PlcPos.ToString(), "2"); + } + + //鍙嶉WMS绯荤粺 浠诲姟瀹屾垚 + //HttpService httpService = new HttpService(); + //var requestMode = new TaskRequestWMS() + //{ + // TaskNo = modFinshTask.TaskNo, + // PalletNo = modFinshTask.PalletNo, + // TaskType = ((int)modFinshTask.TaskType).ToString(), + // TaskStatus = ((int)TaskStatusEnum.Complete).ToString() + //}; + //var modResponseTask = httpService.RequestTask(requestMode).Result; + //modFinshTask.IsSuccess = TaskSuccessEnum.Success; + //_db.Updateable(modFinshTask).ExecuteCommand(); + HubUtil.PublicTask(modFinshTask.Adapt<WcsTaskOutput>()); + + } } - } WcsTask modTask; @@ -260,12 +258,12 @@ var modStationZ = modDevice.listStation.FirstOrDefault(s => s.Text == "鍥涘悜杞︿綅缃�(Z)"); var (resultz, valuez) = plcConn.GetDBValue(modStationZ.PosType, modStationZ.PlcPos); var carXYZ = valuex.ToString().PadLeft(2, '0') + valuey.ToString().PadLeft(2, '0') + valuez.ToString().PadLeft(2, '0'); - if (modTask == null || carTaskNext == null) + if (modTask == null) { //璇诲彇灏忚溅鐢甸噺 var modPosCarDl = modDevice.listStation.FirstOrDefault(s => s.Text == "鐢垫睜鐢甸噺"); var (resultDl, valueDl) = plcConn.GetDBValue(modPosCarDl.PosType, modPosCarDl.PlcPos); - if (resultDl.IsSucceed && valueDl < FourWayCarDLEnum.Dl) + if (resultDl.IsSucceed && valueDl < (int)FourWayCarDLEnum.Dl) { var endLocateCar = ""; if (valuez == 1) @@ -280,24 +278,29 @@ { return; // 灞傛暟閿欒 } - //娣诲姞灏忚溅鍏呯數浣嶇疆 - WcsTask modCarTask = new WcsTask() + var getCdTask = _db.Queryable<WcsTask>().First(m => m.IsDelete == false && m.Levels == 888 && m.EndLocate == endLocateCar && m.Type == PLCTypeEnum.ShuttleCar && m.Status <= TaskStatusEnum.Doing); + if (getCdTask == null) { - TaskNo = _taskService.GetTaskCode(), - TaskType = TaskTypeEnum.Move, - Type = PLCTypeEnum.ShuttleCar, - StartLocate = carXYZ, - EndLocate = endLocateCar, - PalletNo = "", - Status = TaskStatusEnum.Wait, - Levels = 888, //鍏呯數绛夌骇浼樺厛浠诲姟绛夌骇 - Origin = "WCS", - CarIp = modDevice.PlcIdIP - }; - _db.Insertable(modCarTask).ExecuteCommand(); - HubUtil.PublicTask(modCarTask.Adapt<WcsTaskOutput>()); + //娣诲姞灏忚溅鍏呯數浣嶇疆 + WcsTask modCarTask = new WcsTask() + { + TaskNo = _taskService.GetTaskCode(), + TaskType = TaskTypeEnum.Move, + Type = PLCTypeEnum.ShuttleCar, + StartLocate = carXYZ, + EndLocate = endLocateCar, + PalletNo = "", + Status = TaskStatusEnum.Wait, + Levels = 888, //鍏呯數绛夌骇浼樺厛浠诲姟绛夌骇 + Origin = "WCS", + CarIp = modDevice.PlcIdIP + }; + _db.Insertable(modCarTask).ExecuteCommand(); + HubUtil.PublicTask(modCarTask.Adapt<WcsTaskOutput>()); + } + } - else if(resultDl.IsSucceed && valueDl < FourWayCarDLEnum.Dl2) + else if(resultDl.IsSucceed && valueDl < (int)FourWayCarDLEnum.Dl2) { //鍒ゆ柇灏忚溅鏄惁鏈夌┖闂叉椂闂磋褰� 娌℃湁锛氭坊鍔� 鏈夛細鍒ゆ柇褰撳墠鏃堕棿涓庤褰曟椂闂存槸鍚︽弧瓒�5鍒嗛挓 婊¤冻锛氭坊鍔犺灏忚溅鍘诲厖鐢典换鍔� var carTime = _db.Queryable<WcsCarTime>().First(m => m.IsDelete == false && m.CarIp == modDevice.PlcIdIP); @@ -328,32 +331,37 @@ var endLocateCar = ""; if (valuez == 1) { - endLocateCar = "011201"; + endLocateCar = "210401"; } else if (valuez == 2) { - endLocateCar = "011202"; + endLocateCar = "210402"; } else { return; // 灞傛暟閿欒 } - //娣诲姞灏忚溅鍏呯數浣嶇疆 - WcsTask modCarTask = new WcsTask() + var getCdTask = _db.Queryable<WcsTask>().First(m => m.IsDelete == false && m.Levels == 888 && m.EndLocate == endLocateCar && m.Type == PLCTypeEnum.ShuttleCar && m.Status <= TaskStatusEnum.Doing); + if (getCdTask == null) { - TaskNo = _taskService.GetTaskCode(), - TaskType = TaskTypeEnum.Move, - Type = PLCTypeEnum.ShuttleCar, - StartLocate = carXYZ, - EndLocate = endLocateCar, - PalletNo = "", - Status = TaskStatusEnum.Wait, - Levels = 888, //鍏呯數绛夌骇浼樺厛浠诲姟绛夌骇 - Origin = "WCS", - CarIp = modDevice.PlcIdIP - }; - _db.Insertable(modCarTask).ExecuteCommand(); - HubUtil.PublicTask(modCarTask.Adapt<WcsTaskOutput>()); + //娣诲姞灏忚溅鍏呯數浣嶇疆 + WcsTask modCarTask = new WcsTask() + { + TaskNo = _taskService.GetTaskCode(), + TaskType = TaskTypeEnum.Move, + Type = PLCTypeEnum.ShuttleCar, + StartLocate = carXYZ, + EndLocate = endLocateCar, + PalletNo = "", + Status = TaskStatusEnum.Wait, + Levels = 888, //鍏呯數绛夌骇浼樺厛浠诲姟绛夌骇 + Origin = "WCS", + CarIp = modDevice.PlcIdIP + }; + _db.Insertable(modCarTask).ExecuteCommand(); + HubUtil.PublicTask(modCarTask.Adapt<WcsTaskOutput>()); + } + } } @@ -364,7 +372,10 @@ return; } - + if (carTaskNext == null) + { + return; + } if (carTaskNext.Status == TaskStatusEnum.Doing) { Thread.Sleep(3000); @@ -462,6 +473,13 @@ carTaskNext.CarTaskNo = carTaskNo; _db.Updateable(carTaskNext).ExecuteCommand(); //娓呴櫎灏忚溅绌洪棽鏃堕棿 + var carTimeClear = _db.Queryable<WcsCarTime>().First(m=>m.IsDelete == false && m.CarIp == modDevice.PlcIdIP); + if (carTimeClear!= null) + { + carTimeClear.CarTime = null; + carTimeClear.UpdateTime = DateTime.Now; + _db.Updateable(carTimeClear).ExecuteCommand(); + } var taskMonitor = new WcsTaskMonitor() { TaskNo = carTaskNext.TaskNo, -- Gitblit v1.8.0