feat: add superadmin user interaction views
This commit is contained in:
@@ -1704,6 +1704,176 @@ func (s *super) ListUserTenants(ctx context.Context, userID int64, filter *super
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (s *super) ListUserFavorites(ctx context.Context, userID int64, filter *super_dto.SuperUserContentActionListFilter) (*requests.Pager, error) {
|
||||
return s.listUserContentActions(ctx, userID, consts.UserContentActionTypeFavorite, filter)
|
||||
}
|
||||
|
||||
func (s *super) ListUserLikes(ctx context.Context, userID int64, filter *super_dto.SuperUserContentActionListFilter) (*requests.Pager, error) {
|
||||
return s.listUserContentActions(ctx, userID, consts.UserContentActionTypeLike, filter)
|
||||
}
|
||||
|
||||
func (s *super) ListUserFollowing(ctx context.Context, userID int64, filter *super_dto.SuperUserTenantListFilter) (*requests.Pager, error) {
|
||||
if filter == nil {
|
||||
filter = &super_dto.SuperUserTenantListFilter{}
|
||||
}
|
||||
// 关注列表默认只展示普通成员关注关系。
|
||||
role := consts.TenantUserRoleMember
|
||||
filter.Role = &role
|
||||
return s.ListUserTenants(ctx, userID, filter)
|
||||
}
|
||||
|
||||
func (s *super) listUserContentActions(
|
||||
ctx context.Context,
|
||||
userID int64,
|
||||
actionType consts.UserContentActionType,
|
||||
filter *super_dto.SuperUserContentActionListFilter,
|
||||
) (*requests.Pager, error) {
|
||||
if userID == 0 {
|
||||
return nil, errorx.ErrBadRequest.WithMsg("用户ID不能为空")
|
||||
}
|
||||
if filter == nil {
|
||||
filter = &super_dto.SuperUserContentActionListFilter{}
|
||||
}
|
||||
|
||||
tbl, q := models.UserContentActionQuery.QueryContext(ctx)
|
||||
q = q.Where(tbl.UserID.Eq(userID), tbl.Type.Eq(string(actionType)))
|
||||
|
||||
contentIDs, contentFilter, err := s.filterContentIDsForUserActions(ctx, filter)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if contentFilter {
|
||||
if len(contentIDs) == 0 {
|
||||
filter.Pagination.Format()
|
||||
return &requests.Pager{
|
||||
Pagination: filter.Pagination,
|
||||
Total: 0,
|
||||
Items: []super_dto.SuperUserContentActionItem{},
|
||||
}, nil
|
||||
}
|
||||
q = q.Where(tbl.ContentID.In(contentIDs...))
|
||||
}
|
||||
|
||||
if filter.CreatedAtFrom != nil {
|
||||
from, err := s.parseFilterTime(filter.CreatedAtFrom)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if from != nil {
|
||||
q = q.Where(tbl.CreatedAt.Gte(*from))
|
||||
}
|
||||
}
|
||||
if filter.CreatedAtTo != nil {
|
||||
to, err := s.parseFilterTime(filter.CreatedAtTo)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if to != nil {
|
||||
q = q.Where(tbl.CreatedAt.Lte(*to))
|
||||
}
|
||||
}
|
||||
|
||||
orderApplied := false
|
||||
if filter.Desc != nil && strings.TrimSpace(*filter.Desc) != "" {
|
||||
switch strings.TrimSpace(*filter.Desc) {
|
||||
case "id":
|
||||
q = q.Order(tbl.ID.Desc())
|
||||
case "created_at":
|
||||
q = q.Order(tbl.CreatedAt.Desc())
|
||||
}
|
||||
orderApplied = true
|
||||
} else if filter.Asc != nil && strings.TrimSpace(*filter.Asc) != "" {
|
||||
switch strings.TrimSpace(*filter.Asc) {
|
||||
case "id":
|
||||
q = q.Order(tbl.ID)
|
||||
case "created_at":
|
||||
q = q.Order(tbl.CreatedAt)
|
||||
}
|
||||
orderApplied = true
|
||||
}
|
||||
if !orderApplied {
|
||||
q = q.Order(tbl.CreatedAt.Desc())
|
||||
}
|
||||
|
||||
filter.Pagination.Format()
|
||||
total, err := q.Count()
|
||||
if err != nil {
|
||||
return nil, errorx.ErrDatabaseError.WithCause(err)
|
||||
}
|
||||
list, err := q.Offset(int(filter.Pagination.Offset())).Limit(int(filter.Pagination.Limit)).Find()
|
||||
if err != nil {
|
||||
return nil, errorx.ErrDatabaseError.WithCause(err)
|
||||
}
|
||||
if len(list) == 0 {
|
||||
return &requests.Pager{
|
||||
Pagination: filter.Pagination,
|
||||
Total: total,
|
||||
Items: []super_dto.SuperUserContentActionItem{},
|
||||
}, nil
|
||||
}
|
||||
|
||||
contentIDSet := make(map[int64]struct{}, len(list))
|
||||
contentIDs = make([]int64, 0, len(list))
|
||||
for _, action := range list {
|
||||
if action.ContentID == 0 {
|
||||
continue
|
||||
}
|
||||
if _, ok := contentIDSet[action.ContentID]; ok {
|
||||
continue
|
||||
}
|
||||
contentIDSet[action.ContentID] = struct{}{}
|
||||
contentIDs = append(contentIDs, action.ContentID)
|
||||
}
|
||||
|
||||
var contents []*models.Content
|
||||
if len(contentIDs) > 0 {
|
||||
contentTbl, contentQuery := models.ContentQuery.QueryContext(ctx)
|
||||
err := contentQuery.Where(contentTbl.ID.In(contentIDs...)).
|
||||
UnderlyingDB().
|
||||
Preload("Author").
|
||||
Preload("ContentAssets.Asset").
|
||||
Find(&contents).Error
|
||||
if err != nil {
|
||||
return nil, errorx.ErrDatabaseError.WithCause(err)
|
||||
}
|
||||
}
|
||||
|
||||
priceMap, err := s.contentPriceMap(ctx, contents)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
tenantMap, err := s.contentTenantMap(ctx, contents)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
contentMap := make(map[int64]*models.Content, len(contents))
|
||||
for _, content := range contents {
|
||||
contentMap[content.ID] = content
|
||||
}
|
||||
|
||||
items := make([]super_dto.SuperUserContentActionItem, 0, len(list))
|
||||
for _, action := range list {
|
||||
var contentItem *super_dto.AdminContentItem
|
||||
if content := contentMap[action.ContentID]; content != nil {
|
||||
item := s.toSuperContentItem(content, priceMap[content.ID], tenantMap[content.TenantID])
|
||||
contentItem = &item
|
||||
}
|
||||
items = append(items, super_dto.SuperUserContentActionItem{
|
||||
ActionID: action.ID,
|
||||
ActionType: actionType,
|
||||
ActionAt: s.formatTime(action.CreatedAt),
|
||||
Content: contentItem,
|
||||
})
|
||||
}
|
||||
|
||||
return &requests.Pager{
|
||||
Pagination: filter.Pagination,
|
||||
Total: total,
|
||||
Items: items,
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (s *super) ListContents(ctx context.Context, filter *super_dto.SuperContentListFilter) (*requests.Pager, error) {
|
||||
tbl, q := models.ContentQuery.QueryContext(ctx)
|
||||
|
||||
@@ -3444,6 +3614,59 @@ func (s *super) lookupUserIDs(ctx context.Context, username *string) ([]int64, b
|
||||
return ids, true, nil
|
||||
}
|
||||
|
||||
func (s *super) filterContentIDsForUserActions(
|
||||
ctx context.Context,
|
||||
filter *super_dto.SuperUserContentActionListFilter,
|
||||
) ([]int64, bool, error) {
|
||||
if filter == nil {
|
||||
return nil, false, nil
|
||||
}
|
||||
|
||||
tbl, q := models.ContentQuery.QueryContext(ctx)
|
||||
filterApplied := false
|
||||
|
||||
if filter.ContentID != nil && *filter.ContentID > 0 {
|
||||
q = q.Where(tbl.ID.Eq(*filter.ContentID))
|
||||
filterApplied = true
|
||||
}
|
||||
if filter.TenantID != nil && *filter.TenantID > 0 {
|
||||
q = q.Where(tbl.TenantID.Eq(*filter.TenantID))
|
||||
filterApplied = true
|
||||
}
|
||||
|
||||
tenantIDs, tenantFilter, err := s.lookupTenantIDs(ctx, filter.TenantCode, filter.TenantName)
|
||||
if err != nil {
|
||||
return nil, false, err
|
||||
}
|
||||
if tenantFilter {
|
||||
filterApplied = true
|
||||
if len(tenantIDs) == 0 {
|
||||
return []int64{}, true, nil
|
||||
}
|
||||
q = q.Where(tbl.TenantID.In(tenantIDs...))
|
||||
}
|
||||
|
||||
if filter.Keyword != nil && strings.TrimSpace(*filter.Keyword) != "" {
|
||||
keyword := "%" + strings.TrimSpace(*filter.Keyword) + "%"
|
||||
q = q.Where(field.Or(
|
||||
tbl.Title.Like(keyword),
|
||||
tbl.Description.Like(keyword),
|
||||
tbl.Summary.Like(keyword),
|
||||
))
|
||||
filterApplied = true
|
||||
}
|
||||
|
||||
if !filterApplied {
|
||||
return nil, false, nil
|
||||
}
|
||||
|
||||
ids, err := q.PluckIDs()
|
||||
if err != nil {
|
||||
return nil, true, errorx.ErrDatabaseError.WithCause(err)
|
||||
}
|
||||
return ids, true, nil
|
||||
}
|
||||
|
||||
func (s *super) lookupOrderIDsByContent(ctx context.Context, contentID *int64, contentTitle *string) ([]int64, bool, error) {
|
||||
var id int64
|
||||
if contentID != nil {
|
||||
|
||||
Reference in New Issue
Block a user