feat:完善项目管理,增加网站活动管理

This commit is contained in:
henry
2021-12-15 17:36:56 +08:00
parent ba62a25e4b
commit a59759379c
13 changed files with 281 additions and 26 deletions

View File

@ -0,0 +1,47 @@
package api
import (
"SciencesServer/app/api/website/controller"
"SciencesServer/app/basic/api"
"github.com/gin-gonic/gin"
)
type Activity struct{}
func (*Activity) Instance(c *gin.Context) {
form := &struct {
Title string `json:"title" form:"title"`
Mode int `json:"mode" form:"mode"`
api.PageForm
}{}
if err := api.Bind(form)(c); err != nil {
api.APIFailure(err.(error))(c)
return
}
data, err := controller.NewActivity()(nil, "").Instance(form.Title, form.Mode, form.Page, form.PageSize)
api.APIResponse(err, data)(c)
}
func (*Activity) Detail(c *gin.Context) {
form := &struct {
api.IDStringForm
}{}
if err := api.Bind(form)(c); err != nil {
api.APIFailure(err.(error))(c)
return
}
data, err := controller.NewActivity()(nil, "").Detail(form.Convert())
api.APIResponse(err, data)(c)
}
func (*Activity) Join(c *gin.Context) {
form := &struct {
api.IDStringForm
}{}
if err := api.Bind(form)(c); err != nil {
api.APIFailure(err.(error))(c)
return
}
err := controller.NewActivity()(nil, "").Join(form.Convert())
api.APIResponse(err)(c)
}

View File

@ -0,0 +1 @@
package api

View File

