186 lines
7.4 KiB
Go
186 lines
7.4 KiB
Go
package api
|
|
|
|
import (
|
|
"fmt"
|
|
"regexp"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/doug-martin/goqu/v9"
|
|
"github.com/graphql-go/graphql"
|
|
"github.com/thoas/go-funk"
|
|
)
|
|
|
|
type Work struct {
|
|
ID int `json:"id" gorm:"primaryKey"`
|
|
Title string `json:"title"`
|
|
Orientation string `json:"orientation"`
|
|
Device string `json:"device"`
|
|
Era string `json:"era"`
|
|
Tags string `json:"tags"`
|
|
UserId int `json:"user_id"`
|
|
Content string `json:"content"`
|
|
Image string `json:"image"`
|
|
Images string `json:"images"`
|
|
User User `json:"user" gorm:"foreignKey:UserId"`
|
|
Collect bool `json:"collect" gorm:"column:is_collect"`
|
|
Praise bool `json:"praise" gorm:"column:is_praise"`
|
|
CollectCount int `json:"collect_count" gorm:"column:collect_num"`
|
|
PraiseCount int `json:"praise_count" gorm:"column:praise_num"`
|
|
CreateTime time.Time `json:"create_time"`
|
|
UpdateTime time.Time `json:"update_time"`
|
|
}
|
|
|
|
func (Work) TableName() string {
|
|
return "web_article"
|
|
}
|
|
|
|
var workType = graphql.NewObject(graphql.ObjectConfig{
|
|
Name: "Work",
|
|
Description: "作品",
|
|
Fields: graphql.Fields{
|
|
"id": &graphql.Field{Type: graphql.Int, Description: "作品ID"},
|
|
"title": &graphql.Field{Type: graphql.String, Description: "作品标题"},
|
|
"create_time": &graphql.Field{Type: graphql.DateTime, Description: "作品创建时间"},
|
|
"update_time": &graphql.Field{Type: graphql.DateTime, Description: "作品更新时间"},
|
|
"praise": &graphql.Field{Type: graphql.Boolean, Description: "当前用户是否点赞"},
|
|
"collect": &graphql.Field{Type: graphql.Boolean, Description: "当前用户是否收藏"},
|
|
"praise_count": &graphql.Field{Type: graphql.Int, Description: "点赞数"},
|
|
"collect_count": &graphql.Field{Type: graphql.Int, Description: "收藏数"},
|
|
},
|
|
})
|
|
|
|
var WorkItems = &graphql.Field{
|
|
Name: "works",
|
|
Description: "作品列表",
|
|
Type: graphql.NewObject(graphql.ObjectConfig{
|
|
Name: "WorkConnection",
|
|
Description: "条件筛选作品列表",
|
|
Fields: graphql.Fields{
|
|
"list": &graphql.Field{Type: graphql.NewList(workType), Description: "作品列表"},
|
|
//"total": &graphql.Field{Type: graphql.Int, Description: "作品总数"},
|
|
},
|
|
}),
|
|
Args: graphql.FieldConfigArgument{
|
|
"id": &graphql.ArgumentConfig{Type: graphql.Int, Description: "筛选作品中指定ID的"},
|
|
"title": &graphql.ArgumentConfig{Type: graphql.String, Description: "筛选作品中含有指定标题的"},
|
|
"tags": &graphql.ArgumentConfig{Type: graphql.String, Description: "筛选作品中含有指定标签的"},
|
|
"create_time": &graphql.ArgumentConfig{Type: graphql.DateTime, Description: "筛选作品中创建时间等于指定值的"},
|
|
"update_time": &graphql.ArgumentConfig{Type: graphql.DateTime, Description: "筛选作品中更新时间等于指定值的"},
|
|
"sort": &graphql.ArgumentConfig{Type: graphql.String, Description: "按指定字段排序游戏", DefaultValue: "id"},
|
|
"order": &graphql.ArgumentConfig{Type: orderType, Description: "排序类型(升序或降序)", DefaultValue: "ASC"},
|
|
"first": &graphql.ArgumentConfig{Type: graphql.Int, Description: "翻页参数(傳回清單中的前n個元素)"},
|
|
"last": &graphql.ArgumentConfig{Type: graphql.Int, Description: "翻页参数(傳回清單中的最後n個元素)"},
|
|
"after": &graphql.ArgumentConfig{Type: graphql.String, Description: "翻页参数(傳回清單中指定遊標之後的元素)"},
|
|
"before": &graphql.ArgumentConfig{Type: graphql.String, Description: "翻页参数(傳回清單中指定遊標之前的元素)"},
|
|
},
|
|
Resolve: func(p graphql.ResolveParams) (interface{}, error) {
|
|
var works []Work
|
|
var total int
|
|
var err error
|
|
|
|
var query = goqu.Dialect("mysql").From("web_article").Where(goqu.Ex{"category_top_id": 1})
|
|
|
|
// 筛选条件
|
|
for _, format := range []string{"id", "tags"} {
|
|
if p.Args[format] != nil {
|
|
query = query.Where(goqu.C(format).Eq(p.Args[format]))
|
|
}
|
|
}
|
|
|
|
// 按指定用户点赞筛选
|
|
if p.Args["praise"] != nil {
|
|
query = query.Join(goqu.T("web_praise"), goqu.On(
|
|
goqu.I("web_article.id").Eq(goqu.I("web_praise.praise_id")),
|
|
goqu.I("web_praise.user_id").Eq(p.Args["praise"]),
|
|
goqu.I("web_praise.type").Eq(0),
|
|
))
|
|
}
|
|
|
|
// 按指定用户收藏筛选
|
|
if p.Args["collect"] != nil {
|
|
query = query.Join(goqu.T("web_collect"), goqu.On(
|
|
goqu.I("web_article.id").Eq(goqu.I("web_collect.collect_id")),
|
|
goqu.I("web_collect.user_id").Eq(p.Args["collect"]),
|
|
goqu.I("web_collect.type").Eq(0),
|
|
))
|
|
}
|
|
|
|
// 如果查询了 total 字段
|
|
if existField(p.Info.FieldASTs[0].SelectionSet.Selections, "total") {
|
|
sql, _, _ := query.ToSQL()
|
|
sql = strings.Replace(sql, "SELECT *", "SELECT COUNT(*)", 1)
|
|
if err := db.Raw(sql).Scan(&total).Error; err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
|
|
// 如果没有外部排序则使用指定排序(正则sort只能是字母数字下划下)
|
|
if p.Args["text"] == nil && p.Args["similar"] == nil && p.Args["interest"] == nil {
|
|
sort := regexp.MustCompile(`[^a-zA-Z0-9_]`).ReplaceAllString(p.Args["sort"].(string), "")
|
|
query = query.Select("web_article.id", goqu.L(
|
|
fmt.Sprintf("ROW_NUMBER() OVER(ORDER BY web_article.%s %s)", sort, p.Args["order"]),
|
|
).As("row_num"))
|
|
} else {
|
|
// 排序条件
|
|
if p.Args["sort"] != nil {
|
|
if p.Args["order"].(string) == "ASC" {
|
|
query = query.Order(goqu.C(p.Args["sort"].(string)).Asc())
|
|
}
|
|
if p.Args["order"].(string) == "DESC" {
|
|
query = query.Order(goqu.C(p.Args["sort"].(string)).Desc())
|
|
}
|
|
}
|
|
}
|
|
|
|
// 取所有数据的前N条
|
|
sql, _, _ := query.ToSQL()
|
|
|
|
// 遊標截取篩選結果集的前N条
|
|
var cursor string
|
|
if p.Args["after"] != nil {
|
|
cursor = fmt.Sprintf(`WHERE row_num > (SELECT row_num FROM RankedArticles WHERE RankedArticles.id = %d)`, p.Args["after"].(int))
|
|
}
|
|
|
|
var limit int = 10
|
|
if p.Args["first"] != nil {
|
|
limit = p.Args["first"].(int)
|
|
} else if p.Args["last"] != nil {
|
|
limit = p.Args["last"].(int)
|
|
}
|
|
|
|
// 字段选择
|
|
var user_id = p.Context.Value("user_id").(int)
|
|
var fields = ListItem(p.Info.FieldASTs[0].SelectionSet.Selections)
|
|
var praise, praise_join, collect, collect_join, text_count string
|
|
if funk.Contains(fields, "praise") {
|
|
praise = ",CASE WHEN web_praise.id IS NOT NULL THEN TRUE ELSE FALSE END AS is_praise"
|
|
praise_join = fmt.Sprintf("LEFT JOIN web_praise ON web_praise.praise_id = web_article.id AND web_praise.user_id = %d AND web_praise.type = 0", user_id)
|
|
}
|
|
if funk.Contains(fields, "collect") {
|
|
collect = ",CASE WHEN web_collect.id IS NOT NULL THEN TRUE ELSE FALSE END AS is_collect"
|
|
collect_join = fmt.Sprintf("LEFT JOIN web_collect ON web_collect.collect_id = web_article.id AND web_collect.user_id = %d AND web_collect.type = 0", user_id)
|
|
}
|
|
|
|
sql = fmt.Sprintf(`
|
|
WITH RankedArticles AS (%s)
|
|
SELECT * %s %s %s FROM web_article INNER JOIN(
|
|
SELECT id, row_num FROM RankedArticles %s
|
|
) AS LimitedRanked ON LimitedRanked.id = web_article.id %s %s
|
|
ORDER BY LimitedRanked.row_num ASC LIMIT %d
|
|
`, sql, praise, collect, text_count, cursor, praise_join, collect_join, limit)
|
|
|
|
fmt.Println(sql)
|
|
|
|
if err := db.Raw(sql).Scan(&works).Error; err != nil {
|
|
fmt.Println("获取游戏列表失败", err)
|
|
return nil, err
|
|
}
|
|
|
|
return map[string]interface{}{
|
|
"list": works,
|
|
"total": total,
|
|
}, err
|
|
},
|
|
}
|