add patient

internal/use-case/simgos-sync-use-case/patient/case.go

@@ -0,0 +1,203 @@
+package patient
+
+import (
+	pl "simrs-vx/pkg/logger"
+
+	d "github.com/karincake/dodol"
+	"gorm.io/gorm"
+
+	db "simrs-vx/pkg/dualtrx-helper"
+
+	e "simrs-vx/internal/domain/main-entities/patient"
+	esimgos "simrs-vx/internal/domain/simgos-entities/patient"
+	elog "simrs-vx/internal/domain/sync-entities/log"
+	esync "simrs-vx/internal/domain/sync-entities/patient"
+)
+
+const source = "patient"
+
+func Create(input e.Patient) (*d.Data, error) {
+	var (
+		sgData   *esimgos.MPasien
+		syncLink *esync.PatientLink
+		err      error
+	)
+
+	event := pl.Event{
+		Feature: "Create",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "create")
+
+	err = db.WithDualTx(func(tx *db.Dualtx) error {
+		// STEP 1: Insert to simgos
+		sgData, err = CreateSimgosData(input, &event, tx.Simgos)
+		if err != nil {
+			return err
+		}
+
+		// STEP 2: Insert to Link
+		syncLink, err = CreateLinkData(input.Id, sgData.Id, &event, tx.Sync)
+		if err != nil {
+			return err
+		}
+
+		return nil
+	})
+
+	if err != nil {
+		if syncLink != nil {
+			go func() { _ = DeleteLinkData(syncLink, &event) }()
+		}
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.II{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "created",
+		},
+	}, nil
+}
+
+func CreateSimxLog(input elog.SimxLogDto) (*d.Data, error) {
+	event := pl.Event{
+		Feature: "Create",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "create")
+
+	tx := db.NewTx()
+	err := tx.Sync.Transaction(func(tx *gorm.DB) error {
+		// Insert to Log
+		if err := CreateLogData(input, &event, tx); err != nil {
+			return err
+		}
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.II{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "created",
+		},
+	}, nil
+}
+
+func Update(input e.Patient) (*d.Data, error) {
+	event := pl.Event{
+		Feature: "Update",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "update")
+
+	// STEP 1: Get Link
+	syncLink, err := ReadDetailLinkData(uint16(input.Id), &event)
+	if err != nil {
+		return nil, err
+	}
+
+	// STEP 2: Get Simgos
+	patientData, err := ReadDetailSimgosData(uint16(syncLink.Simgos_Id), &event)
+	if err != nil {
+		return nil, err
+	}
+
+	tx := db.NewTx()
+	err = tx.Simgos.Transaction(func(tx *gorm.DB) error {
+		// Step 3: Update Simgos
+		if err = UpdateSimgosData(input, syncLink.Simgos_Id, patientData.Nomr, &event, tx); err != nil {
+			return err
+		}
+
+		return nil
+	})
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "updated",
+		},
+	}, nil
+}
+
+func Delete(input e.DeleteDto) (*d.Data, error) {
+	var isLinkDeleted bool
+
+	event := pl.Event{
+		Feature: "Delete",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "delete")
+
+	// STEP 1: Get Link
+	syncLink, err := ReadDetailLinkData(uint16(input.Id), &event)
+	if err != nil {
+		return nil, err
+	}
+
+	// STEP 2: Get Simgos
+	sgData, err := ReadDetailSimgosData(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)
+		if err != nil {
+			return err
+		}
+
+		// STEP 4: Delete Link
+		err = DeleteLinkData(syncLink, &event, tx.Sync)
+		if err != nil {
+			return err
+		}
+
+		isLinkDeleted = true
+		return nil
+	})
+
+	if err != nil {
+		if isLinkDeleted {
+			go func() {
+				_, _ = CreateLinkData(input.Id, sgData.Id, &event)
+			}()
+		}
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "deleted",
+		},
+	}, nil
+
+}

internal/use-case/simgos-sync-use-case/patient/helper.go

