YY-Hotel-Business-ER/packages/cs_domain/lib/repository/sg_agency_repository.dart

import 'package:domain/entity/response/agency_detail_entity.dart';
import 'package:domain/entity/response/agency_option_entity.dart';
import 'package:domain/entity/response/agency_table_entity.dart';
import 'package:domain/entity/response/contract_detail_entity.dart';
import 'package:domain/entity/response/contract_option_entity.dart';
import 'package:domain/entity/response/contract_table_entity.dart';
import 'package:domain/entity/response/hotel_info_entity.dart';
import 'package:domain/entity/response/position_table_entity.dart';
import 'package:get/get.dart';
import 'package:plugin_platform/http/http_provider.dart';
import 'package:plugin_platform/http/http_result.dart';
import 'package:plugin_platform/platform_export.dart';
import 'package:shared/utils/util.dart';

import '../constants/api_constants.dart';

/// SG的中介相关数据仓库
class SGAgencyRepository extends GetxService {
  HttpProvider httpProvider;

  SGAgencyRepository({required this.httpProvider});

  /// 获取中介列表选项
  Future<HttpResult<AgencyOptionEntity>> fetchAgencyOption({
    CancelToken? cancelToken,
  }) async {
    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyOption,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      final json = result.getDataJson();
      var data = AgencyOptionEntity.fromJson(json!);
      //重新赋值data或list
      return result.convert<AgencyOptionEntity>(data: data);
    }
    return result.convert();
  }

  /// 获取中介列表Table
  Future<HttpResult<AgencyTableEntity>> fetchAgencyTable({
    required int curPage,
    String? keyword,
    String? status,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params["cur_page"] = curPage.toString();
    params["page_size"] = "10";

    if (Utils.isNotEmpty(keyword)) {
      params["keyword"] = keyword!;
    }
    if (Utils.isNotEmpty(status)) {
      params["status"] = status!;
    }

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyTable,
      params: params,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      final json = result.getDataJson();
      var data = AgencyTableEntity.fromJson(json!);
      //重新赋值data或list
      return result.convert<AgencyTableEntity>(data: data);
    }
    return result.convert();
  }

  /// 删除中介
  Future<HttpResult> deleteAgencySubmit(String? pivotId, {
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};

    params['pivot_id'] = pivotId ?? "";

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyDelete,
      method: HttpMethod.POST,
      params: params,
      networkDebounce: true,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      return result.convert();
    }
    return result.convert();
  }

  /// 添加中介
  Future<HttpResult> addAgencySubmit({
    required String? agencyName,
    required String? acraNo,
    String? contactPerson,
    String? address,
    String? contactNo,
    String? contactEmail,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params['agency_name'] = agencyName ?? "";
    params['acra_no'] = acraNo ?? "";
    if (!Utils.isEmpty(contactPerson)) {
      params["contact_person"] = contactPerson!;
    }
    if (!Utils.isEmpty(address)) {
      params["address"] = address!;
    }
    if (!Utils.isEmpty(contactNo)) {
      params["contact_no"] = contactNo!;
    }
    if (!Utils.isEmpty(contactEmail)) {
      params["contact_email"] = contactEmail!;
    }

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyAdd,
      method: HttpMethod.POST,
      params: params,
      networkDebounce: true,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      return result.convert();
    }
    return result.convert();
  }

  /// 编辑中介
  Future<HttpResult> editAgencySubmit({
    required String? pivotId,
    required String? agencyName,
    required String? acraNo,
    String? contactPerson,
    String? address,
    String? contactNo,
    String? contactEmail,
    String? status,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params['pivot_id'] = pivotId ?? "";
    params['agency_name'] = agencyName ?? "";
    params['acra_no'] = acraNo ?? "";
    if (!Utils.isEmpty(contactPerson)) {
      params["contact_person"] = contactPerson!;
    }
    if (!Utils.isEmpty(address)) {
      params["address"] = address!;
    }
    if (!Utils.isEmpty(contactNo)) {
      params["contact_no"] = contactNo!;
    }
    if (!Utils.isEmpty(contactEmail)) {
      params["contact_email"] = contactEmail!;
    }
    if (!Utils.isEmpty(status)) {
      params["status"] = status!;
    }

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyEdit,
      method: HttpMethod.POST,
      params: params,
      networkDebounce: true,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      return result.convert();
    }
    return result.convert();
  }

  /// 获取中介的编辑详情
  Future<HttpResult<AgencyDetailEntity>> fetchAgencyEditDetail({
    required String? pivotId,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    if (!Utils.isEmpty(pivotId)) {
      params["pivot_id"] = pivotId!;
    }

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyDetail,
      params: params,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      final json = result.getDataJson();
      var data = AgencyDetailEntity.fromJson(json!);
      //重新赋值data或list
      return result.convert<AgencyDetailEntity>(data: data);
    }
    return result.convert();
  }

  /// 获取中介职位的列表
  Future<HttpResult<PositionTableEntity>> fetchPositionTable({
    required int curPage,
    String? keyword,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params["cur_page"] = curPage.toString();
    params["page_size"] = "10";

    if (Utils.isNotEmpty(keyword)) {
      params["keyword"] = keyword!;
    }

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyPositionTable,
      params: params,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      final json = result.getDataJson();
      var data = PositionTableEntity.fromJson(json!);
      //重新赋值data或list
      return result.convert<PositionTableEntity>(data: data);
    }
    return result.convert();
  }

  /// 添加职位
  Future<HttpResult> addPositionSubmit({
    required String? name,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params['name'] = name ?? "";

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyPositionAdd,
      method: HttpMethod.POST,
      params: params,
      networkDebounce: true,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      return result.convert();
    }
    return result.convert();
  }

  /// 编辑职位
  Future<HttpResult> editPositionSubmit({
    required String? positionId,
    required String? name,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params['position_id'] = positionId ?? "";
    params['name'] = name ?? "";

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyPositionEdit,
      method: HttpMethod.POST,
      params: params,
      networkDebounce: true,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      return result.convert();
    }
    return result.convert();
  }

  /// 删除职位
  Future<HttpResult> deletePositionSubmit({
    required String? positionId,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params['position_id'] = positionId ?? "";

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiAgencyPositionDelete,
      method: HttpMethod.POST,
      params: params,
      networkDebounce: true,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      return result.convert();
    }
    return result.convert();
  }

  /// 获取中介合同列表选项
  Future<HttpResult<ContractOptionEntity>> fetchContractOption({
    CancelToken? cancelToken,
  }) async {
    final result = await httpProvider.requestNetResult(
      ApiConstants.apiContractOption,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      final json = result.getDataJson();
      var data = ContractOptionEntity.fromJson(json!);
      //重新赋值data或list
      return result.convert<ContractOptionEntity>(data: data);
    }
    return result.convert();
  }

  /// 获取中介合同列表Table
  Future<HttpResult<ContractTableEntity>> fetchContractTable({
    required int curPage,
    String? agencyId,
    String? status,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params["cur_page"] = curPage.toString();
    params["page_size"] = "10";

    if (Utils.isNotEmpty(agencyId)) {
      params["agency_id"] = agencyId!;
    }
    if (Utils.isNotEmpty(status)) {
      params["status"] = status!;
    }

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiContractTable,
      params: params,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      final json = result.getDataJson();
      var data = ContractTableEntity.fromJson(json!);
      //重新赋值data或list
      return result.convert<ContractTableEntity>(data: data);
    }
    return result.convert();
  }

  /// 获取中介的合同添加详情
  Future<HttpResult<ContractDetailEntity>> fetchContractAddOption({
    CancelToken? cancelToken,
  }) async {
    final result = await httpProvider.requestNetResult(
      ApiConstants.apiContractAddOption,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      final json = result.getDataJson();
      var data = ContractDetailEntity.fromJson(json!);
      //重新赋值data或list
      return result.convert<ContractDetailEntity>(data: data);
    }
    return result.convert();
  }

  /// 获取中介的合同编辑详情
  Future<HttpResult<ContractDetailEntity>> fetchContractEditDetail({
    required String? contractId,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params["contract_id"] = contractId ?? "";

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiContractDetail,
      params: params,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      final json = result.getDataJson();
      var data = ContractDetailEntity.fromJson(json!);
      //重新赋值data或list
      return result.convert<ContractDetailEntity>(data: data);
    }
    return result.convert();
  }

  /// 添加合同
  Future<HttpResult> addContractSubmit({
    required String? agencyId,
    required String? startDate,
    required String? endDate,
    List<String>? paths,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params['agency_id'] = agencyId ?? "";
    params['start_date'] = startDate ?? "";
    params['end_date'] = endDate ?? "";

    //文件
    Map<String,String> fileParams = {};
    if (paths != null && paths.isNotEmpty) {
      fileParams['file'] = paths[0];
    }

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiContractAddSubmit,
      method: HttpMethod.POST,
      params: params,
      paths: fileParams,
      networkDebounce: true,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      return result.convert();
    }
    return result.convert();
  }

  /// 编辑合同
  Future<HttpResult> editContractSubmit({
    required String? contractId,
    required String? agencyId,
    required String? startDate,
    required String? endDate,
    List<String>? paths,
    CancelToken? cancelToken,
  }) async {
    //参数
    Map<String, String> params = {};
    params['contract_id'] = contractId ?? "";
    params['agency_id'] = agencyId ?? "";
    params['start_date'] = startDate ?? "";
    params['end_date'] = endDate ?? "";

    //文件
    Map<String,String> fileParams = {};
    if (paths != null && paths.isNotEmpty) {
      fileParams['file'] = paths[0];
    }

    final result = await httpProvider.requestNetResult(
      ApiConstants.apiContractEditSubmit,
      method: HttpMethod.POST,
      params: params,
      paths: fileParams,
      networkDebounce: true,
      isShowLoadingDialog: true,
      cancelToken: cancelToken,
    );

    if (result.isSuccess) {
      //重新赋值data或list
      return result.convert();
    }
    return result.convert();
  }

}