Spaces:

a3216
/

gcli2api

Running

gcli2api / internal /upstream /streak.go

chore: 同步到上游 1.12.0-panel + 凭证同步/独立启动器/保活

6d60378 verified about 1 month ago

3.77 kB

// streak.go 成长中心连登兑换 + 抽奖 API（2026-09-12 成长中心 bundle 逆向 + 页面实测）。
//
// 机制：连登档位（7d/14d/28d）按**连续登录天数**解锁；兑换（POST /activity/growth/redeem）
// 发 credit/energy/补签卡/**抽奖次数**；抽奖（POST /activity/growth/lottery/draw）每次消耗
// 1 次 chances。未解锁兑换返回 HTTP 403「连续登录天数不足」。
// client_token 为前端生成的幂等令牌（randomUUID）。
package upstream

import (
	"crypto/rand"
	"encoding/hex"
	"encoding/json"

	"fmt"
	"github.com/linguo2625469/workbuddy2api-panel/internal/auth"
	"net/http"
)

// streakRedeemPath / lottery 路径（growth 域，growthJSON 走 www.workbuddy.cn）。
const (
	streakRedeemPath   = "/activity/growth/redeem"
	lotterySummaryPath = "/activity/growth/lottery/summary"
	lotteryDrawPath    = "/activity/growth/lottery/draw"
)

// clientToken 幂等令牌（前端 randomUUID 同款语义）。
func clientToken() string {
	b := make([]byte, 16)
	_, _ = rand.Read(b)
	return fmt.Sprintf("%s-%s-%s-%s-%s",
		hex.EncodeToString(b[0:4]), hex.EncodeToString(b[4:6]), hex.EncodeToString(b[6:8]),
		hex.EncodeToString(b[8:10]), hex.EncodeToString(b[10:16]))
}

// StreakFull 连登完整状态（GET /activity/growth/streak）。
type StreakFull struct {
	Streak struct {
		Days              int    `json:"days"`
		MonthTotalDays    int    `json:"month_total_days"`
		NextTier          string `json:"next_tier"`
		NextTierRemaining int    `json:"next_tier_remaining"`
	} `json:"streak"`
	MakeupCards struct {
		Balance int `json:"balance"`
		Max     int `json:"max"`
	} `json:"makeup_cards"`
	RedemptionStatus struct {
		Tier7dStatus  string `json:"tier_7d_status"`
		Tier14dStatus string `json:"tier_14d_status"`
		Tier28dStatus string `json:"tier_28d_status"`
		RemainingDays int    `json:"remaining_days"`
		Tiers         []struct {
			Tier    string `json:"tier"`
			Days    int    `json:"days"`
			Credit  int    `json:"credit"`
			Energy  int    `json:"energy"`
			Cards   int    `json:"cards"`
			Chances int    `json:"chances"`
		} `json:"tiers"`
	} `json:"redemption_status"`
}

// GrowthStreakFull 拉取连登完整状态。
func (c *Client) GrowthStreakFull(a *auth.Auth) (*StreakFull, error) {
	data, err := c.growthJSON(a, http.MethodGet, streakPath, nil)
	if err != nil {
		return nil, err
	}
	out := &StreakFull{}
	if err := json.Unmarshal(data, out); err != nil {
		return nil, err
	}
	return out, nil
}

// GrowthRedeemTier 兑换连登档位（tier: "7d"|"14d"|"28d"）。
// 未解锁返回 *Error（HTTP 403「连续登录天数不足」），调用方按 locked 状态跳过即可。
func (c *Client) GrowthRedeemTier(a *auth.Auth, tier string) error {
	_, err := c.growthJSON(a, http.MethodPost, streakRedeemPath,
		map[string]any{"tier": tier, "client_token": clientToken()})
	return err
}

// LotteryChances 当前抽奖次数（GET /activity/growth/lottery/summary）。
func (c *Client) LotteryChances(a *auth.Auth) (int, error) {
	data, err := c.growthJSON(a, http.MethodGet, lotterySummaryPath, nil)
	if err != nil {
		return 0, err
	}
	var resp struct {
		Chances int `json:"chances"`
		Module  struct {
			Enabled bool `json:"enabled"`
		} `json:"module"`
	}
	if err := json.Unmarshal(data, &resp); err != nil {
		return 0, err
	}
	return resp.Chances, nil
}

