You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
419 lines
8.9 KiB
419 lines
8.9 KiB
// 接口返回值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;
|
|
|
|
//设置请求基地址
|
|
|
|
//给所有请求添加自定义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");
|
|
let {
|
|
status = 0,
|
|
} = err
|
|
|
|
$util.hideAll()
|
|
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,
|
|
}
|
|
|