@ -1,13 +1,118 @@
package controller
type Activity struct{}
import (
"SciencesServer/app/api/website/model"
"SciencesServer/app/basic/controller"
model2 "SciencesServer/app/common/model"
"SciencesServer/app/session"
"errors"
)
type ActivityHandle func() *Activity
type Activity struct {
*session.Enterprise
local string
}
func (c *Activity) Instance(title, page, pageSize int) {
type ActivityHandle func(session *session.Enterprise, local string) *Activity
type (
// ActivityInfo 活动信息
ActivityInfo struct {
ID string `json:"id"`
*model.ActivityInstanceInfo
JoinStatus bool `json:"join_status"`
}
// ActivityDetail 详细信息
ActivityDetail struct {
ID string `json:"id"`
*model.ActivityInstanceDetail
JoinStatus bool `json:"join_status"`
}
)
// Instance 活动信息
func (c *Activity) Instance(title string, mode, page, pageSize int) (*controller.ReturnPages, error) {
mActivityInstance := model.NewActivityInstance()
var count int64
var identityUID uint64
if c.Enterprise != nil {
identityUID = c.IdentityUID
}
where := make([]*model2.ModelWhere, 0)
if title != "" {
where = append(where, model2.NewWhereLike("a.title", title))
}
if mode > 0 {
where = append(where, model2.NewWhere("a.mode", mode))
}
out, err := mActivityInstance.Activity(identityUID, page, pageSize, &count)
if err != nil {
return nil, err
}
list := make([]*ActivityInfo, 0)
for _, v := range out {
list = append(list, &ActivityInfo{
ID: v.GetEncodeID(),
ActivityInstanceInfo: v,
JoinStatus: v.JoinID > 0,
})
}
return &controller.ReturnPages{Data: list, Count: count}, nil
}
// Detail 详细信息
func (c *Activity) Detail(id uint64) (*ActivityDetail, error) {
mActivityInstance := model.NewActivityInstance()
var identityUID uint64
if c.Enterprise != nil {
identityUID = c.IdentityUID
}
out, err := mActivityInstance.Detail(id, identityUID)
if err != nil {
return nil, err
}
return &ActivityDetail{
ID: out.GetEncodeID(),
ActivityInstanceDetail: out,
JoinStatus: out.JoinID > 0.,
}, nil
}
// Join 加入活动
func (c *Activity) Join(id uint64) error {
mActivityInstance := model.NewActivityInstance()
isExist, err := model2.FirstField(mActivityInstance.ActivityInstance, []string{"id", "mode", "join_deadline"},
model2.NewWhere("status", model2.NewWhere("id", id)),
model2.NewWhere("status", model2.ActivityInstanceStatusForShow))
if err != nil {
return err
} else if !isExist {
return errors.New("操作错误,活动信息不存在或已被删除")
}
if !mActivityInstance.IsCanJoin() {
return errors.New("操作错误,当前活动信息不可报名")
}
return nil
}
func NewActivity() ActivityHandle {
return nil
return func(session *session.Enterprise, local string) *Activity {
return &Activity{
Enterprise: session,
local: local,
}
}
}

View File

@ -0,0 +1,83 @@
package model
import (
"SciencesServer/app/common/model"
"SciencesServer/serve/orm"
"fmt"
)
// ActivityInstance 活动信息数据
type ActivityInstance struct {
*model.ActivityInstance
}
type (
// ActivityInstanceInfo 活动信息
ActivityInstanceInfo struct {
model.Model
model.Image
*model.ActivityInstanceBasic
JoinID uint64 `json:"-"`
JoinCount int `json:"join_count"`
}
// ActivityInstanceDetail 活动详细信息
ActivityInstanceDetail struct {
*model.ActivityInstance
JoinID uint64 `json:"-"`
JoinCount int `json:"join_count"`
}
)
// Activity 活动信息
func (m *ActivityInstance) Activity(uid uint64, page, pageSize int, count *int64, where ...*model.ModelWhere) ([]*ActivityInstanceInfo, error) {
mActivityJoin := model.NewActivityJoin()
db := orm.GetDB().Table(m.TableName()+" AS a").
Select("a.id", "a.title", "a.image", "a.begin_at", "a.finish_at", "a.join_deadline",
"IFNULL(u.id, 0) AS join_id", "j.count AS join_count").
Joins(fmt.Sprintf("LEFT JOIN %s u ON a.id = u.activity_id AND u.identity_uid = %d AND u.status = %d AND u.is_deleted = %d",
mActivityJoin.TableName(), uid, model.ActivityJoinStatusForSuccess, model.DeleteStatusForNot)).
Joins(fmt.Sprintf("LEFT JOIN (SELECT activity_id, COUNT(id) AS count FROM %s WHERE status = %d AND is_deleted = %d GROUP BY activity_id) AS j ON a.id = j.activity_id",
mActivityJoin.TableName(), model.ActivityJoinStatusForSuccess, model.DeleteStatusForNot)).
Where("a.status = ?", model.ActivityInstanceStatusForShow).
Where("a.is_deleted = ?", model.DeleteStatusForNot)
if len(where) > 0 {
for _, v := range where {
db = db.Where(v.Condition, v.Value)
}
}
out := make([]*ActivityInstanceInfo, 0)
if err := db.Count(count).Error; err != nil {
return nil, err
}
if err := db.Order("a.id " + model.OrderModeToDesc).Offset((page - 1) * pageSize).Limit(pageSize).Scan(&out).Error; err != nil {
return nil, err
}
return out, nil
}
// Detail 详细信息
func (m *ActivityInstance) Detail(id, uid uint64) (*ActivityInstanceDetail, error) {
mActivityJoin := model.NewActivityJoin()
db := orm.GetDB().Table(m.TableName()+" AS a").
Select("a.id", "a.title", "a.image", "a.begin_at", "a.finish_at", "a.join_deadline",
"IFNULL(u.id, 0) AS join_id", "j.count AS join_count").
Joins(fmt.Sprintf("LEFT JOIN %s u ON a.id = u.activity_id AND u.identity_uid = %d AND u.status = %d AND u.is_deleted = %d",
mActivityJoin.TableName(), uid, model.ActivityJoinStatusForSuccess, model.DeleteStatusForNot)).
Joins(fmt.Sprintf("LEFT JOIN (SELECT activity_id, COUNT(id) AS count FROM %s WHERE status = %d AND is_deleted = %d GROUP BY activity_id) AS j ON a.id = j.activity_id",
mActivityJoin.TableName(), model.ActivityJoinStatusForSuccess, model.DeleteStatusForNot)).
Where("a.id = ?", id)
out := new(ActivityInstanceDetail)
err := db.Scan(&out).Error
return out, err
}
func NewActivityInstance() *ActivityInstance {
return &ActivityInstance{model.NewActivityInstance()}
}