ZiHangQin/electricity_bill_calc_service
1
0
Fork 0
forked from free-lancers/electricity_bill_calc_service
Code Pull Requests Activity

enhance(repo):改进缓存方法。

Browse Source
This commit is contained in:
徐涛 2022-08-12 11:39:19 +08:00
parent b8c44c9b1e
commit 5234ed88de
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
repository/abstract.go
View File

@ -1,5 +1,10 @@
package repository package repository
import (
"electricity_bill_calc/cache"
"time"
)
func _postProcessSingle[T interface{}](instance *T, has bool, err error) (*T, error) { func _postProcessSingle[T interface{}](instance *T, has bool, err error) (*T, error) {
if err != nil { if err != nil {
return nil, err return nil, err
@ -21,3 +26,21 @@ func _postProcessList[T interface{}](instance []*T, has bool, err error) ([]*T,
return nil, nil return nil, nil
} }
} }
func cacheData[T interface{}](instance T, category string, key ...string) error {
var keys = make([]string, 0)
keys = append(keys, category)
keys = append(keys, key...)
cacheKey := cache.CacheKey("cache", keys...)
if exists, _ := cache.Exists(cacheKey); exists {
cache.Delete(cacheKey)
}
return cache.Cache(cacheKey, &instance, 5*time.Minute)
}
func retreiveData[T interface{}](category string, key ...string) (*T, error) {
var keys = make([]string, 0)
keys = append(keys, category)
keys = append(keys, key...)
return cache.Retreive[T](cache.CacheKey("cache", keys...))
}