1

z8018

2025-06-10 e46aa927d231af83724683c7286d9db503e24cf7

 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/CommonConveyorLightJob.cs

@@ -14,6 +14,15 @@

namespace WIDESEAWCS_Tasks
{
    /// <summary>
    /// é€šç”¨ä¼ é€å¸¦ç¯å…‰æŽ§åˆ¶ä»»åŠ¡ <br/>
    /// ä»ŽPLC读取站点状态和释放信号，更新灯光状态字典，并设置对应的PLC信号 <br/>
    /// ä¸»è¦åŠŸèƒ½ï¼š <br/>
    /// 1. è¯»å–PLC中DB15.922.0和DB15.924.0的16位布尔数组作为站点状态和释放信号 <br/>
    /// 2. æ ¹æ®è®¾å¤‡å­ç åˆ†ç»„æ›´æ–°LightStatusStorage中的状态字典 <br/>
    /// 3. æ ¹æ®å½“前灯光状态设置PLC对应的完成/错误/工作中/语音信号 <br/>
    /// å¼‚常处理：记录设备代码和名称相关的异常信息
    /// </summary>
    [DisallowConcurrentExecution]
    public class CommonConveyorLightJob : JobBase, IJob
    {
@@ -31,9 +40,8 @@
        public Task Execute(IJobExecutionContext context)
        {
            bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);
            if (flag && value != null && value is OtherDevice)
            if (flag && value != null && value is OtherDevice otherDevice)
            {
                OtherDevice otherDevice = (OtherDevice)value;
                try
                {
                    bool[] stationStatusArray = otherDevice.Communicator.Read<bool>("DB15.922.0", 16);
@@ -122,40 +130,6 @@

                                    if (otherDevice.GetValue<LightStatusEnum, bool>(LightStatusEnum.LightVoice, deviceChildCodes[i]))
                                        otherDevice.SetValue(LightStatusEnum.LightVoice, false, deviceChildCodes[i]);
                                }
                                else if (LightStatusStorage.LightStatusDic[deviceChildCodes[i]] == LightStatusEnum.ReadyRelease)
                                {
                                    Dt_Task task = _taskRepository.QueryFirst(x => x.NextAddress.Contains(deviceChildCodes[i]));
                                    if (task == null)
                                    {
                                        Dt_Container container = _containerRepository.QueryFirst(x => x.ContainerCode == deviceChildCodes[i]);
                                        if (container != null && container.ContainerStatus == ContainerStatusEnum.ReadyRelease.ObjToInt())
                                        {
                                            container.ContainerStatus = ContainerStatusEnum.Release.ObjToInt();

                                            _containerRepository.UpdateData(container);

                                            if (!otherDevice.GetValue<LightStatusEnum, bool>(LightStatusEnum.LightCompleted, deviceChildCodes[i]))
                                                otherDevice.SetValue(LightStatusEnum.LightCompleted, true, deviceChildCodes[i]);

                                            if (otherDevice.GetValue<LightStatusEnum, bool>(LightStatusEnum.LightError, deviceChildCodes[i]))
                                                otherDevice.SetValue(LightStatusEnum.LightError, false, deviceChildCodes[i]);

                                            if (otherDevice.GetValue<LightStatusEnum, bool>(LightStatusEnum.LightWorking, deviceChildCodes[i]))
                                                otherDevice.SetValue(LightStatusEnum.LightWorking, false, deviceChildCodes[i]);

                                            if (otherDevice.GetValue<LightStatusEnum, bool>(LightStatusEnum.LightVoice, deviceChildCodes[i]))
                                                otherDevice.SetValue(LightStatusEnum.LightVoice, false, deviceChildCodes[i]);

                                            //_webSocketServer发送数据
                                            _webSocketServer.PublishAllClientPayload(new
                                            {
                                                stationCode = deviceChildCodes[i],
                                                release = 1,
                                            }.Serialize());
                                        }

                                    }
                                }
                                else if (LightStatusStorage.LightStatusDic[deviceChildCodes[i]] == LightStatusEnum.Ready)
                                {