PagePlcMonitor.xaml.Event.cs

이 파일의 문서화 페이지로 가기

using Dreamine.PLC.Wpf.ViewModels;
using Dreamine.PLC.Mitsubishi.MxComponent.Options;
using SampleSmart.Pages.PageSub.PlcTabs;
 
namespace SampleSmart.Pages.PageSub;

public sealed class PagePlcMonitorEvent
{
    private readonly PlcSampleRuntime _runtime;

    public PagePlcMonitorEvent(PlcSampleRuntime runtime)
    {
        _runtime = runtime ?? throw new ArgumentNullException(nameof(runtime));
    }

    public PlcMonitorViewModel Monitor => _runtime.Monitor;

    public string Host { get; set; } = "127.0.0.1";

    public string PortText { get; set; } = "55000";
 

    public string ClientModeText { get; set; } = "SimulatorTcp";

    public string MxProgId { get; set; } = MitsubishiMxComponentOptions.DefaultProgId;

    public string MxLogicalStationNumberText { get; set; } = "0";

    public string CxProgId { get; set; } = "OMRON.Compolet.CJ2Compolet";

    public string CxPeerAddress { get; set; } = "127.0.0.1";
 

    public string McHost { get; set; } = "127.0.0.1";

    public string McPortText { get; set; } = "5000";

    public string McTransportText { get; set; } = "Tcp";

    public string McRetryCountText { get; set; } = "1";

    public string HandshakeStartValueText { get; set; } = "1000";

    public string HandshakeIterationsText { get; set; } = "100";

    public string HandshakeDelayMsText { get; set; } = "10";

    public void UseInMemory()
    {
        _runtime.UseInMemoryClient();
    }

    public void StartServer()
    {
        var mode = string.IsNullOrWhiteSpace(ClientModeText) ? "SimulatorTcp" : ClientModeText.Trim();
        if (mode.Equals("MxComponent", StringComparison.OrdinalIgnoreCase)
            || mode.Equals("CxComponent", StringComparison.OrdinalIgnoreCase))
        {
            _runtime.Monitor.StatusMessage = "MxComponent/CxComponent modes use vendor runtime directly. Press Use Client, then Connect.";
            return;
        }
 
        if (!TryGetPort(out var port))
        {
            return;
        }
 
        _ = _runtime.StartProtocolServerAsync(ClientModeText, Host, port);
    }

    public void StopServer()
    {
        _ = _runtime.StopProtocolServerAsync();
    }

    public void UseSelectedClient()
    {
        if (!TryGetPort(out var port))
        {
            return;
        }
 
        var mode = string.IsNullOrWhiteSpace(ClientModeText) ? "SimulatorTcp" : ClientModeText.Trim();
        switch (mode.ToUpperInvariant())
        {
            case "SIMULATORTCP":
                _runtime.UseSimulatorTcpClient(Host, port);
                return;
            case "MCTCP":
                UseMitsubishiMcClient(Host, port, "Tcp");
                return;
            case "MCUDP":
                UseMitsubishiMcClient(Host, port, "Udp");
                return;
            case "FINSTCP":
                UseOmronFinsClient(Host, port, "Tcp");
                return;
            case "FINSUDP":
                UseOmronFinsClient(Host, port, "Udp");
                return;
            case "MXCOMPONENT":
                UseMitsubishiMxComponentClient();
                return;
            case "CXCOMPONENT":
                UseOmronCxComponentClient();
                return;
            default:
                _runtime.Monitor.StatusMessage = "Client mode must be SimulatorTcp, McTcp, McUdp, FinsTcp, FinsUdp, MxComponent, or CxComponent.";
                return;
        }
    }

    private void UseMitsubishiMxComponentClient()
    {
        if (!int.TryParse(MxLogicalStationNumberText, out var logicalStationNumber) || logicalStationNumber < 0)
        {
            _runtime.Monitor.StatusMessage = "MX logical station number must be zero or greater.";
            return;
        }
 
        var progId = string.IsNullOrWhiteSpace(MxProgId)
            ? MitsubishiMxComponentOptions.DefaultProgId
            : MxProgId;
 
        _runtime.UseMitsubishiMxComponentClient(progId, logicalStationNumber);
    }

    private void UseOmronCxComponentClient()
    {
        _runtime.UseOmronCxComponentClient(CxProgId, CxPeerAddress);
    }
 

    private void UseOmronFinsClient(string host, int port, string transportText)
    {
        if (!int.TryParse(McRetryCountText, out var retryCount) || retryCount <= 0)
        {
            _runtime.Monitor.StatusMessage = "FINS retry count must be greater than zero.";
            return;
        }
 
        _runtime.UseOmronFinsClient(host, port, transportText, retryCount);
    }

    public void UseTcpClient()
    {
        if (!TryGetPort(out var port))
        {
            return;
        }
 
        _runtime.UseSimulatorTcpClient(Host, port);
    }
 

    private void UseMitsubishiMcClient(string host, int port, string transportText)
    {
        if (!int.TryParse(McRetryCountText, out var retryCount) || retryCount <= 0)
        {
            _runtime.Monitor.StatusMessage = "MC retry count must be greater than zero.";
            return;
        }
 
        _runtime.UseMitsubishiMcClient(host, port, transportText, retryCount);
    }
 

    public void UseMcClient()
    {
        if (!int.TryParse(McPortText, out var port) || port is <= 0 or > 65535)
        {
            _runtime.Monitor.StatusMessage = "MC port must be between 1 and 65535.";
            return;
        }
 
        if (!int.TryParse(McRetryCountText, out var retryCount) || retryCount <= 0)
        {
            _runtime.Monitor.StatusMessage = "MC retry count must be greater than zero.";
            return;
        }
 
        _runtime.UseMitsubishiMcClient(McHost, port, McTransportText, retryCount);
    }

    public void RunHandshakeTest()
    {
        if (!short.TryParse(HandshakeStartValueText, out var startValue))
        {
            _runtime.Monitor.StatusMessage = "Handshake start value must be a 16-bit integer.";
            return;
        }
 
        if (!int.TryParse(HandshakeIterationsText, out var iterations) || iterations <= 0)
        {
            _runtime.Monitor.StatusMessage = "Handshake iterations must be greater than zero.";
            return;
        }
 
        if (!int.TryParse(HandshakeDelayMsText, out var delayMs) || delayMs < 0)
        {
            _runtime.Monitor.StatusMessage = "Handshake delay must be zero or greater.";
            return;
        }
 
        _ = _runtime.RunHandshakeTestAsync(startValue, iterations, delayMs);
    }

    private bool TryGetPort(out int port)
    {
        if (!int.TryParse(PortText, out port) || port is <= 0 or > 65535)
        {
            _runtime.Monitor.StatusMessage = "Port must be between 1 and 65535.";
            return false;
        }
 
        return true;
    }
}