wip

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

@@ -1,10 +1,15 @@
 package medication
 
 import (
+	"errors"
 	"strconv"
 
 	e "simrs-vx/internal/domain/main-entities/medication"
 
+	erc "simrs-vx/internal/domain/references/common"
+
+	up "simrs-vx/internal/use-case/main-use-case/pharmacist"
+
 	dg "github.com/karincake/apem/db-gorm-pg"
 	d "github.com/karincake/dodol"
 
@@ -277,3 +282,70 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 	}, nil
 
 }
+
+func Complete(input e.ReadDetailDto) (*d.Data, error) {
+	var data *e.Medication
+	var err error
+
+	event := pl.Event{
+		Feature: "Complete",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "complete")
+
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		data, err = ReadDetailData(input, &event, tx)
+		if err != nil {
+			return err
+		}
+
+		if data.IsCompleted() {
+			return errors.New("data already completed")
+		}
+
+		if !input.AuthInfo.IsPharmacist() {
+			event.Status = "failed"
+			event.ErrInfo = pl.ErrorInfo{
+				Code:   "auth-forbidden",
+				Detail: "user position is not allowed",
+				Raw:    errors.New("authentication failed"),
+			}
+			return pl.SetLogError(&event, input)
+		}
+
+		pharmacist_id, err := up.GetIdByUserId(&input.AuthInfo.User_Id, &event, tx)
+		if err != nil {
+			return err
+		}
+
+		data.Status_Code = erc.DSCDone
+		data.Pharmacist_Id = pharmacist_id
+		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
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "fetched",
+		},
+		Data: data.ToResponse(),
+	}, nil
+}

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

@@ -6,6 +6,10 @@ package medication
 
 import (
 	e "simrs-vx/internal/domain/main-entities/medication"
+	// emi "simrs-vx/internal/domain/main-entities/medication-item"
+	// emid "simrs-vx/internal/domain/main-entities/medication-item-dist"
+	// umi "simrs-vx/internal/use-case/main-use-case/medication-item"
+	// umid "simrs-vx/internal/use-case/main-use-case/medication-item-dist"
 )
 
 func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Medication) {
@@ -20,4 +24,35 @@ func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Medication) {
 	data.Encounter_Id = inputSrc.Encounter_Id
 	data.IssuedAt = inputSrc.IssuedAt
 	data.Pharmacist_Id = inputSrc.Pharmacist_Id
+	data.Status_Code = inputSrc.Status_Code
 }
+
+// func createMedicationItemDist(medication_id *uint, event *pl.Event, dbx ...*gorm.DB) error {
+// 	pl.SetLogInfo(event, nil, "started", "createMedicationItemDist")
+// 	var tx *gorm.DB
+// 	if len(dbx) > 0 {
+// 		tx = dbx[0]
+// 	} else {
+// 		tx = dg.I
+// 	}
+
+// 	filterMI := emi.ReadListDto{FilterDto: emi.FilterDto{Medication_Id: medication_id, IsRedeemed: true}}
+// 	medicationItemList, _, err := umi.ReadListData(filterMI, event, tx)
+// 	if err != nil {
+// 		return err
+// 	}
+// 	for _, medicationItem := range medicationItemList {
+// 		midCreate := emid.CreateDto{
+// 			MedicationItem_Id: &medicationItem.Id,
+// 			DateTime:          medicationItem.MedicationItem.DateTime,
+// 			Remain:            medicationItem.MedicationItem.Remain,
+// 			Nurse_Id:          medicationItem.MedicationItem.Nurse_Id,
+// 		}
+// 		if err := umid.Create(midCreate); err != nil {
+// 			return err
+// 		}
+// 	}
+
+// 	pl.SetLogInfo(event, nil, "complete")
+// 	return nil
+// }