ChenKaiLiuG/GoEdgeAPI
Archived
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

优化代码

Browse Source
This commit is contained in:
刘祥超
2022-11-05 14:39:40 +08:00
parent a9d71652b7
commit b2a0204f6b
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/db/models/acme/acme_task_log_dao.go
+2 -2
View File
@@ -27,7 +27,7 @@ func init() {
}) })
} }
// 生成日志 // CreateACMETaskLog 生成日志
func (this *ACMETaskLogDAO) CreateACMETaskLog(tx *dbs.Tx, taskId int64, isOk bool, errMsg string) error { func (this *ACMETaskLogDAO) CreateACMETaskLog(tx *dbs.Tx, taskId int64, isOk bool, errMsg string) error {
var op = NewACMETaskLogOperator() var op = NewACMETaskLogOperator()
op.TaskId = taskId op.TaskId = taskId
@@ -37,7 +37,7 @@ func (this *ACMETaskLogDAO) CreateACMETaskLog(tx *dbs.Tx, taskId int64, isOk boo
return err return err
} }
// 取得任务的最后一条执行日志 // FindLatestACMETasKLog 取得任务的最后一条执行日志
func (this *ACMETaskLogDAO) FindLatestACMETasKLog(tx *dbs.Tx, taskId int64) (*ACMETaskLog, error) { func (this *ACMETaskLogDAO) FindLatestACMETasKLog(tx *dbs.Tx, taskId int64) (*ACMETaskLog, error) {
one, err := this.Query(tx). one, err := this.Query(tx).
Attr("taskId", taskId). Attr("taskId", taskId).
internal/db/models/ssl_cert_dao.go
+5 -1
View File
@@ -204,7 +204,7 @@ func (this *SSLCertDAO) ComposeCertConfig(tx *dbs.Tx, certId int64, cacheMap *ut
if cacheMap == nil { if cacheMap == nil {
cacheMap = utils.NewCacheMap() cacheMap = utils.NewCacheMap()
} }
var cacheKey = this.Table + ":config:" + types.String(certId) var cacheKey = this.Table + ":ComposeCertConfig:" + types.String(certId)
var cache, _ = cacheMap.Get(cacheKey) var cache, _ = cacheMap.Get(cacheKey)
if cache != nil { if cache != nil {
return cache.(*sslconfigs.SSLCertConfig), nil return cache.(*sslconfigs.SSLCertConfig), nil
@@ -600,6 +600,7 @@ func (this *SSLCertDAO) NotifyUpdate(tx *dbs.Tx, certId int64) error {
return nil return nil
} }
// 通知服务更新
serverIds, err := SharedServerDAO.FindAllEnabledServerIdsWithSSLPolicyIds(tx, policyIds) serverIds, err := SharedServerDAO.FindAllEnabledServerIdsWithSSLPolicyIds(tx, policyIds)
if err != nil { if err != nil {
return err return err
@@ -613,5 +614,8 @@ func (this *SSLCertDAO) NotifyUpdate(tx *dbs.Tx, certId int64) error {
return err return err
} }
} }
// TODO 通知用户节点、API节点、管理系统（将来实现选择）更新
return nil return nil
} }