middle-service/app/service/util/http-util.js

'use strict';
const _ = require('lodash');
const { AxiosService } = require('naf-framework-mongoose/lib/service');
const { BusinessError, ErrorCode } = require('naf-core').Error;
const { isNullOrUndefined } = require('naf-core').Util;

class UtilService extends AxiosService {
  constructor(ctx) {
    super(ctx, {}, {});
  }

  // 替换uri中的参数变量
  merge(uri, query = {}) {
    const keys = Object.keys(query);
    const arr = [];
    for (const k of keys) {
      arr.push(`${k}=${query[k]}`);
    }
    if (arr.length > 0) {
      uri = `${uri}?${arr.join('&')}`;
    }
    return uri;
  }

  /**
   * curl-get请求
   * @param {String} uri 接口地址
   * @param {Object} query 地址栏参数
   * @param {Object} options 额外参数
   */
  async $get(uri, query, options) {
    return this.toRequest(uri, null, query, options);
  }

  /**
   * curl-post请求
   * @param {String} uri 接口地址
   * @param {Object} data post的body
   * @param {Object} query 地址栏参数
   * @param {Object} options 额外参数
   */
  async $post(uri, data = {}, query, options) {
    return this.toRequest(uri, data, query, options);
  }

  /**
   * curl-delete请求
   * @param {String} uri 接口地址
   * @param {Object} data post的body
   * @param {Object} query 地址栏参数
   * @param {Object} options 额外参数默认 method:delete
   */
  async $delete(uri, data = {}, query, options) {
    options = { ...options, method: 'delete' };
    return this.toRequest(uri, data, query, options);
  }

  async toRequest(uri, data, query, options) {
    query = _.pickBy(
      query,
      val => val !== '' && val !== 'undefined' && val !== 'null'
    );
    if (!uri) console.error('uri不能为空');
    if (_.isObject(query) && _.isObject(options)) {
      const params = query.params ? query.params : query;
      options = { ...options, params };
    } else if (_.isObject(query) && !query.params) {
      options = { params: query };
    } else if (_.isObject(query) && query.params) {
      options = query;
    }
    // 是否多租户模式,需要改变headers
    const headers = { 'content-type': 'application/json' };
    let url = this.merge(`${uri}`, options.params);
    if (!url.includes('http')) url = `http://127.0.0.1${url}`;
    let res = await this.ctx.curl(url, {
      method: isNullOrUndefined(data) ? 'get' : 'post',
      url,
      data,
      dataType: 'json',
      headers,
      ...options,
    });
    if (res.status === 200) {
      res = res.data || {};
      const { errcode, errmsg, details } = res;
      if (errcode) {
        console.warn(`[${uri}] fail: ${errcode}-${errmsg} ${details}`);
        return { errcode, errmsg };
      }
      return res;
    }
    const { status } = res;
    console.warn(`[${uri}] fail: ${status}-${res.data.message} `);
  }
}
module.exports = UtilService;