on going chemo plan

internal/use-case/main-use-case/chemo-protocol/case.go

@@ -1,6 +1,9 @@
 package chemo_protocol
 
 import (
+	"errors"
+	erc "simrs-vx/internal/domain/references/common"
+	ere "simrs-vx/internal/domain/references/encounter"
 	"strconv"
 
 	dg "github.com/karincake/apem/db-gorm-pg"
@@ -35,6 +38,23 @@ func Create(input e.CreateDto) (*d.Data, error) {
 			return err
 		}
 
+		// get chemo data from latest encounter
+		dataChemo, err := getChemoEncounter(input.Encounter_Id, &event)
+		if err != nil {
+			return err
+		}
+
+		input.Chemo_Id = &dataChemo.Id
+
+		// determine status code chemo-protocol
+		switch dataChemo.Encounter.Ambulatory.Class_Code {
+		case ere.ACCChemo:
+			input.Status_Code = erc.DVCVerified
+		default:
+			input.Status_Code = erc.DVCNew
+
+		}
+
 		if resData, err := CreateData(input, &event, tx); err != nil {
 			return err
 		} else {
@@ -275,3 +295,65 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 	}, nil
 
 }
+
+func Verify(input e.VerifyDto) (*d.Data, error) {
+	rdDto := e.ReadDetailDto{Id: input.Id}
+	var data *e.ChemoProtocol
+	var err error
+
+	event := pl.Event{
+		Feature: "Verify",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "verify")
+
+	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.Status_Code != erc.DVCNew {
+			event.Status = "failed"
+			event.ErrInfo = pl.ErrorInfo{
+				Code:   "data-state-mismatch",
+				Detail: "data is not new",
+				Raw:    errors.New("data is not new"),
+			}
+			return pl.SetLogError(&event, input)
+		}
+
+		data.VerifiedAt = pu.GetTimeNow()
+		data.Status_Code = erc.DVCVerified
+		data.VerifiedBy_User_Id = &input.AuthInfo.User_Id
+
+		err = tx.Save(&data).Error
+		if 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 &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "verify",
+		},
+		Data: data.ToResponse(),
+	}, nil
+}

internal/use-case/main-use-case/chemo-protocol/helper.go

@@ -5,7 +5,15 @@ Any functions that are used internally by the use-case
 package chemo_protocol
 
 import (
+	ec "simrs-vx/internal/domain/main-entities/chemo"
 	e "simrs-vx/internal/domain/main-entities/chemo-protocol"
+	erc "simrs-vx/internal/domain/references/common"
+	ere "simrs-vx/internal/domain/references/encounter"
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+
+	dg "github.com/karincake/apem/db-gorm-pg"
+	gh "github.com/karincake/getuk"
 )
 
 func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.ChemoProtocol) {
@@ -17,12 +25,80 @@ func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.ChemoProtocol) {
 		inputSrc = &inputTemp.CreateDto
 	}
 
-	data.Encounter_Id = inputSrc.Encounter_Id
+	data.Chemo_Id = inputSrc.Chemo_Id
 	data.Patient_Weight = inputSrc.Patient_Weight
 	data.Patient_Height = inputSrc.Patient_Height
 	data.Diagnoses = inputSrc.Diagnoses
-	data.Duration = inputSrc.Duration
-	data.DurationUnit_Code = inputSrc.DurationUnit_Code
+	data.Interval = inputSrc.Interval
+	data.Cycle = inputSrc.Cycle
+	data.Series = inputSrc.Series
 	data.StartDate = inputSrc.StartDate
 	data.EndDate = inputSrc.EndDate
+	data.Status_Code = inputSrc.Status_Code
+}
+
+func getChemoEncounterReg(event *pl.Event) (*ec.Chemo, error) {
+	pl.SetLogInfo(event, nil, "started", "DBReadChemoEncounterReg")
+	data := ec.Chemo{}
+
+	var tx = dg.I
+
+	if err := tx.Model(&ec.Chemo{}).
+		Joins(`LEFT JOIN "Encounter" "e" ON "e"."Id" = "Chemo"."Encounter_Id"`).
+		Joins(`LEFT JOIN "Ambulatory" "a" ON "a"."Encounter_Id" = "e"."Id"`).
+		Where(`"Chemo"."Status_Code" = ? AND a"."Class_Code" = ?`, erc.DVCVerified, ere.ACCReg).
+		Order("\"CreatedAt\" DESC").
+		First(&data).
+		Error; err != nil {
+		if processedErr := pu.HandleReadError(err, event, source, nil, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func getChemoFromLatestEncounter(event *pl.Event) (*ec.Chemo, error) {
+	pl.SetLogInfo(event, nil, "started", "DBReadChemoFromLatestEncounter")
+	data := ec.Chemo{}
+
+	var tx = dg.I
+
+	if err := tx.Model(&ec.Chemo{}).
+		Joins(`LEFT JOIN "Encounter" "e" ON "e"."Id" = "Chemo"."Encounter_Id"`).
+		Joins(`LEFT JOIN "Ambulatory" "a" ON "a"."Encounter_Id" = "e"."Id"`).
+		Where(`"a"."Class_Code" IN (?)"`, []string{string(ere.ACCReg), string(ere.ACCChemo)}).
+		Where(`"Chemo"."Status_Code" = ?`, erc.DVCVerified).
+		Scopes(gh.Preload("Encounter.Ambulatory")).
+		Order("\"Chemo\".\"CreatedAt\" DESC").
+		First(&data).
+		Error; err != nil {
+		if processedErr := pu.HandleReadError(err, event, source, nil, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func getChemoEncounter(encounterId *uint, event *pl.Event) (*ec.Chemo, error) {
+	pl.SetLogInfo(event, encounterId, "started", "DBReadChemoEncounter")
+	data := ec.Chemo{}
+
+	var tx = dg.I
+
+	if err := tx.Model(&ec.Chemo{}).
+		Where(`"Encounter_Id" = ? AND "Status_Code"`, encounterId, erc.DVCVerified).
+		Scopes(gh.Preload("Encounter.Ambulatory")).
+		First(&data).
+		Error; err != nil {
+		if processedErr := pu.HandleReadError(err, event, source, nil, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
 }