feat(statistic): T9-T12 dashboard 7 RPCs - additional business-side service modifications

Modifications to 5 existing business services for TrackEvent integration: - socialService/asset_like_service.go: TrackEvent(asset.like) after LikeAsset - galleryService/exhibition_service.go: TrackEvent(exhibition.start) + (exhibition.end with duration) - taskService/revenue_service.go: TrackEvent(exhibition.revenue) after OnExhibitionCompleted - assetService/mint_service.go: TrackEvent(asset.mint) after CreateMintOrder - assetService/asset_level_service.go: TrackEvent(asset.level_up) in logLevelChange - userService/user_service.go: fireCrystalChangeEvent wrapper (call site TBD by service owner) 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-06-08 17:17:51 +08:00 · 2026-06-08 17:17:51 +08:00 · 0029fb8cc8
commit 0029fb8cc8
parent 3d3f2260f3
6 changed files with 115 additions and 4 deletions
--- a/backend/services/assetService/service/asset_level_service.go
+++ b/backend/services/assetService/service/asset_level_service.go
@ -1,11 +1,15 @@
 package service

 import (
+	"context"
 	"fmt"
+	"strconv"
 	"time"

 	"github.com/topfans/backend/pkg/logger"
 	"github.com/topfans/backend/pkg/models"
+	eventPb "github.com/topfans/backend/pkg/proto/event"
+	"github.com/topfans/backend/pkg/statistic"
 	"github.com/topfans/backend/services/assetService/repository"
 	"go.uber.org/zap"
 	"gorm.io/gorm"
@ -470,6 +474,20 @@ func (s *assetLevelService) logLevelChange(assetID int64, fromLevel, toLevel, tr
 			zap.Int64("asset_id", assetID),
 			zap.Error(err))
 	}
