//app.js
|
const QQMapWX = require("./utils/qqmap-wx-jssdk");
|
const GdMap = require("./utils/amap-wx");
|
// const apiHost = 'http://221.182.45.100:5000/user'
|
// const apiHost = "https://test-qncx.sitechcloud.com/chuxing/user-server"; //本地
|
// const apiHost = "http://192.168.110.111:5000/user-server";
|
// const apiHost = 'http://123.56.89.63:8080/user-server'
|
// 上面地址不管用，下面的地址才用
|
// const apiHost = 'http://221.182.45.100:7894/user'; //本地
|
const apiHost = 'https://ride.cbyzx.com/user' //线上
|
const SOCKET_URL = "wss://ride.cbyzx.com/websocket";
|
const SOCKET_HEARTBEAT_INTERVAL = 10000;
|
const SOCKET_RECONNECT_DELAY = 3000;
|
|
App({
|
// 这里这么写，是要在其他界面监听，而不是在app.js中监听，而且这个监听方法，需要一个回调方法。
|
watch(method) {
|
if (typeof method !== "function") {
|
return;
|
}
|
const socketWatchers = this.globalData.socketWatchers || [];
|
if (socketWatchers.indexOf(method) === -1) {
|
socketWatchers.push(method);
|
}
|
this.globalData.socketWatchers = socketWatchers;
|
},
|
unwatch(method) {
|
if (typeof method !== "function") {
|
return;
|
}
|
this.globalData.socketWatchers = (this.globalData.socketWatchers || []).filter(
|
(item) => item !== method
|
);
|
},
|
registerSocketCallback(method) {
|
if (typeof method !== "function") {
|
return;
|
}
|
const socketCallbacks = this.globalData.socketCallbacks || [];
|
if (socketCallbacks.indexOf(method) === -1) {
|
socketCallbacks.push(method);
|
}
|
this.globalData.socketCallbacks = socketCallbacks;
|
},
|
unregisterSocketCallback(method) {
|
if (typeof method !== "function") {
|
return;
|
}
|
this.globalData.socketCallbacks = (this.globalData.socketCallbacks || []).filter(
|
(item) => item !== method
|
);
|
},
|
notifySocketMessage(res) {
|
this.globalData.lastSocketActiveAt = Date.now();
|
if (typeof this.globalData.callback === "function") {
|
try {
|
this.globalData.callback(res);
|
} catch (error) {
|
console.log("legacy socket callback error", error);
|
}
|
}
|
(this.globalData.socketCallbacks || []).forEach((method) => {
|
try {
|
method(res);
|
} catch (error) {
|
console.log("socket callback error", error);
|
}
|
});
|
(this.globalData.socketWatchers || []).forEach((method) => {
|
try {
|
method(res.data);
|
} catch (error) {
|
console.log("socket watcher error", error);
|
}
|
});
|
this.globalData.resData = res.data;
|
},
|
clearSocketHeartbeat() {
|
if (this.globalData.socketHeartbeatTimer) {
|
clearInterval(this.globalData.socketHeartbeatTimer);
|
this.globalData.socketHeartbeatTimer = null;
|
}
|
},
|
clearSocketReconnectTimer() {
|
if (this.globalData.socketReconnectTimer) {
|
clearTimeout(this.globalData.socketReconnectTimer);
|
this.globalData.socketReconnectTimer = null;
|
}
|
},
|
startSocketHeartbeat() {
|
this.clearSocketHeartbeat();
|
const msg = {
|
code: 200,
|
method: "PING",
|
msg: "SUCCESS",
|
data: {
|
type: 1,
|
userId: wx.getStorageSync("userId"),
|
token: wx.getStorageSync("token") || "",
|
businessType: 1,
|
},
|
};
|
this.sendSocketMessage(JSON.stringify(msg));
|
this.globalData.socketHeartbeatTimer = setInterval(() => {
|
this.sendSocketMessage(JSON.stringify(msg));
|
}, SOCKET_HEARTBEAT_INTERVAL);
|
},
|
scheduleSocketReconnect() {
|
const token = wx.getStorageSync("token");
|
if (!token || token === "quit" || this.globalData.socketReconnectTimer) {
|
return;
|
}
|
this.globalData.socketReconnectTimer = setTimeout(() => {
|
this.globalData.socketReconnectTimer = null;
|
this.initSocket();
|
}, SOCKET_RECONNECT_DELAY);
|
},
|
resetSocketState() {
|
this.globalData.sockTaskStatus = false;
|
this.globalData.isSocketConnecting = false;
|
this.clearSocketHeartbeat();
|
},
|
refreshSocketConnection() {
|
const currentSocket = this.globalData.localSocket;
|
this.clearSocketReconnectTimer();
|
this.resetSocketState();
|
this.globalData.localSocket = null;
|
if (
|
currentSocket &&
|
typeof currentSocket.close === "function" &&
|
(currentSocket.readyState === 0 || currentSocket.readyState === 1)
|
) {
|
try {
|
currentSocket.close({});
|
} catch (error) {
|
console.log("close current socket error", error);
|
}
|
}
|
return this.initSocket();
|
},
|
//初始化socket
|
initSocket() {
|
const token = wx.getStorageSync("token");
|
if (!token || token == "quit") {
|
this.clearSocketReconnectTimer();
|
this.resetSocketState();
|
this.globalData.localSocket = null;
|
return null;
|
}
|
const currentSocket = this.globalData.localSocket;
|
const readyState =
|
currentSocket && typeof currentSocket.readyState !== "undefined" ?
|
currentSocket.readyState :
|
-1;
|
if (this.globalData.sockTaskStatus && readyState === 1) {
|
return currentSocket;
|
}
|
if (this.globalData.isSocketConnecting || readyState === 0) {
|
return currentSocket;
|
}
|
console.log("初始化");
|
this.clearSocketReconnectTimer();
|
this.clearSocketHeartbeat();
|
this.globalData.isSocketConnecting = true;
|
const socketTask = wx.connectSocket({
|
url: SOCKET_URL,
|
});
|
this.globalData.localSocket = socketTask;
|
socketTask.onOpen((res) => {
|
if (this.globalData.localSocket !== socketTask) {
|
return;
|
}
|
console.log("/////////////", res);
|
this.globalData.sockTaskStatus = true;
|
this.globalData.isSocketConnecting = false;
|
this.globalData.lastSocketActiveAt = Date.now();
|
this.startSocketHeartbeat();
|
});
|
socketTask.onMessage((res) => {
|
if (this.globalData.localSocket !== socketTask) {
|
return;
|
}
|
this.notifySocketMessage(res);
|
});
|
socketTask.onError((res) => {
|
if (this.globalData.localSocket !== socketTask) {
|
return;
|
}
|
console.log("readyState=" + socketTask.readyState, res);
|
this.globalData.sockTaskStatus = false;
|
this.globalData.isSocketConnecting = false;
|
this.clearSocketHeartbeat();
|
this.scheduleSocketReconnect();
|
});
|
socketTask.onClose((res) => {
|
if (this.globalData.localSocket !== socketTask) {
|
return;
|
}
|
this.resetSocketState();
|
this.globalData.localSocket = null;
|
console.log(
|
"WebSocket连接已关闭！readyState=" + socketTask.readyState,
|
res
|
);
|
this.scheduleSocketReconnect();
|
});
|
return socketTask;
|
},
|
//统一发送消息
|
sendSocketMessage: function (msg) {
|
if (
|
this.globalData.localSocket &&
|
this.globalData.localSocket.readyState === 1
|
) {
|
this.globalData.localSocket.send({
|
data: msg,
|
});
|
this.globalData.lastSocketActiveAt = Date.now();
|
}
|
},
|
|
//关闭socket
|
closeSocket() {
|
const currentSocket = this.globalData.localSocket;
|
this.clearSocketReconnectTimer();
|
this.resetSocketState();
|
this.globalData.localSocket = null;
|
if (
|
currentSocket &&
|
typeof currentSocket.close === "function" &&
|
(currentSocket.readyState === 0 || currentSocket.readyState === 1)
|
) {
|
currentSocket.close({});
|
}
|
},
|
getFloatStr: function (num) {
|
num += "";
|
num = num.replace(/[^0-9|\.]/g, ""); //清除字符串中的非数字非.字符
|
if (/^0+/)
|
//清除字符串开头的0
|
num = num.replace(/^0+/, "");
|
if (!/\./.test(num))
|
//为整数字符串在末尾添加.00
|
num += ".00";
|
if (/^\./.test(num))
|
//字符以.开头时,在开头添加0
|
num = "0" + num;
|
num += "00"; //在字符串末尾补零
|
num = num.match(/\d+\.\d{2}/)[0];
|
console.log(num);
|
},
|
onShow(options) {
|
//socket
|
if (wx.getStorageSync("token")) {
|
const hiddenDuration = this.globalData.appHideAt ?
|
Date.now() - this.globalData.appHideAt :
|
0;
|
const needRefresh =
|
hiddenDuration >= SOCKET_HEARTBEAT_INTERVAL ||
|
!this.globalData.localSocket ||
|
this.globalData.localSocket.readyState !== 1;
|
if (needRefresh) {
|
this.refreshSocketConnection();
|
} else {
|
this.startSocketHeartbeat();
|
}
|
}
|
var obj = wx.getEnterOptionsSync();
|
if (options.scene == 1069) {
|
return false;
|
}
|
clearInterval(this.globalData.comparisonToken);
|
var comparisonToken = setInterval(() => {
|
this.globalData.comparisonToken = comparisonToken;
|
if (wx.getStorageSync("token") !== "") {
|
this.getsetTime();
|
}
|
}, 5000);
|
},
|
onHide() {
|
this.globalData.appHideAt = Date.now();
|
clearInterval(this.globalData.comparisonToken);
|
this.globalData.comparisonToken = "";
|
},
|
|
//单点登录接口
|
getsetTime() {
|
let token = wx.getStorageSync("token");
|
let header = {
|
"Content-Type": "application/json;charset=UTF-8,",
|
Authorization: "Bearer" + " " + token,
|
};
|
wx.request({
|
url: this.globalData.Url + "/api/user/comparisonToken",
|
header,
|
method: "POST",
|
success: (res) => {
|
if (res.data.code == 600 && token !== "" && token !== "quit") {
|
wx.setStorageSync("token", "");
|
wx.showModal({
|
title: "提示",
|
content: "您在其他地方登录了,是否重新登录",
|
showCancel: false,
|
confirmText: "确定", //默认是“确定”
|
confirmColor: "#00BF30", //确定文字的颜色
|
success: (res) => {
|
if (res.cancel) {
|
//点击取消,默认隐藏弹框
|
} else {
|
wx.redirectTo({
|
url: "/pages/home/home",
|
});
|
clearInterval(this.globalData.comparisonToken);
|
}
|
},
|
fail: function (res) {}, //接口调用失败的回调函数
|
complete: function (res) {}, //接口调用结束的回调函数（调用成功、失败都会执行）
|
});
|
}
|
},
|
});
|
},
|
onLaunch: function (options) {
|
wx.getSystemInfo({
|
success: (res) => {
|
console.log(res);
|
// console.log('手机信息res'+res.model)
|
let modelmes = res.model;
|
if (
|
modelmes.search("iPhone X") != -1 ||
|
modelmes.search("iPhone 11") != -1
|
) {
|
this.globalData.isIphoneX = true;
|
}
|
},
|
});
|
// // 展示本地存储能力
|
|
wx.setStorageSync("height", wx.getSystemInfoSync().windowHeight || "");
|
// 登录
|
wx.login({
|
success: (res) => {
|
// 发送 res.code 到后台换取 openId, sessionKey, unionId
|
},
|
});
|
// 获取用户信息
|
wx.getSetting({
|
success: (res) => {
|
if (res.authSetting["scope.userInfo"]) {
|
// 已经授权，可以直接调用 getUserInfo 获取头像昵称，不会弹框
|
wx.getUserInfo({
|
success: (res) => {
|
// 可以将 res 发送给后台解码出 unionId
|
this.globalData.userInfo = res.userInfo;
|
|
// 由于 getUserInfo 是网络请求，可能会在 Page.onLoad 之后才返回
|
// 所以此处加入 callback 以防止这种情况
|
if (this.userInfoReadyCallback) {
|
this.userInfoReadyCallback(res);
|
}
|
},
|
});
|
}
|
},
|
});
|
},
|
|
getQQMap() {
|
return new GdMap.AMapWX({
|
key: "0a4ecc86729b8d18661abd5d0686e42c",
|
// key:"be262c006216c542747fce766130cee3"
|
});
|
// return new QQMapWX({
|
// key: "UHWBZ-6NM3U-DHCVH-2NMFG-XWCIH-WUBYM",
|
// });
|
},
|
|
getQQMaps() {
|
// return new GdMap.AMapWX({
|
// key: "0a4ecc86729b8d18661abd5d0686e42c",
|
// });
|
return new QQMapWX({
|
key: "UHWBZ-6NM3U-DHCVH-2NMFG-XWCIH-WUBYM",
|
});
|
},
|
//showToast--弹出框
|
showToastSuccess: function (value, images, status, time) {
|
try {
|
let image = images || "";
|
wx.showToast({
|
title: value,
|
image,
|
icon: status,
|
duration: time,
|
});
|
} catch (err) {
|
console.log(err);
|
}
|
},
|
|
//正则手机号验证
|
testPhone: function (phoneNum) {
|
var myreg = /^1[3456789]\d{9}$/;
|
if (phoneNum.length == 0) {
|
wx.showToast({
|
title: "输入手机号",
|
icon: "none",
|
duration: 1500,
|
});
|
return false;
|
} else if (phoneNum.length < 11 || phoneNum.length > 11) {
|
wx.showToast({
|
title: "手机号有误",
|
icon: "none",
|
duration: 1500,
|
});
|
return false;
|
} else if (!myreg.test(phoneNum)) {
|
wx.showToast({
|
title: "手机号错误1",
|
icon: "none",
|
duration: 1500,
|
});
|
return false;
|
} else {
|
return true;
|
}
|
},
|
//验证码手机号验证
|
testPhoneCode: function (phoneNum) {
|
var myreg = /^1[3456789]\d{9}$/;
|
if (phoneNum.length == 0) {
|
wx.showToast({
|
title: "输入手机号",
|
icon: "none",
|
duration: 1500,
|
});
|
return false;
|
} else if (phoneNum.length < 11 || phoneNum.length > 11) {
|
wx.showToast({
|
title: "手机号有误",
|
icon: "none",
|
duration: 1500,
|
});
|
return false;
|
} else if (!myreg.test(phoneNum)) {
|
wx.showToast({
|
title: "手机号错误",
|
icon: "none",
|
duration: 1500,
|
});
|
return false;
|
} else {
|
console.log("1");
|
return true;
|
}
|
},
|
//request请求
|
apiRequest(url, data, method, upload) {
|
let that = this;
|
let token = wx.getStorageSync("token");
|
let header = "";
|
let havePhone = wx.getStorageSync("havePhone");
|
if (!havePhone) {
|
wx.redirectTo({
|
url: "/pages/wxChatPhone/wxChatPhone",
|
});
|
return false;
|
}
|
if (token) {
|
header = {
|
"Content-Type": "application/json;charset=UTF-8,",
|
Authorization: "Bearer" + " " + token,
|
};
|
if (method == "PUT" || method == "POST") {
|
if (upload == 1) {
|
header = {
|
"content-type": "multipart/form-data",
|
Authorization: "Bearer" + " " + token,
|
};
|
} else {
|
header = {
|
"content-type": "application/x-www-form-urlencoded",
|
Authorization: "Bearer" + " " + token,
|
};
|
}
|
}
|
} else {
|
header = {
|
"Content-Type": "application/json;charset=UTF-8,",
|
Authorization: "",
|
};
|
if (method == "PUT" || method == "POST") {
|
header = {
|
"content-type": "application/x-www-form-urlencoded",
|
Authorization: "",
|
};
|
}
|
}
|
|
return new Promise((resolve, reject) => {
|
if (upload != 2) {
|
wx.showLoading({
|
mask: true,
|
});
|
}
|
|
// 上传图片文件
|
if (upload == 1) {
|
// console.log(data);
|
wx.uploadFile({
|
url: apiHost + url,
|
header: header,
|
filePath: data,
|
name: "file",
|
formData: {},
|
success: (res) => {
|
let data = JSON.parse(res.data);
|
//do something
|
resolve(data);
|
},
|
fail: (res) => {
|
reject(res);
|
},
|
});
|
} else {
|
wx.request({
|
url: apiHost + url,
|
data: data || {},
|
header: header,
|
method: method || "GET",
|
dataType: "json",
|
responseType: "text",
|
success: (res) => {
|
// console.log(res);
|
if (upload != 2) {
|
wx.hideLoading();
|
}
|
|
console.log(res);
|
if (res.data.code == 500) {
|
reject();
|
return wx.showToast({
|
title: res.data.msg,
|
icon: "none",
|
duration: 1500,
|
mask: true,
|
});
|
}
|
resolve(res);
|
if (res.data.code == 200) {} else if (res.data.code == 500) {
|
if (res.data.msg == "Token失效") {
|
// 清空本地token
|
wx.setStorageSync("token", "");
|
wx.showModal({
|
title: "登录失效，是否登录",
|
content: "",
|
showCancel: true,
|
cancelText: "取消",
|
cancelColor: "#000000",
|
confirmText: "确定",
|
confirmColor: "#00BF30",
|
success: (result) => {
|
if (result.confirm) {
|
wx.navigateTo({
|
url: "/pages/index/index",
|
});
|
}
|
},
|
});
|
} else if (res.data.msg == "验证码已失效") {
|
wx.setStorageSync("token", "");
|
wx.showToast({
|
title: "验证码有误,请重新输入",
|
icon: "none",
|
duration: 1500,
|
mask: true,
|
});
|
} else {}
|
} else if (res.data.code == 600 || res.data.code == 700) {
|
// 清空本地token
|
if (wx.getStorageSync("token") == "") {
|
wx.showModal({
|
title: "您还未登录，是否登录",
|
content: "",
|
showCancel: false,
|
cancelColor: "#000000",
|
confirmText: "确定",
|
confirmColor: "#00BF30",
|
success: (result) => {
|
if (result.confirm) {
|
wx.navigateTo({
|
url: "/pages/index/index",
|
});
|
}
|
},
|
});
|
setTimeout(() => {
|
this.setData({
|
btnDisabled: false,
|
});
|
}, 2000);
|
return;
|
} else {
|
wx.showModal({
|
title: "登录失效，是否登录",
|
content: "",
|
showCancel: false,
|
cancelColor: "#000000",
|
confirmText: "确定",
|
confirmColor: "#00BF30",
|
success: (result) => {
|
if (result.confirm) {
|
wx.navigateTo({
|
url: "/pages/index/index",
|
});
|
}
|
},
|
});
|
setTimeout(() => {
|
this.setData({
|
btnDisabled: false,
|
});
|
}, 2000);
|
return;
|
}
|
} else {
|
// wx.showToast({
|
// title: res.data.msg,
|
// icon: "none",
|
// duration: 1500,
|
// });
|
}
|
},
|
fail: (res) => {
|
console.log(res);
|
if (upload != 2) {
|
wx.hideLoading();
|
}
|
wx.showToast({
|
title: "网络异常，请检查网络",
|
icon: "none",
|
duration: 1500,
|
});
|
reject(res);
|
},
|
complete: (res) => {},
|
});
|
}
|
});
|
},
|
|
// 弹出弹窗
|
|
globalData: {
|
userInfo: null,
|
cityName: wx.getStorageSync("cityName") || "",
|
userLatitude: wx.getStorageSync("latitude") || "",
|
userLongitude: wx.getStorageSync("longitude") || "",
|
|
// Url:'https://okyueche.com:443/user',
|
// Url: 'http://221.182.45.100:5000/user-server',
|
// Url: "https://test-qncx.sitechcloud.com/chuxing/user-server", //本地
|
// Url: "http://192.168.110.64:8006",
|
// Url: 'http://192.168.0.80:8080/user-server',
|
|
|
// 上面地址不管用，下面的地址才用
|
// Url: 'http://221.182.45.100:7894/user', //本地
|
Url : 'https://ride.cbyzx.com/user',
|
|
|
localSocket: {},
|
callback: function () {},
|
sockTaskStatus: false,
|
isSocketConnecting: false,
|
resData: {},
|
socketWatchers: [],
|
socketCallbacks: [],
|
socketHeartbeatTimer: null,
|
socketReconnectTimer: null,
|
lastSocketActiveAt: 0,
|
appHideAt: 0,
|
isIphoneX: false,
|
state: 0,
|
comparisonToken: "",
|
driveTimer: "",
|
drivelat: "",
|
drivelon: "",
|
timer: require("./utils/wxTime"),
|
},
|
});
|
