first commit

app/libs/apps.js

@@ -0,0 +1,24 @@
+import { appAuth } from '../api/public';
+
+class Apps{
+	/**
+	 * 授权登录获取token
+	 * @param {Object} code
+	 */
+	authApp(code) {
+		return new Promise((resolve, reject) => {
+			appAuth(code,{'spread_spid': 0})
+				.then(({
+					data
+				}) => {
+					resolve(data);
+					Cache.set(WX_AUTH, code);
+					Cache.clear(STATE_KEY);
+					loginType && Cache.clear(LOGINTYPE);
+					
+				})
+				.catch(reject);
+		});
+	}
+}
+export default new Apps();

app/libs/chat.js

@@ -0,0 +1,62 @@
+import $store from "@/store";
+import { VUE_APP_WS_URL } from "@/utils/index.js";
+
+const Socket = function() {
+  this.ws = new WebSocket(wss(VUE_APP_WS_URL));
+  this.ws.onopen = this.onOpen.bind(this);
+  this.ws.onerror = this.onError.bind(this);
+  this.ws.onmessage = this.onMessage.bind(this);
+  this.ws.onclose = this.onClose.bind(this);
+};
+
+function wss(wsSocketUrl) {
+    let ishttps = document.location.protocol == 'https:';
+    if (ishttps) {
+        return wsSocketUrl.replace('ws:', 'wss:');
+    } else {
+        return wsSocketUrl.replace('wss:', 'ws:');
+    }
+}
+
+Socket.prototype = {
+  vm(vm) {
+    this.vm = vm;
+  },
+  close() {
+    clearInterval(this.timer);
+    this.ws.close();
+  },
+  onOpen: function() {
+    console.log("ws open");
+    this.init();
+    this.send({
+      type: "login",
+      data: $store.state.app.token
+    });
+    this.vm.$emit("socket_open");
+  },
+  init: function() {
+    var that = this;
+    this.timer = setInterval(function() {
+      that.send({ type: "ping" });
+    }, 10000);
+  },
+  send: function(data) {
+    return this.ws.send(JSON.stringify(data));
+  },
+  onMessage: function(res) {
+    const { type, data = {} } = JSON.parse(res.data);
+    this.vm.$emit(type, data);
+  },
+  onClose: function() {
+    clearInterval(this.timer);
+  },
+  onError: function(e) {
+    console.log(e);
+    this.vm.$emit("socket_error", e);
+  }
+};
+
+Socket.prototype.constructor = Socket;
+
+export default Socket;

app/libs/login.js

