chat-backend/takai-ai/src/main/java/com/takai/ai/service/impl/MinioConfigServiceImpl.java

package com.takai.ai.service.impl;

import com.takai.ai.domain.TakaiSysOssConfig;
import com.takai.ai.mapper.TakaiSysOssConfigMapper;
import com.takai.ai.service.IMinioConfigService;
import com.takai.common.annotation.DataSource;
import com.takai.common.enums.DataSourceType;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;

@Service
@DataSource(DataSourceType.MASTER)
public class MinioConfigServiceImpl implements IMinioConfigService {

    @Autowired
    private TakaiSysOssConfigMapper takaiSysOssConfigMapper;

    private TakaiSysOssConfig currentConfig;

    @PostConstruct
    public void init() {
        refreshConfig();
    }

    @Override
    public TakaiSysOssConfig getCurrentConfig() {
        return currentConfig;
    }

    @Override
    public void refreshConfig() {
        this.currentConfig = takaiSysOssConfigMapper.selectByOssConfigId("1");
        if (this.currentConfig == null) {
            throw new IllegalStateException("未找到可用的MinIO配置");
        }
    }
}