feat(user): display moemoepoint log in user dropdown

Author: KUN1007

apps/api/internal/app/router.go

@@ -158,6 +158,9 @@ func (a *App) RegisterRoutes() {
 	userRoutes.Post("/image", auth, a.UserHandler.UploadImage)
 	userRoutes.Post("/check-in", auth, a.UserHandler.CheckIn)
 	userRoutes.Get("/search", auth, a.UserHandler.SearchUsers)
+	// Self-service moemoepoint ledger (own records only; id from session).
+	// Registered BEFORE /:id so Fiber doesn't match "moemoepoint" as a :id.
+	userRoutes.Get("/moemoepoint/log", auth, a.UserHandler.GetMoemoepointLog)
 
 	// Public user profiles
 	userRoutes.Get("/:id", optionalAuth, a.UserHandler.GetUserInfo)

apps/api/internal/user/handler/handler.go

@@ -311,6 +311,27 @@ func (h *UserHandler) CheckIn(c *fiber.Ctx) error {
 	return response.OK(c, map[string]int{"moemoepoint": points})
 }
 
+// GetMoemoepointLog GET /api/user/moemoepoint/log
+// The authenticated user's OWN moemoepoint ledger. The user id comes from the
+// session (never a path param), so one user can't read another's records. moyu
+// proxies OAuth's REDUCED s2s view (no admin note / actor). Cursor paginated via
+// before_id (0 / absent = newest page); optional reason filter.
+func (h *UserHandler) GetMoemoepointLog(c *fiber.Ctx) error {
+	user := middleware.MustGetUser(c)
+
+	limit, _ := strconv.Atoi(c.Query("limit"))
+	if limit <= 0 || limit > 50 {
+		limit = 20
+	}
+	beforeID, _ := strconv.ParseInt(c.Query("before_id"), 10, 64)
+
+	items, hasMore, err := h.service.GetMoemoepointLog(c.Context(), user.ID, limit, beforeID, c.Query("reason"))
+	if err != nil {
+		return response.Error(c, errors.ErrInternal(""))
+	}
+	return response.OK(c, fiber.Map{"items": items, "has_more": hasMore})
+}
+
 // SearchUsers GET /api/user/search
 func (h *UserHandler) SearchUsers(c *fiber.Ctx) error {
 	var req dto.SearchUserRequest

apps/api/internal/user/service/service.go

@@ -258,6 +258,13 @@ func (s *UserService) CheckIn(userID int) (int, error) {
 	return points, nil
 }
 
+// GetMoemoepointLog reads a page of the user's OWN moemoepoint ledger from OAuth
+// (the unified source of truth — moyu stores no local ledger). Cursor paginated
+// via beforeID (0 = newest page); reason is an optional filter.
+func (s *UserService) GetMoemoepointLog(ctx context.Context, userID, limit int, beforeID int64, reason string) ([]moemoepoint.LogEntry, bool, error) {
+	return s.mp.Log(ctx, userID, limit, beforeID, reason)
+}
+
 // GetUserPatches retrieves the user's patch list.
 func (s *UserService) GetUserPatches(userID, page, limit int) ([]patchModel.Patch, int64, error) {
 	return s.repo.GetUserPatches(userID, (page-1)*limit, limit)

apps/api/pkg/moemoepoint/awarder.go

@@ -52,3 +52,14 @@ func (a *Awarder) Award(ctx context.Context, userID, delta int, reason, ref, ide
 			"user_id", userID, "balance", res.Balance, "error", err)
 	}
 }
+
+// Log reads a page of the user's moemoepoint ledger from OAuth (the source of
+// truth — moyu keeps no local ledger). Read-only passthrough to the s2s
+// endpoint; used by the self-service "萌萌点记录" view. A nil Awarder/client
+// yields an empty page rather than an error so the UI degrades gracefully.
+func (a *Awarder) Log(ctx context.Context, userID, limit int, beforeID int64, reason string) ([]LogEntry, bool, error) {
+	if a == nil || a.client == nil {
+		return []LogEntry{}, false, nil
+	}
+	return a.client.Log(ctx, userID, limit, beforeID, reason)
+}

apps/api/pkg/moemoepoint/client.go

@@ -17,6 +17,8 @@ import (
 	"encoding/json"
 	"fmt"
 	"net/http"
+	"net/url"
+	"strconv"
 	"strings"
 	"time"
 )
@@ -138,3 +140,67 @@ func (c *Client) Balance(ctx context.Context, userID int) (int, error) {
 	}
 	return env.Data.Balance, nil
 }