@@ -0,0 +1,111 @@
+import store from "../store";
+import Cache from '../utils/cache';
+import {
+	Debounce
+} from '@/utils/validate.js'
+// #ifdef H5
+import {
+	isWeixin
+} from "../utils";
+import auth from './wechat';
+// #endif
+
+import {
+	LOGIN_STATUS,
+	USER_INFO,
+	EXPIRES_TIME,
+	STATE_R_KEY,
+	BACK_URL
+} from './../config/cache';
+
+function prePage() {
+	let pages = getCurrentPages();
+	let prePage = pages[pages.length - 1];
+	return prePage.route;
+}
+
+export const toLogin = Debounce(_toLogin, 800)
+
+export function _toLogin(push, pathLogin) {
+
+	store.commit("LOGOUT");
+	let path = prePage();
+	let login_back_url = Cache.get(BACK_URL);
+
+	// #ifdef APP
+	uni.navigateTo({
+		url: '/pages/users/login/index'
+	})
+	return
+	// #endif
+
+
+	// #ifdef H5
+	// path = location.href;
+	// path = location.pathname + location.search;
+	let url_list = location.href?.split("?");
+	if (url_list.length > 1) {
+		path = "/" + path + "?" + url_list[1]
+	}
+	// #endif
+	if (!pathLogin) {
+		pathLogin = '/page/users/login/index'
+		Cache.set('login_back_url', path);
+	}
+
+	// #ifdef H5
+	if (isWeixin()) {
+		let urlData = location.pathname + location.search
+		if (urlData.indexOf('?') !== -1) {
+			urlData += '&go_longin=1';
+		} else {
+			urlData += '?go_longin=1';
+		}
+		if (!Cache.has('snsapiKey')) {
+			auth.oAuth('snsapi_base', urlData);
+		} else {
+			if (['/pages/user/index'].indexOf(login_back_url) == -1) {
+				uni.navigateTo({
+					url: '/pages/users/wechat_login/index'
+				})
+			}
+		}
+	} else {
+		if (['/pages/user/index'].indexOf(login_back_url) == -1) {
+			uni.navigateTo({
+				url: '/pages/users/login/index'
+			})
+		}
+	}
+	// #endif
+
+	if (['pages/user/index', '/pages/user/index'].indexOf(login_back_url) == -1) {
+		// #ifdef MP
+		uni.navigateTo({
+			url: '/pages/users/wechat_login/index'
+		})
+		// #endif
+	}
+}
+
+
+export function checkLogin() {
+	let token = Cache.get(LOGIN_STATUS);
+	let expiresTime = Cache.get(EXPIRES_TIME);
+	let newTime = Math.round(new Date() / 1000);
+	if (expiresTime < newTime || !token) {
+		Cache.clear(LOGIN_STATUS);
+		Cache.clear(EXPIRES_TIME);
+		Cache.clear(USER_INFO);
+		Cache.clear(STATE_R_KEY);
+		return false;
+	} else {
+		store.commit('UPDATE_LOGIN', token);
+		let userInfo = Cache.get(USER_INFO, true);
+		if (userInfo) {
+			store.commit('UPDATE_USERINFO', userInfo);
+		}
+		return true;
+	}
+
+}

app/libs/order.js

@@ -0,0 +1,47 @@
+import {
+	preOrderApi
+} from '@/api/order.js';
+import util from 'utils/util'
+
+/**
+ * 去商品详情
+ */
+export function goShopDetail(item, uid) {
+	return new Promise(resolve => {
+		if (item.activityH5 && item.activityH5.type === "1") {
+			uni.navigateTo({
+				url: `/pages/activity/goods_seckill_details/index?id=${item.activityH5.id}`
+			})
+		} else if (item.activityH5 && item.activityH5.type === "2") {
+			uni.navigateTo({
+				url: `/pages/activity/goods_bargain_details/index?id=${item.activityH5.id}&startBargainUid=${uid}`
+			})
+		} else if (item.activityH5 && item.activityH5.type === "3") {
+			uni.navigateTo({
+				url: `/pages/activity/goods_combination_details/index?id=${item.activityH5.id}`
+			})
+		} else {
+			resolve(item);
+		}
+	});
+}
+
+/**
+ * 活动商品、普通商品、购物车、再次购买预下单
+ */
+export function getPreOrder(preOrderType, orderDetails) {
+	return new Promise((resolve, reject) => {
+		preOrderApi({
+			"preOrderType": preOrderType,
+			"orderDetails": orderDetails
+		}).then(res => {
+			uni.navigateTo({
+				url: '/pages/users/order_confirm/index?preOrderNo=' + res.data.preOrderNo
+			});
+		}).catch(err => {
+			return util.Tips({
+				title: err
+			});
+		})
+	});
+}

app/libs/routine.js

