From b6b3ae2a6cbb69c745f9ed29e4f9dafef7a05043 Mon Sep 17 00:00:00 2001
From: wangkang <wangkangit@163.com>
Date: Wed, 29 Nov 2017 10:45:10 +0800
Subject: [PATCH] =?UTF-8?q?=E9=98=BF=E9=87=8C=E4=BA=91OSS=E7=94=9F?=
 =?UTF-8?q?=E6=88=90=E7=AD=BE=E5=90=8DURL=E5=88=A4=E6=96=ADobjectKey?=
 =?UTF-8?q?=E6=98=AF=E5=90=A6=E5=AD=98=E5=9C=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/udf-starter-file-aliyun-oss/src/main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java b/udf-starter-file-aliyun-oss/src/main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java
index f21c733..76641fe 100644
--- a/udf-starter-file-aliyun-oss/src/main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java
+++ b/udf-starter-file-aliyun-oss/src/main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java
@@ -104,6 +104,10 @@ public class OssWarpper {
         //实例化oss对象
         OSSClient client = new OSSClient(auth.getEndPoint(), auth.getAccessId(), auth.getAccessKey());
         try {
+            //判断文件是否存在
+            if (!client.doesObjectExist(path.getBucketName(), objectKey)) {
+                throw new ParameterValidException(objectKey + "不存在", null);
+            }
             //构造超时时间
             long expireEndTime = System.currentTimeMillis() + auth.getExpireTime() * NUM_1000;
             Date expiration = new Date(expireEndTime);