feat: 定时更新用户权限

src/composables/index.ts

@@ -1,4 +1,5 @@
 export * from './alarm';
 export * from './device';
+export * from './permission';
 export * from './query';
 export * from './stomp';

src/composables/query/index.ts

@@ -1,5 +1,6 @@
 export * from './use-line-alarms-query';
 export * from './use-line-devices-query';
 export * from './use-line-stations-query';
+export * from './use-user-permissions-query';
 export * from './use-verify-user-query';
 export * from './use-version-check-query';

src/composables/query/use-user-permissions-query.ts

@@ -0,0 +1,55 @@
+import { pagePermissionApi } from '@/apis';
+import { USER_PERMISSIONS_QUERY_KEY } from '@/constants';
+import { PERMISSION_TYPE_NAMES } from '@/enums';
+import { usePermissionStore, useSettingStore, useStationStore, useUserStore } from '@/stores';
+import { useQuery, useQueryClient } from '@tanstack/vue-query';
+import { storeToRefs } from 'pinia';
+import { computed, watch } from 'vue';
+
+export const useUserPermissionsQuery = () => {
+  const queryClient = useQueryClient();
+
+  const settingStore = useSettingStore();
+  const { offlineDev } = storeToRefs(settingStore);
+
+  const stationStore = useStationStore();
+  const { stations } = storeToRefs(stationStore);
+  const userStore = useUserStore();
+  const { userInfo } = storeToRefs(userStore);
+  const permissionStore = usePermissionStore();
+
+  watch(offlineDev, (offline) => {
+    if (offline) {
+      queryClient.cancelQueries({ queryKey: [USER_PERMISSIONS_QUERY_KEY] });
+    }
+  });
+
+  return useQuery({
+    queryKey: computed(() => [USER_PERMISSIONS_QUERY_KEY]),
+    enabled: computed(() => !offlineDev.value),
+    refetchInterval: 10 * 1000,
+    queryFn: async ({ signal }) => {
+      const { employeeId } = userInfo.value ?? {};
+      if (!employeeId) return null;
+
+      const { records } = await pagePermissionApi(
+        {
+          model: {
+            employeeId,
+          },
+          extra: {},
+          current: 1,
+          size: Object.keys(PERMISSION_TYPE_NAMES).length * stations.value.length,
+          sort: 'id',
+          order: 'ascending',
+        },
+        {
+          signal,
+        },
+      );
+      permissionStore.setPermRecords(records);
+
+      return null;
+    },
+  });
+};