@@ -0,0 +1,140 @@
+import store from '../store';
+import { checkLogin } from './login';
+import { login } from '../api/public';
+import Cache from '../utils/cache';
+import { STATE_R_KEY, USER_INFO, EXPIRES_TIME, LOGIN_STATUS} from './../config/cache';
+class Routine 
+{
+	
+	constructor() 
+	{
+	    this.scopeUserInfo = 'scope.userInfo';
+	}
+	
+	async getUserCode(){
+		let isAuth = await this.isAuth(), code = '' ;
+		if(isAuth)
+			code = await this.getCode();
+		return code;
+	}
+	
+	/**
+	 * 获取用户信息
+	 */
+	getUserProfile(){
+		let  that = this , code = this.getUserCode();
+		return new Promise( (resolve,reject) => {
+			uni.getUserProfile({
+				lang: 'zh_CN',
+				desc: '用于完善会员资料', // 声明获取用户个人信息后的用途，后续会展示在弹窗中，请谨慎填写
+				success(user) {
+					if(code) user.code = code;
+					resolve({userInfo:user,islogin:false});
+				},
+				fail(res){
+					reject(res);
+				}
+			})
+		})
+	}
+	
+	/**
+	 * 获取用户信息
+	 */
+	authorize()
+	{
+		let that = this;
+		return new Promise((resolve,reject)=>{
+			if(checkLogin())
+				return resolve({
+					userInfo:Cache.get(USER_INFO,true),
+					islogin:true,
+				});
+			uni.authorize({
+			    scope: that.scopeUserInfo,
+			    success() {
+					resolve({islogin:false});
+			    },
+				fail(res){
+					reject(res);
+				}
+			})
+		})
+	}
+	
+	async getCode(){
+		let provider = await this.getProvider();
+		return new Promise((resolve,reject)=>{
+			uni.login({
+				provider:provider,
+				success(res) {
+					if (res.code) Cache.set(STATE_R_KEY, res.code ,10800);
+					return resolve(res.code);
+				},
+				fail(){
+					return reject(null);
+				}
+			})
+		})
+	}
+	
+	/**
+	 * 获取服务供应商
+	 */
+	getProvider()
+	{
+		return new Promise((resolve,reject)=>{
+			uni.getProvider({
+				service:'oauth',
+				success(res) {
+					resolve(res.provider);
+				},
+				fail() {
+					resolve(false);
+				}
+			});
+		});
+	}
+	
+	/**
+	 * 是否授权
+	 */
+	isAuth(){
+		let that = this;
+		return new Promise((resolve,reject)=>{
+			uni.getSetting({
+				success(res) {
+					if (!res.authSetting[that.scopeUserInfo]) {
+						resolve(true)
+					} else {
+						resolve(true);
+					}
+				},
+				fail(){
+					 resolve(false);
+				}
+			});
+		});
+	}
+	/**
+	 * 小程序登录
+	 */
+	authUserInfo(code,data)
+	{
+		return new Promise((resolve, reject)=>{
+			login(code,data).then(res=>{
+				if(res.data.type==='login'){
+					store.commit('LOGIN', {
+						token: res.data.token
+					});
+					store.commit("SETUID", res.data.uid);
+				}
+				return resolve(res);
+			}).catch(res=>{
+				return reject(res);
+			})
+		})
+	}
+}
+
+export default new Routine();

app/libs/wechat.js

