ruidy/rentease
1
0
Fork 0
mirror of https://github.com/rjNemo/rentease.git synced 2026-06-12 13:46:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

clean the cron job

Browse source
This commit is contained in:
Ruidy 2024-12-07 12:49:05 +01:00
parent c9380481cf
commit d07dc199b7
No known key found for this signature in database
GPG key ID: E00F51288CB857CC
2 changed files with 26 additions and 40 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cmd/cron/main.go
View file

@ -16,7 +16,7 @@ func main() {
Name: "Monthly Booking Report", Name: "Monthly Booking Report",
Schedule: "minute", Schedule: "minute",
//Schedule: "monthly", //Schedule: "monthly",
Action: cron.JobMonthlyBookingReport, // Action: cron.JobMonthlyBookingReport,
}) })
go scheduler.Start() go scheduler.Start()

64
internal/cron/job_report.go
View file

@ -1,46 +1,32 @@
package cron package cron
import ( // func JobMonthlyBookingReport() error {
"fmt" // _ = godotenv.Load()
"log" // db, err := gorm.Open(postgres.Open(os.Getenv("DATABASE_URL")), &gorm.Config{})
"os" // if err != nil {
"time" // return fmt.Errorf("error connecting to the database %w", err)
// }
"github.com/joho/godotenv" // now := time.Now()
"gorm.io/driver/postgres" // log.Println("Start Monthly Booking Report job at:", now)
"gorm.io/gorm"
"github.com/rjNemo/rentease/internal/driver/pdf" // ps, err := pdf.NewPdfClient(
"github.com/rjNemo/rentease/internal/service/booking" // os.Getenv("HTMLDOCS_PROJECT_ID"),
) // os.Getenv("HTMLDOCS_REPORT_PROJECT_ID"),
// os.Getenv("HTMLDOCS_URL"),
// os.Getenv("HTMLDOCS_KEY"),
// )
// if err != nil {
// return fmt.Errorf("error starting pdf service %w", err)
// }
func JobMonthlyBookingReport() error { // service, _ := booking.NewService(db, nil, ps)
_ = godotenv.Load() // period := "monthly"
db, err := gorm.Open(postgres.Open(os.Getenv("DATABASE_URL")), &gorm.Config{}) // month := int(now.Month())
if err != nil { // year := now.Year()
return fmt.Errorf("error connecting to the database %w", err)
}
now := time.Now() // err = service.BuildReport(service.Report(period, month, year), period, month, year)
log.Println("Start Monthly Booking Report job at:", now)
ps, err := pdf.NewPdfClient( // log.Printf("Executed Monthly Booking Report job at %v with errors: %s:", time.Now().Format(time.DateTime), err)
os.Getenv("HTMLDOCS_PROJECT_ID"), // return err
os.Getenv("HTMLDOCS_REPORT_PROJECT_ID"), // }
os.Getenv("HTMLDOCS_URL"),
os.Getenv("HTMLDOCS_KEY"),
)
if err != nil {
return fmt.Errorf("error starting pdf service %w", err)
}
service, _ := booking.NewService(db, nil, ps)
period := "monthly"
month := int(now.Month())
year := now.Year()
err = service.BuildReport(service.Report(period, month, year), period, month, year)
log.Printf("Executed Monthly Booking Report job at %v with errors: %s:", time.Now().Format(time.DateTime), err)
return err
}