@@ -0,0 +1,316 @@
+/*
+DESCRIPTION:
+Any functions that are used internally by the use-case
+*/
+package patient
+
+import (
+	"encoding/json"
+	"fmt"
+	erc "simrs-vx/internal/domain/references/common"
+	erp "simrs-vx/internal/domain/references/person"
+	"strconv"
+
+	e "simrs-vx/internal/domain/main-entities/patient"
+	ep "simrs-vx/internal/domain/main-entities/person"
+	epa "simrs-vx/internal/domain/main-entities/person-address"
+	epc "simrs-vx/internal/domain/main-entities/person-contact"
+	epr "simrs-vx/internal/domain/main-entities/person-relative"
+	esimgos "simrs-vx/internal/domain/simgos-entities/patient"
+	esyncLog "simrs-vx/internal/domain/sync-entities/log"
+	esync "simrs-vx/internal/domain/sync-entities/patient"
+
+	dg "github.com/karincake/apem/db-gorm-pg"
+	"gorm.io/gorm/clause"
+)
+
+func setDataSimgos(input *e.Patient) (data esimgos.MPasien) {
+	if p := input.Person; p != nil {
+		mapPerson(p, &data)
+	}
+
+	if input.Person != nil && input.Person.Addresses != nil {
+		mapAddress(input.Person.Addresses, &data)
+	}
+
+	if input.Person != nil && input.Person.Contacts != nil {
+		mapContact(input.Person.Contacts, &data)
+	}
+
+	if input.Person != nil && input.Person.Relatives != nil {
+		mapRelative(input.Person.Relatives, &data)
+	}
+
+	data.Nip = input.RegisteredBy_User_Name
+	data.Tgldaftar = input.RegisteredAt
+
+	return
+}
+
+func generateNomrPatient() (string, error) {
+	const prefix = "12" // fixed starting prefix (same as $awal_rm) in simgos
+	const maxSuffix = 999999
+
+	type Row struct {
+		Nomr string `gorm:"column:nomr"`
+	}
+
+	var r Row
+
+	// Lock rows for this prefix → prevents race condition
+	if err := dg.IS["simrs"].
+		Table("m_pasien").
+		Select("nomr").
+		Where("nomr LIKE ?", prefix+"%").
+		Order("nomr DESC").
+		Clauses(clause.Locking{Strength: "UPDATE"}).
+		Limit(1).
+		Scan(&r).Error; err != nil {
+		return "", err
+	}
+
+	// No existing NOMR → start fresh
+	if r.Nomr == "" {
+		return prefix + "000001", nil
+	}
+
+	suffix := r.Nomr[len(prefix):] // extract numeric part
+	num, _ := strconv.Atoi(suffix)
+
+	// 3. If suffix reaches 999999 → increment the prefix
+	if num == maxSuffix {
+		p, _ := strconv.Atoi(prefix)
+		p++
+		return fmt.Sprintf("%d000001", p), nil
+	}
+
+	// 4. Normal increment
+	return prefix + fmt.Sprintf("%06d", num+1), nil
+}
+
+func mapPerson(p *ep.Person, data *esimgos.MPasien) {
+	if p.FrontTitle != nil {
+		data.Title = *p.FrontTitle
+	}
+
+	if p.BirthRegency != nil {
+		data.Tempat = p.BirthRegency.Name
+	}
+
+	if p.BirthDate != nil {
+		data.Tgllahir = p.BirthDate
+	}
+
+	if p.Gender_Code != nil {
+		if *p.Gender_Code == erp.GCMale {
+			data.Jeniskelamin = "L"
+		} else if *p.Gender_Code == erp.GCFemale {
+			data.Jeniskelamin = "P"
+		}
+	}
+
+	data.Nama = p.Name
+	data.Noktp = *p.ResidentIdentityNumber
+	data.NoktpBaru = *p.ResidentIdentityNumber
+	data.Pekerjaan = *p.Ocupation_Name
+
+	data.Status, data.TxtStatus = setMaritalStatus(p.MaritalStatus_Code)
+	data.Agama, data.TxtAgama = setReligion(p.Religion_Code)
+	data.Pendidikan, data.TxtPendidikan = setEducation(p.Education_Code)
+
+	if c := p.VclaimMember; c != nil && c.CardNumber != nil {
+		data.NoKartu = *c.CardNumber
+	}
+
+	if l := p.Language; l != nil {
+		data.Bahasa = l.Name
+	}
+
+	if p.CommunicationIssueStatus {
+		data.HambatanKomunikasi = "Y"
+	} else {
+		data.HambatanKomunikasi = "T"
+	}
+
+	if p.Nationality != nil {
+		data.Kebangsaan = *p.Nationality
+	}
+
+	if p.Ethnic != nil {
+		data.Suku = p.Ethnic.Name
+	}
+}
+
+func setMaritalStatus(code *erp.MaritalStatusCode) (uint, string) {
+	if code != nil {
+		switch *code {
+		case erp.MaritalStatusSingle:
+			return 1, "Belum Menikah"
+		case erp.MaritalStatusMarried:
+			return 2, "Menikah"
+		case erp.MaritalStatusDivorced:
+			return 4, "Cerai"
+		case erp.MaritalStatusWidowed:
+			return 3, "Janda/Duda"
+		default:
+			return 0, "Tidak Diketahui"
+		}
+	} else {
+		return 0, "Tidak Diketahui"
+	}
+}
+
+func setReligion(code *erp.ReligionCode) (uint, string) {
+	if code != nil {
+		switch *code {
+		case erp.RCIslam:
+			return 1, "Islam"
+		case erp.RCProtestan:
+			return 2, "Kristen Protestan"
+		case erp.RCKatolik:
+			return 3, "Katholik"
+		case erp.RCHindu:
+			return 4, "Hindu"
+		case erp.RCBudha:
+			return 5, "Budha"
+		case erp.RCKonghucu:
+			return 6, "Konghucu"
+		default:
+			return 9, "Lainnya"
+		}
+	} else {
+		return 0, "Tidak Diketahui"
+	}
+}
+
+func setEducation(code *erp.EducationCode) (uint, string) {
+	if code != nil {
+		switch *code {
+		case erp.ECTS:
+			return 0, "Tidak Sekolah"
+		case erp.ECSD:
+			return 1, string(erp.ECSD)
+		case erp.ECSLTP:
+			return 2, string(erp.ECSLTP)
+		case erp.ECSLTA:
+			return 3, string(erp.ECSLTA)
+		case erp.ECD1, erp.ECD2, erp.ECD3, erp.ECD4:
+			return 4, "D3/Akademik"
+		case erp.ECS1, erp.ECS2, erp.ECS3:
+			return 5, "Universitas"
+		case erp.ECOther:
+			return 6, "Lainnya"
+		default:
+			return 7, "Tidak Diketahui"
+		}
+	} else {
+		return 7, "Tidak Diketahui"
+	}
+}
+
+func mapAddress(addresses *[]epa.PersonAddress, data *esimgos.MPasien) {
+	if addresses == nil || len(*addresses) == 0 {
+		return
+	}
+
+	a := (*addresses)[0]
+	data.Alamat = a.Address
+	data.AlamatKtp = a.Address
+
+	if v := a.Village; v != nil {
+		villageCode, _ := strconv.Atoi(v.Code)
+		data.Kelurahan = uint64(villageCode)
+		data.TxtKelurahan = v.Name
+
+		if d := v.District; d != nil {
+			districtCode, _ := strconv.Atoi(d.Code)
+			data.Kdkecamatan = uint(districtCode)
+			data.TxtKecamatan = d.Name
+
+			if r := d.Regency; r != nil {
+				regencyCode, _ := strconv.Atoi(r.Code)
+				data.Kota = uint(regencyCode)
+				data.TxtKota = r.Name
+
+				if p := r.Province; p != nil {
+					provinceCode, _ := strconv.Atoi(p.Code)
+					data.Kdprovinsi = uint(provinceCode)
+					data.TxtProvinsi = p.Name
+				}
+			}
+		}
+	}
+}
+
+func mapContact(contact *[]epc.PersonContact, data *esimgos.MPasien) {
+	if contact == nil || len(*contact) == 0 {
+		return
+	}
+
+	for _, c := range *contact {
+		if c.Type_Code == erp.CTPhone || c.Type_Code == erp.CTMPhone {
+			data.Notelp = c.Value
+			break
+		}
+	}
+
+}
+
+func mapRelative(relative *[]epr.PersonRelative, data *esimgos.MPasien) {
+	if relative == nil || len(*relative) == 0 {
+		return
+	}
+
+	r := (*relative)[0]
+	data.PenanggungjawabNama = *r.Name
+
+	switch r.Relationship_Code {
+	case erp.RCMother, erp.RCFather:
+		data.PenanggungjawabHubungan = "ORANG TUA"
+		switch {
+		case r.Relationship_Code == erp.RCMother:
+			data.NamaIbu = *r.Name
+			eduCode, _ := setEducation(r.Education_Code)
+			data.PendidikanIbu = strconv.Itoa(int(eduCode))
+		case r.Relationship_Code == erp.RCFather:
+			data.NamaAyah = *r.Name
+			eduCode, _ := setEducation(r.Education_Code)
+			data.PendidikanAyah = strconv.Itoa(int(eduCode))
+		}
+	case erp.RCChild:
+		data.PenanggungjawabHubungan = "ANAK"
+	default:
+		data.PenanggungjawabHubungan = "LAINNYA"
+	}
+
+	data.PenanggungjawabAlamat = *r.Address
+	data.PenanggungjawabPhone = *r.PhoneNumber
+}
+
+func setDataSimxLog(input *esyncLog.SimxLogDto) (data esync.PatientSimxLog) {
+	// encode to JSON
+	jsonData, _ := json.MarshalIndent(input.Payload, "", "  ")
+	jsonString := string(jsonData)
+
+	var status erc.ProcessStatusCode
+	if input.IsSuccess {
+		status = erc.PSCSuccess
+	} else {
+		status = erc.PSCFailed
+		if input.ErrMessage != nil {
+			data.ErrMessage = input.ErrMessage
+		}
+	}
+
+	data.Value = &jsonString
+	data.Date = &now
+	data.Status = status
+
+	return
+}
+
+func setDataSimxLink(simxId, simgosId uint) (data esync.PatientLink) {
+	data.Simx_Id = simxId
+	data.Simgos_Id = simgosId
+	return
+}

