目录直接相关的 API

internal/cmd/gen/gorm/main.go

@@ -215,8 +215,15 @@ func main() {
 		gen.FieldTrimPrefix("idx_"),
 		gen.FieldType("idx_id", "uint32"),
 		gen.FieldType("idx_uid", userIDTypeString),
+		gen.FieldType("idx_collects", "uint32"),
+		// 变量重命名
 		gen.FieldRename("idx_uid", "CreatorID"),
-		gen.FieldType("idx_collects", "uint32")))
+		gen.FieldRename("idx_dateline", "CreatedTime"),
+		gen.FieldRename("idx_lasttouch", "UpdatedTime"),
+		gen.FieldRename("idx_replies", "ReplyCount"),
+		gen.FieldRename("idx_collects", "CollectCount"),
+		gen.FieldRename("idx_subject_total", "SubjectCount"),
+	))
 
 	modelPersonField := g.GenerateModelAs("chii_person_fields", "PersonField",
 		gen.FieldTrimPrefix("prsn_"),
@@ -382,6 +389,11 @@ func main() {
 		gen.FieldRelate(field.BelongsTo, "Subject", modelSubject, &field.RelateConfig{
 			GORMTag: "foreignKey:idx_rlt_sid;references:subject_id",
 		}),
+		// 变量重命名
+		gen.FieldRename("idx_rlt_rid", "IndexID"),
+		gen.FieldRename("idx_rlt_sid", "SubjectID"),
+		gen.FieldRename("idx_rlt_type", "SubjectType"),
+		gen.FieldRename("idx_rlt_dateline", "CreatedTime"),
 	))
 
 	g.ApplyBasic(g.GenerateModelAs("chii_rev_text", "RevisionText",

internal/ctrl/ctrl.go

@@ -32,6 +32,7 @@ func New(
 	person domain.PersonRepo,
 	character domain.CharacterRepo,
 	collection domain.CollectionRepo,
+	index domain.IndexRepo,
 	timeline domain.TimeLineRepo,
 	metric tally.Scope,
 	user domain.UserRepo,
@@ -53,6 +54,7 @@ func New(
 		episode:    episode,
 		subject:    subject,
 		character:  character,
+		index:      index,
 		collection: collection,
 		timeline:   timeline,
 
@@ -81,6 +83,7 @@ type Ctrl struct {
 	subject               subject.Repo
 	character             domain.CharacterRepo
 	collection            domain.CollectionRepo
+	index                 domain.IndexRepo
 	timeline              domain.TimeLineRepo
 	metricUserQueryCached tally.Counter
 	metricUserQueryCount  tally.Counter

internal/ctrl/get_index.go

@@ -0,0 +1,67 @@
+// SPDX-License-Identifier: AGPL-3.0-only
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as published
+// by the Free Software Foundation, version 3.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+// See the GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program. If not, see <https://www.gnu.org/licenses/>
+
+package ctrl
+
+import (
+	"context"
+	"errors"
+	"time"
+
+	"go.uber.org/zap"
+
+	"github.com/bangumi/server/internal/ctrl/internal/cachekey"
+	"github.com/bangumi/server/internal/domain"
+	"github.com/bangumi/server/internal/pkg/errgo"
+	"github.com/bangumi/server/internal/web/res"
+)
+
+func (ctl Ctrl) GetIndexWithCache(c context.Context, id uint32) (res.Index, bool, error) {
+	var key = cachekey.Index(id)
+
+	var r res.Index
+	ok, err := ctl.cache.Get(c, key, &r)
+	if err != nil {
+		return r, ok, errgo.Wrap(err, "cache.Get")
+	}
+
+	if ok {
+		return r, ok, nil
+	}
+
+	i, err := ctl.index.Get(c, id)
+	if err != nil {
+		if errors.Is(err, domain.ErrNotFound) {
+			return res.Index{}, false, nil
+		}
+
+		return res.Index{}, false, errgo.Wrap(err, "Index.Get")
+	}
+
+	u, err := ctl.GetUser(c, i.CreatorID)
+	if err != nil {
+		if errors.Is(err, domain.ErrNotFound) {
+			ctl.log.Error("index missing creator", zap.Uint32("index_id", id), i.CreatorID.Zap())
+		}
+		return res.Index{}, false, errgo.Wrap(err, "failed to get creator: user.GetByID")
+	}
+
+	r = res.IndexModelToResponse(&i, u)
+
+	if e := ctl.cache.Set(c, key, r, time.Hour); e != nil {
+		ctl.log.Error("can't set response to cache", zap.Error(e))
+	}
+
+	return r, true, nil
+}

internal/domain/error.go

@@ -31,3 +31,5 @@ var ErrUserNotFound = errgo.MsgNoTrace(ErrNotFound, "user not found")
 var ErrSubjectNotCollected = errgo.MsgNoTrace(ErrNotFound, "subject is not collected by user")
 
 var ErrInput = errors.New("input not valid")
+
+var ErrExists = errors.New("item already exists")

internal/domain/index.go

@@ -23,11 +23,20 @@ import (
 
 type IndexRepo interface {
 	Get(ctx context.Context, id model.IndexID) (model.Index, error)
+	New(ctx context.Context, i *model.Index) error
+	Update(ctx context.Context, id model.IndexID, title string, desc string) error
+	Delete(ctx context.Context, id model.IndexID) error
 
 	CountSubjects(ctx context.Context, id model.IndexID, subjectType model.SubjectType) (int64, error)
 	ListSubjects(
 		ctx context.Context, id model.IndexID, subjectType model.SubjectType, limit, offset int,
 	) ([]IndexSubject, error)
+	AddOrUpdateIndexSubject(
+		ctx context.Context, id model.IndexID, subjectID model.SubjectID, sort uint32, comment string,
+	) (*IndexSubject, error)
+	DeleteIndexSubject(
+		ctx context.Context, id model.IndexID, subjectID model.SubjectID,
+	) error
 }
 
 type IndexSubject struct {