| | |
| | | import com.qianwen.core.oss.rule.BladeOssRule; |
| | | import com.qianwen.core.oss.rule.OssRule; |
| | | import com.qianwen.core.redis.cache.BladeRedis; |
| | | import com.qianwen.core.tenant.mp.TenantEntity; |
| | | import com.qianwen.core.tool.utils.Func; |
| | | import com.qianwen.core.tool.utils.SpringUtil; |
| | | import com.qianwen.core.tool.utils.StringUtil; |
| | |
| | | import com.qianwen.smartman.modules.resource.enums.BucketEnum; |
| | | import com.qianwen.smartman.modules.resource.service.IOssService; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/resource/builder/oss/OssBuilder.class */ |
| | | public class OssBuilder { |
| | | public static final String OSS_CODE = "oss:code:"; |
| | | public static final String OSS_PARAM_KEY = "code"; |
| | |
| | | private static BladeRedis bladeRedis; |
| | | private final OssProperties ossProperties; |
| | | private final IOssService ossService; |
| | | private final Map<String, OssTemplate> templatePool = new ConcurrentHashMap(); |
| | | private final Map<String, OssTemplate> templatePool = new ConcurrentHashMap<>(); |
| | | private final Map<String, Oss> ossPool = new ConcurrentHashMap<>(); |
| | | |
| | | public OssBuilder(OssProperties ossProperties, IOssService ossService) { |
| | |
| | | |
| | | private static BladeRedis getBladeRedis() { |
| | | if (bladeRedis == null) { |
| | | bladeRedis = (BladeRedis) SpringUtil.getBean(BladeRedis.class); |
| | | bladeRedis = SpringUtil.getBean(BladeRedis.class); |
| | | } |
| | | return bladeRedis; |
| | | } |
| | |
| | | Oss oss = getOss("000000", code); |
| | | Oss ossCached = this.ossPool.get("000000"); |
| | | OssTemplate template2 = this.templatePool.get("000000"); |
| | | if (!Func.hasEmpty(new Object[]{template2, ossCached}) && oss.getEndpoint().equals(ossCached.getEndpoint()) && oss.getAccessKey().equals(ossCached.getAccessKey())) { |
| | | if (!Func.hasEmpty(template2, ossCached) && oss.getEndpoint().equals(ossCached.getEndpoint()) && oss.getAccessKey().equals(ossCached.getAccessKey())) { |
| | | return template2; |
| | | } |
| | | synchronized (OssBuilder.class) { |