Compare commits
14 Commits
v1.1.11
...
ce8d17b3c9
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ce8d17b3c9 | ||
|
|
376ba27a9c | ||
|
|
f2d20e83d6 | ||
|
|
81e05851bc | ||
|
|
349b17551d | ||
|
|
c1572c5ec6 | ||
|
|
108eae597b | ||
|
|
5a0d7a5e84 | ||
|
|
cd5d93a1bb | ||
|
|
8400f29f7e | ||
|
|
4d86d9a8a0 | ||
|
|
c94f47060d | ||
|
|
5832df28c9 | ||
|
|
55653d996b |
141
api/reportHandler.go
Normal file
141
api/reportHandler.go
Normal file
@@ -0,0 +1,141 @@
|
|||||||
|
package api
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net/http"
|
||||||
|
"slices"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"gitea.tecamino.com/paadi/memberDB/models"
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
|
)
|
||||||
|
|
||||||
|
type counter struct {
|
||||||
|
event int
|
||||||
|
total int
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *APIHandler) GetReport(c *gin.Context) {
|
||||||
|
if !a.DBHandlerIsInitialized() {
|
||||||
|
a.logger.Error("GetReport", "database handler is not initialized")
|
||||||
|
c.JSON(http.StatusInternalServerError, nil)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
var err error
|
||||||
|
var report models.Report
|
||||||
|
var request models.ReportFilter
|
||||||
|
|
||||||
|
err = c.BindJSON(&request)
|
||||||
|
if err != nil {
|
||||||
|
a.logger.Error("GetReport", err)
|
||||||
|
c.JSON(http.StatusBadRequest, nil)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(request.Date) == 0 {
|
||||||
|
c.JSON(http.StatusOK, gin.H{
|
||||||
|
"data": report,
|
||||||
|
})
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
var events []models.Event
|
||||||
|
|
||||||
|
if len(request.Name) > 0 {
|
||||||
|
events, err = a.DbHandler.GetEventByKey("name", request.Name, true)
|
||||||
|
} else {
|
||||||
|
events, err = a.DbHandler.GetEvent(0)
|
||||||
|
}
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
a.logger.Error("GetReport", err)
|
||||||
|
c.JSON(http.StatusBadRequest, gin.H{
|
||||||
|
"message": err.Error(),
|
||||||
|
})
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
report.Data = make(map[string]*models.Data)
|
||||||
|
|
||||||
|
//helper
|
||||||
|
count := make(map[string]*counter)
|
||||||
|
|
||||||
|
addedMember := make(map[uint]bool)
|
||||||
|
|
||||||
|
if len(events) == 0 {
|
||||||
|
c.JSON(http.StatusOK, gin.H{})
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, e := range events {
|
||||||
|
var includesDate bool
|
||||||
|
|
||||||
|
for _, d := range request.Date {
|
||||||
|
if strings.Contains(e.Date, d) {
|
||||||
|
includesDate = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !includesDate {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
var data *models.Data
|
||||||
|
if _, ok := count[e.Day]; !ok {
|
||||||
|
count[e.Day] = &counter{}
|
||||||
|
}
|
||||||
|
count[e.Day].event += 1
|
||||||
|
|
||||||
|
data, ok := report.Data[e.Day]
|
||||||
|
if !ok {
|
||||||
|
data = &models.Data{Minimal: len(e.Attendees)}
|
||||||
|
report.Data[e.Day] = data
|
||||||
|
}
|
||||||
|
|
||||||
|
if data.Minimal > len(e.Attendees) {
|
||||||
|
data.Minimal = len(e.Attendees)
|
||||||
|
}
|
||||||
|
|
||||||
|
if data.Maximal < len(e.Attendees) {
|
||||||
|
data.Maximal = len(e.Attendees)
|
||||||
|
}
|
||||||
|
|
||||||
|
count[e.Day].total += len(e.Attendees)
|
||||||
|
data.Average = count[e.Day].total / count[e.Day].event
|
||||||
|
|
||||||
|
for _, a := range e.Attendees {
|
||||||
|
if _, ok := addedMember[a.Id]; ok {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
report.Attendees = append(report.Attendees, a)
|
||||||
|
addedMember[a.Id] = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// add all member not attended
|
||||||
|
members, err := a.DbHandler.GetMember(0)
|
||||||
|
if err != nil {
|
||||||
|
a.logger.Error("GetReport", err)
|
||||||
|
c.JSON(http.StatusBadRequest, gin.H{
|
||||||
|
"message": err.Error(),
|
||||||
|
})
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, m := range members {
|
||||||
|
if _, ok := addedMember[m.Id]; ok {
|
||||||
|
continue
|
||||||
|
} else if len(request.Groups) > 0 {
|
||||||
|
if m.Group == nil {
|
||||||
|
continue
|
||||||
|
} else if !slices.Contains(request.Groups, m.Group.Id) {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
}
|
||||||
|
report.NonAttendees = append(report.NonAttendees, &m)
|
||||||
|
}
|
||||||
|
|
||||||
|
c.JSON(http.StatusOK, gin.H{
|
||||||
|
"data": report,
|
||||||
|
})
|
||||||
|
}
|
||||||
4
go.mod
4
go.mod
@@ -1,9 +1,9 @@
|
|||||||
module gitea.tecamino.com/paadi/memberDB
|
module gitea.tecamino.com/paadi/memberDB
|
||||||
|
|
||||||
go 1.24.5
|
go 1.25.4
|
||||||
|
|
||||||
require (
|
require (
|
||||||
gitea.tecamino.com/paadi/dbHandler v1.1.7
|
gitea.tecamino.com/paadi/dbHandler v1.1.11
|
||||||
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
4
go.sum
@@ -1,5 +1,5 @@
|
|||||||
gitea.tecamino.com/paadi/dbHandler v1.1.7 h1:NqVbxbUwd7EZX6HYntyLYwwPbyTPevOhIBTFqoCVqOU=
|
gitea.tecamino.com/paadi/dbHandler v1.1.10 h1:zZQbDTJ0bu6CIW90Zms8yYIzTLHtWPNhVKRxLUXEDuE=
|
||||||
gitea.tecamino.com/paadi/dbHandler v1.1.7/go.mod h1:y/xn/POJg1DO++67uKvnO23lJQgh+XFQq7HZCS9Getw=
|
gitea.tecamino.com/paadi/dbHandler v1.1.10/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=
|
||||||
|
|||||||
@@ -12,10 +12,6 @@ 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) {
|
|
||||||
return errors.New("event with name: " + event.Name + " exists already")
|
|
||||||
}
|
|
||||||
|
|
||||||
event.Date = utils.GetCurrentTime(dh.timeLocation)
|
event.Date = utils.GetCurrentTime(dh.timeLocation)
|
||||||
event.Day = utils.GetCurrentDay(dh.timeLocation)
|
event.Day = utils.GetCurrentDay(dh.timeLocation)
|
||||||
return dh.database.AddNewColum(&event)
|
return dh.database.AddNewColum(&event)
|
||||||
@@ -28,8 +24,36 @@ func (dh *DatabaseHandler) GetEvent(id uint) (events []models.Event, err error)
|
|||||||
|
|
||||||
err = dh.database.GetById(&events, id, "Attendees")
|
err = dh.database.GetById(&events, id, "Attendees")
|
||||||
|
|
||||||
|
idMap := make(map[uint]bool)
|
||||||
for i := range events {
|
for i := range events {
|
||||||
for j := range events[i].Attendees {
|
for j := range events[i].Attendees {
|
||||||
|
if _, ok := idMap[events[i].Attendees[j].Id]; ok {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
idMap[events[i].Attendees[j].Id] = true
|
||||||
|
events[i].Attendees[j].Decrypt(dh.token)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
func (dh *DatabaseHandler) GetEventByKey(key string, value any, likeSearch bool) (events []models.Event, err error) {
|
||||||
|
if !dh.DatabaseOpened() {
|
||||||
|
return events, errors.New("database not opened")
|
||||||
|
}
|
||||||
|
|
||||||
|
err = dh.database.GetByKey(&events, key, value, likeSearch, "Attendees")
|
||||||
|
|
||||||
|
idMap := make(map[uint]bool)
|
||||||
|
for i := range events {
|
||||||
|
for j := range events[i].Attendees {
|
||||||
|
if _, ok := idMap[events[i].Attendees[j].Id]; ok {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
idMap[events[i].Attendees[j].Id] = true
|
||||||
events[i].Attendees[j].Decrypt(dh.token)
|
events[i].Attendees[j].Decrypt(dh.token)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -44,10 +68,12 @@ func (dh *DatabaseHandler) UpdateEvent(id int, event models.Event) (err error) {
|
|||||||
return errors.New("database not opened")
|
return errors.New("database not opened")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if event.Date != "" {
|
||||||
event.Day, err = utils.GetDayFromDate(event.Date)
|
event.Day, err = utils.GetDayFromDate(event.Date)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
}
|
||||||
return dh.database.UpdateValuesById(&event, uint(event.Id))
|
return dh.database.UpdateValuesById(&event, uint(event.Id))
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -99,6 +125,7 @@ func (dh *DatabaseHandler) DeleteAttendeesFromEvent(newEvent models.Event) error
|
|||||||
|
|
||||||
for _, newAttendee := range newEvent.Attendees {
|
for _, newAttendee := range newEvent.Attendees {
|
||||||
for _, a := range event.Attendees {
|
for _, a := range event.Attendees {
|
||||||
|
a.Decrypt(dh.token)
|
||||||
if a.FirstName == newAttendee.FirstName && a.LastName == newAttendee.LastName {
|
if a.FirstName == newAttendee.FirstName && a.LastName == newAttendee.LastName {
|
||||||
dh.database.DeleteRelation(&event, a, "Attendees")
|
dh.database.DeleteRelation(&event, a, "Attendees")
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -70,12 +70,19 @@ func (dh *DatabaseHandler) GetMember(id uint) (members []models.Member, err erro
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//map for list all decrypted members so it only once derypt each member
|
||||||
|
decryptedList := make(map[uint]bool, 1)
|
||||||
for i := range members {
|
for i := range members {
|
||||||
if err := members[i].Decrypt(dh.token); err != nil {
|
if err := members[i].Decrypt(dh.token); err != nil {
|
||||||
return members, err
|
return members, err
|
||||||
}
|
}
|
||||||
if members[i].Responsible != nil {
|
if members[i].Responsible != nil {
|
||||||
|
//check if already decrypted
|
||||||
|
if decryptedList[members[i].Responsible.Member.Id] {
|
||||||
|
continue
|
||||||
|
}
|
||||||
members[i].Responsible.Member.Decrypt(dh.token)
|
members[i].Responsible.Member.Decrypt(dh.token)
|
||||||
|
decryptedList[members[i].Responsible.Member.Id] = true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
|
|||||||
109
handlers/report.go
Normal file
109
handlers/report.go
Normal file
@@ -0,0 +1,109 @@
|
|||||||
|
package handlers
|
||||||
|
|
||||||
|
import (
|
||||||
|
"errors"
|
||||||
|
"slices"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"gitea.tecamino.com/paadi/memberDB/models"
|
||||||
|
)
|
||||||
|
|
||||||
|
type counter struct {
|
||||||
|
event int
|
||||||
|
total int
|
||||||
|
}
|
||||||
|
|
||||||
|
func (dh *DatabaseHandler) GetReport(filter models.ReportFilter) (report models.Report, err error) {
|
||||||
|
if !dh.DatabaseOpened() {
|
||||||
|
return report, errors.New("database not opened")
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(filter.Date) == 0 {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
var events []models.Event
|
||||||
|
|
||||||
|
if len(filter.Name) > 0 {
|
||||||
|
err = dh.database.GetByKey(&events, "name", filter.Name, true)
|
||||||
|
} else {
|
||||||
|
events, err = dh.GetEvent(0)
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
report.Data = make(map[string]*models.Data)
|
||||||
|
|
||||||
|
//helper
|
||||||
|
count := make(map[string]*counter)
|
||||||
|
|
||||||
|
addedMember := make(map[uint]bool)
|
||||||
|
|
||||||
|
for _, e := range events {
|
||||||
|
|
||||||
|
var includesDate bool
|
||||||
|
|
||||||
|
for _, d := range filter.Date {
|
||||||
|
if strings.Contains(e.Date, d) {
|
||||||
|
includesDate = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !includesDate {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
var data *models.Data
|
||||||
|
if _, ok := count[e.Day]; !ok {
|
||||||
|
count[e.Day] = &counter{}
|
||||||
|
}
|
||||||
|
count[e.Day].event += 1
|
||||||
|
|
||||||
|
data, ok := report.Data[e.Day]
|
||||||
|
if !ok {
|
||||||
|
data = &models.Data{Minimal: len(e.Attendees)}
|
||||||
|
report.Data[e.Day] = data
|
||||||
|
}
|
||||||
|
|
||||||
|
if data.Minimal > len(e.Attendees) {
|
||||||
|
data.Minimal = len(e.Attendees)
|
||||||
|
}
|
||||||
|
|
||||||
|
if data.Maximal < len(e.Attendees) {
|
||||||
|
data.Maximal = len(e.Attendees)
|
||||||
|
}
|
||||||
|
|
||||||
|
count[e.Day].total += len(e.Attendees)
|
||||||
|
data.Average = count[e.Day].total / count[e.Day].event
|
||||||
|
|
||||||
|
for _, a := range e.Attendees {
|
||||||
|
if _, ok := addedMember[a.Id]; ok {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
report.Attendees = append(report.Attendees, a)
|
||||||
|
addedMember[a.Id] = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// add all member not attended
|
||||||
|
members, err := dh.GetMember(0)
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, m := range members {
|
||||||
|
if _, ok := addedMember[m.Id]; ok {
|
||||||
|
continue
|
||||||
|
} else if len(filter.Groups) > 0 {
|
||||||
|
if m.Group == nil {
|
||||||
|
continue
|
||||||
|
} else if !slices.Contains(filter.Groups, m.Group.Id) {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
}
|
||||||
|
report.NonAttendees = append(report.NonAttendees, &m)
|
||||||
|
}
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
19
models/report.go
Normal file
19
models/report.go
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
package models
|
||||||
|
|
||||||
|
type ReportFilter struct {
|
||||||
|
Date []string `json:"date"`
|
||||||
|
Groups []uint `json:"groupIds,omitempty"`
|
||||||
|
Name []string `json:"name,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Report struct {
|
||||||
|
Data map[string]*Data `json:"data,omitempty"`
|
||||||
|
Attendees []*Member `json:"attendees,omitempty"`
|
||||||
|
NonAttendees []*Member `json:"nonAttendees,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Data struct {
|
||||||
|
Minimal int `json:"minimal,omitempty"`
|
||||||
|
Average int `json:"average,omitempty"`
|
||||||
|
Maximal int `json:"maximal,omitempty"`
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user