client-app/App.vue

<script>
    import {useAppStore} from "@/store";
    import website from "@/config/index";
    import userApi from '~api/user/index';
    import {getStorage, setStorage, delStorage} from "@/utils/storage";
    import {calcDate, getObjValue, isNullES, isString} from "js-fast-way";
    import {getWssApiUrl} from "@/config/envApi";
	export default {
        data() {
            return {
                userInfo: {}, refreshLock: false, isSocket: false, timeId: null,
            }
        },
		onLaunch() {
            this.setInitSocket()
		},
		onShow() {
			//console.log('App Show')
		},
		onHide() {
			//console.log('App Hide')
		},
        mounted() {
            const store = useAppStore()
            this.userInfo = store.userInfo
            this.getRefreshToken()
        },
        methods:{
            //刷新token
            getRefreshToken() {
                let _this = this;
                setInterval(() => {
                    const token = getStorage('token', true)
                    const date = calcDate(token.datetime, new Date().getTime())
                    if (isNullES(date)) return false;
                    if (date.seconds >= website.tokenTime && !this.refreshLock) {
                        this.refreshLock = true
                        console.log('刷新token')
                        this.refreshTokenApi().then(() => {
                            _this.refreshLock = false
                        }).catch(() => {
                            _this.refreshLock = false
                            uni.reLaunch({
                                url: '/pages/login/login'
                            });
                        })
                    }
                }, 10000)
            },
            async refreshTokenApi() {
                const store = useAppStore()
                const { dept_id, role_id, tenant_id } = this.userInfo
                const refreshToken = getStorage('refreshToken')
                const {error, status, res} = await userApi.refreshToken({
                    token: refreshToken,
                    tenantId: tenant_id,
                    deptId: dept_id,
                    roleId: role_id
                });
                if (!error && status === 200) {
                    const data = getObjValue(res)
                    setStorage('token', data?.access_token)
                    setStorage('refreshToken', data?.refresh_token)
                    store.setUserInfo(res)
                    return Promise.resolve(res)
                } else {
                    return Promise.reject(res)
                }
            },
            //长连接
            setInitSocket() {
                this.timeId = setInterval(() => {
                    if (this.isSocket) {
                        clearInterval(this.timeId)
                    } else {
                        this.setAppSocket()
                    }
                    console.log('setInterval')
                }, 3000)
            },
            setAppSocket() {
                const {user_id} = this.userInfo
                if (user_id) {
                    this.initWebSocket(user_id)
                }
            },
            initWebSocket(user_id) {
                const _this = this, store = useAppStore()
                let startTime = 0;
                uni.connectSocket({
                    url: getWssApiUrl() + user_id,
                    complete: ()=> {
                        startTime = new Date()
                        _this.isSocket = true
                        console.log('websocket链接成功')
                    }
                });
                uni.onSocketOpen((res) => {
                    console.log('WebSocket连接已打开！');
                    _this.sendSocketMessage();
                });
                uni.onSocketError((res) => {
                    console.log('WebSocket连接失败，请检查！');
                });
                uni.onSocketClose((res) => {
                    console.log('WebSocket 已关闭！');
                    //关闭后在连接
                    const endTime = new Date()
                    const duration = endTime - startTime
                    if(duration > 1000) {
                        _this.isSocket = false
                        //_this.setAppSocket()
                    }
                });
                //收到的消息
                uni.onSocketMessage(({data}) => {
                    const countData = isString(data) ? JSON.parse(data) : {}
                    if (!isNullES(countData)) {
                        console.log(countData)
                        store.setMsgCountData(countData)
                    }
                });
            },
            sendSocketMessage() {
                const store = useAppStore()
                uni.sendSocketMessage({
                    data: store.projectId + ',' + store.contractId
                });
            },
        }
	}
</script>

<style lang="scss">
@import "@/colorui/main.css";
@import "@/colorui/icon.css";
@import "@/style/app.scss";
</style>