4 Commits

Author SHA1 Message Date
Adrian Zürcher
11b9c61113 new model 2025-11-20 10:43:49 +01:00
Adrian Zürcher
fe194754b1 change table to references 2025-11-20 10:40:56 +01:00
Adrian Zürcher
4a469d1fd4 add new group table to database 2025-11-13 16:20:04 +01:00
Adrian Zürcher
dd5d7afdff remove required birthday 2025-11-10 18:02:46 +01:00
18 changed files with 296 additions and 167 deletions

View File

@@ -73,6 +73,10 @@ func (a *APIHandler) OpenDatabase(c *gin.Context) {
return return
} }
if err := a.DbHandler.SetTimezone(os.Getenv("TIMEZONE")); err != nil {
a.logger.Error("OpenDatabase", err)
}
if err := a.DbHandler.AddNewTable(&models.Member{}); err != nil { if err := a.DbHandler.AddNewTable(&models.Member{}); err != nil {
a.logger.Error("OpenDatabase", err) a.logger.Error("OpenDatabase", err)
c.JSON(http.StatusInternalServerError, nil) c.JSON(http.StatusInternalServerError, nil)
@@ -85,7 +89,13 @@ func (a *APIHandler) OpenDatabase(c *gin.Context) {
return return
} }
if err := a.DbHandler.AddNewTable(&models.Person{}); err != nil { if err := a.DbHandler.AddNewTable(&models.Responsible{}); err != nil {
a.logger.Error("OpenDatabase", err)
c.JSON(http.StatusInternalServerError, nil)
return
}
if err := a.DbHandler.AddNewTable(&models.Group{}); err != nil {
a.logger.Error("OpenDatabase", err) a.logger.Error("OpenDatabase", err)
c.JSON(http.StatusInternalServerError, nil) c.JSON(http.StatusInternalServerError, nil)
return return

128
api/groupHandler.go Normal file
View File

@@ -0,0 +1,128 @@
package api
import (
"net/http"
"strconv"
"gitea.tecamino.com/paadi/memberDB/models"
"github.com/gin-gonic/gin"
)
func (a *APIHandler) NewGroup(c *gin.Context) {
if !a.DBHandlerIsInitialized() {
a.logger.Error("StartNewEvent", "database handler is not initialized")
c.JSON(http.StatusInternalServerError, nil)
return
}
var group models.Group
err := c.BindJSON(&group)
if err != nil {
a.logger.Error("NewGroup", err)
c.JSON(http.StatusInternalServerError, nil)
return
}
if err := a.DbHandler.NewGroup(&group); err != nil {
a.logger.Error("NewGroup", err)
c.JSON(http.StatusBadRequest, gin.H{"message": err.Error()})
return
}
c.JSON(http.StatusOK, gin.H{
"message": "New group added " + group.Name,
})
}
func (a *APIHandler) GetGroup(c *gin.Context) {
if !a.DBHandlerIsInitialized() {
a.logger.Error("GetGroup", "database handler is not initialized")
c.JSON(http.StatusInternalServerError, nil)
return
}
var i int
var err error
id := c.Query("id")
if id != "" {
i, err = strconv.Atoi(id)
if err != nil {
a.logger.Error("GetGroup", err)
c.JSON(http.StatusInternalServerError, nil)
return
}
}
groups, err := a.DbHandler.GetGroup(uint(i))
if err != nil {
a.logger.Error("GetGroup", err)
c.JSON(http.StatusBadRequest, nil)
return
}
c.JSON(http.StatusOK, groups)
}
func (a *APIHandler) UpdateGroup(c *gin.Context) {
if !a.DBHandlerIsInitialized() {
a.logger.Error("UpdateGroup", "database handler is not initialized")
c.JSON(http.StatusInternalServerError, nil)
return
}
var groups []models.Group
err := c.BindJSON(&groups)
if err != nil {
a.logger.Error("UpdateGroup", err)
c.JSON(http.StatusInternalServerError, nil)
return
}
for _, event := range groups {
err = a.DbHandler.UpdateGroup(event.Id, event)
if err != nil {
a.logger.Error("UpdateGroup", err)
c.JSON(http.StatusBadRequest, gin.H{
"message": err.Error(),
})
return
}
}
c.JSON(http.StatusOK, gin.H{
"message": "group(s) updated",
})
}
func (a *APIHandler) DeleteGroup(c *gin.Context) {
if !a.DBHandlerIsInitialized() {
a.logger.Error("DeleteGroup", "database handler is not initialized")
c.JSON(http.StatusInternalServerError, nil)
return
}
var err error
var request struct {
Ids []uint `json:"ids"`
}
err = c.BindJSON(&request)
if err != nil {
a.logger.Error("DeleteGroup", err)
c.JSON(http.StatusBadRequest, nil)
return
}
err = a.DbHandler.DeleteGroup(request.Ids...)
if err != nil {
a.logger.Error("DeleteGroup", err)
c.JSON(http.StatusBadRequest, gin.H{
"message": err.Error(),
})
return
}
c.JSON(http.StatusOK, gin.H{
"message": "group deleted",
})
}

View File

@@ -37,9 +37,7 @@ func (a *APIHandler) AddNewMember(c *gin.Context) {
if member.LastName == "" { if member.LastName == "" {
text += "lastName " text += "lastName "
} }
if member.Birthday == "" {
text += "birthday "
}
if text != "" { if text != "" {
a.logger.Error("AddNewMember", text+"can not be empty") a.logger.Error("AddNewMember", text+"can not be empty")
c.JSON(http.StatusBadRequest, gin.H{ c.JSON(http.StatusBadRequest, gin.H{

View File

@@ -16,7 +16,7 @@ func (a *APIHandler) AddNewResponsible(c *gin.Context) {
return return
} }
var responsibles []models.Person var responsibles []models.Responsible
err := c.BindJSON(&responsibles) err := c.BindJSON(&responsibles)
if err != nil { if err != nil {
a.logger.Error("AddNewResponsible", err) a.logger.Error("AddNewResponsible", err)
@@ -30,7 +30,6 @@ func (a *APIHandler) AddNewResponsible(c *gin.Context) {
"message": err.Error(), "message": err.Error(),
}) })
return return
} }
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{

2
go.mod
View File

@@ -3,7 +3,7 @@ module gitea.tecamino.com/paadi/memberDB
go 1.24.5 go 1.24.5
require ( require (
gitea.tecamino.com/paadi/dbHandler v1.0.8 gitea.tecamino.com/paadi/dbHandler v1.1.6
gitea.tecamino.com/paadi/tecamino-logger v0.2.1 gitea.tecamino.com/paadi/tecamino-logger v0.2.1
github.com/gin-contrib/cors v1.7.6 github.com/gin-contrib/cors v1.7.6
github.com/gin-gonic/gin v1.11.0 github.com/gin-gonic/gin v1.11.0

4
go.sum
View File

@@ -1,5 +1,5 @@
gitea.tecamino.com/paadi/dbHandler v1.0.8 h1:ZWSBM/KFtLwTv2cBqwK1mOxWAxAfL0BcWEC3kJ9JALU= gitea.tecamino.com/paadi/dbHandler v1.1.6 h1:Mz7ioUmozXx22oV3P7GHsvQn/2QKOjkNyzdptvqbaN8=
gitea.tecamino.com/paadi/dbHandler v1.0.8/go.mod h1:y/xn/POJg1DO++67uKvnO23lJQgh+XFQq7HZCS9Getw= gitea.tecamino.com/paadi/dbHandler v1.1.6/go.mod h1:y/xn/POJg1DO++67uKvnO23lJQgh+XFQq7HZCS9Getw=
gitea.tecamino.com/paadi/tecamino-logger v0.2.1 h1:sQTBKYPdzn9mmWX2JXZBtGBvNQH7cuXIwsl4TD0aMgE= gitea.tecamino.com/paadi/tecamino-logger v0.2.1 h1:sQTBKYPdzn9mmWX2JXZBtGBvNQH7cuXIwsl4TD0aMgE=
gitea.tecamino.com/paadi/tecamino-logger v0.2.1/go.mod h1:FkzRTldUBBOd/iy2upycArDftSZ5trbsX5Ira5OzJgM= gitea.tecamino.com/paadi/tecamino-logger v0.2.1/go.mod h1:FkzRTldUBBOd/iy2upycArDftSZ5trbsX5Ira5OzJgM=
github.com/bytedance/sonic v1.14.0 h1:/OfKt8HFw0kh2rj8N0F6C/qPGRESq0BbaNZgcNXXzQQ= github.com/bytedance/sonic v1.14.0 h1:/OfKt8HFw0kh2rj8N0F6C/qPGRESq0BbaNZgcNXXzQQ=

View File

@@ -4,6 +4,7 @@ import (
"crypto/hmac" "crypto/hmac"
"crypto/sha256" "crypto/sha256"
"encoding/hex" "encoding/hex"
"time"
"gitea.tecamino.com/paadi/dbHandler" "gitea.tecamino.com/paadi/dbHandler"
"gitea.tecamino.com/paadi/tecamino-logger/logging" "gitea.tecamino.com/paadi/tecamino-logger/logging"
@@ -11,6 +12,7 @@ import (
type DatabaseHandler struct { type DatabaseHandler struct {
database *dbHandler.DBHandler database *dbHandler.DBHandler
timeLocation *time.Location
token []byte token []byte
} }
@@ -23,6 +25,14 @@ func NewDatabaseHandler(name, path string, logger *logging.Logger) (*DatabaseHan
return &DatabaseHandler{database: database}, nil return &DatabaseHandler{database: database}, nil
} }
func (dH *DatabaseHandler) SetTimezone(timezone string) (err error) {
if timezone == "" {
timezone = "Local"
}
dH.timeLocation, err = time.LoadLocation(timezone)
return
}
func (dH *DatabaseHandler) DatabaseOpened() bool { func (dH *DatabaseHandler) DatabaseOpened() bool {
return dH.database != nil return dH.database != nil
} }

View File

@@ -2,10 +2,9 @@ package handlers
import ( import (
"errors" "errors"
"slices"
"time"
"gitea.tecamino.com/paadi/memberDB/models" "gitea.tecamino.com/paadi/memberDB/models"
"gitea.tecamino.com/paadi/memberDB/utils"
) )
func (dh *DatabaseHandler) StartNewEvent(event *models.Event) error { func (dh *DatabaseHandler) StartNewEvent(event *models.Event) error {
@@ -13,11 +12,12 @@ func (dh *DatabaseHandler) StartNewEvent(event *models.Event) error {
return errors.New("database not opened") return errors.New("database not opened")
} }
if dh.database.Exists(&models.Event{}, "name", event.Name, false) { if dh.database.Exists(&models.Event{}, "", "name", event.Name, false) {
return errors.New("event with name: " + event.Name + " exists already") return errors.New("event with name: " + event.Name + " exists already")
} }
event.Date = time.Now().Format("2006-01-02 15:04:05") event.Date = utils.GetCurrentTime(dh.timeLocation)
event.Day = utils.GetCurrentDay(dh.timeLocation)
return dh.database.AddNewColum(&event) return dh.database.AddNewColum(&event)
} }
@@ -26,14 +26,10 @@ func (dh *DatabaseHandler) GetEvent(id uint) (event []models.Event, err error) {
return event, errors.New("database not opened") return event, errors.New("database not opened")
} }
err = dh.database.GetById(&event, id) err = dh.database.GetById(&event, "Attendees", id)
if err != nil { if err != nil {
return return
} }
for i := range event {
event[i].Count = len(event[i].Attendees)
}
return return
} }
@@ -41,7 +37,7 @@ func (dh *DatabaseHandler) UpdateEvent(id int, event models.Event) (err error) {
if !dh.DatabaseOpened() { if !dh.DatabaseOpened() {
return errors.New("database not opened") return errors.New("database not opened")
} }
return dh.database.UpdateValuesById(&event, uint(event.Id)) return dh.database.UpdateValuesById(&event, "", uint(event.Id))
} }
func (dh *DatabaseHandler) DeleteEvent(ids ...uint) error { func (dh *DatabaseHandler) DeleteEvent(ids ...uint) error {
@@ -53,7 +49,7 @@ func (dh *DatabaseHandler) DeleteEvent(ids ...uint) error {
return errors.New("no ids given to be deleted") return errors.New("no ids given to be deleted")
} }
return dh.database.DeleteById(&models.Event{}, ids...) return dh.database.DeleteById(&models.Event{}, "", ids...)
} }
func (dh *DatabaseHandler) AddAttendeesToEvent(newEvent models.Event) error { func (dh *DatabaseHandler) AddAttendeesToEvent(newEvent models.Event) error {
@@ -62,24 +58,24 @@ func (dh *DatabaseHandler) AddAttendeesToEvent(newEvent models.Event) error {
} }
var event models.Event var event models.Event
err := dh.database.GetById(&event, uint(newEvent.Id)) err := dh.database.GetById(&event, "Attendees", uint(newEvent.Id))
if err != nil { if err != nil {
return err return err
} }
next: next:
for _, newAttendee := range newEvent.Attendees { for _, newAttendee := range newEvent.Attendees {
if !dh.database.Exists(&models.Member{}, "", "id", newAttendee.Id, false) {
continue
}
for _, attendee := range event.Attendees { for _, attendee := range event.Attendees {
if attendee.FirstName == newAttendee.FirstName && attendee.LastName == newAttendee.LastName { if attendee.FirstName == newAttendee.FirstName && attendee.LastName == newAttendee.LastName {
continue next continue next
} }
} }
event.Attendees = append(event.Attendees, newAttendee) dh.database.AddRelation(&event, newAttendee, "Attendees")
} }
return nil
event.Count = len(event.Attendees)
return dh.database.UpdateValuesById(&event, uint(newEvent.Id))
} }
func (dh *DatabaseHandler) DeleteAttendeesFromEvent(newEvent models.Event) error { func (dh *DatabaseHandler) DeleteAttendeesFromEvent(newEvent models.Event) error {
@@ -88,17 +84,14 @@ func (dh *DatabaseHandler) DeleteAttendeesFromEvent(newEvent models.Event) error
} }
var event models.Event var event models.Event
dh.database.GetById(&event, uint(newEvent.Id)) dh.database.GetById(&event, "Attendees", uint(newEvent.Id))
next:
for _, newAttendee := range newEvent.Attendees { for _, newAttendee := range newEvent.Attendees {
for i := range event.Attendees { for _, a := range event.Attendees {
if event.Attendees[i].FirstName == newAttendee.FirstName && event.Attendees[i].LastName == newAttendee.LastName { if a.FirstName == newAttendee.FirstName && a.LastName == newAttendee.LastName {
event.Attendees = slices.Delete(event.Attendees, i, i+1) dh.database.DeleteRelation(&event, a, "Attendees")
continue next
} }
} }
} }
event.Count = len(event.Attendees) return nil
return dh.database.UpdateValuesById(&event, uint(newEvent.Id))
} }

49
handlers/group.go Normal file
View File

@@ -0,0 +1,49 @@
package handlers
import (
"errors"
"gitea.tecamino.com/paadi/memberDB/models"
)
func (dh *DatabaseHandler) NewGroup(group *models.Group) error {
if !dh.DatabaseOpened() {
return errors.New("database not opened")
}
if dh.database.Exists(&models.Group{}, "", "name", group.Name, false) {
return errors.New("group with name: " + group.Name + " exists already")
}
return dh.database.AddNewColum(&group)
}
func (dh *DatabaseHandler) GetGroup(id uint) (group []models.Group, err error) {
if !dh.DatabaseOpened() {
return group, errors.New("database not opened")
}
err = dh.database.GetById(&group, "", id)
if err != nil {
return
}
return
}
func (dh *DatabaseHandler) UpdateGroup(id int, group models.Group) (err error) {
if !dh.DatabaseOpened() {
return errors.New("database not opened")
}
return dh.database.UpdateValuesById(&group, "", uint(group.Id))
}
func (dh *DatabaseHandler) DeleteGroup(ids ...uint) error {
if !dh.DatabaseOpened() {
return errors.New("database not opened")
}
if len(ids) == 0 {
return errors.New("no ids given to be deleted")
}
return dh.database.DeleteById(&models.Group{}, "", ids...)
}

View File

@@ -3,7 +3,6 @@ package handlers
import ( import (
"errors" "errors"
"fmt" "fmt"
"time"
"gitea.tecamino.com/paadi/memberDB/crypto" "gitea.tecamino.com/paadi/memberDB/crypto"
"gitea.tecamino.com/paadi/memberDB/models" "gitea.tecamino.com/paadi/memberDB/models"
@@ -75,7 +74,7 @@ func (dh *DatabaseHandler) AddNewMember(members ...models.Member) error {
return err return err
} }
now := time.Now().Format("2006-01-02 15:04:05") now := utils.GetCurrentTime(dh.timeLocation)
encFirstVisit, err := crypto.Encrypt(now, dh.token) encFirstVisit, err := crypto.Encrypt(now, dh.token)
if err != nil { if err != nil {
return err return err
@@ -86,11 +85,6 @@ func (dh *DatabaseHandler) AddNewMember(members ...models.Member) error {
return err return err
} }
encGroup, err := crypto.Encrypt(member.Group, dh.token)
if err != nil {
return err
}
encComment, err := crypto.Encrypt(member.Comment, dh.token) encComment, err := crypto.Encrypt(member.Comment, dh.token)
if err != nil { if err != nil {
return err return err
@@ -109,7 +103,6 @@ func (dh *DatabaseHandler) AddNewMember(members ...models.Member) error {
member.Email = encEmail member.Email = encEmail
member.FirstVisit = encFirstVisit member.FirstVisit = encFirstVisit
member.LastVisit = encLastVisit member.LastVisit = encLastVisit
member.Group = encGroup
member.Comment = encComment member.Comment = encComment
err = dh.database.AddNewColum(&member) err = dh.database.AddNewColum(&member)
@@ -129,7 +122,7 @@ func (dh *DatabaseHandler) DeleteMember(ids ...uint) error {
if len(ids) == 0 { if len(ids) == 0 {
return errors.New("no ids given to be deleted") return errors.New("no ids given to be deleted")
} }
return dh.database.DeleteById(&models.Member{}, ids...) return dh.database.DeleteById(&models.Member{}, "", ids...)
} }
// GetMember returns one member by given id // GetMember returns one member by given id
@@ -138,7 +131,7 @@ func (dh *DatabaseHandler) GetMember(id uint) (members []models.Member, err erro
return members, errors.New("database not opened") return members, errors.New("database not opened")
} }
err = dh.database.GetById(&members, id) err = dh.database.GetById(&members, "", id)
if err != nil { if err != nil {
return return
} }
@@ -214,13 +207,6 @@ func (dh *DatabaseHandler) GetMember(id uint) (members []models.Member, err erro
} }
} }
if members[i].Group != "" {
members[i].Group, err = crypto.Decrypt(members[i].Group, dh.token)
if err != nil {
return
}
}
if members[i].Comment != "" { if members[i].Comment != "" {
members[i].Comment, err = crypto.Decrypt(members[i].Comment, dh.token) members[i].Comment, err = crypto.Decrypt(members[i].Comment, dh.token)
if err != nil { if err != nil {
@@ -316,20 +302,13 @@ func (dh *DatabaseHandler) UpdateMember(id int, member models.Member) (err error
} }
} }
if member.Group != "" {
member.Group, err = crypto.Encrypt(member.Group, dh.token)
if err != nil {
return err
}
}
if member.Comment != "" { if member.Comment != "" {
member.Comment, err = crypto.Encrypt(member.Comment, dh.token) member.Comment, err = crypto.Encrypt(member.Comment, dh.token)
if err != nil { if err != nil {
return err return err
} }
} }
return dh.database.UpdateValuesById(&member, uint(member.Id)) return dh.database.UpdateValuesById(&member, "", uint(member.Id))
} }
// memberExists helper to check wheter member already exists // memberExists helper to check wheter member already exists
@@ -339,7 +318,7 @@ func (dh *DatabaseHandler) memberExists(checkMember models.Member) (bool, error)
} }
var members []models.Member var members []models.Member
if !dh.database.Exists(&members, "birthdayHash", dh.hashField(checkMember.Birthday), false) { if !dh.database.Exists(&members, "", "birthdayHash", dh.hashField(checkMember.Birthday), false) {
return false, nil return false, nil
} }

