Discord-Push hinzugefügt
All checks were successful
release-tag / release-image (push) Successful in 2m11s
All checks were successful
release-tag / release-image (push) Successful in 2m11s
This commit is contained in:
48
main.go
48
main.go
@@ -458,6 +458,20 @@ func main() {
|
|||||||
wareStr := strings.Join(ware, ", ")
|
wareStr := strings.Join(ware, ", ")
|
||||||
zeitaufwand, _ := strconv.ParseFloat(r.FormValue("zeitaufwand"), 64)
|
zeitaufwand, _ := strconv.ParseFloat(r.FormValue("zeitaufwand"), 64)
|
||||||
|
|
||||||
|
e := Entry{
|
||||||
|
Anfangsbestand: anfang,
|
||||||
|
Endbestand: ende,
|
||||||
|
Prozentwert: prozent,
|
||||||
|
Abgabe: abgabe,
|
||||||
|
Startort: startort,
|
||||||
|
Zielort: zielort,
|
||||||
|
Schiff: schiff,
|
||||||
|
Ware: wareStr,
|
||||||
|
Zeitaufwand: zeitaufwand,
|
||||||
|
}
|
||||||
|
|
||||||
|
go sendDiscordWebhook(e)
|
||||||
|
|
||||||
_, err := db.Exec(`INSERT INTO eintraege (anfangsbestand, endbestand, prozentwert, abgabe, created_at, startort, zielort, schiff, ware, zeitaufwand) VALUES (?, ?, ?, ?, datetime('now'), ?, ?, ?, ?, ?)`, anfang, ende, prozent, abgabe, startort, zielort, schiff, wareStr, zeitaufwand)
|
_, err := db.Exec(`INSERT INTO eintraege (anfangsbestand, endbestand, prozentwert, abgabe, created_at, startort, zielort, schiff, ware, zeitaufwand) VALUES (?, ?, ?, ?, datetime('now'), ?, ?, ?, ?, ?)`, anfang, ende, prozent, abgabe, startort, zielort, schiff, wareStr, zeitaufwand)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
http.Error(w, "Fehler beim Einfügen", http.StatusInternalServerError)
|
http.Error(w, "Fehler beim Einfügen", http.StatusInternalServerError)
|
||||||
@@ -694,6 +708,40 @@ type CachedData struct {
|
|||||||
var cache CachedData
|
var cache CachedData
|
||||||
var cacheMutex sync.RWMutex
|
var cacheMutex sync.RWMutex
|
||||||
|
|
||||||
|
var discordWebhook = GetENV("DISCORD_WEBHOOK_URL", "")
|
||||||
|
|
||||||
|
func sendDiscordWebhook(entry Entry) {
|
||||||
|
if discordWebhook == "" {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
message := fmt.Sprintf(
|
||||||
|
"📦 **Neuer Abgabe-Eintrag**\n"+
|
||||||
|
"**UEC:** %s → %s (%s UEC Profit)\n"+
|
||||||
|
"**Abgabe:** %s UEC (%s%%)\n"+
|
||||||
|
"**Route:** %s → %s mit %s\n"+
|
||||||
|
"**Ware:** %s\n"+
|
||||||
|
"**Dauer:** %.0f Minuten",
|
||||||
|
formatNumber(entry.Anfangsbestand),
|
||||||
|
formatNumber(entry.Endbestand),
|
||||||
|
formatNumber(entry.Gesamtwert),
|
||||||
|
formatNumber(entry.Abgabe),
|
||||||
|
formatNumber(entry.Prozentwert),
|
||||||
|
entry.Startort,
|
||||||
|
entry.Zielort,
|
||||||
|
entry.Schiff,
|
||||||
|
entry.Ware,
|
||||||
|
entry.Zeitaufwand,
|
||||||
|
)
|
||||||
|
|
||||||
|
payload := map[string]string{
|
||||||
|
"content": message,
|
||||||
|
}
|
||||||
|
jsonData, _ := json.Marshal(payload)
|
||||||
|
|
||||||
|
http.Post(discordWebhook, "application/json", strings.NewReader(string(jsonData)))
|
||||||
|
}
|
||||||
|
|
||||||
func createTable(db *sql.DB) {
|
func createTable(db *sql.DB) {
|
||||||
_, err := db.Exec(`
|
_, err := db.Exec(`
|
||||||
CREATE TABLE IF NOT EXISTS eintraege (
|
CREATE TABLE IF NOT EXISTS eintraege (
|
||||||
|
Reference in New Issue
Block a user