NodeObserver.php 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. <?php
  2. namespace App\Observers;
  3. use App\Jobs\VNet\reloadNode;
  4. use App\Models\Node;
  5. use App\Models\NodeAuth;
  6. use App\Models\RuleGroup;
  7. use App\Models\UserGroup;
  8. use App\Services\NodeService;
  9. use Log;
  10. class NodeObserver {
  11. public function saved(Node $node): void {
  12. (new NodeService())->getNodeGeo($node->id);
  13. }
  14. public function created(Node $node): void {
  15. $auth = new NodeAuth();
  16. $auth->node_id = $node->id;
  17. $auth->key = makeRandStr(16);
  18. $auth->secret = makeRandStr(8);
  19. if(!$auth->save()){
  20. Log::error('节点生成-自动生成授权时出现错误,请稍后自行生成授权!');
  21. }
  22. }
  23. public function updated(Node $node): void {
  24. if($node->type == 4){
  25. reloadNode::dispatch(Node::whereType(4)->whereId($node->id)->get());
  26. }
  27. }
  28. public function deleted(Node $node): void {
  29. // 删除分组关联、节点标签、节点相关日志
  30. $node->labels()->delete();
  31. $node->heartBeats()->delete();
  32. $node->onlineLogs()->delete();
  33. $node->pingLogs()->delete();
  34. $node->dailyDataFlows()->delete();
  35. $node->hourlyDataFlows()->delete();
  36. $node->rules()->delete();
  37. $node->ruleGroup()->delete();
  38. $node->auth()->delete();
  39. // 断开审计规则分组节点联系
  40. foreach(RuleGroup::all() as $ruleGroup){
  41. $nodes = $ruleGroup->nodes;
  42. if($nodes && in_array($node->id, $nodes, true)){
  43. $ruleGroup->nodes = array_merge(array_diff($nodes, [$node->id]));
  44. $ruleGroup->save();
  45. }
  46. }
  47. // 断开用户分组控制节点联系
  48. foreach(UserGroup::all() as $userGroup){
  49. $nodes = $userGroup->nodes;
  50. if($nodes && in_array($node->id, $nodes, true)){
  51. $userGroup->nodes = array_merge(array_diff($nodes, [$node->id]));
  52. $userGroup->save();
  53. }
  54. }
  55. }
  56. }