DEV-MERGE-LEGACY-BACKEND-2026/internal/identity/service/wechat_service.go

// 微信扫码登录服务（PC 端扫码登录链路编排，复用两步登录②票据机制）。
//
// 与 AuthService（账密两步登录）的关系：
//   - 本服务**复用**两步登录的"② 签 token"机制——扫码成功后生成一张 loginTicket 存入 Redis，
//     前端拿到 status=success + loginTicket 后，与账密登录**完全同一套** ② /auth/issue 签 token。
//     不在此处直接签 token（不重造 ②，避免"作用域校验/菜单下发"逻辑两处漂移）。
//   - 本服务只做微信扫码特有的三件事：① 生成二维码（state 落 Redis）；② 微信回调 code 换 openid →
//     查 t_identity(wechat) → 发 loginTicket 写回 state；③ 前端轮询读 state 返回进度。
//
// 依赖方向：service → wechat.Client（第三方）+ redis.WeChatQrcodeStore/LoginTicketStore +
// repository.IdentityRepository + model；不依赖 handler/main（纯业务，可纯单测：
// fake wechat.Client + miniredis 双 store + mock identity repo）。
package service

import (
	"context"
	"crypto/rand"
	"encoding/hex"
	stderrors "errors"
	"time"

	"yuansiwei/unified-backend/internal/identity/model"
	"yuansiwei/unified-backend/internal/identity/repository"
	"yuansiwei/unified-backend/internal/identity/wechat"
	apperrors "yuansiwei/unified-backend/internal/infra/errors"
	appredis "yuansiwei/unified-backend/internal/infra/redis"
)

// WeChat 扫码状态机取值（state.Status 字段；前端据状态决定是否继续轮询）。
const (
	// WechatQrcodePending 已生成二维码、等待用户扫码（前端继续轮询）。
	WechatQrcodePending = "pending"
	// WechatQrcodeSuccess 扫码成功、已绑定用户、已发 loginTicket（前端停轮询，携 ticket 走 ② issue）。
	WechatQrcodeSuccess = "success"
	// WechatQrcodeUnbound 扫码成功但 openid 未绑定本平台账号（前端停轮询，提示"该微信号未绑定账号"）。
	WechatQrcodeUnbound = "unbound"
	// WechatQrcodeFail 微信换 openid 失败（第三方错误）（前端停轮询，提示"扫码失败，请重试"）。
	WechatQrcodeFail = "fail"
)

// defaultWechatStateTTL 扫码会话有效期（生成二维码 → 扫码 → 轮询到 success 的窗口；
// 与 loginTicketTTL 对齐 5min，给前端留足操作时间）。
const defaultWechatStateTTL = 5 * time.Minute

// WechatService 微信扫码登录业务服务（状态机 + 复用两步票据）。
//
// 字段（装配入口 NewWechatService 注入，均必填）：
//   - client：微信网页授权客户端（code 换 openid；生产 *wechat.HTTPClient，单测 fake）。
//   - states：扫码状态机存储（per-state 会话，Redis；双实例共享）。
//   - tickets：登录票据存储（扫码成功后签发 loginTicket，复用 AuthService 同一存储）。
//   - identities：登录身份仓储（查 (type=wechat, identifier=open_id) → canonical_user_id）。
//   - campuses：per-campus 微信应用配置（来自 config.WeChatCfg.Campuses，决定 appid/secret）。
//   - callbackURL：对外回调地址（微信重定向落点；未配置时 New 报错，不允许"无回调地址生成二维码"）。
type WechatService struct {
	client      wechat.Client
	states      *appredis.WechatQrcodeStore
	tickets     *appredis.LoginTicketStore
	identities  repository.IdentityRepository
	campuses    []WechatCampus
	callbackURL string
	stateTTL    time.Duration
	ticketTTL   time.Duration
}

// WechatCampus per-campus 微信应用（从 config.WeChatCampus 转换；Service 自持避免 infra/config 泄漏进单测）。
type WechatCampus struct {
	CampusID int64
	AppID    string
	Secret   string
}

