duyongjia
2024-12-03 14aaca9a2e1da2849d602487a52094ee26bbe30a
´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs
@@ -21,6 +21,7 @@
using SqlSugar;
using SqlSugar.Extensions;
using System;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel;
using System.Diagnostics.CodeAnalysis;
@@ -41,6 +42,7 @@
using WIDESEAWCS_ITaskInfoRepository;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_QuartzJob.Models;
using WIDESEAWCS_QuartzJob.Service;
@@ -54,6 +56,7 @@
        private readonly ILocationInfoRepository _locationInfoRepository;
        private readonly IMapper _mapper;
        private readonly IUnitOfWorkManage _unitOfWorkManage;
        private readonly ITaskRepository _taskRepository;
        private Dictionary<string, OrderByType> _taskOrderBy = new()
            {
@@ -71,7 +74,7 @@
        public List<int> TaskOtherboundTypes => typeof(TaskOtherTypeEnum).GetEnumIndexList();
        public TaskService(ITaskRepository BaseDal, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IMapper mapper, ILocationInfoRepository locationInfoRepository, IUnitOfWorkManage unitOfWorkManage) : base(BaseDal)
        public TaskService(ITaskRepository BaseDal, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IMapper mapper, ILocationInfoRepository locationInfoRepository, IUnitOfWorkManage unitOfWorkManage, ITaskRepository taskRepository) : base(BaseDal)
        {
            _routerService = routerService;
            _taskExecuteDetailService = taskExecuteDetailService;
@@ -79,6 +82,7 @@
            _mapper = mapper;
            _locationInfoRepository = locationInfoRepository;
            _unitOfWorkManage = unitOfWorkManage;
            _taskRepository = taskRepository;
        }
        /// <summary>
@@ -183,7 +187,7 @@
                            return content = WebResponseContent.Instance.Error($"WCS未查询到源站点对应的库位,源站点:{taskDTO.dest_station.ToString()}");
                        }
                        break;
                    case 3001://AGV放货完成 WMS发3001的同时会写提升信号
                    case 3001://AGV放货完成 WMS发3001的同时WCS需在job中写提升信号
                        if (BaseDal.QueryFirst(x => x.TaskNum == taskDTO.task_id) == null)//手动入库直接发3001,需要生成任务,因为没有1001环节
                        {
@@ -207,7 +211,7 @@
                            if (taskinfo != null)
                            {
                                UpdateTaskStatus(taskinfo.TaskId, (int)TaskInStatusEnum.AGV_InExecuting);
                                _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"AGV入库执行中");
                                _taskExecuteDetailService.AddTaskExecuteDetail(taskinfo.TaskId, $"AGV入库执行中");
                                ServiceLogger.WriteDebug("ReceiveTask", $"AGV入库执行中(自动3001)更新状态成功,任务号:{taskinfo.TaskId}");
                                return content = WebResponseContent.Instance.OK($"AGV入库执行中(自动3001)更新状态成功,任务号:{taskinfo.TaskId}");
                            }
@@ -223,7 +227,7 @@
                        {
                            //更新任务表中NextAddress字段为新的任务号   taskDTO.weight-旧的任务号   taskDTO.task_id-新的任务号
                            UpdateTaskStatus(taskinfo.TaskId, taskDTO.task_id, (int)TaskInStatusEnum.AGV_InFinish);
                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"AGV搬运完成");
                            _taskExecuteDetailService.AddTaskExecuteDetail(taskinfo.TaskId, $"AGV搬运完成");
                            ServiceLogger.WriteDebug("ReceiveTask", $"AGV搬运完成(101)更新状态成功,任务号:{taskinfo.TaskId}");
                            return content = WebResponseContent.Instance.OK($"AGV搬运完成(101)更新状态成功,任务号:{taskinfo.TaskId}");
                        }
@@ -238,6 +242,10 @@
                        task.TaskType= (int)TaskRelocationTypeEnum.Relocation;
                        task.TaskState = (int)TaskOutStatusEnum.OutNew;
                        task.Roadway = "SC01";
                        if (taskDTO.total > 0)
                        {
                            task.Remark = taskDTO.total.ToString();//取出库的总层数
                        }
                        task.Grade = 1;
                        break;
                    case 102:
@@ -583,6 +591,15 @@
        }
        /// <summary>
        /// æŸ¥è¯¢ç§»åº“任务
        /// </summary>
        /// <returns></returns>
        public Dt_Task QueryStackerCraneTaskByRelotion(int taskNum)
        {
            return BaseDal.QueryFirst(x => (x.Roadway == "SC01" )&&x.TaskType==(int)TaskRelocationTypeEnum.Relocation && x.TaskNum==taskNum, TaskOrderBy);
        }
        /// <summary>
        /// æŸ¥è¯¢å°å †åž›æœºå‡ºåº“完成任务
        /// </summary>
        /// <returns></returns>
