Merge branch 'dev' of github.com:dikstub-rssa/simrs-be into feat/file-generator-169

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

@@ -28,6 +28,7 @@ type CreateDto struct {
 	RegisteredAt           *time.Time           `json:"registeredAt"`
 	RegisteredBy_User_Name *string              `json:"registeredBy_user_name" validate:"maxLength=100"`
 	Status_Code            erc.ActiveStatusCode `json:"status_code" validate:"maxLength=10"`
+	Number                 *string              `json:"number"`
 
 	pa.AuthInfo
 }

internal/domain/simgos-entities/patient/entity.go

@@ -4,14 +4,14 @@ import "time"
 
 type MPasien struct {
 	Id                      uint       `json:"id" gorm:"primaryKey;autoIncrement;column:id"`
-	Nomr                    string     `json:"nomr" gorm:"column:nomr"`
+	Nomr                    string     `json:"nomr" gorm:"uniqueIndex;column:nomr"`
 	Title                   string     `json:"title" gorm:"column:title"`
 	Nama                    string     `json:"nama" gorm:"column:nama"`
 	Tempat                  string     `json:"tempat" gorm:"column:tempat"`
 	Tgllahir                *time.Time `json:"tgllahir" gorm:"column:tgllahir"`
 	Jeniskelamin            string     `json:"jeniskelamin" gorm:"column:jeniskelamin"`
 	Alamat                  string     `json:"alamat" gorm:"column:alamat"`
-	Kelurahan               uint       `json:"kelurahan" gorm:"column:kelurahan"`
+	Kelurahan               uint64     `json:"kelurahan" gorm:"column:kelurahan"`
 	Kdkecamatan             uint       `json:"kdkecamatan" gorm:"column:kdkecamatan"`
 	Kota                    uint       `json:"kota" gorm:"column:kota"`
 	Kdprovinsi              uint       `json:"kdprovinsi" gorm:"column:kdprovinsi"`

internal/interface/simgos-sync-handler/patient/handler.go

@@ -0,0 +1,68 @@
+package patient
+
+import (
+	"net/http"
+
+	rw "github.com/karincake/risoles"
+	// ua "github.com/karincake/tumpeng/auth/svc"
+
+	e "simrs-vx/internal/domain/main-entities/patient"
+	esync "simrs-vx/internal/domain/sync-entities/log"
+	u "simrs-vx/internal/use-case/simgos-sync-use-case/patient"
+)
+
+type myBase struct{}
+
+var O myBase
+
+func (obj myBase) Create(w http.ResponseWriter, r *http.Request) {
+	dto := e.Patient{}
+	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.Patient{}
+	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 = uint(id)
+
+	res, err := u.Delete(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) GenerateNomr(w http.ResponseWriter, r *http.Request) {
+	res, err := u.GenerateNomr()
+	rw.DataResponse(w, res, err)
+}

internal/interface/simgos-sync-handler/simgos-sync-handler.go

@@ -1,6 +1,7 @@
 package simgossynchandler
 
 import (
+	"fmt"
 	"net/http"
 	hc "simrs-vx/pkg/handler-crud-helper"
 
@@ -19,6 +20,7 @@ import (
 	"simrs-vx/internal/interface/main-handler/home"
 	division "simrs-vx/internal/interface/simgos-sync-handler/division"
 	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"
 	subspecialist "simrs-vx/internal/interface/simgos-sync-handler/subspecialist"
 	unit "simrs-vx/internal/interface/simgos-sync-handler/unit"
@@ -43,6 +45,8 @@ func SetRoutes() http.Handler {
 	hc.SyncCrud(r, prefix+"/v1/division", division.O)
 	hc.SyncCrud(r, prefix+"/v1/specialist", specialist.O)
 	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)
 
 	return cmw.SetCors(handlerlogger.SetLog(r))
 }

internal/use-case/main-use-case/division/middleware.go

@@ -7,14 +7,14 @@ import (
 // example of middleware
 func init() {
 	createPreMw = append(createPreMw,
-		createMw{Name: "create-unit", Func: plugin.Create})
+		createMw{Name: "sync-create-division", Func: plugin.Create})
 
 	createSimxLogMw = append(createSimxLogMw,
-		createLogMw{Name: "create-log", Func: plugin.CreateLog})
+		createLogMw{Name: "create-sync-log", Func: plugin.CreateLog})
 
 	updatePreMw = append(updatePreMw,
-		updateMw{Name: "update-unit", Func: plugin.Update})
+		updateMw{Name: "sync-update-division", Func: plugin.Update})
 
 	deletePreMw = append(deletePreMw,
-		deleteMw{Name: "delete-unit", Func: plugin.Delete})
+		deleteMw{Name: "sync-delete-division", Func: plugin.Delete})
 }

