From f80938e8a03d9343672b4fb3179836b019f6b9d8 Mon Sep 17 00:00:00 2001 From: 海波 张 <2956280567@qq.com> Date: 星期六, 28 六月 2025 21:38:46 +0800 Subject: [PATCH] 0628 --- core/TaskCore.cs | 66 +++++++++++++++++++++++--------- 1 files changed, 47 insertions(+), 19 deletions(-) diff --git a/core/TaskCore.cs b/core/TaskCore.cs index c4fd023..19cbf6f 100644 --- a/core/TaskCore.cs +++ b/core/TaskCore.cs @@ -11,6 +11,7 @@ using System.Reflection; using System.Threading.Tasks; using System.Web.Services.Description; +using Top.Api; using static HH.WCS.ZhongCeJinTan.api.ApiModel; using static HH.WCS.ZhongCeJinTan.util.Settings; @@ -19,7 +20,6 @@ internal class TaskCore { public static void OperateTaskStatus(AgvTaskState model) { - var wmsTask = TaskHelper.GetTask(model.task_no); var db = new SqlHelper<object>().GetInstance(); @@ -33,7 +33,7 @@ switch (model.state) { case 1: - TaskHelper.Begin(wmsTask,model.forklift_no); + TaskHelper.Begin(wmsTask,model.forklift_no.ToString()); //鑳庨潰浜や簰 TaskHelper.TmSafety(wmsTask); break; @@ -62,12 +62,25 @@ } break; case 2: - TaskHelper.End(wmsTask); + //绌烘墭鍑烘垨鑰呮弧鎵樺嚭浠诲姟瀹屾垚鍒ゆ柇鏄惁瑕佹彁楂樺叆搴撲紭鍏堢骇 + + LogHelper.Info($"浠诲姟{wmsTask.S_CODE}瀹屾垚锛屽垽鏂叆搴撲紭鍏堢骇", "鍏ュ簱浼樺厛绾�); + TaskProcess.inPri(wmsTask); + TaskHelper.End(wmsTask); break; case 7: - //agv鎵ц閫氱煡 - WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no); + var wcsTask1 = TaskHelper.GetTaskByWorkNo(wmsTask.S_OP_CODE, "wcs"); + if (wcsTask1!=null) + { + //agv鎵ц閫氱煡 wcs鍙栨秷 + WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no.ToString()); + if (!TaskHelper.CheckActionRecordExist(wcsTask1.S_CODE, "6")) + { + TaskHelper.Fail(wcsTask1); + TaskProcess.OperateStatus(wcsTask1, 7); + } + } TaskHelper.Fail(wmsTask); TaskProcess.OperateStatus(wmsTask, 7); @@ -77,32 +90,47 @@ ContainerHelper.delCntr(wmsTask.S_CNTR_CODE); ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE); } - //鍑哄簱鍙栨秷鍒ゆ柇鎺ラ┏浣嶆槸鍚︽湁璐э紝鏈夎揣闇�瑙g粦 - if (!WcsTask.WcsCvstate(wmsTask)) - { - LogHelper.Info($"Wcs绔嬪簱鎺ラ┏浣嶆棤璐э紝瑙g粦璐т綅:{wmsTask.S_START_LOC}", "绔嬪簱"); - TaskProcess.OperateStatus(wmsTask, 4); - ContainerHelper.delCntr(wmsTask.S_CNTR_CODE); - ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE); - } - break; + + //鍑哄簱鍙栨秷鍒ゆ柇鎺ラ┏浣嶆槸鍚︽湁璐э紝鏈夎揣闇�瑙g粦 + if (!WcsTask.WcsCvstate(wmsTask)) + { + LogHelper.Info($"Wcs绔嬪簱鎺ラ┏浣嶆棤璐э紝瑙g粦璐т綅:{wmsTask.S_START_LOC}", "绔嬪簱"); + TaskProcess.OperateStatus(wmsTask, 4); + ContainerHelper.delCntr(wmsTask.S_CNTR_CODE); + ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE); + } + break; } - TaskHelper.AddActionRecord(wmsTask.S_CODE, model.state, model.forklift_no, model.ext_data); - + TaskHelper.AddActionRecord(wmsTask.S_CODE, model.state, model.forklift_no.ToString()); } else { //瀹夊叏璇锋眰绛�- TaskProcess.OperateReq(model.task_no, model.state, model.forklift_no, model.ext_data); + TaskProcess.OperateReq(model.task_no, model.state, model.forklift_no.ToString()); } } - } - + public static void addAgvActionState(AgvTaskState model) + { + var agvAction = new AgvActionState(); + agvAction.state = model.state; + agvAction.task_no = model.task_no; + agvAction.forklift_no = model.forklift_no.ToString(); + if (TaskHelper.CreateAgvActionState(agvAction)) + { + LogHelper.Info("娣诲姞agv鍔ㄤ綔缂撳瓨鎴愬姛淇℃伅" + JsonConvert.SerializeObject(agvAction), "agv鍔ㄤ綔缂撳瓨"); + } + else { + LogHelper.Info("娣诲姞agv鍔ㄤ綔缂撳瓨澶辫触淇℃伅" + JsonConvert.SerializeObject(agvAction), "agv鍔ㄤ綔缂撳瓨"); + } + } + + + /// <summary> -- Gitblit v1.9.1