feat: add cleanup

Author: Angular2Guy

backend/pkd/cron/cron.go

@@ -121,6 +121,8 @@ func Start() {
 
 	scheduler.Every(1).Day().At("02:05").Tag("averages").Do(gasstation.ReCalcCountyStatePrices)
 
+	scheduler.Every(1).Day().At("03:08").Tag("cleanupOldPrices").Do(gasstation.CleanupOldPrices)
+
 	msgFileStr := os.Getenv("MSG_MESSAGES")
 	if len(strings.TrimSpace(msgFileStr)) > 3 {
 		msgFiles := strings.Split(msgFileStr, ";")

backend/pkd/gasstation/gsrepo.go

@@ -453,3 +453,18 @@ func FindBySearchLocation(searchLocation gsbody.SearchLocation) []gsmodel.GasSta
 	}
 	return filteredGasStations
 }
+
+func CleanupOldPrices() {
+	log.Printf("CleanupOldPrices started.")
+	myStart := time.Now()
+
+	database.DB.Transaction(func(tx *gorm.DB) error {
+		myTimeFrame := time.Now().Add(time.Hour * -1080)
+		dateStr := fmt.Sprintf("%04d-%02d-%02d", myTimeFrame.Year(), myTimeFrame.Month(), myTimeFrame.Day())
+		tx.Where("date < date(?) ", dateStr).Delete(&gsmodel.GasPrice{})
+		return nil
+	})
+
+	myDuration := time.Since(myStart)
+	log.Printf("CleanupOldPrices finished in %v.", myDuration)
+}