import axios, { InternalAxiosRequestConfig, AxiosResponse } from 'axios';
import { ElMessage, ElMessageBox, type MessageHandler } from 'element-plus';
import { get_cookie } from './index';
import { get_id, get_type } from '@/utils/common';
// 提示拦截
let messageInstance: MessageHandler;
const message_error = (info: string) => {
    if (messageInstance) {
        messageInstance.close();
    }
    messageInstance = ElMessage.error({
        type: 'error',
        message: info,
        duration: 30000,
        showClose: true,
    });
};

// 创建一个状态变量来跟踪是否已经弹出了退出登录的弹窗
const isLogoutModalShown = ref(true);

// 用于存储每个请求的CancelToken
const pendingRequests = new Map();
// 不需要认证的接口
const release_url = ['attachmentapi/upload'];
// 创建 axios 实例
const index = window.location.href.lastIndexOf('.php');
let pro_url = window.location.origin;
if (index !== -1) {
    pro_url = window.location.href.substring(0, index) + '.php';
}
const service = axios.create({
    baseURL: import.meta.env.VITE_APP_BASE_API == '/dev-admin' ? import.meta.env.VITE_APP_BASE_API : pro_url + '?s=',
    timeout: 60000,
    headers: { 'Content-Type': 'application/json;charset=utf-8', 'X-Requested-With': 'XMLHttpRequest' },
});
/** @ts-ignore  */
// 请求拦截器
service.interceptors.request.use(
    async (config: InternalAxiosRequestConfig) => {
        const symbol = config.url?.includes('?') ? '&' : '?';
        if (import.meta.env.VITE_APP_BASE_API == '/dev-admin') {
            let temp_data = await import(import.meta.env.VITE_APP_BASE_API == '/dev-admin' ? '../../temp.d' : '../../temp_pro.d');
            config.url = config.url + symbol + 'token=' + temp_data.default.temp_token;
        } else {
            // 如果是shop认为是多商户插件使用user_info的cookie
            const cookie = get_type() == 'shop' ? get_cookie('user_info') : get_cookie('admin_info');
            if (cookie && cookie !== null && cookie !== 'null') {
                config.url = config.url + '&token=' + (JSON.parse(cookie) !== 'null' ? JSON.parse(cookie)?.token : '');
            }
        }
        // 添加diy_id和diy_type参数
        config.url = `${config.url}&diy_id=${ get_id() }&diy_type=${ get_type() }`;
        // 判断是否是包含不需要认证的接口
        const release_list = release_url.filter(item => config.url?.includes(item));
        if (release_list.length === 0) {
            // 检查是否有相同请求正在进行，如果有则取消, 防止重复请求导致返回数据有误
            if (pendingRequests.has(config.url)) {
                const cancelToken = pendingRequests.get(config.url);
                cancelToken.cancel('canceled');
                pendingRequests.delete(config.url);
            }
            // 创建一个新的 CancelToken
            const source = axios.CancelToken.source();
            config.cancelToken = source.token;
            pendingRequests.set(config.url, source);
        }
        return config;
    },
    (error: any) => {
        return Promise.reject(error);
    }
);
// 响应拦截器
service.interceptors.response.use(
    (response: AxiosResponse) => {
        // 请求完成后，从pendingRequests中移除
        pendingRequests.delete(response.config.url);

        const { code, msg, message, data } = response.data;
        if (code == 0) {
            return response.data;
        } else if (code == -400) {
            if (isLogoutModalShown.value) {
                isLogoutModalShown.value = false;
                ElMessageBox.alert(msg, '温馨提示', {
                    confirmButtonText: '确定',
                    showClose: false,
                    type: 'warning',
                }).then(() => {
                    localStorage.clear(); // @vueuse/core 自动导入
                    window.location.href = data.logout;
                });
            }
        } else {
            message_error(msg || message || '系统出错');
            return Promise.reject(msg || message || '系统出错');
            // return Promise.reject(new Error(msg || 'Error'));
        }
    },
    (error: any) => {
        if (error.response && error.response.data) {
            const { msg, message } = error.response.data;
            message_error(msg || message || '系统出错');
        } else if (error.message == 'canceled') {
            console.log('请求已取消');
        } else {
            message_error(error.message);
        }
        return Promise.reject(error.msg || error.message);
    }
);

// 导出 axios 实例
export default service;