feat: 添加社区发帖活动及其相关模型和功能实现，包括数据库迁移脚本和Makefile

Author: codeErrorSleep

Makefile

@@ -0,0 +1,14 @@
+# init project data
+GOOSE_CMD = goose -dir db/migrations mysql "root:root@tcp(localhost:3306)/db_q_goods_center?parseTime=true"
+
+.PHONY: migrate-up
+migrate-up:
+	$(GOOSE_CMD) up
+
+.PHONY: migrate-down
+migrate-down:
+	$(GOOSE_CMD) down
+
+.PHONY: migrate-status
+migrate-status:
+	$(GOOSE_CMD) status

build.sh

@@ -0,0 +1,2 @@
+# create table, init data
+goose -dir db/migrations mysql "root:root@tcp(localhost:3306)/db_q_goods_center?parseTime=true" up

config/community_activity.json

@@ -0,0 +1,23 @@
+{
+    "category": "community",
+    "version": "v1",
+    "name": "社区发帖活动",
+    "start_at": 1679000000,
+    "end_at": 1679086400,
+    "games": [
+        {
+            "type": "post",
+            "name": "发帖奖励",
+            "config": {
+                "prize": {
+                    "discount_code": "COMMUNITY_2024",
+                    "price_rule_id": 123,
+                    "probability": 100,
+                    "total_num": 1000,
+                    "remain_num": 1000
+                },
+                "state": "OPEN"
+            }
+        }
+    ]
+} 

go.sum

@@ -0,0 +1,100 @@
+package models
+
+import (
+	"encoding/json"
+	"fmt"
+)
+
+// ActivityConfigJSON 活动配置JSON结构体
+type ActivityConfigJSON struct {
+	Category string       `json:"category"` // 活动类型
+	Version  string       `json:"version"`  // 活动版本
+	Name     string       `json:"name"`     // 活动名称
+	StartAt  int64        `json:"start_at"` // 开始时间
+	EndAt    int64        `json:"end_at"`   // 结束时间
+	Games    []GameConfig `json:"games"`    // 玩法配置列表
+}
+
+// GameConfig 玩法配置结构体
+type GameConfig struct {
+	Type   string          `json:"type"`   // 玩法类型
+	Name   string          `json:"name"`   // 玩法名称
+	Config json.RawMessage `json:"config"` // 玩法具体配置
+}
+
+// NewActivityFromConfig 根据配置创建活动实例
+func NewActivityFromConfig(configJSON []byte) (ActivityInterface, error) {
+	var config ActivityConfigJSON
+	if err := json.Unmarshal(configJSON, &config); err != nil {
+		return nil, fmt.Errorf("failed to unmarshal config: %w", err)
+	}
+
+	// 根据活动类型创建对应的活动实例
+	switch config.Category {
+	case "community":
+		return NewCommunityActivity(config)
+	default:
+		return nil, fmt.Errorf("unsupported activity category: %s", config.Category)
+	}
+}
+
+// NewCommunityActivity 创建社区活动实例
+func NewCommunityActivity(config ActivityConfigJSON) (ActivityInterface, error) {
+	// 解析玩法配置
+	var games []GameInterface
+	for _, gameConfig := range config.Games {
+		game, err := NewGameFromConfig(gameConfig)
+		if err != nil {
+			return nil, fmt.Errorf("failed to create game: %w", err)
+		}
+		games = append(games, game)
+	}
+
+	return &CommunityActivity{
+		MetaActivity: MetaActivity{
+			Category: config.Category,
+			Version:  config.Version,
+			StartAt:  config.StartAt,
+			EndAt:    config.EndAt,
+			Status:   1, // 默认上线状态
+		},
+		GameList: games,
+	}, nil
+}
+
+// NewGameFromConfig 根据配置创建玩法实例
+func NewGameFromConfig(config GameConfig) (GameInterface, error) {
+	switch config.Type {
+	case "post":
+		var game CommunityPostGame
+		if err := json.Unmarshal(config.Config, &game); err != nil {
+			return nil, fmt.Errorf("failed to unmarshal game config: %w", err)
+		}
+		game.Name_ = config.Name
+		return &game, nil
+	default:
+		return nil, fmt.Errorf("unsupported game type: %s", config.Type)
+	}
+}
+
+// CommunityActivity 社区活动实现
+type CommunityActivity struct {
+	MetaActivity
+	GameList []GameInterface
+}
+
+func (a *CommunityActivity) Category() string {
+	return a.MetaActivity.Category
+}
+
+func (a *CommunityActivity) Version() string {
+	return a.MetaActivity.Version
+}
+
+func (a *CommunityActivity) Name() string {
+	return a.MetaActivity.ActivityConfig.Activity.Name()
+}
+
+func (a *CommunityActivity) Games() []GameInterface {
+	return a.GameList
+}

