百步立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
肖洋
2024-12-11 68dbe298a5c67d8755cb4379e5106de7c54608c6 
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs


@@ -33,7 +33,9 @@


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.MOM;


using WIDESEAWCS_DTO.TaskInfo;


using WIDESEAWCS_IProcessRepository;


@@ -46,7 +48,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


{


@@ -61,8 +65,10 @@


        private readonly ISys_ConfigService _sys_ConfigService;


        private readonly IMapper _mapper;


        private readonly IDt_StationManagerRepository _stationManagerRepository;


        private readonly ICacheService _cacheService;


        private readonly INoticeService _noticeService;




        public CommonConveyorLine_GWJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IPlatFormRepository platFormRepository, ISys_ConfigService sys_ConfigService, IDt_StationManagerRepository stationManagerRepository)


        public CommonConveyorLine_GWJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IPlatFormRepository platFormRepository, ISys_ConfigService sys_ConfigService, IDt_StationManagerRepository stationManagerRepository, ICacheService cacheService, INoticeService noticeService)


        {


            _taskService = taskService;


            _taskExecuteDetailService = taskExecuteDetailService;


@@ -72,6 +78,8 @@


            _platFormRepository = platFormRepository;


            _sys_ConfigService = sys_ConfigService;


            _stationManagerRepository = stationManagerRepository;


            _cacheService = cacheService;


            _noticeService = noticeService;


        }




        public Task Execute(IJobExecutionContext context)


@@ -157,6 +165,26 @@


                            }


                        }




                        #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


                        {


                            childDeviceCode,


                            commandAfter = command,


                        };


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




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




                    }


                    #endregion




@@ -189,7 +217,7 @@


                var task = _taskService.QueryBarCodeConveyorLineTask(command.ConveyorLineBarcode, childDeviceCode);


                //HandleTaskOut(conveyorLine, command, childDeviceCode, task);


                // && command.ConveyorLineBarcode != "NoRead" && !command.ConveyorLineBarcode.IsNotEmptyOrNull()




                ConsoleHelper.WriteSuccessLine($"【{conveyorLine.DeviceName}】托盘号：【{command.ConveyorLineBarcode}】设备编码：【{childDeviceCode}】");


                if (task == null)


                {


                    HandleNewTask(conveyorLine, command, childDeviceCode);