diff --git a/internal/db/models/user_identity_dao.go b/internal/db/models/user_identity_dao.go index d47b4838..c28bcc5d 100644 --- a/internal/db/models/user_identity_dao.go +++ b/internal/db/models/user_identity_dao.go @@ -132,6 +132,15 @@ func (this *UserIdentityDAO) CancelUserIdentity(tx *dbs.Tx, identityId int64) er UpdateQuickly() } +// ResetUserIdentity 重置实名认证状态 +func (this *UserIdentityDAO) ResetUserIdentity(tx *dbs.Tx, identityId int64) error { + return this.Query(tx). + Pk(identityId). + Set("status", userconfigs.UserIdentityStatusSubmitted). + Set("updatedAt", time.Now().Unix()). + UpdateQuickly() +} + // RejectUserIdentity 拒绝 func (this *UserIdentityDAO) RejectUserIdentity(tx *dbs.Tx, identityId int64, reason string) error { return this.Query(tx). diff --git a/internal/rpc/services/service_user_identity.go b/internal/rpc/services/service_user_identity.go index 9676bd59..b5d9a343 100644 --- a/internal/rpc/services/service_user_identity.go +++ b/internal/rpc/services/service_user_identity.go @@ -240,6 +240,23 @@ func (this *UserIdentityService) CancelUserIdentity(ctx context.Context, req *pb return this.Success() } +// ResetUserIdentity 重置提交身份审核认证信息 +func (this *UserIdentityService) ResetUserIdentity(ctx context.Context, req *pb.ResetUserIdentityRequest) (*pb.RPCSuccess, error) { + _, err := this.ValidateAdmin(ctx) + if err != nil { + return nil, err + } + + var tx = this.NullTx() + + err = models.SharedUserIdentityDAO.ResetUserIdentity(tx, req.UserIdentityId) + if err != nil { + return nil, err + } + + return this.Success() +} + // RejectUserIdentity 拒绝用户身份认证信息 func (this *UserIdentityService) RejectUserIdentity(ctx context.Context, req *pb.RejectUserIdentityRequest) (*pb.RPCSuccess, error) { _, err := this.ValidateAdmin(ctx)