259 lines
8.3 KiB
Go
259 lines
8.3 KiB
Go
// officeHour
|
|
package repositories
|
|
|
|
import (
|
|
"database/sql"
|
|
"errors"
|
|
"fmt"
|
|
"log"
|
|
"officeHours/config"
|
|
"officeHours/models"
|
|
)
|
|
|
|
type OfficeHourRepo struct {
|
|
db *sql.DB
|
|
roomRepo *RoomRepo
|
|
tutorRepo *TutorRepo
|
|
courseRepo *CourseRepo
|
|
config config.Config
|
|
}
|
|
|
|
func NewOfficeHourRepo(db *sql.DB, roomRepo *RoomRepo, tutorRepo *TutorRepo, courseRepo *CourseRepo, conf config.Config) *OfficeHourRepo {
|
|
return &OfficeHourRepo{
|
|
db: db,
|
|
roomRepo: roomRepo,
|
|
tutorRepo: tutorRepo,
|
|
courseRepo: courseRepo,
|
|
config: conf,
|
|
}
|
|
}
|
|
|
|
func (r *OfficeHourRepo) GetAll(activeOnly bool) ([]models.OfficeHour, error) {
|
|
var rows *sql.Rows
|
|
var err error
|
|
if activeOnly {
|
|
rows, err = r.db.Query("SELECT * FROM officeHour WHERE active")
|
|
} else {
|
|
rows, err = r.db.Query("SELECT * FROM officeHour")
|
|
}
|
|
if err != nil {
|
|
err = fmt.Errorf("Error getting all officeHours from database: %w", err)
|
|
if !errors.Is(err, sql.ErrNoRows) {
|
|
log.Println(err.Error())
|
|
}
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
return r.getFromRows(rows)
|
|
}
|
|
|
|
func (r *OfficeHourRepo) FindByCourse(course models.Course, activeOnly bool) ([]models.OfficeHour, error) {
|
|
var rows *sql.Rows
|
|
var err error
|
|
if activeOnly {
|
|
rows, err = r.db.Query("SELECT * FROM officeHour WHERE course=? and active", course.Id)
|
|
} else {
|
|
rows, err = r.db.Query("SELECT * FROM officeHour WHERE course=?", course.Id)
|
|
}
|
|
defer rows.Close()
|
|
if err != nil {
|
|
err = fmt.Errorf("Error getting officeHours by course from database: %w", err)
|
|
if !errors.Is(err, sql.ErrNoRows) {
|
|
log.Println(err.Error())
|
|
}
|
|
return nil, err
|
|
}
|
|
return r.getFromRows(rows)
|
|
}
|
|
|
|
func (r *OfficeHourRepo) FindByRoom(room models.Room, activeOnly bool) ([]models.OfficeHour, error) {
|
|
var rows *sql.Rows
|
|
var err error
|
|
if activeOnly {
|
|
rows, err = r.db.Query("SELECT * FROM officeHour WHERE room=? AND active", room.Id)
|
|
} else {
|
|
rows, err = r.db.Query("SELECT * FROM officeHour WHERE room=?", room.Id)
|
|
}
|
|
if err != nil {
|
|
err = fmt.Errorf("Error getting officeHours by room from database: %w", err)
|
|
if !errors.Is(err, sql.ErrNoRows) {
|
|
log.Println(err.Error())
|
|
}
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
return r.getFromRows(rows)
|
|
}
|
|
|
|
func (r *OfficeHourRepo) FindById(id int) (models.OfficeHour, error) {
|
|
return r.getFromRow(r.db.QueryRow("SELECT * FROM officeHour WHERE id=?", id))
|
|
}
|
|
|
|
func (r *OfficeHourRepo) Add(officeHour models.OfficeHour) (int, error) {
|
|
// Find correct tutor or add if not existent
|
|
_, err := r.tutorRepo.Add(officeHour.Tutor)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
officeHour.Tutor, err = r.tutorRepo.FindByNameAndEmail(officeHour.Tutor.Name, officeHour.Tutor.Email)
|
|
if err != nil {
|
|
err = fmt.Errorf("Newly added tutor not found: %w", err)
|
|
log.Println(err.Error())
|
|
return 0, err
|
|
}
|
|
|
|
//Don't add identical officeHours
|
|
officeHours, err := r.FindByCourse(officeHour.Course, false)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
for _, oldOfficeHour := range officeHours {
|
|
if officeHour.Tutor == oldOfficeHour.Tutor &&
|
|
officeHour.Date == oldOfficeHour.Date &&
|
|
officeHour.Room == oldOfficeHour.Room &&
|
|
// officeHour.Course == oldOfficeHour.Course && already filtered above
|
|
officeHour.Info == oldOfficeHour.Info &&
|
|
officeHour.Active == oldOfficeHour.Active &&
|
|
officeHour.Duration == oldOfficeHour.Duration {
|
|
return oldOfficeHour.Id, nil
|
|
}
|
|
}
|
|
|
|
sqlResult, err := r.db.Exec("INSERT INTO `officeHour` (tutor, day, hour, minute, room, roomname, course, week, info, active, duration) VALUES (?,?,?,?,?,?,?,?,?,?,?)",
|
|
officeHour.Tutor.Id,
|
|
officeHour.Date.Day,
|
|
officeHour.Date.Hour,
|
|
officeHour.Date.Minute,
|
|
officeHour.Room.Id,
|
|
officeHour.RoomName,
|
|
officeHour.Course.Id,
|
|
officeHour.Date.Week,
|
|
officeHour.Info,
|
|
officeHour.Active,
|
|
officeHour.Duration)
|
|
if err != nil {
|
|
return 0, fmt.Errorf("SQL-error inserting new office hour: %w", err)
|
|
}
|
|
id, lastInsertIdErr := sqlResult.LastInsertId()
|
|
if lastInsertIdErr != nil {
|
|
log.Printf("Error getting Id for new tutor: %s", lastInsertIdErr.Error())
|
|
}
|
|
return int(id), err
|
|
}
|
|
|
|
func (r *OfficeHourRepo) Delete(officeHour models.OfficeHour) error {
|
|
_, err := r.db.Exec("DELETE FROM officeHour WHERE id=?", officeHour.Id)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error deleting officeHour from database: %w", err)
|
|
log.Println(err.Error())
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (r *OfficeHourRepo) getFromRow(row *sql.Row) (models.OfficeHour, error) {
|
|
var officeHour models.OfficeHour
|
|
var week, day, hour, minute, tutorId, courseId, roomId int
|
|
err := row.Scan(&officeHour.Id, &tutorId, &day, &hour, &minute, &roomId, &officeHour.RoomName, &courseId, &week, &officeHour.Info, &officeHour.Active, &officeHour.Duration)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error getting single officeHour row from database: %w", err)
|
|
log.Println(err.Error())
|
|
return models.OfficeHour{}, err
|
|
}
|
|
officeHour.Date = models.Date{Week: week, Day: day, Hour: hour, Minute: minute}
|
|
officeHour.Room, err = r.roomRepo.FindById(roomId)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error finding room by id %d for office hour: %w", roomId, err)
|
|
log.Println(err.Error())
|
|
return officeHour, err
|
|
}
|
|
officeHour.Tutor, err = r.tutorRepo.FindById(tutorId)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error finding tutor by id %d for office hour: %w", tutorId, err)
|
|
log.Println(err.Error())
|
|
return officeHour, err
|
|
}
|
|
officeHour.Course, err = r.courseRepo.FindById(courseId)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error finding course by id %d for office hour: %w", courseId, err)
|
|
log.Println(err.Error())
|
|
return officeHour, err
|
|
}
|
|
return officeHour, nil
|
|
}
|
|
|
|
func (r *OfficeHourRepo) getFromRows(rows *sql.Rows) ([]models.OfficeHour, error) {
|
|
var officeHours []models.OfficeHour
|
|
for rows.Next() {
|
|
var officeHour models.OfficeHour
|
|
var week, day, hour, minute, tutorId, roomId, courseId int
|
|
var err error
|
|
if err := rows.Scan(&officeHour.Id, &tutorId, &day, &hour, &minute, &roomId, &officeHour.RoomName, &courseId, &week, &officeHour.Info, &officeHour.Active, &officeHour.Duration); err != nil {
|
|
return officeHours, fmt.Errorf("Error getting multiple officeHour rows from database: %w", err)
|
|
}
|
|
officeHour.Date = models.Date{Week: week, Day: day, Hour: hour, Minute: minute}
|
|
officeHour.Room, err = r.roomRepo.FindById(roomId)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error finding room by id %d for office hour: %w", roomId, err)
|
|
log.Println(err.Error())
|
|
return officeHours, err
|
|
}
|
|
officeHour.Tutor, err = r.tutorRepo.FindById(tutorId)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error finding tutor by id %d for office hour: %w", tutorId, err)
|
|
log.Println(err.Error())
|
|
return officeHours, err
|
|
}
|
|
officeHour.Course, err = r.courseRepo.FindById(courseId)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error finding course by id %d for office hour: %w", courseId, err)
|
|
log.Println(err.Error())
|
|
return officeHours, err
|
|
}
|
|
officeHours = append(officeHours, officeHour)
|
|
}
|
|
return officeHours, nil
|
|
}
|
|
|
|
func (r *OfficeHourRepo) NumberByTimeSpanAndRoom(date models.Date, duration int, room models.Room, activeOnly bool) (int, error) {
|
|
var rows *sql.Rows
|
|
var err error
|
|
if activeOnly {
|
|
rows, err = r.db.Query("SELECT * FROM officeHour WHERE room=? AND day =? AND active", room.Id, date.Day)
|
|
} else {
|
|
rows, err = r.db.Query("SELECT * FROM officeHour WHERE room=?", room.Id)
|
|
}
|
|
if err != nil {
|
|
err = fmt.Errorf("Error getting officeHours by timespan and room from database: %w", err)
|
|
log.Println(err.Error())
|
|
return 0, err
|
|
}
|
|
defer rows.Close()
|
|
officeHours, err := r.getFromRows(rows)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
var count int
|
|
// iterate over all points in the new officehour to get the maximum parallel officehours
|
|
for minute := 0; minute < duration; minute += r.config.Date.MinuteGranularity {
|
|
var minuteCount int = 0
|
|
for _, officeHour := range officeHours {
|
|
// increase count if officehour starts before this point in time and ends later
|
|
if models.DateLess(officeHour.Date, models.GetEndDate(date, minute, false)) && models.DateLess(models.GetEndDate(date, minute, false), models.GetEndDate(officeHour.Date, officeHour.Duration, false)) {
|
|
minuteCount += 1
|
|
}
|
|
}
|
|
if minuteCount > count {
|
|
count = minuteCount
|
|
}
|
|
}
|
|
return count, nil
|
|
}
|
|
|
|
func (r *OfficeHourRepo) AllowedAt(date models.Date, duration int, room models.Room, activeOnly bool) (bool, error) {
|
|
numberOfOfficeHours, err := r.NumberByTimeSpanAndRoom(date, duration, room, activeOnly)
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
return numberOfOfficeHours < room.MaxOccupy, nil
|
|
}
|