@@ -678,7 +695,7 @@
                _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, task.ExceptionMessage);
                content = WebResponseContent.Instance.OK();
            }
            catch (Exception ex)
            {
@@ -700,6 +717,245 @@
            task.Modifier = "System";
            task.ModifyDate = DateTime.Now;
            BaseDal.UpdateData(task);
        }
        /// <summary>
        /// ä»»åŠ¡å¼ºåˆ¶å®Œæˆ å †åž›æœºå®žé™…已完成任务,WCS未收到完成信号或其他未知原因导致WCS任务未完成,可以执行该方法强制完成任务
        /// </summary>
        /// <param name="taskNum"></param>
        /// <returns></returns>
        public WebResponseContent ForceCompleteTask(int taskNum)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                bool isBack = false;
                //1,先查询任务,根据不同的任务类型做任务强制完成操作
                Dt_Task task = _taskRepository.QueryFirst(x => x.TaskNum == taskNum);
                if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信息,任务号:【{taskNum}】");
                Dt_LocationInfo locationsrc = _locationInfoRepository.QueryFirst(x => x.LocationCode == task.SourceAddress.ToString());
                Dt_LocationInfo locationdsc = _locationInfoRepository.QueryFirst(x => x.LocationCode == task.TargetAddress.ToString());
                if (task.TaskType == (int)TaskInboundTypeEnum.Inbound)
                {
                    if (task.TaskState == (int)TaskInStatusEnum.SC_InExecuting)
                    {
                        task.TaskState = (int)TaskInStatusEnum.SC_InFinish;
                        //需要将目标地址改为有货状态
                        locationdsc.LocationStatus = (int)LocationStatusEnum.InStock;
                        //更新状态为任务完成
                        UpdateTaskStatus(task.TaskId, task.TaskState);
                        _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"堆垛机入库完成");
                        _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"入库任务完成");
                        //更新货位
                        _locationInfoRepository.UpdateData(locationdsc);
                        isBack = true;
                    }
                    else
                    {
                        return content = WebResponseContent.Instance.Error("该任务目前状态,不允计强制完成!");
                    }
                }
                else
                {
                    if (task.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting)
                    {
                        if (task.TaskType == (int)TaskOutboundTypeEnum.OutInventory || task.TaskType == (int)TaskOutboundTypeEnum.OutPick)//异常出库 ç©ºè½¦å‡ºåº“
                        {
                            task.TaskState = (int)TaskOutStatusEnum.OutFinish;
                            //源地址更新为空闲
                            locationsrc.LocationStatus = (int)LocationStatusEnum.Free;
                            //更新状态为任务完成
                            UpdateTaskStatus(task.TaskId, task.TaskState);
                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"堆垛机出库完成");
                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"出库任务完成");
                            //更新货位
                            _locationInfoRepository.UpdateData(locationsrc);
                            isBack = true;
                        }
                        else if (task.TaskType == (int)TaskRelocationTypeEnum.Relocation)//移库
                        {
                            task.TaskState = (int)TaskOutStatusEnum.OutFinish;
                            //源地址更新为空闲
                            locationsrc.LocationStatus = (int)LocationStatusEnum.Free;
                            //目标地址更新为有货
                            locationdsc.LocationStatus = (int)LocationStatusEnum.InStock;
                            //更新状态为任务完成
                            UpdateTaskStatus(task.TaskId, task.TaskState);
                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"堆垛机出库完成");
                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"出库任务完成");
                            //更新货位
                            _locationInfoRepository.UpdateData(locationsrc);
                            _locationInfoRepository.UpdateData(locationdsc);
                            isBack = true;
                        }
                        else
                        {
                            return WebResponseContent.Instance.Error($"上料任务不允计强制完成!");
                        }
                    }
                    else
                    {
                        return WebResponseContent.Instance.Error($"该任务状态不允计强制完成!");
                    }
                }
                //任务强制完成回调MES
                if (isBack)
                {
                    if (task.TaskType == (int)TaskInboundTypeEnum.Inbound)//入库时回传需传新任务号
                    {
                        task.TaskNum =int.Parse(task.NextAddress);
                    }
                    MESSendCMD sendcmd = new MESSendCMD { cmd = 201, task_id = task.TaskNum, status = 6 };
                    MESResponse res = ApiInvoke.SendTaskCMD(sendcmd);
                    if (res != null && res.code != 0)
                    {
                        ServiceLogger.WriteDebug("ForceCompleteTask", $"任务强制完成后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                        content = WebResponseContent.Instance.Error($"任务强制完成后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                    }
                    else
                    {
                        ServiceLogger.WriteDebug("ForceCompleteTask", $"任务强制完成后回传MES成功!,任务号:【{taskNum}】");
                        content = WebResponseContent.Instance.Error($"大堆垛机完成后回传MES成功!,任务号:【{taskNum}】");
                    }
                }
            }
            catch (Exception ex)
            {
                content = WebResponseContent.Instance.Error(ex.Message);
            }
            return content;
        }
        /// <summary>
        /// ä»»åŠ¡å–æ¶ˆ
        /// </summary>
        /// <param name="taskid"></param>
        /// <returns></returns>
        public WebResponseContent CancelTask(int taskNum)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                //1,先查询任务,根据不同的任务类型做任务取消操作
                Dt_Task task = _taskRepository.QueryFirst(x => x.TaskNum == taskNum);
                if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信息,任务号:【{taskNum}】");
                Dt_LocationInfo locationsrc = _locationInfoRepository.QueryFirst(x => x.LocationCode == task.SourceAddress.ToString());
                Dt_LocationInfo locationdsc = _locationInfoRepository.QueryFirst(x => x.LocationCode == task.TargetAddress.ToString());
                bool isBack = false;
                //如果是入库分自动和手动两种情况处理
                if (task.TaskType == (int)TaskInboundTypeEnum.Inbound)
                {
                    if (task.WMSId == 0 && task.TaskState == (int)TaskInStatusEnum.InNew)//自动入库,1001-AGV请求是否允计进入,任务状态为“新建入库任务200”之前可以取消
                    {
                        task.TaskState = (int)TaskInStatusEnum.InCancel;
                        //需要将目标地址恢复为空闲状态
                        locationdsc.LocationStatus = (int)LocationStatusEnum.Free;
                        //更新状态为任务取消
                        UpdateTaskStatus(task.TaskId, task.TaskState);
                        _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"入库任务取消");
                        _locationInfoRepository.UpdateData(locationdsc);
                        isBack = true;
                    }
                    else if (task.WMSId == 1 && task.TaskState == (int)TaskInStatusEnum.AGV_InExecuting)//手动入库,3001-AGV放货完成,任务状态为“AGV入库执行中210”之前可以取消
                    {
                        task.TaskState = (int)TaskInStatusEnum.InCancel;
                        //需要将目标地址恢复空闲状态
                        locationdsc.LocationStatus = (int)LocationStatusEnum.Free;
                        //更新状态为任务取消
                        UpdateTaskStatus(task.TaskId, task.TaskState);
                        _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"入库任务取消");
                        _locationInfoRepository.UpdateData(locationdsc);
                        isBack = true;
                    }
                    else
                    {
                        return WebResponseContent.Instance.Error($"该任务状态不允计取消!");
                    }
                }
                else//其他任务,任务状态“新建出库任务”之前,才可以取消
                {
                    if (task.TaskState == (int)TaskOutStatusEnum.OutNew)
                    {
                        if(task.TaskType == (int)TaskOutboundTypeEnum.OutInventory|| task.TaskType == (int)TaskOutboundTypeEnum.OutPick)//异常出库 ç©ºè½¦å‡ºåº“
                        {
                            task.TaskState = (int)TaskOutStatusEnum.OutCancel;
                            //源地址恢复到有货
                            locationsrc.LocationStatus = (int)LocationStatusEnum.InStock;
                            //更新状态为任务取消
                            UpdateTaskStatus(task.TaskId, task.TaskState);
                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"出库任务取消");
                            _locationInfoRepository.UpdateData(locationsrc);
                            isBack = true;
                        }
                        else if(task.TaskType == (int)TaskRelocationTypeEnum.Relocation)//移库
                        {
                            task.TaskState = (int)TaskOutStatusEnum.OutCancel;
                            //源地址恢复到有货
                            locationsrc.LocationStatus = (int)LocationStatusEnum.InStock;
                            //需要将目标地址恢复空闲状态
                            locationdsc.LocationStatus = (int)LocationStatusEnum.Free;
                            //更新状态为任务取消
                            UpdateTaskStatus(task.TaskId, task.TaskState);
                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"出库任务取消");
                            _locationInfoRepository.UpdateData(locationsrc);
                            _locationInfoRepository.UpdateData(locationdsc);
                            isBack = true;
                        }
                        else
                        {
                            return WebResponseContent.Instance.Error($"上料任务不允计取消!");
                        }
                    }
                    else
                    {
                        return WebResponseContent.Instance.Error($"该任务状态不允计取消!");
                    }
                }
                //任务取消回调MES
                if (isBack)
                {
                    MESSendCMD sendcmd = new MESSendCMD { cmd = 201, task_id = task.TaskNum, status = 3 };
                    MESResponse res = ApiInvoke.SendTaskCMD(sendcmd);
                    if (res != null && res.code != 0)
                    {
                        ServiceLogger.WriteDebug("ForceCompleteTask", $"任务取消回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                        content = WebResponseContent.Instance.Error($"任务取消回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                    }
                    else
                    {
                        ServiceLogger.WriteDebug("ForceCompleteTask", $"任务取消回传MES成功!,任务号:【{taskNum}】");
                        content = WebResponseContent.Instance.Error($"任务取消回传MES成功!,任务号:【{taskNum}】");
                    }
                }
                else
                {
                }
            }
            catch (Exception ex)
            {
                content = WebResponseContent.Instance.Error(ex.Message);
            }
            return content;
        }