// LotteryDraw 抽奖一次，返回原始奖品载荷（prize 字段形状由活动期决定，透传给调用方）。
func (c *Client) LotteryDraw(a *auth.Auth) (json.RawMessage, error) {
	return c.growthJSON(a, http.MethodPost, lotteryDrawPath,
		map[string]any{"client_token": clientToken()})
}

	// streak.go 成长中心连登兑换 + 抽奖 API（2026-09-12 成长中心 bundle 逆向 + 页面实测）。
	//
	// 机制：连登档位（7d/14d/28d）按连续登录天数解锁；兑换（POST /activity/growth/redeem）
	// 发 credit/energy/补签卡/抽奖次数；抽奖（POST /activity/growth/lottery/draw）每次消耗
	// 1 次 chances。未解锁兑换返回 HTTP 403「连续登录天数不足」。
	// client_token 为前端生成的幂等令牌（randomUUID）。
	package upstream

	import (
	"crypto/rand"
	"encoding/hex"
	"encoding/json"

	"fmt"
	"github.com/linguo2625469/workbuddy2api-panel/internal/auth"
	"net/http"
	)

	// streakRedeemPath / lottery 路径（growth 域，growthJSON 走 www.workbuddy.cn）。
	const (
	streakRedeemPath = "/activity/growth/redeem"
	lotterySummaryPath = "/activity/growth/lottery/summary"
	lotteryDrawPath = "/activity/growth/lottery/draw"
	)

	// clientToken 幂等令牌（前端 randomUUID 同款语义）。
	func clientToken() string {
	b := make([]byte, 16)
	_, _ = rand.Read(b)
	return fmt.Sprintf("%s-%s-%s-%s-%s",
	hex.EncodeToString(b[0:4]), hex.EncodeToString(b[4:6]), hex.EncodeToString(b[6:8]),
	hex.EncodeToString(b[8:10]), hex.EncodeToString(b[10:16]))
	}

	// StreakFull 连登完整状态（GET /activity/growth/streak）。
	type StreakFull struct {
	Streak struct {
	Days int `json:"days"`
	MonthTotalDays int `json:"month_total_days"`
	NextTier string `json:"next_tier"`
	NextTierRemaining int `json:"next_tier_remaining"`
	} `json:"streak"`
	MakeupCards struct {
	Balance int `json:"balance"`
	Max int `json:"max"`
	} `json:"makeup_cards"`
	RedemptionStatus struct {
	Tier7dStatus string `json:"tier_7d_status"`
	Tier14dStatus string `json:"tier_14d_status"`
	Tier28dStatus string `json:"tier_28d_status"`
	RemainingDays int `json:"remaining_days"`
	Tiers []struct {
	Tier string `json:"tier"`
	Days int `json:"days"`
	Credit int `json:"credit"`
	Energy int `json:"energy"`
	Cards int `json:"cards"`
	Chances int `json:"chances"`
	} `json:"tiers"`
	} `json:"redemption_status"`
	}

	// GrowthStreakFull 拉取连登完整状态。
	func (c Client) GrowthStreakFull(a auth.Auth) (*StreakFull, error) {
	data, err := c.growthJSON(a, http.MethodGet, streakPath, nil)
	if err != nil {
	return nil, err
	}
	out := &StreakFull{}
	if err := json.Unmarshal(data, out); err != nil {
	return nil, err
	}
	return out, nil
	}

	// GrowthRedeemTier 兑换连登档位（tier: "7d"\|"14d"\|"28d"）。
	// 未解锁返回 *Error（HTTP 403「连续登录天数不足」），调用方按 locked 状态跳过即可。
	func (c Client) GrowthRedeemTier(a auth.Auth, tier string) error {
	_, err := c.growthJSON(a, http.MethodPost, streakRedeemPath,
	map[string]any{"tier": tier, "client_token": clientToken()})
	return err
	}

	// LotteryChances 当前抽奖次数（GET /activity/growth/lottery/summary）。
	func (c Client) LotteryChances(a auth.Auth) (int, error) {
	data, err := c.growthJSON(a, http.MethodGet, lotterySummaryPath, nil)
	if err != nil {
	return 0, err
	}
	var resp struct {
	Chances int `json:"chances"`
	Module struct {
	Enabled bool `json:"enabled"`
	} `json:"module"`
	}
	if err := json.Unmarshal(data, &resp); err != nil {
	return 0, err
	}
	return resp.Chances, nil
	}

	// LotteryDraw 抽奖一次，返回原始奖品载荷（prize 字段形状由活动期决定，透传给调用方）。
	func (c Client) LotteryDraw(a auth.Auth) (json.RawMessage, error) {
	return c.growthJSON(a, http.MethodPost, lotteryDrawPath,
	map[string]any{"client_token": clientToken()})
	}