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


@@ -4,7 +4,9 @@


using System.Diagnostics.CodeAnalysis;


using WIDESEAWCS_BasicInfoRepository;


using WIDESEAWCS_Common.TaskEnum;


using WIDESEAWCS_Core.Caches;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_Core.HttpContextUser;


using WIDESEAWCS_DTO.MOM;


using WIDESEAWCS_IProcessRepository;


using WIDESEAWCS_ITaskInfoRepository;


@@ -16,6 +18,7 @@


using WIDESEAWCS_QuartzJob.Models;


using WIDESEAWCS_QuartzJob.Service;


using WIDESEAWCS_QuartzJob.StackerCrane.Enum;


using WIDESEAWCS_SignalR;


using WIDESEAWCS_Tasks.StackerCraneJob;




namespace WIDESEAWCS_Tasks


@@ -28,14 +31,18 @@


        private readonly ITaskRepository _taskRepository;


        private readonly IProcessRepository _processRepository;


        private readonly IDt_StationManagerRepository _stationManagerRepository;


        private readonly ICacheService _cacheService;


        private readonly INoticeService _noticeService;




        public CommonStackerStationCraneJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IProcessRepository processRepository, IDt_StationManagerRepository stationManagerRepository)


        public CommonStackerStationCraneJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IProcessRepository processRepository, IDt_StationManagerRepository stationManagerRepository, ICacheService cacheService, INoticeService noticeService)


        {


            _taskService = taskService;


            _taskExecuteDetailService = taskExecuteDetailService;


            _taskRepository = taskRepository;


            _processRepository = processRepository;


            _stationManagerRepository = stationManagerRepository;


            _cacheService = cacheService;


            _noticeService = noticeService;


        }




        public Task Execute(IJobExecutionContext context)


@@ -78,6 +85,31 @@


                            }


                        }


                    }




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




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


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


                    {


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


                        return Task.CompletedTask;


                    }


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


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




                    object obj = new


                    {


                        commonStackerCrane.StackerCraneStatusDes,


                        commonStackerCrane.StackerCraneAutoStatusDes,


                        commonStackerCrane.StackerCraneWorkStatusDes,


                        commonStackerCrane.DeviceCode,


                        commonStackerCrane.DeviceName,


                        commonStackerCrane.CurrentTaskNum,


                        commonStackerCrane.LastTaskNum,


                    };


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




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


                }


            }


            catch (Exception ex)


@@ -85,7 +117,7 @@


                WriteError("CommonStackerStationCraneJob", "test", ex);


                //Console.WriteLine(nameof(CommonStackerCraneJob) + ":" + ex.ToString());


            }


            WriteDebug("CommonStackerStationCraneJob", "test");


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


            return Task.CompletedTask;


        }




@@ -116,6 +148,13 @@


        private Dt_Task? GetTask(CommonStackerStationCrane commonStackerCrane)


        {


            Dt_Task task;




            task = _taskService.QueryRelocationTask(commonStackerCrane.DeviceCode);


            if (task != null)


            {


                return task;


            }




            if (commonStackerCrane.LastTaskType == null)


            {


                task = _taskService.QueryStackerCraneTask(commonStackerCrane.DeviceCode);


@@ -207,7 +246,7 @@


            string[] sourceCodes = task.SourceAddress.Split("-");


            if (sourceCodes.Length == 3)


            {


                stackerCraneTaskCommand.StartRow = (short)(Convert.ToInt16(sourceCodes[0]) % 2 == 0 ? 2:1);


                stackerCraneTaskCommand.StartRow = (short)(Convert.ToInt16(sourceCodes[0]) % 2 == 0 ? 2 : 1);


                stackerCraneTaskCommand.StartColumn = Convert.ToInt16(sourceCodes[1]);


                stackerCraneTaskCommand.StartLayer = Convert.ToInt16(sourceCodes[2]);


            }


@@ -239,7 +278,7 @@


                //}


                //else


                //{


                   




                //}


                stackerCraneTaskCommand.EndRow = (short)(Convert.ToInt16(targetCodes[0]) % 2 == 0 ? 2 : 1);


                stackerCraneTaskCommand.EndColumn = Convert.ToInt16(targetCodes[1]);