Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e876101688 | ||
|
|
03ace00a4b | ||
|
|
57ef3b92db | ||
|
|
ce8d17b3c9 | ||
|
|
376ba27a9c | ||
|
|
f2d20e83d6 | ||
|
|
81e05851bc | ||
|
|
349b17551d | ||
|
|
c1572c5ec6 | ||
|
|
108eae597b |
129
api/reportHandler.go
Normal file
129
api/reportHandler.go
Normal file
@@ -0,0 +1,129 @@
|
|||||||
|
package api
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net/http"
|
||||||
|
"slices"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"gitea.tecamino.com/paadi/memberDB/models"
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
|
)
|
||||||
|
|
||||||
|
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)
|
||||||
|
|
||||||
|
addedMember := make(map[uint]bool)
|
||||||
|
|
||||||
|
if len(events) == 0 {
|
||||||
|
c.JSON(http.StatusOK, gin.H{})
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, e := range events {
|
||||||
|
var includesDate bool
|
||||||
|
|
||||||
|
for i, d := range request.Date {
|
||||||
|
if strings.Contains(e.Date, d) {
|
||||||
|
request.Date = slices.Delete(request.Date, i, min(len(request.Date), i+1))
|
||||||
|
includesDate = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !includesDate {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
attendanceLength := len(e.Attendees)
|
||||||
|
|
||||||
|
total, ok := report.Data["total"]
|
||||||
|
if !ok {
|
||||||
|
total = models.AddNewData(attendanceLength)
|
||||||
|
report.Data["total"] = total
|
||||||
|
}
|
||||||
|
|
||||||
|
data, ok := report.Data[e.Day]
|
||||||
|
if !ok {
|
||||||
|
data = models.AddNewData(attendanceLength)
|
||||||
|
report.Data[e.Day] = data
|
||||||
|
}
|
||||||
|
|
||||||
|
data.AddData(attendanceLength)
|
||||||
|
total.AddData(attendanceLength)
|
||||||
|
|
||||||
|
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,
|
||||||
|
})
|
||||||
|
}
|
||||||
2
go.mod
2
go.mod
@@ -3,7 +3,7 @@ module gitea.tecamino.com/paadi/memberDB
|
|||||||
go 1.25.4
|
go 1.25.4
|
||||||
|
|
||||||
require (
|
require (
|
||||||
gitea.tecamino.com/paadi/dbHandler v1.1.10
|
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.10 h1:zZQbDTJ0bu6CIW90Zms8yYIzTLHtWPNhVKRxLUXEDuE=
|
gitea.tecamino.com/paadi/dbHandler v1.1.11 h1:hTpMWRr4dW7TkiBnEku0/3ggDC7/uP82U9paRKY/QEs=
|
||||||
gitea.tecamino.com/paadi/dbHandler v1.1.10/go.mod h1:y/xn/POJg1DO++67uKvnO23lJQgh+XFQq7HZCS9Getw=
|
gitea.tecamino.com/paadi/dbHandler v1.1.11/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)
|
||||||
@@ -44,6 +40,29 @@ func (dh *DatabaseHandler) GetEvent(id uint) (events []models.Event, err error)
|
|||||||
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)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
func (dh *DatabaseHandler) UpdateEvent(id int, event models.Event) (err error) {
|
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")
|
||||||
|
|||||||
97
handlers/report.go
Normal file
97
handlers/report.go
Normal file
@@ -0,0 +1,97 @@
|
|||||||
|
package handlers
|
||||||
|
|
||||||
|
import (
|
||||||
|
"errors"
|
||||||
|
"slices"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"gitea.tecamino.com/paadi/memberDB/models"
|
||||||
|
)
|
||||||
|
|
||||||
|
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)
|
||||||
|
|
||||||
|
addedMember := make(map[uint]bool)
|
||||||
|
|
||||||
|
for _, e := range events {
|
||||||
|
|
||||||
|
var includesDate bool
|
||||||
|
|
||||||
|
for i, d := range filter.Date {
|
||||||
|
if strings.Contains(e.Date, d) {
|
||||||
|
filter.Date = slices.Delete(filter.Date, i, min(len(filter.Date), i+1))
|
||||||
|
includesDate = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !includesDate {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
attendanceLength := len(e.Attendees)
|
||||||
|
|
||||||
|
total, ok := report.Data["total"]
|
||||||
|
if !ok {
|
||||||
|
total = models.AddNewData(attendanceLength)
|
||||||
|
report.Data["total"] = total
|
||||||
|
}
|
||||||
|
|
||||||
|
data, ok := report.Data[e.Day]
|
||||||
|
if !ok {
|
||||||
|
data = models.AddNewData(attendanceLength)
|
||||||
|
report.Data[e.Day] = data
|
||||||
|
}
|
||||||
|
|
||||||
|
data.AddData(attendanceLength)
|
||||||
|
total.AddData(attendanceLength)
|
||||||
|
|
||||||
|
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
|
||||||
|
}
|
||||||
38
models/report.go
Normal file
38
models/report.go
Normal file
@@ -0,0 +1,38 @@
|
|||||||
|
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 {
|
||||||
|
Events int `json:"events"`
|
||||||
|
Minimal int `json:"minimal"`
|
||||||
|
Average int `json:"average"`
|
||||||
|
Maximal int `json:"maximal"`
|
||||||
|
averageCount int `json:"-"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func AddNewData(value int) *Data {
|
||||||
|
return &Data{Minimal: value}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (d *Data) AddData(value int) {
|
||||||
|
d.Events += 1
|
||||||
|
if d.Minimal > value {
|
||||||
|
d.Minimal = value
|
||||||
|
}
|
||||||
|
if d.Maximal < value {
|
||||||
|
d.Maximal = value
|
||||||
|
}
|
||||||
|
|
||||||
|
d.averageCount += value
|
||||||
|
d.Average = d.averageCount / d.Events
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user