美瑞安淮安立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
wangxinhui
2025-01-04 ca08d1f380987254814242e2fe3ea9de28228132 
 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs


@@ -27,6 +27,7 @@


using System.Reflection;


using System.Text;


using System.Threading.Tasks;


using WIDESEA_DTO.Agv;


using WIDESEAWCS_Common.APIEnum;


using WIDESEAWCS_Common.TaskEnum;


using WIDESEAWCS_Core;


@@ -34,6 +35,7 @@


using WIDESEAWCS_Core.Enums;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_DTO.BasicInfo;


using WIDESEAWCS_DTO.System;


using WIDESEAWCS_DTO.TaskInfo;


using WIDESEAWCS_IBasicInfoRepository;


using WIDESEAWCS_ITaskInfoRepository;


@@ -43,6 +45,7 @@


using WIDESEAWCS_QuartzJob.Models;


using WIDESEAWCS_QuartzJob.Repository;


using WIDESEAWCS_QuartzJob.Service;


using WIDESEAWCS_TaskInfoRepository;


using ICacheService = WIDESEAWCS_Core.Caches.ICacheService;




namespace WIDESEAWCS_TaskInfoService


@@ -56,6 +59,7 @@


        private readonly ITaskExecuteDetailRepository _taskExecuteDetailRepository;


        private readonly IStationMangerRepository _stationMangerRepository;


        private readonly IRouterRepository _routerRepository;


        private readonly IApiInfoRepository _apiInfoRepository;


        private List<Dt_ApiInfo> apiInfos;




        private Dictionary<string, OrderByType> _taskOrderBy = new()


@@ -72,7 +76,7 @@




        public List<int> TaskOutboundTypes => typeof(TaskTypeEnum).GetEnumIndexList().Where(x => x >= 100 && x < 500).ToList();




        public TaskService(ITaskRepository BaseDal, IMapper mapper, ICacheService cacheService, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository) : base(BaseDal)


        public TaskService(ITaskRepository BaseDal, IMapper mapper, ICacheService cacheService, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository, IApiInfoRepository apiInfoRepository) : base(BaseDal)


        {


            _mapper = mapper;


            _cacheService = cacheService;


@@ -81,6 +85,7 @@


            _taskExecuteDetailRepository = taskExecuteDetailRepository;


            _stationMangerRepository = stationMangerRepository;


            _routerRepository = routerRepository;


            _apiInfoRepository = apiInfoRepository;




            string? cacheStr = _cacheService.Get(nameof(Dt_Warehouse));


            if (!string.IsNullOrEmpty(cacheStr))


@@ -102,7 +107,6 @@


                    apiInfos = infos;


                }


            }




        }




        public WebResponseContent TaskCompleted(int taskNum)


@@ -152,7 +156,6 @@


                    }


                    Dt_Task task = _mapper.Map<Dt_Task>(item);


                    task.Creater = "WMS";


                    task.AgvTaskNum = "AGV-" + item.TaskNum;


                    task.TaskState = (int)TaskStatusEnum.New;


                    task.CurrentAddress = item.SourceAddress;




@@ -162,6 +165,7 @@




                    if (string.IsNullOrEmpty(item.AGVArea))


                    {


                        //task.AgvTaskNum = "AGV-" + DateTime.Now.ToString("yyyyMMdd") + item.TaskNum;


                        Dt_StationManger stationManger = _stationMangerRepository.QueryFirst(x => x.StationCode == item.SourceAddress || x.StackerCraneCode == item.RoadWay);


                        if (stationManger == null)


                        {


@@ -189,6 +193,7 @@


                    {


                        if (item.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)


                        {


                            task.AgvTaskNum = "AGV-" + DateTime.Now.ToString("yyyyMMdd") + item.TaskNum;


                            List<Dt_Router> routers = _routerRepository.QueryData(x => x.InOutType == item.TaskType && item.AGVArea == x.NextPosi);


                            if (routers.FirstOrDefault() == null)


                            {


@@ -202,6 +207,7 @@


                        }


                        else


                        {


                            task.AgvTaskNum = "AGV-" + DateTime.Now.ToString("yyyyMMdd") + item.TaskNum;


                            List<Dt_Router> routers = _routerRepository.QueryData(x => x.InOutType == item.TaskType && item.AGVArea == x.StartPosi);


                            if (routers.FirstOrDefault() == null)


                            {


@@ -216,7 +222,7 @@


                            }




                            task.NextAddress = stationManger?.AGVStationCode ?? "";


                            task.DeviceCode = "AGV";


                            task.DeviceCode = stationManger?.Remark ?? "";


                            task.TaskState = TaskStatusEnum.AGV_Execute.ObjToInt();


                        }


                    }


@@ -227,7 +233,7 @@




                _taskExecuteDetailService.AddTaskExecuteDetail(tasks.Select(x => x.TaskNum).ToList(), "鎺ユ敹WMS浠诲姟");




                content = WebResponseContent.Instance.OK("鎴愬姛");


                content = tasks.Count > 0 ? WebResponseContent.Instance.OK("鎴愬姛") : WebResponseContent.Instance.Error("澶辫触");


            }


            catch (Exception ex)


            {


@@ -274,7 +280,7 @@


        /// <returns></returns>


        public string? RequestAssignLocation(int taskNum, string roadwayNo)


        {


            string responseStr = HttpHelper.Get($"http://127.0.0.1:9293/api/Task/AssignInboundTaskLocation?taskNum={taskNum}&roadwayNo={roadwayNo}");


            string responseStr = HttpHelper.Get($"http://127.0.0.1:9283/api/Task/AssignInboundTaskLocation?taskNum={taskNum}&roadwayNo={roadwayNo}");




            WebResponseContent? responseContent = JsonConvert.DeserializeObject<WebResponseContent>(responseStr);


            if (responseContent != null && responseContent.Status && responseContent.Data != null)


@@ -465,5 +471,35 @@


            }


            return content;


        }




        public WebResponseContent SendSecureReplyToAgv(int taskNum)


        {


            try


            {


                Dt_Task WaitToTask = BaseDal.QueryFirst(x => x.TaskState == TaskStatusEnum.AGV_WaitToExecute.ObjToInt() && x.TaskNum == taskNum);


                AgvSecureReplyDTO replyDTO = new AgvSecureReplyDTO()


                {


                    ReqCode = Guid.NewGuid().ToString().Replace("-", ""), //WaitToTask.TaskNum.ToString(),


                    taskCode = WaitToTask.AgvTaskNum,


                };


                WebResponseContent content = AgvSecureReply(replyDTO);


                if (content.Status)


                {


                    WaitToTask.TaskState = TaskStatusEnum.AGV_Executing.ObjToInt();


                }


                else


                {


                    WaitToTask.TaskState = TaskStatusEnum.Exception.ObjToInt();


                    WaitToTask.ExceptionMessage = content.Message;


                }


                UpdateData(WaitToTask);




                return WebResponseContent.Instance.OK();


            }


            catch (Exception ex)


            {


                return WebResponseContent.Instance.Error(ex.Message);


            }


        }


    }


}