diff --git a/backend/services/assetService/service/asset_like_service.go b/backend/services/assetService/service/asset_like_service.go index 94dce46..1f38104 100644 --- a/backend/services/assetService/service/asset_like_service.go +++ b/backend/services/assetService/service/asset_like_service.go @@ -15,9 +15,10 @@ import ( // AssetLikeService 资产点赞业务逻辑层 type AssetLikeService struct { - assetRepo repository.AssetRepository - assetLikeRepo repository.AssetLikeRepository - db *gorm.DB + assetRepo repository.AssetRepository + assetLikeRepo repository.AssetLikeRepository + db *gorm.DB + assetLevelService AssetLevelService // 资产等级服务 } // NewAssetLikeService 创建资产点赞Service实例 @@ -25,11 +26,13 @@ func NewAssetLikeService( assetRepo repository.AssetRepository, assetLikeRepo repository.AssetLikeRepository, db *gorm.DB, + assetLevelService AssetLevelService, ) *AssetLikeService { return &AssetLikeService{ - assetRepo: assetRepo, - assetLikeRepo: assetLikeRepo, - db: db, + assetRepo: assetRepo, + assetLikeRepo: assetLikeRepo, + db: db, + assetLevelService: assetLevelService, } } @@ -223,6 +226,19 @@ func (s *AssetLikeService) LikeAsset(ctx context.Context, assetID, userID, starI zap.Int32("like_count", asset.LikeCount), ) + // 5. 更新资产等级记录（点赞数变化） + if s.assetLevelService != nil { + if newLevel, upgraded, err := s.assetLevelService.AddLikes(assetID, 1); err != nil { + logger.Logger.Warn("Failed to add likes to asset level", + zap.Int64("asset_id", assetID), + zap.Error(err)) + } else if upgraded { + logger.Logger.Info("Asset leveled up due to likes", + zap.Int64("asset_id", assetID), + zap.String("new_level", newLevel)) + } + } + return asset.LikeCount, nil } @@ -338,6 +354,19 @@ func (s *AssetLikeService) UnlikeAsset(ctx context.Context, assetID, userID, sta zap.Int32("like_count", asset.LikeCount), ) + // 4. 更新资产等级记录（取消点赞） + if s.assetLevelService != nil { + if newLevel, downgraded, err := s.assetLevelService.RemoveLikes(assetID, 1); err != nil { + logger.Logger.Warn("Failed to remove likes from asset level", + zap.Int64("asset_id", assetID), + zap.Error(err)) + } else if downgraded { + logger.Logger.Info("Asset downgraded due to like removal", + zap.Int64("asset_id", assetID), + zap.String("new_level", newLevel)) + } + } + return asset.LikeCount, nil } diff --git a/backend/services/assetService/service/mint_service.go b/backend/services/assetService/service/mint_service.go index 377cc8d..22a868a 100644 --- a/backend/services/assetService/service/mint_service.go +++ b/backend/services/assetService/service/mint_service.go @@ -67,6 +67,7 @@ type mintService struct { registryRepo starbookRepo.AssetRegistryRepository // 资产索引仓库（用于星册体系） localMintCostRepo repository.MintCostRepository // 铸造消耗配置仓库 userMintCountRepo repository.UserMintCountRepository // 用户铸爱累计仓库 + assetLevelService AssetLevelService // 资产等级服务 } // NewMintService 创建铸造服务实例 @@ -79,6 +80,7 @@ func NewMintService( registryRepo starbookRepo.AssetRegistryRepository, localMintCostRepo repository.MintCostRepository, userMintCountRepo repository.UserMintCountRepository, + assetLevelService AssetLevelService, ) MintService { return &mintService{ assetRepo: assetRepo, @@ -89,6 +91,7 @@ func NewMintService( registryRepo: registryRepo, localMintCostRepo: localMintCostRepo, userMintCountRepo: userMintCountRepo, + assetLevelService: assetLevelService, } } @@ -439,7 +442,16 @@ func (s *mintService) CreateMintOrder(req *pb.CreateMintOrderRequest, userID, st return nil, err } - // 4. 无需异步 AI 处理，cover_url 已在步骤 3.2 中直接设置 + // 4. 初始化资产等级记录 + if s.assetLevelService != nil && asset != nil { + if _, err := s.assetLevelService.GetOrCreateRecord(asset.ID); err != nil { + logger.Logger.Warn("Failed to create asset level record", + zap.Int64("asset_id", asset.ID), + zap.Error(err)) + } + } + + // 5. 无需异步 AI 处理，cover_url 已在步骤 3.2 中直接设置 // 5. 获取所有者的昵称（创建时所有者就是当前用户） var ownerNickname string diff --git a/backend/services/taskService/service/revenue_service.go b/backend/services/taskService/service/revenue_service.go index 1f01786..9c42c37 100644 --- a/backend/services/taskService/service/revenue_service.go +++ b/backend/services/taskService/service/revenue_service.go @@ -20,24 +20,38 @@ type RevenueService interface { ClaimExhibitionRevenue(ctx context.Context, userID, starID int64, revenueID int64) (*pb.ClaimExhibitionRevenueResponse, error) ClaimAllExhibitionRevenue(ctx context.Context, userID, starID int64) (*pb.ClaimAllExhibitionRevenueResponse, error) OnExhibitionCompleted(ctx context.Context, req *pb.OnExhibitionCompletedRequest) (*pb.OnExhibitionCompletedResponse, error) + SetAssetLevelService(svc AssetLevelService) +} + +// AssetLevelService 资产等级服务接口（定义在assetService） +type AssetLevelService interface { + GetOrCreateRecord(assetID int64) (interface{}, error) + AddExhibitionHours(assetID int64, hours int) (string, bool, error) } // revenueService 展示收益Service实现 type revenueService struct { - revenueRepo repository.RevenueRepository - userRPCClient client.UserServiceClient + revenueRepo repository.RevenueRepository + userRPCClient client.UserServiceClient galleryRPCClient client.GalleryServiceClient + assetLevelService AssetLevelService // 资产等级服务 } // NewRevenueService 创建收益Service实例 -func NewRevenueService(revenueRepo repository.RevenueRepository, userRPCClient client.UserServiceClient, galleryRPCClient client.GalleryServiceClient) RevenueService { +func NewRevenueService(revenueRepo repository.RevenueRepository, userRPCClient client.UserServiceClient, galleryRPCClient client.GalleryServiceClient, assetLevelService AssetLevelService) RevenueService { return &revenueService{ - revenueRepo: revenueRepo, - userRPCClient: userRPCClient, + revenueRepo: revenueRepo, + userRPCClient: userRPCClient, galleryRPCClient: galleryRPCClient, + assetLevelService: assetLevelService, } } +// SetAssetLevelService 设置资产等级服务 +func (s *revenueService) SetAssetLevelService(svc AssetLevelService) { + s.assetLevelService = svc +} + // GetExhibitionRevenue 获取展示收益列表 func (s *revenueService) GetExhibitionRevenue(ctx context.Context, userID, starID int64, status string, page, pageSize int32) (*pb.GetExhibitionRevenueResponse, error) { logger.Logger.Debug("GetExhibitionRevenue", @@ -367,6 +381,21 @@ func (s *revenueService) OnExhibitionCompleted(ctx context.Context, req *pb.OnEx zap.Int64("crystal_reward", crystalReward)) } + // 增加资产累计展出时长（资产等级系统） + if s.assetLevelService != nil && req.AssetId > 0 && actualHours > 0 { + if newLevel, upgraded, err := s.assetLevelService.AddExhibitionHours(req.AssetId, int(actualHours)); err != nil { + logger.Logger.Warn("OnExhibitionCompleted: failed to add exhibition hours to asset level", + zap.Int64("asset_id", req.AssetId), + zap.Int64("hours", actualHours), + zap.Error(err)) + } else if upgraded { + logger.Logger.Info("OnExhibitionCompleted: asset leveled up due to exhibition", + zap.Int64("asset_id", req.AssetId), + zap.String("new_level", newLevel), + zap.Int64("hours", actualHours)) + } + } + logger.Logger.Info("OnExhibitionCompleted: success", zap.Int64("exhibition_id", req.ExhibitionId), zap.Int64("revenue_record_id", createdRecord.ID))