@ -15,35 +15,23 @@ import (
)
var (
_ core . IndexPostsService = ( * friendIndexSrv ) ( nil )
_ core . IndexPostsService = ( * followIndexSrv ) ( nil )
_ core . IndexPostsService = ( * lightIndexSrv ) ( nil )
_ core . IndexPostsService = ( * shipIndexSrv ) ( nil )
_ core . IndexPostsService = ( * simpleIndexPostsSrv ) ( nil )
)
type friend IndexSrv struct {
type ship IndexSrv struct {
ams core . AuthorizationManageService
ths core . TweetHelpService
db * gorm . DB
}
type followIndexSrv struct {
ths core . TweetHelpService
db * gorm . DB
}
type lightIndexSrv struct {
ths core . TweetHelpService
db * gorm . DB
}
type simpleIndexPostsSrv struct {
ths core . TweetHelpService
db * gorm . DB
}
// IndexPosts 根据userId查询广场推文列表， ；
func ( s * friend IndexSrv) IndexPosts ( user * ms . User , offset int , limit int ) ( * ms . IndexTweetList , error ) {
func ( s * shipIndexSrv ) IndexPosts ( user * ms . User , offset int , limit int ) ( * ms . IndexTweetList , error ) {
predicates := dbr . Predicates {
"ORDER" : [ ] any { "is_top DESC, latest_replied_on DESC" } ,
}
@ -77,60 +65,6 @@ func (s *friendIndexSrv) IndexPosts(user *ms.User, offset int, limit int) (*ms.I
} , nil
}
func ( s * friendIndexSrv ) TweetTimeline ( userId int64 , offset int , limit int ) ( * cs . TweetBox , error ) {
// TODO
return nil , debug . ErrNotImplemented
}
// IndexPosts 根据userId查询广场推文列表
func ( s * followIndexSrv ) IndexPosts ( user * ms . User , offset int , limit int ) ( * ms . IndexTweetList , error ) {
// TODO
return nil , debug . ErrNotImplemented
}
func ( s * followIndexSrv ) TweetTimeline ( userId int64 , offset int , limit int ) ( * cs . TweetBox , error ) {
// TODO
return nil , debug . ErrNotImplemented
}
// IndexPosts 根据userId查询广场推文列表，
func ( s * lightIndexSrv ) IndexPosts ( user * ms . User , offset int , limit int ) ( * ms . IndexTweetList , error ) {
predicates := dbr . Predicates {
"ORDER" : [ ] any { "is_top DESC, latest_replied_on DESC" } ,
}
if user == nil {
predicates [ "visibility = ?" ] = [ ] any { dbr . PostVisitPublic }
} else if ! user . IsAdmin {
args := [ ] any { dbr . PostVisitPublic , dbr . PostVisitPrivate , user . ID }
predicates [ "visibility = ? OR (visibility = ? AND user_id = ?)" ] = args
}
posts , err := ( & dbr . Post { } ) . Fetch ( s . db , predicates , offset , limit )
if err != nil {
logrus . Debugf ( "gormIndexPostsSrv.IndexPosts err: %v" , err )
return nil , err
}
formatPosts , err := s . ths . MergePosts ( posts )
if err != nil {
return nil , err
}
total , err := ( & dbr . Post { } ) . CountBy ( s . db , predicates )
if err != nil {
return nil , err
}
return & ms . IndexTweetList {
Tweets : formatPosts ,
Total : total ,
} , nil
}
func ( s * lightIndexSrv ) TweetTimeline ( userId int64 , offset int , limit int ) ( * cs . TweetBox , error ) {
// TODO
return nil , debug . ErrNotImplemented
}
// simpleCacheIndexGetPosts simpleCacheIndex 专属获取广场推文列表函数
func ( s * simpleIndexPostsSrv ) IndexPosts ( _user * ms . User , offset int , limit int ) ( * ms . IndexTweetList , error ) {
predicates := dbr . Predicates {
@ -165,28 +99,14 @@ func (s *simpleIndexPostsSrv) TweetTimeline(userId int64, offset int, limit int)
return nil , debug . ErrNotImplemented
}
func new Friend IndexService( db * gorm . DB , ams core . AuthorizationManageService , ths core . TweetHelpService ) core . IndexPostsService {
return & friend IndexSrv{
func new Ship IndexService( db * gorm . DB , ams core . AuthorizationManageService , ths core . TweetHelpService ) core . IndexPostsService {
return & ship IndexSrv{
ams : ams ,
ths : ths ,
db : db ,
}
}
func newFollowIndexService ( db * gorm . DB , ths core . TweetHelpService ) core . IndexPostsService {
return & followIndexSrv {
ths : ths ,
db : db ,
}
}
func newLightIndexService ( db * gorm . DB , ths core . TweetHelpService ) core . IndexPostsService {
return & lightIndexSrv {
ths : ths ,
db : db ,
}
}
func newSimpleIndexPostsService ( db * gorm . DB , ths core . TweetHelpService ) core . IndexPostsService {
return & simpleIndexPostsSrv {
ths : ths ,
Michael Li
1 year ago