munawwirul_jamal/simrsx-be
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #161 from dikstub-rssa/feat/sync-from-simx-160

Browse Source 
Feat/sync from simx 160
This commit is contained in:
Dwi Atmoko Purbo Sakti
2025-11-20 10:06:12 +07:00
committed by GitHub
parent db2d02cd05 9a056701c6
commit 6e2fe2c51e
46 changed files with 2076 additions and 128 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/main-migration/migrations/20251119063438.sql
+4
View File
@@ -0,0 +1,4 @@
-- Modify "Person" table
ALTER TABLE "public"."Person" DROP CONSTRAINT "uni_Person_ResidentIdentityNumber", ALTER COLUMN "ResidentIdentityNumber" TYPE text;
-- Create index "idx_resident_identity" to table: "Person"
CREATE UNIQUE INDEX "idx_resident_identity" ON "public"."Person" ("ResidentIdentityNumber") WHERE ("DeletedAt" IS NULL);
cmd/main-migration/migrations/20251119065730.sql
+6
View File
@@ -0,0 +1,6 @@
-- Modify "Person" table
ALTER TABLE "public"."Person" DROP CONSTRAINT "uni_Person_DrivingLicenseNumber", DROP CONSTRAINT "uni_Person_PassportNumber", ALTER COLUMN "ResidentIdentityNumber" TYPE character varying(16), ALTER COLUMN "Nationality" TYPE character varying(50);
-- Create index "idx_driver_license" to table: "Person"
CREATE UNIQUE INDEX "idx_driver_license" ON "public"."Person" ("DrivingLicenseNumber") WHERE ("DeletedAt" IS NULL);
-- Create index "idx_passport" to table: "Person"
CREATE UNIQUE INDEX "idx_passport" ON "public"."Person" ("PassportNumber") WHERE ("DeletedAt" IS NULL);
cmd/main-migration/migrations/20251119072302.sql
+2
View File
@@ -0,0 +1,2 @@
-- Modify "VclaimSepPrint" table
ALTER TABLE "public"."VclaimSepPrint" DROP CONSTRAINT "fk_VclaimSepPrint_VclaimSep", ADD CONSTRAINT "fk_VclaimSep_Prints" FOREIGN KEY ("VclaimSep_Number") REFERENCES "public"."VclaimSep" ("Number") ON UPDATE NO ACTION ON DELETE NO ACTION;
cmd/main-migration/migrations/20251119072450.sql
+15
View File
@@ -0,0 +1,15 @@
-- Create "VclaimSepControlLetter" table
CREATE TABLE "public"."VclaimSepControlLetter" (
"Id" bigserial NOT NULL,
"CreatedAt" timestamptz NULL,
"UpdatedAt" timestamptz NULL,
"DeletedAt" timestamptz NULL,
"VclaimSep_Number" character varying(19) NULL,
"Number" character varying(20) NULL,
"Value" text NULL,
"FileUrl" character varying(1024) NULL,
PRIMARY KEY ("Id"),
CONSTRAINT "uni_VclaimSepControlLetter_FileUrl" UNIQUE ("FileUrl"),
CONSTRAINT "uni_VclaimSepControlLetter_Number" UNIQUE ("Number"),
CONSTRAINT "fk_VclaimSep_ControlLetters" FOREIGN KEY ("VclaimSep_Number") REFERENCES "public"."VclaimSep" ("Number") ON UPDATE NO ACTION ON DELETE NO ACTION
);
cmd/main-migration/migrations/atlas.sum
+6 -2
View File
@@ -1,4 +1,4 @@
h1:afszGTkDIE06d7AaxnxHvAka95f66k0PzwbeS26VK6I=
h1:8gw1BB9DWz+cNATJjG1oMXA+QAF1HrIw47xjbI33aC4=
20250904105930.sql h1:MEM6blCgke9DzWQSTnLzasbPIrcHssNNrJqZpSkEo6k=
20250904141448.sql h1:J8cmYNk4ZrG9fhfbi2Z1IWz7YkfvhFqTzrLFo58BPY0=
20250908062237.sql h1:Pu23yEW/aKkwozHoOuROvHS/GK4ngARJGdO7FB7HZuI=
@@ -120,4 +120,8 @@ h1:afszGTkDIE06d7AaxnxHvAka95f66k0PzwbeS26VK6I=
20251114062746.sql h1:FInLaEFQByESEwFJKuKnuUSTKmcDpi3ZXaxkKwz2+D8=
20251117005942.sql h1:wD3BWrUSmo1HlW16V3lkaBkJvbAZ0fNk77te7J9NhOc=
20251117075427.sql h1:TqU9VKZa3I8YNXUGQWY3WVBYN+1FvyyaKy0hB1jgAho=
20251118074929.sql h1:KQfYOHalnSiUPpKzSUDqdlEWMbRWyNu3PmCqsjuCUGU=
20251118074929.sql h1:p1KsWqCuR1JXA/jVO5BmOhCcaQ8clT7t0YRszAhPFbg=
20251119063438.sql h1:NVGM0X/LHD37EaPl8SNzkNiZDJ7AB1QR+LLwLh6WRdg=
20251119065730.sql h1:U5lzk1WvMB0bw3kwckou7jkEt4bwdYItwHr2Vxqe7w4=
20251119072302.sql h1:8L+NsXPFXGZDQZIOhShvuBM9aLwU3h95tXnz6jxHhlA=
20251119072450.sql h1:ksTc8ljaHFrBo1/HiHtcnT+iJ7kPS93KgetFTf3p4Qc=
cmd/simgos-sync-migration/migrations/20251118082246.sql
+36
View File
@@ -0,0 +1,36 @@
-- Create "PatientLink" table
CREATE TABLE "public"."PatientLink" (
"Id" bigserial NOT NULL,
"CreatedAt" timestamptz NULL,
"UpdatedAt" timestamptz NULL,
"DeletedAt" timestamptz NULL,
"Simx_Id" bigint NULL,
"Simgos_Id" bigint NULL,
PRIMARY KEY ("Id"),
CONSTRAINT "uni_PatientLink_Simgos_Id" UNIQUE ("Simgos_Id"),
CONSTRAINT "uni_PatientLink_Simx_Id" UNIQUE ("Simx_Id")
);
-- Create "PatientSimgosLog" table
CREATE TABLE "public"."PatientSimgosLog" (
"Id" bigserial NOT NULL,
"CreatedAt" timestamptz NULL,
"UpdatedAt" timestamptz NULL,
"DeletedAt" timestamptz NULL,
"Value" text NULL,
"Date" timestamptz NULL,
"Status" text NULL,
"ErrMessage" text NULL,
PRIMARY KEY ("Id")
);
-- Create "PatientSimxLog" table
CREATE TABLE "public"."PatientSimxLog" (
"Id" bigserial NOT NULL,
"CreatedAt" timestamptz NULL,
"UpdatedAt" timestamptz NULL,
"DeletedAt" timestamptz NULL,
"Value" text NULL,
"Date" timestamptz NULL,
"Status" text NULL,
"ErrMessage" text NULL,
PRIMARY KEY ("Id")
);
cmd/simgos-sync-migration/migrations/20251118082915.sql
+36
View File
@@ -0,0 +1,36 @@
-- Create "EncounterLink" table
CREATE TABLE "public"."EncounterLink" (
"Id" bigserial NOT NULL,
"CreatedAt" timestamptz NULL,
"UpdatedAt" timestamptz NULL,
"DeletedAt" timestamptz NULL,
"Simx_Id" bigint NULL,
"Simgos_Id" bigint NULL,
PRIMARY KEY ("Id"),
CONSTRAINT "uni_EncounterLink_Simgos_Id" UNIQUE ("Simgos_Id"),
CONSTRAINT "uni_EncounterLink_Simx_Id" UNIQUE ("Simx_Id")
);
-- Create "EncounterSimgosLog" table
CREATE TABLE "public"."EncounterSimgosLog" (
"Id" bigserial NOT NULL,
"CreatedAt" timestamptz NULL,
"UpdatedAt" timestamptz NULL,
"DeletedAt" timestamptz NULL,
"Value" text NULL,
"Date" timestamptz NULL,
"Status" text NULL,
"ErrMessage" text NULL,
PRIMARY KEY ("Id")
);
-- Create "EncounterSimxLog" table
CREATE TABLE "public"."EncounterSimxLog" (
"Id" bigserial NOT NULL,
"CreatedAt" timestamptz NULL,
"UpdatedAt" timestamptz NULL,
"DeletedAt" timestamptz NULL,
"Value" text NULL,
"Date" timestamptz NULL,
"Status" text NULL,
"ErrMessage" text NULL,
PRIMARY KEY ("Id")
);
cmd/simgos-sync-migration/migrations/atlas.sum
+4 -2
View File
@@ -1,4 +1,6 @@
h1:SN+f41iFH0m63kHeZHYricAjil5GJ9EC0LBOSdFDnmY=
h1:keVmwgYtvwxSqkq+7nB0BA25JFYRAVBpBBu5eA4Q9Hw=
20251113035508.sql h1:rjDlu6yDdy5xv6nrCOr7NialrLSLT23pzduYNq29Hf0=
20251114071129.sql h1:Z0GQ5bJo3C+tplaWzxT8n3J9HLkEaVsRVp5nn7bmYow=
20251117041601.sql h1:mIxZ2luKQREXUBY36PwLNDFI/Wf1T6Z2DDoGOueXFwI=
20251117041601.sql h1:l/RPG5mObqCSBjO4mzG+wTq2ieSycvlfOSz4czpUdWY=
20251118082246.sql h1:VFnYls2DBC8tJm2aw0iBcbWGLsKezYdOHJJV9iS7MjI=
20251118082915.sql h1:tAm67fXrH+8IJCjKbJroIqc1uQyqCnuGJnQtLmw7D20=
internal/domain/bpjs-entities/vclaim-sep-control-letter/dto.go
+61
View File
@@ -0,0 +1,61 @@
package vclaimsepcontrolletter
import (
ecore "simrs-vx/internal/domain/base-entities/core"
)
type CreateDto struct {
VclaimSep_Number *string `json:"vclaimSep_number"`
}
type ReadListDto struct {
FilterDto
Includes string `json:"includes"`
Sort string `json:"sort"`
Pagination ecore.Pagination
}
type FilterDto struct {
VclaimSep_Number *string `json:"vclaimSep_number"`
}
type ReadDetailDto struct {
Id uint `json:"id"`
}
type UpdateDto struct {
Id uint `json:"id"`
CreateDto
}
type DeleteDto struct {
Id uint `json:"id"`
}
type MetaDto struct {
PageNumber int `json:"page_number"`
PageSize int `json:"page_size"`
Count int `json:"count"`
}
type ResponseDto struct {
ecore.Main
VclaimSep_Number *string `json:"vclaimSep_number"`
Counter *uint `json:"counter"`
}
func (d VclaimSepControlLetter) ToResponse() ResponseDto {
resp := ResponseDto{
VclaimSep_Number: d.VclaimSep_Number,
}
resp.Main = d.Main
return resp
}
func ToResponseList(data []VclaimSepControlLetter) []ResponseDto {
resp := make([]ResponseDto, len(data))
for i, u := range data {
resp[i] = u.ToResponse()
}
return resp
}
internal/domain/bpjs-entities/vclaim-sep-control-letter/entity.go
+13
View File
@@ -0,0 +1,13 @@
package vclaimsepcontrolletter
import (
ecore "simrs-vx/internal/domain/base-entities/core"
)
type VclaimSepControlLetter struct {
ecore.Main
VclaimSep_Number *string `json:"vclaimSep_number"`
Number *string `json:"number" gorm:"unique;size:20"`
Value *string `json:"value"`
FileUrl *string `json:"fileUrl" gorm:"unique;size:1024"`
}
internal/domain/bpjs-entities/vclaim-sep-print/entity.go
+2 -4
View File
@@ -2,12 +2,10 @@ package vclaimsepprint
import (
ecore "simrs-vx/internal/domain/base-entities/core"
evs "simrs-vx/internal/domain/bpjs-entities/vclaim-sep"
)
type VclaimSepPrint struct {
ecore.Main
VclaimSep_Number *string `json:"vclaimSep_number"`
VclaimSep *evs.VclaimSep `json:"vclaimSep,omitempty" gorm:"foreignKey:VclaimSep_Number;references:Number"`
Counter *uint `json:"counter"`
VclaimSep_Number *string `json:"vclaimSep_number"`
Counter *uint `json:"counter"`
}
internal/domain/bpjs-entities/vclaim-sep/entitiy.go
+6 -2
View File
@@ -2,10 +2,14 @@ package vclaimsep
import (
ecore "simrs-vx/internal/domain/base-entities/core"
evscl "simrs-vx/internal/domain/bpjs-entities/vclaim-sep-control-letter"
evsp "simrs-vx/internal/domain/bpjs-entities/vclaim-sep-print"
)
type VclaimSep struct {
ecore.Main
Encounter_Id *uint `json:"encounter_id"`
Number *string `json:"number" gorm:"unique;size:19"`
Encounter_Id *uint `json:"encounter_id"`
Number *string `json:"number" gorm:"unique;size:19"`
Prints []*evsp.VclaimSepPrint `json:"prints,omitempty" gorm:"foreignKey:VclaimSep_Number;references:Number"`
ControlLetters []*evscl.VclaimSepControlLetter `json:"controlLetters,omitempty" gorm:"foreignKey:VclaimSep_Number;references:Number"`
}
internal/domain/main-entities/patient/dto.go
+1
View File
@@ -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/main-entities/person/entity.go
+4 -4
View File
@@ -25,16 +25,16 @@ type Person struct {
BirthRegency_Code *string `json:"birthRegency_code" gorm:"size:4"`
BirthRegency *er.Regency `json:"birthRegency,omitempty" gorm:"foreignKey:BirthRegency_Code;references:Code"`
Gender_Code *erp.GenderCode `json:"gender_code" gorm:"size:10"`
ResidentIdentityNumber *string `json:"residentIdentityNumber" gorm:"unique;size:16"`
PassportNumber *string `json:"passportNumber" gorm:"unique;size:20"`
DrivingLicenseNumber *string `json:"drivingLicenseNumber" gorm:"unique;size:20"`
ResidentIdentityNumber *string `json:"residentIdentityNumber" gorm:"uniqueIndex:idx_resident_identity,where:\"DeletedAt\" IS NULL;size:16"`
PassportNumber *string `json:"passportNumber" gorm:"uniqueIndex:idx_passport,where:\"DeletedAt\" IS NULL;size:20"`
DrivingLicenseNumber *string `json:"drivingLicenseNumber" gorm:"uniqueIndex:idx_driver_license,where:\"DeletedAt\" IS NULL;size:20"`
Religion_Code *erp.ReligionCode `json:"religion_code" gorm:"size:10"`
Confidence *string `json:"confidence" gorm:"size:512"`
Education_Code *erp.EducationCode `json:"education_code" gorm:"size:10"`
Ocupation_Code *erp.OcupationCode `json:"occupation_code" gorm:"size:15"`
Ocupation_Name *string `json:"occupation_name" gorm:"size:50"`
MaritalStatus_Code *erp.MaritalStatusCode `json:"maritalStatus_code" gorm:"size:10"`
Nationality *string `json:"nationality": gorm:"size:50"`
Nationality *string `json:"nationality" gorm:"size:50"`
Ethnic_Code *string `json:"ethnic_code" gorm:"size:20"`
Ethnic *ee.Ethnic `json:"ethnic,omitempty" gorm:"foreignKey:Ethnic_Code;references:Code"`
Language_Code *string `json:"language_code" gorm:"size:10"`
internal/domain/simgos-entities/division/entity.go
+10 -10
View File
@@ -1,16 +1,16 @@
package division
type MUnit struct {
KodeUnit uint `json:"kode_unit" gorm:"primaryKey;autoIncrement;column:kode_unit"`
NamaUnit string `json:"nama_unit" gorm:"column:nama_unit"`
GrupUnit uint `json:"grup_unit" gorm:"column:grup_unit"`
NamaGrupunit string `json:"nama_grupunit" gorm:"column:nama_grupunit"`
PendapatanUnit string `json:"pendapatan_unit" gorm:"column:pendapatan_unit"`
Smf string `json:"smf" gorm:"column:smf"`
HaveSubspecialis uint `json:"have_subspecialis" gorm:"column:have_subspecialis"`
KelSmfTarif string `json:"kel_smf_tarif" gorm:"column:kel_smf_tarif"`
IsPilihSatker uint `json:"is_pilih_satker" gorm:"column:is_pilih_satker"`
NamaTempatlayanan string `json:"nama_tempatlayanan" gorm:"column:nama_tempatlayanan"`
KodeUnit uint `json:"kode_unit" gorm:"primaryKey;autoIncrement;column:kode_unit"`
NamaUnit string `json:"nama_unit" gorm:"column:nama_unit"`
GrupUnit uint `json:"grup_unit" gorm:"column:grup_unit"`
NamaGrupunit string `json:"nama_grupunit" gorm:"column:nama_grupunit"`
PendapatanUnit string `json:"pendapatan_unit" gorm:"column:pendapatan_unit"`
Smf *string `json:"smf" gorm:"column:smf"`
HaveSubspecialis *uint `json:"have_subspecialis" gorm:"column:have_subspecialis"`
KelSmfTarif *string `json:"kel_smf_tarif" gorm:"column:kel_smf_tarif"`
IsPilihSatker *uint `json:"is_pilih_satker" gorm:"column:is_pilih_satker"`
NamaTempatlayanan string `json:"nama_tempatlayanan" gorm:"column:nama_tempatlayanan"`
}
func (MUnit) TableName() string {
internal/domain/simgos-entities/encounter/entity.go
+90
View File
@@ -0,0 +1,90 @@
package encounter
import "time"
type TPendaftaran struct {
Nomr string `json:"nomr" gorm:"column:nomr"`
Tglreg *time.Time `json:"tglreg" gorm:"column:tglreg"`
Kddokter uint `json:"kddokter" gorm:"column:kddokter"`
Kdpoly uint `json:"kdpoly" gorm:"column:kdpoly"`
Subspesialis *uint `json:"subspesialis" gorm:"column:subspesialis"`
Kdrujuk uint `json:"kdrujuk" gorm:"column:kdrujuk"`
Kdcarabayar uint `json:"kdcarabayar" gorm:"column:kdcarabayar"`
Nojaminan string `json:"nojaminan" gorm:"column:nojaminan"`
Shift uint `json:"shift" gorm:"column:shift"`
Status uint `json:"status" gorm:"column:status"`
KeteranganStatus *uint `json:"keterangan_status" gorm:"column:keterangan_status"`
Pasienbaru uint `json:"pasienbaru" gorm:"column:pasienbaru"`
Nip string `json:"nip" gorm:"column:nip"`
Idxdaftar uint `json:"idxdaftar" gorm:"column:idxdaftar"`
Masukpoly *time.Time `json:"masukpoly" gorm:"column:masukpoly"`
Keluarpoly *time.Time `json:"keluarpoly" gorm:"column:keluarpoly"`
Ketrujuk string `json:"ketrujuk" gorm:"column:ketrujuk"`
Ketbayar string `json:"ketbayar" gorm:"column:ketbayar"`
PenanggungjawabNama string `json:"penanggungjawab_nama" gorm:"column:penanggungjawab_nama"`
PenanggungjawabHubungan string `json:"penanggungjawab_hubungan" gorm:"column:penanggungjawab_hubungan"`
PenanggungjawabAlamat string `json:"penanggungjawab_alamat" gorm:"column:penanggungjawab_alamat"`
PenanggungjawabPhone string `json:"penanggungjawab_phone" gorm:"column:penanggungjawab_phone"`
Jamreg *time.Time `json:"jamreg" gorm:"column:jamreg"`
MintaRujukan string `json:"minta_rujukan" gorm:"column:minta_rujukan"`
Batal *string `json:"batal" gorm:"column:batal"`
NoSjp *string `json:"no_sjp" gorm:"column:no_sjp"`
NoPeserta *string `json:"no_peserta" gorm:"column:no_peserta"`
Nokartu string `json:"nokartu" gorm:"column:nokartu"`
Norujukan string `json:"norujukan" gorm:"column:norujukan"`
Tglrujukan *time.Time `json:"tglrujukan" gorm:"column:tglrujukan"`
DiagnosaAwal string `json:"diagnosa_awal" gorm:"column:diagnosa_awal"`
Nosep string `json:"nosep" gorm:"column:nosep"`
DiagnosaUtama string `json:"diagnosa_utama" gorm:"column:diagnosa_utama"`
KelasDaftar uint `json:"kelas_daftar" gorm:"column:kelas_daftar"`
KelasRawat *uint `json:"kelas_rawat" gorm:"column:kelas_rawat"`
TglKelasDaftar *time.Time `json:"tgl_kelas_daftar" gorm:"column:tgl_kelas_daftar"`
TglKelasRawat *time.Time `json:"tgl_kelas_rawat" gorm:"column:tgl_kelas_rawat"`
UserKelasDaftar *string `json:"user_kelas_daftar" gorm:"column:user_kelas_daftar"`
UserKelasRawat *string `json:"user_kelas_rawat" gorm:"column:user_kelas_rawat"`
StAsalMasuk string `json:"st_asal_masuk" gorm:"column:st_asal_masuk"`
StatusKecelakaan string `json:"status_kecelakaan" gorm:"column:status_kecelakaan"`
Catatan string `json:"catatan" gorm:"column:catatan"`
NoAntrian *string `json:"no_antrian" gorm:"column:no_antrian"`
StPelayanan *uint `json:"st_pelayanan" gorm:"column:st_pelayanan"`
PetugasKlinik string `json:"petugas_klinik" gorm:"column:petugas_klinik"`
Strujukan uint `json:"strujukan" gorm:"column:strujukan"`
IdPatientEklaim *uint `json:"id_patient_eklaim" gorm:"column:id_patient_eklaim"`
HakKelas *uint `json:"hak_kelas" gorm:"column:hak_kelas"`
SttsKtp string `json:"stts_ktp" gorm:"column:stts_ktp"`
StMeninggal *uint `json:"st_meninggal" gorm:"column:st_meninggal"`
DtMeninggal *time.Time `json:"dt_meninggal" gorm:"column:dt_meninggal"`
SebabMati1 *string `json:"sebab_mati_1" gorm:"column:sebab_mati_1"`
SebabMati2 *string `json:"sebab_mati_2" gorm:"column:sebab_mati_2"`
SebabMati3 *string `json:"sebab_mati_3" gorm:"column:sebab_mati_3"`
IcdMati1 *string `json:"icd_mati_1" gorm:"column:icd_mati_1"`
IcdMati2 *string `json:"icd_mati_2" gorm:"column:icd_mati_2"`
IcdMati3 *string `json:"icd_mati_3" gorm:"column:icd_mati_3"`
KeteranganLain *string `json:"keterangan_lain" gorm:"column:keterangan_lain"`
DokumenPendukung *string `json:"dokumen_pendukung" gorm:"column:dokumen_pendukung"`
NoKunjung uint `json:"no_kunjung" gorm:"column:no_kunjung"`
KdJamin *uint `json:"kd_jamin" gorm:"column:kd_jamin"`
NamaJamin *string `json:"nama_jamin" gorm:"column:nama_jamin"`
SepFile string `json:"sep_file" gorm:"column:sep_file"`
JenisFaskes *string `json:"jenis_faskes" gorm:"column:jenis_faskes"`
Nosipp *string `json:"nosipp" gorm:"column:nosipp"`
SippFile *string `json:"sipp_file" gorm:"column:sipp_file"`
Nosurkon *string `json:"nosurkon" gorm:"column:nosurkon"`
NomorBarcode *string `json:"nomor_barcode" gorm:"column:nomor_barcode"`
BarcodeCode *string `json:"barcode_code" gorm:"column:barcode_code"`
PartialType *string `json:"partial_type" gorm:"column:partial_type"`
IsPartial *uint `json:"is_partial" gorm:"column:is_partial"`
IsPenunjang *uint `json:"is_penunjang" gorm:"column:is_penunjang"`
TindakanCode *string `json:"tindakan_code" gorm:"column:tindakan_code"`
StatusSep *uint `json:"status_sep" gorm:"column:status_sep"`
PoliNameHfis *string `json:"poli_name_hfis" gorm:"column:poli_name_hfis"`
SpesialisIdHfis *string `json:"spesialis_id_hfis" gorm:"column:spesialis_id_hfis"`
DokterNameHfis *string `json:"dokter_name_hfis" gorm:"column:dokter_name_hfis"`
DokterIdHfis *string `json:"dokter_id_hfis" gorm:"column:dokter_id_hfis"`
StatusBridging *string `json:"status_bridging" gorm:"column:status_bridging"`
NoSpri *string `json:"no_spri" gorm:"column:no_spri"`
}
func (TPendaftaran) TableName() string {
return "t_pendaftaran"
}
internal/domain/simgos-entities/patient/entity.go
+80
View File
@@ -0,0 +1,80 @@
package patient
import "time"
type MPasien struct {
Id uint `json:"id" gorm:"primaryKey;autoIncrement;column:id"`
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 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"`
Notelp string `json:"notelp" gorm:"column:notelp"`
Noktp string `json:"noktp" gorm:"column:noktp"`
SuamiOrtu *string `json:"suami_ortu" gorm:"column:suami_ortu"`
Pekerjaan string `json:"pekerjaan" gorm:"column:pekerjaan"`
Status uint `json:"status" gorm:"column:status"`
Agama uint `json:"agama" gorm:"column:agama"`
Pendidikan uint `json:"pendidikan" gorm:"column:pendidikan"`
Kdcarabayar *uint `json:"kdcarabayar" gorm:"column:kdcarabayar"`
Nip *string `json:"nip" gorm:"column:nip"`
Tgldaftar *time.Time `json:"tgldaftar" gorm:"column:tgldaftar"`
AlamatKtp string `json:"alamat_ktp" gorm:"column:alamat_ktp"`
ParentNomr *string `json:"parent_nomr" gorm:"column:parent_nomr"`
Kepercayaan string `json:"kepercayaan" gorm:"column:kepercayaan"`
PenanggungjawabNama string `json:"penanggungjawab_nama" gorm:"column:penanggungjawab_nama"`
PenanggungjawabHubungan string `json:"penanggungjawab_hubungan" gorm:"column:penanggungjawab_hubungan"`
PenanggungjawabAlamat string `json:"penanggungjawab_alamat" gorm:"column:penanggungjawab_alamat"`
PenanggungjawabPhone string `json:"penanggungjawab_phone" gorm:"column:penanggungjawab_phone"`
NoKartu string `json:"no_kartu" gorm:"column:no_kartu"`
JnsPasien string `json:"jns_pasien" gorm:"column:jns_pasien"`
Nk *string `json:"nk" gorm:"column:nk"`
Kdprovider *string `json:"kdprovider" gorm:"column:kdprovider"`
Nmprovider *string `json:"nmprovider" gorm:"column:nmprovider"`
Kelas *uint `json:"kelas" gorm:"column:kelas"`
Sim *string `json:"sim" gorm:"column:sim"`
Paspor *string `json:"paspor" gorm:"column:paspor"`
Disabilitas *string `json:"disabilitas" gorm:"column:disabilitas"`
Bahasa string `json:"bahasa" gorm:"column:bahasa"`
HambatanKomunikasi string `json:"hambatan_komunikasi" gorm:"column:hambatan_komunikasi"`
Kebangsaan string `json:"kebangsaan" gorm:"column:kebangsaan"`
Notelprumah1 string `json:"notelprumah1" gorm:"column:notelprumah1"`
Notelprumah2 *string `json:"notelprumah2" gorm:"column:notelprumah2"`
Notelpkantor string `json:"notelpkantor" gorm:"column:notelpkantor"`
NoHp *string `json:"no_hp" gorm:"column:no_hp"`
AsalMasuk *string `json:"asal_masuk" gorm:"column:asal_masuk"`
Diagnosa *string `json:"diagnosa" gorm:"column:diagnosa"`
DiagnosaUtama *string `json:"diagnosa_utama" gorm:"column:diagnosa_utama"`
Suku string `json:"suku" gorm:"column:suku"`
AgamaLain string `json:"agama_lain" gorm:"column:agama_lain"`
StDisabilitas uint `json:"stDisabilitas" gorm:"column:st_disabilitas"`
TxtKelurahan string `json:"txt_kelurahan" gorm:"column:txt_kelurahan"`
TxtKecamatan string `json:"txt_kecamatan" gorm:"column:txt_kecamatan"`
TxtKota string `json:"txt_kota" gorm:"column:txt_kota"`
TxtProvinsi string `json:"txt_provinsi" gorm:"column:txt_provinsi"`
TxtStatus string `json:"txt_status" gorm:"column:txt_status"`
TxtAgama string `json:"txt_agama" gorm:"column:txt_agama"`
TxtPendidikan string `json:"txt_pendidikan" gorm:"column:txt_pendidikan"`
NamaAyah string `json:"nama_ayah" gorm:"column:nama_ayah"`
NamaIbu string `json:"nama_ibu" gorm:"column:nama_ibu"`
PendidikanAyah string `json:"pendidikan_ayah" gorm:"column:pendidikan_ayah"`
PendidikanIbu string `json:"pendidikan_ibu" gorm:"column:pendidikan_ibu"`
StIdentitasOrtu string `json:"st_identitas_ortu" gorm:"column:st_identitas_ortu"`
NomrBaru *string `json:"nomr_baru" gorm:"column:nomr_baru"`
KtpFile *string `json:"ktp_file" gorm:"column:ktp_file"`
KkFile *string `json:"kk_file" gorm:"column:kk_file"`
CreatedAt *time.Time `json:"created_at" gorm:"column:created_at"`
UpdatedAt *time.Time `json:"updated_at" gorm:"column:updated_at"`
NoKk *string `json:"no_kk" gorm:"column:no_kk"`
NoktpBaru string `json:"noktp_baru" gorm:"column:noktp_baru"`
}
func (MPasien) TableName() string {
return "m_pasien"
}
internal/domain/sync-entities/encounter/entity.go
+31
View File
@@ -0,0 +1,31 @@
package encounter
import (
"time"
erc "simrs-vx/internal/domain/references/common"
ecore "simrs-vx/internal/domain/base-entities/core"
)
type EncounterLink struct {
ecore.Main
Simx_Id uint `json:"simx_id" gorm:"unique"`
Simgos_Id uint `json:"simgos_id" gorm:"unique"`
}
type EncounterSimxLog struct {
ecore.Main
Value *string `json:"value"`
Date *time.Time `json:"date"`
Status erc.ProcessStatusCode `json:"status"`
ErrMessage *string `json:"errMessage"`
}
type EncounterSimgosLog struct {
ecore.Main
Value *string `json:"value"`
Date *time.Time `json:"date"`
Status erc.ProcessStatusCode `json:"status"`
ErrMessage *string `json:"errMessage"`
}
internal/domain/sync-entities/patient/entity.go
+31
View File
@@ -0,0 +1,31 @@
package patient
import (
"time"
erc "simrs-vx/internal/domain/references/common"
ecore "simrs-vx/internal/domain/base-entities/core"
)
type PatientLink struct {
ecore.Main
Simx_Id uint `json:"simx_id" gorm:"unique"`
Simgos_Id uint `json:"simgos_id" gorm:"unique"`
}
type PatientSimxLog struct {
ecore.Main
Value *string `json:"value"`
Date *time.Time `json:"date"`
Status erc.ProcessStatusCode `json:"status"`
ErrMessage *string `json:"errMessage"`
}
type PatientSimgosLog struct {
ecore.Main
Value *string `json:"value"`
Date *time.Time `json:"date"`
Status erc.ProcessStatusCode `json:"status"`
ErrMessage *string `json:"errMessage"`
}
internal/interface/migration/main-entities.go
+2
View File
@@ -103,6 +103,7 @@ import (
///BPJS
vclaimmember "simrs-vx/internal/domain/bpjs-entities/vclaim-member"
vclaimsep "simrs-vx/internal/domain/bpjs-entities/vclaim-sep"
vclaimsepcontrolletter "simrs-vx/internal/domain/bpjs-entities/vclaim-sep-control-letter"
vclaimsephist "simrs-vx/internal/domain/bpjs-entities/vclaim-sep-hist"
vclaimsepprint "simrs-vx/internal/domain/bpjs-entities/vclaim-sep-print"
)
@@ -211,5 +212,6 @@ func getMainEntities() []any {
&rehab.Rehab{},
&chemoprotocol.ChemoProtocol{},
&fileattachemnt.EncounterDocument{},
&vclaimsepcontrolletter.VclaimSepControlLetter{},
}
}
internal/interface/migration/simgossync-entities.go
+8
View File
@@ -3,7 +3,9 @@ package migration
import (
/************** Source ***************/
division "simrs-vx/internal/domain/sync-entities/division"
encounter "simrs-vx/internal/domain/sync-entities/encounter"
installation "simrs-vx/internal/domain/sync-entities/installation"
patient "simrs-vx/internal/domain/sync-entities/patient"
specialist "simrs-vx/internal/domain/sync-entities/specialist"
subspecialist "simrs-vx/internal/domain/sync-entities/subspecialist"
unit "simrs-vx/internal/domain/sync-entities/unit"
@@ -26,5 +28,11 @@ func getSyncEntities() []any {
&subspecialist.SubspecialistLink{},
&subspecialist.SubspecialistSimxLog{},
&subspecialist.SubspecialistSimgosLog{},
&patient.PatientLink{},
&patient.PatientSimxLog{},
&patient.PatientSimgosLog{},
&encounter.EncounterLink{},
&encounter.EncounterSimxLog{},
&encounter.EncounterSimgosLog{},
}
}
internal/interface/simgos-sync-handler/patient/handler.go
+68
View File
@@ -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
+4
View File
@@ -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
+4 -4
View File
@@ -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/generate-file/tycovar.go
+22
View File
@@ -23,6 +23,28 @@ type GenerateDto struct {
Encounter_Id *uint `json:"-"`
}
type VclaimControlLetter struct {
Number string `json:"noSuratKontrol"`
Date string `json:"tglRencanaKontrol"`
Doctor_Name string `json:"namaDokter"`
DstUnit_Name string `json:"namaPoliTujuan"`
ResponsibleDoctor_Name string `json:"namaDokterPembuat"`
VclaimSep VclaimSep `json:"sep"`
}
type VclaimSep struct {
VclaimMember VclaimMember `json:"peserta"`
Diagnose string `json:"diagnosa"`
Number string `json:"noSep"`
}
type VclaimMember struct {
CardNumber string `json:"noKartu"`
Name string `json:"nama"`
BirthDate string `json:"tglLahir"`
Gender string `json:"kelamin"`
}
type GeneratePDFdto struct {
TemplatePath string
TemplateData any
internal/use-case/main-use-case/installation/middleware.go
+4 -4
View File
@@ -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
+120 -38
View File
@@ -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
+51 -29
View File
@@ -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
+2 -1
View File
@@ -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
+90 -10
View File
@@ -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
+18 -3
View File
@@ -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
+35 -6
View File
@@ -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
+25
View File
@@ -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
+25
View File
@@ -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
+25
View File
@@ -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
+25
View File
@@ -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
+4 -4
View File
@@ -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
+1 -1
View File
@@ -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
+4 -4
View File
@@ -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
+207
View File
@@ -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
+231
View File
@@ -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
+317
View File
@@ -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
+189
View File
@@ -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
+104
View File
@@ -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
+9
View File
@@ -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
+44
View File
@@ -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