using System; using System.Collections.Generic; using System.Linq; using System.Reflection; using Base; namespace Model { public interface IDisposerEvent { Type ValueType(); void SetValue(object value); } public abstract class DisposerEvent : IDisposerEvent { private T value; protected T GetValue() { return value; } public void SetValue(object v) { this.value = (T)v; } public Type ValueType() { return typeof(T); } } public sealed class DisposerEventManager { private readonly Dictionary assemblies = new Dictionary(); private Dictionary disposerEvents; private readonly HashSet updates = new HashSet(); private readonly HashSet loaders = new HashSet(); public void Register(string name, Assembly assembly) { this.assemblies[name] = assembly; this.disposerEvents = new Dictionary(); foreach (Assembly ass in this.assemblies.Values) { Type[] types = ass.GetTypes(); foreach (Type type in types) { object[] attrs = type.GetCustomAttributes(typeof(DisposerEventAttribute), false); if (attrs.Length == 0) { continue; } object obj = Activator.CreateInstance(type); IDisposerEvent disposerEvent = obj as IDisposerEvent; if (disposerEvent == null) { Log.Error($"组件事件没有继承IComponentEvent: {type.Name}"); } this.disposerEvents[disposerEvent.ValueType()] = disposerEvent; } } this.Load(); } public Assembly GetAssembly(string name) { return this.assemblies[name]; } public Assembly[] GetAssemblies() { return this.assemblies.Values.ToArray(); } private void Load() { foreach (Disposer disposer in this.loaders) { IDisposerEvent disposerEvent; if (!this.disposerEvents.TryGetValue(disposer.GetType(), out disposerEvent)) { continue; } ILoader iLoader = disposerEvent as ILoader; if (iLoader == null) { continue; } disposerEvent.SetValue(disposer); iLoader.Load(); } } public void Add(Disposer disposer) { if (this.disposerEvents == null) { return; } IDisposerEvent disposerEvent; if (!this.disposerEvents.TryGetValue(disposer.GetType(), out disposerEvent)) { return; } IUpdate iUpdate = disposerEvent as IUpdate; if (iUpdate != null) { this.updates.Add(disposer); } ILoader iLoader = disposerEvent as ILoader; if (iLoader != null) { this.loaders.Add(disposer); } } public void Remove(Disposer disposer) { IDisposerEvent disposerEvent; if (!this.disposerEvents.TryGetValue(disposer.GetType(), out disposerEvent)) { return; } IUpdate iUpdate = disposerEvent as IUpdate; if (iUpdate != null) { this.updates.Remove(disposer); } ILoader iLoader = disposerEvent as ILoader; if (iLoader != null) { this.loaders.Remove(disposer); } } public void Awake(Disposer disposer) { IDisposerEvent disposerEvent; if (!this.disposerEvents.TryGetValue(disposer.GetType(), out disposerEvent)) { return; } IAwake iAwake = disposerEvent as IAwake; if (iAwake == null) { return; } disposerEvent.SetValue(disposer); iAwake.Awake(); } public void Awake(Disposer disposer, P1 p1) { IDisposerEvent disposerEvent; if (!this.disposerEvents.TryGetValue(disposer.GetType(), out disposerEvent)) { return; } IAwake iAwake = disposerEvent as IAwake; if (iAwake == null) { return; } disposerEvent.SetValue(disposer); iAwake.Awake(p1); } public void Awake(Disposer disposer, P1 p1, P2 p2) { IDisposerEvent disposerEvent; if (!this.disposerEvents.TryGetValue(disposer.GetType(), out disposerEvent)) { return; } IAwake iAwake = disposerEvent as IAwake; if (iAwake == null) { return; } disposerEvent.SetValue(disposer); iAwake.Awake(p1, p2); } public void Awake(Disposer disposer, P1 p1, P2 p2, P3 p3) { IDisposerEvent disposerEvent; if (!this.disposerEvents.TryGetValue(disposer.GetType(), out disposerEvent)) { return; } IAwake iAwake = disposerEvent as IAwake; if (iAwake == null) { return; } disposerEvent.SetValue(disposer); iAwake.Awake(p1, p2, p3); } public void Update() { foreach (Disposer disposer in updates) { IDisposerEvent disposerEvent; if (!this.disposerEvents.TryGetValue(disposer.GetType(), out disposerEvent)) { continue; } IUpdate iUpdate = disposerEvent as IUpdate; if (iUpdate == null) { continue; } disposerEvent.SetValue(disposer); try { iUpdate.Update(); } catch (Exception e) { Log.Error(e.ToString()); } } } } }