|
|
@@ -1,6 +1,5 @@
|
|
|
package cn.reghao.oss.console.app.service;
|
|
|
|
|
|
-import cn.reghao.oss.console.app.db.repository.UploadChannelRepository;
|
|
|
import cn.reghao.oss.console.app.model.po.StoreNode;
|
|
|
import cn.reghao.oss.console.app.model.po.UploadChannel;
|
|
|
import cn.reghao.oss.store.api.dto.ObjectChannel;
|
|
|
@@ -19,12 +18,11 @@ import java.util.stream.Collectors;
|
|
|
@Service
|
|
|
public class OssStoreService {
|
|
|
private final StoreNodeService storeNodeService;
|
|
|
- private final UploadChannelRepository uploadChannelRepository;
|
|
|
+ private final UploadChannelService uploadChannelService;
|
|
|
|
|
|
- public OssStoreService(StoreNodeService storeNodeService, UploadChannelRepository uploadChannelRepository) {
|
|
|
+ public OssStoreService(StoreNodeService storeNodeService, UploadChannelService uploadChannelService) {
|
|
|
this.storeNodeService = storeNodeService;
|
|
|
- this.uploadChannelRepository = uploadChannelRepository;
|
|
|
-
|
|
|
+ this.uploadChannelService = uploadChannelService;
|
|
|
}
|
|
|
|
|
|
public void registerNode(StoreNodeDto storeNodeDto) {
|
|
|
@@ -38,35 +36,11 @@ public class OssStoreService {
|
|
|
}
|
|
|
|
|
|
String domain = storeNode.getDomain();
|
|
|
- return uploadChannelRepository.findByBindDomain(domain).stream()
|
|
|
+ return uploadChannelService.getByDomain(domain).stream()
|
|
|
.map(this::getObjectChannel)
|
|
|
.collect(Collectors.toList());
|
|
|
}
|
|
|
|
|
|
- public ObjectChannel getObjectChannel(int createBy, String nodeAddr, int channelId) {
|
|
|
- StoreNode storeNode = storeNodeService.getByNodeAddr(nodeAddr);
|
|
|
- if (storeNode == null) {
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- String domain = storeNode.getDomain();
|
|
|
- UploadChannel uploadChannel = uploadChannelRepository.findByCreateByAndBindDomainAndChannelId(createBy, domain, channelId);
|
|
|
- if (uploadChannel == null) {
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- return getObjectChannel(uploadChannel);
|
|
|
- }
|
|
|
-
|
|
|
- public ObjectChannel getObjectChannel(int createBy, int channelId) {
|
|
|
- UploadChannel uploadChannel = uploadChannelRepository.findByChannelIdAndCreateBy(channelId, createBy);
|
|
|
- if (uploadChannel == null) {
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- return getObjectChannel(uploadChannel);
|
|
|
- }
|
|
|
-
|
|
|
private ObjectChannel getObjectChannel(UploadChannel uploadChannel) {
|
|
|
int channelId = uploadChannel.getChannelId();
|
|
|
String name = uploadChannel.getName();
|