View File

@@ -6,35 +6,31 @@ import (
"gitea.tecamino.com/paadi/memberDB/models" "gitea.tecamino.com/paadi/memberDB/models"
) )
func (dh *DatabaseHandler) AddNewResponsible(responsibles ...models.Person) error { func (dh *DatabaseHandler) AddNewResponsible(responsibles ...models.Responsible) error {
if !dh.DatabaseOpened() { if !dh.DatabaseOpened() {
return errors.New("database not opened") return errors.New("database not opened")
} }
for _, responsible := range responsibles { for i := range responsibles {
// set id to 0 so new uniq id is created if !dh.database.Exists(&models.Member{}, "", "id", 25, false) {
responsible.Id = 0
exists, err := dh.responsibleExists(responsible)
if err != nil {
return err
} else if exists {
continue continue
} }
err = dh.database.AddNewColum(&responsible) err := dh.database.AddNewColum(&responsibles[i])
if err != nil { if err != nil {
return err return err
} }
} }
return nil return nil
} }
func (dh *DatabaseHandler) GetResponsible(id uint) (persons []models.Person, err error) { func (dh *DatabaseHandler) GetResponsible(id uint) (responsibles models.Responsibles, err error) {
if !dh.DatabaseOpened() { if !dh.DatabaseOpened() {
return persons, errors.New("database not opened") return responsibles, errors.New("database not opened")
} }
err = dh.database.GetById(&persons, id) err = dh.database.GetById(&responsibles, "Member", id)
return return
} }
@@ -46,23 +42,5 @@ func (dh *DatabaseHandler) DeleteResponsible(ids ...uint) error {
if len(ids) == 0 { if len(ids) == 0 {
return errors.New("no ids given to be deleted") return errors.New("no ids given to be deleted")
} }
return dh.database.DeleteById(&models.Person{}, ids...) return dh.database.DeleteById(&models.Responsible{}, "", ids...)
}
func (dh *DatabaseHandler) responsibleExists(CheckResponsible models.Person) (bool, error) {
if !dh.DatabaseOpened() {
return false, errors.New("database not opened")
}
var persons []models.Person
if !dh.database.Exists(&persons, "lastName", CheckResponsible.LastName, false) {
return false, nil
}
for _, person := range persons {
if person.FirstName == CheckResponsible.FirstName && person.LastName == CheckResponsible.LastName {
return true, nil
}
}
return false, nil
} }

