Compare commits

..

2 Commits

Author SHA1 Message Date
Pijus Kamandulis b8511f5ff8 Fix? 2025-07-05 08:49:01 +03:00
Pijus Kamandulis ac0285c2e6 Fix? 2025-07-05 08:44:52 +03:00
2 changed files with 13 additions and 11 deletions
+6 -2
View File
@@ -216,13 +216,12 @@ func GetTimeWindowHighShares(db *clover.DB) []models.TimeWindowHighShare {
}
func SetTimeWindowHighShare(db *clover.DB, share models.TimeWindowHighShare) error {
doc := document.NewDocumentOf(&share)
db.Delete(
c.NewQuery(TimeWindowHighShareCollectionName).
Where(c.Field("TimeWindowID").
Eq(share.TimeWindowID)))
doc := document.NewDocumentOf(&share)
db.InsertOne(TimeWindowHighShareCollectionName, doc)
return nil
@@ -261,12 +260,17 @@ func GetDailyStats(db *clover.DB, date time.Time) (*models.DailyStats, error) {
existingDoc, err := db.FindFirst(c.NewQuery(DailyStatsCollectionName).
Where(c.Field("Date").Eq(dateStr)))
if err == nil && existingDoc != nil {
expiresAt := existingDoc.ExpiresAt()
if expiresAt != nil && expiresAt.After(time.Now()) {
DeleteDailyStatsForDay(db, date)
} else {
var stats models.DailyStats
if err := existingDoc.Unmarshal(&stats); err != nil {
return nil, fmt.Errorf("failed to unmarshal daily stats: %v", err)
}
return &stats, nil
}
}
// Get shares in range
since := date.Truncate(24 * time.Hour)
+2 -4
View File
@@ -21,15 +21,13 @@ func (job *RecalculateCurrentDayStatsJob) Run() error {
defer ticker.Stop()
for {
select {
case <-ticker.C:
<-ticker.C
job.recalculateCurrentDayStats()
}
}
}
func (job *RecalculateCurrentDayStatsJob) recalculateCurrentDayStats() {
today := time.Now().Truncate(24 * time.Hour)
today := time.Now()
yesterday := today.Add(-24 * time.Hour)
database.DeleteDailyStatsForDay(job.DB, today)