Merge branch 'develop' of https://gitee.com/fusenpack/fusenapi into develop

utils/curl/client_resty.go

@@ -65,7 +65,7 @@ type (
 
 // PostJson请求
 func (c *defaultClient) PostJson(jsonData interface{}, res interface{}) error {
-	logc.Infof(c.ctx, "客户端名称 Client PostJson jsonData:%+v", jsonData)
+	//logc.Infof(c.ctx, "客户端名称 Client PostJson jsonData:%+v", jsonData)
 
 	logc.Infof(c.ctx, "客户端名称 请求开始时间:%+v", time.Now().UTC())
 	resp, err := c.client.

utils/file/upload.go

@@ -70,12 +70,14 @@ func (upload *Upload) UploadFileByBase64(req *UploadBaseReq) (*UploadBaseRes, er
 
 	var uploadBaseRes = UploadBaseRes{}
 
+	// 是否强制刷新
 	var refresh bool
-
 	if req.ResourceId != "" {
-		refresh = true
 		resourceId = req.ResourceId
 	}
+	if req.Refresh == 1 {
+		refresh = true
+	}
 	err := upload.MysqlConn.Transaction(func(tx *gorm.DB) (err error) {
 		var resourceInfo *gmodel.FsResource
 
@@ -198,15 +200,28 @@ func (upload *Upload) UploadFileByByte(req *UploadBaseReq) (*UploadBaseRes, erro
 
 	var uploadBaseRes = UploadBaseRes{}
 
-	err := upload.MysqlConn.Transaction(func(tx *gorm.DB) error {
+	// 是否强制刷新
+	var refresh bool
+	if req.ResourceId != "" {
+		resourceId = req.ResourceId
+	}
+	if req.Refresh == 1 {
+		refresh = true
+	}
+
+	err := upload.MysqlConn.Transaction(func(tx *gorm.DB) (err error) {
 		var resourceInfo *gmodel.FsResource
-		err := tx.Where("resource_id =?", resourceId).Take(&resourceInfo).Error
-		// resourceInfo, err := resourceModelTS.FindOneById(ctx, resourceId)
-		if err == nil && resourceInfo.ResourceId != "" {
-			uploadBaseRes.Status = 1
-			uploadBaseRes.ResourceId = resourceId
-			uploadBaseRes.ResourceUrl = *resourceInfo.ResourceUrl
-		} else {
+		if !refresh {
+			err = tx.Where("resource_id =?", resourceId).Take(&resourceInfo).Error
+			if err == nil && resourceInfo.ResourceId != "" {
+				uploadBaseRes.Status = 1
+				uploadBaseRes.ResourceId = resourceId
+				uploadBaseRes.ResourceUrl = *resourceInfo.ResourceUrl
+			} else {
+				refresh = true
+			}
+		}
+		if refresh {
 			contentType := http.DetectContentType(req.FileByte)
 			// 创建S3对象存储请求
 			s3req, _ = svc.PutObjectRequest(
@@ -235,19 +250,35 @@ func (upload *Upload) UploadFileByByte(req *UploadBaseReq) (*UploadBaseRes, erro
 				uploadBaseRes.ResourceUrl = url
 				var version string = "0.0.1"
 				var nowTime = time.Now().UTC()
-				err = tx.Create(&gmodel.FsResource{
-					ResourceId:   resourceId,
-					UserId:       &req.UserId,
-					GuestId:      &req.GuestId,
-					ResourceType: &contentType,
-					ResourceUrl:  &url,
-					Version:      &version,
-					UploadedAt:   &nowTime,
-					Metadata:     &req.Metadata,
-					ApiType:      &apiType,
-					BucketName:   bucketName,
-					Source:       &req.Source,
-				}).Error
+				if refresh {
+					err = tx.Save(&gmodel.FsResource{
+						ResourceId:   resourceId,
+						UserId:       &req.UserId,
+						GuestId:      &req.GuestId,
+						ResourceType: &contentType,
+						ResourceUrl:  &url,
+						Version:      &version,
+						UploadedAt:   &nowTime,
+						Metadata:     &req.Metadata,
+						ApiType:      &apiType,
+						BucketName:   bucketName,
+						Source:       &req.Source,
+					}).Error
+				} else {
+					err = tx.Create(&gmodel.FsResource{
+						ResourceId:   resourceId,
+						UserId:       &req.UserId,
+						GuestId:      &req.GuestId,
+						ResourceType: &contentType,
+						ResourceUrl:  &url,
+						Version:      &version,
+						UploadedAt:   &nowTime,
+						Metadata:     &req.Metadata,
+						ApiType:      &apiType,
+						BucketName:   bucketName,
+						Source:       &req.Source,
+					}).Error
+				}
 				if err != nil {
 					logx.Errorf("err:%+v，desc:%+v", err, "fail.upload.resourceInfoAdd.mysql")
 					return err