ApiNodeExtensions.cs 3.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. using System.Collections.Generic;
  2. using System.Runtime.CompilerServices;
  3. using Sers.Gover.Base;
  4. using Sers.Gover.Base.Model;
  5. using Sers.ServiceCenter.Entity;
  6. namespace Vit.Extensions
  7. {
  8. public static partial class ApiNodeExtensions
  9. {
  10. [MethodImpl(MethodImplOptions.AggressiveInlining)]
  11. public static EServiceStationStatus Status_Get(this ApiNode data)
  12. {
  13. return data?.GetDataByConvert<EServiceStationStatus?>("Status")?? EServiceStationStatus.暂停;
  14. }
  15. [MethodImpl(MethodImplOptions.AggressiveInlining)]
  16. public static void Status_Set(this ApiNode data, EServiceStationStatus value)
  17. {
  18. data?.SetData("Status", value);
  19. }
  20. public static void Stop(this ApiNode apiNode, ApiLoadBalancingMng apiLoadBalancingMng)
  21. {
  22. if (apiNode.Status_Get() == EServiceStationStatus.暂停)
  23. {
  24. return;
  25. }
  26. apiNode.Status_Set(EServiceStationStatus.暂停);
  27. apiLoadBalancingMng.ApiNode_Remove(apiNode);
  28. }
  29. public static void Start(this ApiNode apiNode, ApiLoadBalancingMng apiLoadBalancingMng)
  30. {
  31. if (apiNode.Status_Get() == EServiceStationStatus.正常)
  32. {
  33. return;
  34. }
  35. apiNode.Status_Set(EServiceStationStatus.正常);
  36. apiLoadBalancingMng.ApiNode_Add(apiNode);
  37. }
  38. #region reason
  39. static void StopReason_Add(this ApiNode data,string reason)
  40. {
  41. var reasons = data.GetData<Dictionary<string,string>>("StopReason");
  42. if (null == reasons)
  43. {
  44. reasons = new Dictionary<string, string>();
  45. data.SetData("StopReason", reasons);
  46. }
  47. reasons.IDictionaryTryAdd(reason, reason);
  48. }
  49. /// <summary>
  50. /// 返回 移除后是否仍有StopReason
  51. /// </summary>
  52. /// <param name="data"></param>
  53. /// <param name="reason"></param>
  54. /// <returns></returns>
  55. static bool StopReason_Remove(this ApiNode data, string reason)
  56. {
  57. var reasons = data.GetData<Dictionary<string, string>>("StopReason");
  58. if (null == reasons) return false;
  59. reasons.Remove(reason);
  60. return reasons.Count != 0;
  61. }
  62. #endregion
  63. public static void StopReason_Add(this ApiNode apiNode, ApiLoadBalancingMng apiLoadBalancingMng,string reason)
  64. {
  65. apiNode.StopReason_Add(reason);
  66. apiNode.Stop(apiLoadBalancingMng);
  67. }
  68. public static void StopReason_Remove(this ApiNode apiNode, ApiLoadBalancingMng apiLoadBalancingMng, string reason)
  69. {
  70. if (!apiNode.StopReason_Remove(reason))
  71. {
  72. apiNode.Start(apiLoadBalancingMng);
  73. }
  74. }
  75. }
  76. }