diff --git a/internal/db/models/message_dao.go b/internal/db/models/message_dao.go index 949880b1..0e3c6410 100644 --- a/internal/db/models/message_dao.go +++ b/internal/db/models/message_dao.go @@ -26,6 +26,8 @@ const ( type MessageType = string const ( + // 这里的命名问题(首字母大写)为历史遗留问题,暂不修改 + MessageTypeHealthCheckFailed MessageType = "HealthCheckFailed" // 节点健康检查失败 MessageTypeHealthCheckNodeUp MessageType = "HealthCheckNodeUp" // 因健康检查节点上线 MessageTypeHealthCheckNodeDown MessageType = "HealthCheckNodeDown" // 因健康检查节点下线 @@ -36,8 +38,9 @@ const ( MessageTypeSSLCertACMETaskFailed MessageType = "SSLCertACMETaskFailed" // SSL证书任务执行失败 MessageTypeSSLCertACMETaskSuccess MessageType = "SSLCertACMETaskSuccess" // SSL证书任务执行成功 MessageTypeLogCapacityOverflow MessageType = "LogCapacityOverflow" // 日志超出最大限制 - MessageTypeServerNamesAuditingSuccess MessageType = "ServerNamesAuditingSuccess" // 服务域名审核成功 - MessageTypeServerNamesAuditingFailed MessageType = "ServerNamesAuditingFailed" // 服务域名审核失败 + MessageTypeServerNamesAuditingSuccess MessageType = "ServerNamesAuditingSuccess" // 服务域名审核成功(用户) + MessageTypeServerNamesAuditingFailed MessageType = "ServerNamesAuditingFailed" // 服务域名审核失败(用户) + MessageTypeServerNamesRequireAuditing MessageType = "serverNamesRequireAuditing" // 服务域名需要审核(管理员) MessageTypeThresholdSatisfied MessageType = "ThresholdSatisfied" // 满足阈值 MessageTypeFirewallEvent MessageType = "FirewallEvent" // 防火墙事件 MessageTypeIPAddrUp MessageType = "IPAddrUp" // IP地址上线 diff --git a/internal/rpc/services/service_server.go b/internal/rpc/services/service_server.go index 016f6e2c..179053cf 100644 --- a/internal/rpc/services/service_server.go +++ b/internal/rpc/services/service_server.go @@ -466,10 +466,8 @@ func (this *ServerService) UpdateServerNames(ctx context.Context, req *pb.Update if err != nil { return nil, err } - } - // 是否需要审核 - if userId > 0 { + // 是否需要审核 globalConfig, err := models.SharedSysSettingDAO.ReadGlobalConfig(tx) if err != nil { return nil, err @@ -479,6 +477,12 @@ func (this *ServerService) UpdateServerNames(ctx context.Context, req *pb.Update if err != nil { return nil, err } + + // 发送审核通知 + err = models.SharedMessageDAO.CreateMessage(tx, 0, 0, models.MessageTypeServerNamesRequireAuditing, models.MessageLevelWarning, "有新的网站域名需要审核", "有新的网站域名需要审核", maps.Map{ + "serverId": req.ServerId, + }.AsJSON()) + return this.Success() } }