oss-v1版本

yd-oss-feign/src/main/java/com/yd/oss/feign/response/ApiOssFileListResponse.java

@@ -66,4 +66,14 @@ public class ApiOssFileListResponse {
      * 创建时间
      * 创建时间
      */
      */
     private LocalDateTime createTime;
     private LocalDateTime createTime;
+
+    /**
+     * 创建人ID
+     */
+    private String creatorId;
+
+    /**
+     * 创建人名
+     */
+    private String creatorName;
 }
 }

yd-oss-service/src/main/java/com/yd/oss/service/model/OssFile.java

@@ -124,6 +124,12 @@ public class OssFile implements Serializable {
     private String creatorId;
     private String creatorId;
 
 
     /**
     /**
+     * 创建人名
+     */
+    @TableField("creator_name")
+    private String creatorName;
+
+    /**
      * 更新人ID
      * 更新人ID
      */
      */
     @TableField("updater_id")
     @TableField("updater_id")

yd-oss-service/src/main/java/com/yd/oss/service/service/impl/AliYunOssServiceImpl.java

@@ -6,6 +6,8 @@ import com.aliyun.oss.model.CannedAccessControlList;
 import com.aliyun.oss.model.OSSObject;
 import com.aliyun.oss.model.OSSObject;
 import com.aliyun.oss.model.ObjectMetadata;
 import com.aliyun.oss.model.ObjectMetadata;
 import com.aliyun.oss.model.PutObjectRequest;
 import com.aliyun.oss.model.PutObjectRequest;
+import com.yd.auth.core.dto.AuthUserDto;
+import com.yd.auth.core.utils.SecurityUtil;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.exception.BusinessException;
 import com.yd.common.exception.BusinessException;
 import com.yd.common.utils.IpUtil;
 import com.yd.common.utils.IpUtil;
@@ -70,6 +72,8 @@ public class AliYunOssServiceImpl implements OssService {
     @Override
     @Override
     public OssUploadFileResDto uploadFile(InputStream inputStream, String fileName,
     public OssUploadFileResDto uploadFile(InputStream inputStream, String fileName,
                                           String bucketName, String uploadUser, String type) {
                                           String bucketName, String uploadUser, String type) {
+        //获取Security上下文当前用户的登录信息
+        AuthUserDto authUserDto = SecurityUtil.getCurrentLoginUser();
         OssUploadFileResDto ossUploadFileDto = new OssUploadFileResDto();
         OssUploadFileResDto ossUploadFileDto = new OssUploadFileResDto();
         long startTime = System.currentTimeMillis(); // 记录开始时间
         long startTime = System.currentTimeMillis(); // 记录开始时间
         String operationResult = "success"; // 操作结果
         String operationResult = "success"; // 操作结果
@@ -110,6 +114,8 @@ public class AliYunOssServiceImpl implements OssService {
             ossFile.setProviderBizId(currentProvider.getProviderBizId());
             ossFile.setProviderBizId(currentProvider.getProviderBizId());
             ossFile.setBucketName(actualBucket);
             ossFile.setBucketName(actualBucket);
             ossFile.setUploadUser(uploadUser);
             ossFile.setUploadUser(uploadUser);
+            ossFile.setCreatorId(authUserDto.getUserBizId());
+            ossFile.setCreatorName(authUserDto.getUsername());
 
 
             // 保存文件元数据到数据库
             // 保存文件元数据到数据库
             ossFileService.saveFileMetadata(ossFile);
             ossFileService.saveFileMetadata(ossFile);
@@ -173,6 +179,8 @@ public class AliYunOssServiceImpl implements OssService {
      */
      */
     @Override
     @Override
     public OssUploadFileResDto uploadFileBody(MultipartFile file, OssUploadFileReqDto reqDto) {
     public OssUploadFileResDto uploadFileBody(MultipartFile file, OssUploadFileReqDto reqDto) {
+        //获取Security上下文当前用户的登录信息
+        AuthUserDto authUserDto = SecurityUtil.getCurrentLoginUser();
         OssUploadFileResDto ossUploadFileDto = new OssUploadFileResDto();
         OssUploadFileResDto ossUploadFileDto = new OssUploadFileResDto();
         // 记录开始时间
         // 记录开始时间
         long startTime = System.currentTimeMillis();
         long startTime = System.currentTimeMillis();
@@ -238,6 +246,8 @@ public class AliYunOssServiceImpl implements OssService {
             ossFile.setObjectName(reqDto.getObjectName());
             ossFile.setObjectName(reqDto.getObjectName());
             ossFile.setObjectTableName(reqDto.getObjectTableName());
             ossFile.setObjectTableName(reqDto.getObjectTableName());
             ossFile.setObjectType(reqDto.getObjectType());
             ossFile.setObjectType(reqDto.getObjectType());
+            ossFile.setCreatorId(authUserDto.getUserBizId());
+            ossFile.setCreatorName(authUserDto.getUsername());
             // 保存文件元数据到数据库
             // 保存文件元数据到数据库
             ossFileService.saveFileMetadata(ossFile);
             ossFileService.saveFileMetadata(ossFile);