lyhzzz 2 years ago
parent
commit
b9547c3f99

+ 2 - 1
src/main/java/com/fdkankan/manage/service/impl/SceneProServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.io.FileUtil;
 import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.amazonaws.services.s3.AmazonS3;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -299,7 +300,7 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
             if(!fYunFileServiceInterface.fileExist(path)){
                 return;
             }
-            String data = fYunFileServiceInterface.getFileContent("4dkankan",path);
+            String data = fYunFileServiceInterface.getFileContent(path);
             if(StringUtils.isBlank(data)){
                 return;
             }

+ 24 - 0
src/main/java/com/fdkankan/manage/test/TestController.java

@@ -3,6 +3,13 @@ package com.fdkankan.manage.test;
 import cn.hutool.core.io.FileUtil;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.amazonaws.auth.AWSStaticCredentialsProvider;
+import com.amazonaws.auth.BasicAWSCredentials;
+import com.amazonaws.regions.Regions;
+import com.amazonaws.services.s3.AmazonS3;
+import com.amazonaws.services.s3.AmazonS3ClientBuilder;
+import com.amazonaws.services.s3.model.GetObjectRequest;
+import com.amazonaws.services.s3.model.S3Object;
 import com.fdkankan.common.util.FileUtils;
 import com.fdkankan.elasticsearch.service.DocumentService;
 import com.fdkankan.elasticsearch.service.IndexService;
@@ -32,6 +39,8 @@ import org.springframework.web.multipart.MultipartFile;
 import java.io.IOException;
 import java.util.*;
 
+import static com.amazonaws.util.CredentialUtils.getCredentialsProvider;
+
 @Slf4j
 @RestController
 @RequestMapping("/test")
@@ -106,4 +115,19 @@ public class TestController {
         return ResultData.ok();
     }
 
+
+    public static void main(String[] args) {
+        BasicAWSCredentials awsCreds = new BasicAWSCredentials("AKIAWCV5QFZ3ZNELKYUY", "epS5ghyR4LJ7rxk/qJO9ZYh6m9Oz6g5haKDu4yws");
+        String homePath  ="scene_view_data/KJ-t-eur-DBDhqfXKYCK/data/status.json";
+
+        AmazonS3 amazonS3 = AmazonS3ClientBuilder.standard().
+                withCredentials(new AWSStaticCredentialsProvider(awsCreds))
+                .withRegion(Regions.EU_WEST_2)//s3 地区位置
+                .build();
+        boolean b = amazonS3.doesObjectExist("test-4dkankan", homePath);// Works
+        System.out.println(b);
+        GetObjectRequest request  = new GetObjectRequest("test-4dkankan",homePath);
+        S3Object object = amazonS3.getObject(request);
+        System.out.println(object);
+    }
 }