internal/use-case/main-use-case/installation/middleware.go

@@ -7,14 +7,14 @@ import (
 // example of middleware
 func init() {
 	createPreMw = append(createPreMw,
-		createMw{Name: "create-installation", Func: plugin.Create})
+		createMw{Name: "sync-create-installation", Func: plugin.Create})
 
 	createSimxLogMw = append(createSimxLogMw,
-		createLogMw{Name: "create-log", Func: plugin.CreateLog})
+		createLogMw{Name: "create-sync-log", Func: plugin.CreateLog})
 
 	updatePreMw = append(updatePreMw,
-		updateMw{Name: "update-installation", Func: plugin.Update})
+		updateMw{Name: "sync-update-installation", Func: plugin.Update})
 
 	deletePreMw = append(deletePreMw,
-		deleteMw{Name: "delete-installation", Func: plugin.Delete})
+		deleteMw{Name: "sync-delete-installation", Func: plugin.Delete})
 }

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

@@ -3,22 +3,25 @@ package patient
 import (
 	"strconv"
 
-	evm "simrs-vx/internal/domain/bpjs-entities/vclaim-member"
-	e "simrs-vx/internal/domain/main-entities/patient"
-
-	uvm "simrs-vx/internal/use-case/bpjs-use-case/vclaim-member"
-	upe "simrs-vx/internal/use-case/main-use-case/person"
-	upa "simrs-vx/internal/use-case/main-use-case/person-address"
-	upc "simrs-vx/internal/use-case/main-use-case/person-contact"
-	upi "simrs-vx/internal/use-case/main-use-case/person-insurance"
-	upr "simrs-vx/internal/use-case/main-use-case/person-relative"
-
 	pl "simrs-vx/pkg/logger"
 	pu "simrs-vx/pkg/use-case-helper"
 
 	dg "github.com/karincake/apem/db-gorm-pg"
 	d "github.com/karincake/dodol"
 	"gorm.io/gorm"
+
+	erc "simrs-vx/internal/domain/references/common"
+
+	evm "simrs-vx/internal/domain/bpjs-entities/vclaim-member"
+	e "simrs-vx/internal/domain/main-entities/patient"
+	esync "simrs-vx/internal/domain/sync-entities/log"
+
+	uvm "simrs-vx/internal/use-case/bpjs-use-case/vclaim-member"
+	upe "simrs-vx/internal/use-case/main-use-case/person"
+	upa "simrs-vx/internal/use-case/main-use-case/person-address"
+	upc "simrs-vx/internal/use-case/main-use-case/person-contact"
+	upi "simrs-vx/internal/use-case/main-use-case/person-insurance"
+	upr "simrs-vx/internal/use-case/main-use-case/person-relative"
 )
 
 const source = "patient"
@@ -33,15 +36,22 @@ func Create(input e.CreateDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "create")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err := dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
 		if err := mwRunner.RunCreateMiddleware(createPreMw, &input, &data); err != nil {
 			return err
 		}
 
