lyhzzz 2 rokov pred
rodič
commit
370c476d12

+ 25 - 0
src/main/java/com/fdkankan/tk/common/util/UploadToOssUtil.java

@@ -57,6 +57,31 @@ public class UploadToOssUtil {
 		}
 		return false;
 	}
+	/**
+	 * 获取文件内容-阿里云
+	 * @param objectName
+	 * @return
+	 */
+	public Long getSize(String objectName){
+		//创建oss客户端
+		if(objectName.contains(query)){
+			objectName = objectName.replace(query,"");
+		}
+		OSSClient ossClient = new OSSClient(point, key, secrey);
+		// ossObject包含文件所在的存储空间名称、文件名称、文件元信息以及一个输入流。
+		try{
+			OSSObject object = ossClient.getObject(bucket, objectName);
+			ObjectMetadata objectMetadata = object.getObjectMetadata();
+			return objectMetadata.getContentLength();
+		}catch (Exception e){
+			log.error("s4判断是否存在key异常,key=" + objectName, e);
+		}finally {
+			if(ossClient != null){
+				ossClient.shutdown();
+			}
+		}
+		return 0L;
+	}
 
 	/**
 	 * 从阿里云oss下载文件到本地

+ 2 - 2
src/main/java/com/fdkankan/tk/service/impl/RoomServiceImpl.java

@@ -146,13 +146,13 @@ public class RoomServiceImpl extends ServiceImpl<IRoomMapper, Room> implements I
             throw new BusinessException(ResultCode.ROOM_MISS);
         }
         if(type.equals("follower") && StringUtils.isNotBlank(room.getRoomShareCode())){     //普通用户二维码
-            if(uploadToOssUtil.existKey(room.getRoomShareCode())){
+            if(uploadToOssUtil.existKey(room.getRoomShareCode()) && uploadToOssUtil.getSize(room.getRoomShareCode()) >0){
                 return  room.getRoomShareCode() +"?"+System.currentTimeMillis();
             }
         }
 
         if(type.equals("leader") && StringUtils.isNotBlank(room.getRoomHostCode())){      //主持人二维码
-            if(uploadToOssUtil.existKey(room.getRoomHostCode())){
+            if(uploadToOssUtil.existKey(room.getRoomHostCode()) && uploadToOssUtil.getSize(room.getRoomHostCode()) >0){
                 return  room.getRoomHostCode() +"?"+System.currentTimeMillis();
             }
         }