View File

@@ -175,22 +175,23 @@ func TestMemberDB(t *testing.T) {
request{Log: "add existing member", Name: "add existing member", Method: "POST", Path: "/v1/members/add", Payload: payload{FirstName: "Adrian", LastName: "Zürcher", Birthday: "23.06.1987"}, ignoreError: true}, request{Log: "add existing member", Name: "add existing member", Method: "POST", Path: "/v1/members/add", Payload: payload{FirstName: "Adrian", LastName: "Zürcher", Birthday: "23.06.1987"}, ignoreError: true},
request{Log: "add new member", Name: "add new member", Method: "POST", Path: "/v1/members/add", Payload: payload{FirstName: "Paulina", LastName: "Zürcher", Birthday: "15.01.1991"}}, request{Log: "add new member", Name: "add new member", Method: "POST", Path: "/v1/members/add", Payload: payload{FirstName: "Paulina", LastName: "Zürcher", Birthday: "15.01.1991"}},
request{Log: "get members", Name: "get members", Method: "GET", Path: "/v1/members"}, request{Log: "get members", Name: "get members", Method: "GET", Path: "/v1/members"},
request{Log: "update members", Name: "update members", Method: "POST", Path: "/v1/members/edit?id=1", Payload: payload{Group: "testGroup"}}, request{Log: "update members", Name: "update members", Method: "POST", Path: "/v1/members/edit?id=1", Payload: []models.Member{{Group: &models.Group{Name: "testGroup"}}}},
request{Log: "get again members", Name: "get again members", Method: "GET", Path: "/v1/members"}, request{Log: "get again members", Name: "get again members", Method: "GET", Path: "/v1/members"},
request{Log: "delete members", Name: "delete members", Method: "POST", Path: "/v1/members/delete", Payload: payload{Ids: []uint{2, 1}}}, //request{Log: "delete members", Name: "delete members", Method: "POST", Path: "/v1/members/delete", Payload: payload{Ids: []uint{2, 1}}},
request{Log: "get again members", Name: "get again members", Method: "GET", Path: "/v1/members"}, request{Log: "get again members", Name: "get again members", Method: "GET", Path: "/v1/members"},
request{Log: "new event", Name: "new event", Method: "GET", Path: "/v1/events/new?name=testEvent"}, request{Log: "new event", Name: "new event", Method: "POST", Path: "/v1/events/new", Payload: models.Event{Name: "testEvent"}},
request{Log: "add new attendee", Name: "add new attendee", Method: "POST", Path: "/v1/events/attendees/add", Payload: models.Event{Attendees: models.Persons{{FirstName: "Adi", LastName: "Züri"}}}}, request{Log: "add new attendee", Name: "add new attendee", Method: "POST", Path: "/v1/events/attendees/add", Payload: models.Event{Attendees: []*models.Member{{Id: 26}}}},
request{Log: "add another attendee", Name: "add another attendee", Method: "POST", Path: "/v1/events/attendees/add", Payload: models.Event{Attendees: models.Persons{{FirstName: "Pau", LastName: "Züri"}}}}, request{Log: "add another attendee", Name: "add another attendee", Method: "POST", Path: "/v1/events/attendees/add", Payload: models.Event{Attendees: []*models.Member{{Id: 2}}}},
request{Log: "get events", Name: "get events", Method: "GET", Path: "/v1/events"}, request{Log: "get events", Name: "get events", Method: "GET", Path: "/v1/events"},
request{Log: "add delete attendee", Name: "add delete attendee", Method: "POST", Path: "/v1/events/attendees/delete", Payload: models.Event{Attendees: models.Persons{{FirstName: "Adi", LastName: "Züri"}}}}, //request{Log: "delete attendee", Name: "add delete attendee", Method: "POST", Path: "/v1/events/attendees/delete", Payload: models.Event{Attendees: []*models.Member{{FirstName: "Adi", LastName: "Züri"}}}},
request{Log: "get events", Name: "get events", Method: "GET", Path: "/v1/events"}, request{Log: "get events", Name: "get events", Method: "GET", Path: "/v1/events"},
request{Log: "add responsible", Name: "add responsible", Method: "POST", Path: "/v1/responsible/add", Payload: models.Person{FirstName: "Max", LastName: "Muster"}}, //request{Log: "add responsible", Name: "add responsible", Method: "POST", Path: "/v1/responsible/add", Payload: models.Responsibles{models.Responsible{Member: &models.Member{FirstName: "Adi", LastName: "Züri"}}}},
request{Log: "add another responsible", Name: "add another responsible", Method: "POST", Path: "/v1/responsible/add", Payload: models.Person{FirstName: "Hausi", LastName: "Muster"}}, request{Log: "add another responsible", Name: "add another responsible", Method: "POST", Path: "/v1/responsible/add", Payload: models.Responsibles{models.Responsible{MemberId: 1}}},
request{Log: "add another responsible", Name: "add another responsible", Method: "POST", Path: "/v1/responsible/add", Payload: models.Responsibles{models.Responsible{MemberId: 25}}},
request{Log: "get responsible", Name: "get responsible", Method: "GET", Path: "/v1/responsible"}, request{Log: "get responsible", Name: "get responsible", Method: "GET", Path: "/v1/responsible"},
request{Log: "delete responsible id 1", Name: "delete responsible id 1", Method: "POST", Path: "/v1/responsible/delete", Payload: payload{Ids: []uint{1}}}, //request{Log: "delete responsible id 1", Name: "delete responsible id 1", Method: "POST", Path: "/v1/responsible/delete", Payload: payload{Ids: []uint{1}}},
request{Log: "get responsible", Name: "get responsible", Method: "GET", Path: "/v1/responsible"}, request{Log: "get responsible", Name: "get responsible", Method: "GET", Path: "/v1/responsible"},
) )

