wishpal_ironfan
/
service
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

by Robin at 20240522

This commit is contained in:
Leufolium 2024-05-22 23:35:07 +08:00
parent 1d2d8b1cc5
commit 36f87c275e
2 changed files with 61 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/mix/service/apiservice_business_validation.go
View File

@ -226,6 +226,7 @@ func (s *Service) ApiUpdateAccountBusinessValidate(ctx *gin.Context, req *accoun
// 1.业务校验
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.Account.Avatar).
EnsureIsOperatingHisOwn(util.DerefInt64(req.Account.Mid)).
Validate().
Collect()
@ -421,6 +422,8 @@ func (s *Service) ApiCreateStreamerAuthApprovalBusinessValidate(ctx *gin.Context
ec = errcode.ErrCodeStreamerAuthApprovalSrvOk
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.StreamerAuthApproval.Album).
EnsureMediaIsSuccessfullyUploaded(req.StreamerAuthApproval.Shorts).
EnsureIsOperatingHisOwn(util.DerefInt64(req.StreamerAuthApproval.Mid)).
Validate().
Collect()
@ -479,6 +482,8 @@ func (s *Service) ApiUpdateStreamerBusinessValidate(ctx *gin.Context, req *strea
ec = errcode.ErrCodeStreamerSrvOk
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.Streamer.Album).
EnsureMediaIsSuccessfullyUploaded(req.Streamer.Shorts).
EnsureIsOperatingHisOwn(util.DerefInt64(req.Streamer.Mid)).
Validate().
Collect()

56
app/mix/service/opservice_business_validation.go
View File

@ -1,6 +1,7 @@
package service
import (
"service/api/consts"
"service/api/errcode"
accountproto "service/api/proto/account/proto"
accountpunishmentproto "service/api/proto/accountpunishment/proto"
@ -239,6 +240,7 @@ func (s *Service) OpUpdateAccountBusinessValidate(ctx *gin.Context, req *account
// 1.业务校验
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.Account.Avatar).
QueryAccount(_DefaultAccount.OpListByMid).
EnsureAccountExist().
EnsureIsOpRole().
@ -515,6 +517,8 @@ func (s *Service) OpUpdateStreamerBusinessValidate(ctx *gin.Context, req *stream
// 1.业务校验
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.Streamer.Album).
EnsureMediaIsSuccessfullyUploaded(req.Streamer.Shorts).
QueryAccount(_DefaultAccount.OpListByMid).
EnsureAccountExist().
EnsureIsOpRole().
@ -1143,6 +1147,7 @@ func (s *Service) OpCreateMomentBusinessValidate(ctx *gin.Context, req *momentpr
ec = errcode.ErrCodeMomentSrvOk
// 1.业务校验
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.Moment.MediaComp).
QueryAccount(_DefaultAccount.OpListByMid).
EnsureAccountExist().
EnsureIsOpRole().
@ -1159,6 +1164,7 @@ func (s *Service) OpUpdateMomentBusinessValidate(ctx *gin.Context, req *momentpr
ec = errcode.ErrCodeMomentSrvOk
// 1.业务校验
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.Moment.MediaComp).
QueryAccount(_DefaultAccount.OpListByMid).
EnsureAccountExist().
EnsureIsOpRole().
@ -1423,3 +1429,53 @@ func (s *Service) OpHeadZoneMomentBusinessValidate(ctx *gin.Context, req *zonemo
}
return
}
func (s *Service) OpCreateZoneMomentBusinessValidate(ctx *gin.Context, req *zonemomentproto.OpCreateReq) (ec errcode.ErrCode, accountpunishment *dbstruct.AccountPunishment) {
ec = errcode.ErrCodeMomentSrvOk
mediaVisibleRange := int64(0)
switch req.ZoneMoment.GetCType() {
case consts.ZoneMomentCType_Free:
case consts.ZoneMomentCType_Paid:
mediaVisibleRange = req.ZoneMoment.GetMediaVisibleRange()
}
resultList := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.ZoneMoment.MediaComp).
EnsureZoneMomentImagesEnoughForEncryption(req.ZoneMoment.GetMType(), req.ZoneMoment.MediaComp, mediaVisibleRange).
EnsureAmongZoneMomentsPaidItemsLessThanFreeItems(_DefaultZoneMoment.OpCountByMidAndCType, req.ZoneMoment.GetMid(), req.ZoneMoment.GetCType()).
EnsureZoneMomentCreateTimesNotReachedDailyUpperbound(_DefaultZoneMomentCreateTimes.OpGetAndUpdate, req.ZoneMoment.GetMid(), req.ZoneMoment.GetCType()).
Validate().
Collect()
ec, _ = resultList[0].(errcode.ErrCode)
accountpunishment, _ = resultList[3].(*dbstruct.AccountPunishment)
if ec != errcode.ErrCodeOk {
logger.Error("OpCreateZoneMomentBusinessValidate business validation failed!")
return
}
return
}
func (s *Service) OpUpdateZoneMomentBusinessValidate(ctx *gin.Context, req *zonemomentproto.OpUpdateReq) (ec errcode.ErrCode) {
ec = errcode.ErrCodeMomentSrvOk
mediaVisibleRange := int64(0)
switch req.ZoneMoment.GetCType() {
case consts.ZoneMomentCType_Paid:
mediaVisibleRange = req.ZoneMoment.GetMediaVisibleRange()
}
resultList := businessvalidator.NewAuthBusinessValidator(ctx, req).
EnsureMediaIsSuccessfullyUploaded(req.ZoneMoment.MediaComp).
EnsureZoneMomentImagesEnoughForEncryption(req.ZoneMoment.GetMType(), req.ZoneMoment.MediaComp, mediaVisibleRange).
Validate().
Collect()
ec, _ = resultList[0].(errcode.ErrCode)
if ec != errcode.ErrCodeOk {
logger.Error("OpUpdateZoneMomentBusinessValidate business validation failed!")
return
}
return
}