// 接口返回值code说明
// 200=>正常；
// 400=>报错；
// 401=>需要登陆；
// 402=>错误并且弹出报错，报错内容为 error；
// 403=>错误并且弹出报错，报错内容为 error(小程序跳转到个人中心)；
// 404=>错误并且弹出报错，报错内容为 error(小程序跳转到首页)；

var Fly = require("./wx.js") //wx.js为您下载的源码文件
var fly = new Fly; //创建fly实例
var tokenFly = new Fly();
import $api from '@/api/index.js';
import $util from './index.js';
import siteInfo from '../siteinfo.js';
import $store from "@/store/index.js"

// 打印站点信息siteInfo
let allSiteInfo = Object.assign({}, {
	time: "2022年09月14日 10:43",
	remark: "(test)~ update:新增短信验证开启功能~",
}, siteInfo)
console.log(allSiteInfo);

import {
	networkError,
	serverError,
	msgError
} from './error.js';
//添加finally方法,用于指定不管 Promise 对象最后状态如何，都会执行的操作
Promise.prototype.finally = function(callback) {
	let P = this.constructor;
	return this.then(
		value => P.resolve(callback()).then(() => value),
		reason => P.resolve(callback()).then(() => {
			throw reason
		})
	);
};
const isW7 = true
const isH5 = false
const formatUrl = function(url) {
	let model_name = "longbing_massages_city";
	let baseUrl = isW7 ?
		`${siteInfo.siteroot}?i=${siteInfo.uniacid}&t=${siteInfo.multiid}&v=${siteInfo.version}&from=wxapp&c=entry&a=wxapp&do=api&core=core2&m=${model_name}&s=${url}` :
		`${siteInfo.siteroot}?i=${siteInfo.uniacid}&m=${model_name}&s=${url}`

	if (isH5) {
		baseUrl = `/api?i=${siteInfo.uniacid}&m=${model_name}&s=${url}`
	}
	return baseUrl;
}
//阿里云地址转为本地域名的 
const formatImageUrl = function(url) {
	return url.includes(siteInfo.siteroot) ? url :
		`${formatUrl("card/getImage")}&path=${encodeURIComponent(url)}`
}

//微信小程序登录
const wxLogin = async function() {
	let {
		query
	} = await uni.getLaunchOptionsSync();
	console.log('query', query)
	let url = formatUrl("index/login")
	try {
		uni.showLoading({
			title: "登录中..."
		})
		let [providerErr, providerData] = await uni.getProvider({
			service: 'oauth',
		});
		let [loginErr, loginData] = await uni.login({
			provider: providerData.provider[0]
		});

		let login_param = {
			code: loginData.code,
			pid: query.pid
		}

		console.log("login_param==>", login_param);

		let d = await tokenFly.post(url, login_param);
		let {
			code,
			data,
			error
		} = d.data


		if (code !== 200) {
			uni.hideLoading()
			serverError({
				code,
				msg: error
			});
			throw d;
		}
		//登录成功
		uni.hideLoading()
		$store.commit('updateUserItem', {
			key: 'userInfo',
			val: data.data
		})
		$store.commit('updateUserItem', {
			key: 'autograph',
			val: data.autograph
		})
		return data;
	} catch (e) {
		uni.hideLoading()
		let {
			code,
			error
		} = e.response.data
		if (code !== 200) {
			serverError({
				code,
				msg: error
			});
		}
		return await Promise.reject(e);
	}
}

//公众号登录
const gzhLogin = async function() {
	let pageUrl = window.location.href;
	let code = $util.getQueryString('code');
	let {
		gzh_appid: appid,
	} = siteInfo
	let redirect_uri = encodeURIComponent(pageUrl);
	let authUrl =
		`https://open.weixin.qq.com/connect/oauth2/authorize?appid=${appid}&redirect_uri=${redirect_uri}&response_type=code&scope=snsapi_userinfo&state=STATE&connect_redirect=1#wechat_redirect`;
	if (code) {
		let atv_arr = pageUrl.split('coupon_atv_id=')
		let coupon_atv_id = atv_arr.length > 1 ? atv_arr[1].split('&pid=')[0] : 0

		let pid_arr = pageUrl.split('pid=')
		let pid = pid_arr.length > 1 ? pid_arr[1] : 0
		let pad_code_arr = pid ? pid.split('?') : []
		if (pad_code_arr.length) {
			pid = pad_code_arr[0]
		}
		console.log("index/webLogin ==>", code, pad_code_arr, pid)
		let url = formatUrl("index/webLogin")
		try {
			let d = await tokenFly.post(url, {
				code,
				login_type: 'gzh',
				pid,
				coupon_atv_id
			});

			let {
				code: res_code,
				data,
				error
			} = d.data

			if (res_code !== 200) {
				uni.hideLoading()
				serverError({
					code: res_code,
					msg: error
				});
				throw d;
			}
			//登录成功
			uni.hideLoading()
			$store.commit('updateUserItem', {
				key: 'userInfo',
				val: data.data
			})
			$store.commit('updateUserItem', {
				key: 'autograph',
				val: data.autograph
			})
			return data;
		} catch (e) {
			uni.hideLoading()
			let {
				code,
				error
			} = e.response.data
			console.log("catch e code error=======", code, error)
			if (code == 40163) {
				window.location.search = ''
				setTimeout(() => {
					window.location.href = authUrl;
				}, 200)
			} else {
				serverError({
					code,
					msg: error
				});
				uni.hideLoading()
			}
			return await Promise.reject(e);

		}
	} else {
		window.location.href = authUrl;
		return await Promise.reject("跳转授权");
	}
}


