Compare commits
3 Commits
f21ce9a3c3
...
c29a952e1d
| Author | SHA1 | Date | |
|---|---|---|---|
| c29a952e1d | |||
| b12a467ef9 | |||
| 8bb1777519 |
3
.gitignore
vendored
3
.gitignore
vendored
@@ -30,7 +30,8 @@ DB/pg_data
|
||||
|
||||
.env.*
|
||||
.env
|
||||
!.env.example
|
||||
|
||||
Docker/config
|
||||
|
||||
.idea
|
||||
.vscode
|
||||
|
||||
@@ -10,7 +10,6 @@ import (
|
||||
"errors"
|
||||
"log"
|
||||
"net/http"
|
||||
"time"
|
||||
)
|
||||
|
||||
// Relevant for arduino inputs -> creates new Booking from get and put method
|
||||
@@ -40,7 +39,7 @@ func createBooking(w http.ResponseWriter, r *http.Request) {
|
||||
}
|
||||
|
||||
booking := (*models.Booking).FromUrlParams(nil, r.URL.Query())
|
||||
booking.Timestamp = time.Now()
|
||||
// booking.Timestamp = time.Now()
|
||||
if booking.Verify() {
|
||||
err := booking.Insert()
|
||||
if errors.Is(models.SameBookingError{}, err) {
|
||||
|
||||
@@ -52,6 +52,8 @@ func main() {
|
||||
|
||||
defer models.DB.(*sql.DB).Close()
|
||||
|
||||
models.Options = configure()
|
||||
|
||||
if helper.GetEnv("GO_ENV", "production") != "debug" {
|
||||
err = Migrate()
|
||||
if err != nil {
|
||||
@@ -114,3 +116,10 @@ func loggingMiddleware(next http.Handler) http.Handler {
|
||||
slog.Info("Completet Request", slog.String("Time", time.Since(start).String()))
|
||||
})
|
||||
}
|
||||
|
||||
func configure() models.BookingOptions {
|
||||
return models.BookingOptions{
|
||||
AllowOutOfBounds: helper.GetEnv("BOOKING_OUT_OF_BOUNDS", "false") == "true",
|
||||
AllowUnknownUser: helper.GetEnv("BOOKING_FOR_UNKNOWN_USER", "false") == "true",
|
||||
}
|
||||
}
|
||||
|
||||
@@ -39,6 +39,11 @@ type Booking struct {
|
||||
Valid bool `json:"valid"`
|
||||
}
|
||||
|
||||
type BookingOptions struct {
|
||||
AllowOutOfBounds bool
|
||||
AllowUnknownUser bool
|
||||
}
|
||||
|
||||
type IDatabase interface {
|
||||
Prepare(query string) (*sql.Stmt, error)
|
||||
Exec(query string, args ...any) (sql.Result, error)
|
||||
@@ -46,6 +51,8 @@ type IDatabase interface {
|
||||
|
||||
var DB IDatabase
|
||||
|
||||
var Options BookingOptions
|
||||
|
||||
func (b *Booking) NewBooking(cardUid string, gereatId int16, checkInOut int16, typeId int8) Booking {
|
||||
bookingType, err := GetBookingTypeById(typeId)
|
||||
if err != nil {
|
||||
@@ -92,10 +99,44 @@ func (b *Booking) Verify() bool {
|
||||
} else {
|
||||
b.BookingType.Name = bookingType.Name
|
||||
}
|
||||
|
||||
user, err := GetUserByCardUID(b.CardUID)
|
||||
if err == sql.ErrNoRows {
|
||||
log.Println("Cannot find user with given CardUID")
|
||||
return Options.AllowUnknownUser // if allow do not fail verify if not allow fail verify
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
slog.Error("Cannot get user from CardUID", "error", err)
|
||||
return false
|
||||
}
|
||||
|
||||
if bookingOutOfBounds(b, &user) {
|
||||
auditLog, closeLog := logs.NewAudit()
|
||||
defer closeLog()
|
||||
if !Options.AllowOutOfBounds {
|
||||
return false
|
||||
}
|
||||
|
||||
oldTime := b.Timestamp
|
||||
if oldTime.IsZero() {
|
||||
oldTime = time.Now()
|
||||
}
|
||||
if b.CheckInOut%2 == 1 && b.CheckInOut < 200 { //kommen Booking
|
||||
b.Timestamp = user.ArbeitMinStartTime(oldTime)
|
||||
} else {
|
||||
b.Timestamp = user.ArbeitMaxEndeTime(oldTime)
|
||||
}
|
||||
auditLog.Printf("Buchung (%s) von '%s' außerhalb der regulaeren Zeit. Verschieben der Zeit %s -> %s", b.GetBookingType(), user.CardUID, oldTime.Format(time.TimeOnly), b.Timestamp.Format(time.TimeOnly))
|
||||
slog.Info("Booking is out of work time bounds, setting time to match worktime bounds", "new_time", b.Timestamp.String(), "old_time", oldTime)
|
||||
}
|
||||
return true
|
||||
}
|
||||
|
||||
func (b *Booking) Insert() error {
|
||||
if !b.Timestamp.IsZero() {
|
||||
return b.InsertWithTimestamp()
|
||||
}
|
||||
if !checkLastBooking(*b) {
|
||||
return SameBookingError{}
|
||||
}
|
||||
@@ -224,20 +265,21 @@ func (b *Booking) Update(nb Booking) {
|
||||
b.GeraetID = nb.GeraetID
|
||||
}
|
||||
if b.Timestamp != nb.Timestamp {
|
||||
auditLog.Printf("Änderung in Buchung %d von '%s': Buchungszeit (%s -> %s).", b.CounterId, b.CardUID, b.Timestamp.Format("15:04"), nb.Timestamp.Format("15:04)"))
|
||||
auditLog.Printf("Änderung in Buchung %d von '%s': Buchungszeit (%s -> %s).", b.CounterId, b.CardUID, b.Timestamp.Format(time.TimeOnly), nb.Timestamp.Format(time.TimeOnly))
|
||||
b.Timestamp = nb.Timestamp
|
||||
}
|
||||
}
|
||||
|
||||
func checkLastBooking(b Booking) bool {
|
||||
var check_in_out int
|
||||
slog.Info("Checking with timestamp:", "timestamp", b.Timestamp.String())
|
||||
stmt, err := DB.Prepare((`SELECT check_in_out FROM "anwesenheit" WHERE "card_uid" = $1 AND "timestamp" <= $2 ORDER BY "timestamp" DESC LIMIT 1;`))
|
||||
var timestamp time.Time
|
||||
slog.Debug("Checking with timestamp:", "timestamp", b.Timestamp)
|
||||
stmt, err := DB.Prepare((`SELECT check_in_out, timestamp FROM "anwesenheit" WHERE "card_uid" = $1 AND "timestamp" <= $2 ORDER BY "timestamp" DESC LIMIT 1;`))
|
||||
if err != nil {
|
||||
log.Fatalf("Error preparing query: %v", err)
|
||||
return false
|
||||
}
|
||||
err = stmt.QueryRow(b.CardUID, b.Timestamp).Scan(&check_in_out)
|
||||
err = stmt.QueryRow(b.CardUID, b.Timestamp).Scan(&check_in_out, ×tamp)
|
||||
slog.Info("Checking last bookings check_in_out", "Check", check_in_out)
|
||||
if err == sql.ErrNoRows {
|
||||
return true
|
||||
@@ -246,9 +288,13 @@ func checkLastBooking(b Booking) bool {
|
||||
log.Println("Error checking last booking: ", err)
|
||||
return false
|
||||
}
|
||||
|
||||
if int16(check_in_out)%2 == b.CheckInOut%2 {
|
||||
return false
|
||||
}
|
||||
if timestamp.Equal(b.Timestamp) {
|
||||
return false
|
||||
}
|
||||
return true
|
||||
}
|
||||
|
||||
@@ -257,8 +303,6 @@ func (b *Booking) UpdateTime(newTime time.Time) {
|
||||
if hour == b.Timestamp.Hour() && minute == b.Timestamp.Minute() {
|
||||
return
|
||||
}
|
||||
// TODO: add check for time overlap
|
||||
|
||||
var newBooking Booking
|
||||
newBooking.Timestamp = time.Date(b.Timestamp.Year(), b.Timestamp.Month(), b.Timestamp.Day(), hour, minute, 0, 0, b.Timestamp.Location())
|
||||
if b.CheckInOut < 3 {
|
||||
@@ -268,14 +312,11 @@ func (b *Booking) UpdateTime(newTime time.Time) {
|
||||
newBooking.CheckInOut = 4
|
||||
}
|
||||
b.Update(newBooking)
|
||||
// TODO Check verify
|
||||
if b.Verify() {
|
||||
b.Save()
|
||||
} else {
|
||||
log.Println("Cannot save updated booking!", b.ToString())
|
||||
}
|
||||
// b.Verify()
|
||||
// b.Save()
|
||||
}
|
||||
|
||||
func (b *Booking) ToString() string {
|
||||
@@ -327,3 +368,12 @@ func GetBookingTypesCached() []BookingType {
|
||||
}
|
||||
return types.([]BookingType)
|
||||
}
|
||||
|
||||
func bookingOutOfBounds(b *Booking, u *User) bool {
|
||||
bookingTime := b.Timestamp
|
||||
if b.Timestamp.IsZero() {
|
||||
bookingTime = time.Now()
|
||||
}
|
||||
res := bookingTime.Before(u.ArbeitMinStartTime(bookingTime)) || bookingTime.After(u.ArbeitMaxEndeTime(bookingTime))
|
||||
return res
|
||||
}
|
||||
|
||||
@@ -28,6 +28,8 @@ type User struct {
|
||||
ArbeitszeitPerTag float32 //`json:"arbeitszeit_per_tag"`
|
||||
ArbeitszeitPerWoche float32 //`json:"arbeitszeit_per_woche"`
|
||||
Overtime time.Duration
|
||||
ArbeitMinStart time.Time
|
||||
ArbeitMaxEnde time.Time
|
||||
}
|
||||
|
||||
func GetUserFromSession(Session *scs.SessionManager, ctx context.Context) (User, error) {
|
||||
@@ -65,35 +67,41 @@ func (u *User) GetReportedOvertime(startDate time.Time) (time.Duration, error) {
|
||||
return overtime, nil
|
||||
}
|
||||
|
||||
func GetAllUsers() ([]User, error) {
|
||||
qStr, err := DB.Prepare((`SELECT card_uid, vorname, nachname,arbeitszeit_per_tag, arbeitszeit_per_woche FROM s_personal_daten;`))
|
||||
var users []User
|
||||
if err != nil {
|
||||
return users, err
|
||||
}
|
||||
defer qStr.Close()
|
||||
rows, err := qStr.Query()
|
||||
if err != nil {
|
||||
return users, err
|
||||
}
|
||||
defer rows.Close()
|
||||
for rows.Next() {
|
||||
|
||||
func GetUserByCardUID(cardUid string) (User, error) {
|
||||
var user User
|
||||
if err := rows.Scan(&user.CardUID, &user.Vorname, &user.Name, &user.ArbeitszeitPerTag, &user.ArbeitszeitPerWoche); err != nil {
|
||||
log.Println("Error creating user!", err)
|
||||
continue
|
||||
|
||||
qStr, err := DB.Prepare((`SELECT personal_nummer, vorname, nachname, card_uid, arbeitszeit_per_tag, arbeitszeit_per_woche, arbeitszeit_min_start, arbeitszeit_max_ende FROM s_personal_daten WHERE card_uid = $1;`))
|
||||
if err != nil {
|
||||
return user, err
|
||||
}
|
||||
users = append(users, user)
|
||||
err = qStr.QueryRow(cardUid).Scan(&user.PersonalNummer, &user.Vorname, &user.Name, &user.CardUID, &user.ArbeitszeitPerTag, &user.ArbeitszeitPerWoche, &user.ArbeitMinStart, &user.ArbeitMaxEnde)
|
||||
|
||||
if err != nil {
|
||||
return user, err
|
||||
}
|
||||
if err = rows.Err(); err != nil {
|
||||
return users, nil
|
||||
}
|
||||
return users, nil
|
||||
return user, nil
|
||||
}
|
||||
|
||||
func (u *User) GetAll() ([]User, error) {
|
||||
qStr, err := DB.Prepare((`SELECT card_uid, vorname, nachname FROM s_personal_daten;`))
|
||||
func (u *User) ArbeitMinStartTime(date time.Time) time.Time {
|
||||
if date.Hour() > 0 {
|
||||
date = date.Truncate(24 * time.Hour).Add(-time.Hour)
|
||||
}
|
||||
date = date.Truncate(time.Hour)
|
||||
slog.Info("Date truncate", "date", date)
|
||||
return date.Add(time.Hour*time.Duration(u.ArbeitMinStart.Hour()) + time.Minute*time.Duration(u.ArbeitMinStart.Minute()))
|
||||
}
|
||||
|
||||
func (u *User) ArbeitMaxEndeTime(date time.Time) time.Time {
|
||||
if date.Hour() > 0 {
|
||||
date = date.Truncate(24 * time.Hour).Add(-time.Hour)
|
||||
}
|
||||
date = date.Truncate(time.Hour)
|
||||
slog.Info("Date truncate", "date", date)
|
||||
return date.Add(time.Hour*time.Duration(u.ArbeitMaxEnde.Hour()) + time.Minute*time.Duration(u.ArbeitMaxEnde.Minute()))
|
||||
}
|
||||
|
||||
func GetAllUsers() ([]User, error) {
|
||||
qStr, err := DB.Prepare((`SELECT personal_nummer, vorname, nachname, card_uid, arbeitszeit_per_tag, arbeitszeit_per_woche, arbeitszeit_min_start, arbeitszeit_max_ende FROM s_personal_daten;`))
|
||||
var users []User
|
||||
if err != nil {
|
||||
return users, err
|
||||
@@ -107,7 +115,7 @@ func (u *User) GetAll() ([]User, error) {
|
||||
for rows.Next() {
|
||||
|
||||
var user User
|
||||
if err := rows.Scan(&user.CardUID, &user.Vorname, &user.Name); err != nil {
|
||||
if err := rows.Scan(&user.PersonalNummer, &user.Vorname, &user.Name, &user.CardUID, &user.ArbeitszeitPerTag, &user.ArbeitszeitPerWoche, &user.ArbeitMinStart, &user.ArbeitMaxEnde); err != nil {
|
||||
log.Println("Error creating user!", err)
|
||||
continue
|
||||
}
|
||||
@@ -167,11 +175,11 @@ func (u *User) CheckOut() error {
|
||||
func GetUserByPersonalNr(personalNummer int) (User, error) {
|
||||
var user User
|
||||
|
||||
qStr, err := DB.Prepare((`SELECT personal_nummer, card_uid, vorname, nachname, arbeitszeit_per_tag, arbeitszeit_per_woche FROM s_personal_daten WHERE personal_nummer = $1;`))
|
||||
qStr, err := DB.Prepare((`SELECT personal_nummer, vorname, nachname, card_uid, arbeitszeit_per_tag, arbeitszeit_per_woche, arbeitszeit_min_start, arbeitszeit_max_ende FROM s_personal_daten WHERE personal_nummer = $1;`))
|
||||
if err != nil {
|
||||
return user, err
|
||||
}
|
||||
err = qStr.QueryRow(personalNummer).Scan(&user.PersonalNummer, &user.CardUID, &user.Vorname, &user.Name, &user.ArbeitszeitPerTag, &user.ArbeitszeitPerWoche)
|
||||
err = qStr.QueryRow(personalNummer).Scan(&user.PersonalNummer, &user.Vorname, &user.Name, &user.CardUID, &user.ArbeitszeitPerTag, &user.ArbeitszeitPerWoche, &user.ArbeitMinStart, &user.ArbeitMaxEnde)
|
||||
|
||||
if err != nil {
|
||||
return user, err
|
||||
@@ -185,7 +193,7 @@ func GetUserByPersonalNrMulti(personalNummerMulti []int) ([]User, error) {
|
||||
return users, errors.New("No personalNumbers provided")
|
||||
}
|
||||
|
||||
qStr, err := DB.Prepare((`SELECT personal_nummer, card_uid, vorname, nachname, arbeitszeit_per_tag, arbeitszeit_per_woche FROM s_personal_daten WHERE personal_nummer = ANY($1::int[]);`))
|
||||
qStr, err := DB.Prepare((`SELECT personal_nummer, vorname, nachname, card_uid, arbeitszeit_per_tag, arbeitszeit_per_woche, arbeitszeit_min_start, arbeitszeit_max_ende FROM s_personal_daten WHERE personal_nummer = ANY($1::int[]);`))
|
||||
if err != nil {
|
||||
return users, err
|
||||
}
|
||||
@@ -200,7 +208,7 @@ func GetUserByPersonalNrMulti(personalNummerMulti []int) ([]User, error) {
|
||||
defer rows.Close()
|
||||
for rows.Next() {
|
||||
var user User
|
||||
if err := rows.Scan(&user.PersonalNummer, &user.CardUID, &user.Vorname, &user.Name, &user.ArbeitszeitPerTag, &user.ArbeitszeitPerWoche); err != nil {
|
||||
if err := rows.Scan(&user.PersonalNummer, &user.Vorname, &user.Name, &user.CardUID, &user.ArbeitszeitPerTag, &user.ArbeitszeitPerWoche, &user.ArbeitMinStart, &user.ArbeitMaxEnde); err != nil {
|
||||
return users, err
|
||||
}
|
||||
users = append(users, user)
|
||||
@@ -246,6 +254,7 @@ func (u *User) ChangePass(password, newPassword string) (bool, error) {
|
||||
}
|
||||
|
||||
func (u *User) GetTeamMembers() ([]User, error) {
|
||||
var teamMemberPNrs []int
|
||||
var teamMembers []User
|
||||
qStr, err := DB.Prepare(`SELECT personal_nummer FROM s_personal_daten WHERE vorgesetzter_pers_nr = $1 ORDER BY "nachname";`)
|
||||
if err != nil {
|
||||
@@ -261,12 +270,16 @@ func (u *User) GetTeamMembers() ([]User, error) {
|
||||
for rows.Next() {
|
||||
var personalNr int
|
||||
err := rows.Scan(&personalNr)
|
||||
user, err := GetUserByPersonalNr(personalNr)
|
||||
teamMemberPNrs = append(teamMemberPNrs, personalNr)
|
||||
if err != nil {
|
||||
log.Println("Error getting user!")
|
||||
return teamMembers, err
|
||||
}
|
||||
teamMembers = append(teamMembers, user)
|
||||
}
|
||||
teamMembers, err = GetUserByPersonalNrMulti(teamMemberPNrs)
|
||||
if err != nil {
|
||||
log.Println("Error getting users!")
|
||||
return teamMembers, err
|
||||
}
|
||||
|
||||
return teamMembers, nil
|
||||
@@ -343,22 +356,6 @@ LIMIT 1;
|
||||
return lastSub
|
||||
}
|
||||
|
||||
func (u *User) GetFromCardUID(card_uid string) (User, error) {
|
||||
user := User{}
|
||||
var err error
|
||||
|
||||
qStr, err := DB.Prepare((`SELECT personal_nummer, card_uid, vorname, nachname, arbeitszeit_per_tag FROM s_personal_daten WHERE card_uid = $1;`))
|
||||
if err != nil {
|
||||
return user, err
|
||||
}
|
||||
err = qStr.QueryRow(card_uid).Scan(&user.PersonalNummer, &user.CardUID, &user.Vorname, &user.Name, &user.ArbeitszeitPerTag)
|
||||
|
||||
if err != nil {
|
||||
return user, err
|
||||
}
|
||||
return user, nil
|
||||
}
|
||||
|
||||
func (u *User) IsSuperior(e User) bool {
|
||||
var isSuperior int
|
||||
qStr, err := DB.Prepare(`SELECT COUNT(1) FROM s_personal_daten WHERE personal_nummer = $1 AND vorgesetzter_pers_nr = $2`)
|
||||
@@ -372,7 +369,6 @@ func (u *User) IsSuperior(e User) bool {
|
||||
return false
|
||||
}
|
||||
return isSuperior == 1
|
||||
|
||||
}
|
||||
|
||||
func getMonday(ts time.Time) time.Time {
|
||||
|
||||
@@ -424,10 +424,12 @@ GROUP BY
|
||||
|
||||
// returns bool wheter the workday was ended with an automatic logout
|
||||
func (d *WorkDay) RequiresAction() bool {
|
||||
if len(d.Bookings) == 0 {
|
||||
return false
|
||||
for i := range d.Bookings {
|
||||
if d.Bookings[i].CheckInOut > 250 {
|
||||
return true
|
||||
}
|
||||
return d.Bookings[len(d.Bookings)-1].CheckInOut == 254
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
func (d *WorkDay) GetDayProgress(u User) int8 {
|
||||
|
||||
@@ -61,6 +61,8 @@ templ SettingsPage(status int) {
|
||||
<div class="grid-cell col-span-3">
|
||||
<p>Nutzername: <span class="text-neutral-500">{ user.Vorname } { user.Name }</span></p>
|
||||
<p>Personalnummer: <span class="text-neutral-500">{ user.PersonalNummer }</span></p>
|
||||
<p>Frühester Arbeitsbegin: <span class="text-neutral-500">{ user.ArbeitMinStart.Format("15:06") } Uhr</span></p>
|
||||
<p>Spätester Arbeitsende: <span class="text-neutral-500">{ user.ArbeitMaxEnde.Format("15:06") } Uhr</span></p>
|
||||
<p>Arbeitszeit pro Tag: <span class="text-neutral-500">{ helper.FormatDuration(user.ArbeitszeitProTag()) }</span></p>
|
||||
<p>Arbeitszeit pro Woche: <span class="text-neutral-500">{ helper.FormatDuration(user.ArbeitszeitProWoche()) }</span></p>
|
||||
</div>
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
# cron-timing: 05 01 * * 1
|
||||
container_name="arbeitszeitmessung-main-db-1"
|
||||
filename=backup-$(date '+%d%m%Y').sql
|
||||
filename=backup-$(date '+%Y%m%d').sql
|
||||
backup_folder=__BACKUP_FOLDER__
|
||||
database_name=__DATABASE__
|
||||
docker exec $container_name pg_dump $database_name > $backup_folder/$filename
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
# cron-timing: 01 00 01 01 *
|
||||
# Calls endpoint to write all public Holidays for the current year inside a database.
|
||||
port=__PORT__
|
||||
curl localhost:$port/auto/feiertage
|
||||
|
||||
@@ -1,13 +1,16 @@
|
||||
POSTGRES_USER=root # Postgres ADMIN Nutzername
|
||||
POSTGRES_USER=root # Postgres ADMIN Nutzername. regex:^\w+$
|
||||
POSTGRES_PASSWORD=very_secure # Postgres ADMIN Passwort
|
||||
POSTGRES_API_USER=api_nutzer # Postgres API Nutzername (für Arbeitszeitmessung)
|
||||
POSTGRES_API_USER=api_nutzer # Postgres API Nutzername (für Arbeitszeitmessung). regex:^\w+$
|
||||
POSTGRES_API_PASS=password # Postgres API Passwort (für Arbeitszeitmessung)
|
||||
POSTGRES_PATH=__ROOT__/DB # Datebank Pfad (relativ zu Docker Ordner oder absoluter pfad mit /...)
|
||||
POSTGRES_DB=arbeitszeitmessung # Postgres Datenbank Name
|
||||
POSTGRES_DB=arbeitszeitmessung # Postgres Datenbank Name. regex:^[a-z]+$
|
||||
POSTGRES_PORT=5432 # Postgres Port normalerweise nicht freigegeben. regex:^[0-9]{1,5}$
|
||||
TZ=Europe/Berlin # Zeitzone
|
||||
API_TOKEN=dont_access # API Token für ESP Endpoints
|
||||
API_TOKEN=dont_access # API Token für ESP32 Endpoints
|
||||
WEB_PORT=8000 # Port unter welchem Webserver erreichbar ist. regex:^[0-9]{1,5}$
|
||||
LOG_PATH=__ROOT__/logs # Pfad für Audit Logs
|
||||
LOG_LEVEL=warn # Welche Log-Nachrichten werden in der Konsole erscheinen
|
||||
LOG_LEVEL=warn # Welche Log-Nachrichten werden in der Konsole erscheinen. regex:^(debug|info|warn|error)$
|
||||
BACKUP_FOLDER=__ROOT__/backup # Pfad für DB Backup Datein
|
||||
|
||||
BOOKING_OUT_OF_BOUNDS=true # Buchungen außerhalb der festgelegten Arbeitszeit erlauben und auf Arbeitszeit anpassen. regex:^(true|false)$
|
||||
BOOKING_FOR_UNKNOWN_USER=true # Buchungen mit unbekannter CardUID erlauben. regex:^(true|false)$
|
||||
|
||||
232
install.sh
232
install.sh
@@ -1,15 +1,21 @@
|
||||
#!/usr/bin/env bash
|
||||
#©Tom Tröger 2026
|
||||
set -e
|
||||
|
||||
envFile=Docker/.env
|
||||
envBkp=Docker/.env.old
|
||||
envExample=Docker/env.example
|
||||
|
||||
autoBackupScript=Cron/autoBackup.sh
|
||||
autoHolidaysScript=Cron/autoHolidays.sh
|
||||
autoLogoutScript=Cron/autoLogout.sh
|
||||
cronFilePath=Cron
|
||||
customCronFilePath=Docker/config/cron
|
||||
|
||||
echo "Checking Docker installation..."
|
||||
if ! command -v docker >/dev/null 2>&1; then
|
||||
autoBackupScript=autoBackup.sh
|
||||
autoHolidaysScript=autoHolidays.sh
|
||||
autoLogoutScript=autoLogout.sh
|
||||
|
||||
function checkDocker() {
|
||||
echo "Checking Docker installation..."
|
||||
if ! command -v docker >/dev/null 2>&1; then
|
||||
echo "Docker not found. Install Docker? [y/N]"
|
||||
read -r install_docker
|
||||
if [[ "$install_docker" =~ ^[Yy]$ ]]; then
|
||||
@@ -18,42 +24,68 @@ if ! command -v docker >/dev/null 2>&1; then
|
||||
echo "Docker is required. Exiting."
|
||||
exit 1
|
||||
fi
|
||||
else
|
||||
else
|
||||
echo "Docker is already installed."
|
||||
fi
|
||||
fi
|
||||
|
||||
###########################################################################
|
||||
###########################################################################
|
||||
|
||||
echo "Checking Docker Compose..."
|
||||
if ! docker compose version >/dev/null 2>&1; then
|
||||
echo "Checking Docker Compose..."
|
||||
if ! docker compose version >/dev/null 2>&1; then
|
||||
echo "Docker Compose plugin missing. You may need to update Docker."
|
||||
exit 1
|
||||
fi
|
||||
|
||||
fi
|
||||
}
|
||||
###########################################################################
|
||||
|
||||
echo "Preparing .env file..."
|
||||
if [ ! -f $envFile ]; then
|
||||
function setupConfig() {
|
||||
local reconfig=false
|
||||
if [ $# -gt 0 ]; then
|
||||
if ask_reconfig $1 "Reconfigure .env File?"
|
||||
then
|
||||
reconfig=true
|
||||
else
|
||||
return 0
|
||||
fi
|
||||
fi
|
||||
echo -e "\r\n==================================================\r\n"
|
||||
echo "Preparing .env file..."
|
||||
if [ ! -f $envFile ] || [ $reconfig == true ]; then
|
||||
if [ -f $envExample ]; then
|
||||
if [ $reconfig == true ]; then
|
||||
echo "Reconfiguring env file. Backup stored at $envBkp"
|
||||
echo "All previous values will be used as defaults!"
|
||||
cp $envFile $envBkp
|
||||
else
|
||||
echo ".env not found. Creating interactively from .env.example."
|
||||
fi
|
||||
> $envFile
|
||||
|
||||
|
||||
while IFS= read -r line; do
|
||||
|
||||
#ignore empty lines and comments
|
||||
[[ "$line" =~ ^#.*$ || -z "$line" ]] && continue
|
||||
|
||||
|
||||
key=$(printf "%s" "$line" | cut -d '=' -f 1)
|
||||
rest=$(printf "%s" "$line" | cut -d '=' -f 2-)
|
||||
local key=$(printf "%s" "$line" | cut -d '=' -f 1)
|
||||
local rest=$(printf "%s" "$line" | cut -d '=' -f 2-)
|
||||
|
||||
# extract inline comment portion
|
||||
comment=$(printf "%s" "$rest" | sed -n 's/.*# \(.*\)$/\1/p')
|
||||
raw_val=$(printf "%s" "$rest" | sed 's/ *#.*//')
|
||||
default_value=$(printf "%s" "$raw_val" | sed 's/"//g')
|
||||
local comment=$(printf "%s" "$rest" | sed -n 's/.*# \(.*\)$/\1/p')
|
||||
local raw_val=$(printf "%s" "$rest" | sed 's/ *#.*//')
|
||||
|
||||
local default_value=$(printf "%s" "$raw_val" | sed 's/"//g')
|
||||
|
||||
if [ $reconfig == true ]; then
|
||||
local previous_value=$(grep -E "^$key=" $envBkp | cut -d= -f2)
|
||||
if [ -n "$previous_value" ]; then
|
||||
default_value=$previous_value
|
||||
fi
|
||||
fi
|
||||
|
||||
# Replace __ROOT__ with script pwd
|
||||
default_value="${default_value/__ROOT__/$(pwd)}"
|
||||
local default_value="${default_value/__ROOT__/$(pwd)}"
|
||||
|
||||
regex=""
|
||||
if [[ "$comment" =~ regex:(.*)$ ]]; then
|
||||
@@ -103,26 +135,74 @@ if [ ! -f $envFile ]; then
|
||||
echo "Creating an empty .env file for manual editing."
|
||||
touch $envFile
|
||||
fi
|
||||
else
|
||||
else
|
||||
echo "Using existing .env. (found at $envFile)"
|
||||
fi
|
||||
|
||||
fi
|
||||
}
|
||||
###########################################################################
|
||||
|
||||
LOG_PATH=$(grep -E '^LOG_PATH=' $envFile | cut -d= -f2)
|
||||
if [ -z "$LOG_PATH" ]; then
|
||||
function setupFolders(){
|
||||
if [ $# -gt 0 ]; then
|
||||
if ! ask_reconfig $1 "Recreate Folders?"
|
||||
then
|
||||
return 0
|
||||
fi
|
||||
fi
|
||||
LOG_PATH=$(grep -E '^LOG_PATH=' $envFile | cut -d= -f2)
|
||||
if [ -z "$LOG_PATH" ]; then
|
||||
echo "LOG_PATH not found in .env using default $(pwd)/logs"
|
||||
LOG_PATH=$(pwd)/logs
|
||||
fi
|
||||
mkdir -p $LOG_PATH
|
||||
echo "Created logs folder at $LOG_PATH"
|
||||
fi
|
||||
if [ ! -d "$LOG_PATH" ]; then
|
||||
mkdir -p $LOG_PATH
|
||||
echo "Created logs folder at $LOG_PATH"
|
||||
fi
|
||||
|
||||
POSTGRES_PATH=$(grep -E '^POSTGRES_PATH=' $envFile | cut -d= -f2)
|
||||
if [ -z "$POSTGRES_PATH" ]; then
|
||||
echo "POSTGRES_PATH not found in .env using default $(pwd)/DB"
|
||||
POSTGRES_PATH=$(pwd)/DB
|
||||
fi
|
||||
if [ ! -d "$POSTGRES_PATH" ]; then
|
||||
mkdir -p $POSTGRES_PATH
|
||||
echo "Created DB folder at $POSTGRES_PATH"
|
||||
fi
|
||||
|
||||
BACKUP_FOLDER=$(grep -E '^BACKUP_FOLDER=' $envFile | cut -d= -f2)
|
||||
if [ -z "$BACKUP_FOLDER" ]; then
|
||||
echo "BACKUP_FOLDER not found in .env using default $(pwd)/backup"
|
||||
BACKUP_FOLDER=$(pwd)/backup
|
||||
fi
|
||||
if [ ! -d "$BACKUP_FOLDER" ]; then
|
||||
mkdir -p $BACKUP_FOLDER
|
||||
echo "Created backup folder at $BACKUP_FOLDER"
|
||||
fi
|
||||
}
|
||||
###########################################################################
|
||||
|
||||
echo -e "\n\n"
|
||||
echo "Setup Crontab for automatic logout, backup and holiday creation? [y/N]"
|
||||
read -r setup_cron
|
||||
if [[ "$setup_cron" =~ ^[Yy]$ ]]; then
|
||||
function setupCron(){
|
||||
echo -e "\r\n==================================================\r\n"
|
||||
echo "Setup Crontab for automatic logout, backup and holiday creation? [y/N]"
|
||||
read -r setup_cron
|
||||
if [[ "$setup_cron" =~ ^[Yy]$ ]]; then
|
||||
echo "Copying custom cron files to $customCronFilePath"
|
||||
mkdir -p "$customCronFilePath"
|
||||
|
||||
if [ ! -s "$customCronFilePath/$autoBackupScript" ];then
|
||||
cp "$cronFilePath/$autoBackupScript" "$customCronFilePath/$autoBackupScript"
|
||||
echo "Copied $autoBackupScript"
|
||||
fi
|
||||
|
||||
if [ ! -s "$customCronFilePath/$autoLogoutScript" ];then
|
||||
cp "$cronFilePath/$autoLogoutScript" "$customCronFilePath/$autoLogoutScript"
|
||||
echo "Copied $autoLogoutScript"
|
||||
fi
|
||||
|
||||
if [ ! -s "$customCronFilePath/$autoHolidaysScript" ];then
|
||||
cp "$cronFilePath/$autoHolidaysScript" "$customCronFilePath/$autoHolidaysScript"
|
||||
echo "Copied $autoHolidaysScript"
|
||||
fi
|
||||
|
||||
WEB_PORT=$(grep -E '^WEB_PORT=' $envFile | cut -d= -f2)
|
||||
if [ -z "$WEB_PORT" ]; then
|
||||
echo "WEB_PORT not found in .env using default 8000"
|
||||
@@ -141,19 +221,20 @@ if [[ "$setup_cron" =~ ^[Yy]$ ]]; then
|
||||
BACKUP_FOLDER="$(pwd)/backup"
|
||||
fi
|
||||
|
||||
sed -i "s/__PORT__/$WEB_PORT/" $autoHolidaysScript
|
||||
sed -i "s/__PORT__/$WEB_PORT/" $autoLogoutScript
|
||||
sed -i "s/__DATABASE__/$POSTGRES_DB/" $autoBackupScript
|
||||
sed -i "s/__BACKUP_FOLDER__/$BACKUP_FOLDER" $autoBackupScript
|
||||
sed -i "s|__PORT__|$WEB_PORT|" $customCronFilePath/$autoHolidaysScript && \
|
||||
sed -i "s|__PORT__|$WEB_PORT|" $customCronFilePath/$autoLogoutScript && \
|
||||
sed -i "s|__DATABASE__|$POSTGRES_DB|" $customCronFilePath/$autoBackupScript && \
|
||||
sed -i "s|__BACKUP_FOLDER__|$BACKUP_FOLDER|" $customCronFilePath/$autoBackupScript
|
||||
|
||||
chmod +x $autoBackupScript $autoHolidaysScript $autoLogoutScript
|
||||
chmod +x "$customCronFilePath/$autoBackupScript" "$customCronFilePath/$autoHolidaysScript" "$customCronFilePath/$autoLogoutScript"
|
||||
|
||||
# echo "Scripts build with PORT=$WEB_PORT and DATABSE=$POSTGRES_DB!"
|
||||
echo "Adding rules to crontab."
|
||||
|
||||
cron_commands=$(mktemp /tmp/arbeitszeitmessung-cron.XXX)
|
||||
pwd
|
||||
|
||||
for file in Cron/*; do
|
||||
for file in $customCronFilePath/*; do
|
||||
cron_timing=$(grep -E '^# cron-timing:' "$file" | sed 's/^# cron-timing:[[:space:]]*//')
|
||||
|
||||
if [ -z "$cron_timing" ]; then
|
||||
@@ -163,7 +244,6 @@ if [[ "$setup_cron" =~ ^[Yy]$ ]]; then
|
||||
|
||||
( crontab -l ; echo "$cron_timing $(pwd)/$file" )| awk '!x[$0]++' | crontab -
|
||||
echo "Added entry to crontab: $cron_timing $(pwd)/$file."
|
||||
sleep 2
|
||||
done
|
||||
|
||||
if systemctl is-active --quiet cron.service ; then
|
||||
@@ -173,21 +253,75 @@ if [[ "$setup_cron" =~ ^[Yy]$ ]]; then
|
||||
echo "For how to start a service, see: https://wiki.ubuntuusers.de/systemd/systemctl UNITNAME will be cron.service"
|
||||
fi
|
||||
|
||||
else
|
||||
else
|
||||
echo "Please setup cron manually by executing crontab -e and adding all files from inside the Cron directory!"
|
||||
fi
|
||||
|
||||
fi
|
||||
}
|
||||
###########################################################################
|
||||
|
||||
echo -e "\n\n"
|
||||
echo "Start containers with docker compose up -d? [y/N]"
|
||||
read -r start_containers
|
||||
if [[ "$start_containers" =~ ^[Yy]$ ]]; then
|
||||
function startContainer(){
|
||||
echo -e "\r\n==================================================\r\n"
|
||||
echo "Start containers with docker compose up -d? [y/N]"
|
||||
read -r start_containers
|
||||
if [[ "$start_containers" =~ ^[Yy]$ ]]; then
|
||||
cd Docker
|
||||
docker compose up -d
|
||||
echo "Containers started."
|
||||
else
|
||||
else
|
||||
echo "You can start them manually with: docker compose up -d"
|
||||
fi
|
||||
fi
|
||||
}
|
||||
###########################################################################
|
||||
|
||||
echo "Installation finished, you can re-run the script any time!"
|
||||
function help(){
|
||||
echo "Installer Script für Arbeitszeitmessung Software"
|
||||
echo -e "\r\n==================================================\r\n"
|
||||
echo "Nutzung: ./install.sh [options]"
|
||||
echo -e "\r\n==================================================\r\n"
|
||||
echo "Optionen:"
|
||||
echo " -h zeigt diese Übersicht"
|
||||
echo " -c .env Datei bearbeiten/aktualisieren && cron neu configurieren"
|
||||
echo -e "\r\n=================================================="
|
||||
}
|
||||
###########################################################################
|
||||
|
||||
function main(){
|
||||
echo -e "================Arbeitszeitmessung================\r\n"
|
||||
if [ $# -gt 0 ];then
|
||||
if [ $1 == reconfig ]; then
|
||||
echo -e "================Reconfiguring================\r\n"
|
||||
setupConfig $1
|
||||
setupFolders $1
|
||||
setupCron $1
|
||||
fi
|
||||
else
|
||||
checkDocker
|
||||
setupConfig
|
||||
setupFolders
|
||||
setupCron
|
||||
startContainer
|
||||
fi
|
||||
echo "Installation finished, you can re-run the script any time!"
|
||||
}
|
||||
###########################################################################
|
||||
|
||||
function ask_reconfig(){
|
||||
echo -e "\r\n==================================================\r\n"
|
||||
echo "$2 [y/N]"
|
||||
read -r do_reconfig
|
||||
|
||||
[[ "$do_reconfig" =~ ^[Yy]$ ]] && return # true
|
||||
echo "Skipping..."
|
||||
return 1
|
||||
}
|
||||
###########################################################################
|
||||
|
||||
while getopts ":hc" opt; do
|
||||
case $opt in
|
||||
h) help; exit 0 ;;
|
||||
c) main reconfig; exit 0 ;;
|
||||
*) echo "Ungültiges Argument"; exit 1 ;;
|
||||
esac
|
||||
done
|
||||
|
||||
main
|
||||
|
||||
Reference in New Issue
Block a user