修复和优化 Dt_TaskService.cs 中的任务请求逻辑

xxyy

2025-03-10 457b75b642a1fdaa7158e5b047cabc5d7ae16333

 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_QuartzJob/ConveyorLine/CommonConveyorLine.cs

@@ -1,4 +1,5 @@
#region << 版 本 注 释 >>

/*----------------------------------------------------------------
 * 命名空间：WIDESEAWCS_QuartzJob
 * 创建者：胡童庆
@@ -11,8 +12,9 @@
 * 修改时间：
 * 版本：V1.0.1
 * 修改说明：
 * 
 *
 *----------------------------------------------------------------*/

#endregion << 版 本 注 释 >>

using HslCommunication;
@@ -34,6 +36,7 @@
    public class CommonConveyorLine : IConveyorLine
    {
        #region Private Member

        /// <summary>
        /// 堆垛机通讯对象
        /// </summary>
@@ -62,9 +65,11 @@
        private bool _heartStatr = true;

        private bool _isConnected = true;

        #endregion

        #region Public Member

        /// <summary>
        /// 输送线通讯对象
        /// </summary>
@@ -104,9 +109,11 @@
        /// 设备状态
        /// </summary>
        public DeviceStatus Status => DeviceStatus.Offline;

        #endregion

        #region Constructor Function

        /// <summary>
        /// 构造函数
        /// </summary>
@@ -124,9 +131,11 @@
            _deviceName = deviceName;
            CheckConnect();
        }

        #endregion

        #region Private Method

        private void CheckConnect()
        {
            Task.Run(() =>
@@ -150,9 +159,11 @@
                }
            });
        }

        #endregion

        #region Public Method

        /// <summary>
        /// 读取PLC协议地址的数据
        /// </summary>
@@ -163,7 +174,7 @@
        /// <returns>读取到的数据</returns>
        public TRsult GetValue<TEnum, TRsult>(TEnum value, string deviceChildCode) where TEnum : Enum
        {
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络");
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络【 {DeviceName} 】");
            DeviceProDTO? devicePro = _deviceProDTOs.FirstOrDefault(x => x.DeviceProParamName == value.ToString() && x.DeviceChildCode == deviceChildCode);
            return devicePro == null ? throw new Exception() : (TRsult)Communicator.ReadAsObj(devicePro.DeviceProAddress, devicePro.DeviceDataType);
        }
@@ -177,7 +188,7 @@
        }

        /// <summary>
        /// 
        ///
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="command"></param>
@@ -186,7 +197,7 @@
        /// <exception cref="Exception"></exception>
        public bool SendCommand<T>(T command, string deviceChildCode) where T : IDataTransfer, new()
        {
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络");
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络【{DeviceName}】");
            DeviceProDTO? devicePro = _deviceProDTOs.Where(x => x.DeviceProParamType == nameof(DeviceCommand) && x.DeviceChildCode == deviceChildCode).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
            if (devicePro == null)
            {
@@ -208,12 +219,35 @@
        /// <exception cref="Exception"></exception>
        public T ReadCustomer<T>(string deviceChildCode) where T : IDataTransfer, new()
        {
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络");
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络【{DeviceName}】");
            DeviceProDTO? devicePro = _deviceProDTOs.Where(x => x.DeviceProParamType == "ReadDeviceCommand" && x.DeviceChildCode == deviceChildCode).OrderBy(x => x.DeviceProOffset).FirstOrDefault();

            if (devicePro == null)
            {
                throw new Exception("未找到协议信息");
                throw new Exception("未找到协议信息:" + deviceChildCode);
            }
            else
            {
                return Communicator.ReadCustomer<T>(devicePro.DeviceProAddress);
            }
        }

        /// <summary>
        /// 读取PLC数据，返回自定义对象
        /// </summary>
        /// <typeparam name="T">泛型</typeparam>
        /// <param name="deviceChildCode">子设备编号</param>
        /// <param name="deviceProParamType">参数类型</param>
        /// <returns>返回自定义对象或抛出异常</returns>
        /// <exception cref="Exception"></exception>
        public T ReadCustomer<T>(string deviceChildCode, string deviceProParamType) where T : IDataTransfer, new()
        {
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络【{DeviceName}】");
            DeviceProDTO? devicePro = _deviceProDTOs.Where(x => x.DeviceProParamType == deviceProParamType && x.DeviceChildCode == deviceChildCode).OrderBy(x => x.DeviceProOffset).FirstOrDefault();

            if (devicePro == null)
            {
                throw new Exception("未找到协议信息:" + deviceChildCode);
            }
            else
            {
@@ -234,13 +268,13 @@
            where TEnum : Enum
            where TValue : notnull
        {
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络");
            if (!IsConnected) throw new Exception($"通讯连接错误，请检查网络【 {DeviceName} 】");
            DeviceProDTO? devicePro = _deviceProDTOs.FirstOrDefault(x => x.DeviceProParamName == @enum.ToString() && x.DeviceChildCode == deviceChildCode);
            return devicePro == null ? throw new Exception() : Communicator.WriteObj(devicePro.DeviceProAddress, devicePro.DeviceDataType, value);
        }

        /// <summary>
        /// 
        /// 检测站台是否有货
        /// </summary>
        /// <param name="deviceChildCode"></param>
        /// <returns></returns>
@@ -272,12 +306,38 @@
            return false;
        }

        /// <summary>
        /// 检测站台是否有货
        /// </summary>
        /// <param name="deviceChildCode"></param>
        /// <returns></returns>
        /// <exception cref="Exception"></exception>
        public bool IsOccupiedx(string deviceChildCode)
        {
            if (Communicator.IsConnected)
            {
                var device = _deviceProDTOs.Where(x => x.DeviceChildCode == deviceChildCode && x.DeviceProParamName == "InteractiveSignal").FirstOrDefault();

                object readStatus = Communicator.ReadAsObj(device.DeviceProAddress, device.DeviceDataType);

                //todo 协议明细信息未获取到时抛出异常
                if (readStatus.ToString() != "2")
                {
                    return true;
                }
                return false;
            }
            //todo 通讯未连接时抛出异常
            return false;
        }

        public void Dispose()
        {
            _heartStatr = false;
            _communicator.Dispose();
            GC.SuppressFinalize(this);
        }

        #endregion
    }
}
}