Files
api-antrian-operasi/internal/domain/dashboard/repository.go
T
2026-02-03 13:45:43 +07:00

83 lines
1.9 KiB
Go

package dashboard
import (
"antrian-operasi/internal/database"
queryUtils "antrian-operasi/internal/utils/query"
"github.com/gin-gonic/gin"
)
const DB_NAME = "db_antrian"
const TBL_NAME = "data_pasien_operasi"
type IDashboardRepository interface {
GetAntrianPerKategori(c *gin.Context) ([]AntrianPerKategori, error)
}
type dashboardRepo struct {
queryBuilder *queryUtils.QueryBuilder
db database.Service
}
func NewRepository(dbService database.Service) IDashboardRepository {
queryBuilder := queryUtils.NewQueryBuilder(queryUtils.DBTypePostgreSQL).
SetAllowedColumns([]string{
"Kategori_operasi",
"Kategori",
"jumlah_antrean",
})
queryBuilder.SetSecurityOptions(false, 100)
return dashboardRepo{
queryBuilder: queryBuilder,
db: dbService,
}
}
func (r dashboardRepo) GetAntrianPerKategori(c *gin.Context) ([]AntrianPerKategori, error) {
var result []AntrianPerKategori
query := queryUtils.DynamicQuery{
From: TBL_NAME,
Aliases: "dpo",
Fields: []queryUtils.SelectField{
{Expression: "dpo.Kategori_operasi", Alias: "Kategori_operasi"},
{Expression: "dko.Kategori", Alias: "Kategori"},
{Expression: "COUNT(dpo.id)", Alias: "jumlah_antrean"},
},
GroupBy: []string{"dpo.Kategori_operasi", "dko.Kategori"},
Sort: []queryUtils.SortField{
{Column: "dpo.Kategori_operasi", Order: "DESC"},
},
}
query.Joins = []queryUtils.Join{
{
Type: "LEFT",
Table: "daftar_kategori_operasi",
Alias: "dko",
OnConditions: queryUtils.FilterGroup{
Filters: []queryUtils.DynamicFilter{
{
Column: "dpo.Kategori_operasi", Operator: queryUtils.OpEqual, Value: "dko.id",
},
},
},
},
}
dbconn, err := r.db.GetSQLXDB(DB_NAME)
if err != nil {
return result, err
}
err = r.queryBuilder.ExecuteQuery(
c, dbconn, query, &result)
if err != nil {
return result, err
}
return result, nil
}