enhancement update encounter status code

internal/domain/main-entities/encounter/dto.go

@@ -66,6 +66,11 @@ type UpdateDto struct {
 	CreateDto
 }
 
+type UpdateStatusDto struct {
+	Id         uint16             `json:"id"`
+	StatusCode erc.DataStatusCode `json:"status_code"`
+}
+
 type DeleteDto struct {
 	Id uint16 `json:"id"`
 }

internal/interface/main-handler/encounter/handler.go

@@ -10,6 +10,8 @@ import (
 
 	e "simrs-vx/internal/domain/main-entities/encounter"
 	u "simrs-vx/internal/use-case/main-use-case/encounter"
+
+	erc "simrs-vx/internal/domain/references/common"
 )
 
 type myBase struct{}
@@ -83,3 +85,63 @@ func (obj myBase) CheckOut(w http.ResponseWriter, r *http.Request) {
 	res, err := u.CheckOut(dto)
 	rw.DataResponse(w, res, err)
 }
+
+func (obj myBase) Process(w http.ResponseWriter, r *http.Request) {
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	if id <= 0 {
+		return
+	}
+
+	dto := e.UpdateStatusDto{
+		Id:         uint16(id),
+		StatusCode: erc.DSCProcess,
+	}
+
+	res, err := u.UpdateStatusCode(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) Cancel(w http.ResponseWriter, r *http.Request) {
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	if id <= 0 {
+		return
+	}
+
+	dto := e.UpdateStatusDto{
+		Id:         uint16(id),
+		StatusCode: erc.DSCCancel,
+	}
+
+	res, err := u.UpdateStatusCode(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) Reject(w http.ResponseWriter, r *http.Request) {
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	if id <= 0 {
+		return
+	}
+
+	dto := e.UpdateStatusDto{
+		Id:         uint16(id),
+		StatusCode: erc.DSCRejected,
+	}
+
+	res, err := u.UpdateStatusCode(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) Skip(w http.ResponseWriter, r *http.Request) {
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	if id <= 0 {
+		return
+	}
+
+	dto := e.UpdateStatusDto{
+		Id:         uint16(id),
+		StatusCode: erc.DSCSkipped,
+	}
+
+	res, err := u.UpdateStatusCode(dto)
+	rw.DataResponse(w, res, err)
+}

internal/interface/main-handler/main-handler.go

@@ -168,6 +168,10 @@ func SetRoutes() http.Handler {
 		"PATCH /{id}":          encounter.O.Update,
 		"DELETE /{id}":         encounter.O.Delete,
 		"PATCH /{id}/checkout": encounter.O.CheckOut,
+		"PATCH /{id}/proccess": encounter.O.Process,
+		"PATCH /{id}/cancel":   encounter.O.Cancel,
+		"PATCH /{id}/reject":   encounter.O.Reject,
+		"PATCH /{id}/skip":     encounter.O.Skip,
 	})
 	hk.GroupRoutes("/v1/medication", r, auth.GuardMW, hk.MapHandlerFunc{
 		"GET /":                medication.O.GetList,

internal/use-case/main-use-case/encounter/case.go

@@ -421,3 +421,69 @@ func CheckOut(input e.DischargeDto) (*d.Data, error) {
 		Data: data.ToResponse(),
 	}, nil
 }
+
+func UpdateStatusCode(input e.UpdateStatusDto) (*d.Data, error) {
+	rdDto := e.ReadDetailDto{Id: input.Id}
+	var data *e.Encounter
+	var err error
+
+	event := pl.Event{
+		Feature: "Update Status Code",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "update")
+
+	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 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)
+		}
+
+		mwRunner := newMiddlewareRunner(&event, tx)
+		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
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "updated",
+		},
+		Data: data.ToResponse(),
+	}, nil
+
+}

internal/use-case/main-use-case/encounter/helper.go

@@ -59,7 +59,7 @@ func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Encounter) {
 	data.Responsible_Doctor_Id = inputSrc.Responsible_Doctor_Id
 	data.RefSource_Name = inputSrc.RefSource_Name
 	data.Appointment_Id = inputSrc.Appointment_Id
-	data.Status_Code = erc.DSCNew
+	data.Status_Code = erc.DSCProcess
 }
 
 func setDataUpdate(src e.UpdateDto, dst *e.Encounter) {
@@ -308,3 +308,7 @@ func getMcuOrders(encounter_id uint, event *pl.Event, tx *gorm.DB) error {
 
 	return nil
 }
+
+func setDataUpdateStatus(src e.UpdateStatusDto, dst *e.Encounter) {
+	dst.Status_Code = src.StatusCode
+}

internal/use-case/main-use-case/encounter/lib.go

@@ -187,3 +187,28 @@ func IsDone(encounter_id uint, event *pl.Event, dbx ...*gorm.DB) bool {
 	pl.SetLogInfo(event, nil, "complete")
 	return data.IsDone()
 }
+
+func UpdateStatusData(input e.UpdateStatusDto, data *e.Encounter, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, data, "started", "DBUpdate")
+	setDataUpdateStatus(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
+}