龙得利纸质行业立库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
wangxinhui
22 小时以前 c6e8b600398de38b6684f5fa1eaaaade8562859b 
 项目代码/WCS/WCSServices/WIDESEAWCS_Tasks/原料库/StackerCraneJob_YLSC3.cs


@@ -20,9 +20,11 @@


using WIDESEAWCS_Tasks.StackerCraneJob;


using WIDESEAWCS_Tasks;


using WIDESEAWCS_Core;


using SqlSugar.Extensions;


using WIDESEAWCS_Tasks.ConveyorLineJob;


using WIDESEAWCS_QuartzJob.Repository;


using WIDESEAWCS_Core.Helper;


using HslCommunication.WebSocket;


using WIDESEAWCS_DTO.Equipment;




namespace WIDESEAWCS_Tasks


{


@@ -36,8 +38,9 @@


        private readonly IRouterService _routerService;


        private readonly IRouterRepository _routerRepository;


        private readonly IStationMangerRepository _stationMangerRepository;


        private WebSocketServer _webSocketServer;




        public StackerCraneJob_YLSC3(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository)


        public StackerCraneJob_YLSC3(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository,WebSocketServer webSocketServer)


        {


            _taskService = taskService;


            _taskExecuteDetailService = taskExecuteDetailService;


@@ -45,6 +48,7 @@


            _routerService = routerService;


            _stationMangerRepository = stationMangerRepository;


            _routerRepository = routerRepository;


            _webSocketServer = webSocketServer;


        }




        public Task Execute(IJobExecutionContext context)


@@ -76,8 +80,7 @@


                                        commonStackerCrane.LastTaskType = task.TaskType;


                                        task.Dispatchertime = DateTime.Now;


                                        task.ExceptionMessage = "";


                                        _taskService.UpdateTask(task, TaskStatusEnum.SC_Executing);


                                        //_taskService.UpdateTaskStatusToNext(task);


                                        _taskService.UpdateTaskStatusToNext(task);


                                        commonStackerCrane.Communicator.Write("DB1000.20.0", true);


                                        //寤舵椂1s


                                        Thread.Sleep(1000);


@@ -86,6 +89,25 @@


                            }


                        }


                    }




                    #region 璋冪敤浜嬩欢鎬荤嚎閫氱煡鍓嶇




                    EquipmentDTO equipmentDTO = new EquipmentDTO();


                    object obj = new


                    {


                        commonStackerCrane.DeviceName,


                        commonStackerCrane.DeviceCode,


                        StackerCraneAutoStatus.Automatic,


                        StackerCraneStatus.Normal,


                        StackerCraneWorkStatus.Standby,


                        TaskNum = commonStackerCrane.CurrentTaskNum,


                        WorkType = commonStackerCrane.GetValue<StackerCraneDBName, short>(StackerCraneDBName.WorkType),


                        StackerAlarm = commonStackerCrane.Communicator.Read<short>("DB1000.54.0"),


                    };


                    equipmentDTO.StackerDataJson = obj.Serialize();


                    _webSocketServer.PublishAllClientPayload(equipmentDTO.Serialize());




                    #endregion


                }


            }


            catch (Exception ex)


@@ -153,6 +175,7 @@


                                conveyorLine.SetValue(ConveyorLineDBName.TaskNum, taskNum, stationManger.StationCode);


                                conveyorLine.SetValue(ConveyorLineDBName.TargetAddress, router.NextPosi, stationManger.StationCode);


                                conveyorLine.SetValue(ConveyorLineDBName.Width, task.TaskLength, stationManger.StationCode);


                                conveyorLine.SetValue(ConveyorLineDBName.Height, task.HeightType, stationManger.StationCode);


                                conveyorLine.SetValue(ConveyorLineDBName.Barcode, task.PalletCode, stationManger.StationCode);


                                conveyorLine.SetValue(ConveyorLineDBName.ResponState, 86, stationManger.StationCode);


                                _taskService.UpdateTaskStatusToNext(task);