internal/use-case/simgos-sync-use-case/patient/lib.go

@@ -0,0 +1,194 @@
+package patient
+
+import (
+	plh "simrs-vx/pkg/lib-helper"
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+	"time"
+
+	dg "github.com/karincake/apem/db-gorm-pg"
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/patient"
+	esimgos "simrs-vx/internal/domain/simgos-entities/patient"
+	esynclog "simrs-vx/internal/domain/sync-entities/log"
+	esync "simrs-vx/internal/domain/sync-entities/patient"
+)
+
+var now = time.Now()
+
+func CreateSimgosData(input e.Patient, event *pl.Event, dbx ...*gorm.DB) (*esimgos.MPasien, error) {
+	pl.SetLogInfo(event, nil, "started", "DBCreate")
+
+	data := setDataSimgos(&input)
+	nomr, err := generateNomrPatient()
+	if err != nil {
+		return nil, plh.HandleCreateError(input, event, err)
+	}
+	data.Nomr = nomr
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.IS["simrs"]
+	}
+
+	if err := tx.Create(&data).Error; err != nil {
+		return nil, plh.HandleCreateError(input, event, err)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func ReadDetailSimgosData(simgosId uint16, event *pl.Event) (*esimgos.MPasien, error) {
+	pl.SetLogInfo(event, simgosId, "started", "DBReadDetail")
+	data := esimgos.MPasien{}
+
+	var tx = dg.IS["simrs"]
+
+	if err := tx.
+		Where("\"id\" = ?", simgosId).
+		First(&data).Error; err != nil {
+		if processedErr := pu.HandleReadError(err, event, source, simgosId, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func UpdateSimgosData(input e.Patient, patientId uint, patientNomr string, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, input, "started", "DBUpdate")
+
+	data := setDataSimgos(&input)
+	data.Id = patientId
+	data.Nomr = patientNomr
+
+	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 HardDeleteSimgosData(data *esimgos.MPasien, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, data, "started", "DBDelete")
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.IS["simrs"]
+	}
+
+	if err := tx.
+		Delete(&data).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, data)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}
+
+func CreateLinkData(simxId, simgosId uint, event *pl.Event, dbx ...*gorm.DB) (*esync.PatientLink, error) {
+	pl.SetLogInfo(event, nil, "started", "DBCreate")
+	data := setDataSimxLink(simxId, simgosId)
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Create(&data).Error; err != nil {
+		return nil, plh.HandleCreateError(data, event, err)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func ReadDetailLinkData(simxId uint16, event *pl.Event) (*esync.PatientLink, error) {
+	pl.SetLogInfo(event, simxId, "started", "DBReadDetail")
+	data := esync.PatientLink{}
+
+	var tx = dg.I
+
+	if err := tx.
+		Where("\"Simx_Id\" = ?", simxId).
+		First(&data).Error; err != nil {
+		if processedErr := pu.HandleReadError(err, event, source, simxId, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func DeleteLinkData(data *esync.PatientLink, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, data, "started", "DBDelete")
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Delete(&data).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, data)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}
+
+func CreateLogData(input esynclog.SimxLogDto, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, nil, "started", "DBCreate")
+	data := setDataSimxLog(&input)
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Create(&data).Error; err != nil {
+		return plh.HandleCreateError(input, event, err)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}

internal/use-case/simgos-sync-use-case/patient/middleware-runner.go

@@ -0,0 +1,104 @@
+package patient
+
+import (
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/patient"
+)
+
+type middlewareRunner struct {
+	Event  *pl.Event
+	Tx     *gorm.DB
+	MwType pu.MWType
+}
+
+// NewMiddlewareExecutor creates a new middleware executor
+func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
+	return &middlewareRunner{
+		Event: event,
+		Tx:    tx,
+	}
+}
+
+// ExecuteCreateMiddleware executes create middleware
+func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto, data *e.Patient) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); 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) RunReadListMiddleware(middlewares []readListMw, input *e.ReadListDto, data *e.Patient) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); 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) RunReadDetailMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Patient) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); 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) RunUpdateMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Patient) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); 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) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Patient) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); 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/simgos-sync-use-case/patient/middleware.go

