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

set checkin checkout

Browse Source
This commit is contained in:
vanilia
2025-11-24 10:17:37 +07:00
parent ee6f37bb54
commit 157ea603a4
13 changed files with 694 additions and 136 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/domain/main-entities/encounter/dto.go
+4
View File
@@ -140,6 +140,8 @@ type DischargeDto struct {
AdmDischargeEducation *string `json:"admDischargeEducation"`
DischargeReason *string `json:"dischargeReason"`
DeathCause *string `json:"deathCause"`
pa.AuthInfo
}
type CheckinDto struct {
@@ -148,6 +150,8 @@ type CheckinDto struct {
Adm_Employee_Id *uint `json:"adm_employee_id"`
StartedAt *time.Time `json:"startedAt"`
FinishedAt *time.Time `json:"finishedAt"`
pa.AuthInfo
}
type SwitchUnitDto struct {
internal/interface/main-handler/encounter/handler.go
+29 -4
View File
@@ -70,6 +70,11 @@ func (obj myBase) GetDetail(w http.ResponseWriter, r *http.Request) {
}
func (obj myBase) Update(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)
}
id := rw.ValidateInt(w, "id", r.PathValue("id"))
if id <= 0 {
return
@@ -80,29 +85,39 @@ func (obj myBase) Update(w http.ResponseWriter, r *http.Request) {
return
}
dto.Id = uint16(id)
dto.AuthInfo = *authInfo
res, err := u.Update(dto)
rw.DataResponse(w, res, err)
}
func (obj myBase) Delete(w http.ResponseWriter, r *http.Request) {
id := rw.ValidateInt(w, "id", r.PathValue("id"))
if id <= 0 {
return
}
authInfo, err := pa.GetAuthInfo(r)
if err != nil {
rw.WriteJSON(w, http.StatusUnauthorized, d.IS{"message": err.Error()}, nil)
}
id := rw.ValidateInt(w, "id", r.PathValue("id"))
if id <= 0 {
return
}
dto := e.DeleteDto{}
dto.Id = uint16(id)
dto.AuthInfo = *authInfo
res, err := u.Delete(dto)
rw.DataResponse(w, res, err)
}
func (obj myBase) CheckOut(w http.ResponseWriter, r *http.Request) {
dto := e.DischargeDto{}
authInfo, err := pa.GetAuthInfo(r)
if err != nil {
rw.WriteJSON(w, http.StatusUnauthorized, d.IS{"message": err.Error()}, nil)
}
id := rw.ValidateInt(w, "id", r.PathValue("id"))
if id <= 0 {
return
@@ -118,12 +133,20 @@ func (obj myBase) CheckOut(w http.ResponseWriter, r *http.Request) {
}
dto.Id = uint(id)
dto.AuthInfo = *authInfo
res, err := u.CheckOut(dto)
rw.DataResponse(w, res, err)
}
func (obj myBase) CheckIn(w http.ResponseWriter, r *http.Request) {
dto := e.CheckinDto{}
authInfo, err := pa.GetAuthInfo(r)
if err != nil {
rw.WriteJSON(w, http.StatusUnauthorized, d.IS{"message": err.Error()}, nil)
}
id := rw.ValidateInt(w, "id", r.PathValue("id"))
if id <= 0 {
return
@@ -139,6 +162,8 @@ func (obj myBase) CheckIn(w http.ResponseWriter, r *http.Request) {
}
dto.Id = uint(id)
dto.AuthInfo = *authInfo
res, err := u.CheckIn(dto)
rw.DataResponse(w, res, err)
}
internal/interface/simgos-sync-handler/encounter/handler.go
+63
View File
@@ -0,0 +1,63 @@
package encounter
import (
"net/http"
rw "github.com/karincake/risoles"
// ua "github.com/karincake/tumpeng/auth/svc"
e "simrs-vx/internal/domain/main-entities/encounter"
esync "simrs-vx/internal/domain/sync-entities/log"
u "simrs-vx/internal/use-case/simgos-sync-use-case/encounter"
)
type myBase struct{}
var O myBase
func (obj myBase) Create(w http.ResponseWriter, r *http.Request) {
dto := e.Encounter{}
if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
return
}
res, err := u.Create(dto)
rw.DataResponse(w, res, err)
}
func (obj myBase) CreateLog(w http.ResponseWriter, r *http.Request) {
dto := esync.SimxLogDto{}
if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
return
}
res, err := u.CreateSimxLog(dto)
rw.DataResponse(w, res, err)
}
func (obj myBase) Update(w http.ResponseWriter, r *http.Request) {
id := rw.ValidateInt(w, "id", r.PathValue("id"))
if id <= 0 {
return
}
dto := e.Encounter{}
if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
return
}
dto.Id = uint(id)
res, err := u.Update(dto)
rw.DataResponse(w, res, err)
}
func (obj myBase) Delete(w http.ResponseWriter, r *http.Request) {
id := rw.ValidateInt(w, "id", r.PathValue("id"))
if id <= 0 {
return
}
dto := e.DeleteDto{}
dto.Id = uint16(id)
res, err := u.Delete(dto)
rw.DataResponse(w, res, err)
}
internal/interface/simgos-sync-handler/simgos-sync-handler.go
+2
View File
@@ -19,6 +19,7 @@ import (
/******************** internal ********************/
"simrs-vx/internal/interface/main-handler/home"
division "simrs-vx/internal/interface/simgos-sync-handler/division"
encounter "simrs-vx/internal/interface/simgos-sync-handler/encounter"
installation "simrs-vx/internal/interface/simgos-sync-handler/installation"
patient "simrs-vx/internal/interface/simgos-sync-handler/patient"
specialist "simrs-vx/internal/interface/simgos-sync-handler/specialist"
@@ -47,6 +48,7 @@ func SetRoutes() http.Handler {
hc.SyncCrud(r, prefix+"/v1/subspecialist", subspecialist.O)
hc.SyncCrud(r, prefix+"/v1/patient", patient.O)
r.HandleFunc(fmt.Sprintf("GET %s/v1/patient-nomr-generator", prefix), patient.O.GenerateNomr)
hc.SyncCrud(r, prefix+"/v1/encounter", encounter.O)
return cmw.SetCors(handlerlogger.SetLog(r))
}
internal/use-case/main-use-case/encounter/case.go
+133 -67
View File
@@ -3,6 +3,7 @@ package encounter
import (
"errors"
"fmt"
"simrs-vx/internal/lib/auth"
"strconv"
"time"
@@ -17,6 +18,7 @@ import (
ere "simrs-vx/internal/domain/references/encounter"
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"
@@ -25,6 +27,7 @@ import (
es "simrs-vx/internal/domain/main-entities/soapi"
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"
@@ -51,28 +54,10 @@ func Create(input e.CreateDto) (*d.Data, error) {
// Start log
pl.SetLogInfo(&event, input, "started", "create")
// 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)
}
// check only user with registration position is allowed to create encounter
if input.AuthInfo.Employee_Position_Code != nil && *input.AuthInfo.Employee_Position_Code != string(erg.EPCReg) {
event.Status = "failed"
event.ErrInfo = pl.ErrorInfo{
Code: "auth-forbidden",
Detail: "user position is not allowed, only user with registration position is allowed to create encounter",
Raw: errors.New("authentication failed"),
}
return nil, pl.SetLogError(&event, input)
} else {
input.Adm_Employee_Id = input.AuthInfo.Employee_Id
roleAllowed := []string{string(erg.EPCReg)}
err = validateAuth(input.AuthInfo, roleAllowed, "create-encounter", &event)
if err != nil {
return nil, err
}
// validate rehab by bpjs
@@ -90,6 +75,7 @@ func Create(input e.CreateDto) (*d.Data, error) {
// If recentRehabData is not nil, determine the visitMode_Code:
// If the mode is "series", verify whether the visit count still remains
// and whether the series has not expired.
// If visitMode is "series", then get encounterAdm
input.VisitMode_Code, input.RecentEncounterAdm, err = determineVisitMode(recentRehabData, input, &event)
if err != nil {
return nil, err
@@ -110,6 +96,8 @@ func Create(input e.CreateDto) (*d.Data, error) {
// check if patient is new in the hospital
input.NewStatus, err = identifyPatientStatus(input)
input.Adm_Employee_Id = input.AuthInfo.Employee_Id
mwRunner := newMiddlewareRunner(&event)
err = dg.I.Transaction(func(tx *gorm.DB) error {
@@ -127,7 +115,19 @@ func Create(input e.CreateDto) (*d.Data, error) {
return err
}
// insert adm_employee_hist
// insert vclaimReference
if vr := input.VclaimReference; vr != nil {
t, _ := time.Parse("2006-01-02", vr.TglRujukan)
_, err = uv.CreateData(ev.CreateDto{
Encounter_Id: &data.Id,
Date: &t,
SrcCode: input.Ref_Number,
SrcName: input.RefSource_Name,
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,
@@ -137,7 +137,7 @@ func Create(input e.CreateDto) (*d.Data, error) {
dataEncounter, err := ReadDetailData(e.ReadDetailDto{
Id: uint16(data.Id),
Includes: "Adm_Employee.User,Patient.Person.Relatives,Patient.Person.VclaimMember"},
Includes: "Adm_Employee.User,Patient.Person.Relatives,Patient.Person.VclaimMember,VclaimReference"},
&event, tx)
if err != nil {
return err
@@ -280,6 +280,14 @@ func Update(input e.UpdateDto) (*d.Data, error) {
// Start log
pl.SetLogInfo(&event, input, "started", "update")
roleAllowed := []string{string(erg.EPCReg)}
err = validateAuth(input.AuthInfo, roleAllowed, "update-encounter", &event)
if err != nil {
return nil, err
}
input.Adm_Employee_Id = input.AuthInfo.Employee_Id
mwRunner := newMiddlewareRunner(&event)
err = dg.I.Transaction(func(tx *gorm.DB) error {
@@ -349,26 +357,10 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
// Start log
pl.SetLogInfo(&event, input, "started", "delete")
// 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)
}
// check only user with registration position is allowed to create encounter
if input.AuthInfo.Employee_Position_Code != nil && *input.AuthInfo.Employee_Position_Code != string(erg.EPCReg) {
event.Status = "failed"
event.ErrInfo = pl.ErrorInfo{
Code: "auth-forbidden",
Detail: "user position is not allowed, only user with registration position is allowed to create encounter",
Raw: errors.New("authentication failed"),
}
return nil, pl.SetLogError(&event, input)
roleAllowed := []string{string(erg.EPCReg)}
err = validateAuth(input.AuthInfo, roleAllowed, "delete-encounter", &event)
if err != nil {
return nil, err
}
mwRunner := newMiddlewareRunner(&event)
@@ -379,6 +371,33 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
return err
}
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)
}
// Prevent delete if soapi exist
dataSoapi, _, err := us.ReadListData(es.ReadListDto{
FilterDto: es.FilterDto{Encounter_Id: &data.Id}}, &event, tx)
if err != nil {
return err
}
if len(dataSoapi) > 0 {
event.Status = "failed"
event.ErrInfo = pl.ErrorInfo{
Code: "cancel-not-allowed",
Detail: "encounter can't be deleted because SOAPI already exists",
Raw: errors.New("encounter has SOAPI records"),
}
return pl.SetLogError(&event, input)
}
if err := DeleteData(data, &event, tx); err != nil {
return err
}
@@ -422,6 +441,14 @@ func CheckOut(input e.DischargeDto) (*d.Data, error) {
// Start log
pl.SetLogInfo(&event, input, "started", "checkOut")
roleAllowed := []string{string(erg.EPCNur), string(erg.EPCDoc)}
err = validateAuth(input.AuthInfo, roleAllowed, "checkOut-encounter", &event)
if err != nil {
return nil, err
}
mwRunner := newMiddlewareRunner(&event)
err = dg.I.Transaction(func(tx *gorm.DB) error {
pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
if data, err = ReadDetailData(rdDto, &event, tx); err != nil {
@@ -445,7 +472,7 @@ func CheckOut(input e.DischargeDto) (*d.Data, error) {
}
if data.Ambulatory.Class_Code == ere.ACCRehab {
// verify and update rehabData if visit count has reached the allowed limit
// verify and update rehabData to DONE if visit count has reached the allowed limit
if err = verifyRehabLimit(data, &event, tx); err != nil {
return err
}
@@ -488,15 +515,21 @@ func CheckOut(input e.DischargeDto) (*d.Data, error) {
}
}
pl.SetLogInfo(&event, nil, "complete")
mwRunner.setMwType(pu.MWTPre)
// Run pre-middleware
if err := mwRunner.RunCheckoutMiddleware(checkoutEncounter, &input); err != nil {
return err
}
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,
@@ -568,11 +601,8 @@ func UpdateStatusCode(input e.UpdateStatusDto) (*d.Data, error) {
}
// Prevent cancellation if soapi exist
encounterId := uint(input.Id)
dataSoapi, _, err := us.ReadListData(es.ReadListDto{
FilterDto: es.FilterDto{
Encounter_Id: &encounterId,
}}, &event, tx)
FilterDto: es.FilterDto{Encounter_Id: &data.Id}}, &event, tx)
if err != nil {
return err
}
@@ -588,25 +618,12 @@ func UpdateStatusCode(input e.UpdateStatusDto) (*d.Data, error) {
}
}
//mwRunner := newMiddlewareRunner(&event)
//mwRunner.setMwType(pu.MWTPre)
//// Run pre-middleware
//if err := mwRunner.RunUpdateMiddleware(readDetailPreMw, &rdDto, data); err != nil {
// return err
//}
if err := UpdateStatusData(input, data, &event, tx); err != nil {
return err
}
pl.SetLogInfo(&event, nil, "complete")
//mwRunner.setMwType(pu.MWTPost)
//// Run post-middleware
//if err := mwRunner.RunUpdateMiddleware(readDetailPostMw, &rdDto, data); err != nil {
// return err
//}
return nil
})
@@ -638,6 +655,13 @@ func CheckIn(input e.CheckinDto) (*d.Data, error) {
// Start log
pl.SetLogInfo(&event, input, "started", "checkIn")
roleAllowed := []string{string(erg.EPCNur), string(erg.EPCDoc)}
err = validateAuth(input.AuthInfo, roleAllowed, "checkIn-encounter", &event)
if err != nil {
return nil, err
}
input.Adm_Employee_Id = input.AuthInfo.Employee_Id
// validate foreign key
if err := validateForeignKey(input); err != nil {
return nil, err
@@ -648,6 +672,8 @@ func CheckIn(input e.CheckinDto) (*d.Data, error) {
input.StartedAt = &now
}
mwRunner := newMiddlewareRunner(&event)
err = dg.I.Transaction(func(tx *gorm.DB) error {
pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
if data, err = ReadDetailData(rdDto, &event, tx); err != nil {
@@ -685,7 +711,7 @@ func CheckIn(input e.CheckinDto) (*d.Data, error) {
}
// Upsert adm_employee_hist if adm_employee_id has changed
if input.Adm_Employee_Id != nil && *input.Adm_Employee_Id != *data.Adm_Employee_Id {
if *input.Adm_Employee_Id != *data.Adm_Employee_Id {
// upsert admEmployeeHist
if err = upsertAdmEmployeeHist(eaeh.CreateDto{
Encounter_Id: &data.Id,
@@ -701,15 +727,29 @@ func CheckIn(input e.CheckinDto) (*d.Data, error) {
return err
}
pl.SetLogInfo(&event, nil, "complete")
dataEncounter, err := ReadDetailData(e.ReadDetailDto{
Id: uint16(data.Id),
Includes: "Adm_Employee.User"},
&event, tx)
if err != nil {
return err
}
mwRunner.setMwType(pu.MWTPre)
// Run pre-middleware
if err := mwRunner.RunCheckinMiddleware(checkinEncounterMw, dataEncounter); err != nil {
return err
}
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,
@@ -951,3 +991,29 @@ func runLogMiddleware(err error, input any, mwRunner *middlewareRunner) error {
return nil
}
func validateAuth(a auth.AuthInfo, roleAllowed []string, action string, event *pl.Event) error {
// check if user has employee position
if !a.HasEmployeePosition() {
event.Status = "failed"
event.ErrInfo = pl.ErrorInfo{
Code: "auth-forbidden",
Detail: "missing employee position",
Raw: errors.New("authentication failed"),
}
return pl.SetLogError(event, a)
}
// check only roleAllowed position is allowed to create encounter
if a.Employee_Position_Code != nil && !pu.Contains(roleAllowed, *a.Employee_Position_Code) {
event.Status = "failed"
event.ErrInfo = pl.ErrorInfo{
Code: "auth-forbidden",
Detail: fmt.Sprintf("position '%s' is not allowed to %s", *a.Employee_Position_Code, action),
Raw: errors.New("authentication failed"),
}
return pl.SetLogError(event, a)
}
return nil
}
internal/use-case/main-use-case/encounter/helper.go
+1 -1
View File
@@ -617,7 +617,7 @@ func getSoapiByTypeCode(encounter *e.Encounter, event *pl.Event, mode string) (e
rehab = encounter.Rehab
)
// Set Query for get data Soapi
// Set Query for get data Soapi by doc
tx := dg.I.
Model(&es.Soapi{}).
Joins("JOIN \"Employee\" ON \"Employee\".\"Id\" = \"Soapi\".\"Employee_Id\"").
internal/use-case/main-use-case/encounter/middleware-runner.go
+36
View File
@@ -143,6 +143,42 @@ func (me *middlewareRunner) RunDeleteMiddleware(middlewares []deleteMw, input *e
return nil
}
func (me *middlewareRunner) RunCheckinMiddleware(middleware checkinMw, input *e.Encounter) error {
if !me.SyncOn {
return nil
}
logData := pu.GetLogData(input, nil)
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
if err := middleware.Func(input); 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) RunCheckoutMiddleware(middleware checkoutMw, input *e.DischargeDto) error {
if !me.SyncOn {
return nil
}
logData := pu.GetLogData(input, nil)
pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
if err := middleware.Func(input); 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
}
internal/use-case/main-use-case/encounter/middleware.go
+15 -7
View File
@@ -1,9 +1,17 @@
package encounter
// example of middleware
// func init() {
// createPreMw = append(createPreMw,
// CreateMw{Name: "modif-input", Func: pm.ModifInput},
// CreateMw{Name: "check-data", Func: pm.CheckData},
// )
// }
import plugin "simrs-vx/internal/use-case/simgos-sync-plugin/encounter"
func init() {
createPreMw = append(createPreMw,
createMw{Name: "sync-update-encounter", Func: plugin.Create})
createSimxLogMw = append(createSimxLogMw,
createLogMw{Name: "create-sync-log", Func: plugin.CreateLog})
updatePreMw = append(updatePreMw,
updateMw{Name: "sync-update-patient", Func: plugin.Update})
deletePreMw = append(deletePreMw,
deleteMw{Name: "sync-delete-patient", Func: plugin.Delete})
}
internal/use-case/main-use-case/encounter/tycovar.go
+12
View File
@@ -44,6 +44,16 @@ type readDetailMw struct {
Func func(input *e.ReadDetailDto, data *e.Encounter, tx *gorm.DB) error
}
type checkinMw struct {
Name string
Func func(input *e.Encounter) error
}
type checkoutMw struct {
Name string
Func func(input *e.DischargeDto) error
}
type UpdateMw = updateMw
type DeleteMw = deleteMw
@@ -58,3 +68,5 @@ var updatePreMw []updateMw
var updatePostMw []readDetailMw
var deletePreMw []deleteMw
var deletePostMw []readDetailMw
var checkinEncounterMw checkinMw
var checkoutEncounter checkoutMw
internal/use-case/simgos-sync-plugin/encounter/plugin.go
+167
View File
@@ -0,0 +1,167 @@
package encounter
import (
"bytes"
"encoding/json"
"fmt"
"io"
"net/http"
d "github.com/karincake/dodol"
sync "simrs-vx/internal/infra/sync-cfg"
e "simrs-vx/internal/domain/main-entities/encounter"
elog "simrs-vx/internal/domain/sync-entities/log"
)
func Create(input *e.Encounter) error {
endpoint := getPrefixEndpoint()
jsonData, err := json.Marshal(input)
if err != nil {
return fmt.Errorf("failed to encode JSON: %w", err)
}
req, err := http.NewRequest("POST", endpoint, bytes.NewReader(jsonData))
if err != nil {
return err
}
req.Header.Set("Content-Type", "application/json")
resp, err := http.DefaultClient.Do(req)
if err != nil {
return err
}
defer resp.Body.Close()
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return err
}
if resp.StatusCode != http.StatusOK {
errors := d.FieldError{}
_ = json.Unmarshal(bodyBytes, &errors)
return fmt.Errorf(errors.Message)
}
return nil
}
func CreateLog(input *elog.SimxLogDto) error {
prefixEndpoint := getPrefixEndpoint()
endpoint := prefixEndpoint + "/log"
jsonData, err := json.Marshal(input)
if err != nil {
return fmt.Errorf("failed to encode JSON: %w", err)
}
req, err := http.NewRequest("POST", endpoint, bytes.NewReader(jsonData))
if err != nil {
return err
}
req.Header.Set("Content-Type", "application/json")
resp, err := http.DefaultClient.Do(req)
if err != nil {
return err
}
defer resp.Body.Close()
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return err
}
if resp.StatusCode != http.StatusOK {
errors := d.FieldError{}
_ = json.Unmarshal(bodyBytes, &errors)
return fmt.Errorf(errors.Message)
}
return nil
}
func Update(input *e.Encounter) error {
prefixEndpoint := getPrefixEndpoint()
endpoint := fmt.Sprintf("%s/%v", prefixEndpoint, input.Id)
jsonData, err := json.Marshal(input)
if err != nil {
return fmt.Errorf("failed to encode JSON: %w", err)
}
req, err := http.NewRequest("PATCH", endpoint, bytes.NewReader(jsonData))
if err != nil {
return err
}
req.Header.Set("Content-Type", "application/json")
resp, err := http.DefaultClient.Do(req)
if err != nil {
return err
}
defer resp.Body.Close()
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return err
}
if resp.StatusCode != http.StatusOK {
errors := d.FieldError{}
_ = json.Unmarshal(bodyBytes, &errors)
return fmt.Errorf(errors.Message)
}
return nil
}
func Delete(input *e.DeleteDto) error {
prefixEndpoint := getPrefixEndpoint()
endpoint := fmt.Sprintf("%s/%v", prefixEndpoint, input.Id)
jsonData, err := json.Marshal(input)
if err != nil {
return fmt.Errorf("failed to encode JSON: %w", err)
}
req, err := http.NewRequest("DELETE", endpoint, bytes.NewReader(jsonData))
if err != nil {
return err
}
req.Header.Set("Content-Type", "application/json")
resp, err := http.DefaultClient.Do(req)
if err != nil {
return err
}
defer resp.Body.Close()
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return err
}
if resp.StatusCode != http.StatusOK {
errors := d.FieldError{}
_ = json.Unmarshal(bodyBytes, &errors)
return fmt.Errorf(errors.Message)
}
return nil
}
func getPrefixEndpoint() string {
return fmt.Sprintf("%s%s/v1/encounter", sync.O.Host, sync.O.Prefix)
}
internal/use-case/simgos-sync-use-case/encounter/case.go
+98 -4
View File
@@ -33,7 +33,7 @@ func Create(input e.Encounter) (*d.Data, error) {
err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 1: Insert to simgos
sgData, err = CreateSimgosData(input, &event, tx.Simgos)
sgData, err = CreateTPendaftaranData(input, &event, tx.Simgos)
if err != nil {
return err
}
@@ -114,10 +114,16 @@ func Update(input e.Encounter) (*d.Data, error) {
return nil, err
}
// STEP 2: Get Simgos
simgos, err := ReadEncounterDetailData(uint16(syncLink.Simgos_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 {
if err = UpdateTPendaftaranData(input, *simgos, &event, tx); err != nil {
return err
}
@@ -153,14 +159,14 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
}
// STEP 2: Get Simgos
sgData, err := ReadDetailSimgosData(uint16(syncLink.Simgos_Id), &event)
sgData, err := ReadEncounterDetailData(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)
err = HardDeleteTPendaftaranData(sgData, &event, tx.Simgos)
if err != nil {
return err
}
@@ -195,3 +201,91 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
}, nil
}
func CheckIn(input e.Encounter) (*d.Data, error) {
event := pl.Event{
Feature: "CheckIn",
Source: source,
}
// Start log
pl.SetLogInfo(&event, input, "started", "check-in")
// STEP 1: Get Link
syncLink, err := ReadDetailLinkData(uint16(input.Id), &event)
if err != nil {
return nil, err
}
// STEP 2: Get Simgos
simgos, err := ReadEncounterDetailData(uint16(syncLink.Simgos_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 = UpdateCheckinData(input, *simgos, &event, tx); err != nil {
return err
}
// TODO: insert t_pemeriksaan_hist
return nil
})
pl.SetLogInfo(&event, nil, "complete")
return &d.Data{
Meta: d.IS{
"source": source,
"structure": "single-data",
"status": "updated",
},
}, nil
}
func CheckOut(input e.DischargeDto) (*d.Data, error) {
event := pl.Event{
Feature: "CheckIn",
Source: source,
}
// Start log
pl.SetLogInfo(&event, input, "started", "check-in")
// STEP 1: Get Link
syncLink, err := ReadDetailLinkData(uint16(input.Id), &event)
if err != nil {
return nil, err
}
// STEP 2: Get Simgos
simgos, err := ReadEncounterDetailData(uint16(syncLink.Simgos_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 = UpdateCheckoutData(input, *simgos, &event, tx); err != nil {
return err
}
// TODO: insert t_pemeriksaan_hist
return nil
})
pl.SetLogInfo(&event, nil, "complete")
return &d.Data{
Meta: d.IS{
"source": source,
"structure": "single-data",
"status": "updated",
},
}, nil
}
internal/use-case/simgos-sync-use-case/encounter/helper.go
+72 -46
View File
@@ -7,11 +7,10 @@ package encounter
import (
"encoding/json"
epr "simrs-vx/internal/domain/main-entities/person-relative"
erp "simrs-vx/internal/domain/references/person"
"strconv"
erc "simrs-vx/internal/domain/references/common"
ere "simrs-vx/internal/domain/references/encounter"
erp "simrs-vx/internal/domain/references/person"
"strconv"
e "simrs-vx/internal/domain/main-entities/encounter"
esimgos "simrs-vx/internal/domain/simgos-entities/encounter"
@@ -22,17 +21,47 @@ import (
"gorm.io/gorm/clause"
)
func setDataCreate(input *e.Encounter) (data esimgos.TPendaftaran, err error) {
func setDataCreateTPendaftaran(input *e.Encounter) (data esimgos.TPendaftaran, err error) {
data.Nomr = *input.Patient.Number
// set pasienbaru
if input.NewStatus {
data.Pasienbaru = 1
}
// default kelas daftar
data.KelasDaftar = 3
// set noAntrian
defaultFromSimx := "rehab"
data.NoAntrian = &defaultFromSimx
// set no_kunjung
noKunjung, err := generateNoKunjung()
if err != nil {
return esimgos.TPendaftaran{}, err
}
data.NoKunjung = uint(noKunjung)
setDataTPendaftaran(input, data)
return
}
func setDataTPendaftaran(input *e.Encounter, data esimgos.TPendaftaran) {
data.Tglreg = input.RegisteredAt
// set kddokter
kddokter, _ := strconv.Atoi(*input.Appointment_Doctor_Code)
data.Kddokter = uint(kddokter)
if d := input.Appointment_Doctor_Code; d != nil {
kddokter, _ := strconv.Atoi(*input.Appointment_Doctor_Code)
data.Kddokter = uint(kddokter)
}
// set kdpoly
kdpoly, _ := strconv.Atoi(*input.Unit_Code)
data.Kdpoly = uint(kdpoly)
if p := input.Unit_Code; p != nil {
kdpoly, _ := strconv.Atoi(*input.Unit_Code)
data.Kdpoly = uint(kdpoly)
}
// set kdrujuk
setKdrujuk(input.RefType_Code, data)
@@ -42,11 +71,6 @@ func setDataCreate(input *e.Encounter) (data esimgos.TPendaftaran, err error) {
// TODO: shift
// set pasienbaru
if input.NewStatus {
data.Pasienbaru = 1
}
// set nip
if emp := input.Adm_Employee; emp != nil {
if user := emp.User; user != nil {
@@ -74,54 +98,40 @@ func setDataCreate(input *e.Encounter) (data esimgos.TPendaftaran, err error) {
data.Jamreg = input.RegisteredAt
// default kelas daftar
data.KelasDaftar = 3
// TODO: st_asal_masuk
// set noAntrian
defaultFromSimx := "rehab"
data.NoAntrian = &defaultFromSimx
// set no_kunjung
noKunjung, err := generateNoKunjung()
if err != nil {
return esimgos.TPendaftaran{}, err
}
data.NoKunjung = uint(noKunjung)
return
}
func setDataUpdate(input *e.Encounter, data esimgos.TPendaftaran) {
func setDataCheckIn(input e.Encounter, data esimgos.TPendaftaran) {
// set kddokter
kddokter, _ := strconv.Atoi(*input.Responsible_Doctor_Code)
data.Kddokter = uint(kddokter)
// set kdpoly
kdpoly, _ := strconv.Atoi(*input.Unit_Code)
data.Kdpoly = uint(kdpoly)
// set status
setStatus(input.Discharge_Method_Code, data)
if input.Status_Code == erc.DSCCancel {
data.Status = 11
// set petugas_klinik
if data.PetugasKlinik != "" {
if a := input.Adm_Employee; a != nil {
if u := a.User; u != nil {
data.PetugasKlinik = u.Name
}
}
}
data.Masukpoly = input.StartedAt
data.Keluarpoly = input.FinishedAt
return
}
if p := input.Patient.Person; p != nil {
mapRelative(p.Relatives, data)
}
func setDataCheckOut(input e.DischargeDto, data esimgos.TPendaftaran) {
data.Keluarpoly = &now
// set petugas_klinik
if emp := input.Adm_Employee; emp != nil {
if user := emp.User; user != nil {
data.PetugasKlinik = user.Name
}
// set status
setStatus(input.Discharge_Method_Code, data)
if data.Status == 8 || data.Status == 3 {
data.SebabMati1 = input.DeathCause
}
//if input.Status_Code == erc.DSCCancel {
// data.Status = 11
//}
return
}
@@ -162,18 +172,34 @@ func setStatus(code *ere.DischargeMethodCode, data esimgos.TPendaftaran) {
data.Status = 2
case ere.DMCDeathOnArrival:
data.Status = 3
data.StMeninggal = func(u uint) *uint { return &u }(1)
data.DtMeninggal = &now
case ere.DMCDeath:
data.Status = 8
data.StMeninggal = func(u uint) *uint { return &u }(1)
data.DtMeninggal = &now
case ere.DMCHomeReq:
data.Status = 7
case ere.DMCConsulPoly:
data.Status = 5
data.PoliNameHfis = nil
data.SpesialisIdHfis = nil
data.DokterNameHfis = nil
data.DokterIdHfis = nil
case ere.DMCExtRef:
data.Status = 6
case ere.DMCConsulChDay:
data.Status = 12
data.PoliNameHfis = nil
data.SpesialisIdHfis = nil
data.DokterNameHfis = nil
data.DokterIdHfis = nil
case ere.DMCEmergency:
data.Status = 10
data.PoliNameHfis = nil
data.SpesialisIdHfis = nil
data.DokterNameHfis = nil
data.DokterIdHfis = nil
case ere.DMCEmergencyCovid:
data.Status = 13
case ere.DMCConsulExecutive:
internal/use-case/simgos-sync-use-case/encounter/lib.go
+62 -7
View File
@@ -17,10 +17,13 @@ import (
var now = time.Now()
func CreateSimgosData(input e.Encounter, event *pl.Event, dbx ...*gorm.DB) (*esimgos.TPendaftaran, error) {
func CreateTPendaftaranData(input e.Encounter, event *pl.Event, dbx ...*gorm.DB) (*esimgos.TPendaftaran, error) {
pl.SetLogInfo(event, nil, "started", "DBCreate")
data := setDataSimgos(&input)
data, err := setDataCreateTPendaftaran(&input)
if err != nil {
return nil, plh.HandleCreateError(input, event, err)
}
var tx *gorm.DB
if len(dbx) > 0 {
@@ -37,7 +40,7 @@ func CreateSimgosData(input e.Encounter, event *pl.Event, dbx ...*gorm.DB) (*esi
return &data, nil
}
func ReadDetailSimgosData(simgosId uint16, event *pl.Event) (*esimgos.TPendaftaran, error) {
func ReadEncounterDetailData(simgosId uint16, event *pl.Event) (*esimgos.TPendaftaran, error) {
pl.SetLogInfo(event, simgosId, "started", "DBReadDetail")
data := esimgos.TPendaftaran{}
@@ -55,11 +58,10 @@ func ReadDetailSimgosData(simgosId uint16, event *pl.Event) (*esimgos.TPendaftar
return &data, nil
}
func UpdateSimgosData(input e.Encounter, dataSimgos *esync.EncounterLink, event *pl.Event, dbx ...*gorm.DB) error {
func UpdateTPendaftaranData(input e.Encounter, data esimgos.TPendaftaran, event *pl.Event, dbx ...*gorm.DB) error {
pl.SetLogInfo(event, input, "started", "DBUpdate")
data := setDataSimgos(&input)
data.Idxdaftar = dataSimgos.Simgos_Id
setDataTPendaftaran(&input, data)
var tx *gorm.DB
if len(dbx) > 0 {
@@ -82,7 +84,7 @@ func UpdateSimgosData(input e.Encounter, dataSimgos *esync.EncounterLink, event
return nil
}
func HardDeleteSimgosData(data *esimgos.TPendaftaran, event *pl.Event, dbx ...*gorm.DB) error {
func HardDeleteTPendaftaranData(data *esimgos.TPendaftaran, event *pl.Event, dbx ...*gorm.DB) error {
pl.SetLogInfo(event, data, "started", "DBDelete")
var tx *gorm.DB
@@ -107,6 +109,59 @@ func HardDeleteSimgosData(data *esimgos.TPendaftaran, event *pl.Event, dbx ...*g
return nil
}
func UpdateCheckinData(input e.Encounter, data esimgos.TPendaftaran, event *pl.Event, dbx ...*gorm.DB) error {
pl.SetLogInfo(event, input, "started", "DBUpdate")
setDataCheckIn(input, data)
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 UpdateCheckoutData(input e.DischargeDto, data esimgos.TPendaftaran, event *pl.Event, dbx ...*gorm.DB) error {
pl.SetLogInfo(event, input, "started", "DBUpdate")
setDataCheckOut(input, data)
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 CreateTPemeriksaanHist
func CreateLinkData(simxId, simgosId uint, event *pl.Event, dbx ...*gorm.DB) (*esync.EncounterLink, error) {
pl.SetLogInfo(event, nil, "started", "DBCreate")
data := setDataSimxLink(simxId, simgosId)