mirror of https://github.com/rocboss/paopao-ce
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1227 lines
89 KiB
1227 lines
89 KiB
// Code generated by Yesql. DO NOT EDIT.
|
|
// versions:
|
|
// - Yesql v1.9.0
|
|
|
|
package cc
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/alimy/yesql"
|
|
"github.com/bitbus/sqlx"
|
|
)
|
|
|
|
var (
|
|
_ = fmt.Errorf("error for placeholder")
|
|
)
|
|
|
|
const (
|
|
_AuthorizationManage_BeFriendIds = `SELECT user_id FROM @contact WHERE friend_id=? AND status=2 AND is_del=0`
|
|
_AuthorizationManage_IsFriend = `SELECT status FROM @contact WHERE user_id=? AND friend_id=? AND is_del=0`
|
|
_AuthorizationManage_MyFriendSet = `SELECT friend_id FROM @contact WHERE user_id=? AND status=2 AND is_del=0`
|
|
_Comment_GetCommentById = `SELECT * FROM @comment WHERE id=? AND is_del=0`
|
|
_Comment_GetCommentContentsByIds = `SELECT * FROM @comment_content WHERE comment_id IN (?)`
|
|
_Comment_GetCommentCount = `SELECT count(*) FROM @comment WHERE post_id=? AND is_del=0`
|
|
_Comment_GetCommentReplyById = `SELECT * FROM @comment_reply WHERE id=? AND is_del=0`
|
|
_Comment_GetCommentThumbs = `SELECT user_id, tweet_id, comment_id, reply_id, comment_type, is_thumbs_up, is_thumbs_down FROM @tweet_comment_thumbs WHERE user_id=? AND tweet_id=?`
|
|
_Comment_GetCommmentRepliesByIds = `SELECT * FROM @comment_reply WHERE comment_id IN (?) ORDER BY id ASC`
|
|
_Comment_GetDefaultComments = `SELECT * FROM @comment WHERE post_id=? AND is_del=0 ORDER BY is_essence DESC, id ASC LIMIT ? OFFSET ?`
|
|
_Comment_GetHotsComments = `SELECT c.* FROM @comment c LEFT JOIN @comment_metric m ON c.id=m.comment_id WHERE c.post_id=? AND c.is_del=0 AND m.is_del=0 ORDER BY is_essence DESC, m.rank_score DESC, c.id DESC LIMIT ? OFFSET ?`
|
|
_Comment_GetNewestComments = `SELECT * FROM @comment WHERE post_id=? AND is_del=0 ORDER BY is_essence DESC, id DESC LIMIT ? OFFSET ?`
|
|
_Comment_GetUsersByIds = `SELECT id, nickname, username, status, avatar, is_admin FROM @user WHERE id IN (?)`
|
|
_CommentManage_CreateComment = `INSERT INTO @comment (post_id, user_id, ip, ip_loc, created_on) VALUES (?, ?, ?, ?, ?)`
|
|
_CommentManage_CreateCommentContent = `INSERT INTO @comment_content (comment_id, user_id, content, type, sort, created_on) VALUES (?, ?, ?, ?, ?, ?)`
|
|
_CommentManage_CreateCommentReply = `INSERT INTO @comment_reply (comment_id, user_id, content, at_user_id, ip, ip_loc, created_on) VALUES (?, ?, ?, ?, ?, ?, ?)`
|
|
_CommentManage_CreateThumbsUpdownComment = `INSERT INTO @tweet_comment_thumbs (user_id, tweet_id, comment_id, reply_id, is_thumbs_up, is_thumbs_down, comment_type, created_on) VALUES (:user_id, :tweet_id, :comment_id, :reply_id, :is_thumbs_up, :is_thumbs_down, :comment_type, :created_on)`
|
|
_CommentManage_DecrCommentReplyCount = `UPDATE @comment SET reply_count=reply_count-1, modified_on=? WHERE id=? AND is_del=0`
|
|
_CommentManage_DeleteComment = `UPDATE @comment SET deleted_on=?, is_del=1 WHERE id=? AND is_del=0`
|
|
_CommentManage_DeleteCommentReply = `UPDATE @comment_reply SET deleted_on=?, is_del=1 WHERE id=? AND is_del=0`
|
|
_CommentManage_DeleteCommentThumbs = `UPDATE @tweet_comment_thumbs SET deleted_on=?, is_del=1 WHERE user_id=? AND tweet_id=? AND comment_id=? AND is_del=0`
|
|
_CommentManage_DeleteReplyThumbs = `UPDATE @tweet_comment_thumbs SET deleted_on=?, is_del=1 WHERE user_id=? AND comment_id=? AND reply_id=? AND is_del=0`
|
|
_CommentManage_GetIssenceStatusById = `SELECT is_essence FROM @comment WHERE id=?`
|
|
_CommentManage_GetCommentReplyThumb = `SELECT * FROM @tweet_comment_thumbs WHERE user_id=? AND tweet_id=? AND comment_id=? AND reply_id=? AND comment_type=1 AND is_del=0`
|
|
_CommentManage_GetTweetCommentThumb = `SELECT * FROM @tweet_comment_thumbs WHERE user_id=? AND tweet_id=? AND comment_id=? AND comment_type=0 AND is_del=0`
|
|
_CommentManage_HighlightComment = `UPDATE @comment SET is_essence=1-is_essence, modified_on=? WHERE id=? AND user_id=? AND is_del=0`
|
|
_CommentManage_IncrCommentReplyCount = `UPDATE @comment SET reply_count=reply_count+1, modified_on=? WHERE id=? AND is_del=0`
|
|
_CommentManage_UpdateCommentThumbsCount = `UPDATE @comment SET thumbs_up_count=?, thumbs_down_count=?, modified_on=? WHERE id=? AND is_del=0`
|
|
_CommentManage_UpdateReplyThumbsCount = `UPDATE @comment_reply SET thumbs_up_count=?, thumbs_down_count=?, modified_on=? WHERE id=? AND is_del=0`
|
|
_CommentManage_UpdateThumbsUpdownComment = `UPDATE @tweet_comment_thumbs SET is_thumbs_up=:is_thumbs_up, is_thumbs_down=:is_thumbs_down, modified_on=:modified_on WHERE id=:id AND is_del=0`
|
|
_CommentMetrics_AddCommentMetric = `INSERT INTO @comment_metric (comment_id, created_on) VALUES (?, ?)`
|
|
_CommentMetrics_DeleteCommentMetric = `UPDATE @comment_metric SET is_del=1, deleted_on=? WHERE comment_id=? AND is_del=0`
|
|
_CommentMetrics_GetMotivationFactor = `SELECT motivation_factor FROM @comment_metric WHERE comment_id=? AND is_del=0`
|
|
_CommentMetrics_UpdateRankScore = `UPDATE @comment_metric SET rank_score=?, modified_on=? WHERE comment_id=? AND is_del=0`
|
|
_CommentMetrics_UpsertCommentMetric = `INSERT INTO @comment_metric (comment_id, rank_score, created_on) VALUES (?, ?, ?)`
|
|
_ContactManager_AddFriendMsgsUpdate = `UPDATE @message SET reply_id=?, modified_on=? WHERE ((sender_user_id = ? AND receiver_user_id = ?) OR (sender_user_id = ? AND receiver_user_id = ?)) AND type = ? AND reply_id = ?`
|
|
_ContactManager_CreateContact = `INSERT INTO @contact (user_id, friend_id, status, created_on) VALUES (?, ?, ?, ?)`
|
|
_ContactManager_CreateMessage = `INSERT INTO @message (sender_user_id, receiver_user_id, type, brief, content, reply_id, created_on) VALUES (:sender_user_id, :receiver_user_id, :type, :brief, :content, :reply_id, :created_on)`
|
|
_ContactManager_DelFriend = `UPDATE @contact SET status=4, is_del=1, deleted_on=? WHERE id=?`
|
|
_ContactManager_FreshContactStatus = `UPDATE @contact SET status=?, modified_on=?, is_del=0 WHERE id=?`
|
|
_ContactManager_GetContact = `SELECT id, user_id, friend_id, group_id, remark, status, is_top, is_black, notice_enable, is_del FROM @contact WHERE user_id=? AND friend_id=?`
|
|
_ContactManager_GetContacts = `SELECT id, user_id, friend_id, group_id, remark, status, is_top, is_black, notice_enable, is_del FROM @contact WHERE (user_id=? AND friend_id=?) OR (user_id=? AND friend_id=?)`
|
|
_ContactManager_GetUserFriend = `SELECT id, user_id, friend_id, group_id, remark, status, is_top, is_black, notice_enable, is_del FROM @contact WHERE user_id=? AND friend_id=? AND is_del=0`
|
|
_ContactManager_IsFriend = `SELECT true FROM @contact WHERE user_id=? AND friend_id=? AND is_del=0 AND status=2`
|
|
_ContactManager_ListFriend = `SELECT c.friend_id user_id, u.username username, u.nickname nickname, u.avatar avatar, u.phone phone FROM @contact c JOIN @user u ON c.friend_id=u.id WHERE c.user_id=? AND c.status=2 AND c.is_del=0 ORDER BY u.nickname ASC LIMIT ? OFFSET ?`
|
|
_ContactManager_RejectFriendMsgsUpdate = `UPDATE @message SET reply_id=?, modified_on=? WHERE sender_user_id = ? AND receiver_user_id = ? AND type = ? AND reply_id = ?`
|
|
_ContactManager_TotalFriendsById = `SELECT count(*) FROM @contact WHERE user_id=? AND status=2 AND is_del=0`
|
|
_FollowingManager_CountFollowings = `SELECT count(*) FROM @following WHERE follow_id=? AND is_del=0`
|
|
_FollowingManager_CountFollows = `SELECT count(*) FROM @following WHERE user_id=? AND is_del=0`
|
|
_FollowingManager_CreateFollowing = `INSERT INTO @following (user_id, follow_id, created_on) VALUES (?, ?, ?)`
|
|
_FollowingManager_DeleteFollowing = `UPDATE @following SET is_del=1, deleted_on=? WHERE user_id=? AND follow_id=? AND is_del=0`
|
|
_FollowingManager_ExistFollowing = `SELECT 1 FROM @following WHERE user_id=? AND follow_id=? AND is_del=0`
|
|
_FollowingManager_ListFollowings = `SELECT u.id user_id, u.username username, u.nickname nickname, u.avatar avatar, u.created_on created_on FROM @following f JOIN @user u ON f.user_id=u.id WHERE f.follow_id=? AND f.is_del=0 ORDER BY u.nickname ASC LIMIT ? OFFSET ?`
|
|
_FollowingManager_ListFollows = `SELECT u.id user_id, u.username username, u.nickname nickname, u.avatar avatar, u.created_on created_on FROM @following f JOIN @user u ON f.follow_id=u.id WHERE f.user_id=? AND f.is_del=0 ORDER BY u.nickname ASC LIMIT ? OFFSET ?`
|
|
_Message_CountAllMessages = `SELECT count(*) FROM @message WHERE (receiver_user_id=? OR (sender_user_id=? AND type=4)) AND is_del=0`
|
|
_Message_CountRequestingMessages = `SELECT count(*) FROM @message WHERE receiver_user_id=? AND type=5 AND is_del=0`
|
|
_Message_CountSystemMessages = `SELECT count(*) FROM @message WHERE receiver_user_id=? AND type IN (1, 2, 3, 99) AND is_del=0`
|
|
_Message_CountUnreadMessages = `SELECT count(*) FROM @message WHERE receiver_user_id=? AND is_read=0 AND is_del=0`
|
|
_Message_CountWhisperMessages = `SELECT count(*) FROM @message WHERE ((receiver_user_id=? OR sender_user_id=?) AND type=4) AND is_del=0`
|
|
_Message_CreateMessage = `INSERT INTO @message (sender_user_id, receiver_user_id, type, brief, content, post_id, comment_id, reply_id, created_on) VALUES (:sender_user_id, :receiver_user_id, :type, :brief, :content, :post_id, :comment_id, :reply_id, :created_on)`
|
|
_Message_GetAllMessages = `SELECT * FROM @message WHERE (receiver_user_id=? OR (sender_user_id=? AND type=4)) AND is_del=0 ORDER BY id DESC LIMIT ? OFFSET ?`
|
|
_Message_GetMessageById = `SELECT * FROM @message WHERE id=? AND is_del=0`
|
|
_Message_GetRequestingMessages = `SELECT * FROM @message WHERE receiver_user_id=? AND type=5 AND is_del=0 ORDER BY id DESC LIMIT ? OFFSET ?`
|
|
_Message_GetSystemMessages = `SELECT * FROM @message WHERE receiver_user_id=? AND type IN (1, 2, 3, 99) AND is_del=0 ORDER BY id DESC LIMIT ? OFFSET ?`
|
|
_Message_GetUnreadCount = `SELECT count(*) FROM @message WHERE receiver_user_id=? AND is_read=0 AND is_del=0`
|
|
_Message_GetUnreadMessages = `SELECT * FROM @message WHERE receiver_user_id=? AND is_read=0 AND is_del=0 ORDER BY id DESC LIMIT ? OFFSET ?`
|
|
_Message_GetWhisperMessages = `SELECT * FROM @message WHERE ((receiver_user_id=? OR sender_user_id=?) AND type=4) AND is_del=0 ORDER BY id DESC LIMIT ? OFFSET ?`
|
|
_Message_ReadAllMessage = `UPDATE @message SET is_read=1, modified_on=? WHERE receiver_user_id=?`
|
|
_Message_ReadMessage = `UPDATE @message SET is_read=1, modified_on=? WHERE id=?`
|
|
_Security_CreatePhoneCaptcha = `INSERT INTO @captcha (phone, captcha, expired_on, created_on) VALUES (:phone, :captcha, :expired_on, :created_on)`
|
|
_Security_GetLatestPhoneCaptcha = `SELECT * FROM @captcha WHERE phone=? AND is_del=0`
|
|
_Security_UsePhoneCaptcha = `UPDATE @captcha SET use_times=use_times+1, modified_on=? WHERE id=? AND is_del=0`
|
|
_ShipIndex_IndexByAdmin = `SELECT * FROM @post WHERE is_del=0 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_ShipIndex_IndexByGuest = `SELECT * FROM @post WHERE visibility=90 AND is_del=0 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_ShipIndex_IndexBySelf = `SELECT * FROM @post WHERE is_del=0 AND (visibility=90 OR (visibility=0 AND user_id=?) OR (visibility=50 AND user_id IN (?))) ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_ShipIndex_IndexCountByAdmin = `SELECT count(*) FROM @post WHERE is_del=0`
|
|
_ShipIndex_IndexCountByGuest = `SELECT count(*) FROM @post WHERE visibility=90 AND is_del=0`
|
|
_ShipIndex_IndexCountBySelf = `SELECT count(*) FROM @post WHERE is_del=0 AND (visibility=90 OR (visibility=0 AND user_id=?) OR (visibility=50 AND user_id IN (?)))`
|
|
_SimpleIndex_Index = `SELECT * FROM @post WHERE visibility=90 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_SimpleIndex_IndexCount = `SELECT count(*) FROM @post WHERE visibility=90`
|
|
_TrendsManager_CountIndexTrends = `SELECT count(*) FROM @user_relation r JOIN @user u ON r.he_uid=u.id JOIN @user_metric m ON r.he_uid=m.user_id WHERE r.user_id=? AND m.is_del=0 AND m.tweets_count>0`
|
|
_TrendsManager_GetIndexTrends = `SELECT u.username username, u.nickname nickname, u.avatar avatar FROM @user_relation r JOIN @user u ON r.he_uid=u.id JOIN @user_metric m ON r.he_uid=m.user_id WHERE r.user_id=? AND m.is_del=0 AND m.tweets_count>0 ORDER BY r.style ASC, m.latest_trends_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_CountFollowingTweets = `SELECT count(*) FROM @post WHERE user_id=? AND is_del=0`
|
|
_Tweet_CountFollowingTweetsFollow = `SELECT count(*) FROM @post WHERE (user_id=? OR (visibility>=60 AND user_id IN(?))) AND is_del=0`
|
|
_Tweet_CountFollowingTweetsFriend = `SELECT count(*) FROM @post WHERE (user_id=? OR (visibility>=50 AND user_id IN(?))) AND is_del=0`
|
|
_Tweet_CountFollowingTweetsFriendFollow = `SELECT count(*) FROM @post WHERE (user_id=? OR (visibility>=50 AND user_id IN(?)) OR (visibility>=60 AND user_id IN(?))) AND is_del=0`
|
|
_Tweet_CountIndexHotsTweets = `SELECT count(*) FROM @post post LEFT JOIN @post_metric metric ON post.id=metric.post_id AND metric.is_del=0 WHERE post.visibility>=90 AND post.is_del=0`
|
|
_Tweet_CountIndexNewestTweets = `SELECT count(*) FROM @post WHERE visibility>=90 AND is_del=0`
|
|
_Tweet_CountSyncSearchTweets = `SELECT count(*) FROM @post WHERE visibility>=50 AND is_del=0`
|
|
_Tweet_CountUserTweets = `SELECT count(*) FROM @post WHERE user_id=? AND visibility>=? AND is_essence=? AND is_del=0`
|
|
_Tweet_GetAnyPostCount = `SELECT count(*) FROM @post WHERE visibility IN (?)`
|
|
_Tweet_GetAnyPosts = `SELECT * FROM @post WHERE visibility IN (?) AND is_del=0 LIMIT ? OFFSET ?`
|
|
_Tweet_GetBeFollowIds = `SELECT follow_id FROM @following WHERE user_id=? AND is_del=0`
|
|
_Tweet_GetBeFriendIds = `SELECT user_id FROM @contact WHERE friend_id=? AND status=2 AND is_del=0`
|
|
_Tweet_GetPostAttachmentBill = `SELECT * FROM @post_attachment_bill WHERE post_id=? AND user_id=? AND is_del=0`
|
|
_Tweet_GetPostById = `SELECT * FROM @post WHERE id=? AND is_del=0`
|
|
_Tweet_GetPostContentById = `SELECT * FROM @post_content WHERE id=? AND is_del=0`
|
|
_Tweet_GetPostContentsByIds = `SELECT * FROM @post_content WHERE post_id IN (?) AND is_del=0`
|
|
_Tweet_GetUserPostCollection = `SELECT s.*, P.ID "post.id", P.user_id "post.user_id", P.comment_count "post.comment_count", P.collection_count "post.collection_count", P.upvote_count "post.upvote_count", P.share_count "post.share_count", P.visibility "post.visibility", P.is_top "post.is_top", P.is_essence "post.is_essence", P.is_lock "post.is_lock", P.latest_replied_on "post.latest_replied_on", P.tags "post.tags", P.attachment_price "post.attachment_price", P.ip "post.ip", P.ip_loc "post.ip_loc", P.is_del "post.is_del", P.created_on "post.created_on", P.modified_on "post.modified_on", P.deleted_on "post.deleted_on" FROM @post_collection s JOIN @post P ON s.post_id = P.ID WHERE s.post_id = ? AND s.user_id = ? AND s.is_del = 0 AND ( visibility >= 50 OR ( visibility = 0 AND P.user_id = ? ) ) ORDER BY P.ID DESC`
|
|
_Tweet_GetUserPostCollectionCount = `SELECT count(*) FROM @post_collection s JOIN @post P ON s.post_id = P.ID WHERE s.user_id = ? AND s.is_del = 0 AND ( visibility >= 50 OR ( visibility = 0 AND P.user_id = ? ) )`
|
|
_Tweet_GetUserPostCollections = `SELECT s.*, P.ID "post.id", P.user_id "post.user_id", P.comment_count "post.comment_count", P.collection_count "post.collection_count", P.upvote_count "post.upvote_count", P.share_count "post.share_count", P.visibility "post.visibility", P.is_top "post.is_top", P.is_essence "post.is_essence", P.is_lock "post.is_lock", P.latest_replied_on "post.latest_replied_on", P.tags "post.tags", P.attachment_price "post.attachment_price", P.ip "post.ip", P.ip_loc "post.ip_loc", P.is_del "post.is_del", P.created_on "post.created_on", P.modified_on "post.modified_on", P.deleted_on "post.deleted_on" FROM @post_collection s JOIN @post P ON s.post_id = P.ID WHERE s.user_id = ? AND s.is_del = 0 AND ( visibility >= 50 OR ( visibility = 0 AND P.user_id = ? ) ) ORDER BY s.ID DESC, P.ID DESC LIMIT ? OFFSET ?`
|
|
_Tweet_GetUserPostCount = `SELECT count(*) FROM @post WHERE user_id=? AND visibility IN (?)`
|
|
_Tweet_GetUserPostStar = `SELECT s.*, P.ID "post.id", P.user_id "post.user_id", P.comment_count "post.comment_count", P.collection_count "post.collection_count", P.upvote_count "post.upvote_count", P.share_count "post.share_count", P.visibility "post.visibility", P.is_top "post.is_top", P.is_essence "post.is_essence", P.is_lock "post.is_lock", P.latest_replied_on "post.latest_replied_on", P.tags "post.tags", P.attachment_price "post.attachment_price", P.ip "post.ip", P.ip_loc "post.ip_loc", P.is_del "post.is_del", P.created_on "post.created_on", P.modified_on "post.modified_on", P.deleted_on "post.deleted_on" FROM @post_star s JOIN @post P ON s.post_id = P.ID WHERE s.post_id = ? AND s.user_id = ? AND s.is_del = 0 AND ( visibility >= 50 OR ( visibility = 0 AND P.user_id = ? ) ) ORDER BY P.ID DESC`
|
|
_Tweet_GetUserPostStarCount = `SELECT count(*) FROM @post_star s JOIN @post P ON s.post_id = P.ID WHERE s.user_id = ? AND s.is_del = 0 AND ( visibility >= 50 OR ( visibility = 0 AND P.user_id = ? ) )`
|
|
_Tweet_GetUserPostStars = `SELECT s.*, P.ID "post.id", P.user_id "post.user_id", P.comment_count "post.comment_count", P.collection_count "post.collection_count", P.upvote_count "post.upvote_count", P.share_count "post.share_count", P.visibility "post.visibility", P.is_top "post.is_top", P.is_essence "post.is_essence", P.is_lock "post.is_lock", P.latest_replied_on "post.latest_replied_on", P.tags "post.tags", P.attachment_price "post.attachment_price", P.ip "post.ip", P.ip_loc "post.ip_loc", P.is_del "post.is_del", P.created_on "post.created_on", P.modified_on "post.modified_on", P.deleted_on "post.deleted_on" FROM @post_star s JOIN @post P ON s.post_id = P.ID WHERE s.user_id = ? AND s.is_del = 0 AND ( visibility >= 50 OR ( visibility = 0 AND P.user_id = ? ) ) ORDER BY s.ID DESC, P.ID DESC LIMIT ? OFFSET ?`
|
|
_Tweet_GetUserPosts = `SELECT * FROM @post WHERE user_id=? AND visibility IN (?) ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_TweetHelp_GetPostContentByIds = `SELECT id, post_id, content, type, sort FROM @post_content WHERE post_id IN (?) AND is_del=0`
|
|
_TweetHelp_GetUsersByIds = `SELECT id, username, nickname, status, avatar, is_admin FROM @user WHERE id IN (?) AND is_del=0`
|
|
_Tweet_ListFollowingTweets = `SELECT * FROM @post WHERE user_id=? AND is_del=0 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_ListFollowingTweetsFollow = `SELECT * FROM @post WHERE (user_id=? OR (visibility>=60 AND user_id IN(?))) AND is_del=0 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_ListFollowingTweetsFriend = `SELECT * FROM @post WHERE (user_id=? OR (visibility>=50 AND user_id IN(?))) AND is_del=0 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_ListFollowingTweetsFriendFollow = `SELECT * FROM @post WHERE (user_id=? OR (visibility>=50 AND user_id IN(?)) OR (visibility>=60 AND user_id IN(?))) AND is_del=0 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_ListIndexHotsTweets = `SELECT post.* FROM @post post LEFT JOIN @post_metric metric ON post.id=metric.post_id WHERE post.visibility>=90 AND post.is_del=0 ORDER BY post.is_top DESC, metric.rank_score DESC, post.latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_ListIndexNewestTweets = `SELECT * FROM @post WHERE visibility>=90 AND is_del=0 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_ListSyncSearchTweets = `SELECT * FROM @post WHERE visibility>=50 AND is_del=0 LIMIT ? OFFSET ?`
|
|
_Tweet_ListUserTweets = `SELECT * FROM @post WHERE user_id=? AND visibility>=? AND is_essence=? AND is_del=0 ORDER BY is_top DESC, latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_TweetManage_AddAttachment = `INSERT INTO @attachment (user_id, file_size, img_width, img_height, type, content, created_on) VALUES (?, ?, ?, ?, ?, ?, ?)`
|
|
_TweetManage_AddPost = `INSERT INTO @post (user_id, tags, ip, ip_loc, attachment_price, visibility, latest_replied_on, created_on) VALUES (:user_id, :tags, :ip, :ip_loc, :attachment_price, :visibility, :latest_replied_on, :created_on)`
|
|
_TweetManage_AddPostCollection = `INSERT INTO @post_collection (post_id, user_id, created_on) VALUES (?, ?, ?)`
|
|
_TweetManage_AddPostContent = `INSERT INTO @post_content (post_id, user_id, content, type, sort, created_on) VALUES (:post_id, :user_id, :content, :type, :sort, :created_on)`
|
|
_TweetManage_AddPostStar = `INSERT INTO @post_star (post_id, user_id, created_on) VALUES (?, ?, ?)`
|
|
_TweetManage_CommentIdsByPostId = `SELECT id FROM @comment WHERE post_id=? AND is_del=0`
|
|
_TweetManage_CommentMediaFromCommentIds = `SELECT content FROM @comment_content WHERE comment_id IN (?) AND type=3 AND is_del=0`
|
|
_TweetManage_DelCommentByPostId = `UPDATE @comment SET deleted_on=?, is_del=1 WHERE post_id=? AND is_del=0`
|
|
_TweetManage_DelCommentContentByCommentIds = `UPDATE @comment_content SET deleted_on=?, is_del=1 WHERE comment_id IN (?) AND is_del=0`
|
|
_TweetManage_DelPostById = `UPDATE @post SET is_del=1, deleted_on=? WHERE id=? AND is_del=0`
|
|
_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_replied_on=:latest_replied_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`
|
|
_TweetMetrics_AddTweetMetric = `INSERT INTO @post_metric (post_id, created_on) VALUES (?, ?)`
|
|
_TweetMetrics_DeleteTweetMetric = `UPDATE @post_metric SET is_del=1, deleted_on=? WHERE post_id=? AND is_del=0`
|
|
_TweetMetrics_GetMotivationFactor = `SELECT motivation_factor FROM @post_metric WHERE post_id=? AND is_del=0`
|
|
_TweetMetrics_UpdateRankScore = `UPDATE @post_metric SET rank_score=?, modified_on=? WHERE post_id=? AND is_del=0`
|
|
_TweetMetrics_UpsertTweetMetric = `INSERT INTO @post_metric (post_id, rank_score, created_on) VALUES (?, ?, ?)`
|
|
_Tweet_UserCommentTweetsByFriend = `SELECT id, user_id, comment_count, collection_count, upvote_count, share_count, visibility, is_top, is_essence, is_lock, latest_replied_on, tags, attachment_price, ip, ip_loc, created_on, modified_on, deleted_on, is_del FROM @post_by_comment WHERE is_del=0 AND comment_user_id=? AND visibility>=50 ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_UserCommentTweetsByGuest = `SELECT id, user_id, comment_count, collection_count, upvote_count, share_count, visibility, is_top, is_essence, is_lock, latest_replied_on, tags, attachment_price, ip, ip_loc, created_on, modified_on, deleted_on, is_del FROM @post_by_comment WHERE is_del=0 AND comment_user_id=? AND visibility>=90 ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_UserCommentTweetsBySelf = `SELECT id, user_id, comment_count, collection_count, upvote_count, share_count, visibility, is_top, is_essence, is_lock, latest_replied_on, tags, attachment_price, ip, ip_loc, created_on, modified_on, deleted_on, is_del 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>=50`
|
|
_Tweet_UserCommentTweetsCountByGuest = `SELECT count(*) FROM @post_by_comment WHERE is_del=0 AND comment_user_id=? AND visibility>=90`
|
|
_Tweet_UserCommentTweetsCountBySelf = `SELECT count(*) FROM @post_by_comment WHERE is_del=0 AND comment_user_id=?`
|
|
_Tweet_UserMediaTweetsByFriend = `SELECT id, user_id, comment_count, collection_count, upvote_count, share_count, visibility, is_top, is_essence, is_lock, latest_replied_on, tags, attachment_price, ip, ip_loc, created_on, modified_on, deleted_on, is_del FROM @post_by_media WHERE is_del=0 AND user_id=? AND visibility>=50 ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_UserMediaTweetsByGuest = `SELECT id, user_id, comment_count, collection_count, upvote_count, share_count, visibility, is_top, is_essence, is_lock, latest_replied_on, tags, attachment_price, ip, ip_loc, created_on, modified_on, deleted_on, is_del FROM @post_by_media WHERE is_del=0 AND user_id=? AND visibility=90 ORDER BY latest_replied_on DESC LIMIT ? OFFSET ?`
|
|
_Tweet_UserMediaTweetsBySelf = `SELECT id, user_id, comment_count, collection_count, upvote_count, share_count, visibility, is_top, is_essence, is_lock, latest_replied_on, tags, attachment_price, ip, ip_loc, created_on, modified_on, deleted_on, is_del 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>=50`
|
|
_Tweet_UserMediaTweetsCountByGuest = `SELECT count(*) FROM @post_by_media WHERE is_del=0 AND user_id=? AND visibility>=90`
|
|
_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>=50 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>=90 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<>90 OR (post.visibility>=90 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>=50`
|
|
_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>=90`
|
|
_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<>90 OR (post.visibility>=90 AND post.user_id=?))`
|
|
_UserManage_CreateUser = `INSERT INTO @user (username, nickname, password, salt, avatar, status, created_on, balance) VALUES (:username, :nickname, :password, :salt, :avatar, :status, :created_on, 0)`
|
|
_UserManage_GetAnyUsers = `SELECT * FROM @user WHERE is_del=0 ORDER BY id ASC limit 6`
|
|
_UserManage_GetRegisterUserCount = `SELECT count(*) FROM @user WHERE is_del=0`
|
|
_UserManage_GetUserById = `SELECT * FROM @user WHERE id=? AND is_del=0`
|
|
_UserManage_GetUserByPhone = `SELECT * FROM @user WHERE phone=? AND is_del=0`
|
|
_UserManage_GetUserByUsername = `SELECT * FROM @user WHERE username=? AND is_del=0`
|
|
_UserManage_GetUsersByIds = `SELECT * FROM @user WHERE id IN (?) AND is_del=0`
|
|
_UserManage_GetUsersByKeyword = `SELECT * FROM @user WHERE username LIKE ? AND is_del=0 limit 6`
|
|
_UserManage_UpdateUser = `UPDATE @user SET username=:username, nickname=:nickname, phone=:phone, password=:password, salt=:salt, status=:status, avatar=:avatar, balance=:balance, is_admin=:is_admin, modified_on=:modified_on WHERE id=? AND is_del=0`
|
|
_UserManage_UserProfileByName = `SELECT u.id, u.username, u.nickname, u.phone, u.status, u.avatar, u.balance, u.is_admin, u.created_on, CASE WHEN m.tweets_count IS NOT NULL THEN m.tweets_count WHEN m.tweets_count IS NULL THEN 0 END AS tweets_count FROM @user u LEFT JOIN @user_metric m ON u.id=m.user_id WHERE u.username=? AND u.is_del=0`
|
|
_UserMetrics_AddUserMetric = `INSERT INTO @user_metric (user_id, created_on) VALUES (?, ?)`
|
|
_UserMetrics_DeleteUserMetric = `UPDATE @user_metric SET is_del=1, deleted_on=? WHERE user_id=? AND is_del=0`
|
|
_UserMetrics_GetTweetsCount = `SELECT tweets_count FROM @user_metric WHERE user_id=? AND is_del=0`
|
|
_UserMetrics_UpdateUserMetric = `UPDATE @user_metric SET tweets_count=?, latest_trends_on=?, modified_on=? WHERE user_id=? AND is_del=0`
|
|
_UserRelation_MyFollowIds = `SELECT follow_id FROM @following WHERE user_id=? AND is_del=0`
|
|
_UserRelation_MyFriendIds = `SELECT friend_id FROM @contact WHERE user_id=? AND status=2 AND is_del=0`
|
|
_Wallet_AddUserBalance = `UPDATE @user SET balance=balance+?, modified_on=? WHERE id=? AND is_del=0`
|
|
_Wallet_CreateRecharge = `INSERT INTO @wallet_recharge (user_id, amount, created_on) VALUES (?, ?, ?)`
|
|
_Wallet_CreateWalletStatement = `INSERT INTO @wallet_statement (user_id, change_amount, balance_snapshot, reason, created_on) VALUES (?, ?, ?, ?, ?)`
|
|
_Wallet_GetRechargeById = `SELECT * FROM @wallet_recharge WHERE id=? AND is_del=?`
|
|
_Wallet_GetUserBalance = `SELECT balance FROM @user WHERE id=? AND is_del=0`
|
|
_Wallet_GetUserByUid = `SELECT * FROM @user WHERE id=? AND is_del=0`
|
|
_Wallet_GetUserWalletBillCount = `SELECT count(*) FROM @wallet_statement WHERE user_id=? AND is_del=0`
|
|
_Wallet_GetUserWalletBills = `SELECT * FROM @wallet_statement WHERE user_id=? AND is_del=0 ORDER BY id DESC LIMIT ? OFFSET ?`
|
|
_Wallet_MarkSuccessRecharge = `UPDATE @wallet_recharge SET trade_no=?, trade_status='TRADE_SUCCESS', modified_on=? WHERE id=? AND is_del=0`
|
|
_Wallet_MinusUserBalance = `UPDATE @user SET balance=balance-?, modified_on=? WHERE id=? AND is_del=0`
|
|
_Wallet_NewPostAttachmentBill = `INSERT INTO @post_attachment_bill (post_id, user_id, paid_amount, created_on) VALUES (?, ?, ?, ?)`
|
|
_Wallet_NewPostBill = `INSERT INTO @wallet_statement (post_id, user_id, change_amount, balance_snapshot, reason, created_on) VALUES (?, ?, ?, ?, ?, ?)`
|
|
)
|
|
|
|
// PreparexContext enhances the Conn interface with context.
|
|
type PreparexContext interface {
|
|
// PrepareContext prepares a statement.
|
|
// The provided context is used for the preparation of the statement, not for
|
|
// the execution of the statement.
|
|
PreparexContext(ctx context.Context, query string) (*sqlx.Stmt, error)
|
|
|
|
// PrepareNamedContext returns an sqlx.NamedStmt
|
|
PrepareNamedContext(ctx context.Context, query string) (*sqlx.NamedStmt, error)
|
|
|
|
// Rebind rebind query to adapte SQL Driver
|
|
Rebind(query string) string
|
|
}
|
|
|
|
// PreparexBuilder preparex builder interface for sqlx
|
|
type PreparexBuilder interface {
|
|
PreparexContext
|
|
QueryHook(query string) string
|
|
}
|
|
|
|
type AuthorizationManage struct {
|
|
yesql.Namespace `yesql:"authorization_manage"`
|
|
BeFriendIds *sqlx.Stmt `yesql:"be_friend_ids"`
|
|
IsFriend *sqlx.Stmt `yesql:"is_friend"`
|
|
MyFriendSet *sqlx.Stmt `yesql:"my_friend_set"`
|
|
}
|
|
|
|
type Comment struct {
|
|
yesql.Namespace `yesql:"comment"`
|
|
GetCommentContentsByIds string `yesql:"get_comment_contents_by_ids"`
|
|
GetCommmentRepliesByIds string `yesql:"get_commment_replies_by_ids"`
|
|
GetUsersByIds string `yesql:"get_users_by_ids"`
|
|
GetCommentById *sqlx.Stmt `yesql:"get_comment_by_id"`
|
|
GetCommentCount *sqlx.Stmt `yesql:"get_comment_count"`
|
|
GetCommentReplyById *sqlx.Stmt `yesql:"get_comment_reply_by_id"`
|
|
GetCommentThumbs *sqlx.Stmt `yesql:"get_comment_thumbs"`
|
|
GetDefaultComments *sqlx.Stmt `yesql:"get_default_comments"`
|
|
GetHotsComments *sqlx.Stmt `yesql:"get_hots_comments"`
|
|
GetNewestComments *sqlx.Stmt `yesql:"get_newest_comments"`
|
|
}
|
|
|
|
type CommentManage struct {
|
|
yesql.Namespace `yesql:"comment_manage"`
|
|
CreateComment *sqlx.Stmt `yesql:"create_comment"`
|
|
CreateCommentContent *sqlx.Stmt `yesql:"create_comment_content"`
|
|
CreateCommentReply *sqlx.Stmt `yesql:"create_comment_reply"`
|
|
DecrCommentReplyCount *sqlx.Stmt `yesql:"decr_comment_reply_count"`
|
|
DeleteComment *sqlx.Stmt `yesql:"delete_comment"`
|
|
DeleteCommentReply *sqlx.Stmt `yesql:"delete_comment_reply"`
|
|
DeleteCommentThumbs *sqlx.Stmt `yesql:"delete_comment_thumbs"`
|
|
DeleteReplyThumbs *sqlx.Stmt `yesql:"delete_reply_thumbs"`
|
|
GetIssenceStatusById *sqlx.Stmt `yesql:"getIssenceStatusById"`
|
|
GetCommentReplyThumb *sqlx.Stmt `yesql:"get_comment_reply_thumb"`
|
|
GetTweetCommentThumb *sqlx.Stmt `yesql:"get_tweet_comment_thumb"`
|
|
HighlightComment *sqlx.Stmt `yesql:"highlight_comment"`
|
|
IncrCommentReplyCount *sqlx.Stmt `yesql:"incr_comment_reply_count"`
|
|
UpdateCommentThumbsCount *sqlx.Stmt `yesql:"update_comment_thumbs_count"`
|
|
UpdateReplyThumbsCount *sqlx.Stmt `yesql:"update_reply_thumbs_count"`
|
|
CreateThumbsUpdownComment *sqlx.NamedStmt `yesql:"create_thumbs_updown_comment"`
|
|
UpdateThumbsUpdownComment *sqlx.NamedStmt `yesql:"update_thumbs_updown_comment"`
|
|
}
|
|
|
|
type CommentMetrics struct {
|
|
yesql.Namespace `yesql:"comment_metrics"`
|
|
AddCommentMetric *sqlx.Stmt `yesql:"add_comment_metric"`
|
|
DeleteCommentMetric *sqlx.Stmt `yesql:"delete_comment_metric"`
|
|
GetMotivationFactor *sqlx.Stmt `yesql:"get_motivation_factor"`
|
|
UpdateRankScore *sqlx.Stmt `yesql:"update_rank_score"`
|
|
UpsertCommentMetric *sqlx.Stmt `yesql:"upsert_comment_metric"`
|
|
}
|
|
|
|
type ContactManager struct {
|
|
yesql.Namespace `yesql:"contact_manager"`
|
|
AddFriendMsgsUpdate *sqlx.Stmt `yesql:"add_friend_msgs_update"`
|
|
CreateContact *sqlx.Stmt `yesql:"create_contact"`
|
|
DelFriend *sqlx.Stmt `yesql:"del_friend"`
|
|
FreshContactStatus *sqlx.Stmt `yesql:"fresh_contact_status"`
|
|
GetContact *sqlx.Stmt `yesql:"get_contact"`
|
|
GetContacts *sqlx.Stmt `yesql:"get_contacts"`
|
|
GetUserFriend *sqlx.Stmt `yesql:"get_user_friend"`
|
|
IsFriend *sqlx.Stmt `yesql:"is_friend"`
|
|
ListFriend *sqlx.Stmt `yesql:"list_friend"`
|
|
RejectFriendMsgsUpdate *sqlx.Stmt `yesql:"reject_friend_msgs_update"`
|
|
TotalFriendsById *sqlx.Stmt `yesql:"total_friends_by_id"`
|
|
CreateMessage *sqlx.NamedStmt `yesql:"create_message"`
|
|
}
|
|
|
|
type FollowingManager struct {
|
|
yesql.Namespace `yesql:"following_manager"`
|
|
CountFollowings *sqlx.Stmt `yesql:"count_followings"`
|
|
CountFollows *sqlx.Stmt `yesql:"count_follows"`
|
|
CreateFollowing *sqlx.Stmt `yesql:"create_following"`
|
|
DeleteFollowing *sqlx.Stmt `yesql:"delete_following"`
|
|
ExistFollowing *sqlx.Stmt `yesql:"exist_following"`
|
|
ListFollowings *sqlx.Stmt `yesql:"list_followings"`
|
|
ListFollows *sqlx.Stmt `yesql:"list_follows"`
|
|
}
|
|
|
|
type Message struct {
|
|
yesql.Namespace `yesql:"message"`
|
|
CountAllMessages *sqlx.Stmt `yesql:"count_all_messages"`
|
|
CountRequestingMessages *sqlx.Stmt `yesql:"count_requesting_messages"`
|
|
CountSystemMessages *sqlx.Stmt `yesql:"count_system_messages"`
|
|
CountUnreadMessages *sqlx.Stmt `yesql:"count_unread_messages"`
|
|
CountWhisperMessages *sqlx.Stmt `yesql:"count_whisper_messages"`
|
|
GetAllMessages *sqlx.Stmt `yesql:"get_all_messages"`
|
|
GetMessageById *sqlx.Stmt `yesql:"get_message_by_id"`
|
|
GetRequestingMessages *sqlx.Stmt `yesql:"get_requesting_messages"`
|
|
GetSystemMessages *sqlx.Stmt `yesql:"get_system_messages"`
|
|
GetUnreadCount *sqlx.Stmt `yesql:"get_unread_count"`
|
|
GetUnreadMessages *sqlx.Stmt `yesql:"get_unread_messages"`
|
|
GetWhisperMessages *sqlx.Stmt `yesql:"get_whisper_messages"`
|
|
ReadAllMessage *sqlx.Stmt `yesql:"read_all_message"`
|
|
ReadMessage *sqlx.Stmt `yesql:"read_message"`
|
|
CreateMessage *sqlx.NamedStmt `yesql:"create_message"`
|
|
}
|
|
|
|
type Security struct {
|
|
yesql.Namespace `yesql:"security"`
|
|
GetLatestPhoneCaptcha *sqlx.Stmt `yesql:"get_latest_phone_captcha"`
|
|
UsePhoneCaptcha *sqlx.Stmt `yesql:"use_phone_captcha"`
|
|
CreatePhoneCaptcha *sqlx.NamedStmt `yesql:"create_phone_captcha"`
|
|
}
|
|
|
|
type ShipIndex struct {
|
|
yesql.Namespace `yesql:"ship_index"`
|
|
IndexBySelf string `yesql:"index_by_self"`
|
|
IndexCountBySelf string `yesql:"index_count_by_self"`
|
|
IndexByAdmin *sqlx.Stmt `yesql:"index_by_admin"`
|
|
IndexByGuest *sqlx.Stmt `yesql:"index_by_guest"`
|
|
IndexCountByAdmin *sqlx.Stmt `yesql:"index_count_by_admin"`
|
|
IndexCountByGuest *sqlx.Stmt `yesql:"index_count_by_guest"`
|
|
}
|
|
|
|
type SimpleIndex struct {
|
|
yesql.Namespace `yesql:"simple_index"`
|
|
Index *sqlx.Stmt `yesql:"index"`
|
|
IndexCount *sqlx.Stmt `yesql:"index_count"`
|
|
}
|
|
|
|
type TrendsManager struct {
|
|
yesql.Namespace `yesql:"trends_manager"`
|
|
CountIndexTrends *sqlx.Stmt `yesql:"count_index_trends"`
|
|
GetIndexTrends *sqlx.Stmt `yesql:"get_index_trends"`
|
|
}
|
|
|
|
type Tweet struct {
|
|
yesql.Namespace `yesql:"tweet"`
|
|
CountFollowingTweetsFollow string `yesql:"count_following_tweets_follow"`
|
|
CountFollowingTweetsFriend string `yesql:"count_following_tweets_friend"`
|
|
CountFollowingTweetsFriendFollow string `yesql:"count_following_tweets_friend_follow"`
|
|
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"`
|
|
ListFollowingTweetsFollow string `yesql:"list_following_tweets_follow"`
|
|
ListFollowingTweetsFriend string `yesql:"list_following_tweets_friend"`
|
|
ListFollowingTweetsFriendFollow string `yesql:"list_following_tweets_friend_follow"`
|
|
CountFollowingTweets *sqlx.Stmt `yesql:"count_following_tweets"`
|
|
CountIndexHotsTweets *sqlx.Stmt `yesql:"count_index_hots_tweets"`
|
|
CountIndexNewestTweets *sqlx.Stmt `yesql:"count_index_newest_tweets"`
|
|
CountSyncSearchTweets *sqlx.Stmt `yesql:"count_sync_search_tweets"`
|
|
CountUserTweets *sqlx.Stmt `yesql:"count_user_tweets"`
|
|
GetBeFollowIds *sqlx.Stmt `yesql:"get_be_follow_ids"`
|
|
GetBeFriendIds *sqlx.Stmt `yesql:"get_be_friend_ids"`
|
|
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"`
|
|
ListFollowingTweets *sqlx.Stmt `yesql:"list_following_tweets"`
|
|
ListIndexHotsTweets *sqlx.Stmt `yesql:"list_index_hots_tweets"`
|
|
ListIndexNewestTweets *sqlx.Stmt `yesql:"list_index_newest_tweets"`
|
|
ListSyncSearchTweets *sqlx.Stmt `yesql:"list_sync_search_tweets"`
|
|
ListUserTweets *sqlx.Stmt `yesql:"list_user_tweets"`
|
|
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 TweetHelp struct {
|
|
yesql.Namespace `yesql:"tweet_help"`
|
|
GetPostContentByIds string `yesql:"get_post_content_by_ids"`
|
|
GetUsersByIds string `yesql:"get_users_by_ids"`
|
|
}
|
|
|
|
type TweetManage struct {
|
|
yesql.Namespace `yesql:"tweet_manage"`
|
|
CommentMediaFromCommentIds string `yesql:"comment_media_from_comment_ids"`
|
|
DelCommentContentByCommentIds string `yesql:"del_comment_content_by_comment_ids"`
|
|
DelReplyByCommentIds string `yesql:"del_reply_by_comment_ids"`
|
|
AddAttachment *sqlx.Stmt `yesql:"add_attachment"`
|
|
AddPostCollection *sqlx.Stmt `yesql:"add_post_collection"`
|
|
AddPostStar *sqlx.Stmt `yesql:"add_post_star"`
|
|
CommentIdsByPostId *sqlx.Stmt `yesql:"comment_ids_by_post_id"`
|
|
DelCommentByPostId *sqlx.Stmt `yesql:"del_comment_by_post_id"`
|
|
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"`
|
|
AddPostContent *sqlx.NamedStmt `yesql:"add_post_content"`
|
|
UpdatePost *sqlx.NamedStmt `yesql:"update_post"`
|
|
}
|
|
|
|
type TweetMetrics struct {
|
|
yesql.Namespace `yesql:"tweet_metrics"`
|
|
AddTweetMetric *sqlx.Stmt `yesql:"add_tweet_metric"`
|
|
DeleteTweetMetric *sqlx.Stmt `yesql:"delete_tweet_metric"`
|
|
GetMotivationFactor *sqlx.Stmt `yesql:"get_motivation_factor"`
|
|
UpdateRankScore *sqlx.Stmt `yesql:"update_rank_score"`
|
|
UpsertTweetMetric *sqlx.Stmt `yesql:"upsert_tweet_metric"`
|
|
}
|
|
|
|
type UserManage struct {
|
|
yesql.Namespace `yesql:"user_manage"`
|
|
GetUsersByIds string `yesql:"get_users_by_ids"`
|
|
GetAnyUsers *sqlx.Stmt `yesql:"get_any_users"`
|
|
GetRegisterUserCount *sqlx.Stmt `yesql:"get_register_user_count"`
|
|
GetUserById *sqlx.Stmt `yesql:"get_user_by_id"`
|
|
GetUserByPhone *sqlx.Stmt `yesql:"get_user_by_phone"`
|
|
GetUserByUsername *sqlx.Stmt `yesql:"get_user_by_username"`
|
|
GetUsersByKeyword *sqlx.Stmt `yesql:"get_users_by_keyword"`
|
|
UserProfileByName *sqlx.Stmt `yesql:"user_profile_by_name"`
|
|
CreateUser *sqlx.NamedStmt `yesql:"create_user"`
|
|
UpdateUser *sqlx.NamedStmt `yesql:"update_user"`
|
|
}
|
|
|
|
type UserMetrics struct {
|
|
yesql.Namespace `yesql:"user_metrics"`
|
|
AddUserMetric *sqlx.Stmt `yesql:"add_user_metric"`
|
|
DeleteUserMetric *sqlx.Stmt `yesql:"delete_user_metric"`
|
|
GetTweetsCount *sqlx.Stmt `yesql:"get_tweets_count"`
|
|
UpdateUserMetric *sqlx.Stmt `yesql:"update_user_metric"`
|
|
}
|
|
|
|
type UserRelation struct {
|
|
yesql.Namespace `yesql:"user_relation"`
|
|
MyFollowIds *sqlx.Stmt `yesql:"my_follow_ids"`
|
|
MyFriendIds *sqlx.Stmt `yesql:"my_friend_ids"`
|
|
}
|
|
|
|
type Wallet struct {
|
|
yesql.Namespace `yesql:"wallet"`
|
|
AddUserBalance *sqlx.Stmt `yesql:"add_user_balance"`
|
|
CreateRecharge *sqlx.Stmt `yesql:"create_recharge"`
|
|
CreateWalletStatement *sqlx.Stmt `yesql:"create_wallet_statement"`
|
|
GetRechargeById *sqlx.Stmt `yesql:"get_recharge_by_id"`
|
|
GetUserBalance *sqlx.Stmt `yesql:"get_user_balance"`
|
|
GetUserByUid *sqlx.Stmt `yesql:"get_user_by_uid"`
|
|
GetUserWalletBillCount *sqlx.Stmt `yesql:"get_user_wallet_bill_count"`
|
|
GetUserWalletBills *sqlx.Stmt `yesql:"get_user_wallet_bills"`
|
|
MarkSuccessRecharge *sqlx.Stmt `yesql:"mark_success_recharge"`
|
|
MinusUserBalance *sqlx.Stmt `yesql:"minus_user_balance"`
|
|
NewPostAttachmentBill *sqlx.Stmt `yesql:"new_post_attachment_bill"`
|
|
NewPostBill *sqlx.Stmt `yesql:"new_post_bill"`
|
|
}
|
|
|
|
func BuildAuthorizationManage(p PreparexBuilder, ctx ...context.Context) (obj *AuthorizationManage, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &AuthorizationManage{}
|
|
if obj.BeFriendIds, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AuthorizationManage_BeFriendIds))); err != nil {
|
|
return nil, fmt.Errorf("prepare _AuthorizationManage_BeFriendIds error: %w", err)
|
|
}
|
|
if obj.IsFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AuthorizationManage_IsFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _AuthorizationManage_IsFriend error: %w", err)
|
|
}
|
|
if obj.MyFriendSet, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_AuthorizationManage_MyFriendSet))); err != nil {
|
|
return nil, fmt.Errorf("prepare _AuthorizationManage_MyFriendSet error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildComment(p PreparexBuilder, ctx ...context.Context) (obj *Comment, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &Comment{
|
|
GetCommentContentsByIds: p.QueryHook(_Comment_GetCommentContentsByIds),
|
|
GetCommmentRepliesByIds: p.QueryHook(_Comment_GetCommmentRepliesByIds),
|
|
GetUsersByIds: p.QueryHook(_Comment_GetUsersByIds),
|
|
}
|
|
if obj.GetCommentById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetCommentById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Comment_GetCommentById error: %w", err)
|
|
}
|
|
if obj.GetCommentCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetCommentCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Comment_GetCommentCount error: %w", err)
|
|
}
|
|
if obj.GetCommentReplyById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetCommentReplyById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Comment_GetCommentReplyById error: %w", err)
|
|
}
|
|
if obj.GetCommentThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetCommentThumbs))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Comment_GetCommentThumbs error: %w", err)
|
|
}
|
|
if obj.GetDefaultComments, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetDefaultComments))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Comment_GetDefaultComments error: %w", err)
|
|
}
|
|
if obj.GetHotsComments, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetHotsComments))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Comment_GetHotsComments error: %w", err)
|
|
}
|
|
if obj.GetNewestComments, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Comment_GetNewestComments))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Comment_GetNewestComments error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildCommentManage(p PreparexBuilder, ctx ...context.Context) (obj *CommentManage, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &CommentManage{}
|
|
if obj.CreateComment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_CreateComment))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_CreateComment error: %w", err)
|
|
}
|
|
if obj.CreateCommentContent, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_CreateCommentContent))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_CreateCommentContent error: %w", err)
|
|
}
|
|
if obj.CreateCommentReply, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_CreateCommentReply))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_CreateCommentReply error: %w", err)
|
|
}
|
|
if obj.DecrCommentReplyCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DecrCommentReplyCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_DecrCommentReplyCount error: %w", err)
|
|
}
|
|
if obj.DeleteComment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DeleteComment))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_DeleteComment error: %w", err)
|
|
}
|
|
if obj.DeleteCommentReply, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DeleteCommentReply))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_DeleteCommentReply error: %w", err)
|
|
}
|
|
if obj.DeleteCommentThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DeleteCommentThumbs))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_DeleteCommentThumbs error: %w", err)
|
|
}
|
|
if obj.DeleteReplyThumbs, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_DeleteReplyThumbs))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_DeleteReplyThumbs error: %w", err)
|
|
}
|
|
if obj.GetIssenceStatusById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_GetIssenceStatusById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_GetIssenceStatusById error: %w", err)
|
|
}
|
|
if obj.GetCommentReplyThumb, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_GetCommentReplyThumb))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_GetCommentReplyThumb error: %w", err)
|
|
}
|
|
if obj.GetTweetCommentThumb, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_GetTweetCommentThumb))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_GetTweetCommentThumb error: %w", err)
|
|
}
|
|
if obj.HighlightComment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_HighlightComment))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_HighlightComment error: %w", err)
|
|
}
|
|
if obj.IncrCommentReplyCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_IncrCommentReplyCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_IncrCommentReplyCount error: %w", err)
|
|
}
|
|
if obj.UpdateCommentThumbsCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_UpdateCommentThumbsCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_UpdateCommentThumbsCount error: %w", err)
|
|
}
|
|
if obj.UpdateReplyThumbsCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentManage_UpdateReplyThumbsCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_UpdateReplyThumbsCount error: %w", err)
|
|
}
|
|
if obj.CreateThumbsUpdownComment, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CommentManage_CreateThumbsUpdownComment))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_CreateThumbsUpdownComment error: %w", err)
|
|
}
|
|
if obj.UpdateThumbsUpdownComment, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_CommentManage_UpdateThumbsUpdownComment))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentManage_UpdateThumbsUpdownComment error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildCommentMetrics(p PreparexBuilder, ctx ...context.Context) (obj *CommentMetrics, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &CommentMetrics{}
|
|
if obj.AddCommentMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentMetrics_AddCommentMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentMetrics_AddCommentMetric error: %w", err)
|
|
}
|
|
if obj.DeleteCommentMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentMetrics_DeleteCommentMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentMetrics_DeleteCommentMetric error: %w", err)
|
|
}
|
|
if obj.GetMotivationFactor, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentMetrics_GetMotivationFactor))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentMetrics_GetMotivationFactor error: %w", err)
|
|
}
|
|
if obj.UpdateRankScore, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentMetrics_UpdateRankScore))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentMetrics_UpdateRankScore error: %w", err)
|
|
}
|
|
if obj.UpsertCommentMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_CommentMetrics_UpsertCommentMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _CommentMetrics_UpsertCommentMetric error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildContactManager(p PreparexBuilder, ctx ...context.Context) (obj *ContactManager, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &ContactManager{}
|
|
if obj.AddFriendMsgsUpdate, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_AddFriendMsgsUpdate))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_AddFriendMsgsUpdate error: %w", err)
|
|
}
|
|
if obj.CreateContact, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_CreateContact))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_CreateContact error: %w", err)
|
|
}
|
|
if obj.DelFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_DelFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_DelFriend error: %w", err)
|
|
}
|
|
if obj.FreshContactStatus, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_FreshContactStatus))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_FreshContactStatus error: %w", err)
|
|
}
|
|
if obj.GetContact, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_GetContact))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_GetContact error: %w", err)
|
|
}
|
|
if obj.GetContacts, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_GetContacts))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_GetContacts error: %w", err)
|
|
}
|
|
if obj.GetUserFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_GetUserFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_GetUserFriend error: %w", err)
|
|
}
|
|
if obj.IsFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_IsFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_IsFriend error: %w", err)
|
|
}
|
|
if obj.ListFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_ListFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_ListFriend error: %w", err)
|
|
}
|
|
if obj.RejectFriendMsgsUpdate, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_RejectFriendMsgsUpdate))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_RejectFriendMsgsUpdate error: %w", err)
|
|
}
|
|
if obj.TotalFriendsById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ContactManager_TotalFriendsById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_TotalFriendsById error: %w", err)
|
|
}
|
|
if obj.CreateMessage, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_ContactManager_CreateMessage))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ContactManager_CreateMessage error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildFollowingManager(p PreparexBuilder, ctx ...context.Context) (obj *FollowingManager, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &FollowingManager{}
|
|
if obj.CountFollowings, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowingManager_CountFollowings))); err != nil {
|
|
return nil, fmt.Errorf("prepare _FollowingManager_CountFollowings error: %w", err)
|
|
}
|
|
if obj.CountFollows, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowingManager_CountFollows))); err != nil {
|
|
return nil, fmt.Errorf("prepare _FollowingManager_CountFollows error: %w", err)
|
|
}
|
|
if obj.CreateFollowing, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowingManager_CreateFollowing))); err != nil {
|
|
return nil, fmt.Errorf("prepare _FollowingManager_CreateFollowing error: %w", err)
|
|
}
|
|
if obj.DeleteFollowing, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowingManager_DeleteFollowing))); err != nil {
|
|
return nil, fmt.Errorf("prepare _FollowingManager_DeleteFollowing error: %w", err)
|
|
}
|
|
if obj.ExistFollowing, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowingManager_ExistFollowing))); err != nil {
|
|
return nil, fmt.Errorf("prepare _FollowingManager_ExistFollowing error: %w", err)
|
|
}
|
|
if obj.ListFollowings, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowingManager_ListFollowings))); err != nil {
|
|
return nil, fmt.Errorf("prepare _FollowingManager_ListFollowings error: %w", err)
|
|
}
|
|
if obj.ListFollows, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_FollowingManager_ListFollows))); err != nil {
|
|
return nil, fmt.Errorf("prepare _FollowingManager_ListFollows error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildMessage(p PreparexBuilder, ctx ...context.Context) (obj *Message, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &Message{}
|
|
if obj.CountAllMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_CountAllMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_CountAllMessages error: %w", err)
|
|
}
|
|
if obj.CountRequestingMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_CountRequestingMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_CountRequestingMessages error: %w", err)
|
|
}
|
|
if obj.CountSystemMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_CountSystemMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_CountSystemMessages error: %w", err)
|
|
}
|
|
if obj.CountUnreadMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_CountUnreadMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_CountUnreadMessages error: %w", err)
|
|
}
|
|
if obj.CountWhisperMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_CountWhisperMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_CountWhisperMessages error: %w", err)
|
|
}
|
|
if obj.GetAllMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetAllMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_GetAllMessages error: %w", err)
|
|
}
|
|
if obj.GetMessageById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetMessageById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_GetMessageById error: %w", err)
|
|
}
|
|
if obj.GetRequestingMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetRequestingMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_GetRequestingMessages error: %w", err)
|
|
}
|
|
if obj.GetSystemMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetSystemMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_GetSystemMessages error: %w", err)
|
|
}
|
|
if obj.GetUnreadCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetUnreadCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_GetUnreadCount error: %w", err)
|
|
}
|
|
if obj.GetUnreadMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetUnreadMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_GetUnreadMessages error: %w", err)
|
|
}
|
|
if obj.GetWhisperMessages, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_GetWhisperMessages))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_GetWhisperMessages error: %w", err)
|
|
}
|
|
if obj.ReadAllMessage, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_ReadAllMessage))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_ReadAllMessage error: %w", err)
|
|
}
|
|
if obj.ReadMessage, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Message_ReadMessage))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_ReadMessage error: %w", err)
|
|
}
|
|
if obj.CreateMessage, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Message_CreateMessage))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Message_CreateMessage error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildSecurity(p PreparexBuilder, ctx ...context.Context) (obj *Security, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &Security{}
|
|
if obj.GetLatestPhoneCaptcha, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Security_GetLatestPhoneCaptcha))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Security_GetLatestPhoneCaptcha error: %w", err)
|
|
}
|
|
if obj.UsePhoneCaptcha, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Security_UsePhoneCaptcha))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Security_UsePhoneCaptcha error: %w", err)
|
|
}
|
|
if obj.CreatePhoneCaptcha, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_Security_CreatePhoneCaptcha))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Security_CreatePhoneCaptcha error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildShipIndex(p PreparexBuilder, ctx ...context.Context) (obj *ShipIndex, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &ShipIndex{
|
|
IndexBySelf: p.QueryHook(_ShipIndex_IndexBySelf),
|
|
IndexCountBySelf: p.QueryHook(_ShipIndex_IndexCountBySelf),
|
|
}
|
|
if obj.IndexByAdmin, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ShipIndex_IndexByAdmin))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ShipIndex_IndexByAdmin error: %w", err)
|
|
}
|
|
if obj.IndexByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ShipIndex_IndexByGuest))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ShipIndex_IndexByGuest error: %w", err)
|
|
}
|
|
if obj.IndexCountByAdmin, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ShipIndex_IndexCountByAdmin))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ShipIndex_IndexCountByAdmin error: %w", err)
|
|
}
|
|
if obj.IndexCountByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_ShipIndex_IndexCountByGuest))); err != nil {
|
|
return nil, fmt.Errorf("prepare _ShipIndex_IndexCountByGuest error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildSimpleIndex(p PreparexBuilder, ctx ...context.Context) (obj *SimpleIndex, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &SimpleIndex{}
|
|
if obj.Index, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_SimpleIndex_Index))); err != nil {
|
|
return nil, fmt.Errorf("prepare _SimpleIndex_Index error: %w", err)
|
|
}
|
|
if obj.IndexCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_SimpleIndex_IndexCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _SimpleIndex_IndexCount error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildTrendsManager(p PreparexBuilder, ctx ...context.Context) (obj *TrendsManager, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &TrendsManager{}
|
|
if obj.CountIndexTrends, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TrendsManager_CountIndexTrends))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TrendsManager_CountIndexTrends error: %w", err)
|
|
}
|
|
if obj.GetIndexTrends, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TrendsManager_GetIndexTrends))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TrendsManager_GetIndexTrends error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildTweet(p PreparexBuilder, ctx ...context.Context) (obj *Tweet, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &Tweet{
|
|
CountFollowingTweetsFollow: p.QueryHook(_Tweet_CountFollowingTweetsFollow),
|
|
CountFollowingTweetsFriend: p.QueryHook(_Tweet_CountFollowingTweetsFriend),
|
|
CountFollowingTweetsFriendFollow: p.QueryHook(_Tweet_CountFollowingTweetsFriendFollow),
|
|
GetAnyPostCount: p.QueryHook(_Tweet_GetAnyPostCount),
|
|
GetAnyPosts: p.QueryHook(_Tweet_GetAnyPosts),
|
|
GetPostContentsByIds: p.QueryHook(_Tweet_GetPostContentsByIds),
|
|
GetUserPostCount: p.QueryHook(_Tweet_GetUserPostCount),
|
|
GetUserPosts: p.QueryHook(_Tweet_GetUserPosts),
|
|
ListFollowingTweetsFollow: p.QueryHook(_Tweet_ListFollowingTweetsFollow),
|
|
ListFollowingTweetsFriend: p.QueryHook(_Tweet_ListFollowingTweetsFriend),
|
|
ListFollowingTweetsFriendFollow: p.QueryHook(_Tweet_ListFollowingTweetsFriendFollow),
|
|
}
|
|
if obj.CountFollowingTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_CountFollowingTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_CountFollowingTweets error: %w", err)
|
|
}
|
|
if obj.CountIndexHotsTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_CountIndexHotsTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_CountIndexHotsTweets error: %w", err)
|
|
}
|
|
if obj.CountIndexNewestTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_CountIndexNewestTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_CountIndexNewestTweets error: %w", err)
|
|
}
|
|
if obj.CountSyncSearchTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_CountSyncSearchTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_CountSyncSearchTweets error: %w", err)
|
|
}
|
|
if obj.CountUserTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_CountUserTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_CountUserTweets error: %w", err)
|
|
}
|
|
if obj.GetBeFollowIds, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetBeFollowIds))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetBeFollowIds error: %w", err)
|
|
}
|
|
if obj.GetBeFriendIds, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetBeFriendIds))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetBeFriendIds error: %w", err)
|
|
}
|
|
if obj.GetPostAttachmentBill, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetPostAttachmentBill))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetPostAttachmentBill error: %w", err)
|
|
}
|
|
if obj.GetPostById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetPostById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetPostById error: %w", err)
|
|
}
|
|
if obj.GetPostContentById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetPostContentById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetPostContentById error: %w", err)
|
|
}
|
|
if obj.GetUserPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostCollection))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetUserPostCollection error: %w", err)
|
|
}
|
|
if obj.GetUserPostCollectionCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostCollectionCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetUserPostCollectionCount error: %w", err)
|
|
}
|
|
if obj.GetUserPostCollections, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostCollections))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetUserPostCollections error: %w", err)
|
|
}
|
|
if obj.GetUserPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostStar))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetUserPostStar error: %w", err)
|
|
}
|
|
if obj.GetUserPostStarCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostStarCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetUserPostStarCount error: %w", err)
|
|
}
|
|
if obj.GetUserPostStars, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_GetUserPostStars))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_GetUserPostStars error: %w", err)
|
|
}
|
|
if obj.ListFollowingTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_ListFollowingTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_ListFollowingTweets error: %w", err)
|
|
}
|
|
if obj.ListIndexHotsTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_ListIndexHotsTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_ListIndexHotsTweets error: %w", err)
|
|
}
|
|
if obj.ListIndexNewestTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_ListIndexNewestTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_ListIndexNewestTweets error: %w", err)
|
|
}
|
|
if obj.ListSyncSearchTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_ListSyncSearchTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_ListSyncSearchTweets error: %w", err)
|
|
}
|
|
if obj.ListUserTweets, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_ListUserTweets))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_ListUserTweets error: %w", err)
|
|
}
|
|
if obj.UserCommentTweetsByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsByFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserCommentTweetsByFriend error: %w", err)
|
|
}
|
|
if obj.UserCommentTweetsByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsByGuest))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserCommentTweetsByGuest error: %w", err)
|
|
}
|
|
if obj.UserCommentTweetsBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsBySelf))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserCommentTweetsBySelf error: %w", err)
|
|
}
|
|
if obj.UserCommentTweetsCountByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsCountByFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserCommentTweetsCountByFriend error: %w", err)
|
|
}
|
|
if obj.UserCommentTweetsCountByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsCountByGuest))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserCommentTweetsCountByGuest error: %w", err)
|
|
}
|
|
if obj.UserCommentTweetsCountBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserCommentTweetsCountBySelf))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserCommentTweetsCountBySelf error: %w", err)
|
|
}
|
|
if obj.UserMediaTweetsByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsByFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserMediaTweetsByFriend error: %w", err)
|
|
}
|
|
if obj.UserMediaTweetsByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsByGuest))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserMediaTweetsByGuest error: %w", err)
|
|
}
|
|
if obj.UserMediaTweetsBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsBySelf))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserMediaTweetsBySelf error: %w", err)
|
|
}
|
|
if obj.UserMediaTweetsCountByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsCountByFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserMediaTweetsCountByFriend error: %w", err)
|
|
}
|
|
if obj.UserMediaTweetsCountByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsCountByGuest))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserMediaTweetsCountByGuest error: %w", err)
|
|
}
|
|
if obj.UserMediaTweetsCountBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserMediaTweetsCountBySelf))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserMediaTweetsCountBySelf error: %w", err)
|
|
}
|
|
if obj.UserStarTweetsByAdmin, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsByAdmin))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserStarTweetsByAdmin error: %w", err)
|
|
}
|
|
if obj.UserStarTweetsByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsByFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserStarTweetsByFriend error: %w", err)
|
|
}
|
|
if obj.UserStarTweetsByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsByGuest))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserStarTweetsByGuest error: %w", err)
|
|
}
|
|
if obj.UserStarTweetsBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsBySelf))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserStarTweetsBySelf error: %w", err)
|
|
}
|
|
if obj.UserStarTweetsCountByAdmin, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsCountByAdmin))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserStarTweetsCountByAdmin error: %w", err)
|
|
}
|
|
if obj.UserStarTweetsCountByFriend, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsCountByFriend))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserStarTweetsCountByFriend error: %w", err)
|
|
}
|
|
if obj.UserStarTweetsCountByGuest, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsCountByGuest))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserStarTweetsCountByGuest error: %w", err)
|
|
}
|
|
if obj.UserStarTweetsCountBySelf, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Tweet_UserStarTweetsCountBySelf))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Tweet_UserStarTweetsCountBySelf error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildTweetHelp(p PreparexBuilder) (obj *TweetHelp, err error) {
|
|
obj = &TweetHelp{
|
|
GetPostContentByIds: p.QueryHook(_TweetHelp_GetPostContentByIds),
|
|
GetUsersByIds: p.QueryHook(_TweetHelp_GetUsersByIds),
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildTweetManage(p PreparexBuilder, ctx ...context.Context) (obj *TweetManage, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &TweetManage{
|
|
CommentMediaFromCommentIds: p.QueryHook(_TweetManage_CommentMediaFromCommentIds),
|
|
DelCommentContentByCommentIds: p.QueryHook(_TweetManage_DelCommentContentByCommentIds),
|
|
DelReplyByCommentIds: p.QueryHook(_TweetManage_DelReplyByCommentIds),
|
|
}
|
|
if obj.AddAttachment, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddAttachment))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_AddAttachment error: %w", err)
|
|
}
|
|
if obj.AddPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPostCollection))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_AddPostCollection error: %w", err)
|
|
}
|
|
if obj.AddPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPostStar))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_AddPostStar error: %w", err)
|
|
}
|
|
if obj.CommentIdsByPostId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_CommentIdsByPostId))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_CommentIdsByPostId error: %w", err)
|
|
}
|
|
if obj.DelCommentByPostId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelCommentByPostId))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_DelCommentByPostId error: %w", err)
|
|
}
|
|
if obj.DelPostById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelPostById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_DelPostById error: %w", err)
|
|
}
|
|
if obj.DelPostCollection, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelPostCollection))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_DelPostCollection error: %w", err)
|
|
}
|
|
if obj.DelPostStar, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_DelPostStar))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_DelPostStar error: %w", err)
|
|
}
|
|
if obj.HighlightPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_HighlightPost))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_HighlightPost error: %w", err)
|
|
}
|
|
if obj.LockPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_LockPost))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_LockPost error: %w", err)
|
|
}
|
|
if obj.MediaContentByPostId, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_MediaContentByPostId))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_MediaContentByPostId error: %w", err)
|
|
}
|
|
if obj.PostHighlightStatus, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_PostHighlightStatus))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_PostHighlightStatus error: %w", err)
|
|
}
|
|
if obj.StickPost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_StickPost))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_StickPost error: %w", err)
|
|
}
|
|
if obj.VisiblePost, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetManage_VisiblePost))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_VisiblePost error: %w", err)
|
|
}
|
|
if obj.AddPost, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPost))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_AddPost error: %w", err)
|
|
}
|
|
if obj.AddPostContent, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_TweetManage_AddPostContent))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_AddPostContent error: %w", err)
|
|
}
|
|
if obj.UpdatePost, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_TweetManage_UpdatePost))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetManage_UpdatePost error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildTweetMetrics(p PreparexBuilder, ctx ...context.Context) (obj *TweetMetrics, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &TweetMetrics{}
|
|
if obj.AddTweetMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetMetrics_AddTweetMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetMetrics_AddTweetMetric error: %w", err)
|
|
}
|
|
if obj.DeleteTweetMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetMetrics_DeleteTweetMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetMetrics_DeleteTweetMetric error: %w", err)
|
|
}
|
|
if obj.GetMotivationFactor, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetMetrics_GetMotivationFactor))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetMetrics_GetMotivationFactor error: %w", err)
|
|
}
|
|
if obj.UpdateRankScore, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetMetrics_UpdateRankScore))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetMetrics_UpdateRankScore error: %w", err)
|
|
}
|
|
if obj.UpsertTweetMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_TweetMetrics_UpsertTweetMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _TweetMetrics_UpsertTweetMetric error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildUserManage(p PreparexBuilder, ctx ...context.Context) (obj *UserManage, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &UserManage{
|
|
GetUsersByIds: p.QueryHook(_UserManage_GetUsersByIds),
|
|
}
|
|
if obj.GetAnyUsers, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetAnyUsers))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_GetAnyUsers error: %w", err)
|
|
}
|
|
if obj.GetRegisterUserCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetRegisterUserCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_GetRegisterUserCount error: %w", err)
|
|
}
|
|
if obj.GetUserById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetUserById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_GetUserById error: %w", err)
|
|
}
|
|
if obj.GetUserByPhone, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetUserByPhone))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_GetUserByPhone error: %w", err)
|
|
}
|
|
if obj.GetUserByUsername, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetUserByUsername))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_GetUserByUsername error: %w", err)
|
|
}
|
|
if obj.GetUsersByKeyword, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_GetUsersByKeyword))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_GetUsersByKeyword error: %w", err)
|
|
}
|
|
if obj.UserProfileByName, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserManage_UserProfileByName))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_UserProfileByName error: %w", err)
|
|
}
|
|
if obj.CreateUser, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_UserManage_CreateUser))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_CreateUser error: %w", err)
|
|
}
|
|
if obj.UpdateUser, err = p.PrepareNamedContext(c, p.Rebind(p.QueryHook(_UserManage_UpdateUser))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserManage_UpdateUser error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildUserMetrics(p PreparexBuilder, ctx ...context.Context) (obj *UserMetrics, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &UserMetrics{}
|
|
if obj.AddUserMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserMetrics_AddUserMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserMetrics_AddUserMetric error: %w", err)
|
|
}
|
|
if obj.DeleteUserMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserMetrics_DeleteUserMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserMetrics_DeleteUserMetric error: %w", err)
|
|
}
|
|
if obj.GetTweetsCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserMetrics_GetTweetsCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserMetrics_GetTweetsCount error: %w", err)
|
|
}
|
|
if obj.UpdateUserMetric, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserMetrics_UpdateUserMetric))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserMetrics_UpdateUserMetric error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildUserRelation(p PreparexBuilder, ctx ...context.Context) (obj *UserRelation, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &UserRelation{}
|
|
if obj.MyFollowIds, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserRelation_MyFollowIds))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserRelation_MyFollowIds error: %w", err)
|
|
}
|
|
if obj.MyFriendIds, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_UserRelation_MyFriendIds))); err != nil {
|
|
return nil, fmt.Errorf("prepare _UserRelation_MyFriendIds error: %w", err)
|
|
}
|
|
return
|
|
}
|
|
|
|
func BuildWallet(p PreparexBuilder, ctx ...context.Context) (obj *Wallet, err error) {
|
|
var c context.Context
|
|
if len(ctx) > 0 && ctx[0] != nil {
|
|
c = ctx[0]
|
|
} else {
|
|
c = context.Background()
|
|
}
|
|
obj = &Wallet{}
|
|
if obj.AddUserBalance, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_AddUserBalance))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_AddUserBalance error: %w", err)
|
|
}
|
|
if obj.CreateRecharge, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_CreateRecharge))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_CreateRecharge error: %w", err)
|
|
}
|
|
if obj.CreateWalletStatement, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_CreateWalletStatement))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_CreateWalletStatement error: %w", err)
|
|
}
|
|
if obj.GetRechargeById, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_GetRechargeById))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_GetRechargeById error: %w", err)
|
|
}
|
|
if obj.GetUserBalance, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_GetUserBalance))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_GetUserBalance error: %w", err)
|
|
}
|
|
if obj.GetUserByUid, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_GetUserByUid))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_GetUserByUid error: %w", err)
|
|
}
|
|
if obj.GetUserWalletBillCount, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_GetUserWalletBillCount))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_GetUserWalletBillCount error: %w", err)
|
|
}
|
|
if obj.GetUserWalletBills, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_GetUserWalletBills))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_GetUserWalletBills error: %w", err)
|
|
}
|
|
if obj.MarkSuccessRecharge, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_MarkSuccessRecharge))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_MarkSuccessRecharge error: %w", err)
|
|
}
|
|
if obj.MinusUserBalance, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_MinusUserBalance))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_MinusUserBalance error: %w", err)
|
|
}
|
|
if obj.NewPostAttachmentBill, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_NewPostAttachmentBill))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_NewPostAttachmentBill error: %w", err)
|
|
}
|
|
if obj.NewPostBill, err = p.PreparexContext(c, p.Rebind(p.QueryHook(_Wallet_NewPostBill))); err != nil {
|
|
return nil, fmt.Errorf("prepare _Wallet_NewPostBill error: %w", err)
|
|
}
|
|
return
|
|
}
|