穿梭车堆垛机立体库
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
dengjunjie
2025-04-14 970d9c5c36d526a587138232ae9dae719dbcd16d 
 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/StackerCraneJob/CommonStackerCraneJob.cs


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


using WIDESEAWCS_Common.StackerCraneEnum;


using WIDESEAWCS_Common.TaskEnum;


using WIDESEAWCS_Core;


using WIDESEAWCS_Core.Caches;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_IShuttleCar;


using WIDESEAWCS_ITaskInfoRepository;


@@ -29,6 +30,7 @@


using WIDESEAWCS_QuartzJob.StackerCrane.Enum;


using WIDESEAWCS_TaskInfoService;


using WIDESEAWCS_Tasks.ConveyorLineJob;


using WIDESEAWCS_Tasks.ShuttleCarJob;


using WIDESEAWCS_Tasks.StackerCraneJob;




namespace WIDESEAWCS_Tasks


@@ -41,14 +43,16 @@


        private readonly ITaskRepository _taskRepository;


        private readonly IRouterService _routerService;


        private readonly IShuttleCarService _shuttleCarService;


        private readonly ICacheService _cacheService;




        public CommonStackerCraneJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IShuttleCarService shuttleCarService)


        public CommonStackerCraneJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IShuttleCarService shuttleCarService, ICacheService cacheService)


        {


            _taskService = taskService;


            _taskExecuteDetailService = taskExecuteDetailService;


            _taskRepository = taskRepository;


            _routerService = routerService;


            _shuttleCarService = shuttleCarService;


            _cacheService = cacheService;


        }




        public Task Execute(IJobExecutionContext context)


@@ -59,6 +63,10 @@


                if (commonStackerCrane != null)


                {


                    commonStackerCrane.Communicator.IsReadAfterWrite = false;


                    #region èŽ·å–堆垛机信息


                    StackerCraneTaskCommandR common = ReadCustomer<StackerCraneTaskCommandR>(commonStackerCrane, commonStackerCrane.DeviceCode);


                    _cacheService.AddOrUpdate(commonStackerCrane.DeviceCode, common);


                    #endregion


                    #region ä¿¡å·äº¤äº’处理


                    //Heartbeat(commonStackerCrane);


                    ShuttleCarSignal(commonStackerCrane);


@@ -66,7 +74,7 @@




                    #region ä»»åŠ¡å®Œæˆ


                    var completeStatus = commonStackerCrane.GetValue<StackerCraneDBName, short>(StackerCraneDBName.CompleteStatus);


                    if (completeStatus == 2 || completeStatus == 3)


                    if (common.CompleteStatus == 2 || common.CompleteStatus == 3)


                    {


                        NormalCompleted(commonStackerCrane);


                    }