diff --git a/cmd/simgos-sync-migration/migrations/20251118082246.sql b/cmd/simgos-sync-migration/migrations/20251118082246.sql new file mode 100644 index 00000000..f5d9dbf5 --- /dev/null +++ b/cmd/simgos-sync-migration/migrations/20251118082246.sql @@ -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") +); diff --git a/cmd/simgos-sync-migration/migrations/20251118082915.sql b/cmd/simgos-sync-migration/migrations/20251118082915.sql new file mode 100644 index 00000000..90b41344 --- /dev/null +++ b/cmd/simgos-sync-migration/migrations/20251118082915.sql @@ -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") +); diff --git a/cmd/simgos-sync-migration/migrations/atlas.sum b/cmd/simgos-sync-migration/migrations/atlas.sum index 30f8c5dc..07e5fbaf 100644 --- a/cmd/simgos-sync-migration/migrations/atlas.sum +++ b/cmd/simgos-sync-migration/migrations/atlas.sum @@ -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= diff --git a/internal/domain/simgos-entities/Encounter/entity.go b/internal/domain/simgos-entities/Encounter/entity.go new file mode 100644 index 00000000..16ba873e --- /dev/null +++ b/internal/domain/simgos-entities/Encounter/entity.go @@ -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" +} diff --git a/internal/domain/simgos-entities/division/entity.go b/internal/domain/simgos-entities/division/entity.go index c10f5429..0cc38494 100644 --- a/internal/domain/simgos-entities/division/entity.go +++ b/internal/domain/simgos-entities/division/entity.go @@ -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 { diff --git a/internal/domain/simgos-entities/patient/entity.go b/internal/domain/simgos-entities/patient/entity.go new file mode 100644 index 00000000..3013e121 --- /dev/null +++ b/internal/domain/simgos-entities/patient/entity.go @@ -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:"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"` + 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" json:"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" +} diff --git a/internal/domain/sync-entities/encounter/entity.go b/internal/domain/sync-entities/encounter/entity.go new file mode 100644 index 00000000..f92d3e42 --- /dev/null +++ b/internal/domain/sync-entities/encounter/entity.go @@ -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"` +} diff --git a/internal/domain/sync-entities/patient/entity.go b/internal/domain/sync-entities/patient/entity.go new file mode 100644 index 00000000..e8c5b325 --- /dev/null +++ b/internal/domain/sync-entities/patient/entity.go @@ -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"` +} diff --git a/internal/interface/migration/simgossync-entities.go b/internal/interface/migration/simgossync-entities.go index efc4cce9..b10c8607 100644 --- a/internal/interface/migration/simgossync-entities.go +++ b/internal/interface/migration/simgossync-entities.go @@ -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{}, } }