by Robin at 20231222; Op service validate
This commit is contained in:
parent
9a00286db6
commit
1cbc732469
|
|
@ -4,8 +4,18 @@ import (
|
|||
"service/api/errcode"
|
||||
accountproto "service/api/proto/account/proto"
|
||||
accountrelationproto "service/api/proto/accountrelation/proto"
|
||||
callhistoryproto "service/api/proto/callhistory/proto"
|
||||
contact_customer_service_proto "service/api/proto/contact_customer_service/proto"
|
||||
feedbackproto "service/api/proto/feedback/proto"
|
||||
imageaudittaskproto "service/api/proto/imageaudittask/proto"
|
||||
loginproto "service/api/proto/login/proto"
|
||||
mediaproto "service/api/proto/media/proto"
|
||||
realname_authenticationproto "service/api/proto/realname_authentication/proto"
|
||||
streamerproto "service/api/proto/streamer/proto"
|
||||
streamerauthapprovalproto "service/api/proto/streamerauthapproval/proto"
|
||||
streamerlinkproto "service/api/proto/streamerlink/proto"
|
||||
textaudittaskproto "service/api/proto/textaudittask/proto"
|
||||
userwxaddcheckproto "service/api/proto/userwxaddcheck/proto"
|
||||
businessvalidator "service/app/mix/service/business_validator"
|
||||
"service/dbstruct"
|
||||
"service/library/logger"
|
||||
|
|
@ -427,7 +437,602 @@ func (s *Service) OpApproveStreamerAuthApprovalBusinessValidate(ctx *gin.Context
|
|||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerAuthApprovalList business validation failed")
|
||||
logger.Error("OpApproveStreamerAuthApproval business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpCreateStreamerBusinessValidate(ctx *gin.Context, req *streamerproto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpCreateStreamer business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpUpdateStreamerBusinessValidate(ctx *gin.Context, req *streamerproto.OpUpdateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpUpdateStreamer business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerListBusinessValidate(ctx *gin.Context, req *streamerproto.OpListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerListByMidBusinessValidate(ctx *gin.Context, req *streamerproto.OpListByMidReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerListByMid business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerExtListByMidBusinessValidate(ctx *gin.Context, req *streamerproto.OpListExtByMidReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerExtListByMid business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerExtListByMidsBusinessValidate(ctx *gin.Context, req *streamerproto.OpListExtByMidsReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerExtListByMids business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerExtListByUserIdBusinessValidate(ctx *gin.Context, req *streamerproto.OpListExtByUserIdReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerExtListByUserId business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerExtListFuzzilyByUserIdBusinessValidate(ctx *gin.Context, req *streamerproto.OpListExtFuzzilyByUserIdReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerExtListFuzzilyByUserId business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerExtListFuzzilyByNameBusinessValidate(ctx *gin.Context, req *streamerproto.OpListExtFuzzilyByNameReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerExtListFuzzilyByName business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerWxIdBusinessValidate(ctx *gin.Context, req *streamerproto.OpListStreamerWxIdReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerWxId business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerRecommListBusinessValidate(ctx *gin.Context, req *streamerproto.OpRecommListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerRecommList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpCreateFeedbackBusinessValidate(ctx *gin.Context, req *feedbackproto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeFeedbackSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpCreateFeedback business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpUpdateFeedbackBusinessValidate(ctx *gin.Context, req *feedbackproto.OpUpdateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeFeedbackSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpUpdateFeedback business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetFeedbackListBusinessValidate(ctx *gin.Context, req *feedbackproto.OpListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeFeedbackSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetFeedbackList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpCreateCallHistoryBusinessValidate(ctx *gin.Context, req *callhistoryproto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpCreateCallHistory business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpUpdateCallHistoryBusinessValidate(ctx *gin.Context, req *callhistoryproto.OpUpdateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpUpdateCallHistory business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetCallHistoryListBusinessValidate(ctx *gin.Context, req *callhistoryproto.OpListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetCallHistoryList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetCallHistoryCountBusinessValidate(ctx *gin.Context, req *callhistoryproto.OpCountReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetCallHistoryCount business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetCallEvaluationListBusinessValidate(ctx *gin.Context, req *callhistoryproto.OpCallEvaluationListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetCallEvaluationList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetStreamerLinkListByMidBusinessValidate(ctx *gin.Context, req *streamerlinkproto.OpListByMidReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerLinkSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetStreamerLinkListByMid business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpCreateUserWxAddCheckBusinessValidate(ctx *gin.Context, req *userwxaddcheckproto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeUserWxAddCheckSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpCreateUserWxAddCheck business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpUpdateUserWxAddCheckBusinessValidate(ctx *gin.Context, req *userwxaddcheckproto.OpUpdateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeUserWxAddCheckSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpUpdateUserWxAddCheck business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetUserWxAddCheckListBusinessValidate(ctx *gin.Context, req *userwxaddcheckproto.OpListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeUserWxAddCheckSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetUserWxAddCheckList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) MediaAuthBusinessValidate(ctx *gin.Context, req *mediaproto.MediaAuthReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeMediaSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("MediaAuth business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) CUploadBusinessValidate(ctx *gin.Context, req *mediaproto.CUploadReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeMediaSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("CUpload business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetRealNameAuthenticationListBusinessValidate(ctx *gin.Context, req *realname_authenticationproto.OpListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeRealNameAuthenticationSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetRealNameAuthenticationList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpApproveRealNameAuthenticationBusinessValidate(ctx *gin.Context, req *realname_authenticationproto.OpApproveReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeRealNameAuthenticationSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpApproveRealNameAuthentication business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpCreateContactCustomerServiceBusinessValidate(ctx *gin.Context, req *contact_customer_service_proto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeContactCustomerServiceSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpCreateContactCustomerService business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpUpdateContactCustomerServiceByIdsBusinessValidate(ctx *gin.Context, req *contact_customer_service_proto.OpUpdateByIdsReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeContactCustomerServiceSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpUpdateContactCustomerServiceByIds business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetContactCustomerServiceListByMidBusinessValidate(ctx *gin.Context, req *contact_customer_service_proto.OpListByMidReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeContactCustomerServiceSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetContactCustomerServiceListByMid business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetContactCustomerServiceListUnreadGroupByMidBusinessValidate(ctx *gin.Context, req *contact_customer_service_proto.OpListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeContactCustomerServiceSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetContactCustomerServiceListUnreadGroupByMid business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetImageAuditTaskVOListBusinessValidate(ctx *gin.Context, req *imageaudittaskproto.OpListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeImageAuditTaskSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetImageAuditTaskVOList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpPassImageAuditTaskBatchBusinessValidate(ctx *gin.Context, req *imageaudittaskproto.OpPassBatchReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeImageAuditTaskSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpPassImageAuditTaskBatch business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpGetTextAuditTaskVOListBusinessValidate(ctx *gin.Context, req *textaudittaskproto.OpListReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeTextAuditTaskSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpGetTextAuditTaskVOList business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (s *Service) OpPassTextAuditTaskBatchBusinessValidate(ctx *gin.Context, req *textaudittaskproto.OpPassBatchReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeTextAuditTaskSrvOk
|
||||
|
||||
// 1.业务校验
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpPassTextAuditTaskBatch business validation failed")
|
||||
return
|
||||
}
|
||||
return
|
||||
|
|
|
|||
|
|
@ -36,7 +36,6 @@ import (
|
|||
"service/apollostruct"
|
||||
"service/app/mix/conf"
|
||||
"service/app/mix/dao"
|
||||
businessvalidator "service/app/mix/service/business_validator"
|
||||
"service/app/mix/service/logic"
|
||||
"service/bizcommon/util"
|
||||
"service/dbstruct"
|
||||
|
|
@ -1411,6 +1410,11 @@ func (s *Service) OpApproveStreamerAuthApproval(ctx *gin.Context, req *streamera
|
|||
// Streamer
|
||||
func (s *Service) OpCreateStreamer(ctx *gin.Context, req *streamerproto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpCreateStreamerBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultStreamer.OpCreate(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1422,6 +1426,11 @@ func (s *Service) OpCreateStreamer(ctx *gin.Context, req *streamerproto.OpCreate
|
|||
|
||||
func (s *Service) OpUpdateStreamer(ctx *gin.Context, req *streamerproto.OpUpdateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpUpdateStreamerBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultStreamer.OpUpdate(ctx, req)
|
||||
if err == qmgo.ErrNoSuchDocuments {
|
||||
ec = errcode.ErrCodeStreamerNotExist
|
||||
|
|
@ -1450,6 +1459,10 @@ func (s *Service) OpDeleteStreamer(ctx *gin.Context, id int64) (ec errcode.ErrCo
|
|||
func (s *Service) OpGetStreamerList(ctx *gin.Context, req *streamerproto.OpListReq) (list []*dbstruct.Streamer, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpGetStreamerListBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultStreamer.OpList(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpList fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1463,9 +1476,8 @@ func (s *Service) OpGetStreamerListByMid(ctx *gin.Context, req *streamerproto.Op
|
|||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
//业务校验
|
||||
if req.BaseRequest.Mid != util.DerefInt64(req.Mid) {
|
||||
logger.Error("OpGetAccountListByMid: Business exception: header Uid and body Uid do not refer to the same person")
|
||||
return nil, errcode.ErrCodeSelfOnlyOperation
|
||||
if ec = s.OpGetStreamerListByMidBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
streamer, err := _DefaultStreamer.OpListByMid(ctx, req)
|
||||
|
|
@ -1482,6 +1494,10 @@ func (s *Service) OpGetStreamerExtListByMid(ctx *gin.Context, req *streamerproto
|
|||
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpGetStreamerExtListByMidBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
//1.从用户表中查询主播信息
|
||||
account, err := _DefaultAccount.OpListByMid(ctx, &accountproto.OpListByMidReq{
|
||||
Mid: req.Mid,
|
||||
|
|
@ -1506,6 +1522,10 @@ func (s *Service) OpGetStreamerExtListByMids(ctx *gin.Context, req *streamerprot
|
|||
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpGetStreamerExtListByMidsBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
//1.从用户表中查询所有主播信息的用户侧数据，按mid正序排序
|
||||
accountList, err := _DefaultAccount.OpListByMids(ctx, &accountproto.OpListByMidsReq{
|
||||
Mids: req.Mids,
|
||||
|
|
@ -1541,6 +1561,10 @@ func (s *Service) OpGetStreamerExtListByUserId(ctx *gin.Context, req *streamerpr
|
|||
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpGetStreamerExtListByUserIdBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
//1.从用户表中查询主播信息
|
||||
account, err := _DefaultAccount.OpListByUserId(ctx, &accountproto.OpListByUserIdReq{
|
||||
UserId: req.UserId,
|
||||
|
|
@ -1565,6 +1589,10 @@ func (s *Service) OpGetStreamerExtListFuzzilyByUserId(ctx *gin.Context, req *str
|
|||
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpGetStreamerExtListFuzzilyByUserIdBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
//1.从用户表中模糊匹配所有主播信息的用户侧数据，按mid正序排序
|
||||
accountList, err := _DefaultAccount.OpListFuzzilyByUserId(ctx, &accountproto.OpListFuzzilyByUserIdReq{
|
||||
UserId: req.UserId,
|
||||
|
|
@ -1601,6 +1629,10 @@ func (s *Service) OpGetStreamerExtListFuzzilyByName(ctx *gin.Context, req *strea
|
|||
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpGetStreamerExtListFuzzilyByNameBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
//1.从用户表中模糊匹配所有主播信息的用户侧数据，按mid正序排序
|
||||
accountList, err := _DefaultAccount.OpListFuzzilyByName(ctx, &accountproto.OpListFuzzilyByNameReq{
|
||||
Name: req.Name,
|
||||
|
|
@ -1675,6 +1707,10 @@ func (s *Service) OpGetStreamerRecommList(ctx *gin.Context, req *streamerproto.O
|
|||
|
||||
ec = errcode.ErrCodeStreamerSrvOk
|
||||
|
||||
if ec = s.OpGetStreamerRecommListBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
//1.从redis中获取数据
|
||||
err := redis.GetRedisClient().GetObject(consts.RedisStreamerPrefix+"recomm_list", &recommlist)
|
||||
if err != nil {
|
||||
|
|
@ -1723,6 +1759,11 @@ func (s *Service) OpGetStreamerRecommList(ctx *gin.Context, req *streamerproto.O
|
|||
// Feedback
|
||||
func (s *Service) OpCreateFeedback(ctx *gin.Context, req *feedbackproto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeFeedbackSrvOk
|
||||
|
||||
if ec = s.OpCreateFeedbackBusinessValidate(ctx, req); ec != errcode.ErrCodeFeedbackSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultFeedback.OpCreate(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1734,6 +1775,11 @@ func (s *Service) OpCreateFeedback(ctx *gin.Context, req *feedbackproto.OpCreate
|
|||
|
||||
func (s *Service) OpUpdateFeedback(ctx *gin.Context, req *feedbackproto.OpUpdateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeFeedbackSrvOk
|
||||
|
||||
if ec = s.OpUpdateFeedbackBusinessValidate(ctx, req); ec != errcode.ErrCodeFeedbackSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultFeedback.OpUpdate(ctx, req)
|
||||
if err == qmgo.ErrNoSuchDocuments {
|
||||
ec = errcode.ErrCodeFeedbackNotExist
|
||||
|
|
@ -1761,6 +1807,11 @@ func (s *Service) OpDeleteFeedback(ctx *gin.Context, id int64) (ec errcode.ErrCo
|
|||
|
||||
func (s *Service) OpGetFeedbackList(ctx *gin.Context, req *feedbackproto.OpListReq) (list []*dbstruct.Feedback, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeFeedbackSrvOk
|
||||
|
||||
if ec = s.OpGetFeedbackListBusinessValidate(ctx, req); ec != errcode.ErrCodeFeedbackSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultFeedback.OpList(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpGetFeedbackList fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1773,6 +1824,11 @@ func (s *Service) OpGetFeedbackList(ctx *gin.Context, req *feedbackproto.OpListR
|
|||
// CallHistory
|
||||
func (s *Service) OpCreateCallHistory(ctx *gin.Context, req *callhistoryproto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
if ec = s.OpCreateCallHistoryBusinessValidate(ctx, req); ec != errcode.ErrCodeCallHistorySrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultCallHistory.OpCreate(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1784,6 +1840,11 @@ func (s *Service) OpCreateCallHistory(ctx *gin.Context, req *callhistoryproto.Op
|
|||
|
||||
func (s *Service) OpUpdateCallHistory(ctx *gin.Context, req *callhistoryproto.OpUpdateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
if ec = s.OpUpdateCallHistoryBusinessValidate(ctx, req); ec != errcode.ErrCodeCallHistorySrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultCallHistory.OpUpdate(ctx, req)
|
||||
if err == qmgo.ErrNoSuchDocuments {
|
||||
ec = errcode.ErrCodeCallHistoryNotExist
|
||||
|
|
@ -1811,6 +1872,11 @@ func (s *Service) OpDeleteCallHistory(ctx *gin.Context, id int64) (ec errcode.Er
|
|||
|
||||
func (s *Service) OpGetCallHistoryList(ctx *gin.Context, req *callhistoryproto.OpListReq) (list []*dbstruct.CallHistory, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
if ec = s.OpGetCallHistoryListBusinessValidate(ctx, req); ec != errcode.ErrCodeCallHistorySrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultCallHistory.OpList(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpGetCallHistoryList fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1822,6 +1888,11 @@ func (s *Service) OpGetCallHistoryList(ctx *gin.Context, req *callhistoryproto.O
|
|||
|
||||
func (s *Service) OpGetCallHistoryCount(ctx *gin.Context, req *callhistoryproto.OpCountReq) (countMap map[int64]int64, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
if ec = s.OpGetCallHistoryCountBusinessValidate(ctx, req); ec != errcode.ErrCodeCallHistorySrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
countMap, err := _DefaultCallHistory.OpCount(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpCount fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1834,6 +1905,10 @@ func (s *Service) OpGetCallHistoryCount(ctx *gin.Context, req *callhistoryproto.
|
|||
func (s *Service) OpGetCallEvaluationList(ctx *gin.Context, req *callhistoryproto.OpCallEvaluationListReq) (list []*callhistoryproto.OpListCallEvaluationVO, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeCallHistorySrvOk
|
||||
|
||||
if ec = s.OpGetCallEvaluationListBusinessValidate(ctx, req); ec != errcode.ErrCodeCallHistorySrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
//1.查出该主播的通话记录侧数据
|
||||
callHistoryList, err := _DefaultCallHistory.OpList(ctx, &callhistoryproto.OpListReq{
|
||||
Mid: req.Mid,
|
||||
|
|
@ -1895,6 +1970,11 @@ func (s *Service) OpGetCallEvaluationList(ctx *gin.Context, req *callhistoryprot
|
|||
// StreamerLink
|
||||
func (s *Service) OpGetStreamerLinkListByMid(ctx *gin.Context, req *streamerlinkproto.OpListByMidReq) (list []*dbstruct.StreamerLink, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeStreamerLinkSrvOk
|
||||
|
||||
if ec = s.OpGetStreamerLinkListByMidBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerLinkSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultStreamerLink.OpListByMid(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpListByMid fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1907,6 +1987,11 @@ func (s *Service) OpGetStreamerLinkListByMid(ctx *gin.Context, req *streamerlink
|
|||
// UserWxAddCheck
|
||||
func (s *Service) OpCreateUserWxAddCheck(ctx *gin.Context, req *userwxaddcheckproto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeUserWxAddCheckSrvOk
|
||||
|
||||
if ec = s.OpCreateUserWxAddCheckBusinessValidate(ctx, req); ec != errcode.ErrCodeUserWxAddCheckSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultUserWxAddCheck.OpCreate(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1918,6 +2003,11 @@ func (s *Service) OpCreateUserWxAddCheck(ctx *gin.Context, req *userwxaddcheckpr
|
|||
|
||||
func (s *Service) OpUpdateUserWxAddCheck(ctx *gin.Context, req *userwxaddcheckproto.OpUpdateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeUserWxAddCheckSrvOk
|
||||
|
||||
if ec = s.OpUpdateUserWxAddCheckBusinessValidate(ctx, req); ec != errcode.ErrCodeUserWxAddCheckSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultUserWxAddCheck.OpUpdate(ctx, req)
|
||||
if err == qmgo.ErrNoSuchDocuments {
|
||||
ec = errcode.ErrCodeUserWxAddCheckNotExist
|
||||
|
|
@ -1945,6 +2035,11 @@ func (s *Service) OpDeleteUserWxAddCheck(ctx *gin.Context, id int64) (ec errcode
|
|||
|
||||
func (s *Service) OpGetUserWxAddCheckList(ctx *gin.Context, req *userwxaddcheckproto.OpListReq) (list []*dbstruct.UserWxAddCheck, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeUserWxAddCheckSrvOk
|
||||
|
||||
if ec = s.OpGetUserWxAddCheckListBusinessValidate(ctx, req); ec != errcode.ErrCodeUserWxAddCheckSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultUserWxAddCheck.OpList(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpGetUserWxAddCheckList fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1956,6 +2051,11 @@ func (s *Service) OpGetUserWxAddCheckList(ctx *gin.Context, req *userwxaddcheckp
|
|||
|
||||
func (s *Service) MediaAuth(ctx *gin.Context, req *mediaproto.MediaAuthReq) (policyToken *mediaproto.PolicyToken, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeMediaSrvOk
|
||||
|
||||
if ec = s.MediaAuthBusinessValidate(ctx, req); ec != errcode.ErrCodeMediaSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
policyToken, err := _DefaultMedia.GetPolicyToken(req.Mtype)
|
||||
if err != nil {
|
||||
logger.Error("GetPolicyToken fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -1967,6 +2067,11 @@ func (s *Service) MediaAuth(ctx *gin.Context, req *mediaproto.MediaAuthReq) (pol
|
|||
|
||||
func (s *Service) CUpload(ctx *gin.Context, req *mediaproto.CUploadReq) (ret interface{}, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeMediaSrvOk
|
||||
|
||||
if ec = s.CUploadBusinessValidate(ctx, req); ec != errcode.ErrCodeMediaSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
ret, err := _DefaultMedia.Upload(ctx, req.Mtype, req.Item)
|
||||
if err != nil {
|
||||
logger.Error("Upload fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -2023,14 +2128,7 @@ func (s *Service) OpGetRealNameAuthenticationList(ctx *gin.Context, req *realnam
|
|||
ec = errcode.ErrCodeRealNameAuthenticationSrvOk
|
||||
|
||||
// 1.业务校验，鉴权
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpCreateRealNameAuthentication business validation failed")
|
||||
if ec = s.OpGetRealNameAuthenticationListBusinessValidate(ctx, req); ec != errcode.ErrCodeRealNameAuthenticationSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
|
|
@ -2047,14 +2145,7 @@ func (s *Service) OpApproveRealNameAuthentication(ctx *gin.Context, req *realnam
|
|||
ec = errcode.ErrCodeRealNameAuthenticationSrvOk
|
||||
|
||||
// 1.业务校验，鉴权
|
||||
result := businessvalidator.NewAuthBusinessValidator(ctx, req).
|
||||
QueryAccount(_DefaultAccount.OpListByMid).
|
||||
EnsureAccountExist().
|
||||
EnsureIsOpRole().
|
||||
Validate().
|
||||
Collect()
|
||||
if ec = result[0].(errcode.ErrCode); ec != errcode.ErrCodeOk {
|
||||
logger.Error("OpCreateRealNameAuthentication business validation failed")
|
||||
if ec = s.OpApproveRealNameAuthenticationBusinessValidate(ctx, req); ec != errcode.ErrCodeRealNameAuthenticationSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
|
|
@ -2095,6 +2186,11 @@ func (s *Service) OpApproveRealNameAuthentication(ctx *gin.Context, req *realnam
|
|||
// ContactCustomerService
|
||||
func (s *Service) OpCreateContactCustomerService(ctx *gin.Context, req *contact_customer_service_proto.OpCreateReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeContactCustomerServiceSrvOk
|
||||
|
||||
if ec = s.OpCreateContactCustomerServiceBusinessValidate(ctx, req); ec != errcode.ErrCodeContactCustomerServiceSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultContactCustomerService.OpCreate(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -2106,6 +2202,11 @@ func (s *Service) OpCreateContactCustomerService(ctx *gin.Context, req *contact_
|
|||
|
||||
func (s *Service) OpUpdateContactCustomerServiceByIds(ctx *gin.Context, req *contact_customer_service_proto.OpUpdateByIdsReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeContactCustomerServiceSrvOk
|
||||
|
||||
if ec = s.OpUpdateContactCustomerServiceByIdsBusinessValidate(ctx, req); ec != errcode.ErrCodeContactCustomerServiceSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
err := _DefaultContactCustomerService.OpUpdateByIds(ctx, req)
|
||||
if err == qmgo.ErrNoSuchDocuments {
|
||||
ec = errcode.ErrCodeContactCustomerServiceNotExist
|
||||
|
|
@ -2133,6 +2234,11 @@ func (s *Service) OpDeleteContactCustomerService(ctx *gin.Context, id int64) (ec
|
|||
|
||||
func (s *Service) OpGetContactCustomerServiceListByMid(ctx *gin.Context, req *contact_customer_service_proto.OpListByMidReq) (list []*dbstruct.ContactCustomerService, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeContactCustomerServiceSrvOk
|
||||
|
||||
if ec = s.OpGetContactCustomerServiceListByMidBusinessValidate(ctx, req); ec != errcode.ErrCodeContactCustomerServiceSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultContactCustomerService.OpListByMid(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpGetContactCustomerServiceListByMid fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -2144,6 +2250,11 @@ func (s *Service) OpGetContactCustomerServiceListByMid(ctx *gin.Context, req *co
|
|||
|
||||
func (s *Service) OpGetContactCustomerServiceListUnreadGroupByMid(ctx *gin.Context, req *contact_customer_service_proto.OpListReq) (volist []*contact_customer_service_proto.ContactCustomerServiceOpVO, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeContactCustomerServiceSrvOk
|
||||
|
||||
if ec = s.OpGetContactCustomerServiceListUnreadGroupByMidBusinessValidate(ctx, req); ec != errcode.ErrCodeContactCustomerServiceSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultContactCustomerService.OpListUnread(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpGetContactCustomerServiceListUnread fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -2172,6 +2283,11 @@ func (s *Service) OpGetContactCustomerServiceListUnreadGroupByMid(ctx *gin.Conte
|
|||
|
||||
func (s *Service) OpGetImageAuditTaskVOList(ctx *gin.Context, req *imageaudittaskproto.OpListReq) (volist []*imageaudittaskproto.ImageAuditTaskVO, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeImageAuditTaskSrvOk
|
||||
|
||||
if ec = s.OpGetImageAuditTaskVOListBusinessValidate(ctx, req); ec != errcode.ErrCodeImageAuditTaskSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultImageAuditTask.OpList(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpGetImageAuditTaskListByMid fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -2210,6 +2326,11 @@ func (s *Service) OpGetImageAuditTaskVOList(ctx *gin.Context, req *imageaudittas
|
|||
|
||||
func (s *Service) OpPassImageAuditTaskBatch(ctx *gin.Context, req *imageaudittaskproto.OpPassBatchReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeImageAuditTaskSrvOk
|
||||
|
||||
if ec = s.OpPassImageAuditTaskBatchBusinessValidate(ctx, req); ec != errcode.ErrCodeImageAuditTaskSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
ids := make([]string, 0)
|
||||
|
||||
for i, task := range req.ImageAuditTasks {
|
||||
|
|
@ -2236,6 +2357,11 @@ func (s *Service) OpPassImageAuditTaskBatch(ctx *gin.Context, req *imageaudittas
|
|||
|
||||
func (s *Service) OpGetTextAuditTaskVOList(ctx *gin.Context, req *textaudittaskproto.OpListReq) (volist []*textaudittaskproto.TextAuditTaskVO, ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeTextAuditTaskSrvOk
|
||||
|
||||
if ec = s.OpGetTextAuditTaskVOListBusinessValidate(ctx, req); ec != errcode.ErrCodeTextAuditTaskSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
list, err := _DefaultTextAuditTask.OpList(ctx, req)
|
||||
if err != nil {
|
||||
logger.Error("OpGetTextAuditTaskListByMid fail, req: %v, err: %v", util.ToJson(req), err)
|
||||
|
|
@ -2264,6 +2390,11 @@ func (s *Service) OpGetTextAuditTaskVOList(ctx *gin.Context, req *textaudittaskp
|
|||
|
||||
func (s *Service) OpPassTextAuditTaskBatch(ctx *gin.Context, req *textaudittaskproto.OpPassBatchReq) (ec errcode.ErrCode) {
|
||||
ec = errcode.ErrCodeTextAuditTaskSrvOk
|
||||
|
||||
if ec = s.OpPassTextAuditTaskBatchBusinessValidate(ctx, req); ec != errcode.ErrCodeTextAuditTaskSrvOk {
|
||||
return
|
||||
}
|
||||
|
||||
ids := make([]string, 0)
|
||||
|
||||
for i, task := range req.TextAuditTasks {
|
||||
|
|
|
|||
Loading…
Reference in New Issue