- FcmSender.sendToMany() 추가 (chunk/rate limit 지원) - FcmBatchResult 클래스 추가 (발송 결과 집계) - fcm:send 명령어 추가 (대량 발송, dry-run 지원) - fcm:prune-invalid 명령어 추가 (무효 토큰 정리) - PushDeviceToken에 last_error, last_error_at 컬럼 추가 - 실패 토큰 자동 비활성화 (UNREGISTERED, NOT_FOUND, INVALID_ARGUMENT)
125 lines
2.5 KiB
PHP
125 lines
2.5 KiB
PHP
<?php
|
|
|
|
namespace App\Models;
|
|
|
|
use App\Traits\BelongsToTenant;
|
|
use Illuminate\Database\Eloquent\Model;
|
|
use Illuminate\Database\Eloquent\Relations\BelongsTo;
|
|
use Illuminate\Database\Eloquent\SoftDeletes;
|
|
|
|
class PushDeviceToken extends Model
|
|
{
|
|
use BelongsToTenant;
|
|
use SoftDeletes;
|
|
|
|
protected $fillable = [
|
|
'tenant_id',
|
|
'user_id',
|
|
'token',
|
|
'platform',
|
|
'device_name',
|
|
'app_version',
|
|
'is_active',
|
|
'last_used_at',
|
|
'last_error',
|
|
'last_error_at',
|
|
];
|
|
|
|
protected $casts = [
|
|
'is_active' => 'boolean',
|
|
'last_used_at' => 'datetime',
|
|
'last_error_at' => 'datetime',
|
|
];
|
|
|
|
/**
|
|
* 플랫폼 상수
|
|
*/
|
|
public const PLATFORM_IOS = 'ios';
|
|
|
|
public const PLATFORM_ANDROID = 'android';
|
|
|
|
public const PLATFORM_WEB = 'web';
|
|
|
|
/**
|
|
* 사용자 관계
|
|
*/
|
|
public function user(): BelongsTo
|
|
{
|
|
return $this->belongsTo(User::class);
|
|
}
|
|
|
|
/**
|
|
* 테넌트 관계
|
|
*/
|
|
public function tenant(): BelongsTo
|
|
{
|
|
return $this->belongsTo(Tenant::class);
|
|
}
|
|
|
|
/**
|
|
* Scope: 활성 토큰만
|
|
*/
|
|
public function scopeActive($query)
|
|
{
|
|
return $query->where('is_active', true);
|
|
}
|
|
|
|
/**
|
|
* Scope: 플랫폼별 필터
|
|
*/
|
|
public function scopePlatform($query, string $platform)
|
|
{
|
|
return $query->where('platform', $platform);
|
|
}
|
|
|
|
/**
|
|
* Scope: 특정 사용자의 토큰
|
|
*/
|
|
public function scopeForUser($query, int $userId)
|
|
{
|
|
return $query->where('user_id', $userId);
|
|
}
|
|
|
|
/**
|
|
* Scope: 특정 테넌트의 토큰 (global scope 무시)
|
|
*/
|
|
public function scopeForTenant($query, int $tenantId)
|
|
{
|
|
return $query->where('tenant_id', $tenantId);
|
|
}
|
|
|
|
/**
|
|
* Scope: 에러가 있는 토큰
|
|
*/
|
|
public function scopeHasError($query)
|
|
{
|
|
return $query->whereNotNull('last_error');
|
|
}
|
|
|
|
/**
|
|
* 에러 정보 기록
|
|
*/
|
|
public function recordError(string $errorCode): void
|
|
{
|
|
$this->update([
|
|
'last_error' => $errorCode,
|
|
'last_error_at' => now(),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* 토큰 비활성화 (에러와 함께)
|
|
*/
|
|
public function deactivate(?string $errorCode = null): void
|
|
{
|
|
$data = ['is_active' => false];
|
|
|
|
if ($errorCode) {
|
|
$data['last_error'] = $errorCode;
|
|
$data['last_error_at'] = now();
|
|
}
|
|
|
|
$this->update($data);
|
|
}
|
|
}
|