NtMiner/src/NTMinerClient/Core/MinerServer/Impl/ColumnsShowSet.cs

using NTMiner.MinerServer;
using System;
using System.Collections.Generic;

namespace NTMiner.Core.MinerServer.Impl {
    public class ColumnsShowSet : IColumnsShowSet {
        private readonly Dictionary<Guid, ColumnsShowData> _dicById = new Dictionary<Guid, ColumnsShowData>();

        public ColumnsShowSet() {
            VirtualRoot.BuildCmdPath<AddColumnsShowCommand>(action: (message) => {
                InitOnece();
                if (message == null || message.Input == null || message.Input.GetId() == Guid.Empty || message.Input.GetId() == ColumnsShowData.PleaseSelect.Id) {
                    throw new ArgumentNullException();
                }
                if (_dicById.ContainsKey(message.Input.GetId())) {
                    return;
                }
                ColumnsShowData entity = new ColumnsShowData().Update(message.Input);
                Server.ColumnsShowService.AddOrUpdateColumnsShowAsync(entity, (response, exception) => {
                    if (response.IsSuccess()) {
                        _dicById.Add(entity.Id, entity);
                        VirtualRoot.RaiseEvent(new ColumnsShowAddedEvent(message.Id, entity));
                    }
                    else {
                        Write.UserFail(response.ReadMessage(exception));
                    }
                });
            });
            VirtualRoot.BuildCmdPath<UpdateColumnsShowCommand>(action: (message) => {
                InitOnece();
                if (message == null || message.Input == null || message.Input.GetId() == Guid.Empty) {
                    throw new ArgumentNullException();
                }
                if (!_dicById.ContainsKey(message.Input.GetId())) {
                    return;
                }
                ColumnsShowData entity = _dicById[message.Input.GetId()];
                ColumnsShowData oldValue = new ColumnsShowData().Update(entity);
                entity.Update(message.Input);
                Server.ColumnsShowService.AddOrUpdateColumnsShowAsync(entity, (response, exception) => {
                    if (!response.IsSuccess()) {
                        entity.Update(oldValue);
                        VirtualRoot.RaiseEvent(new ColumnsShowUpdatedEvent(message.Id, entity));
                        Write.UserFail(response.ReadMessage(exception));
                    }
                });
                VirtualRoot.RaiseEvent(new ColumnsShowUpdatedEvent(message.Id, entity));
            });
            VirtualRoot.BuildCmdPath<RemoveColumnsShowCommand>(action: (message) => {
                InitOnece();
                if (message == null || message.EntityId == Guid.Empty || message.EntityId == ColumnsShowData.PleaseSelect.Id) {
                    throw new ArgumentNullException();
                }
                if (!_dicById.ContainsKey(message.EntityId)) {
                    return;
                }
                ColumnsShowData entity = _dicById[message.EntityId];
                Server.ColumnsShowService.RemoveColumnsShowAsync(entity.Id, (response, exception) => {
                    if (response.IsSuccess()) {
                        _dicById.Remove(entity.Id);
                        VirtualRoot.RaiseEvent(new ColumnsShowRemovedEvent(message.Id, entity));
                    }
                    else {
                        Write.UserFail(response.ReadMessage(exception));
                    }
                });
            });
        }

        private bool _isInited = false;
        private readonly object _locker = new object();

        private void InitOnece() {
            if (_isInited) {
                return;
            }
            Init();
        }

        private void Init() {
            if (!_isInited) {
                lock (_locker) {
                    if (!_isInited) {
                        var result = Server.ColumnsShowService.GetColumnsShows();
                        foreach (var item in result) {
                            if (!_dicById.ContainsKey(item.GetId())) {
                                _dicById.Add(item.GetId(), item);
                            }
                        }
                        if (!_dicById.ContainsKey(ColumnsShowData.PleaseSelect.Id)) {
                            _dicById.Add(ColumnsShowData.PleaseSelect.Id, ColumnsShowData.PleaseSelect);
                            Server.ColumnsShowService.AddOrUpdateColumnsShowAsync(ColumnsShowData.PleaseSelect, (response, exception) => {
                                if (!response.IsSuccess()) {
                                    Logger.ErrorDebugLine("AddOrUpdateColumnsShowAsync " + response.ReadMessage(exception));
                                }
                            });
                        }
                        _isInited = true;
                    }
                }
            }
        }

        public bool Contains(Guid columnsShowId) {
            InitOnece();
            return _dicById.ContainsKey(columnsShowId);
        }

        public bool TryGetColumnsShow(Guid columnsShowId, out IColumnsShow columnsShow) {
            InitOnece();
            var r = _dicById.TryGetValue(columnsShowId, out ColumnsShowData g);
            columnsShow = g;
            return r;
        }

        public IEnumerable<IColumnsShow> AsEnumerable() {
            InitOnece();
            return _dicById.Values;
        }
    }
}