munawwirul_jamal/simrsx-be
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

adj checkout

Browse Source
This commit is contained in:
vanilia
2025-11-25 19:54:33 +07:00
parent 04312afcee dfce53946b
commit 6d2e85a8fb
13 changed files with 142 additions and 152 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/use-case/main-use-case/encounter/case.go
+37 -90
View File
@@ -19,7 +19,6 @@ import (
erg "simrs-vx/internal/domain/references/organization"
ev "simrs-vx/internal/domain/bpjs-entities/vclaim-reference"
eaeh "simrs-vx/internal/domain/main-entities/adm-employee-hist"
edc "simrs-vx/internal/domain/main-entities/death-cause"
e "simrs-vx/internal/domain/main-entities/encounter"
eir "simrs-vx/internal/domain/main-entities/internal-reference"
@@ -28,7 +27,6 @@ import (
esync "simrs-vx/internal/domain/sync-entities/log"
uv "simrs-vx/internal/use-case/bpjs-use-case/vclaim-reference"
uaeh "simrs-vx/internal/use-case/main-use-case/adm-employee-hist"
udc "simrs-vx/internal/use-case/main-use-case/death-cause"
uir "simrs-vx/internal/use-case/main-use-case/internal-reference"
urdh "simrs-vx/internal/use-case/main-use-case/responsible-doctor-hist"
@@ -126,14 +124,6 @@ func Create(input e.CreateDto) (*d.Data, error) {
Number: &vr.NoSep}, &event, tx)
}
// insert adm_employee_hist (employee with role reg for create)
if _, err = uaeh.CreateData(eaeh.CreateDto{
Encounter_Id: &data.Id,
Employee_Id: data.Adm_Employee_Id,
StartedAt: &now}, &event, tx); err != nil {
return err
}
dataEncounter, err := ReadDetailData(e.ReadDetailDto{
Id: data.Id,
Includes: "Adm_Employee.User,Patient.Person.Relatives," +
@@ -430,7 +420,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
}
func CheckOut(input e.DischargeDto) (*d.Data, error) {
rdDto := e.ReadDetailDto{Id: input.Id, Includes: "Ambulatory,Rehab"}
rdDto := e.ReadDetailDto{Id: input.Id, Includes: "Ambulatory,Rehab,InternalReferences"}
var data *e.Encounter
var err error
@@ -467,7 +457,7 @@ func CheckOut(input e.DischargeDto) (*d.Data, error) {
}
if data.Ambulatory != nil && (data.Ambulatory.Class_Code == ere.ACCReg || data.Ambulatory.Class_Code == ere.ACCRehab) {
// validate if soapi exist
// Validate SOAPI completeness: abort checkout if any required SOAPI is missing.
if err = getSoapiByTypeCode(data, &event, "check-out"); err != nil {
return err
}
@@ -479,12 +469,13 @@ func CheckOut(input e.DischargeDto) (*d.Data, error) {
}
}
} else {
// chemo TBC
// TODO: chemo TBC (to be confirm)
if err := checkSoapiByDocExists(data.Id, &event, tx); err != nil {
return err
}
}
// update encounter
if err := updateDischargeData(input, data, &event, tx); err != nil {
return err
}
@@ -499,16 +490,6 @@ func CheckOut(input e.DischargeDto) (*d.Data, error) {
}
}
// update finishedAt in latest responsible_doctor_hist
if err = updateLatestResponsibleDoctorHist(e.CheckinDto{Id: input.Id, FinishedAt: &now}, &event, tx); err != nil {
return err
}
// update finishedAt in latest adm_employee_hist
if err = updateLatestAdmEmployeeHist(e.CheckinDto{Id: input.Id, FinishedAt: &now}, &event, tx); err != nil {
return err
}
// insert data death-cause
if *input.Discharge_Method_Code == ere.DMCDeath {
if _, err = udc.CreateData(edc.CreateDto{Encounter_Id: &input.Id, Value: input.DeathCause}, &event, tx); err != nil {
@@ -516,6 +497,14 @@ func CheckOut(input e.DischargeDto) (*d.Data, error) {
}
}
// perform additional validation when discharge_method_code is "consul-poly" or "consul-executive"
if *data.Discharge_Method_Code == ere.DMCConsulPoly || *data.Discharge_Method_Code == ere.DMCConsulExecutive {
for _, v := range *data.InternalReferences {
}
}
// read newest data encounter for sync
dataEncounter, err := ReadDetailData(e.ReadDetailDto{
Id: data.Id,
Includes: "DeathCause"},
@@ -561,6 +550,14 @@ func UpdateStatusCode(input e.UpdateStatusDto) (*d.Data, error) {
// Start log
pl.SetLogInfo(&event, input, "started", "update")
// TODO: Only "supervisi pendaftaran" could cancel encounter
roleAllowed := []string{string(erg.EPCReg), string(erg.EPCNur), string(erg.EPCDoc)}
err = validateAuth(input.AuthInfo, roleAllowed, "update-status-encounter", &event)
if err != nil {
return nil, err
}
mwRunner := newMiddlewareRunner(&event)
err = dg.I.Transaction(func(tx *gorm.DB) error {
@@ -582,34 +579,6 @@ func UpdateStatusCode(input e.UpdateStatusDto) (*d.Data, error) {
if input.StatusCode == erc.DSCCancel {
// TODO: Prevent cancellation if the billing has been verified
// TODO: Only "supervisi pendaftaran" could cancel encounter
roleAllowedToCancel := []string{
string(erg.EPCReg),
string(erg.EPCNur),
string(erg.EPCDoc),
}
// 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 pl.SetLogError(&event, input)
}
if input.AuthInfo.Employee_Position_Code != nil && !pu.Contains(roleAllowedToCancel, *input.AuthInfo.Employee_Position_Code) {
event.Status = "failed"
event.ErrInfo = pl.ErrorInfo{
Code: "auth-forbidden",
Detail: "user position is not allowed, only user with registration, nurse, or doctor position is allowed to cancel encounter",
Raw: errors.New("authentication failed"),
}
return pl.SetLogError(&event, input)
}
// Prevent cancellation if soapi exist
dataSoapi, _, err := us.ReadListData(es.ReadListDto{
FilterDto: es.FilterDto{Encounter_Id: &data.Id}}, &event, tx)
@@ -632,7 +601,7 @@ func UpdateStatusCode(input e.UpdateStatusDto) (*d.Data, error) {
return err
}
if input.StatusCode == erc.DSCCancel {
if input.StatusCode == erc.DSCProcess || input.StatusCode == erc.DSCCancel {
mwRunner.setMwType(pu.MWTPre)
// Run pre-middleware
if err := mwRunner.RunUpdateStatusMiddleware(updatestatusEncounter, data); err != nil {
@@ -643,10 +612,12 @@ func UpdateStatusCode(input e.UpdateStatusDto) (*d.Data, error) {
return nil
})
if err != nil {
if err = runLogMiddleware(err, input, mwRunner); err != nil {
return nil, err
}
pl.SetLogInfo(&event, nil, "complete")
return &d.Data{
Meta: d.IS{
"source": source,
@@ -676,10 +647,10 @@ func CheckIn(input e.CheckinDto) (*d.Data, error) {
if err != nil {
return nil, err
}
input.Adm_Employee_Id = input.AuthInfo.Employee_Id
input.Responsible_Nurse_Code = input.AuthInfo.Nurse_Code
// validate foreign key
if err := validateForeignKey(input); err != nil {
if err := validateForeignKey(input, &event); err != nil {
return nil, err
}
@@ -706,7 +677,7 @@ func CheckIn(input e.CheckinDto) (*d.Data, error) {
return pl.SetLogError(&event, input)
}
// validate if soapi exist
// prevent repeated check-in. If SOAPI already exists, block the check-in process.
if data.Ambulatory != nil && (data.Ambulatory.Class_Code == ere.ACCReg || data.Ambulatory.Class_Code == ere.ACCRehab) {
err = getSoapiByTypeCode(data, &event, "check-in")
if err != nil {
@@ -714,30 +685,6 @@ func CheckIn(input e.CheckinDto) (*d.Data, error) {
}
}
// Upsert responsible_doctor_hist if responsible_doctor_code has changed
if data.Responsible_Doctor_Code == nil || *input.Responsible_Doctor_Code != *data.Responsible_Doctor_Code {
// upsert responsibleDoctorHist
if err = upsertResponsibleDoctorHist(erdh.CreateDto{
Encounter_Id: &data.Id,
Doctor_Code: input.Responsible_Doctor_Code,
StartedAt: input.StartedAt,
}, &event, tx); err != nil {
return err
}
}
// Upsert adm_employee_hist if adm_employee_id has changed
if *input.Adm_Employee_Id != *data.Adm_Employee_Id {
// upsert admEmployeeHist
if err = upsertAdmEmployeeHist(eaeh.CreateDto{
Encounter_Id: &data.Id,
Employee_Id: input.Adm_Employee_Id,
StartedAt: input.StartedAt,
}, &event, tx); err != nil {
return err
}
}
// update encounter data
if err := updateCheckInData(input, data, &event, tx); err != nil {
return err
@@ -745,7 +692,7 @@ func CheckIn(input e.CheckinDto) (*d.Data, error) {
dataEncounter, err := ReadDetailData(e.ReadDetailDto{
Id: data.Id,
Includes: "Adm_Employee.User"},
Includes: "Responsible_Nurse.Employee.User"},
&event, tx)
if err != nil {
return err
@@ -901,15 +848,15 @@ func ApproveSwitchUnit(input e.ApproveUnitDto) (*d.Data, error) {
return pl.SetLogError(&event, input)
}
//if data.IsDone() {
// event.Status = "failed"
// event.ErrInfo = pl.ErrorInfo{
// Code: "data-state-mismatch",
// Detail: "encounter is done",
// Raw: errors.New("encounter is done"),
// }
// return pl.SetLogError(&event, input)
//}
if data.IsDone() {
event.Status = "failed"
event.ErrInfo = pl.ErrorInfo{
Code: "data-state-mismatch",
Detail: "encounter is done",
Raw: errors.New("encounter is done"),
}
return pl.SetLogError(&event, input)
}
// verify Soapi exist for current responsible doctor
dataSoapi, err := getSoapiByResponsibleDoctor(*data, &event)
internal/use-case/main-use-case/encounter/helper.go
+8 -10
View File
@@ -7,6 +7,7 @@ package encounter
import (
"errors"
"fmt"
un "simrs-vx/internal/use-case/main-use-case/nurse"
"strings"
"time"
@@ -29,7 +30,6 @@ import (
edo "simrs-vx/internal/domain/main-entities/device-order"
ed "simrs-vx/internal/domain/main-entities/doctor"
ee "simrs-vx/internal/domain/main-entities/emergency"
eem "simrs-vx/internal/domain/main-entities/employee"
e "simrs-vx/internal/domain/main-entities/encounter"
ei "simrs-vx/internal/domain/main-entities/inpatient"
emo "simrs-vx/internal/domain/main-entities/material-order"
@@ -38,6 +38,7 @@ import (
emei "simrs-vx/internal/domain/main-entities/medication-item"
emi "simrs-vx/internal/domain/main-entities/medicine-mix"
emmi "simrs-vx/internal/domain/main-entities/medicine-mix-item"
en "simrs-vx/internal/domain/main-entities/nurse"
ep "simrs-vx/internal/domain/main-entities/prescription"
epi "simrs-vx/internal/domain/main-entities/prescription-item"
er "simrs-vx/internal/domain/main-entities/rehab"
@@ -51,12 +52,12 @@ import (
uc "simrs-vx/internal/use-case/main-use-case/chemo"
ud "simrs-vx/internal/use-case/main-use-case/doctor"
ue "simrs-vx/internal/use-case/main-use-case/emergency"
uem "simrs-vx/internal/use-case/main-use-case/employee"
ui "simrs-vx/internal/use-case/main-use-case/inpatient"
um "simrs-vx/internal/use-case/main-use-case/medication"
umei "simrs-vx/internal/use-case/main-use-case/medication-item"
umi "simrs-vx/internal/use-case/main-use-case/medicine-mix"
ummi "simrs-vx/internal/use-case/main-use-case/medicine-mix-item"
_ "simrs-vx/internal/use-case/main-use-case/nurse"
up "simrs-vx/internal/use-case/main-use-case/prescription"
upi "simrs-vx/internal/use-case/main-use-case/prescription-item"
ur "simrs-vx/internal/use-case/main-use-case/rehab"
@@ -122,10 +123,7 @@ func setDataUpdateStatus(src e.UpdateStatusDto, dst *e.Encounter) {
}
func setDataCheckIn(src e.CheckinDto, dst *e.Encounter) {
if src.Adm_Employee_Id != nil {
dst.Adm_Employee_Id = src.Adm_Employee_Id
}
dst.Responsible_Nurse_Code = src.Responsible_Nurse_Code
dst.Responsible_Doctor_Code = src.Responsible_Doctor_Code
dst.StartedAt = src.StartedAt
}
@@ -905,17 +903,17 @@ func updateRehabStatus(input er.UpdateDto, event *pl.Event, dbx ...*gorm.DB) err
return nil
}
func validateForeignKey(input e.CheckinDto) error {
func validateForeignKey(input e.CheckinDto, event *pl.Event) error {
// validate employee_Id
if input.Adm_Employee_Id != nil {
if _, err := uem.ReadDetail(eem.ReadDetailDto{Id: uint16(*input.Adm_Employee_Id)}); err != nil {
if input.Responsible_Nurse_Code != nil {
if _, err := un.ReadDetailData(en.ReadDetailDto{Code: input.Responsible_Nurse_Code}, event); err != nil {
return err
}
}
// validate doctor_Code
if input.Responsible_Doctor_Code != nil {
if _, err := ud.ReadDetail(ed.ReadDetailDto{Code: input.Responsible_Doctor_Code}); err != nil {
if _, err := ud.ReadDetailData(ed.ReadDetailDto{Code: input.Responsible_Doctor_Code}, event); err != nil {
return err
}
}
internal/use-case/main-use-case/encounter/middleware.go
+1 -1
View File
@@ -21,5 +21,5 @@ func init() {
checkoutEncounter = checkoutMw{Name: "sync-checkout-encounter", Func: plugin.Checkout}
updatestatusEncounter = append(updatestatusEncounter,
updateStatusMw{Name: "sync-update-status-encounter", Func: plugin.Cancel})
updateStatusMw{Name: "sync-update-status-encounter", Func: plugin.UpdateStatus})
}