feat: 添加消防任务支持并修复堆垛机状态处理

wanshenmean

5 天以前 fe2a1e74780259605cd230e6f9c629c3dd7fdf15

 Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_QuartzJob/StackerCrane/Spec/SpeTemperatureStackerCrane.cs

@@ -16,6 +16,30 @@
    [Description("高常温堆垛机")]
    public class SpeTemperatureStackerCrane : StackerCraneBase, IStackerCrane
    {
        #region Constants

        /// <summary>
        /// 设备等待间隔时间（毫秒）
        /// </summary>
        private const int WaitIntervalMs = 500;

        /// <summary>
        /// 设备等待超时时间基数（毫秒）
        /// </summary>
        private const int WaitTimeoutBaseMs = 6000;

        /// <summary>
        /// 设备等待超时时间倍数
        /// </summary>
        private const int WaitTimeoutMultiplier = 10;

        /// <summary>
        /// 设备等待总超时时间（毫秒）
        /// </summary>
        private static readonly int WaitTotalTimeoutMs = WaitTimeoutMultiplier * WaitTimeoutBaseMs;

        #endregion Constants

        #region Private Member

        /// <summary>
@@ -173,7 +197,7 @@
        {
            if (!Communicator.IsConnected)
            {
                return StackerCraneStatus.Unkonw.ToString();
                return StackerCraneStatus.Unknown.ToString();
            }

            List<DeviceProDTO> devicePros = _deviceProDTOs.Where(x => x.DeviceProParamType == protocolParamType).ToList();
@@ -196,7 +220,7 @@
                }
            }

            return StackerCraneStatus.Unkonw.ToString();
            return StackerCraneStatus.Unknown.ToString();
        }

        /// <summary>
@@ -410,22 +434,22 @@

            return typeCode switch
            {
                TypeCode.Boolean => Communicator.Wait(devicePro.DeviceProAddress, 500, 10 * 6000,
                TypeCode.Boolean => Communicator.Wait(devicePro.DeviceProAddress, WaitIntervalMs, WaitTotalTimeoutMs,
                    Convert.ToBoolean(deviceProtocolDetail.ProtocalDetailValue)),

                TypeCode.Byte => Communicator.Wait(devicePro.DeviceProAddress, 500, 10 * 6000,
                TypeCode.Byte => Communicator.Wait(devicePro.DeviceProAddress, WaitIntervalMs, WaitTotalTimeoutMs,
                    Convert.ToByte(deviceProtocolDetail.ProtocalDetailValue)),

                TypeCode.Int16 => Communicator.Wait(devicePro.DeviceProAddress, 500, 10 * 6000,
                TypeCode.Int16 => Communicator.Wait(devicePro.DeviceProAddress, WaitIntervalMs, WaitTotalTimeoutMs,
                    Convert.ToInt16(deviceProtocolDetail.ProtocalDetailValue)),

                TypeCode.Int32 => Communicator.Wait(devicePro.DeviceProAddress, 500, 10 * 6000,
                TypeCode.Int32 => Communicator.Wait(devicePro.DeviceProAddress, WaitIntervalMs, WaitTotalTimeoutMs,
                    Convert.ToInt32(deviceProtocolDetail.ProtocalDetailValue)),

                TypeCode.UInt16 => Communicator.Wait(devicePro.DeviceProAddress, 500, 10 * 6000,
                TypeCode.UInt16 => Communicator.Wait(devicePro.DeviceProAddress, WaitIntervalMs, WaitTotalTimeoutMs,
                    Convert.ToUInt16(deviceProtocolDetail.ProtocalDetailValue)),

                TypeCode.UInt32 => Communicator.Wait(devicePro.DeviceProAddress, 500, 10 * 6000,
                TypeCode.UInt32 => Communicator.Wait(devicePro.DeviceProAddress, WaitIntervalMs, WaitTotalTimeoutMs,
                    Convert.ToUInt32(deviceProtocolDetail.ProtocalDetailValue)),

                _ => new OperateResult<TimeSpan>()