feat: TenantStatField API 구현
- TenantStatFieldService: CRUD + reorder + bulkUpsert 로직 구현 - TenantStatFieldController: 7개 엔드포인트 (SAM API Rules 준수) - FormRequest: Store/Update 검증 클래스 생성 - Swagger: 완전한 API 문서화 (6개 스키마, 7개 엔드포인트) - i18n: message.tenant_stat_field 키 추가 - Route: /tenant-stat-fields 7개 라우트 등록 유니크 제약 검증: tenant_id + target_table + field_key 집계 함수 필터링: avg, sum, min, max, count
This commit is contained in:
237
app/Services/TenantStatFieldService.php
Normal file
237
app/Services/TenantStatFieldService.php
Normal file
@@ -0,0 +1,237 @@
|
||||
<?php
|
||||
|
||||
namespace App\Services;
|
||||
|
||||
use App\Models\Tenants\TenantStatField;
|
||||
use Illuminate\Support\Facades\DB;
|
||||
use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
|
||||
|
||||
class TenantStatFieldService extends Service
|
||||
{
|
||||
public function index(array $params)
|
||||
{
|
||||
$tenantId = $this->tenantId();
|
||||
|
||||
$size = (int) ($params['size'] ?? 20);
|
||||
$targetTable = $params['target_table'] ?? null;
|
||||
$isCritical = $params['is_critical'] ?? null;
|
||||
$aggregationType = $params['aggregation_type'] ?? null;
|
||||
|
||||
$query = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId);
|
||||
|
||||
// 필터: 대상 테이블
|
||||
if ($targetTable) {
|
||||
$query->forTable($targetTable);
|
||||
}
|
||||
|
||||
// 필터: 중요 필드만
|
||||
if ($isCritical !== null && $isCritical !== '') {
|
||||
$query->critical();
|
||||
}
|
||||
|
||||
// 필터: 특정 집계 함수 포함
|
||||
if ($aggregationType) {
|
||||
$query->withAggregation($aggregationType);
|
||||
}
|
||||
|
||||
// 정렬: display_order, field_name
|
||||
$query->ordered();
|
||||
|
||||
return $query->paginate($size);
|
||||
}
|
||||
|
||||
public function store(array $data)
|
||||
{
|
||||
$tenantId = $this->tenantId();
|
||||
$userId = $this->apiUserId();
|
||||
|
||||
// FormRequest에서 이미 검증됨
|
||||
$payload = $data;
|
||||
|
||||
// tenant_id + target_table + field_key 유니크 검증
|
||||
$exists = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->where('target_table', $payload['target_table'])
|
||||
->where('field_key', $payload['field_key'])
|
||||
->exists();
|
||||
if ($exists) {
|
||||
throw new BadRequestHttpException(__('error.duplicate_key'));
|
||||
}
|
||||
|
||||
$payload['tenant_id'] = $tenantId;
|
||||
$payload['is_critical'] = $payload['is_critical'] ?? false;
|
||||
$payload['display_order'] = $payload['display_order'] ?? 0;
|
||||
$payload['created_by'] = $userId;
|
||||
|
||||
return TenantStatField::create($payload);
|
||||
}
|
||||
|
||||
public function show(int $id)
|
||||
{
|
||||
$tenantId = $this->tenantId();
|
||||
|
||||
$field = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->find($id);
|
||||
|
||||
if (! $field) {
|
||||
throw new BadRequestHttpException(__('error.not_found'));
|
||||
}
|
||||
|
||||
return $field;
|
||||
}
|
||||
|
||||
public function update(int $id, array $data)
|
||||
{
|
||||
$tenantId = $this->tenantId();
|
||||
$userId = $this->apiUserId();
|
||||
|
||||
$field = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->find($id);
|
||||
|
||||
if (! $field) {
|
||||
throw new BadRequestHttpException(__('error.not_found'));
|
||||
}
|
||||
|
||||
// FormRequest에서 이미 검증됨
|
||||
$payload = $data;
|
||||
|
||||
// target_table 또는 field_key 변경 시 유니크 검증
|
||||
$targetTableChanged = isset($payload['target_table']) && $payload['target_table'] !== $field->target_table;
|
||||
$fieldKeyChanged = isset($payload['field_key']) && $payload['field_key'] !== $field->field_key;
|
||||
|
||||
if ($targetTableChanged || $fieldKeyChanged) {
|
||||
$newTargetTable = $payload['target_table'] ?? $field->target_table;
|
||||
$newFieldKey = $payload['field_key'] ?? $field->field_key;
|
||||
|
||||
$dup = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->where('target_table', $newTargetTable)
|
||||
->where('field_key', $newFieldKey)
|
||||
->where('id', '!=', $id)
|
||||
->exists();
|
||||
if ($dup) {
|
||||
throw new BadRequestHttpException(__('error.duplicate_key'));
|
||||
}
|
||||
}
|
||||
|
||||
$payload['updated_by'] = $userId;
|
||||
$field->update($payload);
|
||||
|
||||
return $field->refresh();
|
||||
}
|
||||
|
||||
public function destroy(int $id): void
|
||||
{
|
||||
$tenantId = $this->tenantId();
|
||||
|
||||
$field = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->find($id);
|
||||
|
||||
if (! $field) {
|
||||
throw new BadRequestHttpException(__('error.not_found'));
|
||||
}
|
||||
|
||||
$field->delete();
|
||||
}
|
||||
|
||||
public function reorder(array $items): void
|
||||
{
|
||||
$tenantId = $this->tenantId();
|
||||
|
||||
$rows = $items['items'] ?? $items;
|
||||
if (! is_array($rows)) {
|
||||
throw new BadRequestHttpException(__('error.invalid_payload'));
|
||||
}
|
||||
|
||||
DB::transaction(function () use ($tenantId, $rows) {
|
||||
foreach ($rows as $row) {
|
||||
if (! isset($row['id'], $row['display_order'])) {
|
||||
continue;
|
||||
}
|
||||
|
||||
TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->where('id', $row['id'])
|
||||
->update(['display_order' => (int) $row['display_order']]);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
public function bulkUpsert(array $items): array
|
||||
{
|
||||
$tenantId = $this->tenantId();
|
||||
$userId = $this->apiUserId();
|
||||
|
||||
if (! is_array($items) || empty($items)) {
|
||||
throw new BadRequestHttpException(__('error.empty_items'));
|
||||
}
|
||||
|
||||
$result = ['created' => 0, 'updated' => 0];
|
||||
|
||||
DB::transaction(function () use ($tenantId, $userId, $items, &$result) {
|
||||
foreach ($items as $payload) {
|
||||
// 기본 검증
|
||||
if (! isset($payload['target_table'], $payload['field_key'], $payload['field_name'], $payload['field_type'])) {
|
||||
throw new BadRequestHttpException(__('error.invalid_payload'));
|
||||
}
|
||||
|
||||
if (! empty($payload['id'])) {
|
||||
// 수정
|
||||
$model = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->find($payload['id']);
|
||||
if (! $model) {
|
||||
throw new BadRequestHttpException(__('error.not_found'));
|
||||
}
|
||||
|
||||
// target_table 또는 field_key 변경 시 유니크 검증
|
||||
$targetTableChanged = isset($payload['target_table']) && $payload['target_table'] !== $model->target_table;
|
||||
$fieldKeyChanged = isset($payload['field_key']) && $payload['field_key'] !== $model->field_key;
|
||||
|
||||
if ($targetTableChanged || $fieldKeyChanged) {
|
||||
$newTargetTable = $payload['target_table'] ?? $model->target_table;
|
||||
$newFieldKey = $payload['field_key'] ?? $model->field_key;
|
||||
|
||||
$dup = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->where('target_table', $newTargetTable)
|
||||
->where('field_key', $newFieldKey)
|
||||
->where('id', '!=', $payload['id'])
|
||||
->exists();
|
||||
if ($dup) {
|
||||
throw new BadRequestHttpException(__('error.duplicate_key'));
|
||||
}
|
||||
}
|
||||
|
||||
$payload['updated_by'] = $userId;
|
||||
$model->update($payload);
|
||||
$result['updated']++;
|
||||
} else {
|
||||
// 신규 생성
|
||||
$dup = TenantStatField::query()
|
||||
->where('tenant_id', $tenantId)
|
||||
->where('target_table', $payload['target_table'])
|
||||
->where('field_key', $payload['field_key'])
|
||||
->exists();
|
||||
if ($dup) {
|
||||
throw new BadRequestHttpException(__('error.duplicate_key'));
|
||||
}
|
||||
|
||||
$payload['tenant_id'] = $tenantId;
|
||||
$payload['is_critical'] = $payload['is_critical'] ?? false;
|
||||
$payload['display_order'] = $payload['display_order'] ?? 0;
|
||||
$payload['created_by'] = $userId;
|
||||
|
||||
TenantStatField::create($payload);
|
||||
$result['created']++;
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
return $result;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user