EEMS/EEMSUIClient/ViewModels/MainWindowViewModel.cs

using CommunityToolkit.Mvvm.ComponentModel;
using CommunityToolkit.Mvvm.Input;
using EEMSUIClient.Models;
using EEMSUIClient.Services;
using GeneralData;
using System.IO;
using System.Text.Json;
using System.Windows;

namespace EEMSUIClient.ViewModels;

public partial class MainWindowViewModel : ObservableObject
{
    private readonly IClientService _clientService;

    private readonly string _ipAddressFilePath = $"{Environment.CurrentDirectory}/IpAddressInformation.json";
    private readonly string _deviceInfoFilePath = $"{Environment.CurrentDirectory}/DeviceInformation.json";
    private bool _isInitialized = false;

    [ObservableProperty]
    private string _ipAddress = string.Empty;

    [ObservableProperty]
    private string _port = string.Empty;

    [ObservableProperty]
    private string _hubName = string.Empty;

    [ObservableProperty]
    [NotifyPropertyChangedFor(nameof(IsNotConnected))]
    private bool _isConnected;

    [ObservableProperty]
    private string[] _deviceModels = Enum.GetNames(typeof(DeviceModel));

    [ObservableProperty]
    private string _deviceModel = string.Empty;

    [ObservableProperty]
    private int _deviceModelIndex = -1;

    [ObservableProperty]
    private string _deviceSubModel = string.Empty;

    [ObservableProperty]
    private string _deviceName = string.Empty;

    [ObservableProperty]
    private string _position = string.Empty;

    [ObservableProperty]
    private string _softwareVersion = string.Empty;

    [ObservableProperty]
    private string _dBConnectionString = string.Empty;

    [ObservableProperty]
    private string _guidStr = string.Empty;

    public MainWindowViewModel(IClientService clientService)
    {
        _clientService = clientService;
        InitializeIpAddress();
        InitializeDeviceInfo();
    }

    public bool IsNotConnected => !IsConnected;

    [RelayCommand]
    private void Connect()
    {
        if (string.IsNullOrWhiteSpace(IpAddress) || string.IsNullOrWhiteSpace(Port) || string.IsNullOrWhiteSpace(HubName))
        {
            MessageBox.Show("存在未被填写的项目！");
            //log
            return;
        }

        if (!_clientService.Initialize(IpAddress, int.Parse(Port), HubName))
        {
            MessageBox.Show("初始化失败！");
            //log
            return;
        }

        IsConnected = true;

        var addressInfo = new AddressInfo()
        {
            Ip= IpAddress,
            Port=int.Parse(Port),
            HubName=HubName,
        };
        string jsonString = JsonSerializer.Serialize(addressInfo);
        File.WriteAllText(_ipAddressFilePath, jsonString);
    }

    [RelayCommand]
    private void Register()
    {
        if (string.IsNullOrWhiteSpace(DeviceModel) ||
            string.IsNullOrWhiteSpace(DeviceSubModel) ||
            string.IsNullOrWhiteSpace(DeviceName) ||
            string.IsNullOrWhiteSpace(Position) ||
            string.IsNullOrWhiteSpace(SoftwareVersion) ||
            string.IsNullOrWhiteSpace(DBConnectionString))
        {
            MessageBox.Show("存在未被填写的项目！");
            return;
        }

        try
        {
            _ = Enum.TryParse<DeviceModel>(DeviceModel, out var deviceModel);
            var deviceInfo = new Models.DeviceInfo
            {
                DeviceModel = deviceModel,
                DeviceSubModel = DeviceSubModel,
                DeviceName = DeviceName,
                Position = Position,
                Guid = _isInitialized ? Guid.Parse(GuidStr) : null,
                SoftwareVersion = SoftwareVersion,
                DBConnectionString = DBConnectionString
            };

            var guid = _clientService.RegisterDevice(deviceInfo);
            if (guid == Guid.Empty)
            {
                MessageBox.Show("未能获取Guid，设备注册失败！");
                return;
            }

            GuidStr = guid.ToString();
            MessageBox.Show("设备注册成功。");

            var jsonString = JsonSerializer.Serialize(deviceInfo);
            File.WriteAllText(_deviceInfoFilePath, jsonString);
        }
        catch (Exception ex)
        {
            MessageBox.Show($"遭遇异常：{ex.Message}");
        }
    }

    private void InitializeIpAddress()
    {
        if (!Path.Exists(_ipAddressFilePath))
        {
            return;
        }

        string jsonFromFile = File.ReadAllText(_ipAddressFilePath);
        var deserializedAddressInfo = JsonSerializer.Deserialize<AddressInfo>(jsonFromFile);
        if (deserializedAddressInfo is null)
        {
            return;
        }

        IpAddress = deserializedAddressInfo.Ip;
        Port = deserializedAddressInfo.Port.ToString();
        HubName = deserializedAddressInfo.HubName;
    }

    private void InitializeDeviceInfo()
    {
        if (!Path.Exists(_deviceInfoFilePath))
        {
            return;
        }

        string jsonFromFile = File.ReadAllText(_deviceInfoFilePath);
        var deserializedDeviceInfo = JsonSerializer.Deserialize<Models.DeviceInfo>(jsonFromFile);
        if (deserializedDeviceInfo is null)
        {
            return;
        }

        DeviceModelIndex = (int)deserializedDeviceInfo.DeviceModel!;
        DeviceModel = deserializedDeviceInfo.DeviceModel.ToString() ?? string.Empty;
        DeviceSubModel = deserializedDeviceInfo.DeviceSubModel ?? string.Empty;
        DeviceName = deserializedDeviceInfo.DeviceName ?? string.Empty;
        Position = deserializedDeviceInfo.Position ?? string.Empty;
        SoftwareVersion = deserializedDeviceInfo.SoftwareVersion ?? string.Empty;
        GuidStr = deserializedDeviceInfo.Guid.ToString() ?? string.Empty;
        DBConnectionString = deserializedDeviceInfo.DBConnectionString ?? string.Empty;

        _isInitialized = true;
    }

    private void OnRequestFileReceived(object? sender, (Guid guid, ServiceBase.FileType fileType) e)
    {
        //log
    }
}