@@ -872,12 +1128,26 @@
                        _unitOfWorkManage.CommitTran();
                        //出库完成,回传WMS
                        //回传到WMS
                        MESSendCMD sendcmd = new MESSendCMD { cmd = 201, task_id = task.TaskNum, status = 6 };
                        MESResponse res = ApiInvoke.SendTaskCMD(sendcmd);
                        if (res != null && res.code != 0)
                        if (task.TaskType == (int)TaskOutboundTypeEnum.OutPick)
                        {
                            ServiceLogger.WriteDebug("StackCraneTaskCompleted", $"大堆垛机完成出库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                            content = WebResponseContent.Instance.Error($"大堆垛机完成出库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                            MESSendCMD sendcmd = new MESSendCMD { cmd = 201, task_id = task.TaskNum, status = 6 };
                            MESResponse res = ApiInvoke.SendTaskCMD(sendcmd);
                            if (res != null && res.code != 0)
                            {
                                ServiceLogger.WriteDebug("StackCraneTaskCompleted", $"大堆垛机完成空车出库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                                content = WebResponseContent.Instance.Error($"大堆垛机完成空车出库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                            }
                        }
                        else
                        {
                            MESSendCMD sendcmd = new MESSendCMD { cmd = 201, task_id = task.TaskNum, status = 6 };
                            MESResponse res = ApiInvoke.SendTaskCMD(sendcmd);
                            if (res != null && res.code != 0)
                            {
                                ServiceLogger.WriteDebug("StackCraneTaskCompleted", $"大堆垛机完成异常出库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                                content = WebResponseContent.Instance.Error($"大堆垛机完成异常出库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                            }
                        }
                    }
@@ -920,7 +1190,7 @@
                        MESResponse res = ApiInvoke.SendTaskCMD(sendcmd);
                        if (res != null && res.code != 0)
                        {
                            ServiceLogger.WriteDebug("StackCraneTaskCompleted", $"大堆垛机完成入库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                            content = WebResponseContent.Instance.Error($"大堆垛机完成入库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                        }
@@ -969,6 +1239,24 @@
                            ServiceLogger.WriteDebug("StackCraneTaskCompleted", $"大堆垛机完成出库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                            content = WebResponseContent.Instance.Error($"大堆垛机完成出库任务后回传MES失败!,任务号:【{taskNum}】,失败信息:【{res.message}】");
                        }
                        //if(task.TaskType== (int)TaskRelocationTypeEnum.Relocation&&!string.IsNullOrEmpty(task.Remark.Trim()))//出库任务写总层数标识
                        //{
                        //    CommonStackerCrane commonStackerCrane = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "SC01") as CommonStackerCrane;
                        //    //根据任务源地址确定写入PLC位置 Depth
                        //    Dt_LocationInfo location = _locationInfoRepository.QueryFirst(x => x.LocationCode == task.TargetAddress);
                        //    if (commonStackerCrane!=null&&location != null)
                        //    {
                        //        bool issuccess = commonStackerCrane.Communicator.Write<short>("DB28." + location.Depth + ".0", 9);
                        //        if (issuccess)
                        //        {
                        //            ServiceLogger.WriteDebug("TaskService", $"原料出库后写入标识成功!");
                        //        }
                        //        else
                        //        {
                        //            ServiceLogger.WriteDebug("TaskService", $"原料出库后写入标识失败!");
                        //        }
                        //    }
                        //}
                    }
                    catch (Exception ex)