From 2a717d5a9a1639a7d298a75480994eceaa032710 Mon Sep 17 00:00:00 2001 From: Michael Li Date: Fri, 18 Aug 2023 10:16:44 +0800 Subject: [PATCH] sqlx: add miss method for tweet data logic WIP: 95% --- internal/dao/sakila/tweets.go | 90 ++++++++-- internal/dao/sakila/yesql/cc/yesql.go | 140 +++++++++++++-- internal/dao/sakila/yesql/yesql.sql | 247 ++++++++++++++++++++++++++ 3 files changed, 444 insertions(+), 33 deletions(-) diff --git a/internal/dao/sakila/tweets.go b/internal/dao/sakila/tweets.go index 32814f14..48fe8464 100644 --- a/internal/dao/sakila/tweets.go +++ b/internal/dao/sakila/tweets.go @@ -263,9 +263,23 @@ func (s *tweetManageSrv) StickPost(r *ms.Post) error { return err } -func (s *tweetManageSrv) HighlightPost(userId, postId int64) (int, error) { - // TODO - return 0, cs.ErrNotImplemented +func (s *tweetManageSrv) HighlightPost(userId, postId int64) (is_essence int, err error) { + err = s.with(func(tx *sqlx.Tx) error { + var postUserId int64 + err = tx.Stmtx(s.q.PostHighlightStatus).QueryRowx(postId).Scan(&postUserId, &is_essence) + if err != nil { + return err + } + if postUserId != userId { + return cs.ErrNoPermission + } + if _, err = tx.Stmtx(s.q.HighlightPost).Exec(postId); err != nil { + return err + } + is_essence = 1 - is_essence + return nil + }) + return } func (s *tweetManageSrv) VisiblePost(post *ms.Post, visibility core.PostVisibleT) (err error) { @@ -370,19 +384,65 @@ func (s *tweetSrv) GetUserPostStars(userID int64, limit int, offset int) (res [] return } -func (s *tweetSrv) ListUserStarTweets(user *cs.VistUser, limit int, offset int) ([]*ms.PostStar, int64, error) { - // TODO - return nil, 0, cs.ErrNotImplemented +func (s *tweetSrv) ListUserStarTweets(user *cs.VistUser, limit int, offset int) (res []*ms.PostStar, total int64, err error) { + switch user.RelTyp { + case cs.RelationAdmin: + if err = s.q.UserStarTweetsByAdmin.Select(&res, user.UserId, limit, offset); err == nil { + err = s.q.UserStarTweetsCountByAdmin.Get(&total, user.UserId) + } + case cs.RelationSelf: + // Fixed: 这里的查询有Bug，没有考虑查询Friend star 时如果对方已经不是你好友时，应该去除这个star + if err = s.q.UserStarTweetsBySelf.Select(&res, user.UserId, user.UserId, limit, offset); err == nil { + err = s.q.UserStarTweetsCountByAdmin.Get(&total, user.UserId, user.UserId) + } + case cs.RelationFriend: + if err = s.q.UserStarTweetsByFriend.Select(&res, user.UserId, limit, offset); err == nil { + err = s.q.UserStarTweetsByFriend.Get(&total, user.UserId) + } + case cs.RelationGuest: + fallthrough + default: + if err = s.q.UserStarTweetsByGuest.Select(&res, user.UserId, limit, offset); err == nil { + err = s.q.UserStarTweetsCountByGuest.Get(&total, user.UserId) + } + } + return } -func (s *tweetSrv) ListUserMediaTweets(user *cs.VistUser, limit int, offset int) ([]*ms.Post, int64, error) { - // TODO - return nil, 0, cs.ErrNotImplemented +func (s *tweetSrv) ListUserMediaTweets(user *cs.VistUser, limit int, offset int) (res []*ms.Post, total int64, err error) { + gStmt, cStmt := s.q.UserMediaTweetsByGuest, s.q.UserMediaTweetsCountByGuest + switch user.RelTyp { + case cs.RelationAdmin, cs.RelationSelf: + gStmt, cStmt = s.q.UserMediaTweetsBySelf, s.q.UserMediaTweetsCountBySelf + case cs.RelationFriend: + gStmt, cStmt = s.q.UserMediaTweetsByFriend, s.q.UserMediaTweetsCountByFriend + case cs.RelationGuest: + fallthrough + default: + // nothing + } + if err = gStmt.Select(&res, user.UserId, limit, offset); err == nil { + err = cStmt.Get(&total, user.UserId) + } + return } -func (s *tweetSrv) ListUserCommentTweets(user *cs.VistUser, limit int, offset int) ([]*ms.Post, int64, error) { - // TODO - return nil, 0, cs.ErrNotImplemented +func (s *tweetSrv) ListUserCommentTweets(user *cs.VistUser, limit int, offset int) (res []*ms.Post, total int64, err error) { + gStmt, cStmt := s.q.UserCommentTweetsByGuest, s.q.UserCommentTweetsCountByGuest + switch user.RelTyp { + case cs.RelationAdmin, cs.RelationSelf: + gStmt, cStmt = s.q.UserCommentTweetsBySelf, s.q.UserCommentTweetsCountBySelf + case cs.RelationFriend: + gStmt, cStmt = s.q.UserCommentTweetsByFriend, s.q.UserCommentTweetsCountByFriend + case cs.RelationGuest: + fallthrough + default: + // nothing + } + if err = gStmt.Select(&res, user.UserId, limit, offset); err == nil { + err = cStmt.Get(&total, user.UserId) + } + return } func (s *tweetSrv) GetUserPostStarCount(userID int64) (res int64, err error) { @@ -435,12 +495,6 @@ func (s *tweetSrvA) UserTweets(visitorId, userId int64) (res cs.TweetList, err e return nil, debug.ErrNotImplemented } -// checkRelationBy check the relation of visitor with user -func (s *tweetSrvA) checkRelationBy(visitorId, userId int64) uint { - // TODO - return 0 -} - func (s *tweetSrvA) ReactionByTweetId(userId int64, tweetId int64) (*cs.ReactionItem, error) { // TODO return nil, debug.ErrNotImplemented diff --git a/internal/dao/sakila/yesql/cc/yesql.go b/internal/dao/sakila/yesql/cc/yesql.go index a92dc147..e5a2006c 100644 --- a/internal/dao/sakila/yesql/cc/yesql.go +++ b/internal/dao/sakila/yesql/cc/yesql.go @@ -123,11 +123,33 @@ const ( _TweetManage_DelPostCollection = `UPDATE @post_collection SET is_del=1, deleted_on=? WHERE id=? AND is_del=0` _TweetManage_DelPostStar = `UPDATE @post_star SET is_del=1, deleted_on=? WHERE id=? AND is_del=0` _TweetManage_DelReplyByCommentIds = `UPDATE @comment_reply SET deleted_on=?, is_del=1 WHERE comment_id IN (?) AND is_del=0` + _TweetManage_HighlightPost = `UPDATE @post SET is_essence=1-is_essence WHERE id=? AND is_del=0` _TweetManage_LockPost = `UPDATE @post SET is_lock=1-is_lock, modified_on=? WHERE id=? AND is_del=0` _TweetManage_MediaContentByPostId = `SELECT content FROM post_content WHERE post_id=? AND is_del=0 AND type IN (3, 4, 5, 7, 8)` + _TweetManage_PostHighlightStatus = `SELECT user_id, is_essence FROM @post WHERE id=? AND is_del=0` _TweetManage_StickPost = `UPDATE @post SET is_top=1-is_top, modified_on=? WHERE id=? AND is_del=0` _TweetManage_UpdatePost = `UPDATE @post SET comment_count=:comment_count, upvote_count=:upvote_count, collection_count=:collection_count, latest_replies_on=:latest_replies_on, modified_on=:modified_on WHERE id=:id AND is_del=0` _TweetManage_VisiblePost = `UPDATE @post SET visibility=?, is_top=?, modified_on=? WHERE id=? AND is_del=0` + _Tweet_UserCommentTweetsByFriend = `SELECT * FROM @post_by_comment WHERE is_del=0 AND comment_user_id=? AND (visibility=0 OR visibility=2) ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?` + _Tweet_UserCommentTweetsByGuest = `SELECT * FROM @post_by_comment WHERE is_del=0 AND comment_user_id=? AND visibility=0 ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?` + _Tweet_UserCommentTweetsBySelf = `SELECT * FROM @post_by_comment WHERE is_del=0 AND comment_user_id=? ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?` + _Tweet_UserCommentTweetsCountByFriend = `SELECT count(*) FROM @post_by_comment WHERE is_del=0 AND comment_user_id=? AND (visibility=0 OR visibility=2)` + _Tweet_UserCommentTweetsCountByGuest = `SELECT count(*) FROM @post_by_comment WHERE is_del=0 AND comment_user_id=? AND visibility=0` + _Tweet_UserCommentTweetsCountBySelf = `SELECT count(*) FROM @post_by_comment WHERE is_del=0 AND comment_user_id=?` + _Tweet_UserMediaTweetsByFriend = `SELECT * FROM @post_by_media WHERE is_del=0 AND user_id=? AND (visibility=0 OR visibility=2) ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?` + _Tweet_UserMediaTweetsByGuest = `SELECT * FROM @post_by_media WHERE is_del=0 AND user_id=? AND visibility=0 ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?` + _Tweet_UserMediaTweetsBySelf = `SELECT * FROM @post_by_media WHERE is_del=0 AND user_id=? ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?` + _Tweet_UserMediaTweetsCountByFriend = `SELECT count(*) FROM @post_by_media WHERE is_del=0 AND user_id=? AND (visibility=0 OR visibility=2)` + _Tweet_UserMediaTweetsCountByGuest = `SELECT count(*) FROM @post_by_media WHERE is_del=0 AND user_id=? AND visibility=0` + _Tweet_UserMediaTweetsCountBySelf = `SELECT count(*) FROM @post_by_media WHERE is_del=0 AND user_id=?` + _Tweet_UserStarTweetsByAdmin = `SELECT star.*, post.ID "post.id", post.created_on "post.created_on", post.modified_on "post.modified_on", post.deleted_on "post.deleted_on", post.is_del "post.is_del", post.user_id "post.user_id", post.comment_count "post.comment_count", post.collection_count "post.collection_count", post.share_count "post.share_count", post.upvote_count "post.upvote_count", post.visibility "post.visibility", post.is_top "post.is_top", post.is_essence "post.is_essence", post.is_lock "post.is_lock", post.latest_replied_on "post.latest_replied_on", post.tags "post.tags", post.attachment_price "post.attachment_price", post.ip "post.ip", post.ip_loc "post.ip_loc" FROM @post_star star JOIN @post post ON star.post_id = post.ID WHERE star.is_del=0 AND star.user_id=? ORDER BY post.latest_replied_on DESC; LIMIT ? OFFSET ?` + _Tweet_UserStarTweetsByFriend = `SELECT star.*, post.ID "post.id", post.created_on "post.created_on", post.modified_on "post.modified_on", post.deleted_on "post.deleted_on", post.is_del "post.is_del", post.user_id "post.user_id", post.comment_count "post.comment_count", post.collection_count "post.collection_count", post.share_count "post.share_count", post.upvote_count "post.upvote_count", post.visibility "post.visibility", post.is_top "post.is_top", post.is_essence "post.is_essence", post.is_lock "post.is_lock", post.latest_replied_on "post.latest_replied_on", post.tags "post.tags", post.attachment_price "post.attachment_price", post.ip "post.ip", post.ip_loc "post.ip_loc" FROM @post_star star JOIN @post post ON star.post_id = post.ID WHERE star.is_del=0 AND star.user_id=? AND (post.visibility=0 OR post.visibility=2) ORDER BY post.latest_replied_on DESC LIMIT ? OFFSET ?` + _Tweet_UserStarTweetsByGuest = `SELECT star.*, post.ID "post.id", post.created_on "post.created_on", post.modified_on "post.modified_on", post.deleted_on "post.deleted_on", post.is_del "post.is_del", post.user_id "post.user_id", post.comment_count "post.comment_count", post.collection_count "post.collection_count", post.share_count "post.share_count", post.upvote_count "post.upvote_count", post.visibility "post.visibility", post.is_top "post.is_top", post.is_essence "post.is_essence", post.is_lock "post.is_lock", post.latest_replied_on "post.latest_replied_on", post.tags "post.tags", post.attachment_price "post.attachment_price", post.ip "post.ip", post.ip_loc "post.ip_loc" FROM @post_star star JOIN @post post ON star.post_id = post.ID WHERE star.is_del = 0 AND star.user_id =? AND post.visibility = 0 ORDER BY post.latest_replied_on DESC LIMIT ? OFFSET ?` + _Tweet_UserStarTweetsBySelf = `SELECT star.*, post.ID "post.id", post.created_on "post.created_on", post.modified_on "post.modified_on", post.deleted_on "post.deleted_on", post.is_del "post.is_del", post.user_id "post.user_id", post.comment_count "post.comment_count", post.collection_count "post.collection_count", post.share_count "post.share_count", post.upvote_count "post.upvote_count", post.visibility "post.visibility", post.is_top "post.is_top", post.is_essence "post.is_essence", post.is_lock "post.is_lock", post.latest_replied_on "post.latest_replied_on", post.tags "post.tags", post.attachment_price "post.attachment_price", post.ip "post.ip", post.ip_loc "post.ip_loc" FROM @post_star star JOIN @post post ON star.post_id = post.ID WHERE star.is_del=0 AND star.user_id=? AND (post.visibility<>0 (post.visibility=0 AND post.user_id=?)) ORDER BY post.latest_replied_on DESC; LIMIT ? OFFSET ?` + _Tweet_UserStarTweetsCountByAdmin = `SELECT count(*) FROM @post_star star JOIN @post post ON star.post_id = post.ID WHERE star.is_del=0 AND star.user_id=?` + _Tweet_UserStarTweetsCountByFriend = `SELECT count(*) FROM @post_star star JOIN @post post ON star.post_id = post.ID WHERE star.is_del=0 AND star.user_id=? AND (post.visibility=0 OR post.visibility=2)` + _Tweet_UserStarTweetsCountByGuest = `SELECT count(*) FROM @post_star star JOIN @post post ON star.post_id = post.ID WHERE star.is_del=0 AND star.user_id=? AND post.visibility=0` + _Tweet_UserStarTweetsCountBySelf = `SELECT count(*) FROM @post_star star JOIN @post post ON star.post_id = post.ID WHERE star.is_del=0 AND star.user_id=? AND (post.visibility<>0 (post.visibility=0 AND post.user_id=?))` _UserManage_CreateUser = `INSERT INTO @user (username, nickname, password, salt, avatar, status, created_on) VALUES (:username, :nickname, :password, :salt, :avatar, :status, :created_on)` _UserManage_GetAnyUsers = `SELECT * FROM @user WHERE is_del=0 ORDER BY id ASC limit 6` _UserManage_GetUserById = `SELECT * FROM @user WHERE id=? AND is_del=0` @@ -270,21 +292,41 @@ type TopicA struct { } type Tweet struct { - yesql.Namespace `yesql:"tweet"` - GetAnyPostCount string `yesql:"get_any_post_count"` - GetAnyPosts string `yesql:"get_any_posts"` - GetPostContentsByIds string `yesql:"get_post_contents_by_ids"` - GetUserPostCount string `yesql:"get_user_post_count"` - GetUserPosts string `yesql:"get_user_posts"` - GetPostAttachmentBill *sqlx.Stmt `yesql:"get_post_attachment_bill"` - GetPostById *sqlx.Stmt `yesql:"get_post_by_id"` - GetPostContentById *sqlx.Stmt `yesql:"get_post_content_by_id"` - GetUserPostCollection *sqlx.Stmt `yesql:"get_user_post_collection"` - GetUserPostCollectionCount *sqlx.Stmt `yesql:"get_user_post_collection_count"` - GetUserPostCollections *sqlx.Stmt `yesql:"get_user_post_collections"` - GetUserPostStar *sqlx.Stmt `yesql:"get_user_post_star"` - GetUserPostStarCount *sqlx.Stmt `yesql:"get_user_post_star_count"` - GetUserPostStars *sqlx.Stmt `yesql:"get_user_post_stars"` + yesql.Namespace `yesql:"tweet"` + GetAnyPostCount string `yesql:"get_any_post_count"` + GetAnyPosts string `yesql:"get_any_posts"` + GetPostContentsByIds string `yesql:"get_post_contents_by_ids"` + GetUserPostCount string `yesql:"get_user_post_count"` + GetUserPosts string `yesql:"get_user_posts"` + GetPostAttachmentBill *sqlx.Stmt `yesql:"get_post_attachment_bill"` + GetPostById *sqlx.Stmt `yesql:"get_post_by_id"` + GetPostContentById *sqlx.Stmt `yesql:"get_post_content_by_id"` + GetUserPostCollection *sqlx.Stmt `yesql:"get_user_post_collection"` + GetUserPostCollectionCount *sqlx.Stmt `yesql:"get_user_post_collection_count"` + GetUserPostCollections *sqlx.Stmt `yesql:"get_user_post_collections"` + GetUserPostStar *sqlx.Stmt `yesql:"get_user_post_star"` + GetUserPostStarCount *sqlx.Stmt `yesql:"get_user_post_star_count"` + GetUserPostStars *sqlx.Stmt `yesql:"get_user_post_stars"` + UserCommentTweetsByFriend *sqlx.Stmt `yesql:"user_comment_tweets_by_friend"` + UserCommentTweetsByGuest *sqlx.Stmt `yesql:"user_comment_tweets_by_guest"` + UserCommentTweetsBySelf *sqlx.Stmt `yesql:"user_comment_tweets_by_self"` + UserCommentTweetsCountByFriend *sqlx.Stmt `yesql:"user_comment_tweets_count_by_friend"` + UserCommentTweetsCountByGuest *sqlx.Stmt `yesql:"user_comment_tweets_count_by_guest"` + UserCommentTweetsCountBySelf *sqlx.Stmt `yesql:"user_comment_tweets_count_by_self"` + UserMediaTweetsByFriend *sqlx.Stmt `yesql:"user_media_tweets_by_friend"` + UserMediaTweetsByGuest *sqlx.Stmt `yesql:"user_media_tweets_by_guest"` + UserMediaTweetsBySelf *sqlx.Stmt `yesql:"user_media_tweets_by_self"` + UserMediaTweetsCountByFriend *sqlx.Stmt `yesql:"user_media_tweets_count_by_friend"` + UserMediaTweetsCountByGuest *sqlx.Stmt `yesql:"user_media_tweets_count_by_guest"` + UserMediaTweetsCountBySelf *sqlx.Stmt `yesql:"user_media_tweets_count_by_self"` + UserStarTweetsByAdmin *sqlx.Stmt `yesql:"user_star_tweets_by_admin"` + UserStarTweetsByFriend *sqlx.Stmt `yesql:"user_star_tweets_by_friend"` + UserStarTweetsByGuest *sqlx.Stmt `yesql:"user_star_tweets_by_guest"` + UserStarTweetsBySelf *sqlx.Stmt `yesql:"user_star_tweets_by_self"` + UserStarTweetsCountByAdmin *sqlx.Stmt `yesql:"user_star_tweets_count_by_admin"` + UserStarTweetsCountByFriend *sqlx.Stmt `yesql:"user_star_tweets_count_by_friend"` + UserStarTweetsCountByGuest *sqlx.Stmt `yesql:"user_star_tweets_count_by_guest"` + UserStarTweetsCountBySelf *sqlx.Stmt `yesql:"user_star_tweets_count_by_self"` } type TweetA struct { @@ -327,8 +369,10 @@ type TweetManage struct { DelPostById *sqlx.Stmt `yesql:"del_post_by_id"` DelPostCollection *sqlx.Stmt `yesql:"del_post_collection"` DelPostStar *sqlx.Stmt `yesql:"del_post_star"` + HighlightPost *sqlx.Stmt `yesql:"highlight_post"` LockPost *sqlx.Stmt `yesql:"lock_post"` MediaContentByPostId *sqlx.Stmt `yesql:"media_content_by_post_id"` + PostHighlightStatus *sqlx.Stmt `yesql:"post_highlight_status"` StickPost *sqlx.Stmt `yesql:"stick_post"` VisiblePost *sqlx.Stmt `yesql:"visible_post"` AddPost *sqlx.NamedStmt `yesql:"add_post"` @@ -723,6 +767,66 @@ func BuildTweet(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Tweet, er if obj.GetUserPostStars, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostStars))); err != nil { return } + if obj.UserCommentTweetsByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsByFriend))); err != nil { + return + } + if obj.UserCommentTweetsByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsByGuest))); err != nil { + return + } + if obj.UserCommentTweetsBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsBySelf))); err != nil { + return + } + if obj.UserCommentTweetsCountByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsCountByFriend))); err != nil { + return + } + if obj.UserCommentTweetsCountByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsCountByGuest))); err != nil { + return + } + if obj.UserCommentTweetsCountBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsCountBySelf))); err != nil { + return + } + if obj.UserMediaTweetsByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsByFriend))); err != nil { + return + } + if obj.UserMediaTweetsByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsByGuest))); err != nil { + return + } + if obj.UserMediaTweetsBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsBySelf))); err != nil { + return + } + if obj.UserMediaTweetsCountByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsCountByFriend))); err != nil { + return + } + if obj.UserMediaTweetsCountByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsCountByGuest))); err != nil { + return + } + if obj.UserMediaTweetsCountBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsCountBySelf))); err != nil { + return + } + if obj.UserStarTweetsByAdmin, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsByAdmin))); err != nil { + return + } + if obj.UserStarTweetsByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsByFriend))); err != nil { + return + } + if obj.UserStarTweetsByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsByGuest))); err != nil { + return + } + if obj.UserStarTweetsBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsBySelf))); err != nil { + return + } + if obj.UserStarTweetsCountByAdmin, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsCountByAdmin))); err != nil { + return + } + if obj.UserStarTweetsCountByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsCountByFriend))); err != nil { + return + } + if obj.UserStarTweetsCountByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsCountByGuest))); err != nil { + return + } + if obj.UserStarTweetsCountBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsCountBySelf))); err != nil { + return + } return } @@ -795,12 +899,18 @@ func BuildTweetManage(p yesql.PreparexBuilder, ctx ...context.Context) (obj *Twe if obj.DelPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelPostStar))); err != nil { return } + if obj.HighlightPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_HighlightPost))); err != nil { + return + } if obj.LockPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_LockPost))); err != nil { return } if obj.MediaContentByPostId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_MediaContentByPostId))); err != nil { return } + if obj.PostHighlightStatus, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_PostHighlightStatus))); err != nil { + return + } if obj.StickPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_StickPost))); err != nil { return } diff --git a/internal/dao/sakila/yesql/yesql.sql b/internal/dao/sakila/yesql/yesql.sql index 5b413bfb..e93f45b5 100644 --- a/internal/dao/sakila/yesql/yesql.sql +++ b/internal/dao/sakila/yesql/yesql.sql @@ -565,6 +565,245 @@ WHERE post_id IN (?) AND is_del=0; -- prepare: stmt SELECT * FROM @post_content WHERE id=? AND is_del=0; +-- name: user_media_tweets_by_guest@tweet +-- prepare: stmt +SELECT * +FROM @post_by_media +WHERE is_del=0 AND user_id=? AND visibility=0 +ORDER BY latest_replied_on DESC +LIMIT ? OFFSET ?; + +-- name: user_media_tweets_count_by_guest@tweet +-- prepare: stmt +SELECT count(*) +FROM @post_by_media +WHERE is_del=0 AND user_id=? AND visibility=0; + +-- name: user_media_tweets_by_friend@tweet +-- prepare: stmt +SELECT * +FROM @post_by_media +WHERE is_del=0 AND user_id=? AND (visibility=0 OR visibility=2) +ORDER BY latest_replied_on DESC +LIMIT ? OFFSET ?; + +-- name: user_media_tweets_count_by_friend@tweet +-- prepare: stmt +SELECT count(*) +FROM @post_by_media +WHERE is_del=0 AND user_id=? AND (visibility=0 OR visibility=2); + +-- name: user_media_tweets_by_self@tweet +-- prepare: stmt +SELECT * +FROM @post_by_media +WHERE is_del=0 AND user_id=? +ORDER BY latest_replied_on DESC +LIMIT ? OFFSET ?; + +-- name: user_media_tweets_count_by_self@tweet +-- prepare: stmt +SELECT count(*) +FROM @post_by_media +WHERE is_del=0 AND user_id=?; + +-- name: user_comment_tweets_by_guest@tweet +-- prepare: stmt +SELECT * +FROM @post_by_comment +WHERE is_del=0 AND comment_user_id=? AND visibility=0 +ORDER BY latest_replied_on DESC +LIMIT ? OFFSET ?; + +-- name: user_comment_tweets_count_by_guest@tweet +-- prepare: stmt +SELECT count(*) +FROM @post_by_comment +WHERE is_del=0 AND comment_user_id=? AND visibility=0; + +-- name: user_comment_tweets_by_friend@tweet +-- prepare: stmt +SELECT * +FROM @post_by_comment +WHERE is_del=0 AND comment_user_id=? AND (visibility=0 OR visibility=2) +ORDER BY latest_replied_on DESC +LIMIT ? OFFSET ?; + +-- name: user_comment_tweets_count_by_friend@tweet +-- prepare: stmt +SELECT count(*) +FROM @post_by_comment +WHERE is_del=0 AND comment_user_id=? AND (visibility=0 OR visibility=2); + +-- name: user_comment_tweets_by_self@tweet +-- prepare: stmt +SELECT * +FROM @post_by_comment +WHERE is_del=0 AND comment_user_id=? +ORDER BY latest_replied_on DESC +LIMIT ? OFFSET ?; + +-- name: user_comment_tweets_count_by_self@tweet +-- prepare: stmt +SELECT count(*) +FROM @post_by_comment +WHERE is_del=0 AND comment_user_id=?; + +-- name: user_star_tweets_by_guest@tweet +-- prepare: stmt +SELECT + star.*, + post.ID "post.id", + post.created_on "post.created_on", + post.modified_on "post.modified_on", + post.deleted_on "post.deleted_on", + post.is_del "post.is_del", + post.user_id "post.user_id", + post.comment_count "post.comment_count", + post.collection_count "post.collection_count", + post.share_count "post.share_count", + post.upvote_count "post.upvote_count", + post.visibility "post.visibility", + post.is_top "post.is_top", + post.is_essence "post.is_essence", + post.is_lock "post.is_lock", + post.latest_replied_on "post.latest_replied_on", + post.tags "post.tags", + post.attachment_price "post.attachment_price", + post.ip "post.ip", + post.ip_loc "post.ip_loc" +FROM + @post_star star + JOIN @post post ON star.post_id = post.ID +WHERE + star.is_del = 0 + AND star.user_id =? + AND post.visibility = 0 +ORDER BY post.latest_replied_on DESC +LIMIT ? OFFSET ?; + +-- name: user_star_tweets_count_by_guest@tweet +-- prepare: stmt +SELECT count(*) +FROM + @post_star star + JOIN @post post ON star.post_id = post.ID +WHERE star.is_del=0 AND star.user_id=? AND post.visibility=0; + +-- name: user_star_tweets_by_friend@tweet +-- prepare: stmt +SELECT + star.*, + post.ID "post.id", + post.created_on "post.created_on", + post.modified_on "post.modified_on", + post.deleted_on "post.deleted_on", + post.is_del "post.is_del", + post.user_id "post.user_id", + post.comment_count "post.comment_count", + post.collection_count "post.collection_count", + post.share_count "post.share_count", + post.upvote_count "post.upvote_count", + post.visibility "post.visibility", + post.is_top "post.is_top", + post.is_essence "post.is_essence", + post.is_lock "post.is_lock", + post.latest_replied_on "post.latest_replied_on", + post.tags "post.tags", + post.attachment_price "post.attachment_price", + post.ip "post.ip", + post.ip_loc "post.ip_loc" +FROM + @post_star star + JOIN @post post ON star.post_id = post.ID +WHERE star.is_del=0 AND star.user_id=? AND (post.visibility=0 OR post.visibility=2) +ORDER BY post.latest_replied_on DESC +LIMIT ? OFFSET ?; + +-- name: user_star_tweets_count_by_friend@tweet +-- prepare: stmt +SELECT count(*) +FROM + @post_star star + JOIN @post post ON star.post_id = post.ID +WHERE star.is_del=0 AND star.user_id=? AND (post.visibility=0 OR post.visibility=2); + +-- name: user_star_tweets_by_self@tweet +-- prepare: stmt +SELECT + star.*, + post.ID "post.id", + post.created_on "post.created_on", + post.modified_on "post.modified_on", + post.deleted_on "post.deleted_on", + post.is_del "post.is_del", + post.user_id "post.user_id", + post.comment_count "post.comment_count", + post.collection_count "post.collection_count", + post.share_count "post.share_count", + post.upvote_count "post.upvote_count", + post.visibility "post.visibility", + post.is_top "post.is_top", + post.is_essence "post.is_essence", + post.is_lock "post.is_lock", + post.latest_replied_on "post.latest_replied_on", + post.tags "post.tags", + post.attachment_price "post.attachment_price", + post.ip "post.ip", + post.ip_loc "post.ip_loc" +FROM + @post_star star + JOIN @post post ON star.post_id = post.ID +WHERE star.is_del=0 AND star.user_id=? AND (post.visibility<>0 (post.visibility=0 AND post.user_id=?)) +ORDER BY post.latest_replied_on DESC; +LIMIT ? OFFSET ?; + +-- name: user_star_tweets_count_by_self@tweet +-- prepare: stmt +SELECT count(*) +FROM + @post_star star + JOIN @post post ON star.post_id = post.ID +WHERE star.is_del=0 AND star.user_id=? AND (post.visibility<>0 (post.visibility=0 AND post.user_id=?)); + +-- name: user_star_tweets_by_admin@tweet +-- prepare: stmt +SELECT + star.*, + post.ID "post.id", + post.created_on "post.created_on", + post.modified_on "post.modified_on", + post.deleted_on "post.deleted_on", + post.is_del "post.is_del", + post.user_id "post.user_id", + post.comment_count "post.comment_count", + post.collection_count "post.collection_count", + post.share_count "post.share_count", + post.upvote_count "post.upvote_count", + post.visibility "post.visibility", + post.is_top "post.is_top", + post.is_essence "post.is_essence", + post.is_lock "post.is_lock", + post.latest_replied_on "post.latest_replied_on", + post.tags "post.tags", + post.attachment_price "post.attachment_price", + post.ip "post.ip", + post.ip_loc "post.ip_loc" +FROM + @post_star star + JOIN @post post ON star.post_id = post.ID +WHERE star.is_del=0 AND star.user_id=? +ORDER BY post.latest_replied_on DESC; +LIMIT ? OFFSET ?; + +-- name: user_star_tweets_count_by_admin@tweet +-- prepare: stmt +SELECT count(*) +FROM + @post_star star + JOIN @post post ON star.post_id = post.ID +WHERE star.is_del=0 AND star.user_id=?; + -------------------------------------------------------------------------------- -- tweet_manage sql dml -------------------------------------------------------------------------------- @@ -594,6 +833,14 @@ UPDATE @post SET is_top=1-is_top, modified_on=? WHERE id=? AND is_del=0; -- prepare: stmt UPDATE @post SET visibility=?, is_top=?, modified_on=? WHERE id=? AND is_del=0; +-- name: highlight_post@tweet_manage +-- prepare: stmt +UPDATE @post SET is_essence=1-is_essence WHERE id=? AND is_del=0; + +-- name: post_highlight_status@tweet_manage +-- prepare: stmt +SELECT user_id, is_essence FROM @post WHERE id=? AND is_del=0; + -- name: update_post@tweet_manage -- prepare: named_stmt UPDATE @post SET comment_count=:comment_count,