feat: 增加检验竞品报告余额

This commit is contained in:
cjy 2026-01-13 11:24:50 +08:00
parent c5f7903c6c
commit b079b597c3

View File

@ -2,10 +2,12 @@ package cast
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"fonchain-fiee/api/bundle" "fonchain-fiee/api/bundle"
"fonchain-fiee/api/cast" "fonchain-fiee/api/cast"
"fonchain-fiee/pkg/cache" "fonchain-fiee/pkg/cache"
"fonchain-fiee/pkg/e"
modelCast "fonchain-fiee/pkg/model/cast" modelCast "fonchain-fiee/pkg/model/cast"
"fonchain-fiee/pkg/service" "fonchain-fiee/pkg/service"
"fonchain-fiee/pkg/utils" "fonchain-fiee/pkg/utils"
@ -26,6 +28,15 @@ func CreateCompetitiveReport(ctx *gin.Context) {
return return
} }
newCtx := NewCtxWithUserInfo(ctx) newCtx := NewCtxWithUserInfo(ctx)
artistID, _ := strconv.ParseUint(req.ArtistID, 10, 64)
if _, err = CheckUserBundleBalance(int32(artistID), modelCast.BalanceTypeCompetitiveValue); err != nil {
if err != nil && err.Error() == e.ErrorBalanceInsufficient {
service.Error(ctx, errors.New("该艺人竞品报告可用次数为0"))
return
}
service.Error(ctx, err)
return
}
resp, err := service.CastProvider.CreateCompetitiveReport(newCtx, req) resp, err := service.CastProvider.CreateCompetitiveReport(newCtx, req)
if err != nil { if err != nil {
service.Error(ctx, err) service.Error(ctx, err)
@ -428,12 +439,12 @@ func autoConfirmReport(ctx context.Context, reportUuid string) (err error) {
var addBalanceReq bundle.AddBundleBalanceReq var addBalanceReq bundle.AddBundleBalanceReq
addBalanceReq.UserId = int32(userID) addBalanceReq.UserId = int32(userID)
// 检查数据分析余量 // 检查竞品报告余量
if balanceInfoRes.DataAnalysisExtendConsumptionNumber >= balanceInfoRes.DataAnalysisExtendNumber { if balanceInfoRes.CompetitiveExtendConsumptionNumber >= balanceInfoRes.CompetitiveExtendNumber {
confirmRemark = "数据分析余量不足" confirmRemark = "数据分析余量不足"
isFailed = true isFailed = true
} }
addBalanceReq.DataAnalysisConsumptionNumber = 1 addBalanceReq.CompetitiveConsumptionNumber = 1
zap.L().Info("autoConfirmReport AddBundleBalanceReq", zap.Any("addBalanceReq", &addBalanceReq)) zap.L().Info("autoConfirmReport AddBundleBalanceReq", zap.Any("addBalanceReq", &addBalanceReq))
resp, err := service.BundleProvider.AddBundleBalance(context.Background(), &addBalanceReq) resp, err := service.BundleProvider.AddBundleBalance(context.Background(), &addBalanceReq)