This commit is contained in:
daru
2022-07-31 19:00:48 +02:00
parent 1f59f13bfc
commit fa765859e4

View File

@@ -27,7 +27,8 @@ func Arbeit() {
} }
} else { } else {
cleared := 0 cleared := 0
checkDate := time.Now() checkDate := time.Now().Add(-1 * time.Hour)
newCheckDate := time.Now()
data, err := animeListCache.Get(bucketAppoint) data, err := animeListCache.Get(bucketAppoint)
if err == nil { if err == nil {
nanora, err := BytesToInt64(data) nanora, err := BytesToInt64(data)
@@ -35,7 +36,6 @@ func Arbeit() {
checkDate = time.Unix(0, nanora) checkDate = time.Unix(0, nanora)
} }
} }
newCheckDate := time.Now()
for _, a := range appoints { for _, a := range appoints {
if a.Time.Add(22 * time.Hour).Before(newCheckDate) { if a.Time.Add(22 * time.Hour).Before(newCheckDate) {
// appointment expired // appointment expired
@@ -48,7 +48,7 @@ func Arbeit() {
cleared++ cleared++
} }
} else { } else {
if checkDate.Add(40*time.Minute).Before(a.Time) && newCheckDate.Add(60*time.Minute).After(a.Time) { if checkDate.Add(time.Hour).Before(a.Time) && newCheckDate.Add(time.Hour).After(a.Time) {
// This has not happened and is happening soon // This has not happened and is happening soon
go AnnounceBomb(a.Anime, a.Time.Unix(), time.Until(a.Time.Add(-25*time.Minute))) go AnnounceBomb(a.Anime, a.Time.Unix(), time.Until(a.Time.Add(-25*time.Minute)))
} }