1

HuBingJie

2025-11-22 51af2794f47d5b68496edbc09d0ccb168347f02b

 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs

@@ -1,4 +1,4 @@
#region << ç‰ˆ æœ¬ æ³¨ é‡Š >>
#region << ç‰ˆ æœ¬ æ³¨ é‡Š >>
/*----------------------------------------------------------------
 * å‘½åç©ºé—´ï¼šWIDESEAWCS_TaskInfoService
 * åˆ›å»ºè€…：胡童庆
@@ -407,7 +407,14 @@

                    //int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskOutStatusEnum>();

                    task.TaskState = (int)TaskOutStatusEnum.SC_OutExecuting;
                    if (task.TaskState ==(int)TaskOutStatusEnum.SC_OutFinish)
                    {
                        task.TaskState = (int)TaskOutStatusEnum.Line_OutFinish;
                    }
                    else
                    {
                        task.TaskState = (int)TaskOutStatusEnum.SC_OutExecuting;
                    }
                    task.Dispatchertime = DateTime.Now;
                }
                else if (task.TaskType == (int)TaskInboundTypeEnum.Inbound)
@@ -442,7 +449,11 @@

                task.ModifyDate = DateTime.Now;
                task.Modifier = "System";
                BaseDal.UpdateData(task);
                bool res  = BaseDal.UpdateData(task);
                if (!res)
                {
                    return content = WebResponseContent.Instance.Error($"更新任务信息失败,任务号:【{task.TaskNum}】");
                }

                _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, App.User.UserId > 0 ? $"人工手动将任务状态从【{oldState}】跳转到【{task.TaskState}】" : $"系统自动流程，任务状态从【{oldState}】转到【{task.TaskState}】");

@@ -497,7 +508,7 @@
        /// </summary>
        /// <param name="taskNum">任务编号</param>
        /// <returns>返回处理结果</returns>
        public WebResponseContent StackCraneTaskCompleted(int taskNum)
        /*public WebResponseContent StackCraneTaskCompleted(int taskNum)
        {
            WebResponseContent content = new WebResponseContent();
            try
@@ -509,44 +520,31 @@
                {
                    task.TaskState = (int)TaskOutStatusEnum.SC_OutFinish;
                    task.ModifyDate = DateTime.Now;
                    task.Modifier = "System";
                    BaseDal.UpdateData(task);
                    content = HttpHelperh.Get<WebResponseContent>($"{urlTaskCompleted}?TaskNum={task.TaskNum}");
                    Console.WriteLine("任务完成");
                    //BaseDal.DeleteData(task);
                    // _task_HtyService.AddTaskHty(task); éœ€è¦æ·»åŠ ç§»å…¥åŽ†å²
                    //_taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"出库完成");

                }
                else if (task.TaskType == (int)TaskInboundTypeEnum.Inbound && task.TaskState == (int)TaskInStatusEnum.SC_InExecuting)
                {
                    task.TaskState = (int)TaskInStatusEnum.InFinish;
                    BaseDal.UpdateData(task);

                    content = HttpHelperh.Get<WebResponseContent>($"{urlTaskCompleted}?TaskNum={task.TaskNum}");

                    task.ModifyDate = DateTime.Now;
                    task.Modifier = "System";
                    BaseDal.DeleteData(task);
                    // _task_HtyService.AddTaskHty(task); éœ€è¦æ·»åŠ ç§»å…¥åŽ†å²
                    _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"入库完成");

                }
                else if (task.TaskType == (int)TaskRelocationTypeEnum.Relocation)
                {
                    task.TaskState = (int)TaskRelocationStatusEnum.SC_RelocationFinish;
                    BaseDal.UpdateData(task);

                    content = HttpHelperh.Get<WebResponseContent>($"{urlTaskCompleted}?TaskNum={task.TaskNum}");

                  
                    task.ModifyDate = DateTime.Now;
                    BaseDal.DeleteData(task);
                   // _task_HtyService.AddTaskHty(task); éœ€è¦æ·»åŠ ç§»å…¥åŽ†å²
                    BaseDal.UpdateData(task);
                    _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"移库完成");
                }
                else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OtherGroup)
                {

                    BaseDal.DeleteData(task);
                    content = HttpHelperh.Get<WebResponseContent>($"{urlTaskCompleted}?TaskNum={task.TaskNum}");
                   // _task_HtyService.AddTaskHty(task); éœ€è¦æ·»åŠ ç§»å…¥åŽ†å²
                }
                else
                {
@@ -559,6 +557,149 @@
                content = WebResponseContent.Instance.Error($"任务完成异常,任务号:【{taskNum}】，原因：{ex.Message}");
            }
            return content;
        }*/


        public bool StackCraneTaskCompleted(int taskNum)
        {
            bool res;

            try
            {
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
                if (task == null) return false;

                // éªŒè¯ä»»åŠ¡çŠ¶æ€æ˜¯å¦å…è®¸å®Œæˆ
                if (!IsTaskStateValidForCompletion(task))return false;

                // æ ¹æ®ä»»åŠ¡ç±»åž‹å¤„理
                 res = ProcessTaskCompletion(task);
            }
            catch (Exception ex)
            {
                res = false;
            }

            return res;
        }

        /// <summary>
        /// éªŒè¯ä»»åŠ¡çŠ¶æ€æ˜¯å¦å…è®¸å®Œæˆ
        /// </summary>
        private bool IsTaskStateValidForCompletion(Dt_Task task)
        {
            return task.TaskType switch
            {
                (int)TaskOutboundTypeEnum.Outbound => task.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting,
                (int)TaskInboundTypeEnum.Inbound => task.TaskState == (int)TaskInStatusEnum.SC_InExecuting,
                (int)TaskRelocationTypeEnum.Relocation => true, // ç§»åº“任务没有特定状态要求
                _ => false
            };
        }

        /// <summary>
        /// å¤„理任务完成逻辑
        /// </summary>
        private bool ProcessTaskCompletion(Dt_Task task)
        {
            // æ›´æ–°ä»»åŠ¡åŸºç¡€ä¿¡æ¯
            UpdateTaskBaseInfo(task);

            bool result = task.TaskType switch
            {
                (int)TaskOutboundTypeEnum.Outbound => ProcessOutboundTask(task),
                (int)TaskInboundTypeEnum.Inbound => ProcessInboundTask(task),
                (int)TaskRelocationTypeEnum.Relocation => ProcessRelocationTask(task),
                _ => throw new Exception($"未知的任务类型:【{task.TaskType}】")
            };

            // é€šçŸ¥ä»»åŠ¡å®Œæˆ
            if (result == true)
            {
                NotifyTaskCompleted(task.TaskNum);
            }

            return result;
        }

        /// <summary>
        /// æ›´æ–°ä»»åŠ¡åŸºç¡€ä¿¡æ¯
        /// </summary>
        private void UpdateTaskBaseInfo(Dt_Task task)
        {
            task.ModifyDate = DateTime.Now;
            task.Modifier = "System";
        }

        /// <summary>
        /// å¤„理出库任务
        /// </summary>
        private bool ProcessOutboundTask(Dt_Task task)
        {
            task.TaskState = (int)TaskOutStatusEnum.SC_OutFinish;
            bool res = BaseDal.UpdateData(task);
            // æ·»åŠ å…¥åº“历史记录
            //AddTaskHistory(task);


            return res;
        }

        /// <summary>
        /// å¤„理入库任务
        /// </summary>
        private bool ProcessInboundTask(Dt_Task task)
        {
            task.TaskState = (int)TaskInStatusEnum.InFinish;
            BaseDal.UpdateData(task);

            // æ·»åŠ å…¥åº“历史记录
            // _task_HtyService.AddTaskHty(task);
            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, "入库完成");
            //AddTaskHistory(task);

            // å…¥åº“完成后删除任务
            bool res = BaseDal.DeleteData(task);

            return res;
        }

        /// <summary>
        /// å¤„理移库任务
        /// </summary>
        private bool ProcessRelocationTask(Dt_Task task)
        {
            task.TaskState = (int)TaskRelocationStatusEnum.SC_RelocationFinish;
            BaseDal.UpdateData(task);

            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, "移库完成");
            //AddTaskHistory(task);
            // ç§»åº“完成后删除任务
            bool res = BaseDal.DeleteData(task);
            // _task_HtyService.AddTaskHty(task);

            return res;
        }

        /// <summary>
        /// é€šçŸ¥ä»»åŠ¡å®Œæˆ
        /// </summary>
        private void NotifyTaskCompleted(int taskNum)
        {
            try
            {
                var response = HttpHelperh.Get<WebResponseContent>($"{urlTaskCompleted}?TaskNum={taskNum}");
                if (!response.Status)
                {
                    // è®°å½•é€šçŸ¥å¤±è´¥æ—¥å¿—，但不影响主流程
                     //_logger.Warn($"任务完成通知失败,任务号:【{taskNum}】,响应:【{response.Message}】");
                }
            }
            catch (Exception ex)
            {
                // è®°å½•å¼‚常日志，但不影响主流程
                // _logger.Error($"任务完成通知异常,任务号:【{taskNum}】", ex);
            }
        }

        /// <summary>