// WechatConfig WechatService 装配参数（main 按此构造；全部必填，缺则 New 报错）。
type WechatConfig struct {
	Client      wechat.Client
	States      *appredis.WechatQrcodeStore
	Tickets     *appredis.LoginTicketStore
	Identities  repository.IdentityRepository
	Campuses    []WechatCampus
	CallbackURL string
	// StateTTL / TicketTTL 可选：0/缺省用 5min。
	StateTTL  time.Duration
	TicketTTL time.Duration
}

// NewWechatService 构造微信扫码登录服务（启动装配一次，全进程共享）。
//
// 入参：cfg WechatConfig：见 WechatConfig 字段说明。
// 出参：
//   - *WechatService：就绪服务。
//   - error：必填依赖缺失（nil 检查，fail-fast）/ 无 campus 配置 / callbackURL 为空。
func NewWechatService(cfg WechatConfig) (*WechatService, error) {
	if cfg.Client == nil {
		return nil, apperrors.New(apperrors.CodeInternal, "wechat: 微信客户端未注入")
	}
	if cfg.States == nil {
		return nil, apperrors.New(apperrors.CodeInternal, "wechat: 扫码状态机存储未注入")
	}
	if cfg.Tickets == nil {
		return nil, apperrors.New(apperrors.CodeInternal, "wechat: 登录票据存储未注入")
	}
	if cfg.Identities == nil {
		return nil, apperrors.New(apperrors.CodeInternal, "wechat: 登录身份仓储未注入")
	}
	if len(cfg.Campuses) == 0 {
		return nil, apperrors.New(apperrors.CodeInternal, "wechat: 无 per-campus 微信应用配置（Campuses 至少 1 条）")
	}
	if cfg.CallbackURL == "" {
		return nil, apperrors.New(apperrors.CodeInternal, "wechat: 回调地址为空（CallbackURL 必填，且须为已登记的 https 网页授权回调域名）")
	}
	stTTL := cfg.StateTTL
	if stTTL <= 0 {
		stTTL = defaultWechatStateTTL
	}
	tkTTL := cfg.TicketTTL
	if tkTTL <= 0 {
		tkTTL = defaultWechatStateTTL
	}
	return &WechatService{
		client:      cfg.Client,
		states:      cfg.States,
		tickets:     cfg.Tickets,
		identities:  cfg.Identities,
		campuses:    cfg.Campuses,
		callbackURL: cfg.CallbackURL,
		stateTTL:    stTTL,
		ticketTTL:   tkTTL,
	}, nil
}

// QRCodeResult 生成二维码出参（前端渲染 + 轮询凭据）。
type QRCodeResult struct {
	// State 会话标识（16 字节 hex；前端据此轮询 /auth/wechat/status?state=）。
	State string `json:"state"`
	// QRURL 二维码内容（指向微信网页授权 URL，含 state；前端生成二维码图片）。
	QRURL string `json:"qrUrl"`
	// CampusID 本次选定的校区（提示前端"正在登录 X 校区"）。
	CampusID int64 `json:"campusId"`
	// ExpiresIn 会话有效期（秒；前端据此展示倒计时/停止轮询）。
	ExpiresIn int64 `json:"expiresIn"`
}

