NodeObserver.php 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. <?php
  2. namespace App\Observers;
  3. use App\Components\DDNS;
  4. use App\Jobs\VNet\reloadNode;
  5. use App\Models\Node;
  6. use App\Models\NodeAuth;
  7. use App\Models\RuleGroup;
  8. use App\Models\UserGroup;
  9. use App\Services\NodeService;
  10. use Arr;
  11. use Log;
  12. use Str;
  13. class NodeObserver
  14. {
  15. public function saved(Node $node): void
  16. {
  17. (new NodeService())->getNodeGeo($node->id);
  18. }
  19. public function created(Node $node): void
  20. {
  21. $auth = new NodeAuth();
  22. $auth->node_id = $node->id;
  23. $auth->key = Str::random();
  24. $auth->secret = Str::random(8);
  25. if (! $auth->save()) {
  26. Log::warning('节点生成-自动生成授权时出现错误,请稍后自行生成授权!');
  27. }
  28. if ($node->is_ddns == 0 && $node->server && sysConfig('ddns_mode')) {
  29. if ($node->ip) {
  30. DDNS::store($node->server, $node->ip);
  31. }
  32. if ($node->ipv6) {
  33. DDNS::store($node->server, $node->ipv6, 'AAAA');
  34. }
  35. }
  36. }
  37. public function updated(Node $node): void
  38. {
  39. if ($node->is_ddns == 0 && sysConfig('ddns_mode')) {
  40. $changes = $node->getChanges();
  41. if (Arr::hasAny($changes, ['ip', 'ipv6', 'server'])) {
  42. if (Arr::exists($changes, 'server')) {
  43. DDNS::destroy($node->getOriginal('server'));
  44. if ($node->ip) {
  45. DDNS::store($node->server, $node->ip);
  46. }
  47. if ($node->ipv6) {
  48. DDNS::store($node->server, $node->ipv6, 'AAAA');
  49. }
  50. } else {
  51. if (Arr::exists($changes, 'ip')) {
  52. if ($node->ip && $node->getOriginal('ip')) {
  53. DDNS::update($node->server, $node->ip);
  54. } elseif ($node->ip) {
  55. DDNS::store($node->server, $node->ip);
  56. } else {
  57. DDNS::destroy($node->server, 'A');
  58. }
  59. }
  60. if (Arr::exists($changes, 'ipv6')) {
  61. if ($node->ipv6 && $node->getOriginal('ipv6')) {
  62. DDNS::update($node->server, $node->ipv6, 'AAAA');
  63. } elseif ($node->ipv6) {
  64. DDNS::store($node->server, $node->ipv6, 'AAAA');
  65. } else {
  66. DDNS::destroy($node->server, 'AAAA');
  67. }
  68. }
  69. }
  70. }
  71. }
  72. if ($node->type == 4) {
  73. reloadNode::dispatch(Node::whereId($node->id)->get());
  74. }
  75. }
  76. public function deleted(Node $node): void
  77. {
  78. // 删除分组关联、节点标签、节点相关日志
  79. $node->labels()->delete();
  80. $node->heartBeats()->delete();
  81. $node->onlineLogs()->delete();
  82. $node->pingLogs()->delete();
  83. $node->dailyDataFlows()->delete();
  84. $node->hourlyDataFlows()->delete();
  85. $node->rules()->delete();
  86. $node->ruleGroup()->delete();
  87. $node->auth()->delete();
  88. // 断开审计规则分组节点联系
  89. foreach (RuleGroup::all() as $ruleGroup) {
  90. $nodes = $ruleGroup->nodes;
  91. if ($nodes && in_array($node->id, $nodes, true)) {
  92. $ruleGroup->nodes = array_merge(array_diff($nodes, [$node->id]));
  93. $ruleGroup->save();
  94. }
  95. }
  96. // 断开用户分组控制节点联系
  97. foreach (UserGroup::all() as $userGroup) {
  98. $nodes = $userGroup->nodes;
  99. if ($nodes && in_array($node->id, $nodes, true)) {
  100. $userGroup->nodes = array_merge(array_diff($nodes, [$node->id]));
  101. $userGroup->save();
  102. }
  103. }
  104. if ($node->is_ddns == 0 && $node->server && sysConfig('ddns_mode')) {
  105. DDNS::destroy($node->server);
  106. }
  107. }
  108. }