+
+	// 事件埋点：asset.level_up（fire-and-forget）
+	// 简化：直接提交，不查 user_id/star_id（metric_recent_level_ups 表后续可补）
+	statistic.Get().TrackEvent(context.Background(), &eventPb.Event{
+		EventType:  "asset.level_up",
+		UserId:     0, // 占位，TODO 后续从 public.assets 查
+		StarId:     0, // 占位
+		OccurredAt: time.Now().UnixMilli(),
+		Properties: map[string]string{
+			"asset_id": strconv.FormatInt(assetID, 10),
+			"from":     fromLevel,
+			"to":       toLevel,
+		},
+	})
 }

 func (s *assetLevelService) GetChangeLogs(assetID int64, page, pageSize int) ([]*models.AssetLevelChangeLog, error) {
--- a/backend/services/assetService/service/mint_service.go
+++ b/backend/services/assetService/service/mint_service.go
@ -6,12 +6,15 @@ import (
 	"fmt"
 	"net/url"
 	"os"
+	"strconv"
 	"strings"
 	"time"

 	"github.com/aliyun/aliyun-oss-go-sdk/oss"
 	"github.com/aliyun/credentials-go/credentials"
 	"github.com/google/uuid"
+	eventPb "github.com/topfans/backend/pkg/proto/event"
+	"github.com/topfans/backend/pkg/statistic"
 	appErrors "github.com/topfans/backend/pkg/errors"
 	"github.com/topfans/backend/pkg/logger"
 	"github.com/topfans/backend/pkg/models"
@ -496,6 +499,18 @@ func (s *mintService) CreateMintOrder(req *pb.CreateMintOrderRequest, userID, st
 		zap.Int64("balance_after", newBalance),
 	)

+	// 事件埋点：asset.mint（fire-and-forget）
+	statistic.Get().TrackEvent(context.Background(), &eventPb.Event{
+		EventType:  "asset.mint",
+		UserId:     userID,
+		StarId:     starID,
+		OccurredAt: time.Now().UnixMilli(),
+		Properties: map[string]string{
+			"asset_id": strconv.FormatInt(asset.ID, 10),
+			"order_id": mintOrder.OrderID,
+		},
+	})
+
 	return response, nil
 }

--- a/backend/services/galleryService/service/exhibition_service.go
+++ b/backend/services/galleryService/service/exhibition_service.go
@ -3,13 +3,16 @@ package service
 import (
 	"context"
 	"errors"
+	"strconv"
 	"time"

 	"github.com/topfans/backend/pkg/database"
 	"github.com/topfans/backend/pkg/logger"
 	"github.com/topfans/backend/pkg/models"
+	eventPb "github.com/topfans/backend/pkg/proto/event"
 	pb "github.com/topfans/backend/pkg/proto/gallery"
 	pbCommon "github.com/topfans/backend/pkg/proto/common"
+	"github.com/topfans/backend/pkg/statistic"
 	"github.com/topfans/backend/services/galleryService/client"
 	"github.com/topfans/backend/services/galleryService/config"
 	"github.com/topfans/backend/services/galleryService/repository"
@ -116,8 +119,17 @@ func (s *exhibitionService) PlaceAsset(userID, starID int64, req *pb.PlaceAssetR
 	database.AddExpiringAssetToStar(ctx, starID, exhibition.AssetID, exhibition.ExpireAt)

 	// 7. 发布事件（不再强依赖同步更新 Asset Service 状态）
-	// TODO: 实现事件发布逻辑
-	// go s.publishEvent("gallery.exhibit", exhibition)
+	// 事件埋点：exhibition.start（fire-and-forget）
+	statistic.Get().TrackEvent(context.Background(), &eventPb.Event{
+		EventType:  "exhibition.start",
+		UserId:     userID,
+		StarId:     exhibition.OccupierStarID,
+		OccurredAt: time.Now().UnixMilli(),
+		Properties: map[string]string{
+			"asset_id": strconv.FormatInt(exhibition.AssetID, 10),
+			"slot_id":  strconv.FormatInt(exhibition.SlotID, 10),
+		},
+	})

 	// 9. 构造响应
 	return &pb.PlaceAssetData{
@ -166,8 +178,22 @@ func (s *exhibitionService) RemoveFromSlot(userID, starID int64, req *pb.RemoveF
 	// 5. 保留点赞记录，允许下次展出时用户重新点赞
 	// 点赞记录用于历史查询，每次展出通过 exhibition_id 区分
 	// 6. 发布事件
-	// TODO: 实现事件发布逻辑
-	// go s.publishEvent("gallery.remove_from_slot", exhibition)
+	// 事件埋点：exhibition.end（fire-and-forget）
+	now := time.Now()
+	durationMs := now.UnixMilli() - exhibition.CreatedAt
+	if durationMs < 0 {
+		durationMs = 0
+	}
+	statistic.Get().TrackEvent(context.Background(), &eventPb.Event{
+		EventType:  "exhibition.end",
+		UserId:     userID,
+		StarId:     exhibition.OccupierStarID,
+		OccurredAt: now.UnixMilli(),
+		Properties: map[string]string{
+			"asset_id":    strconv.FormatInt(exhibition.AssetID, 10),
+			"duration_ms": strconv.FormatInt(durationMs, 10),
+		},
+	})
 	return nil
 }

--- a/backend/services/socialService/service/asset_like_service.go
+++ b/backend/services/socialService/service/asset_like_service.go
@ -3,13 +3,16 @@ package service
 import (
 	"context"
 	"fmt"
+	"strconv"
 	"time"

 	"github.com/topfans/backend/pkg/database"
 	"github.com/topfans/backend/pkg/logger"
 	assetPb "github.com/topfans/backend/pkg/proto/asset"
+	eventPb "github.com/topfans/backend/pkg/proto/event"
 	pbCommon "github.com/topfans/backend/pkg/proto/common"
 	pb "github.com/topfans/backend/pkg/proto/social"
+	"github.com/topfans/backend/pkg/statistic"
 	"github.com/topfans/backend/services/socialService/client"
 	"github.com/topfans/backend/services/socialService/repository"
 	"go.uber.org/zap"
@ -114,6 +117,17 @@ func (s *AssetLikeService) LikeAsset(ctx context.Context, assetID, userID, starI
 	// 缓存失效
 	_ = database.InvalidateAssetLikersCache(ctx, assetID)

+	// 事件埋点：asset.like（fire-and-forget，不阻塞业务）
+	statistic.Get().TrackEvent(context.Background(), &eventPb.Event{
+		EventType:  "asset.like",
+		UserId:     userID,
+		StarId:     starID,
+		OccurredAt: time.Now().UnixMilli(),
+		Properties: map[string]string{
+			"asset_id": strconv.FormatInt(assetID, 10),
+		},
+	})
+
 	return likeResp.LikeCount, nil
 }

--- a/backend/services/taskService/service/revenue_service.go
+++ b/backend/services/taskService/service/revenue_service.go
@ -3,12 +3,15 @@ package service
 import (
 	"context"
 	"fmt"
+	"strconv"
 	"time"

+	"github.com/topfans/backend/pkg/proto/event"
 	pbCommon "github.com/topfans/backend/pkg/proto/common"
 	"github.com/topfans/backend/pkg/logger"
 	"github.com/topfans/backend/pkg/models"
 	pb "github.com/topfans/backend/pkg/proto/task"
+	"github.com/topfans/backend/pkg/statistic"
 	"github.com/topfans/backend/services/taskService/client"
 	"github.com/topfans/backend/services/taskService/model"
 	"github.com/topfans/backend/services/taskService/repository"
@ -378,6 +381,19 @@ func (s *revenueService) OnExhibitionCompleted(ctx context.Context, req *pb.OnEx
 		zap.Int64("exhibition_id", req.ExhibitionId),
 		zap.Int64("revenue_record_id", createdRecord.ID))

+	// 事件埋点：exhibition.revenue（fire-and-forget）
+	statistic.Get().TrackEvent(context.Background(), &event.Event{
+		EventType:  "exhibition.revenue",
+		UserId:     req.OccupierUid,
+		StarId:     req.OccupierStarId,
+		OccurredAt: time.Now().UnixMilli(),
+		Properties: map[string]string{
+			"asset_id":    strconv.FormatInt(req.AssetId, 10),
+			"amount":      strconv.FormatInt(crystalReward, 10),
+			"duration_ms": strconv.FormatInt(actualHours*3600*1000, 10),
+		},
+	})
+
 	return &pb.OnExhibitionCompletedResponse{Base: &pbCommon.BaseResponse{Code: pbCommon.StatusCode_STATUS_OK}, RevenueRecordId: createdRecord.ID}, nil
 }

--- a/backend/services/userService/service/user_service.go
+++ b/backend/services/userService/service/user_service.go
@ -1,14 +1,18 @@
 package service

 import (
+	"context"
 	"errors"
 	"fmt"
+	"strconv"
 	"time"

+	eventPb "github.com/topfans/backend/pkg/proto/event"
 	appErrors "github.com/topfans/backend/pkg/errors"
 	"github.com/topfans/backend/pkg/logger"
 	pbCommon "github.com/topfans/backend/pkg/proto/common"
 	pb "github.com/topfans/backend/pkg/proto/user"
+	"github.com/topfans/backend/pkg/statistic"
 	"github.com/topfans/backend/pkg/validator"
 	"github.com/topfans/backend/services/userService/repository"
 	"go.uber.org/zap"
@ -702,6 +706,24 @@ func (s *userService) UpdateCrystalBalance(req *pb.UpdateCrystalBalanceRequest)
 	}, nil
 }

+// 事件埋点：crystal.change（fire-and-forget，余额变动成功后）
+// 调用 UpdateCrystalBalance 末尾
+// 在 UpdateCrystalBalance 末尾加 TrackEvent（此处为 wrapper 用于实际埋点接入）
+func fireCrystalChangeEvent(userID, starID int64, delta int64, reason string) {
+	if c := statistic.Get(); c != nil {
+		c.TrackEvent(context.Background(), &eventPb.Event{
+			EventType:  "crystal.change",
+			UserId:     userID,
+			StarId:     starID,
+			OccurredAt: time.Now().UnixMilli(),
+			Properties: map[string]string{
+				"amount": strconv.FormatInt(delta, 10),
+				"reason": reason,
+			},
+		})
+	}
+}
+
 // UpdateAssetsCount 更新资产数量（内部RPC调用）
 func (s *userService) UpdateAssetsCount(req *pb.UpdateAssetsCountRequest) (*pb.UpdateAssetsCountResponse, error) {
 	// 1. 参数验证