+
+// LogEntry is one row of the REDUCED (end-user-facing) moemoepoint ledger from
+// GET /users/:id/moemoepoint/log. Admin-only fields (note / actor_user_id) are
+// deliberately absent — OAuth's s2s view omits them so moderation notes never
+// leak to the user.
+type LogEntry struct {
+	ID        int64  `json:"id"`
+	Delta     int    `json:"delta"`
+	Reason    string `json:"reason"`
+	SourceApp string `json:"source_app"`
+	Ref       string `json:"ref"`
+	CreatedAt string `json:"created_at"`
+}
+
+// Log reads a page of a user's moemoepoint ledger
+// (GET /users/:id/moemoepoint/log). Cursor pagination: pass beforeID=0 for the
+// newest page, then the last returned entry's ID to fetch older rows. reason is
+// an optional filter. Returns the page plus hasMore. The slice is never nil.
+func (c *Client) Log(ctx context.Context, userID, limit int, beforeID int64, reason string) ([]LogEntry, bool, error) {
+	q := url.Values{}
+	if limit > 0 {
+		q.Set("limit", strconv.Itoa(limit))
+	}
+	if beforeID > 0 {
+		q.Set("before_id", strconv.FormatInt(beforeID, 10))
+	}
+	if reason != "" {
+		q.Set("reason", reason)
+	}
+	u := fmt.Sprintf("%s/users/%d/moemoepoint/log", c.baseURL, userID)
+	if enc := q.Encode(); enc != "" {
+		u += "?" + enc
+	}
+	req, err := http.NewRequestWithContext(ctx, http.MethodGet, u, nil)
+	if err != nil {
+		return nil, false, err
+	}
+	req.Header.Set("Authorization", c.authHeader)
+	req.Header.Set("Accept", "application/json")
+
+	resp, err := c.http.Do(req)
+	if err != nil {
+		return nil, false, fmt.Errorf("oauth moemoepoint log: %w", err)
+	}
+	defer resp.Body.Close()
+
+	var env struct {
+		Code int `json:"code"`
+		Data struct {
+			Items   []LogEntry `json:"items"`
+			HasMore bool       `json:"has_more"`
+		} `json:"data"`
+	}
+	if err := json.NewDecoder(resp.Body).Decode(&env); err != nil {
+		return nil, false, fmt.Errorf("oauth moemoepoint log decode (status=%d): %w", resp.StatusCode, err)
+	}
+	if env.Code != 0 {
+		return nil, false, fmt.Errorf("oauth moemoepoint log: code=%d", env.Code)
+	}
+	if env.Data.Items == nil {
+		env.Data.Items = []LogEntry{}
+	}
+	return env.Data.Items, env.Data.HasMore, nil
+}

apps/api/pkg/moemoepoint/client_test.go

@@ -93,3 +93,54 @@ func TestBalance(t *testing.T) {
 		t.Fatalf("got %d, want 99", bal)
 	}
 }
