feat：

tr-modules/tr-module-system/src/main/java/cn/tr/module/sys/storage/controller/StorageFileController.java

@@ -32,7 +32,7 @@ public class StorageFileController {
     public CommonResult<SysStorageRecordDTO> uploadFile(@RequestParam MultipartFile file,
                                                         @RequestParam(required = false) String configId,
                                                         @RequestParam(required = false) String cateId) throws Exception {
-        return CommonResult.success(fileService.upload(cateId,configId,file.getOriginalFilename(), IoUtil.readBytes(file.getInputStream())));
+        return CommonResult.success(fileService.upload(configId,cateId,file.getOriginalFilename(), IoUtil.readBytes(file.getInputStream())));
     }
 
     @ApiOperationSupport(author = "lf",order = 2)

tr-modules/tr-module-system/src/main/java/cn/tr/module/sys/storage/service/IStorageFileService.java

@@ -20,7 +20,7 @@ public interface IStorageFileService {
      */
     void initDefaultConfig();
 
-    void refreshConfig();
+    void refreshConfig(String configId);
 
     /**
      * 上传文件

tr-modules/tr-module-system/src/main/java/cn/tr/module/sys/storage/service/impl/StorageFileServiceImpl.java

@@ -5,9 +5,12 @@ import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.io.FileUtil;
 import cn.hutool.core.map.MapUtil;
+import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.RandomUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.core.util.URLUtil;
+import cn.tr.core.exception.ServiceException;
+import cn.tr.core.exception.TRExcCode;
 import cn.tr.core.utils.JsonUtils;
 import cn.tr.module.api.sys.storage.StoragePojo;
 import cn.tr.module.sys.storage.dto.SysStorageConfigDTO;
@@ -67,10 +70,9 @@ public class StorageFileServiceImpl implements IStorageFileService {
     }
 
     @Override
-    public void refreshConfig() {
-        SysStorageConfigQueryDTO query = new SysStorageConfigQueryDTO();
-        List<SysStorageConfigDTO> list = storageConfigService.selectSysStorageConfigList(query);
-        for (SysStorageConfigDTO storageConfig : list) {
+    public void refreshConfig(String configId) {
+        SysStorageConfigDTO storageConfig = storageConfigService.selectSysStorageConfigById(configId);
+        if(ObjectUtil.isNotNull(storageConfig)){
             fileClientFactory.createOrUpdateFileClient(storageConfig.getId(), storageConfig.getType(),parseClientConfig(storageConfig.getType(), storageConfig.getConfig()));
         }
     }
@@ -81,7 +83,7 @@ public class StorageFileServiceImpl implements IStorageFileService {
         if(StrUtil.isEmpty(configId)){
             configId=defaultConfig.getId();
         }
-        FileClient fileClient = fileClientFactory.getFileClient(configId);
+        FileClient fileClient = getClient(configId);
         String bizName = createBizName(filename);
         String suffix = FileUtil.extName(filename);
         fileClient.upload(content,bizName);
@@ -111,7 +113,7 @@ public class StorageFileServiceImpl implements IStorageFileService {
                 .collect(Collectors.groupingBy(SysStorageRecordDTO::getConfigId));
         List<SysStorageConfigDTO> configs = storageConfigService.selectSysStorageConfigByIds(recordByConfigId.keySet());
         configs.stream()
-                .map(config->getClient(config))
+                .map(config->getClient(config.getId()))
                 .forEach(client->{
                     List<SysStorageRecordDTO> storageRecords = recordByConfigId.get(client.getId());
                     for (SysStorageRecordDTO storageRecord : storageRecords) {
@@ -123,16 +125,14 @@ public class StorageFileServiceImpl implements IStorageFileService {
     @Override
     public String obtainDownloadPath(String recordId) throws Exception {
         SysStorageRecordDTO record = storageRecordService.selectSysStorageRecordById(recordId);
-        SysStorageConfigDTO config = storageConfigService.selectSysStorageConfigById(record.getConfigId());
-        FileClient fileClient = getClient(config);
+        FileClient fileClient = getClient(record.getConfigId());
         return fileClient.downUrl(record.getBizName());
     }
 
     @Override
     public byte[] obtainContent(String recordId) throws Exception {
         SysStorageRecordDTO record = storageRecordService.selectSysStorageRecordById(recordId);
-        SysStorageConfigDTO config = storageConfigService.selectSysStorageConfigById(record.getConfigId());
-        FileClient fileClient = getClient(config);
+        FileClient fileClient = getClient(record.getConfigId());
         return fileClient.getContent(record.getBizName()).getContent();
     }
 
@@ -153,8 +153,16 @@ public class StorageFileServiceImpl implements IStorageFileService {
     }
 
 
-    private FileClient getClient(SysStorageConfigDTO storageConfig){
-        return fileClientFactory.getFileClient(storageConfig.getId());
+    private FileClient getClient(String id){
+        FileClient fileClient = fileClientFactory.getFileClient(id);
+        if(fileClient==null){
+            SysStorageConfigDTO storageConfig = storageConfigService.selectSysStorageConfigById(id);
+            if(ObjectUtil.isNull(storageConfig)){
+                throw new ServiceException(TRExcCode.SYSTEM_ERROR_B0001,"存储配置不存在,请刷新重试");
+            }
+            fileClient=fileClientFactory.createOrUpdateFileClient(storageConfig.getId(), storageConfig.getType(),parseClientConfig(storageConfig.getType(), storageConfig.getConfig()));
+        }
+        return fileClient;
     }
 
     private FileClientConfig parseClientConfig(String storage, Map<String, Object> config) {

tr-modules/tr-module-system/src/main/java/cn/tr/module/sys/storage/service/impl/SysStorageConfigServiceImpl.java

@@ -57,8 +57,8 @@ public class SysStorageConfigServiceImpl implements ISysStorageConfigService, Co
     }
 
     @Subscribe(STORAGE_CONFIG_TOPIC)
-    public void storageConfigUpdate(){
-        storageFileService.refreshConfig();
+    public void storageConfigUpdate(String configId){
+        storageFileService.refreshConfig(configId);
     }
     /**
      * 根据条件查询文件存储配置
@@ -101,11 +101,12 @@ public class SysStorageConfigServiceImpl implements ISysStorageConfigService, Co
      * @date     2023/05/09 14:29
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public boolean updateSysStorageConfigById(SysStorageConfigDTO source){
         SysStorageConfigPO config = SysStorageConfigMapper.INSTANCE.convertPO(source);
         config.setConfig(parseClientConfig(config.getType(), source.getConfig()));
         if (baseRepository.updateById(config)!=0) {
-            eventBus.publishShare(STORAGE_CONFIG_TOPIC,new Object());
+            eventBus.publishShare(STORAGE_CONFIG_TOPIC,source.getId());
             return true;
         }
         return false;
@@ -118,6 +119,7 @@ public class SysStorageConfigServiceImpl implements ISysStorageConfigService, Co
      * @date  2023/05/09 14:29
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public boolean insertSysStorageConfig(SysStorageConfigDTO source){
         Long count = baseRepository.selectCount(new LambdaQueryWrapper<>());
         boolean master=count==0;
@@ -201,7 +203,6 @@ public class SysStorageConfigServiceImpl implements ISysStorageConfigService, Co
     @Override
     public void run(String... args) throws Exception {
         storageUpdate();
-        storageConfigUpdate();
-        log.info("[存储配置]加载完成");
+        log.info("[存储默认配置]加载完成");
     }
 }