+		// Run pre-middleware -> Generate number
+		nomr, err := mwRunner.RunGenerateNumberMiddleware(generatePatientNumber)
+		if err != nil {
+			return err
+		}
+		input.Number = nomr
+
 		if person_id, err := upe.CreateOrUpdatePerson(input.Person, &event, tx); err != nil {
 			return err
 		} else {
@@ -88,21 +98,26 @@ func Create(input e.CreateDto) (*d.Data, error) {
 			data = *resData
 		}
 
-		mwRunner.setMwType(pu.MWTPost)
-		// Run post-middleware
-		if err := mwRunner.RunCreateMiddleware(createPostMw, &input, &data); err != nil {
+		dataPatient, err := ReadDetailData(e.ReadDetailDto{Id: uint16(data.Id)}, &event, tx)
+		if err != nil {
 			return err
 		}
 
-		pl.SetLogInfo(&event, nil, "complete")
+		mwRunner.setMwType(pu.MWTPost)
+		// Run post-middleware
+		if err := mwRunner.RunCreateSyncMiddleware(createSimxSyncMw, dataPatient); 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.II{
 			"source":    source,
@@ -128,7 +143,7 @@ func ReadList(input e.ReadListDto) (*d.Data, error) {
 	pl.SetLogInfo(&event, input, "started", "readList")
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner := newMiddlewareRunner(&event)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
 		if err := mwRunner.RunReadListMiddleware(readListPreMw, &input, data); err != nil {
@@ -179,7 +194,7 @@ func ReadDetail(input e.ReadDetailDto) (*d.Data, error) {
 	pl.SetLogInfo(&event, input, "started", "readDetail")
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner := newMiddlewareRunner(&event)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
 		if err := mwRunner.RunReadDetailMiddleware(readDetailPreMw, &input, data); err != nil {
@@ -225,6 +240,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "update")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
 		pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
@@ -232,13 +248,6 @@ func Update(input e.UpdateDto) (*d.Data, error) {
 			return err
 		}
 
-		mwRunner := newMiddlewareRunner(&event, tx)
-		mwRunner.setMwType(pu.MWTPre)
-		// Run pre-middleware
-		if err := mwRunner.RunUpdateMiddleware(readDetailPreMw, &rdDto, data); err != nil {
-			return err
-		}
-
 		if person_id, err := upe.CreateOrUpdatePerson(input.Person, &event, tx); err != nil {
 			return err
 		} else {
@@ -277,21 +286,26 @@ func Update(input e.UpdateDto) (*d.Data, error) {
 			return err
 		}
 
-		pl.SetLogInfo(&event, nil, "complete")
+		dataPatient, err := ReadDetailData(e.ReadDetailDto{Id: uint16(data.Id)}, &event, tx)
+		if err != nil {
+			return err
+		}
 
-		mwRunner.setMwType(pu.MWTPost)
+		mwRunner.setMwType(pu.MWTPre)
 		// Run post-middleware
-		if err := mwRunner.RunUpdateMiddleware(readDetailPostMw, &rdDto, data); err != nil {
+		if err := mwRunner.RunUpdateMiddleware(updatePreMw, dataPatient); 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,
@@ -315,6 +329,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "delete")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
 		pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
@@ -322,30 +337,68 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 			return err
 		}
 
-		mwRunner := newMiddlewareRunner(&event, tx)
-		mwRunner.setMwType(pu.MWTPre)
-		// Run pre-middleware
-		if err := mwRunner.RunDeleteMiddleware(readDetailPreMw, &rdDto, data); err != nil {
-			return err
-		}
+		input.Id = data.Id
 
+		// Delete Patient
 		if err := DeleteData(data, &event, tx); err != nil {
 			return err
 		}
 
-		mwRunner.setMwType(pu.MWTPost)
+		// Delete PersonInsurance
+		if insurance := data.Person.Insurances; insurance != nil && len(*insurance) > 0 {
+			if err = upi.DeleteMultipleData(data.Person_Id, &event, tx); err != nil {
+				return err
+			}
+		}
+
+		// Delete PersonRelative
+		if relative := data.Person.Relatives; relative != nil && len(*relative) > 0 {
+			if err = upr.DeleteMultipleData(data.Person_Id, &event, tx); err != nil {
+				return err
+			}
+		}
+
+		// Delete PersonContacts
+		if contact := data.Person.Contacts; contact != nil && len(*contact) > 0 {
+			if err = upc.DeleteMultipleData(data.Person_Id, &event, tx); err != nil {
+				return err
+			}
+		}
+
+		// Delete PersonAddress
+		if address := data.Person.Addresses; address != nil && len(*address) > 0 {
+			if err = upa.DeleteMultipleData(data.Person_Id, &event, tx); err != nil {
+				return err
+			}
+		}
+
+		// Delete VclaimMember
+		if vclaim := data.Person.VclaimMember; vclaim != nil {
+			if err = uvm.DeleteData(vclaim, &event, tx); err != nil {
+				return err
+			}
+		}
+
+		// Delete Person
+		if err = upe.DeleteData(data.Person, &event, tx); err != nil {
+			return err
+		}
+
+		mwRunner.setMwType(pu.MWTPre)
 		// Run post-middleware
-		if err := mwRunner.RunDeleteMiddleware(readDetailPostMw, &rdDto, data); err != nil {
+		if err := mwRunner.RunDeleteMiddleware(deletePreMw, &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,
@@ -421,3 +474,32 @@ func Search(input e.SearchDto) (*d.Data, error) {
 		Data: e.ToResponseList(dataList),
 	}, nil
 }
+
+func runLogMiddleware(err error, input any, mwRunner *middlewareRunner) error {
+	var errMsg string
+	inputLog := esync.SimxLogDto{
+		Payload: input,
+		Method:  erc.CCCreate,
+	}
+
+	if err != nil {
+		// Run log-middleware
+		errMsg = err.Error()
+		inputLog.ErrMessage = &errMsg
+		inputLog.IsSuccess = false
+
+		// create log failed
+		if errMiddleware := mwRunner.RunCreateLogMiddleware(createSimxLogMw, &inputLog); errMiddleware != nil {
+			return errMiddleware
+		}
+		return err
+	}
+
+	// create log success
+	inputLog.IsSuccess = true
+	if err = mwRunner.RunCreateLogMiddleware(createSimxLogMw, &inputLog); err != nil {
+		return err
+	}
+
+	return nil
+}

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

@@ -24,12 +24,15 @@ func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Patient) error {
 		inputSrc = &inputTemp.CreateDto
 	}
 
-	if data.Id == 0 {
+	switch {
+	case inputSrc.Number == nil && data.Number == nil:
 		medRecNum, err := GenerateNextMedicalRecordNumber()
 		if err != nil {
 			return err
 		}
 		data.Number = &medRecNum
+	case inputSrc.Number != nil:
+		data.Number = inputSrc.Number
 	}
 
 	data.Person_Id = inputSrc.Person_Id
@@ -52,38 +55,57 @@ func GenerateNextMedicalRecordNumber() (string, error) {
 		return "", err
 	}
 
-	var nextInt int64
-	var format string
+	//var nextInt int64
+	//var format string
 
+	//if last == "" {
+	//	// No existing records, start with 10 digits
+	//	nextInt = 1
+	//	format = "%08d"
+	//} else {
+	//	n, err := strconv.ParseInt(last, 10, 64)
+	//	if err != nil {
+	//		return "", err
+	//	}
+	//	nextInt = n + 1
+	//
+	//	// Dynamically determine format based on existing number
+	//	digitCount := len(last)
+	//
+	//	// If the incremented number needs more digits, expand format
+	//	nextStr := strconv.FormatInt(nextInt, 10)
+	//	if len(nextStr) > digitCount {
+	//		digitCount = len(nextStr)
+	//	}
+	//
+	//	// Ensure minimum 10 digits as per requirement
+	//	if digitCount < 10 {
+	//		digitCount = 10
+	//	}
+	//
+	//	format = fmt.Sprintf("%%0%dd", digitCount)
+	//}
+
+	const prefix = "12" // fixed starting prefix (same as $awal_rm) in simgos
+	const maxSuffix = 999999
+
+	// No existing NOMR → start fresh
 	if last == "" {
-		// No existing records, start with 10 digits
-		nextInt = 1
-		format = "%010d"
-	} else {
-		n, err := strconv.ParseInt(last, 10, 64)
-		if err != nil {
-			return "", err
-		}
-		nextInt = n + 1
-
-		// Dynamically determine format based on existing number
-		digitCount := len(last)
-
-		// If the incremented number needs more digits, expand format
-		nextStr := strconv.FormatInt(nextInt, 10)
-		if len(nextStr) > digitCount {
-			digitCount = len(nextStr)
-		}
-
-		// Ensure minimum 10 digits as per requirement
-		if digitCount < 10 {
-			digitCount = 10
-		}
-
-		format = fmt.Sprintf("%%0%dd", digitCount)
+		return prefix + "000001", nil
 	}
 
-	return fmt.Sprintf(format, nextInt), nil
+	suffix := last[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 endpointMapper(noBpjs string) string {

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

@@ -92,7 +92,8 @@ func ReadDetailData(input e.ReadDetailDto, event *pl.Event, dbx ...*gorm.DB) (*e
 		Preload("Person.Relatives.Village.District.Regency.Province").
 		Preload("Person.Addresses.Village.District.Regency.Province").
 		Preload("Person.Addresses.PostalRegion.Village.District.Regency.Province").
-		Preload("Person.Insurances.InsuranceCompany")
+		Preload("Person.Insurances.InsuranceCompany").
+		Preload("Person.VclaimMember")
 
 	if err := tx.First(&data, input.Id).Error; err != nil {
 		if processedErr := pu.HandleReadError(err, event, source, input.Id, data); processedErr != nil {

internal/use-case/main-use-case/patient/middleware-runner.go

@@ -1,24 +1,29 @@
 package patient
 
 import (
-	e "simrs-vx/internal/domain/main-entities/patient"
 	pl "simrs-vx/pkg/logger"
 	pu "simrs-vx/pkg/use-case-helper"
 
 	"gorm.io/gorm"
+
+	sync "simrs-vx/internal/infra/sync-cfg"
+
+	e "simrs-vx/internal/domain/main-entities/patient"
+	esync "simrs-vx/internal/domain/sync-entities/log"
 )
 
 type middlewareRunner struct {
 	Event  *pl.Event
 	Tx     *gorm.DB
 	MwType pu.MWType
+	SyncOn bool
 }
 
 // NewMiddlewareExecutor creates a new middleware executor
-func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
+func newMiddlewareRunner(event *pl.Event) *middlewareRunner {
 	return &middlewareRunner{
-		Event: event,
-		Tx:    tx,
+		Event:  event,
+		SyncOn: sync.O.Enable,
 	}
 }
 
@@ -38,7 +43,51 @@ func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e
 	return nil
 }
 
+// ExecuteCreateMiddleware executes create middleware
+func (me *middlewareRunner) RunCreateSyncMiddleware(middlewares []createSyncMw, input *e.Patient) error {
+	if !me.SyncOn {
+		return nil
+	}
+
+	for _, middleware := range middlewares {
+		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
+}
+
+// ExecuteCreateMiddleware executes create middleware
+func (me *middlewareRunner) RunCreateLogMiddleware(middlewares []createLogMw, input *esync.SimxLogDto) error {
+	if !me.SyncOn {
+		return nil
+	}
+
+	for _, middleware := range middlewares {
+		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) RunReadListMiddleware(middlewares []readListMw, input *e.ReadListDto, data *e.Patient) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, data)
 
@@ -54,6 +103,10 @@ func (me *middlewareRunner) RunReadListMiddleware(middlewares []readListMw, inpu
 }
 
 func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Patient) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, data)
 
@@ -68,13 +121,17 @@ func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw,
 	return nil
 }
 
-func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Patient) error {
+func (me *middlewareRunner) RunUpdateMiddleware(middlewares []updateMw, input *e.Patient) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
-		logData := pu.GetLogData(input, data)
+		logData := pu.GetLogData(input, nil)
 
 		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
 
-		if err := middleware.Func(input, data, me.Tx); err != nil {
+		if err := middleware.Func(input); err != nil {
 			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
 		}
 
@@ -83,13 +140,17 @@ func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, inpu
 	return nil
 }
 
-func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Patient) error {
+func (me *middlewareRunner) RunDeleteMiddleware(middlewares []deleteMw, input *e.DeleteDto) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
-		logData := pu.GetLogData(input, data)
+		logData := pu.GetLogData(input, nil)
 
 		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
 
-		if err := middleware.Func(input, data, me.Tx); err != nil {
+		if err := middleware.Func(input); err != nil {
 			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
 		}
 
@@ -98,6 +159,25 @@ func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, inpu
 	return nil
 }
 
+func (me *middlewareRunner) RunGenerateNumberMiddleware(middlewares generateNumberMw) (generateNorm *string, err error) {
+	if !me.SyncOn {
+		return nil, nil
+	}
+
+	logData := pu.GetLogData(nil, nil)
+
+	pl.SetLogInfo(me.Event, logData, "started", middlewares.Name)
+
+	generateNorm, err = middlewares.Func()
+	if err != nil {
+		return nil, pu.HandleMiddlewareError(me.Event, string(me.MwType), middlewares.Name, logData, err)
+	}
+
+	pl.SetLogInfo(me.Event, nil, "complete")
+
+	return
+}
+
 func (me *middlewareRunner) setMwType(mwType pu.MWType) {
 	me.MwType = mwType
 }

internal/use-case/main-use-case/patient/middleware.go

@@ -6,16 +6,31 @@ import (
 	"io"
 	"net/http"
 
+	"gorm.io/gorm"
+
 	e "simrs-vx/internal/domain/main-entities/patient"
 
-	"gorm.io/gorm"
+	plugin "simrs-vx/internal/use-case/simgos-sync-plugin/patient"
 )
 
 // example of middleware
 func init() {
 	createPreMw = append(createPreMw,
-		createMw{Name: "check-vclaim-member", Func: checkVclaimMember},
-	)
+		createMw{Name: "check-vclaim-member", Func: checkVclaimMember})
+
+	createSimxSyncMw = append(createSimxSyncMw,
+		createSyncMw{Name: "sync-create-patient", 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})
+
+	generatePatientNumber = generateNumberMw{Name: "generate-nomr-patient", Func: plugin.GenerateNomrPatient}
 }
 
 func checkVclaimMember(input *e.CreateDto, data *e.Patient, tx *gorm.DB) error {

internal/use-case/main-use-case/patient/tycovar.go

@@ -12,6 +12,7 @@ import (
 	"gorm.io/gorm"
 
 	e "simrs-vx/internal/domain/main-entities/patient"
+	elog "simrs-vx/internal/domain/sync-entities/log"
 )
 
 type createMw struct {
@@ -19,6 +20,26 @@ type createMw struct {
 	Func func(input *e.CreateDto, data *e.Patient, tx *gorm.DB) error
 }
 
+type createSyncMw struct {
+	Name string
+	Func func(input *e.Patient) error
+}
+
+type createLogMw struct {
+	Name string
+	Func func(input *elog.SimxLogDto) error
+}
+
+type updateMw struct {
+	Name string
+	Func func(input *e.Patient) error
+}
+
+type deleteMw struct {
+	Name string
+	Func func(input *e.DeleteDto) error
+}
+
 type readListMw struct {
 	Name string
 	Func func(input *e.ReadListDto, data *e.Patient, tx *gorm.DB) error
@@ -29,19 +50,27 @@ type readDetailMw struct {
 	Func func(input *e.ReadDetailDto, data *e.Patient, tx *gorm.DB) error
 }
 
-type UpdateMw = readDetailMw
-type DeleteMw = readDetailMw
+type generateNumberMw struct {
+	Name string
+	Func func() (*string, error)
+}
 
-var createPreMw []createMw      // preprocess middleware
-var createPostMw []createMw     // postprocess middleware
+type UpdateMw = updateMw
+type DeleteMw = deleteMw
+
+var createPreMw []createMw          // preprocess middleware
+var createPostMw []createMw         // postprocess middleware
+var createSimxSyncMw []createSyncMw // postprocess middleware
+var createSimxLogMw []createLogMw
 var readListPreMw []readListMw  // ..
 var readListPostMw []readListMw // ..
 var readDetailPreMw []readDetailMw
 var readDetailPostMw []readDetailMw
-var updatePreMw []readDetailMw
+var updatePreMw []updateMw
 var updatePostMw []readDetailMw
-var deletePreMw []readDetailMw
+var deletePreMw []deleteMw
 var deletePostMw []readDetailMw
+var generatePatientNumber generateNumberMw
 
 type BPJSResponse struct {
 	MetaData struct {

internal/use-case/main-use-case/person-address/lib.go

@@ -191,3 +191,28 @@ func CreateOrUpdateBatch(input []e.UpdateDto, event *pl.Event, tx ...*gorm.DB) e
 
 	return nil
 }
+
+func DeleteMultipleData(personId *uint, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, personId, "started", "DBDelete")
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.
+		Where("\"Person_Id\" = ?", *personId).
+		Delete(&e.PersonAddress{}).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, personId)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}

internal/use-case/main-use-case/person-contact/lib.go

@@ -191,3 +191,28 @@ func CreateOrUpdateBatch(input []e.UpdateDto, event *pl.Event, tx ...*gorm.DB) e
 
 	return nil
 }
+
+func DeleteMultipleData(personId *uint, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, personId, "started", "DBDelete")
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.
+		Where("\"Person_Id\" = ?", *personId).
+		Delete(&e.PersonContact{}).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, personId)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}

internal/use-case/main-use-case/person-insurance/lib.go

@@ -191,3 +191,28 @@ func CreateOrUpdateBatch(input []e.UpdateDto, event *pl.Event, tx ...*gorm.DB) e
 
 	return nil
 }
+
+func DeleteMultipleData(personId *uint, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, personId, "started", "DBDelete")
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.
+		Where("\"Person_Id\" = ?", *personId).
+		Delete(&e.PersonInsurance{}).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, personId)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}

internal/use-case/main-use-case/person-relative/lib.go

@@ -191,3 +191,28 @@ func CreateOrUpdateBatch(input []e.UpdateDto, event *pl.Event, tx ...*gorm.DB) e
 
 	return nil
 }
+
+func DeleteMultipleData(personId *uint, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, personId, "started", "DBDelete")
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.
+		Where("\"Person_Id\" = ?", *personId).
+		Delete(&e.PersonRelative{}).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, personId)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}

internal/use-case/main-use-case/specialist/middleware.go

@@ -7,14 +7,14 @@ import (
 // example of middleware
 func init() {
 	createPreMw = append(createPreMw,
-		createMw{Name: "create-unit", Func: plugin.Create})
+		createMw{Name: "sync-create-specialist", Func: plugin.Create})
 
 	createSimxLogMw = append(createSimxLogMw,
-		createLogMw{Name: "create-log", Func: plugin.CreateLog})
+		createLogMw{Name: "create-sync-log", Func: plugin.CreateLog})
 
 	updatePreMw = append(updatePreMw,
-		updateMw{Name: "update-unit", Func: plugin.Update})
+		updateMw{Name: "sync-update-specialiast", Func: plugin.Update})
 
 	deletePreMw = append(deletePreMw,
-		deleteMw{Name: "delete-unit", Func: plugin.Delete})
+		deleteMw{Name: "sync-delete-specialist", Func: plugin.Delete})
 }

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