+
+func TestLog(t *testing.T) {
+	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		if r.Method != http.MethodGet || r.URL.Path != "/users/42/moemoepoint/log" {
+			t.Errorf("unexpected request: %s %s", r.Method, r.URL.Path)
+		}
+		// cursor + limit must be forwarded as query params
+		if got := r.URL.Query().Get("limit"); got != "20" {
+			t.Errorf("limit query = %q, want 20", got)
+		}
+		if got := r.URL.Query().Get("before_id"); got != "100" {
+			t.Errorf("before_id query = %q, want 100", got)
+		}
+		_ = json.NewEncoder(w).Encode(map[string]any{
+			"code": 0, "data": map[string]any{
+				"items": []map[string]any{
+					{"id": 99, "delta": 3, "reason": "content_approved", "source_app": "moyu", "ref": "resource:7", "created_at": "2026-05-29T10:00:00Z"},
+					{"id": 98, "delta": -1, "reason": "liked", "source_app": "moyu", "ref": "comment:3", "created_at": "2026-05-28T09:00:00Z"},
+				},
+				"has_more": true,
+			},
+		})
+	}))
+	defer srv.Close()
+
+	items, hasMore, err := newTestClient(srv).Log(context.Background(), 42, 20, 100, "")
+	if err != nil {
+		t.Fatalf("Log error: %v", err)
+	}
+	if !hasMore {
+		t.Fatal("expected has_more=true")
+	}
+	if len(items) != 2 || items[0].ID != 99 || items[0].Delta != 3 || items[1].Delta != -1 {
+		t.Fatalf("unexpected items: %+v", items)
+	}
+}
+
+func TestLog_EmptyNeverNil(t *testing.T) {
+	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
+		_ = json.NewEncoder(w).Encode(map[string]any{"code": 0, "data": map[string]any{"has_more": false}})
+	}))
+	defer srv.Close()
+
+	items, _, err := newTestClient(srv).Log(context.Background(), 42, 20, 0, "")
+	if err != nil {
+		t.Fatalf("Log error: %v", err)
+	}
+	if items == nil {
+		t.Fatal("items must be non-nil (empty slice) so JSON marshals to [] not null")
+	}
+}

apps/web/app/components/kun/top-bar/MoemoepointLog.vue

