From bf765893039bc7968b8160a70bda778526dca98c Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期二, 31 十二月 2024 15:28:19 +0800 Subject: [PATCH] 定时任务 --- common/src/main/java/com/jilongda/common/component/AliOssFileUploadController.java | 49 ++++++++++++++++++++++--------------------------- 1 files changed, 22 insertions(+), 27 deletions(-) diff --git a/common/src/main/java/com/jilongda/common/component/AliOssFileUploadController.java b/common/src/main/java/com/jilongda/common/component/AliOssFileUploadController.java index 29abf8d..21770ec 100644 --- a/common/src/main/java/com/jilongda/common/component/AliOssFileUploadController.java +++ b/common/src/main/java/com/jilongda/common/component/AliOssFileUploadController.java @@ -41,28 +41,28 @@ private String FILE_CDN; - @ApiOperation(value = "单文件上传", notes = "单文件上传,rename 默认不重命名") - @PostMapping(value = "strUpload", headers = "content-type=multipart/form-data") - public String strUploads(@RequestParam(value = "file") MultipartFile mf) throws IOException { - if (mf.isEmpty()) { - return "请传入文件!"; - } - String fileName = mf.getOriginalFilename(); - String TimeDir =new SimpleDateFormat("yyyy-MM-dd").format(new Date()); -// String realPath = "D:\\" + TimeDir; - String realPath = "/usr/local/nginx/html/images/" + TimeDir; - File file = new File(realPath); - // 没有目录就创建 - if (!file.exists()) { - file.mkdirs(); - } - File targetFile = new File(realPath, fileName);//目标文件 - //开始从源文件拷贝到目标文件 - //传图片一步到位 - mf.transferTo(targetFile); - //拼接数据 - return "http://sales.chelota.com/images/" + TimeDir +"/"+ fileName; - } +// @ApiOperation(value = "单文件上传", notes = "单文件上传,rename 默认不重命名") +// @PostMapping(value = "strUpload", headers = "content-type=multipart/form-data") +// public String strUploads(@RequestParam(value = "file") MultipartFile mf) throws IOException { +// if (mf.isEmpty()) { +// return "请传入文件!"; +// } +// String fileName = mf.getOriginalFilename(); +// String TimeDir =new SimpleDateFormat("yyyy-MM-dd").format(new Date()); +//// String realPath = "D:\\" + TimeDir; +// String realPath = "/usr/local/nginx/html/images/" + TimeDir; +// File file = new File(realPath); +// // 没有目录就创建 +// if (!file.exists()) { +// file.mkdirs(); +// } +// File targetFile = new File(realPath, fileName);//目标文件 +// //开始从源文件拷贝到目标文件 +// //传图片一步到位 +// mf.transferTo(targetFile); +// //拼接数据 +// return "http://eyes.chelota.com/images/" + TimeDir +"/"+ fileName; +// } @ApiOperation(value = "服务端上传", notes = "服务端上传") @PostMapping(value = "upload") public ApiResult<String> fileUpload(@RequestParam(value = "file") MultipartFile file) throws IOException { @@ -76,14 +76,12 @@ final String bucketName = AliOss.bucketName; // <yourObjectName>上传文件到OSS时需要指定包含文件后缀在内的完整路径,例如abc/efg/123.jpg。 String objectName = AliOss.dir + filename; - log.info(objectName); // 创建OSSClient实例。 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); // 填写本地文件的完整路径。如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。 // InputStream inputStream = new FileInputStream("D:\\localpath\\examplefile.txt"); // 依次填写Bucket名称(例如examplebucket)和Object完整路径(例如exampledir/exampleobject.txt)。Object完整路径中不能包含Bucket名称。 PutObjectResult putObjectResult = ossClient.putObject(bucketName, objectName, inputStream); - log.info("上传结果:{}", putObjectResult); OSSObject ossObject = ossClient.getObject(bucketName, objectName); String uri = ossObject.getResponse().getUri(); // 关闭OSSClient。 @@ -151,14 +149,12 @@ final String bucketName = AliOss.bucketName; // <yourObjectName>上传文件到OSS时需要指定包含文件后缀在内的完整路径,例如abc/efg/123.jpg。 String objectName = AliOss.dir + filename; - log.info(objectName); // 创建OSSClient实例。 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); // 填写本地文件的完整路径。如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。 // InputStream inputStream = new FileInputStream("D:\\localpath\\examplefile.txt"); // 依次填写Bucket名称(例如examplebucket)和Object完整路径(例如exampledir/exampleobject.txt)。Object完整路径中不能包含Bucket名称。 PutObjectResult putObjectResult = ossClient.putObject(bucketName, objectName, inputStream); - log.info("上传结果:{}", putObjectResult); OSSObject ossObject = ossClient.getObject(bucketName, objectName); String uri = ossObject.getResponse().getUri(); // 关闭OSSClient。 @@ -175,7 +171,6 @@ @ApiOperation(value = "oss回调", notes = "oss回调") @PostMapping(value = "/callback") public ApiResult callback(@RequestBody Map<String, Object> callback) { - log.info("oss回调{}", callback); String filename = "http://".concat(AliOss.bucketName).concat(".").concat(AliOss.endpoint).concat("/").concat(callback.get("filename").toString()); return ApiResult.okmsg(filename); } -- Gitblit v1.7.1