ThingsGateway/framework/plugin/ThingsGateway.Plugin.Modbus/ModbusUdp/ModbusUdp.cs

#region copyright

//------------------------------------------------------------------------------
//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
//  此代码版权（除特别声明外的代码）归作者本人Diego所有
//  源代码使用协议遵循本仓库的开源协议及附加协议
//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
//  QQ群：605534569
//------------------------------------------------------------------------------

#endregion

using ThingsGateway.Foundation.Demo;

namespace ThingsGateway.Plugin.Modbus;

/// <inheritdoc/>
public class ModbusUdp : CollectBase
{
    private readonly ModbusUdpProperty _driverPropertys = new();

    private ThingsGateway.Foundation.Adapter.Modbus.ModbusUdp _plc;

    /// <inheritdoc/>
    public override Type DriverDebugUIType => typeof(ModbusUdpDebugPage);

    /// <inheritdoc/>
    public override DriverPropertyBase DriverPropertys => _driverPropertys;

    public override Type DriverUIType => null;

    /// <inheritdoc/>
    protected override IReadWrite _readWrite => _plc;

    /// <inheritdoc/>
    protected override void Init(ISenderClient client = null)
    {
        if (client == null)
        {
            FoundataionConfig.SetRemoteIPHost(new IPHost($"{_driverPropertys.IP}:{_driverPropertys.Port}"))
                .SetBindIPHost(new IPHost(0))
                ;
            client = new UdpSession();
            ((UdpSession)client).Setup(FoundataionConfig);
        }
        //载入配置
        _plc = new((UdpSession)client)
        {
            DataFormat = _driverPropertys.DataFormat,
            FrameTime = _driverPropertys.FrameTime,
            Station = _driverPropertys.Station,
            TimeOut = _driverPropertys.TimeOut,
            IsCheckMessageId = _driverPropertys.MessageIdCheckEnable
        };

        base.Init(client);
    }

    /// <inheritdoc/>
    protected override List<DeviceVariableSourceRead> ProtectedLoadSourceRead(List<DeviceVariableRunTime> deviceVariables)
    {
        return _plc.LoadSourceRead<DeviceVariableSourceRead, DeviceVariableRunTime>(deviceVariables, _driverPropertys.MaxPack, CurrentDevice.IntervalTime);
    }
}