From 4f39dcc195f28fa275fc2d065fbf1bf6a46c21b7 Mon Sep 17 00:00:00 2001 From: dengjunjie <dengjunjie@hnkhzn.com> Date: 星期二, 17 六月 2025 00:41:18 +0800 Subject: [PATCH] 优化出入库逻辑 --- 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs | 248 ++++++++++++++++++++++--------------------------- 1 files changed, 110 insertions(+), 138 deletions(-) diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs" index af65e7b..cbee66c 100644 --- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs" +++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs" @@ -17,24 +17,12 @@ using AutoMapper; using Newtonsoft.Json; -using OfficeOpenXml.FormulaParsing.Excel.Functions.Text; using SqlSugar; -using System; -using System.Collections.Generic; -using System.ComponentModel; using System.Diagnostics.CodeAnalysis; -using System.Linq; -using System.Reflection; -using System.Reflection.Emit; -using System.Security.Policy; -using System.Text; -using System.Threading.Tasks; using WIDESEA_Comm.Http; using WIDESEA_Common.Log; using WIDESEAWCS_Core; using WIDESEAWCS_Core.BaseServices; -using WIDESEAWCS_Core.DB.Models; -using WIDESEAWCS_Core.Enums; using WIDESEAWCS_DTO.TaskInfo; using WIDESEAWCS_ITaskInfoRepository; using WIDESEAWCS_ITaskInfoService; @@ -44,6 +32,8 @@ using WIDESEAWCS_Core.Helper; using WIDESEA_Core.Enums; using WIDESEAWCS_Core.BaseRepository; +using WIDESEAWCS_DTO.TaskEnum; + namespace WIDESEAWCS_TaskInfoService { @@ -59,7 +49,7 @@ private Dictionary<string, OrderByType> _taskOrderBy = new() { - {nameof(Dt_Task.Grade),OrderByType.Desc }, + {nameof(Dt_Task.Grade),OrderByType.Asc }, {nameof(Dt_Task.CreateDate),OrderByType.Asc}, }; @@ -111,6 +101,10 @@ { _unitOfWorkManage.RollbackTran(); content = WebResponseContent.Instance.Error($"{ex.Message}"); + } + finally + { + WriteLog.GetLog("鎺ユ敹浠诲姟").Write($"鎺ユ敹鍙傛暟锛歿JsonConvert.SerializeObject(taskDTOs)}{Environment.NewLine}鎶ユ枃锛歿JsonConvert.SerializeObject(content)}", "鎺ユ敹浠诲姟"); } return content; } @@ -190,11 +184,11 @@ /// <returns></returns> public Dt_Task? QuertStackerCraneTask(string deviceNo, TaskTypeGroup? taskTypeGroup = null) { - if(taskTypeGroup == null) + if (taskTypeGroup == null) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && (TaskInboundTypes.Contains(x.TaskType) && x.TaskStatus == (int)TaskInStatusEnum.Line_InFinish || TaskOutboundTypes.Contains(x.TaskType) && x.TaskStatus == (int)TaskOutStatusEnum.OutNew), TaskOrderBy); - if(taskTypeGroup.Value == TaskTypeGroup.InboundGroup) + if (taskTypeGroup.Value == TaskTypeGroup.InboundGroup) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskInboundTypes.Contains(x.TaskType) && x.TaskStatus == (int)TaskInStatusEnum.Line_InFinish, TaskOrderBy); - if(taskTypeGroup.Value == TaskTypeGroup.OutbondGroup) + if (taskTypeGroup.Value == TaskTypeGroup.OutbondGroup) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskStatus == (int)TaskOutStatusEnum.OutNew, TaskOrderBy); return null; } @@ -205,20 +199,9 @@ /// <param name="deviceNo">璁惧缂栧彿</param> /// <param name="currentAddress">褰撳墠鍦板潃</param> /// <returns>杩斿洖浠诲姟瀹炰綋瀵硅薄锛屽彲鑳戒负null</returns> - public Dt_Task QueryStackerCraneTask(string deviceNo, string currentAddress = "") + public Dt_Task? QueryStackerCraneTask(string deviceNo, string currentAddress = "") { - Dt_Task taskGrade = BaseDal.QueryFirst(x => x.Grade == 0, TaskOrderBy); - if (taskGrade != null) - { - return taskGrade; - } - else - { - if (string.IsNullOrEmpty(currentAddress)) - return BaseDal.QueryFirst(x => x.Roadway == deviceNo && (TaskTypeEnums.Contains(x.TaskType) && (x.TaskStatus == (int)TaskInStatusEnum.InNew || x.TaskStatus == (int)TaskOutStatusEnum.OutNew)), TaskOrderBy); - else - return BaseDal.QueryFirst(x => x.Roadway == deviceNo && x.CurrentAddress == currentAddress && (TaskTypeEnums.Contains(x.TaskType) && x.TaskStatus == (int)TaskInStatusEnum.Line_InFinish || TaskOutboundTypes.Contains(x.TaskType) && x.TaskStatus == (int)TaskOutStatusEnum.OutNew), TaskOrderBy); - } + return BaseDal.QueryFirst(x => x.TaskStatus == (int)InTaskStatusEnum.InNew || x.TaskStatus == (int)OutTaskStatusEnum.OutNew || x.TaskStatus == (int)RelocationTaskStatusEnum.RelocationNew, TaskOrderBy); } /// <summary> @@ -229,7 +212,7 @@ /// <returns>杩斿洖浠诲姟瀹炰綋瀵硅薄锛屽彲鑳戒负null</returns> public Dt_Task QueryStackerCraneInTask(string deviceNo, string currentAddress = "") { - Dt_Task taskGrade = BaseDal.QueryFirst(x => x.Grade == 0, TaskOrderBy); + Dt_Task taskGrade = BaseDal.QueryFirst(x => true, TaskOrderBy); if (taskGrade != null) { return taskGrade; @@ -262,20 +245,6 @@ } } /// <summary> - /// 鏍规嵁璁惧缂栧彿銆佸綋鍓嶅湴鍧�鎸夌収浼樺厛绾т互鍙婂垱寤烘椂闂存帓搴忔煡璇换鍔℃睜鍏ュ簱绫诲瀷鐨勬柊澧炵殑浠诲姟 - /// </summary> - /// <param name="deviceNo">璁惧缂栧彿</param> - /// <param name="currentAddress">褰撳墠鍦板潃</param> - /// <returns>杩斿洖浠诲姟瀹炰綋瀵硅薄锛屽彲鑳戒负null</returns> - public Dt_Task QueryStackerCraneRelocationTask(string deviceNo, string currentAddress = "") - { - if (string.IsNullOrEmpty(currentAddress)) - return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskStatus == (int)TaskOutStatusEnum.OutNew, TaskOrderBy); - else - return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskInboundTypes.Contains(x.TaskType) && x.TaskStatus == (int)TaskInStatusEnum.InNew && x.CurrentAddress == currentAddress, TaskOrderBy); - } - - /// <summary> /// 鏍规嵁璁惧缂栧彿銆佸綋鍓嶅湴鍧�鎸夌収浼樺厛绾т互鍙婂垱寤烘椂闂存帓搴忔煡璇换鍔℃睜鍑哄簱绫诲瀷鐨勬柊澧炵殑浠诲姟 /// </summary> /// <param name="deviceNo">璁惧缂栧彿</param> @@ -283,7 +252,7 @@ /// <returns>杩斿洖浠诲姟瀹炰綋瀵硅薄锛屽彲鑳戒负null</returns> public Dt_Task QueryStackerCraneOutTask(string deviceNo, string currentAddress = "") { - Dt_Task taskGrade = BaseDal.QueryFirst(x => x.Grade == 0, TaskOrderBy); + Dt_Task taskGrade = BaseDal.QueryFirst(x => true, TaskOrderBy); if (taskGrade != null) { return taskGrade; @@ -325,7 +294,7 @@ /// <returns>杩斿洖浠诲姟瀹炰綋瀵硅薄闆嗗悎锛屽彲鑳戒负null</returns> public List<Dt_Task> QueryStackerCraneOutTasks(string deviceNo, string outStationCodes) { - List<Dt_Task> taskGrade = BaseDal.QueryData(x => x.Grade == 0, TaskOrderBy); + List<Dt_Task> taskGrade = BaseDal.QueryData(x => true, TaskOrderBy); if (taskGrade != null) { return taskGrade; @@ -358,7 +327,7 @@ } else if (task.TaskType == (int)TaskTypeEnum.Relocation) { - task.TaskStatus = (int)InTaskStatusEnum.RelocationException; + task.TaskStatus = (int)RelocationTaskStatusEnum.RelocationException; } task.ExceptionMessage = message; @@ -400,7 +369,7 @@ try { Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); - if (task == null) return WebResponseContent.Instance.Error($"鏈壘鍒拌浠诲姟淇℃伅,浠诲姟鍙�:銆恵taskNum}銆�"); + if (task == null) return WebResponseContent.Instance.Error($"鏈壘鍒拌浠诲姟淇℃伅,浠诲姟鍙�:銆恵taskNum}銆�!"); return UpdateTaskStatusToNext(task); } catch (Exception ex) @@ -421,7 +390,7 @@ try { int oldState = task.TaskStatus; - if (task.TaskType == (int)TaskTypeEnum.Outbound|| task.TaskType == (int)TaskTypeEnum.PalletOutbound) + if (task.TaskType == (int)TaskTypeEnum.Outbound || task.TaskType == (int)TaskTypeEnum.PalletOutbound) { task.TaskStatus = OutTaskStatusEnum.SC_OutExecuting.ObjToInt(); } @@ -431,7 +400,7 @@ } else if (task.TaskType == (int)TaskTypeEnum.Relocation) { - task.TaskStatus = (int)InTaskStatusEnum.RelocationExecuting; + task.TaskStatus = (int)RelocationTaskStatusEnum.RelocationExecuting; } else { @@ -450,7 +419,7 @@ var response = HttpHelpers.Post<WebResponseContent>(url + "UpdateTaskStatus?taskNum=" + task.TaskNum, "", "鏇存柊浠诲姟鐘舵��"); if (!response.Status) { - _unitOfWorkManage.RollbackTran(); + throw new Exception(response.Message); } _unitOfWorkManage.CommitTran(); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, App.User.UserId > 0 ? $"浜哄伐鎵嬪姩灏嗕换鍔$姸鎬佷粠銆恵oldState}銆戣烦杞埌銆恵task.TaskStatus}銆�" : $"绯荤粺鑷姩娴佺▼锛屼换鍔$姸鎬佷粠銆恵oldState}銆戣浆鍒般�恵task.TaskStatus}銆�"); @@ -504,7 +473,7 @@ /// </summary> /// <param name="taskNum">浠诲姟缂栧彿</param> /// <returns>杩斿洖澶勭悊缁撴灉</returns> - public WebResponseContent StackCraneTaskCompleted(int taskNum) + public WebResponseContent StackCraneTaskCompleted(int taskNum, string Modifier = "") { WebResponseContent content = new WebResponseContent(); try @@ -512,68 +481,53 @@ Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); if (task == null) return WebResponseContent.Instance.Error($"鏈壘鍒拌浠诲姟淇℃伅,浠诲姟鍙�:銆恵taskNum}銆�"); + task.ModifyDate = DateTime.Now; + if (App.User.UserId > 0) Modifier = App.User.UserName; + task.Modifier = Modifier.IsNullOrEmpty() ? "WMS" : Modifier; if (task.TaskType == (int)TaskTypeEnum.Outbound || task.TaskType == (int)TaskTypeEnum.PalletOutbound) { _unitOfWorkManage.BeginTran(); task.TaskStatus = (int)OutTaskStatusEnum.OutFinish; - task.ModifyDate = DateTime.Now; - task.Modifier = "System"; + _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈哄嚭搴撳畬鎴�"); BaseDal.DeleteData(task); _task_HtyService.AddTaskHty(task); - _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈哄嚭搴撳畬鎴�"); - var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCompleted?taskNum="+task.TaskNum,"" , "浠诲姟瀹屾垚"); - if (response.Status) + _unitOfWorkManage.CommitTran(); + if (!Modifier.IsNullOrEmpty()) { - _unitOfWorkManage.CommitTran(); - return content.OK(); + var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCompleted?taskNum=" + task.TaskNum, "", "浠诲姟瀹屾垚"); + if (!response.Status) throw new Exception(response.Message); } - else - { - _unitOfWorkManage.RollbackTran(); - return content = WebResponseContent.Instance.Error(response.Message); - } + return content.OK(); } - else if (task.TaskType == (int)TaskTypeEnum.Inbound || task.TaskType == (int)TaskTypeEnum.PalletInbound) + else if (task.TaskType == (int)TaskTypeEnum.Inbound || task.TaskType == (int)TaskTypeEnum.PalletInbound) { _unitOfWorkManage.BeginTran(); task.TaskStatus = (int)InTaskStatusEnum.InFinish; - task.ModifyDate = DateTime.Now; - task.Modifier = "System"; + _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈哄叆搴撳畬鎴�"); BaseDal.DeleteData(task); _task_HtyService.AddTaskHty(task); - _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈哄叆搴撳畬鎴�"); - var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCompleted?taskNum="+ task.TaskNum,"", "浠诲姟瀹屾垚"); - if (response.Status) + _unitOfWorkManage.CommitTran(); + if (!Modifier.IsNullOrEmpty()) { - _unitOfWorkManage.CommitTran(); - return content.OK(); + var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCompleted?taskNum=" + task.TaskNum, "", "浠诲姟瀹屾垚"); + if (!response.Status) throw new Exception(response.Message); } - else - { - _unitOfWorkManage.RollbackTran(); - return content = WebResponseContent.Instance.Error(response.Message); - } + return content.OK(); } - else if (task.TaskType== (int)TaskTypeEnum.Relocation) + else if (task.TaskType == (int)TaskTypeEnum.Relocation) { _unitOfWorkManage.BeginTran(); - task.TaskStatus = (int)InTaskStatusEnum.RelocationFinish; - task.ModifyDate = DateTime.Now; - task.Modifier = "System"; + task.TaskStatus = (int)RelocationTaskStatusEnum.RelocationFinish; + _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈虹Щ搴撳畬鎴�"); BaseDal.DeleteData(task); _task_HtyService.AddTaskHty(task); - _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈虹Щ搴撳畬鎴�"); - var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCompleted?taskNum=" + task.TaskNum, "", "浠诲姟瀹屾垚"); - if (response.Status) + _unitOfWorkManage.CommitTran(); + if (!Modifier.IsNullOrEmpty()) { - _unitOfWorkManage.CommitTran(); - return content.OK(); + var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCompleted?taskNum=" + task.TaskNum, "", "浠诲姟瀹屾垚"); + if (!response.Status) throw new Exception(response.Message); } - else - { - _unitOfWorkManage.RollbackTran(); - return content = WebResponseContent.Instance.Error(response.Message); - } + return content.OK(); } else { @@ -582,15 +536,16 @@ } catch (Exception ex) { - _unitOfWorkManage.RollbackTran(); - content = WebResponseContent.Instance.Error($"浠诲姟瀹屾垚寮傚父,浠诲姟鍙�:銆恵taskNum}銆�,寮傚父淇℃伅锛歿ex.Message}"); + //_unitOfWorkManage.RollbackTran(); + content = WebResponseContent.Instance.OK($"浠诲姟瀹屾垚寮傚父,浠诲姟鍙�:銆恵taskNum}銆�,寮傚父淇℃伅锛歿ex.Message}"); } finally { - WriteLog.GetLog("瀹屾垚浠诲姟").Write(JsonConvert.SerializeObject(content), "瀹屾垚浠诲姟"); + WriteLog.GetLog("瀹屾垚浠诲姟").Write($"鎿嶄綔浜猴細{(App.User.UserId > 0 ? App.User.UserName : "鍫嗗灈鏈�")}{Environment.NewLine}浠诲姟鍙凤細{taskNum}{Environment.NewLine}{JsonConvert.SerializeObject(content)}", "瀹屾垚浠诲姟"); } return content; } + public WebResponseContent TaskCancel(int taskNum) { WebResponseContent content = new WebResponseContent(); @@ -599,68 +554,85 @@ Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); if (task == null) return WebResponseContent.Instance.Error($"鏈壘鍒拌浠诲姟淇℃伅,浠诲姟鍙�:銆恵taskNum}銆�"); - if (task.TaskType == (int)TaskTypeEnum.Outbound || task.TaskType == (int)TaskTypeEnum.PalletOutbound) + task.ModifyDate = DateTime.Now; + task.Modifier = "WMS"; + if (task.TaskType == (int)TaskTypeEnum.Outbound || task.TaskType == (int)TaskTypeEnum.PalletOutbound) { _unitOfWorkManage.BeginTran(); task.TaskStatus = (int)OutTaskStatusEnum.OutCancel; - task.ModifyDate = DateTime.Now; - task.Modifier = "System"; - BaseDal.DeleteData(task); - _task_HtyService.AddTaskHty(task); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈哄嚭搴撳彇娑�"); - var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCancel?taskNum=" + task.TaskNum, "", "浠诲姟鍙栨秷"); - if (response.Status) + if (App.User.UserId > 0) { - _unitOfWorkManage.CommitTran(); - return content.OK(); + BaseDal.DeleteData(task); + _task_HtyService.AddTaskHty(task); + task.Modifier = "System"; + var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCancel?taskNum=" + task.TaskNum, "", "鍙栨秷浠诲姟"); + if (response.Status) + { + _unitOfWorkManage.CommitTran(); + return content.OK(); + } + else + { + UpdateTaskExceptionMessage(task.TaskNum, $"鍫嗗灈鏈轰换鍔″彇娑堝け璐�"); + _unitOfWorkManage.RollbackTran(); + return content = WebResponseContent.Instance.Error(response.Message); + } } - else - { - _unitOfWorkManage.RollbackTran(); - return content = WebResponseContent.Instance.Error(response.Message); - } + _unitOfWorkManage.CommitTran(); + return content.OK(); } else if (task.TaskType == (int)TaskTypeEnum.Inbound || task.TaskType == (int)TaskTypeEnum.PalletInbound) { _unitOfWorkManage.BeginTran(); task.TaskStatus = (int)InTaskStatusEnum.InCancel; - task.ModifyDate = DateTime.Now; - task.Modifier = "System"; + _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈哄叆搴撳彇娑�"); + if (App.User.UserId > 0) + { + task.Modifier = "System"; + var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCancel?taskNum=" + task.TaskNum, "", "鍙栨秷浠诲姟"); + if (response.Status) + { + _unitOfWorkManage.CommitTran(); + return content.OK(); + } + else + { + UpdateTaskExceptionMessage(task.TaskNum, $"鍫嗗灈鏈轰换鍔″彇娑堝け璐�"); + _unitOfWorkManage.RollbackTran(); + return content = WebResponseContent.Instance.Error(response.Message); + } + } BaseDal.DeleteData(task); _task_HtyService.AddTaskHty(task); - _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈哄叆搴撳彇娑�"); - var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCancel?taskNum=" + task.TaskNum, "", "浠诲姟鍙栨秷"); - if (response.Status) - { - _unitOfWorkManage.CommitTran(); - return content.OK(); - } - else - { - _unitOfWorkManage.RollbackTran(); - return content = WebResponseContent.Instance.Error(response.Message); - } + _unitOfWorkManage.CommitTran(); + return content.OK(); } else if (task.TaskType == (int)TaskTypeEnum.Relocation) { _unitOfWorkManage.BeginTran(); - task.TaskStatus = (int)InTaskStatusEnum.RelocationCancel; - task.ModifyDate = DateTime.Now; - task.Modifier = "System"; + task.TaskStatus = (int)RelocationTaskStatusEnum.RelocationCancel; + _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈虹Щ搴撳彇娑�"); + if (App.User.UserId > 0) + { + task.Modifier = "System"; + var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCancel?taskNum=" + task.TaskNum, "", "鍙栨秷浠诲姟"); + if (response.Status) + { + _unitOfWorkManage.CommitTran(); + return content.OK(); + } + else + { + UpdateTaskExceptionMessage(task.TaskNum, $"鍫嗗灈鏈轰换鍔″彇娑堝け璐�"); + _unitOfWorkManage.RollbackTran(); + return content = WebResponseContent.Instance.Error(response.Message); + } + } BaseDal.DeleteData(task); _task_HtyService.AddTaskHty(task); - _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"鍫嗗灈鏈虹Щ搴撳彇娑�"); - var response = HttpHelpers.Post<WebResponseContent>(url + "TaskCancel?taskNum=" + task.TaskNum, "", "浠诲姟鍙栨秷"); - if (response.Status) - { - _unitOfWorkManage.CommitTran(); - return content.OK(); - } - else - { - _unitOfWorkManage.RollbackTran(); - return content = WebResponseContent.Instance.Error(response.Message); - } + _unitOfWorkManage.CommitTran(); + return content.OK(); } else { @@ -674,7 +646,7 @@ } finally { - WriteLog.GetLog("鍙栨秷浠诲姟").Write(JsonConvert.SerializeObject(content), "鍙栨秷浠诲姟"); + WriteLog.GetLog("鍙栨秷浠诲姟").Write($"鎿嶄綔浜猴細{(App.User.UserId > 0 ? App.User.UserName : "")}{Environment.NewLine}浠诲姟鍙凤細{taskNum}{Environment.NewLine}{JsonConvert.SerializeObject(content)}", "鍙栨秷浠诲姟"); } } /// <summary> -- Gitblit v1.9.3