基于DDD落地Go微服务开发总结

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

func (i *UploadImageIntf) UploadImage(req interface{}) (rsp interface{}, err error) {
    ctx := context.Background()

    // fill data from info
    images, err := i.app.UploadImage(ctx, &entity.UploadInfo{
        FileName:   "",
        WebUrl:     "",
        UploadFrom: 0,
        Method:     0,
        Style:      nil,
        Tag:        nil,
    })
    if err != nil {
        return nil, err
    }

    // json rsp
    data, _ := json.Marshal(images)
    _ = data

    // rsp.data = data
    return rsp, nil
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

// UploadImage 图片上传
func (app *ImageUploadApp) UploadImage(ctx context.Context, updInfo *entity.UploadInfo) ([]*entity.Image, error) {
    // 1. 图片解析&上传&水印
    var uploadImgFiles []*entity.UploadFile
    var err error
    from := updInfo.UploadFrom
    switch from {
    case entity.UploadFromAI:
        // 获取prompt 配置
        uploadImgFiles, err = app.srv.UploadAIImage(ctx, "key", "macbook in the sky")
        if err != nil {
            return nil, errors.Wrap(err, "upload ai image got err")
        }
    case entity.UploadFromLocalFile:
        // 获取上传图片
        var uploads []*os.File
        uploadImgFiles, err = app.srv.UploadLocalImage(ctx, uploads)
        if err != nil {
            return nil, errors.Wrap(err, "upload local image got err")
        }
    case entity.UploadFromWebUrl:
        // 从data 获取weburl
        var webUrls []string
        uploadImgFiles, err = app.srv.UploadWebImage(ctx, webUrls)
        if err != nil {
            return nil, errors.Wrap(err, "upload web url image got err")
        }
    default:
        return nil, errors.New("error upload image type")
    }

    // 2. 存储到DB
    imgs, err := app.srv.StorageImage(ctx, 0, uploadImgFiles)
    if err != nil {
        return nil, errors.Wrap(err, "storage image got err")
    }

    return imgs, nil
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17

// IServiceImageUpload 图片上传服务接口
type IServiceImageUpload interface {
    // UploadLocalImage 本地图片上传&保存
    UploadLocalImage(ctx context.Context, uploads []*os.File) ([]*entity.UploadFile, error)

    // UploadAIImage 按域定义的prompt key生成AI图片上传&保存
    UploadAIImage(ctx context.Context, promptKey string, keywords string) ([]*entity.UploadFile, error)

    // UploadWebImage 上传了一张web url地址图片，需要下载webUrl图片，保存图片
    UploadWebImage(ctx context.Context, webImgUrl []string) ([]*entity.UploadFile, error)

    // StorageImage 将上传处理后的文件，附加标签等信息后，存储到DB中
    StorageImage(ctx context.Context, method entity.StorageMethod, imgs []*entity.UploadFile) ([]*entity.Image, error)

    // GetImages 通过图片的uuid获取指定上传的文件信息
    GetImages(uuids []uint64) ([]*entity.Image, error)
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18

// UploadInfo 上传信息 - 值对象
type UploadInfo struct {
	FileName   string         // 本地文件名称
	WebUrl     string         // 网络图片URL
	UploadFrom UploadFromType // 图片上传来源
	Method     StorageMethod
	Style      *Style
	Tag        *Tag
}

// UploadFile 上传文件 - 实体
type UploadFile struct {
	UploadInfo *UploadInfo // 图片上传信息

	SaveMethod      StorageMethod // 保存方式
	OriginImagePath string        // 保存路径
	WaterImagePath  string        // 水印图
}

1
2
3
4
5
6
7

type IReposStorage interface {
	// SaveImage 图片存储到指定服务（可能是本地文件存储服务、COS等）
	SaveImage(imgs []*entity.Image) error

	// FindImages 基于图片ID从存储中找到文件
	FindImages(ids []uint64) ([]*entity.Image, error)
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22

func (infra *MysqlInfra) SaveImage(imgs []*entity.Image) error {
	err := infra.db.Debug().CreateInBatches(imgs, 100).Error
	if err != nil {
		return errors.Wrap(err, "db sql[SaveImage] got err")
	}

	return nil
}

func (infra *MysqlInfra) FindImages(ids []uint64) ([]*entity.Image, error) {
	var records []*entity.Image
	err := infra.db.Debug().
		Find(&records, "uuid in (?)", ids).Error
	if err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return nil, nil
		}
		return nil, errors.Wrap(err, "db sql[FindImages] got err")
	}

	return records, nil
}