Quellcode durchsuchen

OssServerServiceImpl 实现 createChannel 方法, 供 oss-console 创建 channel 时调用

reghao vor 2 Jahren
Ursprung
Commit
ef23f4db57

+ 9 - 1
oss-store/src/main/java/cn/reghao/oss/store/rpc/OssServerServiceImpl.java

@@ -1,11 +1,14 @@
 package cn.reghao.oss.store.rpc;
 
+import cn.reghao.oss.api.constant.ObjectScope;
 import cn.reghao.oss.api.dto.ObjectChannel;
 import cn.reghao.oss.store.config.OssProperties;
+import cn.reghao.oss.store.service.ObjectNameService;
 import cn.reghao.oss.store.util.JwtUtil;
 import cn.reghao.oss.api.constant.ChannelAction;
 import cn.reghao.oss.api.dto.OssPayload;
 import cn.reghao.oss.api.iface.OssServerService;
+import cn.reghao.oss.store.util.UserContext;
 import org.apache.dubbo.config.annotation.DubboService;
 import org.springframework.stereotype.Service;
 
@@ -17,9 +20,11 @@ import org.springframework.stereotype.Service;
 @Service
 public class OssServerServiceImpl implements OssServerService {
     private final OssProperties ossProperties;
+    private final ObjectNameService objectNameService;
 
-    public OssServerServiceImpl(OssProperties ossProperties) {
+    public OssServerServiceImpl(OssProperties ossProperties, ObjectNameService objectNameService) {
         this.ossProperties = ossProperties;
+        this.objectNameService = objectNameService;
     }
 
     @Override
@@ -33,5 +38,8 @@ public class OssServerServiceImpl implements OssServerService {
 
     @Override
     public void createChannel(long userId, ObjectChannel channel) {
+        UserContext userContext = new UserContext(userId);
+        String objectName = channel.getPrefix();
+        objectNameService.createParentDirs(objectName, ObjectScope.PUBLIC.getCode());
     }
 }