// Qrcode 生成扫码登录二维码（GET /auth/wechat/qrcode 编排）。
//
// 行为：选第一个配置的 campus → 生成随机 state → 写 Redis(pending, campusId) → 返回 state + QR URL。
//
// 出参：
//   - *QRCodeResult：state + 二维码 URL。
//   - error：*AppError（CodeInternal：Redis 写失败——fail-closed，不放行"无 state 的二维码"）。
func (s *WechatService) Qrcode(ctx context.Context) (*QRCodeResult, error) {
	campus := s.campuses[0] // 多 campus 选第一个（后续可加 campus 选择入参，本期 PC 统一）
	state, err := s.newState()
	if err != nil {
		return nil, apperrors.WithCause(apperrors.ErrInternal, err)
	}
	st := appredis.WechatState{Status: WechatQrcodePending, CampusID: campus.CampusID}
	if err := s.states.SetState(ctx, state, st, s.stateTTL); err != nil {
		return nil, err // *AppError（ErrDBError）——Redis 故障，fail-closed
	}
	return &QRCodeResult{
		State:     state,
		QRURL:     wechat.BuildQRConnectURL(campus.AppID, s.callbackURL, state),
		CampusID:  campus.CampusID,
		ExpiresIn: int64(s.stateTTL / time.Second),
	}, nil
}

// StatusResult 轮询状态出参（前端据此驱动 UI：pending 继续轮 / success 携 ticket 走 ② / 终态停轮）。
type StatusResult struct {
	// Status 状态机取值（pending/success/unbound/fail，见 WechatQrcode* 常量）。
	Status string `json:"status"`
	// CampusID 本次会话的校区（success/unbound 时回显，供前端提示）。
	CampusID int64 `json:"campusId"`
	// LoginTicket success 时携带的登录票据（前端用同一套 ② /auth/issue 签 token）。
	LoginTicket string `json:"loginTicket,omitempty"`
	// UserID success 时绑定的用户 ULID（前端可据此展示"已登录 X"）。
	UserID string `json:"userId,omitempty"`
	// Expired true = state 不存在/已过期（前端停止轮询，提示"二维码已失效，请刷新"）。
	// 与 Status 互斥：Expired=true 时 Status 为空串（调用方按 Expired 优先判断）。
	Expired bool `json:"expired,omitempty"`
}

// Status 轮询扫码状态（GET /auth/wechat/status?state= 编排；只读快照，不消费）。
//
// 出参：
//   - *StatusResult：当前状态（见 StatusResult 字段）。
//   - error：*AppError（CodeInternal/DBError：Redis 读失败——fail-closed，不放行"读不到当已失效"）。
func (s *WechatService) Status(ctx context.Context, state string) (*StatusResult, error) {
	st, err := s.states.GetState(ctx, state)
	if err != nil {
		return nil, err // *AppError（ErrDBError）——Redis 故障，fail-closed
	}
	if st.Status == "" {
		// 键不存在/已过期：返回"已失效"（前端停轮询，提示刷新）——这是正常的"过期"语义，非故障。
		return &StatusResult{Expired: true}, nil
	}
	res := &StatusResult{Status: st.Status, CampusID: st.CampusID}
	if st.Status == WechatQrcodeSuccess {
		res.LoginTicket = st.Ticket
		res.UserID = st.UserID
	}
	return res, nil
}

