114 lines
3.3 KiB
Go
114 lines
3.3 KiB
Go
package service
|
||
|
||
import (
|
||
"encoding/json"
|
||
"strings"
|
||
|
||
"gorm.io/gorm"
|
||
|
||
"nl-pms-api/internal/commonservice"
|
||
"nl-pms-api/internal/model"
|
||
)
|
||
|
||
// ProfileService 用户公开资料。
|
||
type ProfileService struct {
|
||
DB *gorm.DB
|
||
}
|
||
|
||
// ProfileDTO 对外资料（techTags 为数组）。
|
||
type ProfileDTO struct {
|
||
Nickname string `json:"nickname"`
|
||
Title string `json:"title"`
|
||
Email string `json:"email"`
|
||
Bio string `json:"bio"`
|
||
TechTags []string `json:"techTags"`
|
||
AvatarThumb string `json:"avatarThumb"`
|
||
UpdatedAt string `json:"updatedAt"`
|
||
}
|
||
|
||
func sanitizeProfile(p *ProfileDTO) error {
|
||
p.Nickname = commonservice.ClipRunes(p.Nickname, 32)
|
||
p.Title = commonservice.ClipRunes(p.Title, 48)
|
||
p.Email = commonservice.ClipRunes(p.Email, 128)
|
||
p.Bio = commonservice.ClipRunes(p.Bio, 300)
|
||
if p.Email != "" && (!strings.Contains(p.Email, "@") || strings.ContainsAny(p.Email, " \t")) {
|
||
return commonservice.BadRequest("PROFILE_EMAIL_INVALID")
|
||
}
|
||
tags, seen := []string{}, map[string]bool{}
|
||
for _, t := range p.TechTags {
|
||
t = commonservice.ClipRunes(t, 24)
|
||
if t == "" || seen[strings.ToLower(t)] {
|
||
continue
|
||
}
|
||
seen[strings.ToLower(t)] = true
|
||
tags = append(tags, t)
|
||
if len(tags) >= 20 {
|
||
break
|
||
}
|
||
}
|
||
p.TechTags = tags
|
||
return nil
|
||
}
|
||
|
||
// Get 读取本人资料；无记录返回空结构。
|
||
func (s *ProfileService) Get(userID int64) (*ProfileDTO, error) {
|
||
var row model.UserProfile
|
||
err := s.DB.Where("user_id = ?", userID).First(&row).Error
|
||
if err == gorm.ErrRecordNotFound {
|
||
return &ProfileDTO{TechTags: []string{}}, nil
|
||
}
|
||
if err != nil {
|
||
return nil, commonservice.Internal("QUERY_FAILED")
|
||
}
|
||
return &ProfileDTO{
|
||
Nickname: row.Nickname,
|
||
Title: row.Title,
|
||
Email: row.Email,
|
||
Bio: row.Bio,
|
||
TechTags: parseTechTags(row.TechTags),
|
||
AvatarThumb: row.AvatarThumb,
|
||
UpdatedAt: row.UpdatedAt,
|
||
}, nil
|
||
}
|
||
|
||
// Put LWW 写入资料：仅当传入 updatedAt 更新时覆盖。
|
||
func (s *ProfileService) Put(userID int64, p ProfileDTO) (*ProfileDTO, error) {
|
||
if err := sanitizeProfile(&p); err != nil {
|
||
return nil, err
|
||
}
|
||
if p.UpdatedAt == "" {
|
||
p.UpdatedAt = commonservice.NowRFC()
|
||
}
|
||
tags, _ := json.Marshal(p.TechTags)
|
||
var remote model.UserProfile
|
||
err := s.DB.Where("user_id = ?", userID).First(&remote).Error
|
||
if err == nil && remote.UpdatedAt >= p.UpdatedAt {
|
||
// 远端相同或更新：返回远端，不覆盖。
|
||
return &ProfileDTO{
|
||
Nickname: remote.Nickname,
|
||
Title: remote.Title,
|
||
Email: remote.Email,
|
||
Bio: remote.Bio,
|
||
TechTags: parseTechTags(remote.TechTags),
|
||
AvatarThumb: remote.AvatarThumb,
|
||
UpdatedAt: remote.UpdatedAt,
|
||
}, nil
|
||
}
|
||
q := `INSERT INTO user_profiles(user_id,nickname,title,email,bio,tech_tags,avatar_thumb,updated_at)
|
||
VALUES(?,?,?,?,?,?,?,?)
|
||
ON DUPLICATE KEY UPDATE nickname=VALUES(nickname),title=VALUES(title),email=VALUES(email),bio=VALUES(bio),
|
||
tech_tags=VALUES(tech_tags),avatar_thumb=VALUES(avatar_thumb),updated_at=VALUES(updated_at)`
|
||
if err := s.DB.Exec(q, userID, p.Nickname, p.Title, p.Email, p.Bio, string(tags), p.AvatarThumb, p.UpdatedAt).Error; err != nil {
|
||
return nil, commonservice.Internal("SAVE_FAILED")
|
||
}
|
||
return &p, nil
|
||
}
|
||
|
||
func parseTechTags(s string) []string {
|
||
out := []string{}
|
||
if json.Unmarshal([]byte(s), &out) != nil {
|
||
return []string{}
|
||
}
|
||
return out
|
||
}
|