From 1cad14bca191807e18705c3a5526eda8151be439 Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期一, 14 四月 2025 23:10:22 +0800
Subject: [PATCH] 批量审核和图片保存bug
---
ycl-common/src/main/java/com/ycl/service/oss/impl/OssServiceImpl.java | 285 ++++++++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 230 insertions(+), 55 deletions(-)
diff --git a/ycl-common/src/main/java/com/ycl/service/oss/impl/OssServiceImpl.java b/ycl-common/src/main/java/com/ycl/service/oss/impl/OssServiceImpl.java
index 47a4f18..3cae4d0 100644
--- a/ycl-common/src/main/java/com/ycl/service/oss/impl/OssServiceImpl.java
+++ b/ycl-common/src/main/java/com/ycl/service/oss/impl/OssServiceImpl.java
@@ -3,26 +3,246 @@
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.ObjectMetadata;
+import com.aliyun.oss.model.VoidResult;
import com.ycl.service.oss.OssService;
import com.ycl.utils.ConstantPropertiesUtils;
+import com.ycl.utils.common.RandomUtils;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
-import java.io.ByteArrayInputStream;
-import java.io.InputStream;
+import javax.imageio.IIOImage;
+import javax.imageio.ImageIO;
+import javax.imageio.ImageWriteParam;
+import javax.imageio.ImageWriter;
+import javax.imageio.stream.ImageOutputStream;
+import java.awt.*;
+import java.awt.image.BufferedImage;
+import java.io.*;
+import java.net.URL;
+import java.net.URLDecoder;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.Arrays;
import java.util.Date;
-import java.util.UUID;
@Service
public class OssServiceImpl implements OssService {
@Override
public String uploadImages(MultipartFile file) {
+ DateTimeFormatter dtf2 = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+ System.out.println("寮�濮嬩笂浼�--" + dtf2.format(LocalDateTime.now()));
+ if (file == null) {
+ return "涓婁紶鏂囦欢涓虹┖";
+ }
String endpoint = ConstantPropertiesUtils.END_POINT;
String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID;
String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET;
String bucketName = ConstantPropertiesUtils.BUCKET_NAME;
// 鍒涘缓OSSClient瀹炰緥銆�
+ OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
+ // 涓婁紶鏂囦欢娴�
+ try {
+ // 鑾峰彇鏂囦欢鐨勫悕绉�
+
+ byte[] newImg = file.getBytes();
+ String originalFilename = file.getOriginalFilename();
+ String fileType = originalFilename.substring(originalFilename.lastIndexOf("."));
+
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd");
+ String fileName = "sczf/" + LocalDateTime.now().format(formatter) + RandomUtils.generateRandomInt(8) + fileType;
+
+ if (".png".equalsIgnoreCase(fileType) || ".jpg".equalsIgnoreCase(fileType) || ".jpeg".equalsIgnoreCase(fileType)) {
+ if (file.getSize() > 2097152) {
+ newImg = compressUnderSize(file.getBytes(), 2097152);
+ }
+ }
+ ObjectMetadata objectMetadata = new ObjectMetadata();
+ objectMetadata.setContentType(getcontentType(fileName.substring(fileName.lastIndexOf("."))));
+ // 璋冪敤oss鐨勬柟娉曞疄鐜伴暱浼�
+ // 绗竴涓弬鏁� bucketName
+ // 绗簩涓弬鏁� 涓婁紶鍒皁ss鐨勬枃浠惰矾寰勫拰鏂囦欢鍚嶇О
+ ossClient.putObject(bucketName, fileName, new ByteArrayInputStream(newImg), objectMetadata);
+ // 鍏抽棴OSSClient銆�
+ ossClient.shutdown();
+ // 鎶婁笂浼犵殑鏂囦欢璺緞杩斿洖 锛堟墜鍔ㄦ嫾鎺ワ級
+ // 杩欓噷璁剧疆鍥剧墖鏈夋晥鏃堕棿 鎴戣缃簡30骞�
+ Date expiration = new Date(System.currentTimeMillis() + (long) 946080000 * 1000);
+
+ String url = ossClient.generatePresignedUrl(bucketName, fileName, expiration).toString();
+
+ System.out.println("涓婁紶缁撴潫--" + url + "------" + dtf2.format(LocalDateTime.now()));
+ return url;
+ } catch (Exception e) {
+ System.out.println("uploadImages涓婁紶鍥剧墖澶辫触锛�");
+ // e.printStackTrace();
+ return null;
+ }
+ }
+
+ /**
+ * 鎸夌収 瀹介珮 姣斾緥鍘嬬缉
+ *
+ * @param imgIs 寰呭帇缂╁浘鐗囪緭鍏ユ祦
+ * @param scale 鍘嬬缉鍒诲害
+ * @param out 杈撳嚭
+ * @return 鍘嬬缉鍚庡浘鐗囨暟鎹�
+ * @throws IOException 鍘嬬缉鍥剧墖杩囩▼涓嚭閿�
+ */
+ public byte[] compress(byte[] srcImgData, double scale) throws IOException {
+ BufferedImage bi = ImageIO.read(new ByteArrayInputStream(srcImgData));
+ int width = (int) (bi.getWidth() * scale); // 婧愬浘瀹藉害
+ int height = (int) (bi.getHeight() * scale); // 婧愬浘楂樺害
+
+ Image image = bi.getScaledInstance(width, height, Image.SCALE_SMOOTH);
+ BufferedImage tag = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);
+
+ Graphics g = tag.getGraphics();
+ g.setColor(Color.RED);
+ g.drawImage(image, 0, 0, null); // 缁樺埗澶勭悊鍚庣殑鍥�
+ g.dispose();
+
+ ByteArrayOutputStream bOut = new ByteArrayOutputStream();
+ ImageIO.write(tag, "JPEG", bOut);
+
+ return bOut.toByteArray();
+ }
+
+ /**
+ * 灏嗗浘鐗囧帇缂╁埌鎸囧畾澶у皬浠ュ唴
+ *
+ * @param srcImgData 婧愬浘鐗囨暟鎹�
+ * @param maxSize 鐩殑鍥剧墖澶у皬
+ * @return 鍘嬬缉鍚庣殑鍥剧墖鏁版嵁
+ */
+ public byte[] compressUnderSize(byte[] srcImgData, long maxSize) {
+ double scale = 0.9;
+ byte[] imgData = Arrays.copyOf(srcImgData, srcImgData.length);
+
+ if (imgData.length > maxSize) {
+ do {
+ try {
+ imgData = compress(imgData, scale);
+
+ } catch (IOException e) {
+ throw new IllegalStateException("鍘嬬缉鍥剧墖杩囩▼涓嚭閿欙紝璇峰強鏃惰仈绯荤鐞嗗憳锛�", e);
+ }
+
+ } while (imgData.length > maxSize);
+ }
+
+ return imgData;
+ }
+
+ private byte[] readInputStream(InputStream inStream) throws Exception {
+ ByteArrayOutputStream outStream = new ByteArrayOutputStream();
+ //鍒涘缓涓�涓狟uffer瀛楃涓�
+ byte[] buffer = new byte[1024];
+ //姣忔璇诲彇鐨勫瓧绗︿覆闀垮害锛屽鏋滀负-1锛屼唬琛ㄥ叏閮ㄨ鍙栧畬姣�
+ int len = 0;
+ //浣跨敤涓�涓緭鍏ユ祦浠巄uffer閲屾妸鏁版嵁璇诲彇鍑烘潵
+ while ((len = inStream.read(buffer)) != -1) {
+ //鐢ㄨ緭鍑烘祦寰�buffer閲屽啓鍏ユ暟鎹紝涓棿鍙傛暟浠ｈ〃浠庡摢涓綅缃紑濮嬭锛宭en浠ｈ〃璇诲彇鐨勯暱搴�
+ outStream.write(buffer, 0, len);
+ }
+ //鍏抽棴杈撳叆娴�
+ inStream.close();
+ //鎶妎utStream閲岀殑鏁版嵁鍐欏叆鍐呭瓨
+ return outStream.toByteArray();
+ }
+
+ @Override
+ public boolean deleteImages(String fileUrl) {
+ try {
+
+ String endpoint = ConstantPropertiesUtils.END_POINT;
+ String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID;
+ String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET;
+ String bucketName = ConstantPropertiesUtils.BUCKET_NAME;
+ //鍒涘缓OSSClient瀹炰緥
+ OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
+
+ String imgFile = fileUrl.replace(ConstantPropertiesUtils.PREFIX_URL, "");
+ String fileName = imgFile;
+ if (imgFile.contains("?")) {
+ fileName = imgFile.substring(0, imgFile.indexOf("?"));
+ }
+
+ fileName = URLDecoder.decode(fileName, "UTF-8");
+
+ // 鏍规嵁BucketName,objectName鍒犻櫎鏂囦欢
+ boolean b = ossClient.doesObjectExist(bucketName, fileName);
+ if (b) {
+ VoidResult voidResult = ossClient.deleteObject(bucketName, fileName);
+// System.out.println(voidResult.toString());
+ }
+ ossClient.shutdown();
+ return true;
+
+ } catch (Exception e) {
+ System.out.println("-------鍒犻櫎鍥剧墖澶辫触锛屽浘鐗囧湴鍧�:" + fileUrl);
+ }
+ return false;
+ }
+
+ @Override
+ public String uploadImages(InputStream inputStream, String ext, Integer times) {
+ if (times < 3) {
+ String endpoint = ConstantPropertiesUtils.END_POINT;
+ String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID;
+ String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET;
+ String bucketName = ConstantPropertiesUtils.BUCKET_NAME;
+
+ DateTimeFormatter dtf2 = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+// System.out.println("鍑嗗涓婁紶--" + dtf2.format(LocalDateTime.now()));
+ // 鍒涘缓OSSClient瀹炰緥銆�
+ OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
+ // 涓婁紶鏂囦欢娴�
+ try {
+ // 鑾峰彇鏂囦欢鐨勫悕绉�
+ LocalDate date = LocalDate.now();
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd");
+ String fileName = "sczf/" + date.format(formatter) + RandomUtils.generateRandomInt(8) + ext;
+
+ ObjectMetadata objectMetadata = new ObjectMetadata();
+ objectMetadata.setContentType(getcontentType(ext));
+
+// System.out.println("寮�濮嬩笂浼�--" + dtf2.format(LocalDateTime.now()));
+
+ ossClient.putObject(bucketName, fileName, inputStream, objectMetadata);
+ ossClient.shutdown();
+
+ Date expiration = new Date(System.currentTimeMillis() + (long) 946080000 * 1000);
+
+ String url = ossClient.generatePresignedUrl(bucketName, fileName, expiration).toString();
+// System.out.println("oss涓婁紶鎴愬姛锛�" + url);
+
+// System.out.println("涓婁紶瀹屾垚--" + dtf2.format(LocalDateTime.now()));
+ return url;
+
+ } catch (Exception e) {
+ System.out.println("oss寮傚父锛�" + e.getMessage());
+ // e.printStackTrace();
+ return this.uploadImages(inputStream, ext, times + 1);
+ }
+ } else {
+ return "";
+ }
+ }
+
+ @Override
+ public String uploadVideo(MultipartFile file) {
+ if (file == null) {
+ return "涓婁紶瑙嗛涓虹┖";
+ }
+ String endpoint = ConstantPropertiesUtils.END_POINT;
+ String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID;
+ String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET;
+ String bucketName = ConstantPropertiesUtils.BUCKET_NAME;
+ // 鍒涘缓OSSClient瀹炰緥
OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
// 涓婁紶鏂囦欢娴�
try {
@@ -38,67 +258,22 @@
ossClient.shutdown();
// 鎶婁笂浼犵殑鏂囦欢璺緞杩斿洖 锛堟墜鍔ㄦ嫾鎺ワ級
// 杩欓噷璁剧疆鍥剧墖鏈夋晥鏃堕棿 鎴戣缃簡30骞�
- Date expiration = new Date(System.currentTimeMillis() + 946080000 * 1000);
+ Date expiration = new Date(System.currentTimeMillis() + (long) 946080000 * 1000);
String url = ossClient.generatePresignedUrl(bucketName, fileName, expiration).toString();
+
return url;
} catch (Exception e) {
- e.printStackTrace();
- return null;
- }
- }
-
- @Override
- public boolean deleteImages(String fileUrl) {
- String endpoint = ConstantPropertiesUtils.END_POINT;
- String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID;
- String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET;
- String bucketName = ConstantPropertiesUtils.BUCKET_NAME;
- //鍒涘缓OSSClient瀹炰緥
- OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
- String imgFile = fileUrl.replace("https://bucket-ans.oss-cn-hangzhou.aliyuncs.com/", "");
- String fileName = imgFile.substring(0, imgFile.indexOf("?"));
-
- // 鏍规嵁BucketName,objectName鍒犻櫎鏂囦欢
- ossClient.deleteObject(bucketName, fileName);
- ossClient.shutdown();
- return true;
- }
-
- @Override
- public String uploadImages(InputStream inputStream, String ext) {
- String endpoint = ConstantPropertiesUtils.END_POINT;
- String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID;
- String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET;
- String bucketName = ConstantPropertiesUtils.BUCKET_NAME;
-
- // 鍒涘缓OSSClient瀹炰緥銆�
- OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
- // 涓婁紶鏂囦欢娴�
- try {
- // 鑾峰彇鏂囦欢鐨勫悕绉�
- String fileName = "sczf/" + String.valueOf(UUID.randomUUID());
- ObjectMetadata objectMetadata = new ObjectMetadata();
- objectMetadata.setContentType(getcontentType(ext));
- // 璋冪敤oss鐨勬柟娉曞疄鐜伴暱浼�
- // 绗竴涓弬鏁� bucketName
- // 绗簩涓弬鏁� 涓婁紶鍒皁ss鐨勬枃浠惰矾寰勫拰鏂囦欢鍚嶇О
- ossClient.putObject(bucketName, fileName, inputStream, objectMetadata);
- // 鍏抽棴OSSClient銆�
- ossClient.shutdown();
- // 鎶婁笂浼犵殑鏂囦欢璺緞杩斿洖 锛堟墜鍔ㄦ嫾鎺ワ級
- // 杩欓噷璁剧疆鍥剧墖鏈夋晥鏃堕棿 鎴戣缃簡30骞�
- Date expiration = new Date(System.currentTimeMillis() + 946080000 * 1000);
- String url = ossClient.generatePresignedUrl(bucketName, fileName, expiration).toString();
- // System.out.println("oss鎴愬姛锛�" + url);
- return url;
- } catch (Exception e) {
- System.out.println("oss寮傚父锛�" + e.getMessage());
+ System.out.println("uploadImages涓婁紶瑙嗛澶辫触锛�");
// e.printStackTrace();
return null;
}
}
+
public static String getcontentType(String FilenameExtension) {
+ if (FilenameExtension.equalsIgnoreCase(".mp4") || FilenameExtension.equalsIgnoreCase(".mov")) {
+ return "video/mp4";
+ }
if (FilenameExtension.equalsIgnoreCase(".bmp")) {
return "image/bmp";
}
--
Gitblit v1.8.0