ahdan.zeeda.0103/api-tes
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perubahan

Browse Source
This commit is contained in:
Ahdan Zeeda Prasetya
2025-12-01 11:44:15 +07:00
parent bd02bb83a7
commit b9e915e2da
20 changed files with 0 additions and 1130 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/database/mongo/database.go
-13
View File
@@ -1,13 +0,0 @@
package mongo
import (
"go.mongodb.org/mongo-driver/mongo"
)
type DatabaseService struct {
DB *mongo.Database
}
func NewDatabaseService(db *mongo.Database) *DatabaseService {
return &DatabaseService{DB: db}
}
pkg/database/mongo/master_data.go
-24
View File
@@ -1,24 +0,0 @@
package mongo
import (
"context"
"log"
"template_blueprint/pkg/models/master_data"
"time"
)
func (s *DatabaseService) InsertDataMaster(req master_data.ReqInsertData) error {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
_, err := s.DB.Collection(req.Table).InsertOne(ctx, master_data.ReqInsertDataMaster{
ID: req.ID,
System: req.System,
Code: req.Code,
Display: req.Display,
})
if err != nil {
log.Println(err)
return err
}
return nil
}
pkg/database/mongo/mongo.go
-29
View File
@@ -1,29 +0,0 @@
package mongo
import (
"context"
"go.mongodb.org/mongo-driver/bson"
"log"
"template_blueprint/pkg/models/local"
"time"
)
func (s *DatabaseService) GetDataLog() ([]*local.StartUpLog, error) {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
dataLog, err := s.DB.Collection("startup_log").Find(ctx, bson.M{})
if err != nil {
log.Println("MASUK SINI")
log.Println(err)
return nil, err
}
log.Println("Data", dataLog.Current)
var logs []*local.StartUpLog
errDecode := dataLog.All(ctx, &logs)
if errDecode != nil {
log.Println(errDecode)
return nil, errDecode
}
log.Println("LOGS :", logs)
return logs, nil
}
pkg/database/mongo/patient.go
-36
View File
@@ -1,36 +0,0 @@
package mongo
import (
"context"
"go.mongodb.org/mongo-driver/bson"
"log"
"template_blueprint/pkg/models/patient"
"time"
)
func (s *DatabaseService) InsertPatient(req *patient.Patient) error {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
_, err := s.DB.Collection("patient").InsertOne(ctx, req)
if err != nil {
log.Println(err)
return err
}
return nil
}
func (s *DatabaseService) GetAllDataPatient() ([]*patient.Patient, error) {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
dataUser, err := s.DB.Collection("patient").Find(ctx, bson.D{})
if err != nil {
log.Println(err)
}
var users []*patient.Patient
err = dataUser.All(ctx, &users)
if err != nil {
log.Println(err)
return nil, err
}
return users, nil
}
pkg/database/mongo/user.go
-88
View File
@@ -1,88 +0,0 @@
package mongo
import (
"context"
"go.mongodb.org/mongo-driver/bson"
"log"
"template_blueprint/pkg/models/user"
"time"
)
func (s *DatabaseService) InsertUser(req user.ReqInsertUser) error {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
_, err := s.DB.Collection("user").InsertOne(ctx, user.ReqInsertUser{
ID: req.ID,
Name: req.Name,
Age: req.Age,
Address: req.Address,
Gender: req.Gender,
Religion: req.Religion,
})
if err != nil {
log.Println(err)
return err
}
return nil
}
func (s *DatabaseService) GetAllDataUser() ([]*user.User, error) {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
dataUser, err := s.DB.Collection("user").Find(ctx, bson.D{})
if err != nil {
log.Println(err)
}
var users []*user.User
err = dataUser.All(ctx, &users)
if err != nil {
log.Println(err)
return nil, err
}
return users, nil
}
func (s *DatabaseService) GetUserById(id string) (*user.User, error) {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
dataUser := s.DB.Collection("user").FindOne(ctx, bson.D{{Key: "_id", Value: id}})
var user *user.User
err := dataUser.Decode(&user)
if err != nil {
log.Println(err)
return nil, err
}
return user, nil
}
func (s *DatabaseService) UpdateUser(reqUpdate *user.ReqUpdateUser) error {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
log.Println(reqUpdate.ID)
filter := bson.M{"_id": reqUpdate.ID}
update := bson.M{"$set": bson.M{
"name": reqUpdate.Name,
"age": reqUpdate.Age,
"address": reqUpdate.Address,
"gender": reqUpdate.Gender,
"religion": reqUpdate.Religion,
}}
updatedData, err := s.DB.Collection("user").UpdateOne(ctx, filter, update)
if err != nil {
log.Println(err)
return err
}
log.Println(updatedData)
return nil
}
func (s *DatabaseService) DeleteUserById(id string) error {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
_, err := s.DB.Collection("user").DeleteOne(ctx, bson.D{{Key: "_id", Value: id}})
if err != nil {
log.Println(err)
return err
}
return nil
}
pkg/database/satu_data/master_location.go
-24
View File
@@ -1,24 +0,0 @@
package satu_data
import (
"errors"
"gorm.io/gorm"
"log"
"template_blueprint/pkg/models/satu_data"
)
func (s *DatabaseService) PoliklinikGetData(Status_pelayanan string) []*satu_data.PoliklinikGetData {
var datapoliklinik []*satu_data.PoliklinikGetData
query := `select dlr."Nama",dlr."Kode",dlr."id" from daftar_lokasi_ruang dlr where dlr."Status_pelayanan" = ?`
errQuery := s.DB.Debug().Raw(query, Status_pelayanan).Scan(&datapoliklinik).Error
if errQuery != nil {
if errors.Is(errQuery, gorm.ErrRecordNotFound) {
errMsg := errors.New("Data Tidak Ditemukan")
log.Println(errMsg)
return nil
}
log.Println(errQuery)
return nil
}
return datapoliklinik
}
pkg/database/satu_data/retribusi.go
-73
View File
@@ -1,73 +0,0 @@
package satu_data
import (
"errors"
"log"
"template_blueprint/pkg/models/satu_data"
)
func (s *DatabaseService) GetRetribusi(Limit string, Offset string) ([]*satu_data.Retribusi, error) {
var result []*satu_data.Retribusi
query := `select * from data_retribusi dr limit ? offset ?`
errQuery := s.DB.Debug().Raw(query, Limit, Offset).Scan(&result).Error
if errQuery != nil {
log.Println("errQuery:", errQuery)
return nil, errQuery
}
return result, nil
}
func (s *DatabaseService) InsertRetribusi(data *satu_data.Retribusi) error {
//id := uuid.New()
log.Println("ini data:", data)
//data.ID = id.String()
//log.Println("InsertRetribusi:", data)
query := `insert into data_retribusi ("id", "status", "sort", "user_created", "date_created", "Jenis", "Pelayanan", "Dinas",
"Kelompok_obyek", "Kode_tarif", "Tarif", "Satuan", "Tarif_overtime", "Satuan_overtime",
"Rekening_pokok", "Rekening_denda","Uraian_1", "Uraian_2", "Uraian_3")
values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`
errQuery := s.DB.Debug().Exec(query, data.ID, data.Status, data.Sort, data.UserCreated, data.DateCreated,
data.Jenis, data.Pelayanan, data.Dinas, data.KelompokObyek,
data.KodeTarif, data.Tarif, data.Satuan, data.TarifOverTime, data.SatuanOverTime, data.RekeningPokok, data.RekeningDenda,
data.Uraian1, data.Uraian2, data.Uraian3).Error
if errQuery != nil {
log.Println(errQuery)
return errors.New("Tidak dapat Simpan data retribusi")
}
return nil
}
func (s *DatabaseService) UpdateRetribusi(data *satu_data.Retribusi) error {
log.Println("update data_retribusi:", data)
query := `update data_retribusi set status=?, sort=?, user_updated=?, date_updated=?, "Jenis"=?, "Pelayanan"=?, "Dinas"=?, "Kelompok_obyek"=?, "Kode_tarif"=?, "Tarif"=?, "Satuan"=?, "Tarif_overtime"=?, "Satuan_overtime"=?, "Rekening_pokok"=?, "Rekening_denda"=?, "Uraian_1"=?, "Uraian_2"=?, "Uraian_3"=? where id=?`
errQuery := s.DB.Debug().Exec(query, data.Status, data.Sort, data.UserUpdated, data.DateUpdated, data.Jenis, data.Pelayanan, data.Dinas, data.KelompokObyek, data.KodeTarif, data.Tarif, data.Satuan, data.TarifOverTime, data.SatuanOverTime, data.RekeningPokok, data.RekeningDenda, data.Uraian1, data.Uraian2, data.Uraian3, data.ID).Error
if errQuery != nil {
log.Println(errQuery)
return errors.New("Tidak dapat ubah data retribusi")
}
return nil
}
func (s *DatabaseService) DeleteRetribusi(id string) error {
query := `delete from data_retribusi where id=?`
errQuery := s.DB.Debug().Exec(query, id).Error
if errQuery != nil {
log.Println(errQuery)
return errors.New("Tidak dapat hapus data retribusi")
}
return nil
}
func (s *DatabaseService) SearchRetribusi(kelompok_obyek string) ([]*satu_data.Retribusi, error) {
//log.Println("search retribusi by:", kelompok_obyek)
var result []*satu_data.Retribusi
query := `select * from data_retribusi where "Kelompok_obyek"=?`
errQuery := s.DB.Debug().Raw(query, kelompok_obyek).Scan(&result).Error
if errQuery != nil {
log.Println(errQuery)
return nil, errors.New("Tidak dapat data retribusi")
}
return result, nil
}