162 lines
3.8 KiB
TypeScript
162 lines
3.8 KiB
TypeScript
// 基础请求工具函数
|
||
|
||
import { API_CONFIG } from './config';
|
||
|
||
// 请求选项接口
|
||
export interface RequestOptions {
|
||
method?: 'GET' | 'POST' | 'PUT' | 'DELETE';
|
||
headers?: Record<string, string>;
|
||
body?: any;
|
||
timeout?: number;
|
||
}
|
||
|
||
// 自定义错误类
|
||
export class ApiError extends Error {
|
||
status?: number;
|
||
data?: any;
|
||
|
||
constructor(message: string, status?: number, data?: any) {
|
||
super(message);
|
||
this.name = 'ApiError';
|
||
this.status = status;
|
||
this.data = data;
|
||
}
|
||
}
|
||
|
||
// 基础请求函数
|
||
export async function request<T = any>(
|
||
url: string,
|
||
options: RequestOptions = {}
|
||
): Promise<T> {
|
||
const {
|
||
method = 'GET',
|
||
headers = {},
|
||
body,
|
||
timeout = API_CONFIG.TIMEOUT,
|
||
} = options;
|
||
|
||
const fullUrl = url.startsWith('http') ? url : `${API_CONFIG.BASE_URL}${url}`;
|
||
|
||
const controller = new AbortController();
|
||
const timeoutId = setTimeout(() => controller.abort(), timeout);
|
||
|
||
try {
|
||
const requestHeaders: Record<string, string> = {
|
||
...API_CONFIG.HEADERS,
|
||
...headers,
|
||
};
|
||
|
||
let requestBody: string | FormData | undefined;
|
||
|
||
if (body instanceof FormData) {
|
||
// 对于 FormData，不设置 Content-Type，让浏览器自动设置
|
||
delete requestHeaders['Content-Type'];
|
||
requestBody = body;
|
||
} else if (body) {
|
||
requestBody = JSON.stringify(body);
|
||
}
|
||
|
||
const response = await fetch(fullUrl, {
|
||
method,
|
||
headers: requestHeaders,
|
||
body: requestBody,
|
||
signal: controller.signal,
|
||
});
|
||
|
||
clearTimeout(timeoutId);
|
||
|
||
if (!response.ok) {
|
||
let errorData: any;
|
||
try {
|
||
errorData = await response.json();
|
||
} catch {
|
||
errorData = { message: response.statusText };
|
||
}
|
||
|
||
throw new ApiError(
|
||
errorData.message || `HTTP ${response.status}: ${response.statusText}`,
|
||
response.status,
|
||
errorData
|
||
);
|
||
}
|
||
|
||
// 检查响应是否有内容
|
||
const contentType = response.headers.get('content-type');
|
||
if (contentType && contentType.includes('application/json')) {
|
||
return await response.json();
|
||
} else {
|
||
// 如果没有 JSON 内容，返回空对象
|
||
return {} as T;
|
||
}
|
||
} catch (error) {
|
||
clearTimeout(timeoutId);
|
||
|
||
if (error instanceof ApiError) {
|
||
throw error;
|
||
}
|
||
|
||
if (error instanceof Error) {
|
||
if (error.name === 'AbortError') {
|
||
throw new ApiError('请求超时', 408);
|
||
}
|
||
throw new ApiError(error.message);
|
||
}
|
||
|
||
throw new ApiError('未知错误');
|
||
}
|
||
}
|
||
|
||
// GET 请求
|
||
export function get<T = any>(url: string, params?: Record<string, any>): Promise<T> {
|
||
let fullUrl = url;
|
||
|
||
if (params) {
|
||
const searchParams = new URLSearchParams();
|
||
Object.entries(params).forEach(([key, value]) => {
|
||
if (value !== undefined && value !== null) {
|
||
searchParams.append(key, String(value));
|
||
}
|
||
});
|
||
|
||
const queryString = searchParams.toString();
|
||
if (queryString) {
|
||
fullUrl += (url.includes('?') ? '&' : '?') + queryString;
|
||
}
|
||
}
|
||
|
||
return request<T>(fullUrl, { method: 'GET' });
|
||
}
|
||
|
||
// POST 请求
|
||
export function post<T = any>(url: string, data?: any, options?: Partial<RequestOptions>): Promise<T> {
|
||
return request<T>(url, {
|
||
method: 'POST',
|
||
body: data,
|
||
...options,
|
||
});
|
||
}
|
||
|
||
// PUT 请求
|
||
export function put<T = any>(url: string, data?: any): Promise<T> {
|
||
return request<T>(url, {
|
||
method: 'PUT',
|
||
body: data,
|
||
});
|
||
}
|
||
|
||
// DELETE 请求
|
||
export function del<T = any>(url: string): Promise<T> {
|
||
return request<T>(url, { method: 'DELETE' });
|
||
}
|
||
|
||
// 文件上传请求
|
||
export function upload<T = any>(url: string, file: File, fieldName = 'file', options?: Partial<RequestOptions>): Promise<T> {
|
||
const formData = new FormData();
|
||
formData.append(fieldName, file);
|
||
|
||
return request<T>(url, {
|
||
method: 'POST',
|
||
body: formData,
|
||
...options,
|
||
});
|
||
} |