@@ -653,11 +794,11 @@
            return BaseDal.QueryFirst(x => x.PalletCode == Pallat);
        }

        public WebResponseContent UpdateTaskIninfo(string Pallat, int TaskNo)
        public WebResponseContent UpdateTaskIninfo(string Pallat, string StationCode)
        {
            try
            {
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == TaskNo && x.PalletCode == Pallat);
                Dt_Task task = BaseDal.QueryFirst(x => x.PalletCode == Pallat && x.SourceAddress== StationCode);
                if (task != null)
                {
                    task.TaskState = (int)TaskInStatusEnum.Line_InFinish;
@@ -718,5 +859,64 @@
        {
            return BaseDal.QueryFirst(x => x.TargetAddress== PLCaddress && x.TaskState == (int)TaskOutStatusEnum.SC_OutFinish, TaskOrderBy);
        }

        public Dt_Task GetOutTaskInfo2(string PalletCode)
        {
            return BaseDal.QueryFirst(x => x.PalletCode == PalletCode && x.TaskState == (int)TaskOutStatusEnum.Line_OutFinish, TaskOrderBy);
        }

        public List<Dt_Task> QueryStackerCraneYKTasks(string deviceNo)
        {
            return BaseDal.QueryData(x => x.Roadway == deviceNo && x.TaskType == (int)TaskRelocationTypeEnum.Relocation && x.TaskState == (int)TaskRelocationStatusEnum.RelocationNew, TaskOrderBy);

        }

        public WebResponseContent WCSCancelinventory(int taskNum)
        {
            //查询任务信息
            Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
            if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信息,任务号:【{taskNum}】");
            bool taskmsseg = BaseDal.DeleteData(task);
            //bool res = AddTaskHistory(task);
            //return taskmsseg && res ? WebResponseContent.Instance.OK() : WebResponseContent.Instance.Error();
            return null;

        }

        /// <summary>
        /// æ·»åŠ åŽ†å²ä»»åŠ¡è®°å½•ï¼ˆé™æ€æ–¹æ³•ï¼‰
        /// </summary>
        /// <param name="task">任务对象</param>
        /// <returns>是否添加成功</returns>
        public static bool AddTaskHistory(Dt_Task task)
        {
            try
            {
                if (task == null)
                {
                    return false;
                }

                // åˆ›å»ºä»»åŠ¡åŽ†å²æœåŠ¡å®žä¾‹
                var taskHtyService = App.GetService<ITaskHtyService>();
                if (taskHtyService == null)
                {
                    return false;
                }

                // æ·»åŠ åŽ†å²è®°å½•
                bool result = taskHtyService.AddTaskHistory(task, "自动完成");
                
                return result;
            }
            catch (Exception ex)
            {
                // è®°å½•å¼‚常日志
                Console.WriteLine($"添加历史任务记录失败: {ex.Message}");
                return false;
            }
        }


    }
}