feat(): noah api 透传

src/modules/api/controller/open_v4.ts

@@ -0,0 +1,1350 @@
+import {
+  All,
+  ALL,
+  Body,
+  Del,
+  Get,
+  Inject,
+  Param,
+  Post,
+  Provide,
+  Put,
+  Query,
+} from '@midwayjs/decorator';
+import { BaseController, CoolController } from '@cool-midway/core';
+import { Context } from 'vm';
+import { IndividualEntity } from '../../payment/entity/individual';
+import { NoahPayAdapter } from '../../payment/adapter/noah.adapter';
+import { NoahOpenService } from '../service/open_v4';
+import { OrderType } from '../entity/open_payment_order';
+
+/**
+ * 客户管理
+ */
+@Provide()
+@CoolController('/api/open/v4')
+export class OpenApiControllerV4 extends BaseController {
+  @Inject()
+  ctx: Context; // Inject the context
+
+  @Inject()
+  noahPayAdapter: NoahPayAdapter;
+
+  @Inject()
+  noahOpenService: NoahOpenService;
+
+  /**
+   * 生成sign
+   */
+  // @Post('/sign/v4', { summary: '创建sign' })
+  // async createSign(@Body(ALL) userBody: any) {
+  //   const { params, timestamp, nonce, secret } = userBody;
+  //   return this.noahOpenService.createSign(params, timestamp, nonce, secret);
+  // }
+
+  /**
+   * 创建用户
+   */
+  @Put('/v1/customers/:id', { summary: '创建账户/更新用户' })
+    //
+  async createPayInOrder(@Body(ALL) params: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    const res = await this.noahPayAdapter.request(method, path, params);
+    this.noahOpenService.save_user(res, params);
+    return res;
+  }
+
+  /**
+   * 查询用户列表
+   */
+  @Get('/v1/customers', { summary: '查询用户列表' })
+    //
+  async getAccounts(@Query(ALL) params: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询用户详情
+   */
+  @Get('/v1/customers/:id', { summary: '查询用户信息' })
+    //
+  async getAccountsInfo(@Param('id') id: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(
+      method,
+      `${path}`.replace(':id', id),
+      {}
+    );
+  }
+
+
+  /**
+   * 查询用户付款方式
+   */
+  @Get('/v1/payment-methods', { summary: '查询余额' })
+  async getPaymentMethods(
+    @Param('CustomerID') CustomerID: any,
+    @Body() params: any
+  ) {
+    //
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(
+      method,
+      `${path}`.replace(':CustomerID', CustomerID),
+      params
+    );
+  }
+
+  /**
+   * 查询费率
+   */
+  @Get('/v1/price', { summary: '查询余额' })
+  async getPrice(
+    @Param('SourceCurrency') SourceCurrency: any,
+    @Param('DestinationCurrency') DestinationCurrency: any,
+    @Body() params: any
+  ) {
+    //
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(
+      method,
+      `${path}`.replace(':SourceCurrency', SourceCurrency).replace(':DestinationCurrency', DestinationCurrency),
+      params
+    );
+  }
+
+  /**
+   * 查询订单列表
+   */
+  @Get('/v1/transactions', { summary: '查询订单列表' })
+    //
+  async getTransactions(@Query(ALL) params: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询订单详情
+   */
+  @Get('/v1/transactions/:id', { summary: '查询订单详情' })
+    //
+  async getTransactionsById(@Param('id') id: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(
+      method,
+      `${path}`.replace(':id', id),
+      {}
+    );
+  }
+
+  /**
+   * 申请收款账户
+   */
+  @Post('/v3/applications', { summary: '申请收款账户' })
+  async applications(@Body() params: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    const res = await this.noahPayAdapter.request(method, path, params);
+    this.noahOpenService.save_user_account(res, params);
+    return res;
+  }
+
+  /**
+   * 查询申请列表
+   */
+  @Get('/v3/applications', { summary: '查询申请列表' })
+  async getApplications(@Query() params: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询申请
+   */
+  @Get('/v3/applications/:id', { summary: '查询申请' })
+  async getApplicationsInfo(@Param('id') id: string) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 查询收款账户列表
+   */
+  @Get('/v1/bank_accounts', { summary: '查询收款账户列表' })
+  async getBank_accounts(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询收款账户
+   */
+  @Get('/v1/bank_accounts/:id', { summary: '查询收款账户' })
+  async getBank_accountsInfo(@Param('id') id: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 创建支付订单
+   */
+  @Post('/v3/acquiring/payments', { summary: '创建支付订单' })
+  async CreatedAcquiringPayments(@Body() params: any) {
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    const res = await this.noahPayAdapter.request(method, path, params);
+    this.noahOpenService.save_user_order(res, params, OrderType.ACQUIRING_PAYMENT);
+    return res;
+  }
+
+  /**
+   * 查询支付单
+   */
+  @Get('/v3/acquiring/payments/:id', { summary: '查询支付单' })
+  async getAcquiringPaymentsInfo(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 取消支付单
+   */
+  @Post('/v3/acquiring/payments/:id/cancel', { summary: '取消支付单' })
+  async cancelAcquiringPayments(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+  /**
+   * 查询支付单列表
+   */
+  @Get('/v3/acquiring/payments', { summary: '查询支付单列表' })
+  async getAcquiringPayments(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+    console.log('Request params:', params);
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 退款
+   */
+  @Post('/v3/acquiring/refunds', { summary: '退款' })
+  async acquiringRefunds(@Body() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+    console.log('Request params:', params);
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    const res = await this.noahPayAdapter.request(method, path, params);
+    this.noahOpenService.save_user_order(res, params, OrderType.ACQUIRING_REFUND);
+    return res;
+  }
+  /**
+   * 查询退款
+   */
+  @Get('/v3/acquiring/refunds/:id', { summary: '查询退款' })
+  async acquiringRefundsInfo(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+  /**
+   * 查询退款单列表
+   */
+  @Get('/v3/acquiring/refunds', { summary: '查询退款单列表' })
+  async acquiringRefundsList(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询对账单列表
+   */
+  @Get('/v3/acquiring/statements', { summary: '查询对账单列表' })
+  async acquiringStatements(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 查询结算单列表
+   */
+  @Get('/v3/acquiring/settlements', { summary: '查询结算单列表' })
+  async acquiringSettlements(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 查询结算单列表
+   */
+  @Get('/v3/acquiring/settlements/:id', { summary: '查询结算单列表' })
+  async acquiringSettlementsInfo(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+  /**
+   * 查询渠道汇率
+   */
+  @Get('/v3/acquiring/exchange_rates', { summary: '查询渠道汇率' })
+  async acquiringExchange_rates(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询入账列表
+   */
+  @Get('/v1/deposits', { summary: '查询入账列表' })
+  async depositsList(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+    console.log('Request params:', params);
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 查询入账
+   */
+  @Get('/v1/deposits/:id', { summary: '查询入账' })
+  async depositsInfo(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 入账凭证下载
+   */
+  @Get('/v1/deposits/:id/proof', { summary: '入账凭证下载' })
+  async depositsProofInfo(@Param('id') id: any, @Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 查询汇率
+   */
+  @Get('/v1/exchange_rates', { summary: '入账凭证下载' })
+  async exchange_ratesInfo(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 创建换汇订单
+   */
+  @Post('/v1/exchanges', { summary: '创建换汇订单' })
+  async createdExchanges(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    const res = await this.noahPayAdapter.request(method, path, params);
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+    this.noahOpenService.save_user_order(res, params, OrderType.CURRENCY_EXCHANGE);
+    return res;
+  }
+
+  /**
+   * 查询换汇订单列表
+   */
+  @Get('/v1/exchanges', { summary: '查询换汇订单列表' })
+  async exchangesList(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询换汇订单
+   */
+  @Get('/v1/exchanges/:id', { summary: '查询换汇订单' })
+  async exchangesInfo(@Param() id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 付款
+   */
+  @Post('/v1/payments', { summary: '付款' })
+  async createdPayments(@Body() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+    const res = await this.noahPayAdapter.request(method, path, params);
+    this.noahOpenService.save_user_order(res, params, OrderType.PAYMENT);
+    return res;
+  }
+
+  /**
+   * 查询付款列表
+   */
+  @Get('/v1/payments', { summary: '查询付款列表' })
+  async getPaymentsList(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询付款
+   */
+  @Get('/v1/payments/:id', { summary: '查询付款' })
+  async paymentsInfo(@Param() id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 补充材料
+   */
+  @Post('/v1/payments/:id/documents', { summary: '补充材料' })
+  async putPaymentsDocuments(@Param() id: any, @Body() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 付款凭证下载
+   */
+  @Get('/v1/payments/proof', { summary: '付款凭证下载' })
+  async paymentsProof(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 转账
+   */
+  @Post('/v1/transfers', { summary: '转账' })
+  async transfers(@Body() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    const res = await this.noahPayAdapter.request(method, path, params);
+    this.noahOpenService.save_user_order(res, params, OrderType.TRANSFER);
+    return res;
+  }
+
+  /**
+   * 查询转账列表
+   */
+  @Get('/v1/transfers', { summary: '查询转账列表' })
+  async transfersList(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+    console.log('Request params:', params);
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 查询转账
+   */
+  @Get('/v1/transfers/:id', { summary: '查询转账' })
+  async transfersInfo(@Param() id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 查询账户流水
+   */
+  @Get('/v3/accounts/:account_id/transactions', { summary: '查询账户流水' })
+  async accountsTransactionsInfo(
+    @Param() account_id: any,
+    @Query() params: any
+  ) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 根据 transaction ID 查询
+   */
+  @Get('/v3/accounts/:account_id/transactions/:id', {
+    summary: '根据 transaction ID 查询',
+  })
+  async accountsTransactionsInfoByAccount_id(
+    @Param() account_id: any,
+    @Param() id: any
+  ) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 查询实名更新请求列表
+   */
+  @Get('/v3/legal_entity_requests', { summary: '查询实名更新请求列表' })
+  async legal_entity_requestslist(@Query() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 提交实名更新
+   */
+  @Post('/v3/legal_entity_requests/:id/submit', { summary: '提交实名更新' })
+  async legal_entity_requestsSubmit(@Param() id: any, @Body() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 收款人信息校验
+   */
+  @Post('/v3/beneficiaries/validate', { summary: '收款人信息校验' })
+  async beneficiariesValidate(@Body() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 通过实名
+   */
+  @Post('/v3/simulate/accounts/:id/approve', { summary: '通过实名' })
+  async simulateAccountsApprove(@Param() id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 通过实名更新
+   */
+  @Post('/v3/simulate/legal_entity_requests/:id/confirm', {
+    summary: '通过实名更新',
+  })
+  async simulateLegal_entity_requestsConfirm(@Param() id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 驳回实名
+   */
+  @Post('/v3/simulate/accounts/:id/reject', { summary: '驳回实名' })
+  async simulateAccountsReject(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 创建实名更新
+   */
+  @Post('/v3/simulate/legal_entity_requests', { summary: '创建实名更新' })
+  async simulateLegal_entity_requests(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 入账
+   */
+  @Post('/v1/simulate/deposits', { summary: '入账' })
+  async simulateDeposits(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 拒绝更新请求
+   */
+  @Post('/v3/simulate/legal_entity_requests/:id/reject', {
+    summary: '拒绝更新请求',
+  })
+  async simulateLegal_entity_requestsReject(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 收款账户审核通过
+   */
+  @Post('/v3/simulate/applications/:id/confirm', {
+    summary: '收款账户审核通过',
+  })
+  async simulateApplicationsConfirm(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 收款账户审核驳回
+   */
+  @Post('/v3/simulate/applications/:id/reject', { summary: '收款账户审核驳回' })
+  async simulateApplicationsReject(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 通过付款
+   */
+  @Post('/v1/simulate/payments/:id/confirm', { summary: '通过付款' })
+  async simulatePaymentsConfirm(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 拒绝付款
+   */
+  @Post('/v1/simulate/payments/:id/reject', { summary: '拒绝付款' })
+  async simulatePaymentsReject(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 通过换汇
+   */
+  @Post('/v1/simulate/exchanges/:id/confirm', { summary: '通过换汇' })
+  async simulateExchangesConfirm(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 拒绝换汇
+   */
+  @Post('/v1/simulate/exchanges/:id/reject', { summary: '拒绝换汇' })
+  async simulateExchangesReject(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+
+  /**
+   * 创建 Webhook
+   */
+  @Post('/v3/webhooks', { summary: '创建 Webhook' })
+  async createdWebhooks(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 查询 Webhook
+   */
+  @Get('/v3/webhooks', { summary: '查询 Webhook' })
+  async getWebhooks(@Query(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 修改 Webhook
+   */
+  @Put('/v3/webhooks/:id', { summary: '修改 Webhook' })
+  async putWebhooks(@Param('id') id: any, @Body() params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 删除 Webhook
+   */
+  @Del('/v3/webhooks/:id', { summary: '修改 Webhook' })
+  async delWebhooks(@Param('id') id: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, {});
+  }
+  /**
+   * 创建 Webhook HMAC Key
+   */
+  @Post('/v3/webhook_hmac_key', { summary: '创建 Webhook HMAC Key' })
+  async createWebhook_hmac_key(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 账户审核通过
+   */
+  @Post('/account_approved', { summary: '账户审核通过' })
+  async account_approved(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 账户审核驳回
+   */
+  @Post('/account_rejected', { summary: '账户审核驳回' })
+  async account_rejected(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 实名待更新
+   */
+  @Post('/legal_entity_request_created', { summary: '实名待更新' })
+  async legal_entity_request_created(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 实名更新审核通过
+   */
+  @Post('/legal_entity_request_success', { summary: '实名更新审核通过' })
+  async legal_entity_request_success(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+  /**
+   * 实名更新审核驳回
+   */
+  @Post('/legal_entity_request_rejected', { summary: '实名更新审核驳回 ' })
+  async legal_entity_request_rejected(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 收款账户申请成功
+   */
+  @Post('/application_success', { summary: '收款账户申请成功' })
+  async application_success(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 收款账户申请失败
+   */
+  @Post('/application_failed', { summary: '收款账户申请失败' })
+  async application_failed(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 收款账户信息变更
+   */
+  @Post('/bank_account_updated', { summary: '收款账户信息变更' })
+  async bank_account_updated(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 收单支付成功通知
+   */
+  @Post('/acquiring_payment_success', { summary: '收单支付成功通知' })
+  async acquiring_payment_success(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 收单退款成功通知
+   */
+  @Post('/acquiring_refund_success', { summary: '收单退款成功通知' })
+  async acquiring_refund_success(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 收单退款失败通知
+   */
+  @Post('/acquiring_refund_failed', { summary: '收单退款失败通知' })
+  async acquiring_refund_failed(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 入账成功
+   */
+  @Post('/deposit_success', { summary: '入账成功' })
+  async deposit_success(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 换汇成功
+   */
+  @Post('/exchange_success', { summary: '换汇成功' })
+  async exchange_success(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 换汇失败
+   */
+  @Post('/exchange_failed', { summary: '换汇失败' })
+  async exchange_failed(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 收款账户已下发
+   */
+  @Post('/bank_account_created', { summary: '收款账户已下发' })
+  async bank_account_created(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 付款成功
+   */
+  @Post('/payment_success', { summary: '付款成功' })
+  async payment_success(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 付款失败
+   */
+  @Post('/payment_failed', { summary: '付款失败' })
+  async payment_failed(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 付款银行退回
+   */
+  @Post('/payment_refunded', { summary: '付款银行退回' })
+  async payment_refunded(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 转账成功
+   */
+  @Post('/transfer_success', { summary: '转账成功' })
+  async transfer_success(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+
+  /**
+   * 转账失败
+   */
+  @Post('/transfer_failed', { summary: '转账失败' })
+  async transfer_failed(@Body(ALL) params: any) {
+    // Access the request method and path
+    const method = this.ctx.method;
+    const path = this.ctx.path;
+
+    console.log('Request Method:', method);
+    console.log('Request Path:', path);
+
+    // console.log(typeof params)
+    // return `${method}, ${path}, ${params}`
+    return await this.noahPayAdapter.request(method, path, params);
+  }
+}
+

src/modules/api/service/open_v4.ts

@@ -0,0 +1,254 @@
+import { BaseService, CoolTransaction } from '@cool-midway/core';
+import { ILogger, Inject, Provide } from '@midwayjs/core';
+import { InjectEntityModel } from '@midwayjs/typeorm';
+import { OpenUserEntity } from '../entity/open_user';
+import * as crypto from 'crypto';
+import { In, LessThan, QueryRunner, Repository } from 'typeorm';
+import {
+  OpenPaymentOrderEntity,
+  OrderType,
+} from '../entity/open_payment_order';
+import { OpenPaymentAccountEntity } from '../entity/open_payment_account';
+import { NoahPayAdapter } from '../../payment/adapter/noah.adapter';
+
+/**
+ * 描述
+ */
+@Provide()
+export class NoahOpenService extends BaseService {
+  @InjectEntityModel(OpenUserEntity)
+  openUserEntity: Repository<OpenUserEntity>;
+
+  @InjectEntityModel(OpenPaymentOrderEntity)
+  openPaymentOrderEntity: Repository<OpenPaymentOrderEntity>;
+
+  @InjectEntityModel(OpenPaymentAccountEntity)
+  openPaymentAccountEntity: Repository<OpenPaymentAccountEntity>;
+
+  @Inject()
+  logger: ILogger;
+
+  @Inject()
+  noahPayAdapter: NoahPayAdapter;
+
+  @Inject()
+  ctx;
+
+  /*
+    记录用户的数据来源
+    */
+  async save_user(userInfo, params) {
+    try {
+      const openUserObj = {
+        mch_id: this.ctx.admin.merchant.mchId,
+        account_id: userInfo.data.id,
+        source: 'NOAHPAY',
+      };
+      await this.openUserEntity.insert(openUserObj);
+      this.logger.info(
+        `save_user 商户: ${this.ctx.admin.merchant.mchId}; userInfo${JSON.stringify(userInfo)} params${JSON.stringify(params)}`
+      );
+    } catch (error) {
+      this.logger.error('save_user:error: ', error);
+    }
+  }
+
+  /*
+    记录用户的收款账户数据来源
+    */
+  async save_user_account(userInfo, params) {
+    try {
+      const openUserObj = {
+        mch_id: this.ctx.admin.merchant.mchId,
+        account_id: params.account_id,
+        payment_account_id: userInfo.data.id,
+        source: 'NOAHPAY',
+      };
+      await this.openPaymentAccountEntity.insert(openUserObj);
+      this.logger.info(
+        `save_user_account 商户: ${this.ctx.admin.merchant.mchId}; userInfo${JSON.stringify(userInfo)} params${JSON.stringify(params)}`
+      );
+    } catch (error) {
+      this.logger.error('save_user_account:error: ', error);
+    }
+  }
+
+  /*
+    记录用户的订单数据来源
+  */
+  async save_user_order(orderInfo, params, type: OrderType) {
+    try {
+      let openOrderObj: any = {
+        mch_id: this.ctx.admin.merchant.mchId,
+        account_id: params.account_id,
+        request_id: params.payment.request_id,
+        order_type: type,
+        additional_info: {
+          orderInfo,
+          params,
+          type,
+        },
+      };
+
+      // 收单支付订单
+      if (OrderType.ACQUIRING_PAYMENT === type) {
+        openOrderObj.amount = params.payment.amount;
+        openOrderObj.currency = params.payment.currency;
+      }
+
+      // 收单退款订单
+      if (OrderType.ACQUIRING_REFUND === type) {
+        openOrderObj.amount = params.refund.amount;
+        openOrderObj.currency = params.refund.currency;
+      }
+
+      // 换汇
+      if (OrderType.CURRENCY_EXCHANGE === type) {
+        openOrderObj.amount = params.sell_amount; // 卖出金额
+        openOrderObj.currency = params.sell_currency; // 卖出币种
+
+        openOrderObj.target_amount = params.buy_amount; // 买入金额
+        openOrderObj.target_currency = params.buy_currency; // 买入币种
+      }
+
+      // 付款
+      if (OrderType.PAYMENT === type) {
+        openOrderObj.amount = params.amount;
+        openOrderObj.currency = params.currency;
+      }
+
+      // 转账
+      if (OrderType.TRANSFER === type) {
+        openOrderObj.amount = params.amount;
+        openOrderObj.currency = params.currency;
+        openOrderObj.from_account_id = params.from_account_id;
+        openOrderObj.to_account_id = params.to_account_id;
+      }
+
+      // // 入账
+      // if (OrderType.DEPOSIT === type) {
+      //   openOrderObj.amount = params.payment.amount;
+      //   openOrderObj.currency = params.payment.currency;
+      // }
+
+      await this.openPaymentOrderEntity.insert(openOrderObj);
+
+      /* 更新相关订单信息 */
+
+      // 退款事件处理
+      if (OrderType.ACQUIRING_REFUND === type) {
+        const paymentOrder: any = {};
+        if (params.hasOwnProperty('payment_id')) {
+          paymentOrder.event_id = params.payment_id;
+        }
+        if (params.hasOwnProperty('payment_request_id')) {
+          paymentOrder.request_id = params.payment_request_id;
+        }
+        openOrderObj.currency = params.payment.currency;
+        await this.openPaymentOrderEntity.update(paymentOrder, {
+          status: 'REFUNDED',
+        });
+      }
+      this.logger.info(
+        `save_user_order 商户: ${this.ctx.admin.merchant.mchId}; userInfo${JSON.stringify(orderInfo)} params${JSON.stringify(params)}`
+      );
+    } catch (error) {
+      this.logger.error('save_user_order:error: ', error);
+    }
+  }
+
+  createSign(params, timestamp, nonce, secret) {
+    // 2. 生成签名
+    const sign = this.generateSignature(
+      `${timestamp}`,
+      `${nonce}`,
+      JSON.stringify(params),
+      `${secret}`
+    );
+    return sign;
+  }
+  /**
+   * 生成签名
+   * @see https://docs-merchant.sunpay.pro/guide
+   */
+  generateSignature(timestamp, nonce, body = '', secret = '') {
+    const payload = `${timestamp}${nonce}${body}`;
+    const signature = crypto
+      .createHmac('sha256', secret)
+      .update(payload)
+      .digest('hex')
+      .toUpperCase();
+    return signature;
+  }
+
+  /**
+   * 处理未完成的订单
+   */
+  @CoolTransaction({ isolation: 'SERIALIZABLE' })
+  async handleUnfinishedOrder(params, queryRunner?: QueryRunner) {
+    const orders = await this.openPaymentOrderEntity.find({
+      where: {
+        status: '',
+        // 1小时未完成的订单
+        createTime: LessThan(new Date(Date.now() - 1 * 60 * 60 * 1000)),
+      },
+    });
+    this.logger.info(`处理未完成的订单:${orders.length}`);
+    try {
+      for (const order of orders) {
+        const status = await this.thawed(order, queryRunner);
+        order.status = status;
+        await this.openPaymentOrderEntity.update(order.id, order);
+      }
+    } catch (err) {
+      this.logger.error(784, err);
+    }
+  }
+  /*
+   */
+  async thawed(order, queryRunner) {
+    // 收单支付订单
+    if (OrderType.ACQUIRING_PAYMENT === order.type) {
+      const res = await this.noahPayAdapter.request(
+        'GET',
+        `/v3/acgiinqru/payments/${order.event_id}`
+      );
+      return res.data.status;
+    }
+    // 收单退款订单
+    if (OrderType.ACQUIRING_REFUND === order.type) {
+      const res = await this.noahPayAdapter.request(
+        'GET',
+        `/v3/acquiring/refunds/${order.event_id}`
+      );
+      return res.data.status;
+    }
+
+    // 换汇
+    if (OrderType.CURRENCY_EXCHANGE === order.type) {
+      const res = await this.noahPayAdapter.request(
+        'GET',
+        `/v1/exchanges/${order.event_id}`
+      );
+      return res.data.status;
+    }
+
+    // 付款
+    if (OrderType.PAYMENT === order.type) {
+      const res = await this.noahPayAdapter.request(
+        'GET',
+        `/v1/payments/${order.event_id}`
+      );
+      return res.data.status;
+    }
+
+    // 转账
+    if (OrderType.TRANSFER === order.type) {
+      const res = await this.noahPayAdapter.request(
+        'GET',
+        `/v1/transfers/${order.event_id}`
+      );
+      return res.data.status;
+    }
+  }
+}