feat: reviewed/unreviewed filter

internal/controller/poll/poll_v1_get_polls.go

@@ -3,8 +3,6 @@ package poll
 import (
 	"context"
 
-	"github.com/gogf/gf/v2/frame/g"
-
 	"github.com/hitokoto-osc/reviewer/internal/model"
 
 	"github.com/hitokoto-osc/reviewer/internal/consts"
@@ -24,8 +22,8 @@ func (c *ControllerV1) GetPolls(ctx context.Context, req *v1.GetPollsReq) (res *
 	if user.Role != consts.UserRoleAdmin && req.StatusEnd >= int(consts.PollStatusApproved) {
 		return nil, gerror.NewCode(gcode.CodeInvalidOperation, "权限不足")
 	}
-	keys, e := g.DB().GetCache().KeyStrings(ctx)
-	g.Log().Debugf(ctx, "%+v %+v", keys, e)
+	// keys, e := g.DB().GetCache().KeyStrings(ctx)
+	// g.Log().Debugf(ctx, "%+v %+v", keys, e)
 	out, err := service.Poll().GetPollList(ctx, &model.GetPollListInput{
 		StatusStart:     req.StatusStart,
 		StatusEnd:       req.StatusEnd,

internal/logic/poll/poll.go

@@ -158,9 +158,15 @@ WHERE
 	} else {
 		query = query.WhereBetween(dao.Poll.Columns().Status, in.StatusStart, in.StatusEnd)
 	}
-	query = query.Order(dao.Poll.Columns().CreatedAt, in.Order).
-		Page(in.Page, in.PageSize)
 	eg, egCtx := errgroup.WithContext(ctx)
+	query.Ctx(egCtx)
+	eg.Go(func() error {
+		var e error
+		q := query.Clone()
+		count, e = q.Count()
+		g.Log().Debugf(ctx, "count: %d", count)
+		return e
+	})
 	eg.Go(func() error {
 		q := query.Clone()
 		if in.WithCache {
@@ -192,13 +198,7 @@ WHERE
 				Force:    false,
 			})
 		}
-		e := q.Scan(&result)
-		return e
-	})
-	eg.Go(func() error {
-		var e error
-		q := query.Clone()
-		count, e = q.Count()
+		e := q.Order(dao.Poll.Columns().CreatedAt, in.Order).Page(in.Page, in.PageSize).Scan(&result)
 		return e
 	})
 	if err := eg.Wait(); err != nil {