encounter mapping
This commit is contained in:
@@ -112,6 +112,9 @@ const (
|
||||
RCNephew RelationshipCode = "nephew" // Keponakan
|
||||
RCGdChild RelationshipCode = "gd-child" // Cucu
|
||||
RCOther RelationshipCode = "other" // Lainnya
|
||||
RCFriend RelationshipCode = "friend" // Teman
|
||||
RCSpouse RelationshipCode = "spouse" // Pasangan (Suami / Istri)
|
||||
RCSelf RelationshipCode = "self" // Diri Sendiri
|
||||
|
||||
ALTCIdn AddressLocationTypeCode = "identity" // Sesuai Identitas
|
||||
ALTCDom AddressLocationTypeCode = "domicile" // Sesuai Domisili
|
||||
|
||||
@@ -65,7 +65,7 @@ type MPasien struct {
|
||||
NamaIbu string `json:"nama_ibu" gorm:"column:nama_ibu"`
|
||||
PendidikanAyah string `json:"pendidikan_ayah" gorm:"column:pendidikan_ayah"`
|
||||
PendidikanIbu string `json:"pendidikan_ibu" gorm:"column:pendidikan_ibu"`
|
||||
StIdentitasOrtu string `json:"st_identitas_ortu" gorm:"column:st_identitas_ortu"`
|
||||
StIdentitasOrtu uint `json:"st_identitas_ortu" gorm:"column:st_identitas_ortu"`
|
||||
NomrBaru *string `json:"nomr_baru" gorm:"column:nomr_baru"`
|
||||
KtpFile *string `json:"ktp_file" gorm:"column:ktp_file"`
|
||||
KkFile *string `json:"kk_file" gorm:"column:kk_file"`
|
||||
|
||||
@@ -2,6 +2,7 @@ package patient
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
pa "simrs-vx/internal/lib/auth"
|
||||
|
||||
rw "github.com/karincake/risoles"
|
||||
sf "github.com/karincake/semprit"
|
||||
@@ -19,10 +20,17 @@ type myBase struct{}
|
||||
var O myBase
|
||||
|
||||
func (obj myBase) Create(w http.ResponseWriter, r *http.Request) {
|
||||
authInfo, err := pa.GetAuthInfo(r)
|
||||
if err != nil {
|
||||
rw.WriteJSON(w, http.StatusUnauthorized, d.IS{"message": err.Error()}, nil)
|
||||
}
|
||||
|
||||
dto := e.CreateDto{}
|
||||
if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
|
||||
return
|
||||
}
|
||||
|
||||
dto.AuthInfo = *authInfo
|
||||
res, err := u.Create(dto)
|
||||
rw.DataResponse(w, res, err)
|
||||
}
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
package patient
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"strconv"
|
||||
|
||||
pl "simrs-vx/pkg/logger"
|
||||
@@ -38,6 +39,19 @@ func Create(input e.CreateDto) (*d.Data, error) {
|
||||
pl.SetLogInfo(&event, input, "started", "create")
|
||||
mwRunner := newMiddlewareRunner(&event)
|
||||
|
||||
// check if user has employee position
|
||||
if !input.AuthInfo.HasEmployeePosition() {
|
||||
event.Status = "failed"
|
||||
event.ErrInfo = pl.ErrorInfo{
|
||||
Code: "auth-forbidden",
|
||||
Detail: "user has no employee position",
|
||||
Raw: errors.New("authentication failed"),
|
||||
}
|
||||
return nil, pl.SetLogError(&event, input)
|
||||
}
|
||||
|
||||
input.RegisteredBy_User_Name = &input.AuthInfo.User_Name
|
||||
|
||||
err := dg.I.Transaction(func(tx *gorm.DB) error {
|
||||
mwRunner.setMwType(pu.MWTPre)
|
||||
// Run pre-middleware
|
||||
|
||||
@@ -0,0 +1,197 @@
|
||||
package encounter
|
||||
|
||||
import (
|
||||
pl "simrs-vx/pkg/logger"
|
||||
|
||||
d "github.com/karincake/dodol"
|
||||
"gorm.io/gorm"
|
||||
|
||||
db "simrs-vx/pkg/dualtrx-helper"
|
||||
|
||||
e "simrs-vx/internal/domain/main-entities/division"
|
||||
esimgos "simrs-vx/internal/domain/simgos-entities/division"
|
||||
esync "simrs-vx/internal/domain/sync-entities/division"
|
||||
elog "simrs-vx/internal/domain/sync-entities/log"
|
||||
)
|
||||
|
||||
const source = "division"
|
||||
|
||||
func Create(input e.CreateDto) (*d.Data, error) {
|
||||
var (
|
||||
sgData *esimgos.MUnit
|
||||
syncLink *esync.DivisionLink
|
||||
err error
|
||||
)
|
||||
|
||||
event := pl.Event{
|
||||
Feature: "Create",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "create")
|
||||
|
||||
err = db.WithDualTx(func(tx *db.Dualtx) error {
|
||||
// STEP 1: Insert to simgos
|
||||
sgData, err = CreateSimgosData(input, &event, tx.Simgos)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// STEP 2: Insert to Link
|
||||
syncLink, err = CreateLinkData(*input.Id, sgData.KodeUnit, &event, tx.Sync)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
if syncLink != nil {
|
||||
go func() { _ = DeleteLinkData(syncLink, &event) }()
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
|
||||
pl.SetLogInfo(&event, nil, "complete")
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.II{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "created",
|
||||
},
|
||||
}, nil
|
||||
}
|
||||
|
||||
func CreateSimxLog(input elog.SimxLogDto) (*d.Data, error) {
|
||||
event := pl.Event{
|
||||
Feature: "Create",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "create")
|
||||
|
||||
tx := db.NewTx()
|
||||
err := tx.Sync.Transaction(func(tx *gorm.DB) error {
|
||||
// Insert to Log
|
||||
if err := CreateLogData(input, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
pl.SetLogInfo(&event, nil, "complete")
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.II{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "created",
|
||||
},
|
||||
}, nil
|
||||
}
|
||||
|
||||
func Update(input e.UpdateDto) (*d.Data, error) {
|
||||
event := pl.Event{
|
||||
Feature: "Update",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "update")
|
||||
|
||||
// STEP 1: Get Link
|
||||
syncLink, err := ReadDetailLinkData(*input.Id, &event)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
tx := db.NewTx()
|
||||
err = tx.Simgos.Transaction(func(tx *gorm.DB) error {
|
||||
// Step 2: Update Simgos
|
||||
if err = UpdateSimgosData(input, syncLink, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
pl.SetLogInfo(&event, nil, "complete")
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.IS{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "updated",
|
||||
},
|
||||
}, nil
|
||||
}
|
||||
|
||||
func Delete(input e.DeleteDto) (*d.Data, error) {
|
||||
var isLinkDeleted bool
|
||||
|
||||
event := pl.Event{
|
||||
Feature: "Delete",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "delete")
|
||||
|
||||
// STEP 1: Get Link
|
||||
syncLink, err := ReadDetailLinkData(*input.Id, &event)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
// STEP 2: Get Simgos
|
||||
sgData, err := ReadDetailSimgosData(uint16(syncLink.Simgos_Id), &event)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
err = db.WithDualTx(func(tx *db.Dualtx) error {
|
||||
// STEP 3: Delete Simgos
|
||||
err = HardDeleteSimgosData(sgData, &event, tx.Simgos)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// STEP 4: Delete Link
|
||||
err = DeleteLinkData(syncLink, &event, tx.Sync)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
isLinkDeleted = true
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
if isLinkDeleted {
|
||||
go func() {
|
||||
_, _ = CreateLinkData(uint(*input.Id), sgData.KodeUnit, &event)
|
||||
}()
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
|
||||
pl.SetLogInfo(&event, nil, "complete")
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.IS{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "deleted",
|
||||
},
|
||||
}, nil
|
||||
|
||||
}
|
||||
@@ -0,0 +1,74 @@
|
||||
/*
|
||||
DESCRIPTION:
|
||||
Any functions that are used internally by the use-case
|
||||
*/
|
||||
package encounter
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"strconv"
|
||||
|
||||
erc "simrs-vx/internal/domain/references/common"
|
||||
ere "simrs-vx/internal/domain/references/encounter"
|
||||
|
||||
e "simrs-vx/internal/domain/main-entities/encounter"
|
||||
esimgos "simrs-vx/internal/domain/simgos-entities/encounter"
|
||||
esync "simrs-vx/internal/domain/sync-entities/encounter"
|
||||
esyncLog "simrs-vx/internal/domain/sync-entities/encounter"
|
||||
)
|
||||
|
||||
func setDataSimgos(input *e.Encounter) (data esimgos.TPendaftaran) {
|
||||
data.Nomr = *input.Patient.Number
|
||||
data.Tglreg = input.RegisteredAt
|
||||
|
||||
kddokter, _ := strconv.Atoi(*input.Appointment_Doctor_Code)
|
||||
data.Kddokter = uint(kddokter)
|
||||
|
||||
kdpoly, _ := strconv.Atoi(*input.Unit_Code)
|
||||
data.Kdpoly = uint(kdpoly)
|
||||
|
||||
setKdrujuk(input.RefType_Code, data)
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func setKdrujuk(input *ere.RefTypeCode, data esimgos.TPendaftaran) {
|
||||
switch *input {
|
||||
case ere.RTCGov:
|
||||
data.Kdrujuk = 1
|
||||
case ere.RTCPrivate:
|
||||
data.Kdrujuk = 2
|
||||
case ere.RTCBpjs:
|
||||
data.Kdrujuk = 3
|
||||
default:
|
||||
data.Kdrujuk = 0
|
||||
}
|
||||
}
|
||||
|
||||
func setDataSimxLog(input *esyncLog.SimxLogDto) (data esync.DivisionSimxLog) {
|
||||
// encode to JSON
|
||||
jsonData, _ := json.MarshalIndent(input.Payload, "", " ")
|
||||
jsonString := string(jsonData)
|
||||
|
||||
var status erc.ProcessStatusCode
|
||||
if input.IsSuccess {
|
||||
status = erc.PSCSuccess
|
||||
} else {
|
||||
status = erc.PSCFailed
|
||||
if input.ErrMessage != nil {
|
||||
data.ErrMessage = input.ErrMessage
|
||||
}
|
||||
}
|
||||
|
||||
data.Value = &jsonString
|
||||
data.Date = &now
|
||||
data.Status = status
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func setDataSimxLink(simxId, simgosId uint) (data esync.DivisionLink) {
|
||||
data.Simx_Id = simxId
|
||||
data.Simgos_Id = simgosId
|
||||
return
|
||||
}
|
||||
@@ -0,0 +1,188 @@
|
||||
package encounter
|
||||
|
||||
import (
|
||||
plh "simrs-vx/pkg/lib-helper"
|
||||
pl "simrs-vx/pkg/logger"
|
||||
pu "simrs-vx/pkg/use-case-helper"
|
||||
"time"
|
||||
|
||||
dg "github.com/karincake/apem/db-gorm-pg"
|
||||
"gorm.io/gorm"
|
||||
|
||||
e "simrs-vx/internal/domain/main-entities/division"
|
||||
esimgos "simrs-vx/internal/domain/simgos-entities/division"
|
||||
esync "simrs-vx/internal/domain/sync-entities/division"
|
||||
esynclog "simrs-vx/internal/domain/sync-entities/log"
|
||||
)
|
||||
|
||||
var now = time.Now()
|
||||
|
||||
func CreateSimgosData(input e.CreateDto, event *pl.Event, dbx ...*gorm.DB) (*esimgos.MUnit, error) {
|
||||
pl.SetLogInfo(event, nil, "started", "DBCreate")
|
||||
|
||||
data := setDataSimgos(&input)
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.IS["simrs"]
|
||||
}
|
||||
|
||||
if err := tx.Create(&data).Error; err != nil {
|
||||
return nil, plh.HandleCreateError(input, event, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return &data, nil
|
||||
}
|
||||
|
||||
func ReadDetailSimgosData(simgosId uint16, event *pl.Event) (*esimgos.MUnit, error) {
|
||||
pl.SetLogInfo(event, simgosId, "started", "DBReadDetail")
|
||||
data := esimgos.MUnit{}
|
||||
|
||||
var tx = dg.IS["simrs"]
|
||||
|
||||
if err := tx.
|
||||
Where("\"kode_unit\" = ?", simgosId).
|
||||
First(&data).Error; err != nil {
|
||||
if processedErr := pu.HandleReadError(err, event, source, simgosId, data); processedErr != nil {
|
||||
return nil, processedErr
|
||||
}
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return &data, nil
|
||||
}
|
||||
|
||||
func UpdateSimgosData(input e.UpdateDto, dataSimgos *esync.DivisionLink, event *pl.Event, dbx ...*gorm.DB) error {
|
||||
pl.SetLogInfo(event, input, "started", "DBUpdate")
|
||||
|
||||
data := setDataSimgos(&input)
|
||||
data.KodeUnit = dataSimgos.Simgos_Id
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.IS["simrs"]
|
||||
}
|
||||
|
||||
if err := tx.Save(&data).Error; err != nil {
|
||||
event.Status = "failed"
|
||||
event.ErrInfo = pl.ErrorInfo{
|
||||
Code: "data-update-fail",
|
||||
Detail: "Database update failed",
|
||||
Raw: err,
|
||||
}
|
||||
return pl.SetLogError(event, input)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return nil
|
||||
}
|
||||
|
||||
func HardDeleteSimgosData(data *esimgos.MUnit, event *pl.Event, dbx ...*gorm.DB) error {
|
||||
pl.SetLogInfo(event, data, "started", "DBDelete")
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.IS["simrs"]
|
||||
}
|
||||
|
||||
if err := tx.
|
||||
Delete(&data).Error; err != nil {
|
||||
event.Status = "failed"
|
||||
event.ErrInfo = pl.ErrorInfo{
|
||||
Code: "data-delete-fail",
|
||||
Detail: "Database delete failed",
|
||||
Raw: err,
|
||||
}
|
||||
return pl.SetLogError(event, data)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return nil
|
||||
}
|
||||
|
||||
func CreateLinkData(simxId, simgosId uint, event *pl.Event, dbx ...*gorm.DB) (*esync.DivisionLink, error) {
|
||||
pl.SetLogInfo(event, nil, "started", "DBCreate")
|
||||
data := setDataSimxLink(simxId, simgosId)
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
if err := tx.Create(&data).Error; err != nil {
|
||||
return nil, plh.HandleCreateError(data, event, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return &data, nil
|
||||
}
|
||||
|
||||
func ReadDetailLinkData(simxId uint16, event *pl.Event) (*esync.DivisionLink, error) {
|
||||
pl.SetLogInfo(event, simxId, "started", "DBReadDetail")
|
||||
data := esync.DivisionLink{}
|
||||
|
||||
var tx = dg.I
|
||||
|
||||
if err := tx.
|
||||
Where("\"Simx_Id\" = ?", simxId).
|
||||
First(&data).Error; err != nil {
|
||||
if processedErr := pu.HandleReadError(err, event, source, simxId, data); processedErr != nil {
|
||||
return nil, processedErr
|
||||
}
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return &data, nil
|
||||
}
|
||||
|
||||
func DeleteLinkData(data *esync.DivisionLink, event *pl.Event, dbx ...*gorm.DB) error {
|
||||
pl.SetLogInfo(event, data, "started", "DBDelete")
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
if err := tx.Delete(&data).Error; err != nil {
|
||||
event.Status = "failed"
|
||||
event.ErrInfo = pl.ErrorInfo{
|
||||
Code: "data-delete-fail",
|
||||
Detail: "Database delete failed",
|
||||
Raw: err,
|
||||
}
|
||||
return pl.SetLogError(event, data)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return nil
|
||||
}
|
||||
|
||||
func CreateLogData(input esynclog.SimxLogDto, event *pl.Event, dbx ...*gorm.DB) error {
|
||||
pl.SetLogInfo(event, nil, "started", "DBCreate")
|
||||
data := setDataSimxLog(&input)
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
if err := tx.Create(&data).Error; err != nil {
|
||||
return plh.HandleCreateError(input, event, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return nil
|
||||
}
|
||||
@@ -0,0 +1,104 @@
|
||||
package encounter
|
||||
|
||||
import (
|
||||
pl "simrs-vx/pkg/logger"
|
||||
pu "simrs-vx/pkg/use-case-helper"
|
||||
|
||||
"gorm.io/gorm"
|
||||
|
||||
e "simrs-vx/internal/domain/main-entities/encounter"
|
||||
)
|
||||
|
||||
type middlewareRunner struct {
|
||||
Event *pl.Event
|
||||
Tx *gorm.DB
|
||||
MwType pu.MWType
|
||||
}
|
||||
|
||||
// NewMiddlewareExecutor creates a new middleware executor
|
||||
func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
|
||||
return &middlewareRunner{
|
||||
Event: event,
|
||||
Tx: tx,
|
||||
}
|
||||
}
|
||||
|
||||
// ExecuteCreateMiddleware executes create middleware
|
||||
func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto, data *e.Encounter) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) RunReadListMiddleware(middlewares []readListMw, input *e.ReadListDto, data *e.Encounter) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Encounter) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Encounter) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Encounter) error {
|
||||
for _, middleware := range middlewares {
|
||||
logData := pu.GetLogData(input, data)
|
||||
|
||||
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
|
||||
|
||||
if err := middleware.Func(input, data, me.Tx); err != nil {
|
||||
return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
|
||||
}
|
||||
|
||||
pl.SetLogInfo(me.Event, nil, "complete")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (me *middlewareRunner) setMwType(mwType pu.MWType) {
|
||||
me.MwType = mwType
|
||||
}
|
||||
@@ -0,0 +1,9 @@
|
||||
package encounter
|
||||
|
||||
// example of middleware
|
||||
// func init() {
|
||||
// createPreMw = append(createPreMw,
|
||||
// CreateMw{Name: "modif-input", Func: pm.ModifInput},
|
||||
// CreateMw{Name: "check-data", Func: pm.CheckData},
|
||||
// )
|
||||
// }
|
||||
@@ -0,0 +1,44 @@
|
||||
/*
|
||||
DESCRIPTION:
|
||||
A sample, part of the package that contains type, constants, and/or variables.
|
||||
|
||||
In this sample it also provides type and variable regarding the needs of the
|
||||
middleware to separate from main use-case which has the basic CRUD
|
||||
functionality. The purpose of this is to make the code more maintainable.
|
||||
*/
|
||||
package encounter
|
||||
|
||||
import (
|
||||
"gorm.io/gorm"
|
||||
|
||||
e "simrs-vx/internal/domain/main-entities/encounter"
|
||||
)
|
||||
|
||||
type createMw struct {
|
||||
Name string
|
||||
Func func(input *e.CreateDto, data *e.Encounter, tx *gorm.DB) error
|
||||
}
|
||||
|
||||
type readListMw struct {
|
||||
Name string
|
||||
Func func(input *e.ReadListDto, data *e.Encounter, tx *gorm.DB) error
|
||||
}
|
||||
|
||||
type readDetailMw struct {
|
||||
Name string
|
||||
Func func(input *e.ReadDetailDto, data *e.Encounter, tx *gorm.DB) error
|
||||
}
|
||||
|
||||
type UpdateMw = readDetailMw
|
||||
type DeleteMw = readDetailMw
|
||||
|
||||
var createPreMw []createMw // preprocess middleware
|
||||
var createPostMw []createMw // postprocess middleware
|
||||
var readListPreMw []readListMw // ..
|
||||
var readListPostMw []readListMw // ..
|
||||
var readDetailPreMw []readDetailMw
|
||||
var readDetailPostMw []readDetailMw
|
||||
var updatePreMw []readDetailMw
|
||||
var updatePostMw []readDetailMw
|
||||
var deletePreMw []readDetailMw
|
||||
var deletePostMw []readDetailMw
|
||||
@@ -211,7 +211,7 @@ func GenerateNomr() (*d.Data, error) {
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, nil, "started", "create")
|
||||
|
||||
norm, err := generateNomrPatient()
|
||||
norm, err := generateNomrPatient("12")
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
@@ -39,21 +39,33 @@ func setDataSimgos(input *e.Patient) (data esimgos.MPasien) {
|
||||
|
||||
if input.Person != nil && input.Person.Relatives != nil {
|
||||
mapRelative(input.Person.Relatives, &data)
|
||||
} else {
|
||||
data.PenanggungjawabHubungan = "DIRI SENDIRI"
|
||||
data.PenanggungjawabNama = input.Person.Name
|
||||
data.PenanggungjawabPhone = data.Notelp
|
||||
data.PenanggungjawabAlamat = data.Alamat
|
||||
}
|
||||
|
||||
data.Nip = input.RegisteredBy_User_Name
|
||||
data.Tgldaftar = input.RegisteredAt
|
||||
data.Nomr = *input.Number
|
||||
|
||||
nomrBaru, _ := generateNomrPatient("00")
|
||||
data.NomrBaru = &nomrBaru
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func generateNomrPatient() (string, error) {
|
||||
const prefix = "12" // fixed starting prefix (same as $awal_rm) in simgos
|
||||
func generateNomrPatient(prefix string) (string, error) {
|
||||
const maxSuffix = 999999
|
||||
|
||||
column := "nomr"
|
||||
if prefix == "00" {
|
||||
column = "nomr_baru"
|
||||
}
|
||||
|
||||
type Row struct {
|
||||
Nomr string `gorm:"column:nomr"`
|
||||
Value string `gorm:"column:value"`
|
||||
}
|
||||
|
||||
var r Row
|
||||
@@ -61,31 +73,35 @@ func generateNomrPatient() (string, error) {
|
||||
// Lock rows for this prefix → prevents race condition
|
||||
if err := dg.IS["simrs"].
|
||||
Table("m_pasien").
|
||||
Select("nomr").
|
||||
Where("nomr LIKE ?", prefix+"%").
|
||||
Order("nomr DESC").
|
||||
Select(fmt.Sprintf("%s AS value", column)).
|
||||
Where(fmt.Sprintf("%s LIKE ?", column), prefix+"%").
|
||||
Order(fmt.Sprintf("%s DESC", column)).
|
||||
Clauses(clause.Locking{Strength: "UPDATE"}).
|
||||
Limit(1).
|
||||
Scan(&r).Error; err != nil {
|
||||
return "", err
|
||||
}
|
||||
|
||||
// No existing NOMR → start fresh
|
||||
if r.Nomr == "" {
|
||||
// No existing number → start at 000001
|
||||
if r.Value == "" || len(r.Value) < len(prefix) {
|
||||
return prefix + "000001", nil
|
||||
}
|
||||
|
||||
suffix := r.Nomr[len(prefix):] // extract numeric part
|
||||
num, _ := strconv.Atoi(suffix)
|
||||
|
||||
// 3. If suffix reaches 999999 → increment the prefix
|
||||
if num == maxSuffix {
|
||||
p, _ := strconv.Atoi(prefix)
|
||||
p++
|
||||
return fmt.Sprintf("%d000001", p), nil
|
||||
suffix := r.Value[len(prefix):]
|
||||
num, err := strconv.Atoi(suffix)
|
||||
if err != nil {
|
||||
// data corrupt, reset nomor
|
||||
return prefix + "000001", nil
|
||||
}
|
||||
|
||||
// 4. Normal increment
|
||||
// If reached 999999 → increment prefix
|
||||
if num >= maxSuffix {
|
||||
p, _ := strconv.Atoi(prefix)
|
||||
p++
|
||||
return fmt.Sprintf("%02d000001", p), nil
|
||||
}
|
||||
|
||||
// Normal increment
|
||||
return prefix + fmt.Sprintf("%06d", num+1), nil
|
||||
}
|
||||
|
||||
@@ -262,30 +278,47 @@ func mapRelative(relative *[]epr.PersonRelative, data *esimgos.MPasien) {
|
||||
return
|
||||
}
|
||||
|
||||
r := (*relative)[0]
|
||||
data.PenanggungjawabNama = *r.Name
|
||||
for _, r := range *relative {
|
||||
if r.Responsible {
|
||||
data.PenanggungjawabNama = *r.Name
|
||||
|
||||
switch r.Relationship_Code {
|
||||
case erp.RCMother, erp.RCFather:
|
||||
data.PenanggungjawabHubungan = "ORANG TUA"
|
||||
switch {
|
||||
case r.Relationship_Code == erp.RCMother:
|
||||
data.NamaIbu = *r.Name
|
||||
eduCode, _ := setEducation(r.Education_Code)
|
||||
data.PendidikanIbu = strconv.Itoa(int(eduCode))
|
||||
case r.Relationship_Code == erp.RCFather:
|
||||
data.NamaAyah = *r.Name
|
||||
eduCode, _ := setEducation(r.Education_Code)
|
||||
data.PendidikanAyah = strconv.Itoa(int(eduCode))
|
||||
switch r.Relationship_Code {
|
||||
case erp.RCMother, erp.RCFather:
|
||||
data.PenanggungjawabHubungan = "ORANG TUA"
|
||||
switch {
|
||||
case r.Relationship_Code == erp.RCMother:
|
||||
data.NamaIbu = *r.Name
|
||||
eduCode, _ := setEducation(r.Education_Code)
|
||||
data.PendidikanIbu = strconv.Itoa(int(eduCode))
|
||||
case r.Relationship_Code == erp.RCFather:
|
||||
data.NamaAyah = *r.Name
|
||||
eduCode, _ := setEducation(r.Education_Code)
|
||||
data.PendidikanAyah = strconv.Itoa(int(eduCode))
|
||||
}
|
||||
case erp.RCChild:
|
||||
data.PenanggungjawabHubungan = "ANAK"
|
||||
case erp.RCSibling:
|
||||
data.PenanggungjawabHubungan = "SAUDARA"
|
||||
case erp.RCUncle, erp.RCAunt,
|
||||
erp.RCGdMother, erp.RCGdFather,
|
||||
erp.RCNephew, erp.RCGdChild:
|
||||
data.PenanggungjawabHubungan = "KELUARGA LAIN"
|
||||
case erp.RCFriend:
|
||||
data.PenanggungjawabHubungan = "TEMAN"
|
||||
case erp.RCSpouse:
|
||||
data.PenanggungjawabHubungan = "SUAMI/ISTRI"
|
||||
case erp.RCSelf:
|
||||
data.PenanggungjawabHubungan = "DIRI SENDIRI"
|
||||
default:
|
||||
data.PenanggungjawabHubungan = "LAINNYA ..."
|
||||
}
|
||||
|
||||
data.PenanggungjawabAlamat = *r.Address
|
||||
data.PenanggungjawabPhone = *r.PhoneNumber
|
||||
|
||||
break
|
||||
}
|
||||
case erp.RCChild:
|
||||
data.PenanggungjawabHubungan = "ANAK"
|
||||
default:
|
||||
data.PenanggungjawabHubungan = "LAINNYA"
|
||||
}
|
||||
|
||||
data.PenanggungjawabAlamat = *r.Address
|
||||
data.PenanggungjawabPhone = *r.PhoneNumber
|
||||
}
|
||||
|
||||
func setDataSimxLog(input *esyncLog.SimxLogDto) (data esync.PatientSimxLog) {
|
||||
|
||||
Reference in New Issue
Block a user