From 96b1afcbf80cd6b12c1108b61ba2cef1345b1398 Mon Sep 17 00:00:00 2001 From: xxyy <cathay_xy@163.com> Date: 星期三, 12 二月 2025 17:33:20 +0800 Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/HuaYiZhongHeng/BaiBuLiKu --- Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs | 63 ++++++++++++++++++++----------- 1 files changed, 40 insertions(+), 23 deletions(-) diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs index 7e35a13..b66182f 100644 --- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs +++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs @@ -1,18 +1,10 @@ -锘縰sing Castle.Components.DictionaryAdapter.Xml; -using log4net.Core; -using Masuit.Tools; -using System.CodeDom; -using System.Threading.Tasks; -using WIDESEA_Common; +锘縰sing Masuit.Tools; using WIDESEA_Common.CustomModels; //using WIDESEA_Common.CustomModels; -using WIDESEA_Core.BaseRepository; using WIDESEA_Core.Const; using WIDESEA_DTO.MOM; using WIDESEA_DTO.WMS; -using WIDESEA_StorageTaskRepository; -using WIDESEAWCS_BasicInfoRepository; using WIDESEAWCS_Model.Models; using WIDESEAWCS_QuartzJob.Models; @@ -123,7 +115,6 @@ { throw new Exception(ex.Message); } - } /// <summary> @@ -209,7 +200,8 @@ TaskType = (int)TaskOutboundTypeEnum.InToOut, TaskNum = await BaseDal.GetTaskNo(), Creater = "Systeam", - ProductionLine = result.ProductionLine + ProductionLine = result.ProductionLine, + ProcessCode = result.ProcessCode, }; return taskNG; } @@ -267,7 +259,8 @@ TaskType = (int)TaskOutboundTypeEnum.InToOut, TaskNum = await BaseDal.GetTaskNo(), Creater = "Systeam", - ProductionLine = result.ProductionLine + ProductionLine = result.ProductionLine, + ProcessCode = result.ProcessCode, }; return taskNG; } @@ -300,7 +293,8 @@ TaskType = (int)TaskOutboundTypeEnum.InToOut, TaskNum = await BaseDal.GetTaskNo(), Creater = "Systeam", - ProductionLine = result.ProductionLine + ProductionLine = result.ProductionLine, + ProcessCode = result.ProcessCode, }; return task; } @@ -377,7 +371,8 @@ TaskType = (int)TaskOutboundTypeEnum.InToOut, TaskNum = await BaseDal.GetTaskNo(), Creater = "Systeam", - ProductionLine = result.ProductionLine + ProductionLine = result.ProductionLine, + ProcessCode = result.ProcessCode, }; return taskNG; } @@ -407,7 +402,7 @@ ////// 璋冪敤GetProcessResponseAsync鏂规硶锛岃幏鍙栧伐鑹哄搷搴� ////var processResponse = await GetProcessResponseAsync(process, input.Position); var isBox = await _boxingInfoRepository.AddDataNavAsync(boxing); - #endregion + #endregion 鍏ュ簱浠诲姟 } var task = new Dt_Task @@ -427,6 +422,7 @@ TaskNum = await BaseDal.GetTaskNo(), Creater = "Systeam", ProductionLine = result.ProductionLine, + ProcessCode = result.ProcessCode, }; int lastStatus = locationInfo.LocationStatus; ConsoleHelper.WriteSuccessLine($"淇敼鍓嶏細" + lastStatus.ToString()); @@ -439,11 +435,12 @@ return task; } - #endregion 鍏ュ簱浠诲姟 + #endregion 璇锋眰浠诲姟鍏ュ簱 #region 搴撲綅鍒嗛厤 #region 鑾峰彇璐т綅 + /// <summary> /// /// </summary> @@ -477,9 +474,11 @@ return null; } } + #endregion 鑾峰彇璐т綅 #region 寮傚父鍙e叆搴撹幏鍙栧簱浣� + private async Task<DtLocationInfo> RequestLocationByAbnormal(RequestTaskDto requestTask, bool isCheckRequest = false) { try @@ -507,7 +506,8 @@ return null; } } - #endregion + + #endregion 寮傚父鍙e叆搴撹幏鍙栧簱浣� #endregion 搴撲綅鍒嗛厤 @@ -530,6 +530,7 @@ #endregion 璇锋眰浠诲姟鍏ュ簱 #region 鍒涘缓绌烘鍑哄簱浠诲姟 + public async Task<Dt_Task> CreateEmptyOutTaskAsync(RequestTaskDto input, Dt_StationManager stationManager) { try @@ -571,6 +572,7 @@ throw new Exception(ex.Message); } } + #endregion #region 鐩存帴鍑哄簱浠诲姟瀹屾垚 @@ -594,11 +596,13 @@ return content.Error(ex.Message); } } + #endregion #region 寮傚父鍙d换鍔℃娴� + /// <summary> - /// 寮傚父鎺掑嚭鍙e叆搴撴牎楠� 鎵�鏈夊紓甯镐氦缁橶CS鍋氬師鍦板潃NG澶勭悊 + /// 寮傚父鎺掑嚭鍙e叆搴撴牎楠� 鎵�鏈夊紓甯镐氦缁橶CS鍋氬師鍦板潃NG澶勭悊 /// </summary> /// <param name="input"></param> /// <param name="stationManager"></param> @@ -622,7 +626,7 @@ // 璋冪敤GetTrayCellStatusAsync鏂规硶锛岃幏鍙栨暣鐩樼數鑺� WebResponseContent content = await GetTrayCellStatusAsync(trayCells); // 濡傛灉鐘舵�佷负false锛屽垯杩斿洖content - if (!content.Status) //鑾峰彇鏁寸洏鐢佃姱鏁版嵁锛� 濡傚紓甯� 浣跨敤绌烘绫诲瀷鍏ュ簱 + if (!content.Status) //鑾峰彇鏁寸洏鐢佃姱鏁版嵁锛� 濡傚紓甯� 浣跨敤绌烘绫诲瀷鍏ュ簱 { ConsoleHelper.WriteErrorLine(content.Message); throw new Exception("MOM鏁寸洏鐢佃姱灞炴�ц幏鍙栧紓甯�"); @@ -654,6 +658,7 @@ TaskNum = await BaseDal.GetTaskNo(), Creater = "Systeam", ProductionLine = result.ProductionLine, + ProcessCode = result.ProcessCode, }; return Epmtytask; } @@ -715,6 +720,7 @@ TaskNum = await BaseDal.GetTaskNo(), Creater = "Systeam", ProductionLine = result.ProductionLine, + ProcessCode = result.ProcessCode, }; var isBox = await _boxingInfoRepository.AddDataNavAsync(boxing); @@ -735,9 +741,11 @@ throw new Exception(ex.Message); } } + #endregion #region 绉诲簱浠诲姟浜嬪姟 + private async Task<bool> ExecuteTransaction(DtStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo fromLocation, DtLocationInfo toLocation, int taskId) { _unitOfWorkManage.BeginTran(); @@ -780,6 +788,7 @@ #endregion MyRegion #region 妫�娴嬮珮娓╁簱鏄惁鏈夊彲鍑哄簱搴撳瓨 + public WebResponseContent StockCheckingAsync() { WebResponseContent webResponseContent = new WebResponseContent(); @@ -864,6 +873,7 @@ #endregion 妫�娴嬮珮娓╁簱鏄惁鏈夊彲鍑哄簱搴撳瓨 #region 甯告俯琛ョ┖鎵樼洏鑷冲垎瀹� + public async Task<WebResponseContent> GetFROutTrayToCW(RequestTaskDto taskDTO) { WebResponseContent content = new WebResponseContent(); @@ -927,7 +937,6 @@ ConsoleHelper.WriteColorLine(station.Roadway, ConsoleColor.Magenta); var stackers = station.Roadway.Split(',').ToList(); - var devices = SqlSugarHelper.DbWCS.Queryable<Dt_DeviceInfo>() .Where(x => x.DeviceStatus == "1") .Where(x => stackers.Contains(x.DeviceCode)) @@ -953,6 +962,13 @@ #endregion + #region 甯告俯3鍑哄簱鑷冲寘瑁� + + /// <summary> + /// 甯告俯3鍑哄簱鑷冲寘瑁� + /// </summary> + /// <param name="json"></param> + /// <returns></returns> public async Task<WebResponseContent> RequestOutTaskToBZAsync(RequestTaskDto json) { WebResponseContent content = new WebResponseContent(); @@ -993,6 +1009,7 @@ TaskNum = await BaseDal.GetTaskNo(), Creater = "Systeam", ProductionLine = stockInfo.ProductionLine, + ProcessCode = stockInfo.ProcessCode, }; WMSTaskDTO taskDTO = CreateTaskDTO(task); @@ -1014,9 +1031,10 @@ } } - + #endregion #region 鐏鍑哄簱 + public WebResponseContent EmergencyTask(object obj) { WebResponseContent content = new WebResponseContent(); @@ -1062,7 +1080,6 @@ { throw new Exception("宸叉坊鍔犵伀璀﹀嚭搴撲换鍔�"); } - int taskNum = BaseDal.GetTaskNo().Result; Dt_Task task = new Dt_Task @@ -1126,7 +1143,6 @@ LogFactory.GetLog("DTS鐏鍑哄簱").Info(true, $"\r\r--------------------------------------"); LogFactory.GetLog("DTS鐏鍑哄簱").Info(true, obj.ToJsonString()); return content.OK(); - } catch (Exception ex) { @@ -1135,5 +1151,6 @@ return content.Error(ex.Message); } } + #endregion } \ No newline at end of file -- Gitblit v1.9.3