EEMS/EEMSMain/Service/UIProvider.cs

using Device;
using Mapster;
using ServiceBase;
namespace EEMSMain.Service;

internal class UIProvider(DeviceCollection deviceCollection) : IUIProvider
{
    Task<bool> IUIProvider.InsertNewDevice(DeviceInfo deviceInfo)
    {
        DeviceInfo_VM device = deviceInfo.Adapt<DeviceInfo_VM>();
        device.IsConnected = true;
        if (device.Guid is null)
            return Task.FromResult(true);


        App.Current.Dispatcher.Invoke(() =>
        {
            deviceCollection.NewDeviceList[device.Guid.Value] = device;
        });

        return Task.FromResult(true);
    }


    Task<bool> IUIProvider.UpdateDevice(DeviceInfo deviceInfo)
    {
        DeviceInfo_VM device = deviceInfo.Adapt<DeviceInfo_VM>();

        if (device.Guid is null)
            return Task.FromResult(true);
        DeviceData_VM deviceData = new()
        {
            DeviceId = device.Guid.Value,
            DeviceModel = device.DeviceModel,
            OtherInfo = [],
            Alarms = []
        };
        App.Current.Dispatcher.Invoke(() =>
        {
            deviceCollection.DeviceDataList[device.Guid.Value] = deviceData;
            deviceCollection.DeviceList[device.Guid.Value] = device;
        });

        return Task.FromResult(true);
    }

    Task<bool> IUIProvider.UpdateDeviceList(IEnumerable<DeviceInfo> device)
    {
        return Task.FromResult(true);
    }

    Task<bool> IUIProvider.UpdateRealtimeData(Guid guid, Dictionary<string, object> data)
    {
        if (!deviceCollection.DeviceDataList.TryGetValue(guid, out DeviceData_VM? deviceData) || deviceData is null)
            return Task.FromResult(false);

        App.Current.Dispatcher?.Invoke(() =>
        {
            deviceData.OtherInfo.Clear();
            foreach (var item in data)
            {
                switch (item.Key)
                {
                    case "Status":
                        deviceData.DeviceStatus = item.Value.ToString();
                        break;
                    default:
                        deviceData.OtherInfo[item.Key] = item.Value;
                        break;
                }
            }
        });

        return Task.FromResult(true);
    }

    Task<bool> IUIProvider.UpdateRecipeInfo(Recipe recipeInfo)
    {
        if (!deviceCollection.DeviceDataList.TryGetValue(recipeInfo.DeviceId, out DeviceData_VM? deviceData) || deviceData is null)
            return Task.FromResult(false);
        App.Current.Dispatcher?.Invoke(() =>
        {
            deviceData.RecipeInfo = recipeInfo.Adapt<RecipeInfo_VM>();
        });

        return Task.FromResult(true);
    }

    Task<bool> IUIProvider.UpdateAlarm(IEnumerable<Alarm> alarm)
    {
        if (alarm is null || alarm.FirstOrDefault() is not Alarm first)
            return Task.FromResult(true);

        if (!deviceCollection.DeviceDataList.TryGetValue(first.DeviceID, out DeviceData_VM? deviceData) || deviceData is null)
            return Task.FromResult(false);

        App.Current.Dispatcher?.Invoke(() =>
        {
            deviceData.Alarms ??= [];
            deviceData.Alarms.Clear();
            foreach (var item in alarm)
                deviceData.Alarms.Add(item.Adapt<Alarm_VM>());
        });

        return Task.FromResult(true);
    }
}