Blizzard
cbfcaada55
竞品那张「居民身份卡」，完整做了。 ## 后端 service/wxacode.go —— 小程序码。两步：先拿 access_token（2h 有效，进程内缓存、 提前 5 分钟过期），再调 getwxacodeunlimit 换一张 PNG 存到 MinIO 返回 URL。 同一只宠物的码 object 名按 pet id 定死，存在就直接返回不重新生成 —— 微信侧有日调用配额，不能每次点都烧一次。 ⚠️ getwxacodeunlimit 要求 page 在**已发布**的小程序版本里。开发/未发布时返回 errcode 41030，实测确认。这时身份卡照常出、只是没码（qr_ready=false）， 发布后自动就有，不用改代码。best-effort，取不到不算错。 service/idcard.go —— 组装卡片内容。身份 ID 用「宠物雪花 id 的数字 + 生日」 拼成 18 位、每 4 位空一下，纯装饰不入库不校验，同一只每次都一样。 介绍按物种给默认（汪星人/喵星人来地球啦~）。有效期用生日起算。 GET /api/pets/:id/id-card storage 加了 Exists（StatObject），生成前先查。 ## 前端 pages/idcard 离屏 canvas 2d 画卡，导出成图展示 + 存相册 + 分享（open-type=share， imageUrl 用画好的卡当封面）。 两张远程图（头像 + 小程序码）都用 node.createImage() 异步加载， **Promise.all 等两张都就绪再开画** —— 否则小程序码会画不上或画一半 （规划里专门点过名的坑）。任一张加载失败 resolve(null)，缺图也照画： 头像缺→画物种 emoji，码缺→画「小程序码 待发布」占位框。 存相册的权限被拒过一次后 wx.authorize 不再弹，走 openSetting 引导（同海报那套）。 绘制复用了 bottom-sheet 里 poster 的 canvas 模式（dpr 放大、roundRect、 canvasToTempFilePath），但 poster 只画文字不画远程图，这里的双图加载是新写的。 入口：「我的」→ 身份卡，用当前选中的宠物。 ## 验证（预生产库实跑） id-card 接口返回：姓名/性别/品种/生日/介绍/身份ID/有效期 全对 身份 ID = 3410 4333 1420 2503 17（宠物id数字+生日，稳定） qr_ready = false，日志确认 41030 invalid page（小程序未发布，预期） canvas 版式用 HTML 复刻确认过：未发布=占位、发布后=真码 Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
108 lines
3.2 KiB
Go
108 lines
3.2 KiB
Go
package storage
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"io"
|
|
"log"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/minio/minio-go/v7"
|
|
"github.com/minio/minio-go/v7/pkg/credentials"
|
|
|
|
"github.com/sundynix/pets-be/internal/config"
|
|
)
|
|
|
|
// Storage MinIO 对象存储封装
|
|
type Storage struct {
|
|
client *minio.Client
|
|
bucket string
|
|
publicBaseURL string
|
|
}
|
|
|
|
// New 初始化 MinIO 客户端，并确保 bucket 存在且可公开下载
|
|
func New(cfg config.MinIOConfig) (*Storage, error) {
|
|
client, err := minio.New(cfg.Endpoint, &minio.Options{
|
|
Creds: credentials.NewStaticV4(cfg.AccessKey, cfg.SecretKey, ""),
|
|
Secure: cfg.UseSSL,
|
|
})
|
|
if err != nil {
|
|
return nil, fmt.Errorf("minio new: %w", err)
|
|
}
|
|
|
|
s := &Storage{
|
|
client: client,
|
|
bucket: cfg.Bucket,
|
|
publicBaseURL: strings.TrimRight(cfg.PublicBaseURL, "/"),
|
|
}
|
|
if err := s.ensureBucket(); err != nil {
|
|
return nil, err
|
|
}
|
|
return s, nil
|
|
}
|
|
|
|
func (s *Storage) ensureBucket() error {
|
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
|
defer cancel()
|
|
|
|
exists, err := s.client.BucketExists(ctx, s.bucket)
|
|
if err != nil {
|
|
return fmt.Errorf("bucket exists: %w", err)
|
|
}
|
|
if exists {
|
|
// 桶已存在：绝不碰它的策略。MinIO 可能是多个服务共用的，
|
|
// 万一 bucket 配错（填成别的服务的桶），无条件改策略会把人家的桶
|
|
// 悄悄变成全网可读。已存在的桶由运维一次性配好读权限。
|
|
log.Printf("minio: 复用已存在的 bucket %q（不修改其访问策略）", s.bucket)
|
|
return nil
|
|
}
|
|
|
|
if err := s.client.MakeBucket(ctx, s.bucket, minio.MakeBucketOptions{}); err != nil {
|
|
return fmt.Errorf("make bucket: %w", err)
|
|
}
|
|
// 仅对「本服务刚创建」的桶设公开只读：小程序要用 URL 直接加载图片。
|
|
policy := fmt.Sprintf(`{
|
|
"Version": "2012-10-17",
|
|
"Statement": [{
|
|
"Effect": "Allow",
|
|
"Principal": {"AWS": ["*"]},
|
|
"Action": ["s3:GetObject"],
|
|
"Resource": ["arn:aws:s3:::%s/*"]
|
|
}]
|
|
}`, s.bucket)
|
|
if err := s.client.SetBucketPolicy(ctx, s.bucket, policy); err != nil {
|
|
return fmt.Errorf("set bucket policy: %w", err)
|
|
}
|
|
log.Printf("minio: 已创建 bucket %q 并设为公开只读（图片需可直链访问）", s.bucket)
|
|
return nil
|
|
}
|
|
|
|
// Upload 上传对象，返回可公开访问的 URL
|
|
func (s *Storage) Upload(objectName string, reader io.Reader, size int64, contentType string) (string, error) {
|
|
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
|
|
defer cancel()
|
|
|
|
_, err := s.client.PutObject(ctx, s.bucket, objectName, reader, size, minio.PutObjectOptions{
|
|
ContentType: contentType,
|
|
})
|
|
if err != nil {
|
|
return "", fmt.Errorf("put object: %w", err)
|
|
}
|
|
return s.PublicURL(objectName), nil
|
|
}
|
|
|
|
// Exists 对象在不在。小程序码有微信侧配额，同一只宠物的码存一次就够，
|
|
// 生成前先查
|
|
func (s *Storage) Exists(objectName string) bool {
|
|
ctx, cancel := context.WithTimeout(context.Background(), 8*time.Second)
|
|
defer cancel()
|
|
_, err := s.client.StatObject(ctx, s.bucket, objectName, minio.StatObjectOptions{})
|
|
return err == nil
|
|
}
|
|
|
|
// PublicURL 由对象名拼出可访问 URL（用当前配置的 public_base_url，避免存旧地址）
|
|
func (s *Storage) PublicURL(objectName string) string {
|
|
return fmt.Sprintf("%s/%s/%s", s.publicBaseURL, s.bucket, objectName)
|
|
}
|