models/activity_config.go

@@ -2,62 +2,131 @@ package models
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 )
 
-// 简单活动，只有一个玩法
-// 玩法就是发帖，发帖完成之后就可以发奖品了
-
+// CommunityPostGame 社区发帖玩法
 type CommunityPostGame struct {
-	Name  string         `json:"name"`
-	Prize PrizeInterface // 以旧换新的奖品
+	Name_ string             `json:"-"` // 玩法名称，从GameConfig中获取
+	Prize *DiscountCodePrize `json:"prize"`
+	State GameState          `json:"state"`
 }
 
-func (p CommunityPostGame) Game(parent string) string {
-	return parent + p.Name
+// Name 返回玩法名称
+func (p CommunityPostGame) Name(ctx context.Context) string {
+	return p.Name_
 }
 
-func (p CommunityPostGame) Perform(user User, action ActionInterface) (ResultInterface, error) {
-	// TODO: select db
-	fmt.Println(user)
-	if user.Uid == "" {
-		return nil, fmt.Errorf("user is nil")
+// Perform 执行玩法逻辑
+func (p CommunityPostGame) Perform(ctx context.Context, user User, action ActionInterface) (ResultInterface, error) {
+	// 1. 检查玩法状态
+	if p.GameState(ctx) != GameStateOPEN {
+		return nil, fmt.Errorf("game is not open")
+	}
+
+	// 2. 检查用户状态
+	if p.UserState(ctx) != UserStateOPEN {
+		return nil, fmt.Errorf("user cannot participate")
 	}
 
-	// 这里判断一下是否需要发奖
-	// 成功后发奖
+	// 3. 验证用户是否已发帖
+	// TODO: 调用社区服务检查用户是否已发帖
+	// checkUserPost(ctx, user.Uid)
+
+	// 4. 发放折扣码奖励
 	if p.Prize != nil {
-		err := p.Prize.WinPrize(context.Background(), user)
+		err := p.Prize.WinPrize(ctx, user)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("failed to give prize: %w", err)
 		}
 	}
 
-	return nil, nil
+	// 5. 记录用户参与状态
+	// TODO: 更新用户参与记录
+	// updateUserGameRecord(ctx, user.Uid, UserStateCLOSED)
+
+	return &CommunityPostResult{
+		GameName: p.Name_,
+		Prize:    p.Prize,
+	}, nil
 }
 
-func (p CommunityPostGame) Actions() []ActionInterface {
-	return []ActionInterface{}
+// GameState 返回玩法状态
+func (p CommunityPostGame) GameState(ctx context.Context) GameState {
+	return p.State
 }
 
-func (p CommunityPostGame) Results() []ResultInterface {
-	return []ResultInterface{}
+// UserState 返回用户参与状态
+func (p CommunityPostGame) UserState(ctx context.Context) UserState {
+	// TODO:
+	// 1. 检查用户是否已经参与过
+	// 2. 检查用户是否已经获得奖励
+	// 3. 返回对应状态
+	return UserStateOPEN
 }
 
-func (p CommunityPostGame) ValidateConfig() error {
-	//TODO implement me
-	if p.Name == "" {
-		return fmt.Errorf("name is empty")
+// ValidateConfig 验证配置
+func (p CommunityPostGame) ValidateConfig(ctx context.Context) error {
+	if p.Prize == nil {
+		return fmt.Errorf("prize is not configured")
 	}
 	return nil
 }
 
-func (p CommunityPostGame) UnmarshalJSON(bytes []byte) error {
-	//TODO implement me
-	panic("implement me")
+// Actions 返回支持的操作
+func (p CommunityPostGame) Actions(ctx context.Context) []ActionInterface {
+	return []ActionInterface{
+		&CommunityPostAction{}, // 定义发帖动作
+	}
 }
 
+// Results 返回支持的结果
+func (p CommunityPostGame) Results(ctx context.Context) []ResultInterface {
+	return []ResultInterface{
+		&CommunityPostResult{}, // 定义结果类型
+	}
+}
+
+// MarshalJSON 实现json.Marshaler接口
 func (p CommunityPostGame) MarshalJSON() ([]byte, error) {
-	//TODO implement me
-	panic("implement me")
+	type Alias CommunityPostGame
+	return json.Marshal(&struct {
+		*Alias
+	}{
+		Alias: (*Alias)(&p),
+	})
+}
+
+// UnmarshalJSON 实现json.Unmarshaler接口
+func (p *CommunityPostGame) UnmarshalJSON(data []byte) error {
+	type Alias CommunityPostGame
+	aux := &struct {
+		*Alias
+	}{
+		Alias: (*Alias)(p),
+	}
+	if err := json.Unmarshal(data, &aux); err != nil {
+		return err
+	}
+	return nil
+}
+
+// CommunityPostAction 发帖动作
+type CommunityPostAction struct {
+	PostID string `json:"post_id"` // 用户发帖ID
+}
+
+func (a CommunityPostAction) Target(ctx context.Context) string {
+	return "community_post"
+}
+
+// CommunityPostResult 发帖结果
+type CommunityPostResult struct {
+	GameName string             `json:"game_name"`
+	Prize    *DiscountCodePrize `json:"prize"`
+}
+
+func (r CommunityPostResult) Target(ctx context.Context) string {
+	return r.GameName
 }

models/community_activity.go

@@ -1,24 +1,35 @@
 package models
 
-import "context"
+import (
+	"context"
+	"fmt"
+)
 
 // 折扣码的奖品
 
+// DiscountCodePrize 折扣码奖品
 type DiscountCodePrize struct {
-	DiscountCode string `json:"discount_code"`
-	PriceRuleID  int64  `json:"price_rule_id"`
-	Probability  int64  `json:"probability"` // 中奖概率
+	DiscountCode string `json:"discount_code"` // 折扣码前缀
+	PriceRuleID  int64  `json:"price_rule_id"` // 价格规则ID
+	Probability  int64  `json:"probability"`   // 中奖概率
+	TotalNum     int64  `json:"total_num"`     // 总数量
+	RemainNum    int64  `json:"remain_num"`    // 剩余数量
 }
 
 func (p DiscountCodePrize) WinPrize(ctx context.Context, user User) error {
-	// 找到一个空的，直接分配给用户J
+	// 1. 检查库存
+	if p.RemainNum <= 0 {
+		return fmt.Errorf("prize stock is empty")
+	}
 
-	//
+	// 2. 找到一个空的，直接分配给用户
+	// TODO: 实现折扣码分配逻辑
 
+	// 3. 更新库存
+	p.RemainNum--
 	return nil
 }
 
 func (p DiscountCodePrize) WinProbability() int64 {
-	//TODO implement me
 	return p.Probability
 }

models/discount_code.go

@@ -0,0 +1,32 @@
+package models
+
+import (
+	"context"
+	"encoding/json"
+)
+
+// GameInterface 是对目前Shopping项目中所有玩法的公共抽象
+// Method 中第一个参数为context的出发点是传递上下文，例如tracing等场景
+type GameInterface interface {
+	// Perform 当请求到来时，游戏实例需要执行的业务逻辑
+	Perform(ctx context.Context, user User, action ActionInterface) (ResultInterface, error)
+	// ValidateConfig 校验配置是否合法, ctx 用于传递活动和玩法的上下文信息
+	ValidateConfig(ctx context.Context) error
+
+	Name(ctx context.Context) string               // 游戏的名称，在同一个活动中，游戏名称必须保证唯一
+	Actions(ctx context.Context) []ActionInterface // 游戏支持哪些请求
+	Results(ctx context.Context) []ResultInterface // 游戏支持哪些响应
+	GameState(ctx context.Context) GameState       // 玩法状态
+	UserState(ctx context.Context) UserState       // 用户参与结果
+
+	json.Unmarshaler // 非业务功能
+	json.Marshaler   // 非业务功能
+}
+
+type GameState = string
+
+const (
+	GameStateUNKNOWN GameState = "UNKNOWN" // 占位用
+	GameStateOPEN    GameState = "OPEN"    // 还可以继续参加
+	GameStateCLOSED  GameState = "CLOSED"  // 玩法关闭
+)