null/common/request/request.js

import env from '../config.js'
// import NProgress from 'nprogress'
// import 'nprogress/nprogress.css'
import store from '../../store/index.js'
const TAG_NAME="REQUEST REQUEST.JS";
import Tools from '../tools.js';

export default class Request {
	config = {
		baseUrl: env.consoleBaseUrl,
		header: {
			'content-type': 'application/x-www-form-urlencoded',
			// 'content-type': 'application/json',
			// 'platform': uni.getStorageSync('platform'),
		},
		method: 'GET',
		dataType: 'json',
		// #ifndef MP-ALIPAY || APP-PLUS
		responseType: 'text',
		// #endif
		custom: {},
		// #ifdef MP-ALIPAY
		timeout: 30000,
		// #endif
		// #ifdef APP-PLUS
		sslVerify: false
		// #endif
	}

	static posUrl(url) { /* 判断url是否为绝对路径 */
		return /(http|https):\/\/([\w.]+\/?)\S*/.test(url)
	}

	// static addQueryString(params) {
	// 	let paramsData = ''
	// 	Object.keys(params).forEach(function(key) {
	// 		paramsData += key + '=' + encodeURIComponent(params[key]) + '&'
	// 	})
	// 	return paramsData.substring(0, paramsData.length - 1)
	// }

	/**
	 * @property {Function} request 请求拦截器
	 * @property {Function} response 响应拦截器
	 * @type {{request: Request.interceptor.request, response: Request.interceptor.response}}
	 */
	interceptor = {
		/**
		 * @param {Request~requestCallback} cb - 请求之前拦截,接收一个函数（config, cancel）=> {return config}。第一个参数为全局config,第二个参数为函数，调用则取消本次请求。
		 */
		request: (cb) => {
			if (cb) {
				this.requestBeforeFun = cb
			}
		},
		/**
		 * @param {Request~responseCallback} cb 响应拦截器，对响应数据做点什么
		 * @param {Request~responseErrCallback} ecb 响应拦截器，对响应错误做点什么
		 */
		response: (cb, ecb) => {
			if (cb && ecb) {
				this.requestComFun = cb
				this.requestComFail = ecb
			}
		}
	}

	requestBeforeFun(config) {
		return config
	}

	requestComFun(response) {
		return response
	}

	requestComFail(response) {
		return response
	}

	/**
	 * 自定义验证器，如果返回true 则进入响应拦截器的响应成功函数(resolve)，否则进入响应拦截器的响应错误函数(reject)
	 * @param { Number } statusCode - 请求响应体statusCode（只读）
	 * @return { Boolean } 如果为true,则 resolve, 否则 reject
	 */
	validateStatus(statusCode) {
		return statusCode === 200
	}

	/**
	 * @Function
	 * @param {Request~setConfigCallback} f - 设置全局默认配置
	 */
	setConfig(f) {
		this.config = f(this.config)
	}

	/**
	 * @Function
	 * @param {Object} options - 请求配置项
	 * @prop {String} options.url - 请求路径
	 * @prop {Object} options.data - 请求参数
	 * @prop {Object} [options.responseType = config.responseType] [text|arraybuffer] - 响应的数据类型
	 * @prop {Object} [options.dataType = config.dataType] - 如果设为 json，会尝试对返回的数据做一次 JSON.parse
	 * @prop {Object} [options.header = config.header] - 请求header
	 * @prop {Object} [options.method = config.method] - 请求方法
	 * @returns {Promise<unknown>}
	 */
	request(options = {}) {
		options.baseUrl = this.config.baseUrl
		options.dataType = options.dataType || this.config.dataType
		// #ifndef MP-ALIPAY || APP-PLUS
		options.responseType = options.responseType || this.config.responseType
		// #endif
		// #ifdef MP-ALIPAY
		options.timeout = options.timeout || this.config.timeout
		// #endif
		options.url = options.url || ''
		options.data = options.data || {}
		options.params = options.params || {}
		options.header = options.header || this.config.header
		options.method = options.method || this.config.method
		options.custom = { ...this.config.custom,
			...(options.custom || {})
		}
		options.isNprogress = options.isNprogress || false 
		// #ifdef APP-PLUS
		options.sslVerify = options.sslVerify === undefined ? this.config.sslVerify : options.sslVerify
		// #endif
		// uni.showToast({
		// 	icon: "loading",
		// 	image: "/static/imgs//logo/logo.gif"
		// })
		return new Promise((resolve, reject) => {
			let next = true
			let handleRe = {}

			options.complete = (response) => {
				if(handleRe.isNprogress) {
					// console.log('complete 支付成功 关闭弹窗~~',handleRe.isNprogress);
					uni.hideLoading();
				}
				
				response.config = handleRe
				if (this.validateStatus(response.statusCode)) { // 成功
				    response = this.requestComFun(response)
					const data = response.data;
					// const errLoginCode = ['100000','100001','100002','100003','100004'];
					// if(data && data.code && errLoginCode.includes(data.code)){
					//    const pages = getCurrentPages()
					//    if(pages.length > 1 && pages[pages.length - 1].route== 'pages/index/login'){
					// 	   //解决同时多个请求，都跳登录页情况
					// 	   reject(TAG_NAME,'已在登录页，无需在次进入')
					// 	   return;
					//    }
					//    console.log(TAG_NAME,options.url,'重新登录~')
					//    uni.removeStorageSync('token')
					//    setTimeout(()=>{
					// 	   //已有提示
					// 	   uni.redirectTo({
					// 		 url:'/pages/index/login'
					// 	   })  
					//    },1200)
					// }
					if (data.code !== 1) { // 服务端返回的状态码不等于200，则reject()
						uni.showToast({
							title: data.msg || '请求出错,稍后重试',
							icon: 'none',
							duration: 2000,
							mask: true
						});
						reject(response)
					}else{
						resolve(data)
					}
				}else {
					response = this.requestComFail(response)
					reject(response)
				}
			}
			//type = 1 reject; type = 2 有缓存resolve,request是否向下进行
			const cancel = (msg = 'handle cancel',data={},type=1, config = options) => {
				const obj = {
					msg: msg,
					data,
					config: config
				}
				type == 1 ? reject(obj) : resolve(data); //外层直接取res.code;
				if(config.isNprogress) uni.hideLoading();  //store.commit('loading/HIDE')
				next = false 
			}

			handleRe = { ...this.requestBeforeFun(options, cancel)}
			const _config = { ...handleRe}
			// console.log('_config---', next, _config);
			if (!next) return;
			delete _config.custom
			if(_config.isNprogress) uni.showLoading({})
			let mergeUrl = Request.posUrl(_config.url) ? _config.url : (_config.baseUrl + _config.url)
			// 仅使用_config.data,未使用_config.params，且data内要添加token
			// if (JSON.stringify(_config.params) !== '{}') {
			// 	const paramsH = Request.addQueryString(_config.params);
			// 	mergeUrl += mergeUrl.indexOf('?') === -1 ? `?${paramsH}` : `&${paramsH}`
			// }
			_config.url = mergeUrl
			uni.request(_config)
		})
	}