View File

@@ -4,6 +4,6 @@ type Event struct {
Id int `gorm:"primaryKey" json:"id"` Id int `gorm:"primaryKey" json:"id"`
Name string `gorm:"column:name" json:"name"` Name string `gorm:"column:name" json:"name"`
Date string `gorm:"column:date" json:"date"` Date string `gorm:"column:date" json:"date"`
Attendees Persons `gorm:"type:json" json:"attendees"` Day string `gorm:"column:day" json:"day"`
Count int `gorm:"column:count" json:"count"` Attendees []*Member `gorm:"many2many:member_events;"`
} }

6
models/group.go Normal file
View File

@@ -0,0 +1,6 @@
package models
type Group struct {
Id int `gorm:"primaryKey" json:"id"`
Name string `gorm:"column:name" json:"name"`
}

View File

@@ -1,7 +1,7 @@
package models package models
type Member struct { type Member struct {
Id int `gorm:"primaryKey" json:"id"` Id int `gorm:"primaryKey" json:"id,omitempty"`
FirstName string `gorm:"column:firstName" json:"firstName,omitempty"` FirstName string `gorm:"column:firstName" json:"firstName,omitempty"`
FirstNameHash string `gorm:"column:firstNameHash" json:"-"` FirstNameHash string `gorm:"column:firstNameHash" json:"-"`
LastName string `gorm:"column:lastName" json:"lastName,omitempty"` LastName string `gorm:"column:lastName" json:"lastName,omitempty"`
@@ -15,7 +15,10 @@ type Member struct {
Email string `gorm:"column:email" json:"email,omitempty"` Email string `gorm:"column:email" json:"email,omitempty"`
FirstVisit string `gorm:"column:firstVisit" json:"firstVisit,omitempty"` FirstVisit string `gorm:"column:firstVisit" json:"firstVisit,omitempty"`
LastVisit string `gorm:"column:lastVisit" json:"lastVisit,omitempty"` LastVisit string `gorm:"column:lastVisit" json:"lastVisit,omitempty"`
Group string `gorm:"column:group" json:"group,omitempty"` GroupId *int `json:"GroupId,omitempty"`
ResponsiblePerson Person `gorm:"type:json" json:"responsiblePerson"` Group *Group `gorm:"foreignKey:GroupId" json:"group,omitempty"`
Comment string `gorm:"column:comment" json:"comment"` ResponsibleId *int `json:"ResponsibleId,omitempty"`
Responsible *Member `gorm:"foreignKey:ResponsibleId" json:"responsible,omitempty"`
Comment string `gorm:"column:comment" json:"comment,omitempty"`
Events []*Event `gorm:"many2many:member_events;" `
} }

View File

@@ -1,43 +0,0 @@
package models
import (
"database/sql/driver"
"encoding/json"
"fmt"
)
type Persons []Person
// --- Implement driver.Valuer (for saving to DB)
func (r Persons) Value() (driver.Value, error) {
return json.Marshal(r)
}
// --- Implement sql.Scanner (for reading from DB)
func (r *Persons) Scan(value any) error {
bytes, ok := value.([]byte)
if !ok {
return fmt.Errorf("failed to unmarshal Settings: %v", value)
}
return json.Unmarshal(bytes, r)
}
type Person struct {
Id int `gorm:"primaryKey" json:"id"`
FirstName string `gorm:"column:firstName" json:"firstName"`
LastName string `gorm:"column:lastName" json:"lastName"`
}
// --- Implement driver.Valuer (for saving to DB)
func (r Person) Value() (driver.Value, error) {
return json.Marshal(r)
}
// --- Implement sql.Scanner (for reading from DB)
func (r *Person) Scan(value any) error {
bytes, ok := value.([]byte)
if !ok {
return fmt.Errorf("failed to unmarshal Settings: %v", value)
}
return json.Unmarshal(bytes, r)
}

9
models/responsible.go Normal file
View File

@@ -0,0 +1,9 @@
package models
type Responsible struct {
Id uint `gorm:"primaryKey"`
MemberId uint
Member *Member `gorm:"foreignKey:MemberId"`
}
type Responsibles []Responsible

View File

@@ -1,6 +1,7 @@
package utils package utils
import ( import (
"fmt"
"net/mail" "net/mail"
"time" "time"
) )
@@ -25,3 +26,11 @@ func IsValidBirthday(birthday string) bool {
} }
return false return false
} }
func GetCurrentTime(loc *time.Location) string {
return time.Now().In(loc).Format("2006-01-02 15:04:05")
}
func GetCurrentDay(loc *time.Location) string {
return fmt.Sprint(time.Now().In(loc).Weekday())
}