import 'package:dio/dio.dart';
import 'package:injectable/injectable.dart';
import '../../core/constants/api_endpoints.dart';
import '../../core/constants/app_constants.dart';
import '../../core/errors/exceptions.dart';
import '../../domain/repositories/rent_repository.dart';
import '../models/rent_dto.dart';

@LazySingleton(as: RentRepository)
class RentRepositoryImpl implements RentRepository {
  final Dio dio;

  RentRepositoryImpl(this.dio);

  @override
  Future<RentListResponse> getRents({
    int page = 1,
    int perPage = AppConstants.rentPageSize,
    int? equipmentId,
    int? companyId,
    bool? isActive,
    DateTime? dateFrom,
    DateTime? dateTo,
  }) async {
    try {
      final queryParameters = <String, dynamic>{
        'page': page,
        'per_page': perPage,
      };
      
      if (equipmentId != null) {
        queryParameters['equipment_id'] = equipmentId;
      }
      
      if (companyId != null) {
        queryParameters['company_id'] = companyId;
      }
      
      if (isActive != null) {
        queryParameters['is_active'] = isActive;
      }
      
      if (dateFrom != null) {
        queryParameters['date_from'] = dateFrom.toIso8601String().split('T')[0];
      }
      
      if (dateTo != null) {
        queryParameters['date_to'] = dateTo.toIso8601String().split('T')[0];
      }

      final response = await dio.get(
        ApiEndpoints.rents,
        queryParameters: queryParameters,
      );

      return RentListResponse.fromJson(response.data);
    } on DioException catch (e) {
      throw ServerException(message: _handleError(e));
    } catch (e) {
      throw ServerException(message: '임대 목록을 가져오는 중 오류가 발생했습니다: $e');
    }
  }

  @override
  Future<RentDto> getRent(int id) async {
    try {
      final response = await dio.get('${ApiEndpoints.rents}/$id');
      return RentDto.fromJson(response.data);
    } on DioException catch (e) {
      throw ServerException(message: _handleError(e));
    } catch (e) {
      throw ServerException(message: '임대 상세 정보를 가져오는 중 오류가 발생했습니다: $e');
    }
  }

  @override
  Future<RentDto> createRent(RentRequestDto request) async {
    try {
      final response = await dio.post(
        ApiEndpoints.rents,
        data: request.toJson(),
      );
      return RentDto.fromJson(response.data);
    } on DioException catch (e) {
      throw ServerException(message: _handleError(e));
    } catch (e) {
      throw ServerException(message: '임대 생성 중 오류가 발생했습니다: $e');
    }
  }

  @override
  Future<RentDto> updateRent(int id, RentUpdateRequestDto request) async {
    try {
      final response = await dio.put(
        '${ApiEndpoints.rents}/$id',
        data: request.toJson(),
      );
      return RentDto.fromJson(response.data);
    } on DioException catch (e) {
      throw ServerException(message: _handleError(e));
    } catch (e) {
      throw ServerException(message: '임대 수정 중 오류가 발생했습니다: $e');
    }
  }

  @override
  Future<void> deleteRent(int id) async {
    try {
      await dio.delete('${ApiEndpoints.rents}/$id');
    } on DioException catch (e) {
      throw ServerException(message: _handleError(e));
    } catch (e) {
      throw ServerException(message: '임대 삭제 중 오류가 발생했습니다: $e');
    }
  }

  @override
  Future<List<RentDto>> getActiveRents() async {
    try {
      final response = await dio.get('${ApiEndpoints.rents}/active');
      
      // Backend returns List<RentDto> directly for /active endpoint
      final List<dynamic> dataList = response.data as List<dynamic>;
      return dataList.map((json) => RentDto.fromJson(json)).toList();
    } on DioException catch (e) {
      throw ServerException(message: _handleError(e));
    } catch (e) {
      throw ServerException(message: '진행중인 임대를 가져오는 중 오류가 발생했습니다: $e');
    }
  }

  Future<List<RentDto>> getOverdueRents({
    int page = 1,
    int perPage = AppConstants.rentPageSize,
  }) async {
    // 백엔드 호환: 비활성 임대 중 만료일이 과거인 것들
    final response = await getRents(
      page: page,
      perPage: perPage,
      isActive: false, // 비활성 임대
      dateTo: DateTime.now(), // 오늘까지의 날짜
    );
    
    return response.items;
  }

  Future<Map<String, dynamic>> getRentStats() async {
    try {
      // 백엔드 호환: 클라이언트 측에서 통계 계산
      final allRents = await getRents(perPage: AppConstants.maxBulkPageSize); // 충분히 큰 페이지 사이즈
      
      int totalRents = allRents.totalCount ?? 0;
      int activeRents = 0;
      int overdueRents = 0;
      int returnedRents = 0;
      
      for (final rent in allRents.items ?? []) {
        final now = DateTime.now();
        final endDate = DateTime.parse(rent.endedAt);
        
        if (endDate.isBefore(now)) {
          overdueRents++;
        } else {
          activeRents++;
        }
      }
      
      return {
        'total': totalRents,
        'active': activeRents,
        'overdue': overdueRents,
        'returned': returnedRents,
      };
    } catch (e) {
      throw ServerException(message: '임대 통계를 계산하는 중 오류가 발생했습니다: $e');
    }
  }

  // returnRent() 메서드 제거 - 백엔드에 해당 API 엔드포인트 없음

  // 에러 처리 메서드
  String _handleError(DioException e) {
    if (e.response != null) {
      final statusCode = e.response!.statusCode;
      final data = e.response!.data;
      
      if (data is Map && data.containsKey('message')) {
        return data['message'];
      }
      
      switch (statusCode) {
        case 400:
          return '잘못된 요청입니다.';
        case 401:
          return '인증이 필요합니다.';
        case 403:
          return '권한이 없습니다.';
        case 404:
          return '리소스를 찾을 수 없습니다.';
        case 500:
          return '서버 내부 오류입니다.';
        default:
          return 'HTTP 오류 $statusCode';
      }
    }
    
    switch (e.type) {
      case DioExceptionType.connectionTimeout:
        return '연결 시간 초과';
      case DioExceptionType.sendTimeout:
        return '요청 전송 시간 초과';
      case DioExceptionType.receiveTimeout:
        return '응답 수신 시간 초과';
      case DioExceptionType.connectionError:
        return '네트워크 연결 오류';
      case DioExceptionType.cancel:
        return '요청이 취소됨';
      default:
        return '네트워크 오류: ${e.message}';
    }
  }
}