	get(url, options = {}) {
		return this.request({
			url,
			method: 'GET',
			...options
		})
	}

	post(url, data, options = {}) {
		return this.request({
			url,
			data,
			method: 'POST',
			...options
		})
	}

	// upload(url, {
	// 	// #ifdef APP-PLUS
	// 	files,
	// 	// #endif
	// 	// #ifdef MP-ALIPAY
	// 	fileType,
	// 	// #endif
	// 	filePath,
	// 	name,
	// 	header,
	// 	formData,
	// 	custom
	// }) {
	// 	return new Promise((resolve, reject) => {
	// 		let next = true
	// 		let handleRe = {}
	// 		const globalHeader = { ...this.config.header
	// 		}
	// 		delete globalHeader['content-type']
	// 		const pubConfig = {
	// 			baseUrl: this.config.baseUrl,
	// 			url,
	// 			// #ifdef APP-PLUS
	// 			files,
	// 			// #endif
	// 			// #ifdef MP-ALIPAY
	// 			fileType,
	// 			// #endif
	// 			filePath,
	// 			method: 'UPLOAD',
	// 			name,
	// 			header: header || globalHeader,
	// 			formData,
	// 			custom: { ...this.config.custom,
	// 				...(custom || {})
	// 			},
	// 			complete: (response) => {
	// 				response.config = handleRe
	// 				if (response.statusCode === 200) { // 成功
	// 					response = this.requestComFun(response)
	// 					resolve(response)
	// 				} else {
	// 					response = this.requestComFail(response)
	// 					reject(response)
	// 				}
	// 			}
	// 		}
	// 		const cancel = (t = 'handle cancel', config = pubConfig) => {
	// 			const err = {
	// 				errMsg: t,
	// 				config: config
	// 			}
	// 			reject(err)
	// 			next = false
	// 		}

	// 		handleRe = { ...this.requestBeforeFun(pubConfig, cancel)
	// 		}
	// 		const _config = { ...handleRe
	// 		}
	// 		if (!next) return
	// 		delete _config.custom
	// 		_config.url = Request.posUrl(_config.url) ? _config.url : (_config.baseUrl + _config.url)
	// 		uni.uploadFile(_config)
	// 	})
	// }
}

/**
 * setConfig回调
 * @return {Object} - 返回操作后的config
 * @callback Request~setConfigCallback
 * @param {Object} config - 全局默认config
 */
/**
 * 请求拦截器回调
 * @return {Object} - 返回操作后的config
 * @callback Request~requestCallback
 * @param {Object} config - 全局config
 * @param {Function} [cancel] - 取消请求钩子，调用会取消本次请求
 */
/**
 * 响应拦截器回调
 * @return {Object} - 返回操作后的response
 * @callback Request~responseCallback
 * @param {Object} response - 请求结果 response
 */
/**
 * 响应错误拦截器回调
 * @return {Object} - 返回操作后的response
 * @callback Request~responseErrCallback
 * @param {Object} response - 请求结果 response
 */