This commit is contained in:
parent
13e188e2e8
commit
46a0a22722
|
@ -0,0 +1,26 @@
|
|||
{
|
||||
// launch.json 配置了启动调试时相关设置,configurations下节点名称可为 app-plus/h5/mp-weixin/mp-baidu/mp-alipay/mp-qq/mp-toutiao/mp-360/
|
||||
// launchtype项可配置值为local或remote, local代表前端连本地云函数,remote代表前端连云端云函数
|
||||
"version" : "0.0",
|
||||
"configurations" : [
|
||||
{
|
||||
"app-plus" : {
|
||||
"launchtype" : "local"
|
||||
},
|
||||
"default" : {
|
||||
"launchtype" : "local"
|
||||
},
|
||||
"type" : "uniCloud"
|
||||
},
|
||||
{
|
||||
"openVueDevtools" : false,
|
||||
"playground" : "custom",
|
||||
"type" : "uni-app:app-android"
|
||||
},
|
||||
{
|
||||
"openVueDevtools" : false,
|
||||
"playground" : "standard",
|
||||
"type" : "uni-app:app-ios"
|
||||
}
|
||||
]
|
||||
}
|
|
@ -250,14 +250,14 @@
|
|||
},
|
||||
"TT-AMapNavi" : {
|
||||
"__plugin_info__" : {
|
||||
"name" : "tongtong-高德导航原生插件 - [试用版,仅用于自定义调试基座]",
|
||||
"name" : "tongtong-高德导航原生插件",
|
||||
"description" : "高德导航原生插件",
|
||||
"platforms" : "Android,iOS",
|
||||
"url" : "https://ext.dcloud.net.cn/plugin?id=8072",
|
||||
"android_package_name" : "",
|
||||
"android_package_name" : "uni.UNI5A081C6",
|
||||
"ios_bundle_id" : "",
|
||||
"isCloud" : true,
|
||||
"bought" : 0,
|
||||
"bought" : 1,
|
||||
"pid" : "8072",
|
||||
"parameters" : {}
|
||||
}
|
||||
|
|
|
@ -0,0 +1,127 @@
|
|||
import {
|
||||
HTTP_REQUEST_URL_THREE,
|
||||
HEADER,
|
||||
TOKENNAME,
|
||||
} from '@/config/app';
|
||||
import {
|
||||
Toast
|
||||
} from '../libs/uniApi';
|
||||
// import { checkLogin } from '../libs/login';
|
||||
import store from '../store';
|
||||
|
||||
function toLogin() {
|
||||
uni.showToast({
|
||||
title: '请先登录',
|
||||
icon: 'none',
|
||||
duration: 1000
|
||||
});
|
||||
}
|
||||
|
||||
function baseRequestTwo(url, method, data, {
|
||||
noAuth = false,
|
||||
noVerify = false,
|
||||
onReLogin = false
|
||||
}) {
|
||||
let Url = HTTP_REQUEST_URL_THREE,
|
||||
header = HEADER;
|
||||
if (!noAuth) {
|
||||
// 已经未登录了,禁止请求
|
||||
if (!store.state.config.request) return Promise.reject({
|
||||
msg: '未登录'
|
||||
});
|
||||
//登录过期自动登录
|
||||
if (!store.state.app.token) {
|
||||
toLogin();
|
||||
store.commit("SET_REQUEST", false);
|
||||
return Promise.reject({
|
||||
msg: '未登录'
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
// if (store.state.app.token) header[TOKENNAME] = 'Bearer ' + store.state.app.token;
|
||||
if (store.state.app.token) header[TOKENNAME] = store.state.app.token;
|
||||
|
||||
// header[TOKENNAME] = 'Bearer sdjflidshjgfkbdasgjmasbgvhauuiavhkesvndkaesbvkjsdbv';
|
||||
return new Promise((reslove, reject) => {
|
||||
// uni.showLoading({
|
||||
// title: '加载中'
|
||||
// })
|
||||
uni.request({
|
||||
// url: Url + '/api/v1' + url,
|
||||
url: Url + url,
|
||||
method: method || 'GET',
|
||||
header: {
|
||||
...header
|
||||
},
|
||||
data: method != 'GET' ? data || {} : {},
|
||||
params: method == 'GET' ? data : {},
|
||||
success: (res) => {
|
||||
if (noVerify)
|
||||
reslove(res.data);
|
||||
else if (res.data.code == -1) {
|
||||
if(onReLogin) {
|
||||
store.commit('LOGOUT');
|
||||
return reject();
|
||||
}
|
||||
// 如果登录超时,自动重新登录并且继续发送请求
|
||||
store.dispatch("RE_LOGIN", {
|
||||
url: url,
|
||||
method: method,
|
||||
data: data,
|
||||
opt: {
|
||||
noAuth,
|
||||
noVerify
|
||||
}
|
||||
}).then((e)=>{
|
||||
reslove(e);
|
||||
}).catch((err)=>{
|
||||
reject(res.data);
|
||||
})
|
||||
// store.commit("SET_REQUEST", false);
|
||||
} else if (res.data.code == 0) {
|
||||
if (res.data.msg != '无登录信息') {
|
||||
uni.showToast({
|
||||
title: res.data.msg || '请检查网络',
|
||||
icon: 'none',
|
||||
})
|
||||
}
|
||||
reject(res.data);
|
||||
} else if (res.data.code == 1) {
|
||||
store.commit("SET_REQUEST");
|
||||
reslove(res.data);
|
||||
} else if (res.data.code == 200) {
|
||||
store.commit("SET_REQUEST");
|
||||
reslove(res.data.data);
|
||||
} else if ([410000, 410001, 410002, 40000].indexOf(res.data.code) !== -1) {
|
||||
toLogin();
|
||||
reject(res.data);
|
||||
} else if (res.data.code == 501) {
|
||||
reject(res.data);
|
||||
} else {
|
||||
uni.showToast({
|
||||
title: res.data.msg || '请检查网络',
|
||||
icon: 'none'
|
||||
})
|
||||
reject(res.data.msg || '请检查网络');
|
||||
}
|
||||
},
|
||||
fail: (message) => {
|
||||
// uni.hideLoading()
|
||||
uni.showToast({
|
||||
title: '网络错误',
|
||||
icon: 'none'
|
||||
})
|
||||
reject('请求失败');
|
||||
}
|
||||
})
|
||||
});
|
||||
}
|
||||
|
||||
const oahttp = {};
|
||||
|
||||
['options', 'get', 'post', 'put', 'head', 'delete', 'trace', 'connect'].forEach((method) => {
|
||||
oahttp[method] = (api, data, opt) => baseRequestTwo(api, method, data, opt || {})
|
||||
});
|
||||
|
||||
export default oahttp;
|
|
@ -0,0 +1,164 @@
|
|||
/*! https://mths.be/base64 v1.0.0 by @mathias | MIT license */
|
||||
;(function(root) {
|
||||
|
||||
// Detect free variables `exports`.
|
||||
var freeExports = typeof exports == 'object' && exports;
|
||||
|
||||
// Detect free variable `module`.
|
||||
var freeModule = typeof module == 'object' && module &&
|
||||
module.exports == freeExports && module;
|
||||
|
||||
// Detect free variable `global`, from Node.js or Browserified code, and use
|
||||
// it as `root`.
|
||||
var freeGlobal = typeof global == 'object' && global;
|
||||
if (freeGlobal.global === freeGlobal || freeGlobal.window === freeGlobal) {
|
||||
root = freeGlobal;
|
||||
}
|
||||
|
||||
/*--------------------------------------------------------------------------*/
|
||||
|
||||
var InvalidCharacterError = function(message) {
|
||||
this.message = message;
|
||||
};
|
||||
InvalidCharacterError.prototype = new Error;
|
||||
InvalidCharacterError.prototype.name = 'InvalidCharacterError';
|
||||
|
||||
var error = function(message) {
|
||||
// Note: the error messages used throughout this file match those used by
|
||||
// the native `atob`/`btoa` implementation in Chromium.
|
||||
throw new InvalidCharacterError(message);
|
||||
};
|
||||
|
||||
var TABLE = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/';
|
||||
// http://whatwg.org/html/common-microsyntaxes.html#space-character
|
||||
var REGEX_SPACE_CHARACTERS = /[\t\n\f\r ]/g;
|
||||
|
||||
// `decode` is designed to be fully compatible with `atob` as described in the
|
||||
// HTML Standard. http://whatwg.org/html/webappapis.html#dom-windowbase64-atob
|
||||
// The optimized base64-decoding algorithm used is based on @atk’s excellent
|
||||
// implementation. https://gist.github.com/atk/1020396
|
||||
var decode = function(input) {
|
||||
input = String(input)
|
||||
.replace(REGEX_SPACE_CHARACTERS, '');
|
||||
var length = input.length;
|
||||
if (length % 4 == 0) {
|
||||
input = input.replace(/==?$/, '');
|
||||
length = input.length;
|
||||
}
|
||||
if (
|
||||
length % 4 == 1 ||
|
||||
// http://whatwg.org/C#alphanumeric-ascii-characters
|
||||
/[^+a-zA-Z0-9/]/.test(input)
|
||||
) {
|
||||
error(
|
||||
'Invalid character: the string to be decoded is not correctly encoded.'
|
||||
);
|
||||
}
|
||||
var bitCounter = 0;
|
||||
var bitStorage;
|
||||
var buffer;
|
||||
var output = '';
|
||||
var position = -1;
|
||||
while (++position < length) {
|
||||
buffer = TABLE.indexOf(input.charAt(position));
|
||||
bitStorage = bitCounter % 4 ? bitStorage * 64 + buffer : buffer;
|
||||
// Unless this is the first of a group of 4 characters…
|
||||
if (bitCounter++ % 4) {
|
||||
// …convert the first 8 bits to a single ASCII character.
|
||||
output += String.fromCharCode(
|
||||
0xFF & bitStorage >> (-2 * bitCounter & 6)
|
||||
);
|
||||
}
|
||||
}
|
||||
return output;
|
||||
};
|
||||
|
||||
// `encode` is designed to be fully compatible with `btoa` as described in the
|
||||
// HTML Standard: http://whatwg.org/html/webappapis.html#dom-windowbase64-btoa
|
||||
var encode = function(input) {
|
||||
input = String(input);
|
||||
if (/[^\0-\xFF]/.test(input)) {
|
||||
// Note: no need to special-case astral symbols here, as surrogates are
|
||||
// matched, and the input is supposed to only contain ASCII anyway.
|
||||
error(
|
||||
'The string to be encoded contains characters outside of the ' +
|
||||
'Latin1 range.'
|
||||
);
|
||||
}
|
||||
var padding = input.length % 3;
|
||||
var output = '';
|
||||
var position = -1;
|
||||
var a;
|
||||
var b;
|
||||
var c;
|
||||
var buffer;
|
||||
// Make sure any padding is handled outside of the loop.
|
||||
var length = input.length - padding;
|
||||
|
||||
while (++position < length) {
|
||||
// Read three bytes, i.e. 24 bits.
|
||||
a = input.charCodeAt(position) << 16;
|
||||
b = input.charCodeAt(++position) << 8;
|
||||
c = input.charCodeAt(++position);
|
||||
buffer = a + b + c;
|
||||
// Turn the 24 bits into four chunks of 6 bits each, and append the
|
||||
// matching character for each of them to the output.
|
||||
output += (
|
||||
TABLE.charAt(buffer >> 18 & 0x3F) +
|
||||
TABLE.charAt(buffer >> 12 & 0x3F) +
|
||||
TABLE.charAt(buffer >> 6 & 0x3F) +
|
||||
TABLE.charAt(buffer & 0x3F)
|
||||
);
|
||||
}
|
||||
|
||||
if (padding == 2) {
|
||||
a = input.charCodeAt(position) << 8;
|
||||
b = input.charCodeAt(++position);
|
||||
buffer = a + b;
|
||||
output += (
|
||||
TABLE.charAt(buffer >> 10) +
|
||||
TABLE.charAt((buffer >> 4) & 0x3F) +
|
||||
TABLE.charAt((buffer << 2) & 0x3F) +
|
||||
'='
|
||||
);
|
||||
} else if (padding == 1) {
|
||||
buffer = input.charCodeAt(position);
|
||||
output += (
|
||||
TABLE.charAt(buffer >> 2) +
|
||||
TABLE.charAt((buffer << 4) & 0x3F) +
|
||||
'=='
|
||||
);
|
||||
}
|
||||
|
||||
return output;
|
||||
};
|
||||
|
||||
var base64 = {
|
||||
'encode': encode,
|
||||
'decode': decode,
|
||||
'version': '1.0.0'
|
||||
};
|
||||
|
||||
// Some AMD build optimizers, like r.js, check for specific condition patterns
|
||||
// like the following:
|
||||
if (
|
||||
typeof define == 'function' &&
|
||||
typeof define.amd == 'object' &&
|
||||
define.amd
|
||||
) {
|
||||
define(function() {
|
||||
return base64;
|
||||
});
|
||||
} else if (freeExports && !freeExports.nodeType) {
|
||||
if (freeModule) { // in Node.js or RingoJS v0.8.0+
|
||||
freeModule.exports = base64;
|
||||
} else { // in Narwhal or RingoJS v0.7.0-
|
||||
for (var key in base64) {
|
||||
base64.hasOwnProperty(key) && (freeExports[key] = base64[key]);
|
||||
}
|
||||
}
|
||||
} else { // in Rhino or a web browser
|
||||
root.base64 = base64;
|
||||
}
|
||||
|
||||
}(this));
|
|
@ -0,0 +1,140 @@
|
|||
import { EXPIRE } from '@/config/app';
|
||||
|
||||
class Cache {
|
||||
|
||||
constructor(handler) {
|
||||
this.cacheSetHandler = uni.setStorageSync;
|
||||
this.cacheGetHandler = uni.getStorageSync;
|
||||
this.cacheClearHandler = uni.removeStorageSync;
|
||||
this.cacheExpire = '_expire_2019_12_17_18_44';
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前时间戳
|
||||
*/
|
||||
time() {
|
||||
return Math.round(new Date() / 1000);
|
||||
}
|
||||
|
||||
/**
|
||||
* 设置过期时间缓存
|
||||
* @param {Object} key
|
||||
* @param {Object} expire
|
||||
*/
|
||||
setExpireCahe(key, expire) {
|
||||
expire = expire !== undefined ? expire : EXPIRE;
|
||||
if (expire) {
|
||||
this.cacheSetHandler(key + this.cacheExpire, this.time() + expire)
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 缓存是否过期,过期自动删除
|
||||
* @param {Object} key
|
||||
* @param {Object} $bool true = 删除,false = 不删除
|
||||
*/
|
||||
getExpireCahe(key, $bool) {
|
||||
try {
|
||||
let time = this.cacheGetHandler(key + this.cacheExpire);
|
||||
if (time) {
|
||||
let newTime = parseInt(time);
|
||||
if (time && time < this.time() && !Number.isNaN(newTime)) {
|
||||
if ($bool === undefined || $bool === true) {
|
||||
this.cacheClearHandler(key);
|
||||
this.cacheClearHandler(key + this.cacheExpire);
|
||||
}
|
||||
return false;
|
||||
} else
|
||||
return true;
|
||||
} else {
|
||||
return !!this.cacheGetHandler(key);
|
||||
}
|
||||
} catch (e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 设置缓存
|
||||
* @param {Object} key
|
||||
* @param {Object} data
|
||||
*/
|
||||
set(key, data, expire) {
|
||||
if (typeof data === 'object')
|
||||
data = JSON.stringify(data);
|
||||
try {
|
||||
this.setExpireCahe(key, expire);
|
||||
return this.cacheSetHandler(key, data);
|
||||
} catch (e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 检测缓存是否存在
|
||||
* @param {Object} key
|
||||
*/
|
||||
has(key) {
|
||||
return this.getExpireCahe(key);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取缓存
|
||||
* @param {Object} key
|
||||
* @param {Object} $default
|
||||
* @param {Object} expire
|
||||
*/
|
||||
get(key, $default, expire) {
|
||||
try {
|
||||
let isBe = this.getExpireCahe(key);
|
||||
let data = this.cacheGetHandler(key);
|
||||
if (data && isBe) {
|
||||
if (typeof $default === 'boolean')
|
||||
return JSON.parse(data);
|
||||
else
|
||||
return data;
|
||||
} else {
|
||||
if (typeof $default === 'function') {
|
||||
let value = $default();
|
||||
this.set(key, value, expire);
|
||||
return value;
|
||||
} else {
|
||||
this.set(key, $default, expire);
|
||||
return $default;
|
||||
}
|
||||
}
|
||||
} catch (e) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 删除缓存
|
||||
* @param {Object} key
|
||||
*/
|
||||
clear(key) {
|
||||
try {
|
||||
let cahceValue = this.cacheGetHandler(key + this.cacheExpire);
|
||||
if (cahceValue)
|
||||
this.cacheClearHandler(key + this.cacheExpire);
|
||||
return this.cacheClearHandler(key);
|
||||
} catch (e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 清除过期缓存
|
||||
*/
|
||||
clearOverdue() {
|
||||
// let cacheList = uni.getStorageInfoSync(),that = this;
|
||||
// if (typeof cacheList.keys === 'object'){
|
||||
// cacheList.keys.forEach(item=>{
|
||||
// that.getExpireCahe(item);
|
||||
// })
|
||||
// }
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
export default new Cache;
|
|
@ -0,0 +1,66 @@
|
|||
import Base64 from "@/utils/base64.js"
|
||||
import cryptoJS from "@/node_modules/crypto-js"
|
||||
|
||||
const key_code = 'gxzhptxiaochengxu_1';
|
||||
|
||||
// 加密
|
||||
const encode = (key, data='')=>{
|
||||
try{
|
||||
let str;
|
||||
typeof data == 'object'? str = JSON.stringify(data) : str = data;
|
||||
str = cryptoJS.AES.encrypt(str, key_code).toString();
|
||||
uni.setStorageSync(key, str)
|
||||
return true;
|
||||
}catch(e){
|
||||
console.log(e);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
// 解密
|
||||
const decode = (key)=>{
|
||||
try{
|
||||
let str = uni.getStorageSync(key);
|
||||
str = cryptoJS.AES.decrypt(str, key_code).toString(cryptoJS.enc.Utf8);
|
||||
isJSON(str) ? str = JSON.parse(str) : null;
|
||||
return str;
|
||||
}catch(e){
|
||||
console.log(e);
|
||||
return undefined;
|
||||
}
|
||||
}
|
||||
|
||||
const isJSON = (str)=>{
|
||||
try{
|
||||
JSON.parse(str)
|
||||
return true;
|
||||
}catch(e){
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
const LOGIN = ()=>{
|
||||
return new Promise((reslove, reject) => {
|
||||
uni.request({
|
||||
url: Url + '/api' + url,
|
||||
method: 'POST',
|
||||
data: data,
|
||||
success: (res) => {
|
||||
|
||||
},
|
||||
fail: (message) => {
|
||||
uni.showToast({
|
||||
title: '网络错误',
|
||||
icon: 'none'
|
||||
})
|
||||
reject('请求失败');
|
||||
}
|
||||
})
|
||||
});
|
||||
}
|
||||
|
||||
export default {
|
||||
encode,
|
||||
decode
|
||||
}
|
|
@ -0,0 +1,89 @@
|
|||
import {
|
||||
HTTP_REQUEST_URL,
|
||||
HTTP_REQUEST_URL_TWO,
|
||||
HTTP_REQUEST_URL_THREE,
|
||||
HEADER,
|
||||
TOKENNAME,
|
||||
} from '@/config/app';
|
||||
import {
|
||||
checkLogin
|
||||
} from '../libs/login';
|
||||
import { Toast } from '../libs/uniApi';
|
||||
import store from '../store';
|
||||
|
||||
function toLogin() {
|
||||
store.commit("LOGOUT");
|
||||
uni.showToast({
|
||||
title: '请登录',
|
||||
icon: 'none',
|
||||
duration: 1000
|
||||
});
|
||||
}
|
||||
|
||||
function baseRequestTwo(url, method, data, {
|
||||
noAuth = false,
|
||||
noVerify = false
|
||||
}) {
|
||||
let Url = HTTP_REQUEST_URL_TWO,
|
||||
header = HEADER;
|
||||
|
||||
if (!noAuth) {
|
||||
//登录过期自动登录
|
||||
if (!store.state.app.token && !checkLogin()) {
|
||||
toLogin();
|
||||
return Promise.reject({
|
||||
msg: '未登录'
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
if (store.state.app.token) header[TOKENNAME] = 'Bearer ' + store.state.app.token;
|
||||
|
||||
return new Promise((reslove, reject) => {
|
||||
uni.request({
|
||||
url: Url + '/api' + url,
|
||||
method: method || 'GET',
|
||||
header: header,
|
||||
data: data || {},
|
||||
success: (res) => {
|
||||
// #ifdef APP-PLUS
|
||||
console.log('app', Url + '/api/' + url, res.data);
|
||||
// #endif
|
||||
if (noVerify)
|
||||
// reslove(res.data, res);
|
||||
reslove(res.data);
|
||||
else if (res.data.status == 200)
|
||||
reslove(res.data, res);
|
||||
else if (res.data.code == 1) {
|
||||
reslove(res.data.data);
|
||||
} else if (res.data.code == 0) {
|
||||
reslove(res.data, res);
|
||||
} else if ([410000, 410001, 410002, 40000].indexOf(res.data.status) !== -1) {
|
||||
toLogin();
|
||||
reject(res.data);
|
||||
} else if (res.data.status == 501) {
|
||||
uni.reLaunch({
|
||||
url: '/pages/error/index'
|
||||
})
|
||||
reject(res.data);
|
||||
} else if (res.statusCode === 500)
|
||||
Toast("请检查网络")
|
||||
else
|
||||
reject(res.data.message || '请检查网络');
|
||||
|
||||
},
|
||||
fail: (message) => {
|
||||
console.log('message', message);
|
||||
reject('请求失败');
|
||||
}
|
||||
})
|
||||
});
|
||||
}
|
||||
|
||||
const http = {};
|
||||
|
||||
['options', 'get', 'post', 'put', 'head', 'delete', 'trace', 'connect'].forEach((method) => {
|
||||
http[method] = (api, data, opt) => baseRequestTwo(api, method, data, opt || {})
|
||||
});
|
||||
|
||||
export default http;
|
|
@ -0,0 +1,276 @@
|
|||
// 引用方式
|
||||
var jpushModule = uni.requireNativePlugin("JG-JPush");
|
||||
// console.log('【sk】【引用方式】【jpushModule】【requireNativePlugin】')
|
||||
|
||||
// 开启 debug 模式,默认是关闭
|
||||
function openDebug() {
|
||||
jpushModule.setLoggerEnable(true);
|
||||
}
|
||||
|
||||
// 关闭 debug 模式,默认是关闭
|
||||
function closeDebug() {
|
||||
jpushModule.setLoggerEnable(false);
|
||||
}
|
||||
|
||||
// 获取 RegistrationID,只有当应用程序成功注册到 JPush 的服务器时才返回对应的值,否则返回空字符串
|
||||
function getRegistrationID(skBack) {
|
||||
jpushModule.getRegistrationID(result => {
|
||||
// code number 状态码 0 - 成功, 1011 - iOS模拟器调用会报此错误
|
||||
// registerID string 返回的 registrationID
|
||||
console.log('【sk】获取 RegistrationID=>', result)
|
||||
skBack(result.registerID)
|
||||
})
|
||||
}
|
||||
|
||||
// 跳转至系统设置页面,0 - 成功 1 - 失败
|
||||
function openSettingsForNotification() {
|
||||
jpushModule.openSettingsForNotification((result) => {
|
||||
// code number 0 - 成功 1 - 失败
|
||||
console.log('【sk】跳转至系统设置页面result=>', result.code)
|
||||
})
|
||||
}
|
||||
|
||||
// 初始化SDK iOS 说明:如果在mainfest.json里 将JPUSH_DEFAULTINITJPUSH_IOS值配置为"true",插件内部将默认初始化JPush,用户则不需要调用该初始化方法。
|
||||
function initJPushService() {
|
||||
console.log(jpushModule)
|
||||
jpushModule.initJPushService()
|
||||
}
|
||||
|
||||
// 连接状态回调,true - 已连接, false - 未连接
|
||||
function addConnectEventListener(skBack) {
|
||||
jpushModule.addConnectEventListener(result => {
|
||||
// connectEnable boolean true - 已连接, false - 未连接
|
||||
console.log('【sk】连接状态回调=>', result.connectEnable)
|
||||
skBack(result.connectEnable);
|
||||
})
|
||||
}
|
||||
|
||||
// 通知事件回调
|
||||
function addNotificationListener(skBack) {
|
||||
jpushModule.addNotificationListener(result => {
|
||||
// messageID string 唯一标识通知消息的 ID
|
||||
// title string 对应 Portal 推送通知界面上的“通知标题”字段
|
||||
// content string 对应 Portal 推送通知界面上的“通知内容”字段
|
||||
// badge string 对应 Portal 推送通知界面上的可选设置里面的“badge”字段 (ios only)
|
||||
// ring string 推送通知界面上的可选设置里面的“sound”字段 (ios only)
|
||||
// extras dictionary 对应 Portal 推送消息界面上的“可选设置”里的附加字段
|
||||
// iOS dictionary 对应原生返回的通知内容,如需要更多字段请查看该字段内容
|
||||
// android dictionary 对应原生返回的通知内容,如需要更多字段请查看该字段内容
|
||||
// notificationEventType string 分为notificationArrived和notificationOpened两种
|
||||
console.log('【sk】通知事件回调result=>', result)
|
||||
skBack(result);
|
||||
})
|
||||
}
|
||||
|
||||
// 自定义消息事件回调
|
||||
function addCustomMessageListener(skBack) {
|
||||
jpushModule.addCustomMessageListener(result => {
|
||||
// messageID string 唯一标识通知消息的 ID
|
||||
// content string 对应 Portal 推送通知界面上的“通知内容”字段
|
||||
// extras dictionary 对应 Portal 推送消息界面上的“可选设置”里的附加字段
|
||||
console.log('【sk】自定义消息事件回调result=>', result)
|
||||
skBack(result);
|
||||
})
|
||||
}
|
||||
|
||||
// 应用内消息回调
|
||||
function addInMessageListener(skBack) {
|
||||
jpushModule.addInMessageListener(result => {
|
||||
// eventType string show - 应用内消息展示 disappear - 应用内消息已消失 click - 应用内消息点击
|
||||
// messageType string 消息类型, eventType 不为 disappear时返回, inMessageNoti - 通知类型的inMessage
|
||||
// content dictionary 应用内消息内容, eventType 不为 disappear 时返回
|
||||
console.log('【sk】应用内消息回调result=>', result)
|
||||
skBack(result);
|
||||
})
|
||||
}
|
||||
|
||||
// 本地通知事件回调
|
||||
function addLocalNotificationListener(skBack) {
|
||||
jpushModule.addLocalNotificationListener(result => {
|
||||
// messageID string 唯一标识通知消息的ID
|
||||
// title string 对应“通知标题”字段
|
||||
// content string 对应“通知内容”字段
|
||||
// extras dictionary 对应“附加内容”字段
|
||||
console.log('【sk】本地通知事件回调result=>', result)
|
||||
skBack(result);
|
||||
})
|
||||
}
|
||||
|
||||
// 添加一个本地通知
|
||||
function addLocalNotification(e) {
|
||||
jpushModule.addLocalNotification({
|
||||
messageID: e.messageID ? e.messageID : '', // 唯一标识通知消息的ID
|
||||
title: e.title ? e.title : '', // 对应“通知标题”字段
|
||||
content: e.content ? e.content : '', // 对应“通知内容”字段
|
||||
extras: e.extras ? e.extras : {
|
||||
name: '',
|
||||
age: ''
|
||||
} // 对应“附加内容”字段
|
||||
})
|
||||
}
|
||||
|
||||
// 移除指定的本地通知
|
||||
function removeLocalNotification(e) {
|
||||
jpushModule.removeLocalNotification({
|
||||
messageID: e.messageID ? e.messageID : '' // 唯一标识通知消息的ID
|
||||
})
|
||||
}
|
||||
|
||||
// 移除所有的本地通知
|
||||
function clearLocalNotifications() {
|
||||
jpushModule.clearLocalNotifications()
|
||||
}
|
||||
|
||||
// 标签别名事件回调
|
||||
function addTagAliasListener(skBack) {
|
||||
jpushModule.addTagAliasListener(result => {
|
||||
// code number 请求状态码 0 - 成功
|
||||
// sequence number 请求时传入的序列号,会在回调时原样返回
|
||||
// tags StringArray 执行tag数组操作时返回
|
||||
// tag string 执行查询指定tag(queryTag)操作时会返回
|
||||
// tagEnable boolean 执行查询指定tag(queryTag)操作时会返回是否可用
|
||||
// alias string 对alias进行操作时返回
|
||||
console.log('【sk】标签别名事件回调result=>', result)
|
||||
skBack(result);
|
||||
})
|
||||
}
|
||||
|
||||
// 新增标签
|
||||
function addTags(e) {
|
||||
jpushModule.addTags({
|
||||
'tags': e.tags ? e.tags : [], // StringArray string类型的数组
|
||||
'sequence': e.sequence ? e.sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 覆盖标签
|
||||
function updateTags(e) {
|
||||
jpushModule.updateTags({
|
||||
'tags': e.tags ? e.tags : [], // StringArray string类型的数组
|
||||
'sequence': e.sequence ? e.sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 删除指定标签
|
||||
function deleteTags(e) {
|
||||
jpushModule.deleteTags({
|
||||
'tags': e.tags ? e.tags : [], // StringArray string类型的数组
|
||||
'sequence': e.sequence ? e.sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 清除所有标签
|
||||
function cleanTags(e) {
|
||||
jpushModule.cleanTags({
|
||||
'sequence': e.sequence ? e.sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 查询指定 tag 与当前用户绑定的状态
|
||||
function queryTag(e) {
|
||||
jpushModule.queryTag({
|
||||
'tag': e.tag ? e.tag : '', // string 需要查询的标签
|
||||
'sequence': e.sequence ? sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 查询所有标签
|
||||
function getAllTags(e) {
|
||||
jpushModule.getAllTags({
|
||||
'sequence': e.sequence ? e.sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 设置别名
|
||||
function setAlias(e) {
|
||||
console.log('设置别名', e)
|
||||
jpushModule.setAlias({
|
||||
'alias': e.alias ? e.alias : '', // string 有效的别名组成:字母(区分大小写)、数字、下划线、汉字、特殊字符@!#$&*+=.|
|
||||
'sequence': e.sequence ? e.sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 删除别名
|
||||
function deleteAlias(e) {
|
||||
jpushModule.deleteAlias({
|
||||
'sequence': e.sequence ? e.sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 查询别名
|
||||
function queryAlias(e) {
|
||||
jpushModule.queryAlias({
|
||||
'sequence': e.sequence ? e.sequence : 1 // number 请求时传入的序列号,会在回调时原样返回
|
||||
})
|
||||
}
|
||||
|
||||
// 开启 CrashLog 上报
|
||||
function initCrashHandler() {
|
||||
jpushModule.initCrashHandler()
|
||||
}
|
||||
|
||||
// 设置地理围栏的最大个数
|
||||
function setMaxGeofenceNumber(e) {
|
||||
jpushModule.setMaxGeofenceNumber(e.geofenceNumber ? e.geofenceNumber : 10) // 默认值为 10 ,iOS系统默认地理围栏最大个数为20
|
||||
}
|
||||
|
||||
// 删除指定id的地理围栏
|
||||
function deleteGeofence(e) {
|
||||
jpushModule.deleteGeofence(e.geofence ? e.geofence : '') // 删除指定id的地理围栏
|
||||
}
|
||||
|
||||
// 设置 Badge
|
||||
function setBadge(e) {
|
||||
jpushModule.setBadge(e.badge ? e.badge : 0) // number
|
||||
}
|
||||
|
||||
// 设置手机号码
|
||||
function setMobileNumber(e) {
|
||||
jpushModule.setMobileNumber({
|
||||
sequence: e.sequence ? e.sequence : 1, // number 请求时传入的序列号,会在回调时原样返回
|
||||
mobileNumber: e.mobileNumber ? e.mobileNumber : '' // string 手机号码 会与用户信息一一对应。可为空,为空则清除号码。
|
||||
})
|
||||
}
|
||||
|
||||
// 设置手机号码回调
|
||||
function addMobileNumberListener(skBack) {
|
||||
jpushModule.addMobileNumberListener(result => {
|
||||
// code number 状态码 0 - 成功
|
||||
// sequence number 请求时传入的序列号,会在回调时原样返回
|
||||
console.log('【sk】设置手机号码回调result=>', result)
|
||||
skBack(result);
|
||||
})
|
||||
}
|
||||
|
||||
|
||||
module.exports = {
|
||||
openDebug: openDebug,
|
||||
closeDebug: closeDebug,
|
||||
getRegistrationID: getRegistrationID,
|
||||
openSettingsForNotification: openSettingsForNotification,
|
||||
initJPushService: initJPushService,
|
||||
addConnectEventListener: addConnectEventListener,
|
||||
addNotificationListener: addNotificationListener,
|
||||
addCustomMessageListener: addCustomMessageListener,
|
||||
addInMessageListener: addInMessageListener,
|
||||
addLocalNotificationListener: addLocalNotificationListener,
|
||||
addLocalNotification: addLocalNotification,
|
||||
removeLocalNotification: removeLocalNotification,
|
||||
clearLocalNotifications: clearLocalNotifications,
|
||||
addTagAliasListener: addTagAliasListener,
|
||||
addTags: addTags,
|
||||
updateTags: updateTags,
|
||||
deleteTags: deleteTags,
|
||||
cleanTags: cleanTags,
|
||||
queryTag: queryTag,
|
||||
getAllTags: getAllTags,
|
||||
setAlias: setAlias,
|
||||
deleteAlias: deleteAlias,
|
||||
queryAlias: queryAlias,
|
||||
initCrashHandler: initCrashHandler,
|
||||
setMaxGeofenceNumber: setMaxGeofenceNumber,
|
||||
deleteGeofence: deleteGeofence,
|
||||
setBadge: setBadge,
|
||||
setMobileNumber: setMobileNumber,
|
||||
addMobileNumberListener: addMobileNumberListener
|
||||
}
|
|
@ -0,0 +1,118 @@
|
|||
import {
|
||||
HTTP_REQUEST_URL_TWO,
|
||||
HEADER,
|
||||
TOKENNAME,
|
||||
} from '@/config/app';
|
||||
import {
|
||||
Toast
|
||||
} from '../libs/uniApi';
|
||||
// import { checkLogin } from '../libs/login';
|
||||
import store from '../store';
|
||||
|
||||
function toLogin() {
|
||||
uni.showToast({
|
||||
title: '请先登录',
|
||||
icon: 'none',
|
||||
duration: 1000
|
||||
});
|
||||
}
|
||||
|
||||
function baseRequestTwo(url, method, data, {
|
||||
noAuth = false,
|
||||
noVerify = false
|
||||
}) {
|
||||
let Url = HTTP_REQUEST_URL_TWO,
|
||||
header = HEADER;
|
||||
if (!noAuth) {
|
||||
// 已经未登录了,禁止请求
|
||||
if (!store.state.config.request) return Promise.reject({
|
||||
msg: '未登录'
|
||||
});
|
||||
//登录过期自动登录
|
||||
if (!store.state.app.token) {
|
||||
toLogin();
|
||||
store.commit("SET_REQUEST", false);
|
||||
return Promise.reject({
|
||||
msg: '未登录'
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
// if (store.state.app.token) header[TOKENNAME] = 'Bearer ' + store.state.app.token;
|
||||
if (store.state.app.token) header[TOKENNAME] = store.state.app.token;
|
||||
|
||||
// header[TOKENNAME] = 'Bearer sdjflidshjgfkbdasgjmasbgvhauuiavhkesvndkaesbvkjsdbv';
|
||||
return new Promise((reslove, reject) => {
|
||||
// uni.showLoading({
|
||||
// title: '加载中'
|
||||
// })
|
||||
uni.request({
|
||||
// url: Url + '/api/v1' + url,
|
||||
url: Url + '/api' + url,
|
||||
method: method || 'GET',
|
||||
header: {
|
||||
...header
|
||||
|
||||
},
|
||||
data: method != 'GET' ? data || {} : {},
|
||||
params: method == 'GET' ? data : {},
|
||||
success: (res) => {
|
||||
// uni.hideLoading()
|
||||
if (noVerify)
|
||||
// reslove(res.data, res);
|
||||
reslove(res.data);
|
||||
else if (res.data.code == -1) {
|
||||
store.commit("LOGOUT");
|
||||
store.commit("SET_REQUEST", false);
|
||||
reject(res.data);
|
||||
} else if (res.data.code == 0) {
|
||||
// uni.hideLoading();
|
||||
if (res.data.show != 1 && res.data.msg != '无登录信息') {
|
||||
uni.showToast({
|
||||
title: res.data.msg || '请检查网络',
|
||||
icon: 'none',
|
||||
})
|
||||
}
|
||||
reject(res.data);
|
||||
} else if (res.data.code == 1) {
|
||||
store.commit("SET_REQUEST");
|
||||
reslove(res.data);
|
||||
} else if (res.data.code == 200) {
|
||||
store.commit("SET_REQUEST");
|
||||
reslove(res.data.data);
|
||||
} else if ([410000, 410001, 410002, 40000].indexOf(res.data.code) !== -1) {
|
||||
toLogin();
|
||||
reject(res.data);
|
||||
} else if (res.data.code == 501) {
|
||||
// uni.reLaunch({
|
||||
// url: '/pages/error/index'
|
||||
// })
|
||||
reject(res.data);
|
||||
} else {
|
||||
// uni.hideLoading();
|
||||
uni.showToast({
|
||||
title: res.data.msg || '请检查网络',
|
||||
icon: 'none'
|
||||
})
|
||||
reject(res.data.msg || '请检查网络');
|
||||
}
|
||||
},
|
||||
fail: (message) => {
|
||||
// uni.hideLoading()
|
||||
uni.showToast({
|
||||
title: '网络错误',
|
||||
icon: 'none'
|
||||
})
|
||||
reject('请求失败');
|
||||
}
|
||||
})
|
||||
});
|
||||
}
|
||||
|
||||
const oahttp = {};
|
||||
|
||||
['options', 'get', 'post', 'put', 'head', 'delete', 'trace', 'connect'].forEach((method) => {
|
||||
oahttp[method] = (api, data, opt) => baseRequestTwo(api, method, data, opt || {})
|
||||
});
|
||||
|
||||
export default oahttp;
|
|
@ -0,0 +1,134 @@
|
|||
import {
|
||||
HTTP_REQUEST_URL_THREE,
|
||||
HEADER,
|
||||
TOKENNAME,
|
||||
} from '@/config/app';
|
||||
import {
|
||||
Toast
|
||||
} from '../libs/uniApi';
|
||||
// import { checkLogin } from '../libs/login';
|
||||
import store from '../store';
|
||||
|
||||
function toLogin() {
|
||||
uni.showToast({
|
||||
title: '请先登录',
|
||||
icon: 'none',
|
||||
duration: 1000
|
||||
});
|
||||
}
|
||||
|
||||
function baseRequestTwo(url, method, data, {
|
||||
noAuth = false,
|
||||
noVerify = false,
|
||||
onReLogin = false
|
||||
}) {
|
||||
let Url = HTTP_REQUEST_URL_THREE,
|
||||
header = HEADER;
|
||||
if (!noAuth) {
|
||||
// 已经未登录了,禁止请求
|
||||
if (!store.state.config.request) return Promise.reject({
|
||||
msg: '未登录'
|
||||
});
|
||||
//登录过期自动登录
|
||||
if (!store.state.app.token) {
|
||||
toLogin();
|
||||
store.commit("SET_REQUEST", false);
|
||||
return Promise.reject({
|
||||
msg: '未登录'
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
// if (store.state.app.token) header[TOKENNAME] = 'Bearer ' + store.state.app.token;
|
||||
if (store.state.app.token) header[TOKENNAME] = store.state.app.token;
|
||||
|
||||
// header[TOKENNAME] = 'Bearer sdjflidshjgfkbdasgjmasbgvhauuiavhkesvndkaesbvkjsdbv';
|
||||
return new Promise((reslove, reject) => {
|
||||
// uni.showLoading({
|
||||
// title: '加载中'
|
||||
// })
|
||||
uni.request({
|
||||
// url: Url + '/api/v1' + url,
|
||||
url: Url + '/api' + url,
|
||||
method: method || 'GET',
|
||||
header: {
|
||||
...header
|
||||
},
|
||||
data: method != 'GET' ? data || {} : {},
|
||||
params: method == 'GET' ? data : {},
|
||||
success: (res) => {
|
||||
|
||||
if (noVerify)
|
||||
reslove(res.data);
|
||||
else if (res.data.code == -1) {
|
||||
if (onReLogin) {
|
||||
store.commit('LOGOUT');
|
||||
return reject();
|
||||
}
|
||||
|
||||
// 如果登录超时,自动重新登录并且继续发送请求
|
||||
store.dispatch("RE_LOGIN", {
|
||||
url: url,
|
||||
method: method,
|
||||
data: data,
|
||||
opt: {
|
||||
noAuth,
|
||||
noVerify
|
||||
}
|
||||
}).then((e) => {
|
||||
reslove(e);
|
||||
}).catch((err) => {
|
||||
reject(res.data);
|
||||
})
|
||||
// store.commit("SET_REQUEST", false);
|
||||
} else if (res.data.code == 0) {
|
||||
|
||||
if (res.data.msg != '无登录信息') {
|
||||
uni.showToast({
|
||||
title: res.data.msg || '请检查网络',
|
||||
icon: 'none',
|
||||
})
|
||||
}
|
||||
// reject(res.data);
|
||||
reslove(res.data);
|
||||
} else if (res.data.code == 1) {
|
||||
|
||||
reslove(res.data);
|
||||
|
||||
} else if (res.data.code == 200) {
|
||||
store.commit("SET_REQUEST");
|
||||
reslove(res.data.data);
|
||||
|
||||
} else if ([410000, 410001, 410002, 40000].indexOf(res.data.code) !== -1) {
|
||||
toLogin();
|
||||
reject(res.data);
|
||||
} else if (res.data.code == 501) {
|
||||
reject(res.data);
|
||||
} else {
|
||||
uni.showToast({
|
||||
title: res.data.msg || '请检查网络',
|
||||
icon: 'none'
|
||||
})
|
||||
reject(res.data.msg || '请检查网络');
|
||||
}
|
||||
},
|
||||
fail: (message) => {
|
||||
console.log(message)
|
||||
// uni.hideLoading()
|
||||
uni.showToast({
|
||||
title: '网络错误',
|
||||
icon: 'none'
|
||||
})
|
||||
reject('请求失败');
|
||||
}
|
||||
})
|
||||
});
|
||||
}
|
||||
|
||||
const oahttp = {};
|
||||
|
||||
['options', 'get', 'post', 'put', 'head', 'delete', 'trace', 'connect'].forEach((method) => {
|
||||
oahttp[method] = (api, data, opt) => baseRequestTwo(api, method, data, opt || {})
|
||||
});
|
||||
|
||||
export default oahttp;
|
|
@ -0,0 +1,77 @@
|
|||
import { HTTP_REQUEST_URL, HEADER, TOKENNAME, } from '@/config/app';
|
||||
// import { checkLogin } from '../libs/login';
|
||||
import store from '../store';
|
||||
import props from '../uni_modules/uview-ui/libs/config/props';
|
||||
|
||||
|
||||
function toLogin() {
|
||||
store.commit("LOGOUT");
|
||||
uni.showToast({
|
||||
title: '请登录',
|
||||
icon: 'none',
|
||||
duration: 1000
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* 发送请求
|
||||
*/
|
||||
function baseRequest(url, method, data, {
|
||||
noAuth = false,
|
||||
noVerify = false
|
||||
}) {
|
||||
console.log('当前环境', process.env.NODE_ENV);
|
||||
let Url = HTTP_REQUEST_URL,
|
||||
header = HEADER;
|
||||
|
||||
if (!noAuth) {
|
||||
//登录过期自动登录
|
||||
// if (!store.state.app.token && !checkLogin()) {
|
||||
if (!store.state.app.token) {
|
||||
toLogin();
|
||||
return Promise.reject({
|
||||
msg: '未登录'
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
if (store.state.app.token) header[TOKENNAME] = 'Bearer ' + store.state.app.token;
|
||||
|
||||
return new Promise((reslove, reject) => {
|
||||
uni.request({
|
||||
url: Url + '/api/' + url,
|
||||
method: method || 'GET',
|
||||
header: header,
|
||||
data: data || {},
|
||||
success: (res) => {
|
||||
// #ifdef APP-PLUS
|
||||
console.log('app', Url + '/api/' + url, res.data);
|
||||
// #endif
|
||||
if (noVerify)
|
||||
reslove(res.data, res);
|
||||
else if (res.data.status == 200)
|
||||
reslove(res.data, res);
|
||||
else if ([410000, 410001, 410002, 40000].indexOf(res.data.status) !== -1) {
|
||||
toLogin();
|
||||
reject(res.data);
|
||||
} else if (res.data.status == 501) {
|
||||
uni.reLaunch({
|
||||
url: '/pages/error/index'
|
||||
})
|
||||
reject(res.data);
|
||||
} else
|
||||
reject(res.data.message || '系统错误');
|
||||
},
|
||||
fail: (message) => {
|
||||
reject('请求失败');
|
||||
}
|
||||
})
|
||||
});
|
||||
}
|
||||
|
||||
const request = {};
|
||||
['options', 'get', 'post', 'put', 'head', 'delete', 'trace', 'connect'].forEach((method) => {
|
||||
request[method] = (api, data, opt) => baseRequest(api, method, data, opt || {})
|
||||
});
|
||||
|
||||
export default request;
|
|
@ -0,0 +1,34 @@
|
|||
|
||||
// 格式化:50分钟前,1小时前.20天前
|
||||
export const getTimeAgo = (timestamp) => {
|
||||
const now = Date.now();
|
||||
const diff = now - new Date(timestamp);
|
||||
|
||||
// 计算时间差的毫秒数
|
||||
const milliseconds = Math.abs(diff);
|
||||
|
||||
// 定义时间单位与对应的毫秒数
|
||||
const timeUnits = [
|
||||
{ unit: '年', ms: 1000 * 60 * 60 * 24 * 365 },
|
||||
{ unit: '个月', ms: 1000 * 60 * 60 * 24 * 30 },
|
||||
{ unit: '周', ms: 1000 * 60 * 60 * 24 * 7 },
|
||||
{ unit: '天', ms: 1000 * 60 * 60 * 24 },
|
||||
{ unit: '小时', ms: 1000 * 60 * 60 },
|
||||
{ unit: '分钟', ms: 1000 * 60 },
|
||||
];
|
||||
|
||||
let str = ''
|
||||
|
||||
// 循环遍历时间单位,并计算时间差所对应的单位
|
||||
for (let i = 0; i < timeUnits.length; i++) {
|
||||
const { unit, ms } = timeUnits[i];
|
||||
if (milliseconds >= ms) {
|
||||
const count = Math.floor(milliseconds / ms);
|
||||
str = `${count}${unit}前`;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
// 如果时间差过小,可以自定义返回结果
|
||||
return str||'刚刚';
|
||||
}
|
|
@ -0,0 +1,85 @@
|
|||
let socket = null;
|
||||
const HEARTBEAT_INTERVAL = 5000;
|
||||
let heartbeatTimer = null;
|
||||
|
||||
// // 连接到后端 WebSocket,并开始心跳
|
||||
// function connect() {
|
||||
// WebSocket.connect('ws://your-backend-url');
|
||||
// startHeartbeat();
|
||||
// }
|
||||
|
||||
// 开始发送心跳消息
|
||||
function startHeartbeat() {
|
||||
heartbeatTimer = setInterval(() => {
|
||||
WebSocket.send('heartbeat');
|
||||
}, HEARTBEAT_INTERVAL);
|
||||
}
|
||||
|
||||
// 停止发送心跳消息
|
||||
function stopHeartbeat() {
|
||||
clearInterval(heartbeatTimer);
|
||||
}
|
||||
|
||||
// 监听收到的消息
|
||||
WebSocket.onMessage((event) => {
|
||||
if (event.data === 'heartbeat') {
|
||||
// 收到心跳响应,重置定时器
|
||||
resetHeartbeatTimer();
|
||||
} else {
|
||||
// 处理其他消息
|
||||
}
|
||||
});
|
||||
|
||||
// 重置心跳定时器
|
||||
function resetHeartbeatTimer() {
|
||||
clearInterval(heartbeatTimer);
|
||||
startHeartbeat();
|
||||
}
|
||||
|
||||
// 在页面关闭或组件销毁时,关闭 WebSocket 连接并停止心跳
|
||||
uni.onUnload(() => {
|
||||
WebSocket.close();
|
||||
stopHeartbeat();
|
||||
});
|
||||
|
||||
|
||||
function connect(url) {
|
||||
socket = uni.connectSocket({
|
||||
url: url
|
||||
});
|
||||
|
||||
socket.onOpen(() => {
|
||||
console.log('WebSocket 连接已打开');
|
||||
});
|
||||
|
||||
socket.onError((error) => {
|
||||
console.error('WebSocket 连接发生错误', error);
|
||||
});
|
||||
|
||||
socket.onClose((e) => {
|
||||
console.log('WebSocket 连接已关闭', e);
|
||||
});
|
||||
|
||||
socket.onMessage((event) => {
|
||||
console.log('收到服务器消息', event.data);
|
||||
// 处理收到的消息
|
||||
});
|
||||
}
|
||||
|
||||
function send(message) {
|
||||
socket.send({
|
||||
data: message
|
||||
});
|
||||
}
|
||||
|
||||
function close() {
|
||||
if (socket) {
|
||||
socket.close();
|
||||
}
|
||||
}
|
||||
|
||||
export default {
|
||||
connect,
|
||||
send,
|
||||
close
|
||||
};
|
Loading…
Reference in New Issue