// Callback 微信重定向落点（GET /auth/wechat/callback?code=&state= 编排）。
//
// 行为：读 state 会话 → 校验仍 pending（防重放）→ code 换 openid → 查 t_identity(wechat) →
//   - 命中：发 loginTicket（复用 ② 机制）写回 state=success；
//   - 未命中：state=unbound（提示"该微信号未绑定账号"）。
//
// 出参：
//   - *StatusResult：回调后的状态（success/unbound/fail，前端据此决定跳登录或提示）。
//   - error：*AppError：
//     - ErrDBError(5002)：Redis 读写故障（fail-closed）；
//     - CodeThirdTimeout(4003)：微信换 openid 失败（state 置 fail）；
//     - ErrUnauth(1001)：state 不存在/已过期/已终态（防重放，前端提示"二维码已失效"）。
func (s *WechatService) Callback(ctx context.Context, code, state string) (*StatusResult, error) {
	if code == "" || state == "" {
		return nil, apperrors.ErrBadParam
	}
	st, err := s.states.GetState(ctx, state)
	if err != nil {
		return nil, err // Redis 故障 fail-closed
	}
	if st.Status == "" {
		// state 不存在/已过期：拒绝（防重放 + 防任意 state 注入）
		return nil, apperrors.New(apperrors.CodeUnauth, "扫码会话已失效，请重新获取二维码")
	}
	if st.Status != WechatQrcodePending {
		// 已终态（success/unbound/fail）：拒绝二次回调（防重放）
		return nil, apperrors.New(apperrors.CodeUnauth, "扫码会话已结束，请重新获取二维码")
	}

	campus := s.campusByID(st.CampusID)
	if campus == nil {
		// 会话 campusId 对不上配置（配置热变更/脏数据）：置 fail
		_ = s.states.SetState(ctx, state, appredis.WechatState{Status: WechatQrcodeFail, CampusID: st.CampusID}, s.stateTTL)
		return &StatusResult{Status: WechatQrcodeFail, CampusID: st.CampusID}, nil
	}

	// code 换 openid（第三方；失败置 fail）
	openid, err := s.client.ExchangeCode(ctx, campus.AppID, campus.Secret, code, s.callbackURL)
	if err != nil {
		_ = s.states.SetState(ctx, state, appredis.WechatState{Status: WechatQrcodeFail, CampusID: st.CampusID}, s.stateTTL)
		return nil, apperrors.New(apperrors.CodeThirdTimeout, "微信扫码失败，请重试") // 4003 第三方
	}

	// 查绑定：(type=wechat, identifier=open_id) → canonical_user_id
	it, err := s.identities.GetByTypeIdentifier(ctx, model.IdentityTypeWechat, openid)
	if err != nil {
		if stderrors.Is(err, apperrors.ErrNotFound) {
			// 未绑定：置 unbound（前端提示"该微信号未绑定账号"，引导去账密登录后绑定）
			_ = s.states.SetState(ctx, state, appredis.WechatState{Status: WechatQrcodeUnbound, CampusID: st.CampusID}, s.stateTTL)
			return &StatusResult{Status: WechatQrcodeUnbound, CampusID: st.CampusID}, nil
		}
		return nil, err // *AppError（ErrDBError）
	}

	// 已绑定：发 loginTicket（复用 ② 机制）写回 state=success
	ticket, terr := s.newTicket()
	if terr != nil {
		return nil, apperrors.WithCause(apperrors.ErrInternal, terr)
	}
	if setErr := s.tickets.SetTicket(ctx, ticket, it.CanonicalUserID, s.ticketTTL); setErr != nil {
		return nil, setErr // *AppError（ErrDBError）——票据写失败阻断（不放行半套）
	}
	final := appredis.WechatState{
		Status:   WechatQrcodeSuccess,
		CampusID: st.CampusID,
		Ticket:   ticket,
		UserID:   it.CanonicalUserID,
	}
	if setErr := s.states.SetState(ctx, state, final, s.stateTTL); setErr != nil {
		return nil, setErr
	}
	return &StatusResult{Status: WechatQrcodeSuccess, CampusID: st.CampusID, LoginTicket: ticket, UserID: it.CanonicalUserID}, nil
}

// ---- 私有工具 ----

// campusByID 按 campusId 取配置（找不到返回 nil——调用方按"脏数据"置 fail）。
func (s *WechatService) campusByID(campusID int64) *WechatCampus {
	for i := range s.campuses {
		if s.campuses[i].CampusID == campusID {
			return &s.campuses[i]
		}
	}
	return nil
}

// newState 生成扫码会话 state（16 字节随机 → 32 hex）。
func (s *WechatService) newState() (string, error) {
	buf := make([]byte, 16)
	if _, err := rand.Read(buf); err != nil {
		return "", err
	}
	return hex.EncodeToString(buf), nil
}

// newTicket 生成登录票据（16 字节随机 → 32 hex，与 AuthService.newTicket 同语义）。
func (s *WechatService) newTicket() (string, error) {
	buf := make([]byte, 16)
	if _, err := rand.Read(buf); err != nil {
		return "", err
	}
	return hex.EncodeToString(buf), nil
}