diff --git a/internal/db/models/acme/acme_user_dao.go b/internal/db/models/acme/acme_user_dao.go index 27a19382..67fc0274 100644 --- a/internal/db/models/acme/acme_user_dao.go +++ b/internal/db/models/acme/acme_user_dao.go @@ -131,6 +131,8 @@ func (this *ACMEUserDAO) CountACMEUsersWithAdminId(tx *dbs.Tx, adminId int64, us } if userId > 0 { query.Attr("userId", userId) + } else { + query.Attr("userId", 0) } if accountId > 0 { query.Attr("accountId", accountId) @@ -149,6 +151,8 @@ func (this *ACMEUserDAO) ListACMEUsers(tx *dbs.Tx, adminId int64, userId int64, } if userId > 0 { query.Attr("userId", userId) + } else { + query.Attr("userId", 0) } _, err = query. diff --git a/internal/rpc/services/service_acme_task.go b/internal/rpc/services/service_acme_task.go index abc54ff9..473bf529 100644 --- a/internal/rpc/services/service_acme_task.go +++ b/internal/rpc/services/service_acme_task.go @@ -232,6 +232,12 @@ func (this *ACMETaskService) CreateACMETask(ctx context.Context, req *pb.CreateA req.AuthType = acme.AuthTypeDNS } + if adminId > 0 { + if req.UserId > 0 { + userId = req.UserId + } + } + var tx = this.NullTx() taskId, err := acmemodels.SharedACMETaskDAO.CreateACMETask(tx, adminId, userId, req.AuthType, req.AcmeUserId, req.DnsProviderId, req.DnsDomain, req.Domains, req.AutoRenew, req.AuthURL) if err != nil { diff --git a/internal/rpc/services/service_acme_user.go b/internal/rpc/services/service_acme_user.go index b8ffcc64..5151037b 100644 --- a/internal/rpc/services/service_acme_user.go +++ b/internal/rpc/services/service_acme_user.go @@ -22,6 +22,12 @@ func (this *ACMEUserService) CreateACMEUser(ctx context.Context, req *pb.CreateA var tx = this.NullTx() + if adminId > 0 { + if req.UserId > 0 { + userId = req.UserId + } + } + acmeUserId, err := acmemodels.SharedACMEUserDAO.CreateACMEUser(tx, adminId, userId, req.AcmeProviderCode, req.AcmeProviderAccountId, req.Email, req.Description) if err != nil { return nil, err