智能控制中心，出版发布

vue/apps/web-antd/src/api/core/auth.ts

@@ -0,0 +1,69 @@
+import { sha256 } from 'js-sha256';
+
+import { baseRequestClient, requestClient } from '#/api/request';
+
+export namespace AuthApi {
+  /** 登录接口参数 */
+  export interface LoginParams {
+    account?: string;
+    password?: string;
+  }
+
+  export interface Token {
+    token: string;
+    expiresAt: number;
+    expiresStr: string;
+  }
+
+  /** 登录接口返回值 */
+  export interface LoginResult {
+    userId: string;
+    accessToken: Token;
+    refreshToken: Token;
+  }
+
+  export interface RefreshTokenResult {
+    data: string;
+    status: number;
+  }
+}
+
+/**
+ * 登录
+ */
+export async function loginApi(data: AuthApi.LoginParams) {
+  // 密码加密
+  data.password = sha256(data.password?.toString() || '');
+  // 去掉data中的username参数
+  delete data.username;
+  return requestClient.post<AuthApi.LoginResult>('/user/login', data);
+}
+
+/**
+ * 刷新accessToken
+ */
+export async function refreshTokenApi() {
+  return baseRequestClient.post<AuthApi.RefreshTokenResult>(
+    '/user/refreshToken',
+    {
+      withCredentials: true,
+    },
+  );
+}
+
+/**
+ * 退出登录
+ */
+export async function logoutApi() {
+  return baseRequestClient.post('/auth/logout', {
+    withCredentials: true,
+  });
+}
+
+/**
+ * 获取用户权限码
+ */
+export async function getAccessCodesApi() {
+  // return requestClient.get<string[]>('/auth/codes');
+  return [];
+}

vue/apps/web-antd/src/api/core/index.ts

@@ -0,0 +1,4 @@
+export * from './auth';
+export * from './menu';
+export * from './remote';
+export * from './user';

vue/apps/web-antd/src/api/core/menu.ts

@@ -0,0 +1,10 @@
+import type { RouteRecordStringComponent } from '@vben/types';
+
+import { requestClient } from '#/api/request';
+
+/**
+ * 获取用户所有菜单
+ */
+export async function getAllMenusApi() {
+  return requestClient.get<RouteRecordStringComponent[]>('/menu/all');
+}

vue/apps/web-antd/src/api/core/remote.ts

@@ -0,0 +1,24 @@
+import { requestClient } from '#/api/request';
+
+/**
+ * 获取在线设备列表数据
+ */
+export async function refreshDeviceList() {
+  return requestClient.get('/remote/refreshDeviceList');
+}
+
+/**
+ * 按照端口连接设备
+ */
+export async function connectDeviceByPort(port: string) {
+  return requestClient.get('/remote/connectLocalDevice', {
+    params: { port },
+  });
+}
+
+/**
+ * 断开连接
+ */
+export async function disConnectAll() {
+  return requestClient.get('/remote/disConnectAll');
+}

vue/apps/web-antd/src/api/core/user.ts

@@ -0,0 +1,15 @@
+import type { UserInfo } from '@vben/types';
+
+import { requestClient } from '#/api/request';
+
+/**
+ * 获取用户信息
+ */
+export async function getUserInfoApi() {
+  return requestClient.get<UserInfo>('/user/getUserInfo');
+}
+// export async function getUserInfoApi(user_id: string) {
+//   return requestClient.get<UserInfo>('/user/getUserInfo', {
+//     params: { user_id },
+//   });
+// }

vue/apps/web-antd/src/api/index.ts

@@ -0,0 +1 @@
+export * from './core';

vue/apps/web-antd/src/api/model/remote.ts

@@ -0,0 +1,12 @@
+/** 用户信息 */
+interface DeviceItem {
+  /**
+   * 设备名
+   */
+  deviceName: string;
+  /**
+   * 设备端口
+   */
+  devicePort: string;
+}
+export type { DeviceItem };

vue/apps/web-antd/src/api/request.ts

@@ -0,0 +1,113 @@
+/**
+ * 该文件可自行根据业务逻辑进行调整
+ */
+import type { RequestClientOptions } from '@vben/request';
+
+import { useAppConfig } from '@vben/hooks';
+import { preferences } from '@vben/preferences';
+import {
+  authenticateResponseInterceptor,
+  defaultResponseInterceptor,
+  errorMessageResponseInterceptor,
+  RequestClient,
+} from '@vben/request';
+import { useAccessStore } from '@vben/stores';
+
+import { message } from 'ant-design-vue';
+
+import { useAuthStore } from '#/store';
+
+import { refreshTokenApi } from './core';
+
+const { apiURL } = useAppConfig(import.meta.env, import.meta.env.PROD);
+
+function createRequestClient(baseURL: string, options?: RequestClientOptions) {
+  const client = new RequestClient({
+    ...options,
+    baseURL,
+  });
+
+  /**
+   * 重新认证逻辑
+   */
+  async function doReAuthenticate() {
+    console.warn('Access token or refresh token is invalid or expired. ');
+    const accessStore = useAccessStore();
+    const authStore = useAuthStore();
+    accessStore.setAccessToken(null);
+    if (
+      preferences.app.loginExpiredMode === 'modal' &&
+      accessStore.isAccessChecked
+    ) {
+      accessStore.setLoginExpired(true);
+    } else {
+      await authStore.logout();
+    }
+  }
+
+  /**
+   * 刷新token逻辑
+   */
+  async function doRefreshToken() {
+    const accessStore = useAccessStore();
+    const resp = await refreshTokenApi();
+    const newToken = resp.data;
+    accessStore.setAccessToken(newToken);
+    return newToken;
+  }
+
+  function formatToken(token: null | string) {
+    return token ? `Bearer ${token}` : null;
+  }
+
+  // 请求头处理
+  client.addRequestInterceptor({
+    fulfilled: async (config) => {
+      const accessStore = useAccessStore();
+
+      config.headers.Authorization = formatToken(accessStore.accessToken);
+      config.headers['Accept-Language'] = preferences.app.locale;
+      return config;
+    },
+  });
+
+  // 处理返回的响应数据格式
+  client.addResponseInterceptor(
+    defaultResponseInterceptor({
+      codeField: 'status',
+      dataField: 'data',
+      successCode: true,
+    }),
+  );
+
+  // token过期的处理
+  client.addResponseInterceptor(
+    authenticateResponseInterceptor({
+      client,
+      doReAuthenticate,
+      doRefreshToken,
+      enableRefreshToken: preferences.app.enableRefreshToken,
+      formatToken,
+    }),
+  );
+
+  // 通用的错误处理,如果没有进入上面的错误处理逻辑，就会进入这里
+  client.addResponseInterceptor(
+    errorMessageResponseInterceptor((msg: string, error) => {
+      // 这里可以根据业务进行定制,你可以拿到 error 内的信息进行定制化处理，根据不同的 code 做不同的提示，而不是直接使用 message.error 提示 msg
+      // 当前mock接口返回的错误字段是 error 或者 message
+      const responseData = error?.response?.data ?? {};
+      const errorMessage = responseData?.error ?? responseData?.message ?? '';
+      // 如果没有错误信息，则会根据状态码进行提示
+      message.error(errorMessage || msg);
+    }),
+  );
+
+  return client;
+}
+
+export const requestClient = createRequestClient(apiURL, {
+  responseReturn: 'data',
+});
+
+export const baseRequestClient = new RequestClient({ baseURL: apiURL });