{/* 左侧四个切换tab */}
@@ -476,8 +476,8 @@ function HomeModule5() {
throw new Error("create checkout session failed");
}
- setShowCallbackModal(true)
- window.open(result.data.checkout_url, '_blank');
+ setShowCallbackModal(true);
+ window.open(result.data.checkout_url, "_blank");
} catch (error) {
throw new Error("create checkout session failed, please try again later");
}
@@ -518,7 +518,7 @@ function HomeModule5() {
Yearly - 10%
-
+
{/* 主要价格卡片 */}
diff --git a/lib/auth.ts b/lib/auth.ts
index 1e111fa..b411296 100644
--- a/lib/auth.ts
+++ b/lib/auth.ts
@@ -1,10 +1,11 @@
import { BASE_URL } from "@/api/constants";
+import { post } from "@/api/request";
// API配置
-const API_BASE_URL = process.env.NEXT_PUBLIC_API_BASE_URL || '';
-
+const API_BASE_URL = process.env.NEXT_PUBLIC_BASE_URL || '';
+const JAVA_BASE_URL = process.env.NEXT_PUBLIC_JAVA_URL || '';
// Token存储键
-const TOKEN_KEY = 'X-EASE-ADMIN-TOKEN';
+const TOKEN_KEY = 'token';
const USER_KEY = 'currentUser';
/**
@@ -12,37 +13,26 @@ const USER_KEY = 'currentUser';
*/
export const loginUser = async (email: string, password: string) => {
try {
- const response = await fetch(`${API_BASE_URL}/admin/login/signIn`, {
+ const response = await fetch(`${JAVA_BASE_URL}/api/user/login`, {
method: 'POST',
headers: {
'Accept': 'application/json',
'Content-Type': 'application/json',
},
body: JSON.stringify({
- userName: email,
+ username: email,
password: password,
}),
});
const data = await response.json();
+ console.log('data', data)
+ // 保存token到本地存储
+ setToken(data.token);
- if (data.code === '200' && data.status === 200) {
- // 保存token到本地存储
- setToken(data.body.token);
+ const user = await getUserProfile();
- // 保存用户信息
- const user = {
- id: data.body.userId,
- name: data.body.userName,
- email: email,
- token: data.body.token,
- };
- setUser(user);
-
- return user;
- } else {
- throw new Error(data.msg || '登录失败');
- }
+ return user;
} catch (error) {
console.error('Login failed:', error);
throw error;
@@ -59,7 +49,7 @@ export const checkAuth = async (): Promise
=> {
}
try {
- const response = await fetch(`${API_BASE_URL}/admin/login/auth`, {
+ const response = await fetch(`${process.env.NEXT_PUBLIC_API_BASE_URL}/admin/login/auth`, {
method: 'POST',
headers: {
'Accept': 'application/json',
@@ -69,14 +59,14 @@ export const checkAuth = async (): Promise => {
});
const data = await response.json();
+ return true;
+ // if (data.code === '401' || data.status === 401) {
+ // // Token无效，清除本地存储
+ // // clearAuthData();
+ // // return false;
+ // }
- if (data.code === '401' || data.status === 401) {
- // Token无效，清除本地存储
- clearAuthData();
- return false;
- }
-
- return data.code === '200' && data.status === 200;
+ // return data.code === '200' && data.status === 200;
} catch (error) {
console.error('Auth check failed:', error);
return false;
@@ -250,3 +240,148 @@ export const validateOAuthState = (state: string): boolean => {
// Validate that the returned state matches what we stored
return state === storedState;
};
+
+/**
+ * 获取用户信息
+ * @returns {Promise} 用户信息对象
+ */
+export const getUserProfile = async (): Promise => {
+ try {
+ const token = getToken();
+ if (!token) {
+ throw new Error('No token available');
+ }
+
+ const response = await fetch(`${API_BASE_URL}/java-auth/profile`, {
+ method: 'GET',
+ headers: {
+ 'Accept': 'application/json',
+ 'Content-Type': 'application/json',
+ 'Authorization': `Bearer ${token}`,
+ },
+ });
+
+ if (!response.ok) {
+ throw new Error(`HTTP error! status: ${response.status}`);
+ }
+
+ const data = await response.json();
+
+ if (data.code === 0 && data.successful) {
+ // 更新本地存储的用户信息
+ const userInfo = {
+ id: data.data.user_id,
+ userId: data.data.user_id,
+ username: data.data.username,
+ name: data.data.name,
+ email: data.data.email,
+ role: data.data.role,
+ isActive: data.data.is_active,
+ authType: data.data.auth_type,
+ lastLogin: data.data.last_login,
+ };
+
+ setUser(userInfo);
+ return userInfo;
+ } else {
+ throw new Error(data.message || 'Failed to get user profile');
+ }
+ } catch (error) {
+ console.error('Get user profile failed:', error);
+ throw error;
+ }
+};
+
+/**
+ * 刷新用户信息
+ * @returns {Promise} 最新的用户信息
+ */
+export const refreshUserProfile = async (): Promise => {
+ try {
+ const profile = await getUserProfile();
+ return profile;
+ } catch (error) {
+ console.error('Refresh user profile failed:', error);
+ // 如果刷新失败，返回本地存储的用户信息
+ return getCurrentUser();
+ }
+};
+
+/**
+ * 检查用户权限
+ * @param {string} requiredRole 需要的角色权限
+ * @returns {boolean} 是否有权限
+ */
+export const checkUserPermission = (requiredRole: string): boolean => {
+ const user = getCurrentUser();
+ if (!user || !user.role) {
+ return false;
+ }
+
+ // 角色权限等级
+ const roleHierarchy = {
+ 'ADMIN': 3,
+ 'MODERATOR': 2,
+ 'USER': 1,
+ };
+
+ const userRoleLevel = roleHierarchy[user.role as keyof typeof roleHierarchy] || 0;
+ const requiredRoleLevel = roleHierarchy[requiredRole as keyof typeof roleHierarchy] || 0;
+
+ return userRoleLevel >= requiredRoleLevel;
+};
+
+/**
+ * 检查用户是否激活
+ * @returns {boolean} 用户是否激活
+ */
+export const isUserActive = (): boolean => {
+ const user = getCurrentUser();
+ return user?.isActive === 1;
+};
+/**
+ * 用户注册
+ * @param {Object} params - 注册参数
+ * @param {string} params.userName - 用户名
+ * @param {string} params.password - 密码
+ * @param {string} params.email - 邮箱
+ * @param {string} [params.inviteCode] - 邀请码（可选）
+ * @returns {Promise} 注册结果
+ * @throws {Error} 注册失败时抛出异常
+ */
+export const registerUser = async ({
+ userName,
+ password,
+ email,
+ inviteCode,
+}: {
+ userName: string;
+ password: string;
+ email: string;
+ inviteCode?: string;
+}): Promise => {
+ try {
+ const response = await fetch(`${JAVA_BASE_URL}/api/user/register`, {
+ method: 'POST',
+ headers: {
+ 'Accept': 'application/json',
+ 'Content-Type': 'application/json',
+ },
+ body: JSON.stringify({
+ userName,
+ password,
+ email,
+ inviteCode,
+ }),
+ });
+
+ const data = await response.json();
+
+ return data as {
+ success: boolean;
+ };
+ } catch (error) {
+ console.error('Register failed:', error);
+ throw error;
+ }
+};