@@ -0,0 +1,188 @@
+<script setup lang="ts">
+// 萌萌点记录 — the user's OWN moemoepoint ledger. OAuth is the source of truth;
+// moyu proxies the reduced s2s view via GET /user/moemoepoint/log (id from the
+// session, never a path param). Cursor paginated by the last row's id.
+const open = defineModel<boolean>({ required: true })
+
+const api = useApi()
+const userStore = useUserStore()
+
+interface MoemoepointLogEntry {
+  id: number
+  delta: number
+  reason: string
+  source_app: string
+  ref: string
+  created_at: string
+}
+
+const LIMIT = 20
+
+const items = ref<MoemoepointLogEntry[]>([])
+const hasMore = ref(false)
+const loading = ref(false)
+const loadingMore = ref(false)
+const loaded = ref(false)
+const failed = ref(false)
+
+// reason → human label + icon + color. Mirrors OAuth's reason enum
+// (06-moemoepoint.md); admin_*/migration only appear for cross-channel rows.
+const REASONS: Record<string, { label: string; icon: string; class: string }> = {
+  content_approved: {
+    label: '内容被采纳',
+    icon: 'lucide:badge-check',
+    class: 'text-success-500'
+  },
+  content_removed: {
+    label: '内容被移除',
+    icon: 'lucide:badge-x',
+    class: 'text-danger-500'
+  },
+  daily_checkin: {
+    label: '每日签到',
+    icon: 'lucide:calendar-check',
+    class: 'text-primary-500'
+  },
+  liked: { label: '获得喜欢', icon: 'lucide:heart', class: 'text-danger-500' },
+  admin_grant: { label: '管理员发放', icon: 'lucide:gift', class: 'text-success-500' },
+  admin_deduct: { label: '管理员扣除', icon: 'lucide:gavel', class: 'text-warning-500' },
+  migration: { label: '初始迁移', icon: 'lucide:database', class: 'text-default-400' }
+}
+
+const reasonMeta = (reason: string) =>
+  REASONS[reason] ?? {
+    label: reason,
+    icon: 'lucide:circle-dot',
+    class: 'text-default-400'
+  }
+
+// ref is "type:id" (e.g. "resource:42", "galgame:1207"). Map the ones that have
+// an in-site page to a link; everything else (comment, admin:*, …) has no link.
+const refLink = (refStr: string): string | null => {
+  const [type, id] = (refStr || '').split(':')
+  if (!id) return null
+  if (type === 'resource') return `/resource/${id}`
+  if (type === 'galgame' || type === 'patch') return `/patch/${id}`
+  return null
+}
+
+const fetchPage = async (beforeID?: number) => {
+  const params = new URLSearchParams({ limit: String(LIMIT) })
+  if (beforeID) params.set('before_id', String(beforeID))
+  const res = await api.get<{ items: MoemoepointLogEntry[]; has_more: boolean }>(
+    `/user/moemoepoint/log?${params.toString()}`
+  )
+  if (res.code !== 0) throw new Error(res.message)
+  return res.data
+}
+
+const load = async () => {
+  loading.value = true
+  failed.value = false
+  try {
+    const data = await fetchPage()
+    items.value = data.items ?? []
+    hasMore.value = data.has_more
+    loaded.value = true
+  } catch {
+    failed.value = true
+  } finally {
+    loading.value = false
+  }
+}
+
+const loadMore = async () => {
+  const last = items.value[items.value.length - 1]
+  if (loadingMore.value || !hasMore.value || !last) return
+  loadingMore.value = true
+  try {
+    const data = await fetchPage(last.id)
+    items.value.push(...(data.items ?? []))
+    hasMore.value = data.has_more
+  } catch {
+    useKunMessage('加载更多失败', 'error')
+  } finally {
+    loadingMore.value = false
+  }
+}
+
+// Refetch on each open so a record earned this session (e.g. a fresh check-in)
+// shows without a page reload.
+watch(open, (v) => {
+  if (v) load()
+})
+</script>
+
+<template>
+  <KunModal v-model="open" inner-class-name="max-w-lg w-full">
+    <div class="space-y-4">
+      <div class="flex items-center justify-between">
+        <h3 class="flex items-center gap-2 text-lg font-semibold">
+          <KunIcon name="lucide:lollipop" class="size-5" />
+          萌萌点记录
+        </h3>
+        <span class="text-foreground/60 text-sm">
+          当前 {{ userStore.user.moemoepoint }}
+        </span>
+      </div>
+
+      <KunLoading v-if="loading" description="加载记录中..." />
+
+      <KunNull v-else-if="failed" description="加载失败, 请稍后再试" />
+
+      <KunNull
+        v-else-if="loaded && !items.length"
+        description="还没有萌萌点记录哦"
+      />
+
+      <ul v-else class="max-h-[60vh] space-y-1 overflow-y-auto">
+        <li
+          v-for="item in items"
+          :key="item.id"
+          class="hover:bg-default-100 flex items-center gap-3 rounded-lg px-2 py-2"
+        >
+          <span
+            class="bg-default-100 flex size-9 shrink-0 items-center justify-center rounded-full"
+            :class="reasonMeta(item.reason).class"
+          >
+            <KunIcon :name="reasonMeta(item.reason).icon" class="size-4" />
+          </span>
+          <div class="min-w-0 flex-1">
+            <p class="flex items-center gap-2 text-sm font-medium">
+              <span class="truncate">{{ reasonMeta(item.reason).label }}</span>
+              <NuxtLink
+                v-if="refLink(item.ref)"
+                :to="refLink(item.ref)!"
+                class="text-primary-500 shrink-0 text-xs hover:underline"
+                @click="open = false"
+              >
+                查看
+              </NuxtLink>
+            </p>
+            <p class="text-foreground/50 text-xs">
+              {{ formatTimeDifference(item.created_at) }}
+            </p>
+          </div>
+          <span
+            class="shrink-0 text-sm font-semibold tabular-nums"
+            :class="item.delta >= 0 ? 'text-success-500' : 'text-danger-500'"
+          >
+            {{ item.delta >= 0 ? '+' : '' }}{{ item.delta }}
+          </span>
+        </li>
+
+        <li v-if="hasMore" class="pt-1">
+          <KunButton
+            variant="light"
+            full-width
+            :loading="loadingMore"
+            :disabled="loadingMore"
+            @click="loadMore"
+          >
+            加载更多
+          </KunButton>
+        </li>
+      </ul>
+    </div>
+  </KunModal>
+</template>