百步立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
肖洋
2024-12-10 01ba2e2affa33320ef8aca6e033248388bb8f60e 
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_After/CommonConveyorLine_AfterJob.cs


@@ -29,10 +29,14 @@


using System.Threading.Tasks;


using WIDESEAWCS_BasicInfoRepository;


using WIDESEAWCS_BasicInfoService;


using WIDESEAWCS_Common;


using WIDESEAWCS_Common.TaskEnum;


using WIDESEAWCS_Core;


using WIDESEAWCS_Core.Caches;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_Core.HttpContextUser;


using WIDESEAWCS_DTO.TaskInfo;


using WIDESEAWCS_ISystemServices;


using WIDESEAWCS_ITaskInfoRepository;


using WIDESEAWCS_ITaskInfoService;


using WIDESEAWCS_Model.Models;


@@ -40,7 +44,9 @@


using WIDESEAWCS_QuartzJob.DeviceBase;


using WIDESEAWCS_QuartzJob.DTO;


using WIDESEAWCS_QuartzJob.Service;


using WIDESEAWCS_SignalR;


using WIDESEAWCS_Tasks.ConveyorLineJob;


using ICacheService = WIDESEAWCS_Core.Caches.ICacheService;




namespace WIDESEAWCS_Tasks


{


@@ -53,8 +59,11 @@


        private readonly IRouterService _routerService;


        private readonly IMapper _mapper;


        private readonly IDt_StationManagerService _stationManagerService;


        private readonly ISys_ConfigService _sys_ConfigService;


        private readonly ICacheService _cacheService;


        private readonly INoticeService _noticeService;




        public CommonConveyorLine_AfterJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IDt_StationManagerService stationManagerService)


        public CommonConveyorLine_AfterJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IDt_StationManagerService stationManagerService, ISys_ConfigService sys_ConfigService, ICacheService cacheService, INoticeService noticeService)


        {


            _taskService = taskService;


            _taskExecuteDetailService = taskExecuteDetailService;


@@ -62,9 +71,12 @@


            _mapper = mapper;


            _taskRepository = taskRepository;


            _stationManagerService = stationManagerService;


            _sys_ConfigService = sys_ConfigService;


            _cacheService = cacheService;


            _noticeService = noticeService;


        }




        public Task Execute(IJobExecutionContext context)


        public async Task Execute(IJobExecutionContext context)


        {


            try


            {


@@ -85,6 +97,29 @@


                                method.Invoke(this, new object[] { conveyorLine, command, station });


                            }


                        }


                        if (station.stationType == 6 && station.stationArea == "3")


                        {


                            await GetEmptyTrayAsync(station);


                        }




                        #region 调用事件总线通知前端




                        var tokenInfos = _cacheService.Get<List<UserInfo>>("Cache_UserToken");


                        if (tokenInfos == null || !tokenInfos.Any())


                        {


                            //throw new Exception(conveyorLine.DeviceName + "缓存中未找到Token缓存");


                            continue;


                        }


                        var userTokenIds = tokenInfos?.Select(x => x.Token_ID).ToList();


                        var userIds = tokenInfos?.Select(x => x.UserId).ToList();




                        object obj = new


                        {


                            commandAfter = command,


                        };


                        _noticeService.StackerData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, data = obj });




                        #endregion 调用事件总线通知前端


                    }




                    #region 路由方式


@@ -117,7 +152,7 @@


                //WriteDebug("CommonConveyorLineJob", "test");


                //Console.Out.WriteLine(DateTime.Now);


            }


            return Task.CompletedTask;


            return;


        }




        /// <summary>


@@ -128,6 +163,7 @@


        /// <param name="childDeviceCode">子设备编号</param>


        public void RequestInbound(CommonConveyorLine_After conveyorLine, ConveyorLineTaskCommand_After command, Dt_StationManager stationInfo)


        {


            ConsoleHelper.WriteSuccessLine($"【{conveyorLine.DeviceName}】,托盘号：【{command.ConveyorLineBarcode}】,站台：【{stationInfo.remark}】请求任务");


            var taskNew = _taskService.QueryTaskByPalletCode(command.ConveyorLineBarcode, stationInfo.Roadway);


            if (taskNew == null)


            {


@@ -161,6 +197,7 @@


            var taskNew = _taskRepository.QueryFirst(x => x.Roadway == stationInfo.Roadway && x.TaskType == (int)TaskOutboundTypeEnum.OutTray);


            if (taskNew == null)   //不存在空框出库任务 则请求WMS出空库


            {


                ConsoleHelper.WriteWarningLine("请求空托盘");


                if (_taskService.RequestTask(command.ConveyorLineBarcode, stationInfo).Result.Status)


                {


                    Dt_Task task = _taskService.QueryTaskByPalletCode(command.ConveyorLineBarcode, stationInfo.Roadway);


@@ -216,6 +253,30 @@


        //    }


        //}




        private async Task GetEmptyTrayAsync(Dt_StationManager stationManager)


        {


            var config = _sys_ConfigService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);


            var wmsBase = config.FirstOrDefault(x => x.ConfigKey == SysConfigKeyConst.WMSIP_BASE)?.ConfigValue;


            var requestTask = config.FirstOrDefault(x => x.ConfigKey == SysConfigKeyConst.GetFROutTrayToCW)?.ConfigValue;


            if (wmsBase == null || requestTask == null)


            {


                throw new InvalidOperationException("WMS IP 未配置");


            }


            var wmsIpAddrss = wmsBase + requestTask;




            var result = await HttpHelper.PostAsync(wmsIpAddrss, new { palletCode = "", EquiCodeMOM = stationManager.stationEquipMOM, Roadways = stationManager.Roadway, area = stationManager.stationArea, Position = stationManager.stationChildCode }.ToJsonString());


            WebResponseContent content = JsonConvert.DeserializeObject<WebResponseContent>(result);


            if(!content.Status)


            {


                //ConsoleHelper.WriteErrorLine($"分容呼叫空托盘失败{content.Message}");


                return;


            }


            WMSTaskDTO wMSTaskDTO = JsonConvert.DeserializeObject<WMSTaskDTO>(content.Data.ToString());




            ConsoleHelper.WriteSuccessLine(content.Data.ToString());


            List<WMSTaskDTO> wMSTaskDTOs = new List<WMSTaskDTO>() { wMSTaskDTO };


            _taskService.ReceiveWMSTask(wMSTaskDTOs);


        }


    }


}


#endregion