@@ -210,7 +210,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 			return err
 		}
 
-		mwRunner.setMwType(pu.MWTPost)
+		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
 		if err := mwRunner.RunDeleteMiddleware(deletePreMw, &input); err != nil {
 			return err

internal/use-case/main-use-case/unit/middleware.go

@@ -7,14 +7,14 @@ import (
 // example of middleware
 func init() {
 	createPreMw = append(createPreMw,
-		createMw{Name: "create-unit", Func: plugin.Create})
+		createMw{Name: "sync-create-unit", Func: plugin.Create})
 
 	createSimxLogMw = append(createSimxLogMw,
-		createLogMw{Name: "create-log", Func: plugin.CreateLog})
+		createLogMw{Name: "create-sync-log", Func: plugin.CreateLog})
 
 	updatePreMw = append(updatePreMw,
-		updateMw{Name: "update-unit", Func: plugin.Update})
+		updateMw{Name: "sync-update-unit", Func: plugin.Update})
 
 	deletePreMw = append(deletePreMw,
-		deleteMw{Name: "delete-unit", Func: plugin.Delete})
+		deleteMw{Name: "sync-delete-unit", Func: plugin.Delete})
 }

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

@@ -0,0 +1,207 @@
+package patient
+
+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/patient"
+	elog "simrs-vx/internal/domain/sync-entities/log"
+)
+
+func Create(input *e.Patient) 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.Patient) 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 GenerateNomrPatient() (*string, error) {
+	prefixEndpoint := getPrefixEndpoint()
+	endpoint := fmt.Sprintf("%s-nomr-generator", prefixEndpoint)
+
+	req, err := http.NewRequest("GET", endpoint, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return nil, fmt.Errorf(errors.Message)
+	}
+
+	var result map[string]any
+	if err = json.Unmarshal(bodyBytes, &result); err != nil {
+		return nil, err
+	}
+
+	dataMap := result["data"].(map[string]any)
+	nomr := dataMap["nomr"].(string)
+
+	return &nomr, nil
+}
+
+func getPrefixEndpoint() string {
+	return fmt.Sprintf("%s%s/v1/patient", sync.O.Host, sync.O.Prefix)
+}

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

@@ -0,0 +1,231 @@
+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, patientData, &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
+
+}
+
+func GenerateNomr() (*d.Data, error) {
+	event := pl.Event{
+		Feature: "Generate Nomr",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, nil, "started", "create")
+
+	norm, err := generateNomrPatient()
+	if err != nil {
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.II{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "created",
+		},
+		Data: d.IS{
+			"nomr": norm,
+		},
+	}, nil
+}

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

@@ -0,0 +1,317 @@
+/*
+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
+	data.Nomr = *input.Number
+
+	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,189 @@
+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)
+
+	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, patientData *esimgos.MPasien, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, input, "started", "DBUpdate")
+
+	data := setDataSimgos(&input)
+	data.Id = patientData.Id
+	data.CreatedAt = patientData.CreatedAt
+
+	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