// app登录
const appLogin = async function() {
	let url = formatUrl("index/appLogin")
	try {
		let userInfo = $store.state.user.appLogin
		let {
			openId = ''
		} = userInfo
		if (!openId) return
		let d = await tokenFly.post(url, {
			data: userInfo
		});
		let {
			code,
			data,
			error
		} = d.data
		if (code !== 200) {
			uni.hideLoading()
			serverError({
				code,
				msg: error
			});
			throw d;
		}
		//登录成功
		uni.hideLoading()
		$store.commit('updateUserItem', {
			key: 'userInfo',
			val: data.data
		})
		$store.commit('updateUserItem', {
			key: 'autograph',
			val: data.autograph
		})
		return data
	} catch (e) {
		return await Promise.reject(e);
	}
}

//设置超时
fly.config.timeout = 15000;
console.log("123456789")
//设置请求基地址

//给所有请求添加自定义header
fly.config.headers = tokenFly.config.headers = {
	"content-type": "application/json",
	 "Access-Control-Allow-Origin":"*",
	 "Access-Control-Allow-Headers":"Origin,X-Requested-With,Content-Type,Accept,Authorization,sourcetype,token",
	 "Access-Control-Allow-Methods":"GET, POST, OPTIONS, PUT, DELETE",
}

//添加请求拦截器
fly.interceptors.request.use(
	async (request) => {
		//添加验证token
		request.headers['autograph'] = $store.state.user.autograph || '';
		// #ifdef APP-PLUS
		request.headers['isapp'] = 1;
		// #endif
		// #ifdef H5
		request.headers['isapp'] = 2;
		// #endif
		return request;
	})

//添加响应拦截器，响应拦截器会在then/catch处理之前执行
fly.interceptors.response.use(
	async (response) => {
			//token过期验证
			// console.log("response====>", response.data.code, response)
			if (response.data.code != 401) return response;
			fly.lock()

			//#ifdef  MP-WEIXIN
			console.log("==> MP-WEIXIN 401")
			await wxLogin();
			//#endif

			//#ifdef H5
			console.log("==> H5 401")
			if (isH5) {
				$store.commit('updateUserItem', {
					key: 'autograph',
					val: 'e0de4470ea6a0ce31979ba9105078c69'
				})
			} else {
				await gzhLogin();
			}
			//#endif 

			//#ifdef  APP-PLUS 
			console.log("==> APP-PLUS 401")
			await appLogin()
			//#endif

			response.request.headers["autograph"] = $store.state.user.autograph || ''
			fly.unlock();
			return fly.request(response.request);
		},
		async (err) => {
			console.log(err, "=======fly.interceptors.response.use err",err);
			let {
				status = 0,
			} = err

			$util.hideAll()
			console.log(err)
			msgError({
				msg: err.response.data.error.error

			})
			networkError({
				code: status,
			})
			//网络错误
			return await Promise.reject(err);
		}
)

//统一处理请求,satus=200网络正常code=200服务器正常
const httpType = ["post", "get"]
const formatReq = function() {
	let req = {};
	httpType.forEach((type) => {
		req[type] = async function(url, param) {
			//构造请求地址
			url = formatUrl(url);
			let res = await fly[type](url, param)
			// console.log(res, "========= formatReq res")
			// #ifdef MP-BAIDU
			res.data = typeof(res.data) == "string" ? JSON.parse(res.data) : res.data;
			// #endif
			let {
				code,
				error,
				data
			} = res.data
			code = code * 1
			if (code === 200) return data;
			//code!=200抛出错误
			$util.hideAll();
			if (code == 400 && error) {
				console.log(code, error, "code != 200");
				msgError({
					msg: error
				})
			}
			return await Promise.reject(res.data);
		}
	})
	return req;
}
const req = formatReq();


// 定义上传,picture--代表图片 audio--音频 video--视频,默认picture
const uploadFile = async (url, {
	name = "file",
	filePath,
	header = {
		autograph: $store.state.user.autograph || '',
		// #ifdef APP-PLUS
		isapp: 1,
		// #endif
		// #ifdef H5
		isapp: 2,
		// #endif
	},
	formData = {
		type: 'picture'
	}
} = {}) => {
	url = formatUrl(url);
	console.log(formData, "======uploadFile formData")
	let [, res] = await uni.uploadFile({
		url,
		filePath,
		name,
		formData,
		header,
	})

	if (res.statusCode != 200) {
		$util.hideAll()
		networkError();
		return await Promise.reject(res);
	}
	let parseData = JSON.parse(res.data)
	//服务器错误
	let {
		code,
		msg,
		data
	} = parseData;
	if (code != 200) {
		$util.hideAll()
		serverError({
			code,
			msg
		});
		return await Promise.reject(res);
	}
	return data
}

export {
	fly,
	req,
	uploadFile,
	formatImageUrl,
	formatUrl,
}