MTP2.0_WEB/src/services/bus/index.ts

import APP from '@/services';
import { isLogin } from '@/services/bus/login';
import { checkTokenLoop, handleTokenCheck } from '@/services/bus/token';
import { GetPCMenus, getServerTime, queryErrorInfos, QueryTableDefine } from '@/services/go/commonService/index';
import { getAppConfig, getCommonApiUrl } from '@/services/go/config';
import { LoginQuery } from '@/services/go/useInfo/index';
import { setServiceURL } from '@/services/request/serviceURL';
import ProtobufCtr from '@/services/socket/protobuf/index';
import { localStorageUtil } from '@/utils/storage';
import { message } from 'ant-design-vue';

/**
 * 全局数据刷新
 */
export async function globalDataRefresh(): Promise<string> {
    // 全局初始化依赖查询
    await queryDependencies();
    try {
        // 首先判断是否登录 如果没有登录不需要长链
        if (isLogin()) {
            // 获取服务时间，token校验需要用到
            await getServerTime();
            await LoginQuery();
            // 建立行情交易长链x
            await APP.connectTrading();

            // token 校验处理
            const res = await handleTokenCheck()
                .then(() => true)
                .catch(() => false);
            if (!res) {
                // Router.push({ path: '/login' }); // 回到登录页面
                return Promise.reject('刷新时token校验失败');
            } else {
                // token校验成功 马上轮询
                checkTokenLoop();
                await GetPCMenus();
                await QueryTableDefine();
            }
        } else {
            // 重置数据中心数据
            APP.reset();
        }

        if (!localStorageUtil.getItem('errorCodeInfos')) {
            await queryErrorInfos();
        }

        // await queryGoodsList();
        return Promise.resolve('ok');
    } catch (error) {
        return Promise.reject('刷新数据加载失败');
    }
}

/**
 * 全局依赖的数据查询，涉及各个方面
 */
async function queryDependencies(): Promise<number> {
    try {
        // 加载proto文件
        await ProtobufCtr.loadProto('./proto/mtp.proto');
        /** 获取接口查询配置信息 */
        const config = await getAppConfig();
        const apiUrl = await getCommonApiUrl(config.data.apiUrl);

        if (apiUrl.data.code === 200) setServiceURL(apiUrl.data.data);

        // await APP.connectQuote();
        /** 数据返回 */
        return Promise.resolve(1);
    } catch (error) {
        message.error(error.message);
        return Promise.reject(error);
    }
}