#region << 版 本 注 释 >> /*---------------------------------------------------------------- * 命å空间:WIDESEAWCS_TaskInfoService * 创建者:胡童庆 * 创建时间:2024/8/2 16:13:36 * 版本:V1.0.0 * æè¿°ï¼š * * ---------------------------------------------------------------- * 修改人: * 修改时间: * 版本:V1.0.1 * 修改说明: * *----------------------------------------------------------------*/ #endregion << 版 本 注 释 >> using AutoMapper; 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.Text; using System.Threading.Tasks; using WIDESEAWCS_Core; using WIDESEAWCS_Core.BaseServices; using WIDESEAWCS_Core.Enums; using WIDESEAWCS_DTO.TaskInfo; using WIDESEAWCS_ITaskInfoRepository; using WIDESEAWCS_ITaskInfoService; using WIDESEAWCS_Model.Models; using WIDESEAWCS_QuartzJob.Models; using WIDESEAWCS_QuartzJob.Service; namespace WIDESEAWCS_TaskInfoService { public class TaskService : ServiceBase<Dt_Task, ITaskRepository>, ITaskService { private readonly IRouterService _routerService; private readonly ITaskExecuteDetailService _taskExecuteDetailService; private readonly ITaskExecuteDetailRepository _taskExecuteDetailRepository; private readonly IMapper _mapper; private Dictionary<string, OrderByType> _taskOrderBy = new() { {nameof(Dt_Task.Grade),OrderByType.Desc }, {nameof(Dt_Task.CreateDate),OrderByType.Asc}, }; public Dictionary<string, OrderByType> TaskOrderBy { get { return _taskOrderBy; } set { _taskOrderBy = value; } } public List<int> TaskInboundTypes => typeof(TaskInboundTypeEnum).GetEnumIndexList(); public List<int> TaskOutboundTypes => typeof(TaskOutboundTypeEnum).GetEnumIndexList(); public TaskService(ITaskRepository BaseDal, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IMapper mapper) : base(BaseDal) { _routerService = routerService; _taskExecuteDetailService = taskExecuteDetailService; _taskExecuteDetailRepository = taskExecuteDetailRepository; _mapper = mapper; } /// <summary> /// 接收WMSä»»åŠ¡ä¿¡æ¯ /// </summary> /// <param name="taskDTOs">WMS任务对象集åˆ</param> /// <returns>返回处ç†ç»“æžœ</returns> public WebResponseContent ReceiveWMSTask([NotNull]List<WMSTaskDTO> taskDTOs) { WebResponseContent content = new WebResponseContent(); try { List<Dt_Task> tasks = new List<Dt_Task>(); foreach (var item in taskDTOs) { if (BaseDal.QueryFirst(x => x.TaskNum == item.TaskNum || x.PalletCode == item.PalletCode) != null) { continue; } Dt_Task task = _mapper.Map<Dt_Task>(item); task.Creater = "WMS"; if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup) { List<Dt_Router> routers = _routerService.QueryNextRoutes(item.RoadWay, item.TargetAddress); //æš‚ä¸è€ƒè™‘多路径 if (routers.Count > 0) { task.TaskState = (int)TaskOutStatusEnum.OutNew; task.CurrentAddress = item.SourceAddress; task.NextAddress = routers.FirstOrDefault().ChildPosi; } } else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) { List<Dt_Router> routers = _routerService.QueryNextRoutes(item.SourceAddress, item.TargetAddress); //æš‚ä¸è€ƒè™‘多路径 if (routers.Count > 0) { task.TaskState = (int)TaskInStatusEnum.InNew; task.CurrentAddress = item.SourceAddress; task.NextAddress = routers.FirstOrDefault().ChildPosi; } } tasks.Add(task); } BaseDal.AddData(tasks); _taskExecuteDetailService.AddTaskExecuteDetail(tasks.Select(x => x.TaskNum).ToList(), "接收WMS任务"); content = WebResponseContent.Instance.OK("æˆåŠŸ"); } catch (Exception ex) { content = WebResponseContent.Instance.Error($"任务接收错误,错误信æ¯:{ex.Message}"); } return content; } /// <summary> /// æ ¹æ®æ‰˜ç›˜å·ã€èµ·å§‹åœ°å€å‘WMS请求任务 /// </summary> /// <param name="palletCode">托盘å·</param> /// <param name="sourceAddress">起始地å€</param> /// <returns></returns> public WebResponseContent RequestWMSTask(string palletCode, string sourceAddress) { WebResponseContent content = new WebResponseContent(); try { WMSTaskDTO taskDTO = new WMSTaskDTO() { TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")), Grade = 1, PalletCode = palletCode, RoadWay = "SC01", SourceAddress = sourceAddress, TargetAddress = "SC01", TaskState = (int)TaskInStatusEnum.InNew, Id = 0, TaskType = (int)TaskInboundTypeEnum.Inbound }; content = ReceiveWMSTask(new List<WMSTaskDTO> { taskDTO }); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } /// <summary> /// æ ¹æ®è®¾å¤‡ç¼–å·ã€å½“å‰åœ°å€æŸ¥è¯¢è¾“é€çº¿æœªæ‰§è¡Œçš„任务 /// </summary> /// <param name="deviceNo">设备编å·</param> /// <param name="currentAddress">当å‰åœ°å€</param> /// <returns></returns> public Dt_Task QueryConveyorLineTask(string deviceNo, string currentAddress) { return BaseDal.QueryFirst(x => (TaskInboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskInStatusEnum.InNew || TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.SC_OutFinish) && x.CurrentAddress == currentAddress, TaskOrderBy); } /// <summary> /// æ ¹æ®ä»»åŠ¡å·ã€ä¸‹ä¸€åœ°å€æŸ¥è¯¢è¾“é€çº¿æ‰§è¡Œä¸çš„任务 /// </summary> /// <param name="taskNum">任务å·</param> /// <param name="nextAddress">下一地å€</param> /// <returns></returns> public Dt_Task QueryExecutingConveyorLineTask(int taskNum, string nextAddress) { return BaseDal.QueryFirst(x => x.TaskNum == taskNum && x.NextAddress == nextAddress && (x.TaskState == (int)TaskInStatusEnum.Line_InExecuting || x.TaskState == (int)TaskOutStatusEnum.Line_OutExecuting), TaskOrderBy); } /// <summary> /// æ ¹æ®ä»»åŠ¡å·ã€å½“å‰åœ°å€æŸ¥è¯¢è¾“é€çº¿å®Œæˆçš„任务 /// </summary> /// <param name="taskNum">任务å·</param> /// <param name="currentAddress">当å‰åœ°å€</param> /// <returns></returns> public Dt_Task QueryCompletedConveyorLineTask(int taskNum, string currentAddress) { return BaseDal.QueryFirst(x => x.TaskNum == taskNum && x.CurrentAddress == currentAddress && (x.TaskState == (int)TaskInStatusEnum.Line_InFinish || x.TaskState == (int)TaskOutStatusEnum.Line_OutFinish), TaskOrderBy); } /// <summary> /// æ ¹æ®è®¾å¤‡ç¼–å·ã€ä»»åŠ¡ç±»åž‹åˆ†ç»„(å¯é€‰)按照优先级以åŠåˆ›å»ºæ—¶é—´æŽ’åºæŸ¥è¯¢ä»»åŠ¡æ± æ–°å¢žçš„ä»»åŠ¡ /// </summary> /// <param name="deviceNo">设备编å·</param> /// <param name="taskTypeGroup">任务类型分组(å¯é€‰)</param> /// <returns></returns> public Dt_Task? QuertStackerCraneTask(string deviceNo, TaskTypeGroup? taskTypeGroup = null) { if(taskTypeGroup == null) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && (TaskInboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskInStatusEnum.Line_InFinish || TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew), TaskOrderBy); if(taskTypeGroup.Value == TaskTypeGroup.InboundGroup) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskInboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskInStatusEnum.Line_InFinish, TaskOrderBy); if(taskTypeGroup.Value == TaskTypeGroup.OutbondGroup) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew, TaskOrderBy); return null; } /// <summary> /// æ ¹æ®è®¾å¤‡ç¼–å·ã€å½“å‰åœ°å€æŒ‰ç…§ä¼˜å…ˆçº§ä»¥åŠåˆ›å»ºæ—¶é—´æŽ’åºæŸ¥è¯¢ä»»åŠ¡æ± æ–°å¢žçš„ä»»åŠ¡ /// </summary> /// <param name="deviceNo">设备编å·</param> /// <param name="currentAddress">当å‰åœ°å€</param> /// <returns>返回任务实体对象,å¯èƒ½ä¸ºnull</returns> public Dt_Task QueryStackerCraneTask(string deviceNo, string currentAddress = "") { if (string.IsNullOrEmpty(currentAddress)) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && (TaskInboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskInStatusEnum.Line_InFinish || TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew), TaskOrderBy); else return BaseDal.QueryFirst(x => x.Roadway == deviceNo && x.CurrentAddress == currentAddress && (TaskInboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskInStatusEnum.Line_InFinish || TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew), TaskOrderBy); } /// <summary> /// æ ¹æ®è®¾å¤‡ç¼–å·ã€å½“å‰åœ°å€æŒ‰ç…§ä¼˜å…ˆçº§ä»¥åŠåˆ›å»ºæ—¶é—´æŽ’åºæŸ¥è¯¢ä»»åŠ¡æ± å…¥åº“ç±»åž‹çš„æ–°å¢žçš„ä»»åŠ¡ /// </summary> /// <param name="deviceNo">设备编å·</param> /// <param name="currentAddress">当å‰åœ°å€</param> /// <returns>返回任务实体对象,å¯èƒ½ä¸ºnull</returns> public Dt_Task QueryStackerCraneInTask(string deviceNo, string currentAddress = "") { if (string.IsNullOrEmpty(currentAddress)) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskInboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskInStatusEnum.Line_InFinish, TaskOrderBy); else return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskInboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskInStatusEnum.Line_InFinish && x.CurrentAddress == currentAddress, TaskOrderBy); } /// <summary> /// æ ¹æ®è®¾å¤‡ç¼–å·ã€å½“å‰åœ°å€æŒ‰ç…§ä¼˜å…ˆçº§ä»¥åŠåˆ›å»ºæ—¶é—´æŽ’åºæŸ¥è¯¢ä»»åŠ¡æ± å‡ºåº“ç±»åž‹çš„æ–°å¢žçš„ä»»åŠ¡ /// </summary> /// <param name="deviceNo">设备编å·</param> /// <param name="currentAddress">当å‰åœ°å€</param> /// <returns>返回任务实体对象,å¯èƒ½ä¸ºnull</returns> public Dt_Task QueryStackerCraneOutTask(string deviceNo, string currentAddress = "") { if (string.IsNullOrEmpty(currentAddress)) return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew, TaskOrderBy); else return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew && x.CurrentAddress == currentAddress, TaskOrderBy); } /// <summary> /// æ ¹æ®è®¾å¤‡ç¼–å·ã€å½“å‰åœ°å€æŒ‰ç…§ä¼˜å…ˆçº§ä»¥åŠåˆ›å»ºæ—¶é—´æŽ’åºæŸ¥è¯¢ä»»åŠ¡æ± å‡ºåº“ç±»åž‹çš„æ–°å¢žçš„ä»»åŠ¡ /// </summary> /// <param name="deviceNo">设备编å·</param> /// <param name="currentAddress">当å‰åœ°å€</param> /// <returns>返回任务实体对象集åˆï¼Œå¯èƒ½ä¸ºnull</returns> public List<Dt_Task> QueryStackerCraneOutTasks(string deviceNo, List<string> outStationCodes) { return BaseDal.QueryData(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew && outStationCodes.Contains(x.CurrentAddress), TaskOrderBy); } /// <summary> /// æ›´æ–°ä»»åŠ¡å¼‚å¸¸ä¿¡æ¯æ˜¾ç¤º /// </summary> /// <param name="taskNum">任务å·</param> /// <param name="message">异常信æ¯</param> public WebResponseContent UpdateTaskExceptionMessage(int taskNum, string message) { WebResponseContent content = new WebResponseContent(); try { Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信æ¯,任务å·:ã€{taskNum}】"); if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup) { task.TaskState = (int)TaskOutStatusEnum.OutPending; } else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) { task.TaskState = (int)TaskInStatusEnum.InPending; } task.ExceptionMessage = message; task.ModifyDate = DateTime.Now; BaseDal.UpdateData(task); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, task.ExceptionMessage); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } /// <summary> /// 更新任务状æ€ä¿¡æ¯ï¼Œå¹¶åŒæ¥è‡³WMS /// </summary> /// <param name="taskNum">任务å·</param> /// <param name="status">任务状æ€</param> public void UpdateTaskStatus(int taskNum, int status) { Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); if (task == null) return; task.TaskState = status; task.ModifyDate = DateTime.Now; BaseDal.UpdateData(task); } /// <summary> /// 将任务状æ€ä¿®æ”¹ä¸ºä¸‹ä¸€ä¸ªçŠ¶æ€ /// </summary> /// <param name="taskNum">任务å·</param> public WebResponseContent UpdateTaskStatusToNext(int taskNum) { WebResponseContent content = new WebResponseContent(); try { Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信æ¯,任务å·:ã€{taskNum}】"); return UpdateTaskStatusToNext(task); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } /// <summary> /// 将任务状æ€ä¿®æ”¹ä¸ºä¸‹ä¸€ä¸ªçŠ¶æ€ /// </summary> /// <param name="task">任务实体对象</param> /// <returns></returns> public WebResponseContent UpdateTaskStatusToNext([NotNull] Dt_Task task) { WebResponseContent content = new WebResponseContent(); try { int oldState = task.TaskState; if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup) { if (task.TaskState >= (int)TaskOutStatusEnum.OutFinish) { return content = WebResponseContent.Instance.Error($"该任务状æ€ä¸å¯è·³è½¬åˆ°ä¸‹ä¸€æ¥,任务å·:ã€{task.TaskNum}】,任务状æ€:ã€{task.TaskState}】"); } int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskOutStatusEnum>(); task.TaskState = nextStatus; } else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) { if (task.TaskState >= (int)TaskInStatusEnum.InFinish) { return content = WebResponseContent.Instance.Error($"该任务状æ€ä¸å¯è·³è½¬åˆ°ä¸‹ä¸€æ¥,任务å·:ã€{task.TaskNum}】,任务状æ€:ã€{task.TaskState}】"); } int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskInStatusEnum>(); task.TaskState = nextStatus; if (task.TaskState == (int)TaskInStatusEnum.Line_InFinish) { Random random = new Random(); task.CurrentAddress = task.NextAddress; task.NextAddress = $"{random.Next(1, 100).ToString().PadLeft(3, '0')}-{random.Next(1, 100).ToString().PadLeft(3, '0')}-{random.Next(1, 100).ToString().PadLeft(3, '0')}"; task.TargetAddress = task.NextAddress; } } else { throw new Exception($"任务类型错误,未找到该任务类型,任务å·:ã€{task.TaskNum}】,任务类型:ã€{task.TaskType}】"); } if (task.TaskState <= 0) { return content = WebResponseContent.Instance.Error($"该任务状æ€ä¸å¯è·³è½¬åˆ°ä¸‹ä¸€æ¥,任务å·:ã€{task.TaskNum}】,任务状æ€:ã€{task.TaskState}】"); } task.ModifyDate = DateTime.Now; task.Modifier = "System"; BaseDal.UpdateData(task); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, App.User.UserId > 0 ? $"人工手动将任务状æ€ä»Žã€{oldState}】跳转到ã€{task.TaskState}】" : $"系统自动æµç¨‹ï¼Œä»»åŠ¡çŠ¶æ€ä»Žã€{oldState}】转到ã€{task.TaskState}】"); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } /// <summary> /// æ ¹æ®ä»»åŠ¡å·ã€å½“å‰åœ°å€æ›´æ–°ä»»åŠ¡ä½ç½®ä¿¡æ¯ /// </summary> /// <param name="taskNum">任务å·</param> /// <param name="currentAddress">当å‰åœ°å€</param> /// <returns></returns> public Dt_Task? UpdatePosition(int taskNum, string currentAddress) { try { Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum && x.CurrentAddress == currentAddress); if (task == null) throw new Exception($"未找到该任务信æ¯,任务å·:ã€{taskNum}】"); string oldCurrentPos = task.CurrentAddress; string oldNextPos = task.NextAddress; List<Dt_Router> routers = _routerService.QueryNextRoutes(task.NextAddress, task.TargetAddress); if (!routers.Any()) throw new Exception($"未找到设备路由信æ¯"); task.CurrentAddress = task.NextAddress; task.NextAddress = routers.FirstOrDefault().ChildPosi; task.ModifyDate = DateTime.Now; task.Modifier = "System"; BaseDal.UpdateData(task); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"系统自动æµç¨‹ï¼Œæ›´æ–°å½“å‰ä½ç½®ã€{oldCurrentPos} ----> {task.CurrentAddress}】和下一ä½ç½®ã€{oldNextPos} ----> {task.NextAddress}】"); return task; } catch (Exception ex) { } return null; } /// <summary> /// ä»»åŠ¡å®Œæˆ /// </summary> /// <param name="taskNum">任务编å·</param> /// <returns>返回处ç†ç»“æžœ</returns> public WebResponseContent StackCraneTaskCompleted(int taskNum) { WebResponseContent content = new WebResponseContent(); try { Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信æ¯,任务å·:ã€{taskNum}】"); if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup && task.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting) { List<Dt_Router> routers = _routerService.QueryNextRoutes(task.NextAddress, task.TargetAddress); if (!routers.Any()) return WebResponseContent.Instance.Error($"未找到设备路由信æ¯"); int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskOutStatusEnum>(); task.TaskState = nextStatus; task.CurrentAddress = task.NextAddress; task.NextAddress = routers.FirstOrDefault().ChildPosi; task.ModifyDate = DateTime.Now; task.Modifier = "System"; BaseDal.UpdateData(task); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"å †åž›æœºå‡ºåº“å®Œæˆ"); //todo åŒæ¥åˆ°WMS //æš‚ä¸è€ƒè™‘å¤šä¸ªå‡ºåº“å£ } else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup && task.TaskState == (int)TaskInStatusEnum.SC_InExecuting) { //todo int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskInStatusEnum>(); task.TaskState = nextStatus; task.ModifyDate = DateTime.Now; task.Modifier = "System"; BaseDal.UpdateData(task); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"å †åž›æœºå…¥åº“å®Œæˆ"); WMSTaskDTO taskDTO = new WMSTaskDTO() { TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")), Grade = 1, PalletCode = task.PalletCode + "S", RoadWay = "SC01", SourceAddress = task.TargetAddress, TargetAddress = "CLOutAreaA", TaskState = (int)TaskOutStatusEnum.OutNew, Id = 0, TaskType = (int)TaskOutboundTypeEnum.Outbound }; content = ReceiveWMSTask(new List<WMSTaskDTO> { taskDTO }); } else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup) { //todo 调用WMSç§»åº“å®Œæˆ } else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OtherGroup) { } else { throw new Exception($"任务类型错误,未找到该任务类型,任务å·:ã€{taskNum}】,任务类型:ã€{task.TaskType}】"); } content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error($"任务完æˆå¼‚常,任务å·:ã€{taskNum}】"); } return content; } /// <summary> /// æ¢å¤æŒ‚起任务 /// </summary> /// <param name="taskNum">任务å·</param> /// <returns>返回处ç†ç»“æžœ</returns> public WebResponseContent TaskStatusRecovery(int taskNum) { WebResponseContent content = new WebResponseContent(); try { Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信æ¯,任务å·:ã€{taskNum}】"); if (task.TaskState != (int)TaskInStatusEnum.InPending && task.TaskState != (int)TaskOutStatusEnum.OutPending) { return content = WebResponseContent.Instance.Error($"该任务状æ€ä¸å¯æ¢å¤,任务å·:ã€{taskNum}】,任务状æ€:ã€{task.TaskState}】"); } Dt_TaskExecuteDetail taskExecuteDetail = _taskExecuteDetailRepository.QueryFirst(x => x.TaskId == task.TaskId && x.IsNormal, new Dictionary<string, OrderByType> { { nameof(Dt_TaskExecuteDetail.TaskDetailId), OrderByType.Desc } }); if (taskExecuteDetail != null) { task.TaskState = taskExecuteDetail.TaskState; } else { if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup) { task.TaskState = (int)TaskOutStatusEnum.OutNew; } else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) { task.TaskState = (int)TaskInStatusEnum.InNew; } //todo } task.ExceptionMessage = string.Empty; BaseDal.UpdateData(task); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"人工æ¢å¤æŒ‚起任务,æ¢å¤æŒ‚起时任务状æ€ã€{task.TaskState}】"); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } /// <summary> /// å›žæ»šä»»åŠ¡çŠ¶æ€ /// </summary> /// <param name="taskNum">任务å·</param> /// <returns>返回处ç†ç»“æžœ</returns> public WebResponseContent RollbackTaskStatusToLast(int taskNum) { WebResponseContent content = new(); try { Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum); if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信æ¯,任务å·:ã€{taskNum}】"); int oldState = task.TaskState; Dt_TaskExecuteDetail taskExecuteDetail = _taskExecuteDetailRepository.QueryFirst(x => x.TaskId == task.TaskId && x.TaskState < task.TaskState && x.TaskState > 0, new Dictionary<string, OrderByType> { { nameof(Dt_TaskExecuteDetail.TaskDetailId), OrderByType.Desc } }); if (taskExecuteDetail != null) { task.TaskState = taskExecuteDetail.TaskState; task.CurrentAddress = taskExecuteDetail.CurrentAddress; task.NextAddress = taskExecuteDetail.NextAddress; } else { return content = WebResponseContent.Instance.Error($"未找到任务明细信æ¯,该任务状æ€ä¸å¯å›žæ»šåˆ°ä¸Šä¸€æ¥,任务å·:ã€{taskNum}】,任务状æ€:ã€{task.TaskState}】"); } task.ExceptionMessage = string.Empty; BaseDal.UpdateData(task); _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"人工将任务状æ€ä»Žã€{oldState}】回滚到ã€{task.TaskState}】"); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } } }