生产环境配置

xin

2025-09-25 a6ac90e29e513b80b7ad881da8e319338021ef8b

 oying-tools/src/main/java/com/oying/service/impl/BucketStorageServiceImpl.java

@@ -14,6 +14,7 @@
import com.oying.service.BucketStorageService;
import com.oying.domain.dto.BucketStorageQueryCriteria;
import com.oying.mapper.BucketStorageMapper;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@@ -39,6 +40,8 @@
    private final BucketStorageMapper bucketStorageMapper;
    private final ObsProperties properties;
    private final FileProperties fileProperties;
    @Value("${oying.enabled}")
    private Boolean oyingEnabled;

    @Override
    public PageResult<BucketStorage> queryAll(BucketStorageQueryCriteria criteria, Page<Object> page) {
@@ -58,6 +61,9 @@
        String type = FileUtil.getFileType(suffix);
        String reaName = System.currentTimeMillis() + "." + suffix;
        String objectKey = type + "/" + reaName;
        if (oyingEnabled) {
            objectKey = "test/" +objectKey;
        }
        PutObjectResult result = ObsUtils.putObject(properties, file, objectKey, AccessControlList.REST_CANNED_PUBLIC_READ);
        if (ObjectUtil.isNull(result)) {
            throw new BadRequestException("上传失败");
@@ -83,6 +89,9 @@
        String type = FileUtil.getFileType(suffix);
        String reaName = IdUtil.getSnowflake(1, 1).nextId() + "." + suffix;
        String objectKey = type + "/" + reaName;
        if (oyingEnabled) {
            objectKey = "test/" +objectKey;
        }
        PutObjectResult result = ObsUtils.putObject(properties, FileUtil.toFile(file), objectKey, AccessControlList.REST_CANNED_PUBLIC_READ);
        if (ObjectUtil.isNull(result)) {
            throw new BadRequestException("上传失败");