mirror of https://github.com/muety/wakapi.git
Compare commits
2 Commits
8de56a4c7b
...
1a6ee55d14
Author | SHA1 | Date |
---|---|---|
Ferdinand Mütsch | 1a6ee55d14 | |
Miles Liu | 74390bfccf |
|
@ -2,6 +2,7 @@ package repositories
|
|||
|
||||
import (
|
||||
"errors"
|
||||
"github.com/muety/wakapi/config"
|
||||
"github.com/muety/wakapi/models"
|
||||
"gorm.io/gorm"
|
||||
"gorm.io/gorm/clause"
|
||||
|
@ -36,8 +37,12 @@ func (r *KeyValueRepository) GetString(key string) (*models.KeyStringValue, erro
|
|||
|
||||
func (r *KeyValueRepository) Search(like string) ([]*models.KeyStringValue, error) {
|
||||
var keyValues []*models.KeyStringValue
|
||||
condition := "key like ?"
|
||||
if r.db.Config.Name() == config.SQLDialectMysql {
|
||||
condition = "`key` like ?"
|
||||
}
|
||||
if err := r.db.Table("key_string_values").
|
||||
Where("`key` like ?", like).
|
||||
Where(condition, like).
|
||||
Find(&keyValues).
|
||||
Error; err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -268,16 +268,25 @@ func (srv *MiscService) sendSubscriptionNotificationScheduled(user *models.User,
|
|||
}
|
||||
|
||||
func (srv *MiscService) existsUsersTotalTime() bool {
|
||||
results, _ := srv.keyValueService.GetByPrefix(config.KeyLatestTotalTime)
|
||||
results, err := srv.keyValueService.GetByPrefix(config.KeyLatestTotalTime)
|
||||
if err != nil {
|
||||
config.Log().Error("failed to fetch latest time key-values, %v", err)
|
||||
}
|
||||
return len(results) > 0
|
||||
}
|
||||
|
||||
func (srv *MiscService) existsUsersFirstData() bool {
|
||||
results, _ := srv.keyValueService.GetByPrefix(config.KeyFirstHeartbeat)
|
||||
results, err := srv.keyValueService.GetByPrefix(config.KeyFirstHeartbeat)
|
||||
if err != nil {
|
||||
config.Log().Error("failed to fetch first heartbeats key-values, %v", err)
|
||||
}
|
||||
return len(results) > 0
|
||||
}
|
||||
|
||||
func (srv *MiscService) existsSubscriptionNotifications() bool {
|
||||
results, _ := srv.keyValueService.GetByPrefix(config.KeySubscriptionNotificationSent)
|
||||
results, err := srv.keyValueService.GetByPrefix(config.KeySubscriptionNotificationSent)
|
||||
if err != nil {
|
||||
config.Log().Error("failed to fetch notifications key-values, %v", err)
|
||||
}
|
||||
return len(results) > 0
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue