jiu/client/lib/repositories/stock_in_repository.dart

import 'package:dio/dio.dart';
import '../core/api/api_client.dart';
import '../core/exceptions.dart';
import '../core/models/page_result.dart';
import '../models/stock_in.dart';

class StockInRepository {
  final ApiClient _client;

  const StockInRepository(this._client);

  Future<PageResult<StockInOrder>> list({
    String? status,
    String? startDate,
    String? endDate,
    String? keyword,
    int page = 1,
    int pageSize = 20,
  }) async {
    try {
      final params = <String, dynamic>{
        'page': page,
        'page_size': pageSize,
        if (status != null && status.isNotEmpty) 'status': status,
        if (startDate != null) 'start_date': startDate,
        if (endDate != null) 'end_date': endDate,
        if (keyword != null && keyword.isNotEmpty) 'keyword': keyword,
      };
      final resp = await _client.get('/stock-in/orders', params: params);
      return PageResult.fromJson(
        resp.data as Map<String, dynamic>,
        StockInOrder.fromJson,
      );
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '获取入库单列表失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  Future<StockInOrder> get(int id) async {
    try {
      final resp = await _client.get('/stock-in/orders/$id');
      return StockInOrder.fromJson(
          (resp.data as Map<String, dynamic>)['data'] as Map<String, dynamic>);
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '获取入库单详情失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  Future<StockInOrder> create(Map<String, dynamic> data) async {
    try {
      final resp = await _client.post('/stock-in/orders', data: data);
      return StockInOrder.fromJson(
          (resp.data as Map<String, dynamic>)['data'] as Map<String, dynamic>);
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '创建入库单失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  Future<void> update(int id, Map<String, dynamic> data) async {
    try {
      await _client.put('/stock-in/orders/$id', data: data);
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '修改入库单失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  Future<void> delete(int id) async {
    try {
      await _client.delete('/stock-in/orders/$id');
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '删除入库单失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  Future<void> submit(int id) async {
    try {
      await _client.put('/stock-in/orders/$id/submit');
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '提交审核失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  Future<void> approve(int id) async {
    try {
      await _client.put('/stock-in/orders/$id/approve');
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '审核通过失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  Future<void> reject(int id) async {
    try {
      await _client.put('/stock-in/orders/$id/reject');
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '拒绝失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  Future<void> withdraw(int id) async {
    try {
      await _client.put('/stock-in/orders/$id/withdraw');
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '撤回失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  /// 退单：退掉指定明细（item ids）。入库退单对应库存从库存删除。
  Future<void> returnItems(int id, List<int> itemIds) async {
    try {
      await _client.post('/stock-in/orders/$id/return', data: {'item_ids': itemIds});
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '退单失败',
        statusCode: e.response?.statusCode,
      );
    }
  }

  /// 确认进价：把指定明细的暂估 0 价补成真实进价（前向补偿成本与应付）。
  /// items 形如 [{'item_id': 1, 'unit_price': 50.0}]。
  Future<void> confirmCost(int id, List<Map<String, dynamic>> items) async {
    try {
      await _client.post('/stock-in/orders/$id/confirm-cost', data: {'items': items});
    } on DioException catch (e) {
      throw AppException(
        e.response?.data?['error'] as String? ?? '确认进价失败',
        statusCode: e.response?.statusCode,
      );
    }
  }
}