Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
2223b96432 | ||
|
|
21388b63fb | ||
|
|
86a4ef798a | ||
|
|
442afcb44c | ||
|
|
8b8d99e162 | ||
|
|
103a07b7ac | ||
|
|
a20a21d251 | ||
|
|
ee7ce526f3 | ||
|
|
a938f41e94 | ||
|
|
1d09705adb |
@@ -15,22 +15,23 @@ func (a *APIHandler) StartNewEvent(c *gin.Context) {
|
||||
return
|
||||
}
|
||||
|
||||
name := c.Query("name")
|
||||
if name == "" {
|
||||
a.logger.Error("StartNewEvent", "missing query 'name'")
|
||||
|
||||
var event models.Event
|
||||
err := c.BindJSON(&event)
|
||||
if err != nil {
|
||||
a.logger.Error("StartNewEvent", err)
|
||||
c.JSON(http.StatusInternalServerError, nil)
|
||||
return
|
||||
}
|
||||
|
||||
if err := a.DbHandler.StartNewEvent(name); err != nil {
|
||||
if err := a.DbHandler.StartNewEvent(&event); err != nil {
|
||||
a.logger.Error("StartNewEvent", err)
|
||||
c.JSON(http.StatusBadRequest, gin.H{"message": err.Error()})
|
||||
return
|
||||
}
|
||||
|
||||
c.JSON(http.StatusOK, gin.H{
|
||||
"message": "New Event added " + name,
|
||||
"message": "New Event added " + event.Name,
|
||||
"data": event,
|
||||
})
|
||||
}
|
||||
|
||||
@@ -65,6 +66,36 @@ func (a *APIHandler) GetEvent(c *gin.Context) {
|
||||
c.JSON(http.StatusOK, events)
|
||||
}
|
||||
|
||||
func (a *APIHandler) UpdateEvent(c *gin.Context) {
|
||||
if !a.DBHandlerIsInitialized() {
|
||||
a.logger.Error("UpdateEvent", "database handler is not initialized")
|
||||
c.JSON(http.StatusInternalServerError, nil)
|
||||
return
|
||||
}
|
||||
|
||||
var events []models.Event
|
||||
err := c.BindJSON(&events)
|
||||
if err != nil {
|
||||
a.logger.Error("UpdateEvent", err)
|
||||
c.JSON(http.StatusInternalServerError, nil)
|
||||
return
|
||||
}
|
||||
|
||||
for _, event := range events {
|
||||
err = a.DbHandler.UpdateEvent(event.Id, event)
|
||||
if err != nil {
|
||||
a.logger.Error("UpdateEvent", err)
|
||||
c.JSON(http.StatusBadRequest, gin.H{
|
||||
"message": err.Error(),
|
||||
})
|
||||
return
|
||||
}
|
||||
}
|
||||
c.JSON(http.StatusOK, gin.H{
|
||||
"message": "event(s) updated",
|
||||
})
|
||||
}
|
||||
|
||||
func (a *APIHandler) DeleteEvent(c *gin.Context) {
|
||||
if !a.DBHandlerIsInitialized() {
|
||||
a.logger.Error("DeleteEvent", "database handler is not initialized")
|
||||
|
||||
@@ -16,24 +16,25 @@ func (a *APIHandler) AddNewResponsible(c *gin.Context) {
|
||||
return
|
||||
}
|
||||
|
||||
var responsible models.Person
|
||||
err := c.BindJSON(&responsible)
|
||||
var responsibles []models.Person
|
||||
err := c.BindJSON(&responsibles)
|
||||
if err != nil {
|
||||
a.logger.Error("AddNewResponsible", err)
|
||||
c.JSON(http.StatusInternalServerError, nil)
|
||||
return
|
||||
}
|
||||
|
||||
err = a.DbHandler.AddNewResponsible(responsible)
|
||||
err = a.DbHandler.AddNewResponsible(responsibles...)
|
||||
if err != nil {
|
||||
c.JSON(http.StatusBadRequest, gin.H{
|
||||
"message": err.Error(),
|
||||
})
|
||||
return
|
||||
|
||||
}
|
||||
|
||||
c.JSON(http.StatusOK, gin.H{
|
||||
"message": "responsible added",
|
||||
"message": "responsible(s) added",
|
||||
})
|
||||
}
|
||||
|
||||
|
||||
2
go.mod
2
go.mod
@@ -3,7 +3,7 @@ module gitea.tecamino.com/paadi/memberDB
|
||||
go 1.24.5
|
||||
|
||||
require (
|
||||
gitea.tecamino.com/paadi/dbHandler v1.0.4
|
||||
gitea.tecamino.com/paadi/dbHandler v1.0.8
|
||||
gitea.tecamino.com/paadi/tecamino-logger v0.2.1
|
||||
github.com/gin-contrib/cors v1.7.6
|
||||
github.com/gin-gonic/gin v1.11.0
|
||||
|
||||
4
go.sum
4
go.sum
@@ -1,5 +1,5 @@
|
||||
gitea.tecamino.com/paadi/dbHandler v1.0.4 h1:ctnaec0GDdtw3gRQdUISVDYLJ9x+vt50VW41OemfhD4=
|
||||
gitea.tecamino.com/paadi/dbHandler v1.0.4/go.mod h1:y/xn/POJg1DO++67uKvnO23lJQgh+XFQq7HZCS9Getw=
|
||||
gitea.tecamino.com/paadi/dbHandler v1.0.8 h1:ZWSBM/KFtLwTv2cBqwK1mOxWAxAfL0BcWEC3kJ9JALU=
|
||||
gitea.tecamino.com/paadi/dbHandler v1.0.8/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/go.mod h1:FkzRTldUBBOd/iy2upycArDftSZ5trbsX5Ira5OzJgM=
|
||||
github.com/bytedance/sonic v1.14.0 h1:/OfKt8HFw0kh2rj8N0F6C/qPGRESq0BbaNZgcNXXzQQ=
|
||||
|
||||
@@ -8,19 +8,17 @@ import (
|
||||
"gitea.tecamino.com/paadi/memberDB/models"
|
||||
)
|
||||
|
||||
func (dh *DatabaseHandler) StartNewEvent(name string) error {
|
||||
func (dh *DatabaseHandler) StartNewEvent(event *models.Event) error {
|
||||
if !dh.DatabaseOpened() {
|
||||
return errors.New("database not opened")
|
||||
}
|
||||
|
||||
if nil == dh.database.Exists(&models.Event{}, "name", name, false) {
|
||||
return errors.New("event with name: " + name + " exists already")
|
||||
if dh.database.Exists(&models.Event{}, "name", event.Name, false) {
|
||||
return errors.New("event with name: " + event.Name + " exists already")
|
||||
}
|
||||
|
||||
return dh.database.AddNewColum(&models.Event{
|
||||
Name: name,
|
||||
Date: time.Now().Format("2006-01-02 15:04:05"),
|
||||
})
|
||||
event.Date = time.Now().Format("2006-01-02 15:04:05")
|
||||
return dh.database.AddNewColum(&event)
|
||||
}
|
||||
|
||||
func (dh *DatabaseHandler) GetEvent(id uint) (event []models.Event, err error) {
|
||||
@@ -39,6 +37,13 @@ func (dh *DatabaseHandler) GetEvent(id uint) (event []models.Event, err error) {
|
||||
return
|
||||
}
|
||||
|
||||
func (dh *DatabaseHandler) UpdateEvent(id int, event models.Event) (err error) {
|
||||
if !dh.DatabaseOpened() {
|
||||
return errors.New("database not opened")
|
||||
}
|
||||
return dh.database.UpdateValuesById(&event, uint(event.Id))
|
||||
}
|
||||
|
||||
func (dh *DatabaseHandler) DeleteEvent(ids ...uint) error {
|
||||
if !dh.DatabaseOpened() {
|
||||
return errors.New("database not opened")
|
||||
|
||||
@@ -91,11 +91,6 @@ func (dh *DatabaseHandler) AddNewMember(members ...models.Member) error {
|
||||
return err
|
||||
}
|
||||
|
||||
encResponsiblePerson, err := crypto.Encrypt(member.ResponsiblePerson, dh.token)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
member.FirstNameHash = dh.hashField(member.FirstName)
|
||||
member.FirstName = encFirstName
|
||||
member.LastNameHash = dh.hashField(member.LastName)
|
||||
@@ -110,7 +105,6 @@ func (dh *DatabaseHandler) AddNewMember(members ...models.Member) error {
|
||||
member.FirstVisit = encFirstVisit
|
||||
member.LastVisit = encLastVisit
|
||||
member.Group = encGroup
|
||||
member.ResponsiblePerson = encResponsiblePerson
|
||||
|
||||
err = dh.database.AddNewColum(&member)
|
||||
if err != nil {
|
||||
@@ -198,11 +192,6 @@ func (dh *DatabaseHandler) GetMember(id uint) (members []models.Member, err erro
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
members[i].ResponsiblePerson, err = crypto.Decrypt(members[i].ResponsiblePerson, dh.token)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
}
|
||||
return
|
||||
}
|
||||
@@ -298,13 +287,6 @@ func (dh *DatabaseHandler) UpdateMember(id int, member models.Member) (err error
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
if member.ResponsiblePerson != "" {
|
||||
member.ResponsiblePerson, err = crypto.Encrypt(member.ResponsiblePerson, dh.token)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
return dh.database.UpdateValuesById(&member, uint(member.Id))
|
||||
}
|
||||
|
||||
@@ -315,8 +297,7 @@ func (dh *DatabaseHandler) memberExists(checkMember models.Member) (bool, error)
|
||||
}
|
||||
|
||||
var member models.Member
|
||||
err := dh.database.Exists(&member, "birthdayHash", dh.hashField(checkMember.Birthday), false)
|
||||
if err != nil {
|
||||
if !dh.database.Exists(&member, "birthdayHash", dh.hashField(checkMember.Birthday), false) {
|
||||
return false, nil
|
||||
}
|
||||
return dh.hashField(checkMember.FirstName) == member.FirstNameHash && dh.hashField(checkMember.LastName) == member.LastNameHash && dh.hashField(checkMember.Birthday) == member.BirthdayHash, nil
|
||||
|
||||
@@ -10,11 +10,10 @@ func (dh *DatabaseHandler) AddNewResponsible(responsibles ...models.Person) erro
|
||||
if !dh.DatabaseOpened() {
|
||||
return errors.New("database not opened")
|
||||
}
|
||||
if !dh.DatabaseOpened() {
|
||||
return errors.New("database not opened")
|
||||
}
|
||||
for _, responsible := range responsibles {
|
||||
|
||||
for _, responsible := range responsibles {
|
||||
// set id to 0 so new uniq id is created
|
||||
responsible.Id = 0
|
||||
exists, err := dh.responsibleExists(responsible)
|
||||
if err != nil {
|
||||
return err
|
||||
@@ -56,8 +55,7 @@ func (dh *DatabaseHandler) responsibleExists(CheckResponsible models.Person) (bo
|
||||
}
|
||||
|
||||
var person models.Person
|
||||
err := dh.database.Exists(&person, "lastName", CheckResponsible.LastName, false)
|
||||
if err != nil {
|
||||
if !dh.database.Exists(&person, "lastName", CheckResponsible.LastName, false) {
|
||||
return false, nil
|
||||
}
|
||||
return person.FirstName == CheckResponsible.FirstName && person.LastName == CheckResponsible.LastName, nil
|
||||
|
||||
@@ -129,19 +129,20 @@ func TestMemberDB(t *testing.T) {
|
||||
|
||||
v1 := r.Group("v1")
|
||||
v1.GET("/events", apiHandler.GetEvent)
|
||||
v1.GET("/events/new", apiHandler.StartNewEvent)
|
||||
v1.GET("/events/delete", apiHandler.DeleteEvent)
|
||||
v1.GET("/members", apiHandler.GetMember)
|
||||
v1.GET("/responsible", apiHandler.GetResponsible)
|
||||
|
||||
v1.POST("/database/open", apiHandler.OpenDatabase)
|
||||
v1.POST("/members/add", apiHandler.AddNewMember)
|
||||
v1.POST("/members/edit", apiHandler.EditMember)
|
||||
v1.POST("/members/edit", apiHandler.UpdateMember)
|
||||
v1.POST("/members/delete", apiHandler.DeleteMember)
|
||||
v1.POST("/members/import/csv", apiHandler.ImportCSV)
|
||||
|
||||
v1.POST("/events/new", apiHandler.StartNewEvent)
|
||||
v1.POST("/events/attendees/add", apiHandler.AddNewAttendees)
|
||||
v1.POST("/events/attendees/delete", apiHandler.DeleteAttendee)
|
||||
v1.POST("/events/edit", apiHandler.UpdateEvent)
|
||||
v1.POST("/events/delete", apiHandler.DeleteEvent)
|
||||
|
||||
v1.POST("/responsible/add", apiHandler.AddNewResponsible)
|
||||
v1.POST("/responsible/delete", apiHandler.DeleteResponsible)
|
||||
|
||||
@@ -16,5 +16,5 @@ type Member struct {
|
||||
FirstVisit string `gorm:"column:firstVisit" json:"firstVisit,omitempty"`
|
||||
LastVisit string `gorm:"column:lastVisit" json:"lastVisit,omitempty"`
|
||||
Group string `gorm:"column:group" json:"group,omitempty"`
|
||||
ResponsiblePerson string `gorm:"column:responsiblePerson" json:"responsiblePerson,omitempty"`
|
||||
ResponsiblePerson Person `gorm:"type:json" json:"responsiblePerson"`
|
||||
}
|
||||
|
||||
@@ -8,12 +8,6 @@ import (
|
||||
|
||||
type Persons []Person
|
||||
|
||||
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 Persons) Value() (driver.Value, error) {
|
||||
return json.Marshal(r)
|
||||
@@ -27,3 +21,23 @@ func (r *Persons) Scan(value any) error {
|
||||
}
|
||||
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)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user