最新

huanghongfeng

7 小时以前 b7f53ba61fbc1844d7b92ff852762b140d46ab54

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs

@@ -49,6 +49,7 @@
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob.Models;
using WIDESEAWCS_QuartzJob.Service;
using WIDESEAWCS_TaskInfoRepository;
using static Microsoft.IO.RecyclableMemoryStreamManager;

namespace WIDESEAWCS_TaskInfoService
@@ -59,6 +60,7 @@
        private readonly ITaskExecuteDetailService _taskExecuteDetailService;
        private readonly ITaskExecuteDetailRepository _taskExecuteDetailRepository;
        private readonly ITask_HtyService _task_HtyService;
        private readonly ITask_HtyRepository _task_HtyRepository;
        private readonly IMapper _mapper;

        private Dictionary<string, OrderByType> _taskOrderBy = new()
@@ -73,12 +75,13 @@

        public List<int> TaskOutboundTypes => typeof(TaskOutboundTypeEnum).GetEnumIndexList();

        public TaskService(ITaskRepository BaseDal, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IMapper mapper, ITask_HtyService task_HtyService) : base(BaseDal)
        public TaskService(ITaskRepository BaseDal, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IMapper mapper, ITask_HtyService task_HtyService, ITask_HtyRepository task_HtyRepository) : base(BaseDal)
        {
            _routerService = routerService;
            _taskExecuteDetailService = taskExecuteDetailService;
            _taskExecuteDetailRepository = taskExecuteDetailRepository;
            _task_HtyService = task_HtyService;
            _task_HtyRepository = task_HtyRepository;
            _mapper = mapper;
        }

@@ -364,7 +367,7 @@
                        if (task.TaskNum != _Task.TaskNum)
                        {
                            WriteLog.GetLog("接收任务").Write("移库任务：" + JsonConvert.SerializeObject(task), "接收任务");
                            task.TaskState = (int)TaskRelocationTypeEnum.Relocation;
                            task.TaskState = (int)TaskOutStatusEnum.ResRestNet;
                            task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                            task.TaskNum = task.TaskNum;
                            task.Grade = 3;
@@ -595,6 +598,19 @@
            {
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
                if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信息,任务号:【{taskNum}】");

                if(task.TaskType == (int)TaskRelocationTypeEnum.Relocation)
                {
                    if (task.TaskState != (int)TaskOutStatusEnum.ResRestNet)
                    {
                        return content = WebResponseContent.Instance.Error($"该任务状态不可跳转到下一步,任务号:【{task.TaskNum}】,任务状态:【{task.TaskState}】");
                    }
                    task.TaskState = (int)TaskOutStatusEnum.ResRest;    //下发移库任务
                    task.ModifyDate = DateTime.Now;
                    task.Modifier = "System";
                    BaseDal.UpdateData(task);
                }

                return UpdateTaskStatusToNext(task);
            }
            catch (Exception ex)
@@ -814,6 +830,16 @@
            return content;
        }

        public WebResponseContent StackCraneTashty(int taskNum)
        {
            WebResponseContent content = new WebResponseContent();
            int taskcount = _task_HtyRepository.QueryData(x =>x.TaskNum == taskNum && x.CreateDate >= DateTime.Now.AddMinutes(-30)).Count();

            if (taskcount>0) return WebResponseContent.Instance.OK();

             return WebResponseContent.Instance.Error($"未找到该任务信息，时间不在范围内,任务号为：{taskNum}");
        }

        /// <summary>
        /// æ¢å¤æŒ‚起任务
        /// </summary>