OpenApiRateLimit.php 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148
  1. <?php
  2. namespace App\Module\OpenAPI\Models;
  3. use UCore\ModelCore;
  4. /**
  5. * OpenAPI频率限制记录模型
  6. *
  7. * field start
  8. * field end
  9. */
  10. class OpenApiRateLimit extends ModelCore
  11. {
  12. /**
  13. * 数据类型转换
  14. *
  15. * @var array
  16. */
  17. protected $casts = [
  18. 'window_start' => 'datetime',
  19. 'request_count' => 'integer',
  20. 'is_blocked' => 'boolean',
  21. 'headers' => 'array',
  22. ];
  23. /**
  24. * 关联应用模型
  25. *
  26. * @return \Illuminate\Database\Eloquent\Relations\BelongsTo
  27. */
  28. public function app()
  29. {
  30. return $this->belongsTo(OpenApiApp::class, 'app_id', 'app_id');
  31. }
  32. /**
  33. * 获取限制类型的中文名称
  34. *
  35. * @return string
  36. */
  37. public function getLimitTypeNameAttribute(): string
  38. {
  39. return match ($this->limit_type) {
  40. 'requests_per_minute' => '每分钟请求数',
  41. 'requests_per_hour' => '每小时请求数',
  42. 'requests_per_day' => '每天请求数',
  43. 'requests_per_week' => '每周请求数',
  44. 'requests_per_month' => '每月请求数',
  45. default => $this->limit_type,
  46. };
  47. }
  48. /**
  49. * 获取状态标签
  50. *
  51. * @return string
  52. */
  53. public function getStatusLabelAttribute(): string
  54. {
  55. return $this->is_blocked ? '已阻止' : '正常';
  56. }
  57. /**
  58. * 获取状态颜色
  59. *
  60. * @return string
  61. */
  62. public function getStatusColorAttribute(): string
  63. {
  64. return $this->is_blocked ? 'danger' : 'success';
  65. }
  66. /**
  67. * 按应用ID查询
  68. *
  69. * @param \Illuminate\Database\Eloquent\Builder $query
  70. * @param string $appId
  71. * @return \Illuminate\Database\Eloquent\Builder
  72. */
  73. public function scopeByApp($query, string $appId)
  74. {
  75. return $query->where('app_id', $appId);
  76. }
  77. /**
  78. * 按IP地址查询
  79. *
  80. * @param \Illuminate\Database\Eloquent\Builder $query
  81. * @param string $ip
  82. * @return \Illuminate\Database\Eloquent\Builder
  83. */
  84. public function scopeByIp($query, string $ip)
  85. {
  86. return $query->where('ip_address', $ip);
  87. }
  88. /**
  89. * 按限制类型查询
  90. *
  91. * @param \Illuminate\Database\Eloquent\Builder $query
  92. * @param string $limitType
  93. * @return \Illuminate\Database\Eloquent\Builder
  94. */
  95. public function scopeByLimitType($query, string $limitType)
  96. {
  97. return $query->where('limit_type', $limitType);
  98. }
  99. /**
  100. * 查询被阻止的记录
  101. *
  102. * @param \Illuminate\Database\Eloquent\Builder $query
  103. * @return \Illuminate\Database\Eloquent\Builder
  104. */
  105. public function scopeBlocked($query)
  106. {
  107. return $query->where('is_blocked', true);
  108. }
  109. /**
  110. * 按时间范围查询
  111. *
  112. * @param \Illuminate\Database\Eloquent\Builder $query
  113. * @param \Carbon\Carbon $start
  114. * @param \Carbon\Carbon $end
  115. * @return \Illuminate\Database\Eloquent\Builder
  116. */
  117. public function scopeInTimeRange($query, $start, $end)
  118. {
  119. return $query->whereBetween('window_start', [$start, $end]);
  120. }
  121. /**
  122. * 获取最近的限制记录
  123. *
  124. * @param \Illuminate\Database\Eloquent\Builder $query
  125. * @param int $hours
  126. * @return \Illuminate\Database\Eloquent\Builder
  127. */
  128. public function scopeRecent($query, int $hours = 24)
  129. {
  130. return $query->where('window_start', '>=', now()->subHours($hours));
  131. }
  132. }