feat: 完成众筹后台管理功能

api/handler/admin/reward_handler.go

@@ -0,0 +1,57 @@
+package admin
+
+import (
+	"chatplus/core"
+	"chatplus/handler"
+	"chatplus/store/model"
+	"chatplus/store/vo"
+	"chatplus/utils"
+	"chatplus/utils/resp"
+	"github.com/gin-gonic/gin"
+	"gorm.io/gorm"
+)
+
+type RewardHandler struct {
+	handler.BaseHandler
+	db *gorm.DB
+}
+
+func NewRewardHandler(app *core.AppServer, db *gorm.DB) *RewardHandler {
+	h := RewardHandler{db: db}
+	h.App = app
+	return &h
+}
+
+func (h *RewardHandler) List(c *gin.Context) {
+	var items []model.Reward
+	res := h.db.Find(&items)
+	var rewards = make([]vo.Reward, 0)
+	if res.Error == nil {
+		userIds := make([]uint, 0)
+		for _, v := range items {
+			userIds = append(userIds, v.UserId)
+		}
+		var users []model.User
+		h.db.Where("id IN ?", userIds).Find(&users)
+		var userMap = make(map[uint]model.User)
+		for _, u := range users {
+			userMap[u.Id] = u
+		}
+
+		for _, v := range items {
+			var r vo.Reward
+			err := utils.CopyObject(v, &r)
+			if err != nil {
+				continue
+			}
+
+			r.Id = v.Id
+			r.Username = userMap[v.UserId].Username
+			r.CreatedAt = v.CreatedAt.Unix()
+			r.UpdatedAt = v.UpdatedAt.Unix()
+			rewards = append(rewards, r)
+		}
+	}
+
+	resp.SUCCESS(c, rewards)
+}

api/main.go

@@ -136,6 +136,7 @@ func main() {
 		fx.Provide(admin.NewApiKeyHandler),
 		fx.Provide(admin.NewUserHandler),
 		fx.Provide(admin.NewChatRoleHandler),
+		fx.Provide(admin.NewRewardHandler),
 
 		// 创建服务
 		fx.Provide(service.NewAliYunSmsService),
@@ -213,6 +214,10 @@ func main() {
 			group.POST("sort", h.SetSort)
 			group.GET("remove", h.Remove)
 		}),
+		fx.Invoke(func(s *core.AppServer, h *admin.RewardHandler) {
+			group := s.Engine.Group("/api/admin/reward/")
+			group.GET("list", h.List)
+		}),
 
 		fx.Invoke(func(s *core.AppServer, db *gorm.DB) {
 			err := s.Run(db)

api/store/vo/reward.go

@@ -0,0 +1,11 @@
+package vo
+
+type Reward struct {
+	BaseVo
+	UserId   uint    `json:"user_id"` // 用户 ID
+	Username string  `json:"username"`
+	TxId     string  `json:"tx_id"`  // 交易ID
+	Amount   float64 `json:"amount"` // 打赏金额
+	Remark   string  `json:"remark"` // 打赏备注
+	Status   bool    `json:"status"` // 核销状态
+}