Files
superport/lib/domain/usecases/vendor_usecase.dart

155 lines
4.3 KiB
Dart

import 'package:injectable/injectable.dart';
import 'package:superport/data/models/vendor_dto.dart';
import 'package:superport/data/models/vendor_stats_dto.dart';
import 'package:superport/data/repositories/vendor_repository.dart';
import 'package:superport/utils/constants.dart';
abstract class VendorUseCase {
Future<VendorListResponse> getVendors({
int page = 1,
int limit = PaginationConstants.defaultPageSize,
String? search,
bool? isActive,
});
Future<VendorDto> getVendorById(int id);
Future<VendorDto> createVendor(VendorDto vendor);
Future<VendorDto> updateVendor(int id, VendorDto vendor);
Future<void> deleteVendor(int id);
Future<void> restoreVendor(int id);
Future<bool> validateVendor(VendorDto vendor);
Future<bool> checkDuplicateName(String name, {int? excludeId});
Future<VendorStatsDto> getVendorStats();
}
@Injectable(as: VendorUseCase)
class VendorUseCaseImpl implements VendorUseCase {
final VendorRepository _repository;
VendorUseCaseImpl(this._repository);
@override
Future<VendorListResponse> getVendors({
int page = 1,
int limit = PaginationConstants.defaultPageSize,
String? search,
bool? isActive,
}) async {
// 비즈니스 로직: 페이지네이션 유효성 검사
if (page < 1) page = 1;
if (limit < 1 || limit > 100) limit = 20;
return await _repository.getAll(
page: page,
limit: limit,
search: search,
isActive: isActive,
);
}
@override
Future<VendorDto> getVendorById(int id) async {
if (id <= 0) {
throw ArgumentError('유효하지 않은 벤더 ID입니다.');
}
return await _repository.getById(id);
}
@override
Future<VendorDto> createVendor(VendorDto vendor) async {
// 비즈니스 규칙 검증
await _validateVendorData(vendor);
// 중복 이름 검사
final isDuplicate = await checkDuplicateName(vendor.name);
if (isDuplicate) {
throw Exception('이미 존재하는 벤더명입니다.');
}
return await _repository.create(vendor);
}
@override
Future<VendorDto> updateVendor(int id, VendorDto vendor) async {
if (id <= 0) {
throw ArgumentError('유효하지 않은 벤더 ID입니다.');
}
// 비즈니스 규칙 검증
await _validateVendorData(vendor);
// 중복 이름 검사 (자기 자신 제외)
final isDuplicate = await checkDuplicateName(vendor.name, excludeId: id);
if (isDuplicate) {
throw Exception('이미 존재하는 벤더명입니다.');
}
return await _repository.update(id, vendor);
}
@override
Future<void> deleteVendor(int id) async {
if (id <= 0) {
throw ArgumentError('유효하지 않은 벤더 ID입니다.');
}
// 비즈니스 로직: 연관된 모델이나 장비가 있는지 확인
// TODO: 모델 및 장비 연관성 체크 구현
await _repository.delete(id);
}
@override
Future<void> restoreVendor(int id) async {
if (id <= 0) {
throw ArgumentError('유효하지 않은 벤더 ID입니다.');
}
await _repository.restore(id);
}
@override
Future<bool> validateVendor(VendorDto vendor) async {
try {
await _validateVendorData(vendor);
return true;
} catch (e) {
return false;
}
}
@override
Future<bool> checkDuplicateName(String name, {int? excludeId}) async {
if (name.trim().isEmpty) {
return false;
}
try {
final response = await _repository.getAll(search: name);
final duplicates = response.items.where((v) =>
v.name.toLowerCase() == name.toLowerCase() &&
(excludeId == null || v.id != excludeId)
);
return duplicates.isNotEmpty;
} catch (e) {
// 에러 발생 시 중복 없음으로 처리
return false;
}
}
Future<void> _validateVendorData(VendorDto vendor) async {
// 필수 필드 검증
if (vendor.name.trim().isEmpty) {
throw ArgumentError('벤더명은 필수 입력 항목입니다.');
}
if (vendor.name.length > 100) {
throw ArgumentError('벤더명은 100자를 초과할 수 없습니다.');
}
// 백엔드 스키마와 일치하는 필드만 검증 (name, is_deleted, registered_at, updated_at)
}
@override
Future<VendorStatsDto> getVendorStats() async {
return await _repository.getStats();
}
}