121 lines
2.9 KiB
Go
121 lines
2.9 KiB
Go
package user
|
|
|
|
import (
|
|
"SciencesServer/app/api/enterprise/model"
|
|
"SciencesServer/app/basic/controller"
|
|
model2 "SciencesServer/app/common/model"
|
|
"SciencesServer/app/session"
|
|
"strings"
|
|
)
|
|
|
|
// Consume 消耗日志
|
|
type Consume struct {
|
|
*session.Enterprise
|
|
local string
|
|
}
|
|
|
|
type ConsumeHandle func(session *session.Enterprise, local string) *Consume
|
|
|
|
type (
|
|
// ConsumeInfo 消耗日志信息
|
|
ConsumeInfo struct {
|
|
ID string `json:"id"`
|
|
*model2.UserConsume
|
|
}
|
|
// ConsumePageInfo 消耗日志分页信息
|
|
ConsumePageInfo struct {
|
|
controller.ReturnPages
|
|
TotalConsume float64 `json:"total_consume"`
|
|
}
|
|
)
|
|
|
|
// Instance 列表信息
|
|
func (c *Consume) Instance(source int, createdAt string, page, pageSize int) (*controller.ReturnPages, error) {
|
|
mUserConsume := model.NewUserConsume()
|
|
|
|
where := []*model2.ModelWhereOrder{
|
|
&model2.ModelWhereOrder{
|
|
Where: model2.NewWhere("uid", c.UID),
|
|
Order: model2.NewOrder("id", model2.OrderModeToDesc),
|
|
},
|
|
}
|
|
if source > 0 {
|
|
where = append(where, &model2.ModelWhereOrder{Where: model2.NewWhere("source", source)})
|
|
}
|
|
if createdAt != "" {
|
|
_wheres := model2.NewWhereSectionAt("created_at", strings.Split(createdAt, " ~ "))
|
|
|
|
where = append(where, &model2.ModelWhereOrder{
|
|
Where: _wheres[0],
|
|
}, &model2.ModelWhereOrder{
|
|
Where: _wheres[1],
|
|
})
|
|
}
|
|
out := make([]*model2.UserConsume, 0)
|
|
|
|
var count int64
|
|
|
|
if err := model2.Pages(mUserConsume.UserConsume, &out, page, pageSize, &count, where...); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
list := make([]*ConsumeInfo, 0)
|
|
|
|
for _, v := range out {
|
|
list = append(list, &ConsumeInfo{
|
|
ID: v.GetEncodeID(),
|
|
UserConsume: v,
|
|
})
|
|
}
|
|
return &controller.ReturnPages{Data: list, Count: count}, nil
|
|
}
|
|
|
|
// Exchange 兑换信息
|
|
func (c *Consume) Exchange(orderNo string, createdAt string, page, pageSize int) (*ConsumePageInfo, error) {
|
|
mUserConsume := model.NewUserConsume()
|
|
|
|
where := []*model2.ModelWhere{
|
|
model2.NewWhere("uid", c.UID),
|
|
model2.NewWhereIn("source", []model2.UserConsumeSource{
|
|
model2.UserConsumeSourceForExchangeCoin,
|
|
}),
|
|
}
|
|
if orderNo != "" {
|
|
where = append(where, model2.NewWhereLike("order_no", orderNo))
|
|
}
|
|
if createdAt != "" {
|
|
where = append(where, model2.NewWhereSectionAt("created_at", strings.Split(createdAt, " ~ "))...)
|
|
}
|
|
out := new(ConsumePageInfo)
|
|
|
|
res, err := mUserConsume.Exchange(page, pageSize, &out.Count, &out.TotalConsume)
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
list := make([]*ConsumeInfo, 0)
|
|
|
|
for _, v := range res {
|
|
list = append(list, &ConsumeInfo{ID: v.GetEncodeID(), UserConsume: v})
|
|
}
|
|
out.Data = list
|
|
|
|
return out, nil
|
|
}
|
|
|
|
// Delete 删除操作
|
|
func (c *Consume) Delete(id uint64) error {
|
|
mUserConsume := model.NewUserConsume()
|
|
mUserConsume.ID = id
|
|
return model2.Delete(mUserConsume.UserConsume)
|
|
}
|
|
|
|
func NewConsume() ConsumeHandle {
|
|
return func(session *session.Enterprise, local string) *Consume {
|
|
return &Consume{
|
|
Enterprise: session,
|
|
local: local,
|
|
}
|
|
}
|
|
}
|