From 7217ded7f40adca8f78c3913105a77781c41a700 Mon Sep 17 00:00:00 2001 From: renaldybrada Date: Thu, 19 Feb 2026 11:15:48 +0700 Subject: [PATCH] refactor all antrian repository --- internal/domain/antrian_operasi/repository.go | 25 +++++++++---------- 1 file changed, 12 insertions(+), 13 deletions(-) diff --git a/internal/domain/antrian_operasi/repository.go b/internal/domain/antrian_operasi/repository.go index 80b17bc..39c7120 100644 --- a/internal/domain/antrian_operasi/repository.go +++ b/internal/domain/antrian_operasi/repository.go @@ -10,7 +10,6 @@ import ( "context" - "github.com/gin-gonic/gin" "github.com/google/uuid" ) @@ -22,12 +21,12 @@ const TBL_TINDAKAN_OPERASI = "data_tindakan_pasien_operasi" const TBL_DOKTER_OPERASI = "data_pasien_operasi_data_pegawai_2" type IAntrianOperasiRepository interface { - CreateAntrianOperasi(c *gin.Context, req CreatePasienOperasiRequest) (CreatePasienOperasiRequest, error) + CreateAntrianOperasi(c context.Context, req CreatePasienOperasiRequest) (CreatePasienOperasiRequest, error) SearchableListAntrianOperasi(c context.Context, q AntrianQuery) (ListPasienOperasiPaginate, error) - GetAntrianOperasiById(c *gin.Context, id string) (DetailPasienOperasiResultQuery, error) - UpdateAntrianOperasi(c *gin.Context, id string, req CreatePasienOperasiRequest) (CreatePasienOperasiRequest, error) - UpdateStatusAntrianOperasi(c *gin.Context, id string, req StatusPasienRequest) (StatusPasienRequest, error) - DeleteStatusAntrianOperasi(c *gin.Context, id string) error + GetAntrianOperasiById(c context.Context, id string) (DetailPasienOperasiResultQuery, error) + UpdateAntrianOperasi(c context.Context, id string, req CreatePasienOperasiRequest) (CreatePasienOperasiRequest, error) + UpdateStatusAntrianOperasi(c context.Context, id string, req StatusPasienRequest) (StatusPasienRequest, error) + DeleteStatusAntrianOperasi(c context.Context, id string) error } type antrianOperasiRepo struct { @@ -59,7 +58,7 @@ func NewRepository(dbService database.Service) IAntrianOperasiRepository { } } -func (r antrianOperasiRepo) insertAntrianChildTables(c *gin.Context, tx *sql.Tx, idAntrian string, req CreatePasienOperasiRequest) error { +func (r antrianOperasiRepo) insertAntrianChildTables(c context.Context, tx *sql.Tx, idAntrian string, req CreatePasienOperasiRequest) error { returningCols := []string{ "id", } @@ -208,7 +207,7 @@ func (r antrianOperasiRepo) insertAntrianChildTables(c *gin.Context, tx *sql.Tx, return nil } -func (r antrianOperasiRepo) deleteAntrianChildTables(c *gin.Context, tx *sql.Tx, idAntrian string) error { +func (r antrianOperasiRepo) deleteAntrianChildTables(c context.Context, tx *sql.Tx, idAntrian string) error { // parsedId := uuid.MustParse(idAntrian) // delete telephone filters := []queryUtils.FilterGroup{ @@ -289,7 +288,7 @@ func (r antrianOperasiRepo) deleteAntrianChildTables(c *gin.Context, tx *sql.Tx, return nil } -func (r antrianOperasiRepo) CreateAntrianOperasi(c *gin.Context, req CreatePasienOperasiRequest) (CreatePasienOperasiRequest, error) { +func (r antrianOperasiRepo) CreateAntrianOperasi(c context.Context, req CreatePasienOperasiRequest) (CreatePasienOperasiRequest, error) { db, err := r.db.GetSQLXDB(DB_NAME) if err != nil { return req, err @@ -558,7 +557,7 @@ func (r antrianOperasiRepo) SearchableListAntrianOperasi(c context.Context, q An return result, nil } -func (r antrianOperasiRepo) GetAntrianOperasiById(c *gin.Context, id string) (DetailPasienOperasiResultQuery, error) { +func (r antrianOperasiRepo) GetAntrianOperasiById(c context.Context, id string) (DetailPasienOperasiResultQuery, error) { var result DetailPasienOperasiResultQuery // main query @@ -768,7 +767,7 @@ func (r antrianOperasiRepo) GetAntrianOperasiById(c *gin.Context, id string) (De return result, nil } -func (r antrianOperasiRepo) UpdateAntrianOperasi(c *gin.Context, id string, req CreatePasienOperasiRequest) (CreatePasienOperasiRequest, error) { +func (r antrianOperasiRepo) UpdateAntrianOperasi(c context.Context, id string, req CreatePasienOperasiRequest) (CreatePasienOperasiRequest, error) { // Update main table updateMainQuery := queryUtils.UpdateData{ Columns: []string{ @@ -839,7 +838,7 @@ func (r antrianOperasiRepo) UpdateAntrianOperasi(c *gin.Context, id string, req return req, nil } -func (r antrianOperasiRepo) UpdateStatusAntrianOperasi(c *gin.Context, id string, req StatusPasienRequest) (StatusPasienRequest, error) { +func (r antrianOperasiRepo) UpdateStatusAntrianOperasi(c context.Context, id string, req StatusPasienRequest) (StatusPasienRequest, error) { // Update main table updateMainQuery := queryUtils.UpdateData{ Columns: []string{ @@ -884,7 +883,7 @@ func (r antrianOperasiRepo) UpdateStatusAntrianOperasi(c *gin.Context, id string return req, nil } -func (r antrianOperasiRepo) DeleteStatusAntrianOperasi(c *gin.Context, id string) error { +func (r antrianOperasiRepo) DeleteStatusAntrianOperasi(c context.Context, id string) error { db, err := r.db.GetSQLXDB(DB_NAME) if err != nil { log.Printf("Erorr initiating db : %v", err)