feat (encouter): not tested yet, also add crud for soapi, adime, sbar
This commit is contained in:
No files matched your search
@@ -335,3 +335,49 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
|
||||
}, nil
|
||||
|
||||
}
|
||||
|
||||
func CheckOut(input e.DischargeDto) (*d.Data, error) {
|
||||
rdDto := e.ReadDetailDto{Id: uint16(input.Id)}
|
||||
var data *e.Encounter
|
||||
var err error
|
||||
|
||||
event := pl.Event{
|
||||
Feature: "CheckOut",
|
||||
Source: source,
|
||||
}
|
||||
|
||||
// Start log
|
||||
pl.SetLogInfo(&event, input, "started", "checkOut")
|
||||
|
||||
err = dg.I.Transaction(func(tx *gorm.DB) error {
|
||||
pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
|
||||
if data, err = ReadDetailData(rdDto, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := checkSoapiByDocExists(data.Id, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := UpdateDischargeData(input, data, &event, tx); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
pl.SetLogInfo(&event, nil, "complete")
|
||||
|
||||
return nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &d.Data{
|
||||
Meta: d.IS{
|
||||
"source": source,
|
||||
"structure": "single-data",
|
||||
"status": "checkOut",
|
||||
},
|
||||
Data: data.ToResponse(),
|
||||
}, nil
|
||||
}
|
||||
@@ -5,7 +5,13 @@ Any functions that are used internally by the use-case
|
||||
package encounter
|
||||
|
||||
import (
|
||||
"errors"
|
||||
e "simrs-vx/internal/domain/main-entities/encounter"
|
||||
es "simrs-vx/internal/domain/main-entities/soapi"
|
||||
|
||||
ero "simrs-vx/internal/domain/references/organization"
|
||||
|
||||
"gorm.io/gorm"
|
||||
)
|
||||
|
||||
func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Encounter) {
|
||||
@@ -28,3 +34,31 @@ func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Encounter) {
|
||||
data.RefSource_Name = inputSrc.RefSource_Name
|
||||
data.Appointment_Id = inputSrc.Appointment_Id
|
||||
}
|
||||
|
||||
func setDataDischarge(src e.DischargeDto, dst *e.Encounter) {
|
||||
dst.DischargeMethod_Code = src.DischargeMethod_Code
|
||||
dst.EarlyEducation = src.EarlyEducation
|
||||
dst.MedicalDischargeEducation = src.MedicalDischargeEducation
|
||||
dst.AdmDischargeEducation = src.AdmDischargeEducation
|
||||
dst.DischargeReason = src.DischargeReason
|
||||
}
|
||||
|
||||
func checkSoapiByDocExists(encounter_id uint, tx *gorm.DB) error {
|
||||
soapi := es.Soapi{}
|
||||
err := tx.
|
||||
Preload("Employee").
|
||||
Preload("Employee.User").
|
||||
Where("\"Encounter_Id\" = ?", encounter_id).First(&soapi).Error
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if soapi.Employee == nil || soapi.Employee.User == nil {
|
||||
return errors.New("employee not found")
|
||||
}
|
||||
if soapi.Employee.User.Position_Code != ero.UPCDoc {
|
||||
return errors.New("employee is not a doctor")
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
@@ -153,3 +153,28 @@ func DeleteData(data *e.Encounter, event *pl.Event, dbx ...*gorm.DB) error {
|
||||
pl.SetLogInfo(event, nil, "complete")
|
||||
return nil
|
||||
}
|
||||
|
||||
func UpdateDischargeData(input e.DischargeDto, data *e.Encounter, event *pl.Event, dbx ...*gorm.DB) error {
|
||||
pl.SetLogInfo(event, data, "started", "DBUpdateDischarge")
|
||||
setDataDischarge(input, data)
|
||||
|
||||
var tx *gorm.DB
|
||||
if len(dbx) > 0 {
|
||||
tx = dbx[0]
|
||||
} else {
|
||||
tx = dg.I
|
||||
}
|
||||
|
||||
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
|
||||
}
|
||||
Reference in New Issue
Block a user