最新

zhangchengsong

4 天以前 0e450768c357b45701a2e5ed162f4e93b3dd617c

 ÏîÄ¿´úÂë/WIDESEAWCS_Server/WIDESEAWCS_Tasks/StackerCraneJob/CommonStackerCraneJob.cs

@@ -56,13 +56,12 @@
            _DtPlatformStationService= dt_PlatformStationService;
        }

        public Task Execute(IJobExecutionContext context)
        public  Task Execute(IJobExecutionContext context)
        {
            try
            {
                CommonStackerCrane commonStackerCrane = (CommonStackerCrane)context.JobDetail.JobDataMap.Get("JobParams");
                

                CommonStackerCrane commonStackerCrane = (CommonStackerCrane)context.JobDetail.JobDataMap.Get("JobParams");
                if (commonStackerCrane != null)
                {

@@ -96,13 +95,6 @@
                        }
                    }

                    WriteLog.Write_Log("堆垛机当前状态", "堆垛机当前状态信息", $"堆垛机设备地址:【DB105.2.0】,读取的数据：【{commonStackerCrane.StackerCraneAutoStatusDes}】\n" +
                           $"堆垛机工作模式地址:【DB105.3.0】,读取的数据：【{commonStackerCrane.StackerCraneStatusDes}】\n" +
                           $"堆垛机作业状态地址:【DB105.22.0】,读取的数据：【{commonStackerCrane.StackerCraneWorkStatusDes}】\n" +
                           $"堆垛机当前任务执行中地址:【DB105.18.0】,读取的数据：【{commonStackerCrane.CurrentTaskNum}】\n");

                  
                   

                    if (commonStackerCrane.StackerCraneAutoStatusValue == StackerCraneAutoStatus.Automatic && commonStackerCrane.StackerCraneStatusValue == StackerCraneStatus.Normal)
                    {
@@ -185,7 +177,6 @@
                        }
                        else if (taskItem.TaskType == (int)TaskTypeEnum.Inbound || taskItem.TaskType == (int)TaskTypeEnum.Inventorybound)
                        {
                            InTaskStationIsOccupied(taskItem.SourceAddress, taskItem.Roadway);
                            return taskItem;
                        }
                    }
@@ -220,7 +211,6 @@

                    int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                    int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);
                     conveyorLine.Communicator.Write<short>(HandShakeprodto.DeviceProAddress, 1);

                    WriteLog.Write_Log("出库库口状态信息", "出库库口状态信息", $"库口是【{NextAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n" +
                         $"库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
@@ -256,44 +246,7 @@

            return false;
        }
        /// <summary>
        /// å…¥åº“任务库口有货无货状态
        /// </summary>
        private void InTaskStationIsOccupied(string SourceAddress, string Roadway)
        {
            try
            {
                if (Roadway == "C")
                {
                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1004");
                    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                    DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "StationNum");
                    DeviceProDTO? HandShakeprodto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "HandShake");
 
                    int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                    int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);
                    WriteLog.Write_Log("入库库口状态信息", "入库库口状态信息", $"库口是【{SourceAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n" +
                        $"库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
                }
                else
                {
                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1003");
                    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                    DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "StationNum");
                    DeviceProDTO? HandShakeprodto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "HandShake");

                    int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                    int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);
                    WriteLog.Write_Log("入库库口状态信息", "入库库口状态信息", $"库口是【{SourceAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n" +
                        $"库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("读取站台信息错误：" + ex.Message);
            }

        }

        /// <summary>
        /// ä»»åŠ¡å®žä½“转换成命令Model
@@ -451,53 +404,37 @@
        /// <param name="stackerCraneWorkStatusDes"></param>
        public void UpdateHandShake(int taskNum, string stackerCraneWorkStatusDes)
        {
            // 1. æŸ¥è¯¢ä»»åŠ¡ï¼Œç©ºå€¼ç›´æŽ¥è¿”回
            Dt_Task? dtTask = _taskRepository.QueryFirst(x => x.TaskNum == taskNum);
            if (dtTask == null) return;

            // 2. å®šä¹‰å›ºå®šåœ°å€
            string[] targetAddresses = { "G03", "G04", "C02", "C01" };

            // 3. æ¡ä»¶åˆ¤æ–­ + ç¡®å®šå†™å…¥å€¼
            short writeValue = -1;
            if (dtTask.TaskType == 100 && targetAddresses.Contains(dtTask.TargetAddress))
            try
            {
                writeValue = stackerCraneWorkStatusDes switch
                Dt_Task? dtTask = _taskRepository.QueryFirst(x => x.TaskNum == taskNum);
                if (dtTask == null) return;

                string[] targetAddresses = { "G03", "G04", "C02", "C01" };
                if (dtTask.TaskType != 100 || !targetAddresses.Contains(dtTask.TargetAddress))
                    return;

                short writeValue = stackerCraneWorkStatusDes switch
                {
                    "放货中" => 1,
                    "任务完成" => 0,
                    _ => -1
                };
            }

            // 4. èŽ·å–设备编码
            string deviceCode = dtTask.CurrentAddress.StartsWith("C") ? "1004" : "1003";
                if (writeValue == -1) return;

            // 5. èŽ·å–设备，空值直接返回
            IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == deviceCode);
            if (device != null && writeValue != -1)
            {
                CommonConveyorLine? conveyorLine = (CommonConveyorLine)device;
                string deviceCode = dtTask.CurrentAddress.StartsWith("C") ? "1004" : "1003";
                IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == deviceCode);
                if (device == null) return;

                // 6. èŽ·å–握手点位，空值直接返回
                CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                DeviceProDTO? handShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == dtTask.TargetAddress && x.DeviceProParamName == "HandShake");
                if (handShake == null)
                {
                    WriteLog.Write_Log("出库库口光栅状态错误信息", "出库库口光栅状态错误信息", $"WCS未找到库口信息是【{dtTask.TargetAddress}】，任务号：【{dtTask.TaskNum}】,堆垛机作业状态：【{stackerCraneWorkStatusDes}】");
                    return;
                }
                    // 7. å†™å…¥å€¼
                 conveyorLine.Communicator.Write<short>(handShake.DeviceProAddress, writeValue);
                WriteLog.Write_Log("出库库口光栅状态正常信息", "出库库口光栅状态正常信息", $"库口是【{dtTask.TargetAddress}】，申请状态地址：【{handShake.DeviceProAddress}】,读取的数据：【{conveyorLine.Communicator.Read<ushort>(handShake.DeviceProAddress)}】\n" +
                 $"任务号：【{dtTask.TaskNum}】,堆垛机作业状态：【{stackerCraneWorkStatusDes}】");
                return;
                if (handShake == null) return;

                conveyorLine.Communicator.Write<short>(handShake.DeviceProAddress, writeValue);
            }
            else
            catch
            {
                WriteLog.Write_Log("出库库口光栅状态错误信息", "出库库口光栅状态错误信息", $"库口是【{dtTask.TargetAddress}】，任务号：【{dtTask.TaskNum}】,堆垛机作业状态：【{stackerCraneWorkStatusDes}】");
                return;
            }
           
        }

    }