@@ -0,0 +1,9 @@
+package patient
+
+// example of middleware
+// func init() {
+// 	createPreMw = append(createPreMw,
+// 		CreateMw{Name: "modif-input", Func: pm.ModifInput},
+// 		CreateMw{Name: "check-data", Func: pm.CheckData},
+// 	)
+// }

internal/use-case/simgos-sync-use-case/patient/tycovar.go

@@ -0,0 +1,44 @@
+/*
+DESCRIPTION:
+A sample, part of the package that contains type, constants, and/or variables.
+
+In this sample it also provides type and variable regarding the needs of the
+middleware to separate from main use-case which has the basic CRUD
+functionality. The purpose of this is to make the code more maintainable.
+*/
+package patient
+
+import (
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/patient"
+)
+
+type createMw struct {
+	Name string
+	Func func(input *e.CreateDto, data *e.Patient, tx *gorm.DB) error
+}
+
+type readListMw struct {
+	Name string
+	Func func(input *e.ReadListDto, data *e.Patient, tx *gorm.DB) error
+}
+
+type readDetailMw struct {
+	Name string
+	Func func(input *e.ReadDetailDto, data *e.Patient, tx *gorm.DB) error
+}
+
+type UpdateMw = readDetailMw
+type DeleteMw = readDetailMw
+
+var createPreMw []createMw      // preprocess middleware
+var createPostMw []createMw     // postprocess middleware
+var readListPreMw []readListMw  // ..
+var readListPostMw []readListMw // ..
+var readDetailPreMw []readDetailMw
+var readDetailPostMw []readDetailMw
+var updatePreMw []readDetailMw
+var updatePostMw []readDetailMw
+var deletePreMw []readDetailMw
+var deletePostMw []readDetailMw