mirza.millahsyafiq.0912/mongotest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix code crud user and insert master data for fhir

Browse Source
This commit is contained in:
Mirza Millahsyafiq Khusni
2025-03-07 11:11:44 +07:00
parent 26271ef9e3
commit a0fdf0240f
18 changed files with 940 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
pkg/database/mongo/master_data.go Normal file
View File

@@ -0,0 +1,24 @@
package mongo
import (
"context"
"log"
"mongotest/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
}

32
pkg/database/mongo/user.go
View File

@@ -12,10 +12,12 @@ 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,
ID: req.ID,
Name: req.Name,
Age: req.Age,
Address: req.Address,
Gender: req.Gender,
Religion: req.Religion,
})
if err != nil {
log.Println(err)
@@ -53,14 +55,17 @@ func (s *DatabaseService) GetUserById(id string) (*user.User, error) {
return user, nil
}
func (s *DatabaseService) UpdateUser(reqUpdate *user.User) error {
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,
"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 {
@@ -70,3 +75,14 @@ func (s *DatabaseService) UpdateUser(reqUpdate *user.User) error {
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
}