diff --git a/internal/db/models/acme/acme_task_log_dao.go b/internal/db/models/acme/acme_task_log_dao.go index 087b8ba4..5e6ab982 100644 --- a/internal/db/models/acme/acme_task_log_dao.go +++ b/internal/db/models/acme/acme_task_log_dao.go @@ -27,7 +27,7 @@ func init() { }) } -// 生成日志 +// CreateACMETaskLog 生成日志 func (this *ACMETaskLogDAO) CreateACMETaskLog(tx *dbs.Tx, taskId int64, isOk bool, errMsg string) error { var op = NewACMETaskLogOperator() op.TaskId = taskId @@ -37,7 +37,7 @@ func (this *ACMETaskLogDAO) CreateACMETaskLog(tx *dbs.Tx, taskId int64, isOk boo return err } -// 取得任务的最后一条执行日志 +// FindLatestACMETasKLog 取得任务的最后一条执行日志 func (this *ACMETaskLogDAO) FindLatestACMETasKLog(tx *dbs.Tx, taskId int64) (*ACMETaskLog, error) { one, err := this.Query(tx). Attr("taskId", taskId). diff --git a/internal/db/models/ssl_cert_dao.go b/internal/db/models/ssl_cert_dao.go index d8fdea7f..7deb42fc 100644 --- a/internal/db/models/ssl_cert_dao.go +++ b/internal/db/models/ssl_cert_dao.go @@ -204,7 +204,7 @@ func (this *SSLCertDAO) ComposeCertConfig(tx *dbs.Tx, certId int64, cacheMap *ut if cacheMap == nil { cacheMap = utils.NewCacheMap() } - var cacheKey = this.Table + ":config:" + types.String(certId) + var cacheKey = this.Table + ":ComposeCertConfig:" + types.String(certId) var cache, _ = cacheMap.Get(cacheKey) if cache != nil { return cache.(*sslconfigs.SSLCertConfig), nil @@ -600,6 +600,7 @@ func (this *SSLCertDAO) NotifyUpdate(tx *dbs.Tx, certId int64) error { return nil } + // 通知服务更新 serverIds, err := SharedServerDAO.FindAllEnabledServerIdsWithSSLPolicyIds(tx, policyIds) if err != nil { return err @@ -613,5 +614,8 @@ func (this *SSLCertDAO) NotifyUpdate(tx *dbs.Tx, certId int64) error { return err } } + + // TODO 通知用户节点、API节点、管理系统(将来实现选择)更新 + return nil }