From b5fc6dbf04f34f16b6576baba270427d98517e3d Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Fri, 21 Apr 2023 19:52:57 +0800
Subject: [PATCH] third

---
 pkg/common/db/controller/storage.go | 6 +++---
 pkg/errs/code.go                    | 4 ++++
 pkg/errs/predefine.go               | 3 +++
 3 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/pkg/common/db/controller/storage.go b/pkg/common/db/controller/storage.go
index 78c881e5b..3b3361c3c 100644
--- a/pkg/common/db/controller/storage.go
+++ b/pkg/common/db/controller/storage.go
@@ -274,14 +274,14 @@ func (c *s3Database) ConfirmPut(ctx context.Context, req *third.ConfirmPutReq) (
 		}
 	}()
 	if put.Complete {
-		return nil, errors.New("put completed")
+		return nil, errs.ErrFileUploadedComplete.Wrap("put complete")
 	}
 	now := time.Now().UnixMilli()
 	if put.EffectiveTime.UnixMilli() < now {
-		return nil, errors.New("upload expired")
+		return nil, errs.ErrFileUploadedExpired.Wrap("put expired")
 	}
 	if put.ValidTime != nil && put.ValidTime.UnixMilli() < now {
-		return nil, errors.New("object expired")
+		return nil, errs.ErrFileUploadedExpired.Wrap("object expired")
 	}
 	if hash, err := c.hash.Take(ctx, put.Hash, c.obj.Name()); err == nil {
 		o := relation.ObjectInfoModel{
diff --git a/pkg/errs/code.go b/pkg/errs/code.go
index 36c0e2e81..4380358ce 100644
--- a/pkg/errs/code.go
+++ b/pkg/errs/code.go
@@ -82,4 +82,8 @@ const (
 	ConnOverMaxNumLimit = 1601
 	ConnArgsErr         = 1602
 	ConnUpdateErr       = 1603
+
+	// S3错误码
+	FileUploadedCompleteError = 2001 // 文件已上传
+	FileUploadedExpiredError  = 2002 // 上传过期
 )
diff --git a/pkg/errs/predefine.go b/pkg/errs/predefine.go
index 6ba2f76f8..5f16fe5c0 100644
--- a/pkg/errs/predefine.go
+++ b/pkg/errs/predefine.go
@@ -58,4 +58,7 @@ var (
 	ErrConnUpdateErr = NewCodeError(ConnArgsErr, "upgrade http conn err")
 
 	ErrConfig = NewCodeError(ConfigError, "ConfigError")
+
+	ErrFileUploadedComplete = NewCodeError(FileUploadedCompleteError, "FileUploadedComplete")
+	ErrFileUploadedExpired  = NewCodeError(FileUploadedExpiredError, "FileUploadedExpiredError")
 )