@@ -0,0 +1,325 @@
+// #ifdef H5
+import WechatJSSDK from "@/plugin/jweixin-module/index.js";
+
+
+import {
+	getWechatConfig,
+	wechatAuth
+} from "@/api/public";
+import {
+	WX_AUTH,
+	STATE_KEY,
+	LOGINTYPE,
+	BACK_URL
+} from '@/config/cache';
+import {
+	parseQuery
+} from '@/utils';
+import store from '@/store';
+import Cache from '@/utils/cache';
+
+class AuthWechat {
+
+	constructor() {
+		//微信实例化对象
+		this.instance = WechatJSSDK;
+		//是否实例化
+		this.status = false;
+
+		this.initConfig = {};
+
+	}
+
+	isAndroid() {
+		let u = navigator.userAgent;
+		return u.indexOf('Android') > -1 || u.indexOf('Adr') > -1;
+	}
+
+	signLink() {
+		if (typeof window.entryUrl === 'undefined' || window.entryUrl === '') {
+			window.entryUrl = location.href.split('#')[0]
+		}
+		return /(Android)/i.test(navigator.userAgent) ? location.href.split('#')[0] : window.entryUrl;
+	}
+
+
+	/**
+	 * 初始化wechat(分享配置)
+	 */
+	wechat() {
+		return new Promise((resolve, reject) => {
+			if (this.status && !this.isAndroid()) return resolve(this.instance);
+			getWechatConfig()
+				.then(res => {
+					this.instance.config(res.data);
+					this.initConfig = res.data;
+					this.status = true;
+					this.instance.ready(() => {
+						resolve(this.instance);
+					})
+				}).catch(err => {
+					console.log('微信分享配置失败', err);
+					this.status = false;
+					reject(err);
+				});
+		});
+	}
+
+	/**
+	 * 验证是否初始化
+	 */
+	verifyInstance() {
+		let that = this;
+		return new Promise((resolve, reject) => {
+			if (that.instance === null && !that.status) {
+				that.wechat().then(res => {
+					resolve(that.instance);
+				}).catch(() => {
+					return reject();
+				})
+			} else {
+				return resolve(that.instance);
+			}
+		})
+	}
+	// 微信公众号的共享地址
+	openAddress() {
+		return new Promise((resolve, reject) => {
+			this.wechat().then(wx => {
+				this.toPromise(wx.openAddress).then(res => {
+					resolve(res);
+				}).catch(err => {
+					reject(err);
+				});
+			}).catch(err => {
+				reject(err);
+			})
+		});
+	}
+
+	// 获取经纬度；
+	location() {
+		return new Promise((resolve, reject) => {
+			this.wechat().then(wx => {
+				this.toPromise(wx.getLocation, {
+					type: 'wgs84'
+				}).then(res => {
+					resolve(res);
+				}).catch(err => {
+					reject(err);
+				});
+			}).catch(err => {
+				reject(err);
+			})
+		});
+	}
+
+	// 使用微信内置地图查看位置接口；
+	seeLocation(config) {
+		return new Promise((resolve, reject) => {
+			this.wechat().then(wx => {
+				this.toPromise(wx.openLocation, config).then(res => {
+					resolve(res);
+				}).catch(err => {
+					reject(err);
+				});
+			}).catch(err => {
+				reject(err);
+			})
+		});
+	}
+
+	/**
+	 * 微信支付
+	 * @param {Object} config
+	 */
+	pay(config) {
+		return new Promise((resolve, reject) => {
+			this.wechat().then((wx) => {
+				this.toPromise(wx.chooseWXPay, config).then(res => {
+					resolve(res);
+				}).catch(res => {
+					resolve(res);
+				});
+			}).catch(res => {
+				reject(res);
+			});
+		});
+	}
+
+	toPromise(fn, config = {}) {
+		return new Promise((resolve, reject) => {
+			fn({
+				...config,
+				success(res) {
+					resolve(res);
+				},
+				fail(err) {
+					reject(err);
+				},
+				complete(err) {
+					reject(err);
+				},
+				cancel(err) {
+					reject(err);
+				}
+			});
+		});
+	}
+
+	/**
+	 * 自动去授权
+	 */
+	oAuth(snsapiBase, url) {
+		if (uni.getStorageSync(WX_AUTH) && store.state.app.token && snsapiBase == 'snsapi_base') return;
+		const {
+			code
+		} = parseQuery();
+		if (!code || code == uni.getStorageSync('snsapiCode')) {
+			return this.toAuth(snsapiBase, url);
+		} else {
+			if (Cache.has('snsapiKey'))
+				return this.auth(code).catch(error => {
+					uni.showToast({
+						title: error,
+						icon: 'none'
+					})
+				})
+		}
+		// if (uni.getStorageSync(WX_AUTH) && store.state.app.token) return;
+		// const {
+		// 	code
+		// } = parseQuery();
+		// if (!code){
+		// 	return this.toAuth(snsapiBase,url);
+		// }else{
+		// 	if(Cache.has('snsapiKey'))
+		// 		return this.auth(code).catch(error=>{
+		// 			uni.showToast({
+		// 				title:error,
+		// 				icon:'none'
+		// 			})
+		// 		})
+		// }
+	}
+
+	clearAuthStatus() {
+
+	}
+
+	/**
+	 * 授权登录获取token
+	 * @param {Object} code
+	 */
+	auth(code) {
+		return new Promise((resolve, reject) => {
+			wechatAuth(code, Cache.get("spread"))
+				.then(({
+					data
+				}) => {
+					resolve(data);
+					Cache.set(WX_AUTH, code);
+					Cache.clear(STATE_KEY);
+					// Cache.clear('spread');
+					loginType && Cache.clear(LOGINTYPE);
+
+				})
+				.catch(reject);
+		});
+	}
+
+	/**
+	 * 获取跳转授权后的地址
+	 * @param {Object} appId
+	 */
+	getAuthUrl(appId, snsapiBase, backUrl) {
+		if (backUrl.includes("/pages")) {
+			backUrl = "/front/#" + backUrl;
+		}
+		let url = `${location.origin}${backUrl}`
+		if (url.indexOf('?') == -1) {
+			url = url + '?'
+		} else {
+			url = url + '&'
+		}
+		const redirect_uri = encodeURIComponent(
+			`${url}scope=${snsapiBase}&back_url=` +
+			encodeURIComponent(
+				encodeURIComponent(
+					uni.getStorageSync(BACK_URL) ?
+					uni.getStorageSync(BACK_URL) :
+					location.pathname + location.search
+				)
+			)
+		);
+		uni.removeStorageSync(BACK_URL);
+		const state = encodeURIComponent(
+			("" + Math.random()).split(".")[1] + "authorizestate"
+		);
+		uni.setStorageSync(STATE_KEY, state);
+		return `https://open.weixin.qq.com/connect/oauth2/authorize?appid=${appId}&redirect_uri=${redirect_uri}&response_type=code&scope=snsapi_userinfo&state=${state}#wechat_redirect`;
+		// if(snsapiBase==='snsapi_base'){
+		// 	return `https://open.weixin.qq.com/connect/oauth2/authorize?appid=${appId}&redirect_uri=${redirect_uri}&response_type=code&scope=snsapi_base&state=${state}#wechat_redirect`;
+		// }else{
+		// 	return `https://open.weixin.qq.com/connect/oauth2/authorize?appid=${appId}&redirect_uri=${redirect_uri}&response_type=code&scope=snsapi_userinfo&state=${state}#wechat_redirect`;
+		// }
+	}
+
+	/**
+	 * 跳转自动登录
+	 */
+	toAuth(snsapiBase, backUrl) {
+		let that = this;
+		this.wechat().then(wx => {
+
+			location.href = this.getAuthUrl(that.initConfig.appId, snsapiBase,
+				backUrl);
+		})
+	}
+
+	/**
+	 * 绑定事件
+	 * @param {Object} name 事件名
+	 * @param {Object} config 参数
+	 */
+	wechatEvevt(name, config) {
+		let that = this;
+		return new Promise((resolve, reject) => {
+			let configDefault = {
+				fail(res) {
+					if (that.instance) return reject({
+						is_ready: true,
+						wx: that.instance
+					});
+					that.verifyInstance().then(wx => {
+						return reject({
+							is_ready: true,
+							wx: wx
+						});
+					})
+				},
+				success(res) {
+					return resolve(res, 2222);
+				}
+			};
+			Object.assign(configDefault, config);
+			that.wechat().then(wx => {
+				if (typeof name === 'object') {
+					name.forEach(item => {
+						wx[item] && wx[item](configDefault)
+					})
+				} else {
+					wx[name] && wx[name](configDefault)
+				}
+			})
+		});
+	}
+
+	isWeixin() {
+		return navigator.userAgent.toLowerCase().indexOf("micromessenger") !== -1;
+	}
+
+}
+
+export default new AuthWechat();
+// #endif