update code

Reviewed-on: #6

.env

@@ -4,8 +4,8 @@ SATUDATA_PASSWORD=stim*RS54
 SATUDATA_NAME=satu_db
 SATUDATA_PORT=5000
 
-BASEURL_BPJS=https://apijkn.bpjs-kesehatan.go.id/
-ANTREAN_RS=antreanrs
+BASEURL_BPJS=https://apijkn.bpjs-kesehatan.go.id
+ANTREAN_RS=/antreanrs
 CONS_ID=5257
 USER_KEY=4cf1cbef8c008440bbe9ef9ba789e482
 SECRET_KEY=1bV363512D
@@ -13,12 +13,23 @@ SECRET_KEY=1bV363512D
 CONS_ID_DEV=16041
 USER_KEY_DEV=467a2817fde5070f66c9a41fbeb8dc2c
 SECRET_KEY_DEV=8pP3D5431E
+USER_KEY_ICARE=1cd65acaa349684be6353bea5149e2e2
+
+BASEURL_BPJS_DEV=https://apijkn-dev.bpjs-kesehatan.go.id
+VCLAIM_RS_DEV=/vclaim-rest-dev
+SURAT_KONTROL_RS=/vclaim-rest
+I_CARE_JKN=/wsihs
+I_CARE_JKN_DEV=/ihs_dev
 
-BASEURL_BPJS_DEV=https://apijkn-dev.bpjs-kesehatan.go.id/
-SURAT_KONTROL_RS=vclaim-rest
 INSERT_SURAT_KONTROL=/RencanaKontrol/insert
 UPDATE_SURAT_KONTROL=/RencanaKontrol/Update
 DELETE_SURAT_KONTROL=/RencanaKontrol/Delete
 GET_NOMOR_SURAT_KONTROL=/RencanaKontrol/noSuratKontrol/
 GET_SURAT_KONTROL_SEP=/RencanaKontrol/nosep/
+GET_NOMOR_RUJUKAN=/Rujukan/
+GET_NOMOR_RUJUKAN_BATCH=/Rujukan/List/Peserta/
+
+GET_FKRTL=/api/rs/validate
+GET_FKTP=/api/pcare/validate
+
 

.idea/.gitignore

@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

.idea/api-bpjs-surkon.iml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="WEB_MODULE" version="4">
+  <component name="Go" enabled="true">
+    <buildTags>
+      <option name="os" value="linux" />
+    </buildTags>
+  </component>
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/api-bpjs-surkon.iml" filepath="$PROJECT_DIR$/.idea/api-bpjs-surkon.iml" />
+    </modules>
+  </component>
+</project>

.idea/vcs.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="" vcs="Git" />
+  </component>
+</project>

Dockerfile

@@ -12,7 +12,11 @@ RUN CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o main .
 # RUN CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o app .
 
 FROM alpine:latest
-RUN apk --no-cache add ca-certificates
+
+# Set timezone ke Asia/Jakarta
+ENV TZ=Asia/Jakarta
+
+RUN apk --no-cache add ca-certificates tzdata
 
 WORKDIR /root/
 

config/config.go

@@ -36,20 +36,19 @@ func ConnectDB() {
 	}
 }
 
-func SetHeader(cfg config.ConfigBpjs) *config.Header {
+func SetHeader(isIcare bool, cfg config.ConfigBpjs) *config.Header {
 
 	timenow := time.Now().UTC()
 	time := time.Date(1970, 1, 1, 0, 0, 0, 0, time.UTC)
 	tstamp := timenow.Unix() - time.Unix()
 
-	// cfg.Cons_id = os.Getenv("CONS_ID_DEV")
-	// cfg.User_key = os.Getenv("USER_KEY_DEV")
-	// cfg.Secret_key = os.Getenv("SECRET_KEY_DEV")
-
 	cfg.Cons_id = os.Getenv("CONS_ID")
 	cfg.User_key = os.Getenv("USER_KEY")
 	cfg.Secret_key = os.Getenv("SECRET_KEY")
 
+	if isIcare {
+		cfg.User_key = os.Getenv("USER_KEY_ICARE")
+	}
 	secret := []byte(cfg.Secret_key)
 	message := []byte(cfg.Cons_id + "&" + fmt.Sprint(tstamp))
 	hash := hmac.New(sha256.New, secret)

database/satu_data/dokter/dokter.go

@@ -14,7 +14,7 @@ import (
 func GetDokter() ([]dokter.DaftarDokterRes, error) {
 	var listDokter []dokter.DaftarDokter
 	var res []dokter.DaftarDokterRes
-	result := config.SatuDataDB.Debug().Raw(`select "id", "HFIS_code" from "data_pegawai" where "HFIS_code" is not null`).Scan(&listDokter)
+	result := config.SatuDataDB.Raw(`select "id", "HFIS_code" from "data_pegawai" where "HFIS_code" is not null`).Scan(&listDokter)
 	if result.Error != nil {
 		if !errors.Is(result.Error, gorm.ErrRecordNotFound) {
 			log.Fatalf("Error get data : %v", result.Error)
@@ -43,7 +43,7 @@ func GetDokter() ([]dokter.DaftarDokterRes, error) {
 
 func GetNamaLengkapDokter(idDokter []string) ([]dokter.NamaLengkap, error) {
 	var namaDokter []dokter.NamaLengkap
-	result := config.SatuDataDB.Debug().Raw(`select dp.id, 
+	result := config.SatuDataDB.Raw(`select dp.id, 
 		array(
 		select dgd. "Gelar_depan"
 		from data_pegawai_daftar_gelar_depan dpdgd
@@ -55,7 +55,8 @@ func GetNamaLengkapDokter(idDokter []string) ([]dokter.NamaLengkap, error) {
 		from data_pegawai_daftar_gelar_belakang dpdgb
 		left join daftar_gelar_belakang dgb on dpdgb.daftar_gelar_belakang_id = dgb.id where dpdgb.data_pegawai_id = dp.id
 		) AS gelarbelakang,
-		dp."HFIS_code"
+		dp."HFIS_code",
+		dp."Code_dpjp" as "DPJP_code"
 		from "data_pegawai" dp
 		left join data_ktp dk on dp."KTP" = dk.id
 		WHERE dp.id in ?`, idDokter).Find(&namaDokter)
@@ -70,3 +71,19 @@ func GetNamaLengkapDokter(idDokter []string) ([]dokter.NamaLengkap, error) {
 
 	return namaDokter, nil
 }
+
+func GetHFISCode(dpjp string) (*dokter.DaftarDokter, error) {
+	var dataDokter *dokter.DaftarDokter
+	err := config.SatuDataDB.Raw(`select dp."id", dp."HFIS_code" from data_pegawai dp where dp."Code_dpjp" = ?`, dpjp).First(&dataDokter).Error
+	if err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			errMsg := errors.New("Data tidak ditemukan")
+			log.Println("error :", errMsg)
+			return nil, errMsg
+		}
+		log.Println("error :", err)
+		return nil, err
+	}
+	log.Println("Daftar Dokter :", dataDokter)
+	return dataDokter, nil
+}

database/satu_data/dokter/jadwal_dokter.go

@@ -3,6 +3,7 @@ package dokter
 import (
 	"bridging-rssa/config"
 	"bridging-rssa/models/bpjs/jadwal_dokter"
+	"gorm.io/gorm"
 	"log"
 	"strconv"
 
@@ -11,7 +12,7 @@ import (
 
 func GetJadwalDokterByDPJP(dpjp string) (string, error) {
 	var id string
-	errSelect := config.SatuDataDB.Debug().Raw(`select "id" from "data_pegawai" where "Code_dpjp" = ?`, dpjp).First(&id).Error
+	errSelect := config.SatuDataDB.Raw(`select "id" from "data_pegawai" where "Code_dpjp" = ?`, dpjp).First(&id).Error
 	if errSelect != nil {
 		log.Printf("Failed get data : %v", errSelect)
 		return "", errSelect
@@ -21,7 +22,7 @@ func GetJadwalDokterByDPJP(dpjp string) (string, error) {
 
 func GetJadwalHariDokterBySpesialis(id string) ([]jadwal_dokter.JadwalDokterSatuData, error) {
 	var hari []jadwal_dokter.JadwalDokterSatuData
-	errSelect := config.SatuDataDB.Debug().Raw(`select * from "daftar_jadwal_dokter" where "Dokter" = ? order by "id"`, id).Scan(&hari).Error
+	errSelect := config.SatuDataDB.Raw(`select * from "daftar_jadwal_dokter" where "Dokter" = ? order by "id"`, id).Scan(&hari).Error
 	if errSelect != nil {
 		log.Printf("Failed get data : %v", errSelect)
 		return nil, errSelect
@@ -31,7 +32,7 @@ func GetJadwalHariDokterBySpesialis(id string) ([]jadwal_dokter.JadwalDokterSatu
 
 func GetJadwalDokterByIDDokter(hari string) ([]string, error) {
 	var spesialis []string
-	errSelect := config.SatuDataDB.Debug().Raw(`select distinct "Spesialis" from "daftar_jadwal_dokter" where "Nama_hari" = ? order by "Spesialis"`, hari).Scan(&spesialis).Error
+	errSelect := config.SatuDataDB.Raw(`select distinct "Spesialis" from "daftar_jadwal_dokter" where "Nama_hari" = ? order by "Spesialis"`, hari).Scan(&spesialis).Error
 	if errSelect != nil {
 		log.Printf("Failed get data : %v", errSelect)
 		return nil, errSelect
@@ -40,7 +41,7 @@ func GetJadwalDokterByIDDokter(hari string) ([]string, error) {
 }
 func GetJadwalDokterByDate(hari string) ([]string, error) {
 	var spesialis []string
-	errSelect := config.SatuDataDB.Debug().Raw(`select distinct "Spesialis" from "daftar_jadwal_dokter" where "Nama_hari" = ? order by "Spesialis"`, hari).Scan(&spesialis).Error
+	errSelect := config.SatuDataDB.Raw(`select distinct "Spesialis" from "daftar_jadwal_dokter" where "Nama_hari" = ? order by "Spesialis"`, hari).Scan(&spesialis).Error
 	if errSelect != nil {
 		log.Printf("Failed get data : %v", errSelect)
 		return nil, errSelect
@@ -50,7 +51,7 @@ func GetJadwalDokterByDate(hari string) ([]string, error) {
 
 func GetJadwalSubspesialisByDate(hari string) ([]int, error) {
 	var subspesialis []int
-	errSelect := config.SatuDataDB.Debug().Raw(`select distinct "Sub_spesialis" from "daftar_jadwal_dokter" where "Nama_hari" = ? order by "Sub_spesialis"`, hari).Scan(&subspesialis).Error
+	errSelect := config.SatuDataDB.Raw(`select distinct "Sub_spesialis" from "daftar_jadwal_dokter" where "Nama_hari" = ? order by "Sub_spesialis"`, hari).Scan(&subspesialis).Error
 	if errSelect != nil {
 		log.Printf("Failed get data : %v", errSelect)
 		return nil, errSelect
@@ -60,7 +61,7 @@ func GetJadwalSubspesialisByDate(hari string) ([]int, error) {
 
 func GetJadwalDokterBySpesialis(hari string, spesialis string) ([]string, error) {
 	var listDokter []string
-	errSelect := config.SatuDataDB.Debug().Raw(`select "Dokter" from "daftar_jadwal_dokter" where "Nama_hari" = ? and "Spesialis" = ? order by "Spesialis"`, hari, spesialis).Scan(&listDokter).Error
+	errSelect := config.SatuDataDB.Raw(`select "Dokter" from "daftar_jadwal_dokter" where "Nama_hari" = ? and "Spesialis" = ? order by "Spesialis"`, hari, spesialis).Scan(&listDokter).Error
 	if errSelect != nil {
 		log.Printf("Failed get data : %v", errSelect)
 		return nil, errSelect
@@ -70,7 +71,7 @@ func GetJadwalDokterBySpesialis(hari string, spesialis string) ([]string, error)
 
 func GetJadwalDokterBySubpesialis(hari string, subspesialis string) ([]string, error) {
 	var listDokter []string
-	errSelect := config.SatuDataDB.Debug().Raw(`select "Dokter" from "daftar_jadwal_dokter" where "Nama_hari" = ? and "Sub_spesialis" = ? order by "Sub_spesialis"`, hari, subspesialis).Scan(&listDokter).Error
+	errSelect := config.SatuDataDB.Raw(`select "Dokter" from "daftar_jadwal_dokter" where "Nama_hari" = ? and "Sub_spesialis" = ? order by "Sub_spesialis"`, hari, subspesialis).Scan(&listDokter).Error
 	if errSelect != nil {
 		log.Printf("Failed get data : %v", errSelect)
 		return nil, errSelect
@@ -79,7 +80,17 @@ func GetJadwalDokterBySubpesialis(hari string, subspesialis string) ([]string, e
 }
 
 func DeleteJadwalDokter() error {
-	err := config.SatuDataDB.Debug().Exec(`truncate table "daftar_jadwal_dokter"`).Error
+	err := config.SatuDataDB.Exec(`truncate table "daftar_jadwal_dokter"`).Error
+	if err != nil {
+		log.Printf("Failed truncate data : %v", err)
+		return err
+	}
+	log.Println("Success truncate data")
+	return nil
+}
+
+func TruncateDataJadwalDokter() error {
+	err := config.SatuDataDB.Exec(`truncate table "data_jadwal_dokter"`).Error
 	if err != nil {
 		log.Printf("Failed truncate data : %v", err)
 		return err
@@ -89,7 +100,7 @@ func DeleteJadwalDokter() error {
 }
 
 func DeleteJadwalDokterTemp() error {
-	err := config.SatuDataDB.Debug().Exec(`truncate table "daftar_jadwal_dokter_temp"`).Error
+	err := config.SatuDataDB.Exec(`truncate table "daftar_jadwal_dokter_temp"`).Error
 	if err != nil {
 		log.Printf("Failed truncate data : %v", err)
 		return err
@@ -99,7 +110,7 @@ func DeleteJadwalDokterTemp() error {
 }
 
 func InsertJadwalDokter(reqInsert *jadwal_dokter.JadwalDokterSatuData) error {
-	err := config.SatuDataDB.Debug().Exec(`insert into "daftar_jadwal_dokter" ("Hari", "Nama_hari", "Waktu", "Dokter", "Spesialis", "Sub_spesialis", "Status") values (?, ? ,?, ?, ?, ?, ?)`, reqInsert.Hari, reqInsert.NamaHari, reqInsert.Waktu, reqInsert.Dokter, reqInsert.Spesialis, reqInsert.SubSpesialis, reqInsert.Status).Error
+	err := config.SatuDataDB.Exec(`insert into "daftar_jadwal_dokter" ("Hari", "Nama_hari", "Waktu", "Dokter", "Spesialis", "Sub_spesialis", "Status") values (?, ? ,?, ?, ?, ?, ?)`, reqInsert.Hari, reqInsert.NamaHari, reqInsert.Waktu, reqInsert.Dokter, reqInsert.Spesialis, reqInsert.SubSpesialis, reqInsert.Status).Error
 	if err != nil {
 		log.Printf("Failed insert data : %v", err)
 		return err
@@ -112,7 +123,17 @@ func InsertJadwalDokterTemp(reqInsert *jadwal_dokter.JadwalDokterSatuData) error
 	spesialis := strconv.Itoa(reqInsert.Spesialis)
 	subspesialis := strconv.Itoa(reqInsert.SubSpesialis)
 	id := uuid.New()
-	err := config.SatuDataDB.Debug().Exec(`insert into "daftar_jadwal_dokter_temp" ("id", "Hari", "Nama_hari", "Waktu", "Dokter", "Spesialis", "Sub_spesialis", "Status") values (?, ?, ?, ?, ?, ?, ?, ?)`, id, reqInsert.Hari, reqInsert.NamaHari, reqInsert.Waktu, reqInsert.Dokter, spesialis, subspesialis, reqInsert.Status).Error
+	err := config.SatuDataDB.Exec(`insert into "daftar_jadwal_dokter_temp" ("id", "Hari", "Nama_hari", "Waktu", "Dokter", "Spesialis", "Sub_spesialis", "Status") values (?, ?, ?, ?, ?, ?, ?, ?)`, id, reqInsert.Hari, reqInsert.NamaHari, reqInsert.Waktu, reqInsert.Dokter, spesialis, subspesialis, reqInsert.Status).Error
+	if err != nil {
+		log.Printf("Failed insert data : %v", err)
+		return err
+	}
+	log.Println("Success insert data")
+	return nil
+}
+
+func InsertDataJadwalDokter(tx *gorm.DB, reqInsert *jadwal_dokter.DataJadwalDokterSatuData) error {
+	err := tx.Debug().Exec(`insert into "data_jadwal_dokter" ("id", "Hari", "Nama_hari", "Waktu", "Dokter", "Spesialis", "Sub_spesialis", "Tanggal_jadwal") values (?, ?, ? ,?, ?, ?, ?, ?)`, reqInsert.ID, reqInsert.Hari, reqInsert.NamaHari, reqInsert.Waktu, reqInsert.Dokter, reqInsert.Spesialis, reqInsert.SubSpesialis, reqInsert.TanggalJadwal).Error
 	if err != nil {
 		log.Printf("Failed insert data : %v", err)
 		return err

database/satu_data/dokter/spesialis.go

@@ -12,7 +12,7 @@ import (
 func GetSpesialis() ([]dokter.DaftarSpesialis, error) {
 	var daftarSpesialis []dokter.DaftarSpesialis
 
-	result := config.SatuDataDB.Debug().Raw(`select * from "daftar_spesialis"`).Find(&daftarSpesialis)
+	result := config.SatuDataDB.Raw(`select * from "daftar_spesialis"`).Find(&daftarSpesialis)
 	if result.Error != nil {
 		if !errors.Is(result.Error, gorm.ErrRecordNotFound) {
 			log.Printf("Error get data : %v", result.Error)
@@ -27,7 +27,7 @@ func GetSpesialis() ([]dokter.DaftarSpesialis, error) {
 
 func GetSpesialisByID(idSpesialis []string) ([]dokter.DaftarSpesialis, error) {
 	var daftarSpesialis []dokter.DaftarSpesialis
-	result := config.SatuDataDB.Debug().Raw(`select * from "daftar_spesialis" where "id" in ?`, idSpesialis).Find(&daftarSpesialis)
+	result := config.SatuDataDB.Raw(`select * from "daftar_spesialis" where "id" in ?`, idSpesialis).Find(&daftarSpesialis)
 	if result.Error != nil {
 		if !errors.Is(result.Error, gorm.ErrRecordNotFound) {
 			log.Printf("Error get data : %v", result.Error)

database/satu_data/dokter/subspesialis.go

@@ -12,7 +12,7 @@ import (
 func GetSubspesialis() ([]dokter.DaftarSubspesialis, error) {
 	var daftarSubspesialis []dokter.DaftarSubspesialis
 
-	result := config.SatuDataDB.Debug().Raw(`select * from "daftar_subspesialis"`).Find(&daftarSubspesialis)
+	result := config.SatuDataDB.Raw(`select * from "daftar_subspesialis"`).Find(&daftarSubspesialis)
 	if result.Error != nil {
 		if !errors.Is(result.Error, gorm.ErrRecordNotFound) {
 			log.Printf("Error get data : %v", result.Error)
@@ -29,7 +29,7 @@ func GetSubspesialis() ([]dokter.DaftarSubspesialis, error) {
 func GetSubspesialisByID(idSubspesialis int) (*dokter.DaftarSubspesialis, error) {
 	var daftarSubspesialis *dokter.DaftarSubspesialis
 
-	result := config.SatuDataDB.Debug().Raw(`select dss.*, ds."Spesialis" 
+	result := config.SatuDataDB.Raw(`select dss.*, ds."Spesialis" 
 			from "daftar_subspesialis" dss 
 			left join "daftar_spesialis" ds on ds."id" = dss."FK_daftar_spesialis_ID" 
 			where dss.id = ?`, idSubspesialis).First(&daftarSubspesialis)
@@ -48,7 +48,7 @@ func GetSubspesialisByID(idSubspesialis int) (*dokter.DaftarSubspesialis, error)
 
 func GetSubspesialisByIDBatch(idSubspesialis []int) ([]dokter.DaftarSubspesialis, error) {
 	var daftarSubspesialis []dokter.DaftarSubspesialis
-	result := config.SatuDataDB.Debug().Raw(`select dss.*, ds."Spesialis" 
+	result := config.SatuDataDB.Raw(`select dss.*, ds."Spesialis" 
 			from "daftar_subspesialis" dss 
 			left join "daftar_spesialis" ds on ds."id" = dss."FK_daftar_spesialis_ID" 
 			where dss.id in ?

database/satu_data/jadwal/jadwal_libur.go

@@ -0,0 +1,21 @@
+package jadwal
+
+import (
+	"bridging-rssa/config"
+	"bridging-rssa/models/jadwal"
+	"log"
+)
+
+func GetJadwalLibur(date string) (*jadwal.DaftarJadwalLiburPelayanan, bool, error) {
+	var jadwalLibur *jadwal.DaftarJadwalLiburPelayanan
+	query := `select * from daftar_jadwal_libur_pelayanan where "Tanggal_libur_pelayanan" = ?`
+	q := config.SatuDataDB.Debug().Raw(query, date).Scan(&jadwalLibur)
+	if q.Error != nil {
+		log.Println(q.Error)
+		return nil, false, q.Error
+	} else if q.RowsAffected == 0 {
+		log.Println("Tidak pada hari libur")
+		return jadwalLibur, false, nil
+	}
+	return jadwalLibur, true, nil
+}

database/satu_data/log_api/log_api.go

@@ -0,0 +1,34 @@
+package logapi
+
+import (
+	"bridging-rssa/config"
+	logapi "bridging-rssa/models/log_api"
+	"log"
+)
+
+func InsertLogAPI(reqInsert *logapi.DataLogAPI) error {
+	query := `insert into "data_log_api" (
+        "id", "date_created", "User_agent", "IP", "Parameter", "Header", "Method", "URL", "Request", "Respon", "Respon_code", "Respontime_start", "Respontime_end", "Comment"
+    ) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`
+	err := config.SatuDataDB.Exec(query,
+		reqInsert.ID,
+		reqInsert.DateCreated,
+		reqInsert.UserAgent,
+		reqInsert.IP,
+		reqInsert.Parameter,
+		reqInsert.Header,
+		reqInsert.Method,
+		reqInsert.Url,
+		reqInsert.Request,
+		reqInsert.Respon,
+		reqInsert.ResponCode,
+		reqInsert.ResponTimeStart,
+		reqInsert.ResponTimeEnd,
+		reqInsert.Comment,
+	).Error
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	return nil
+}

database/satu_data/log_api/log_icare.go

@@ -0,0 +1,24 @@
+package logapi
+
+import (
+	"bridging-rssa/config"
+	logapi "bridging-rssa/models/log_api"
+	"log"
+)
+
+func InsertLogICare(reqInsert *logapi.InsertLogICare) error {
+	query := `insert into "data_log_icare_bpjs" ("id", "date_created", "Ruangan", "Dokter", "Kunjungan_pasien", "Waktu_transaksi") 
+			values (?, ?, ?, ?, ?, ?)`
+	errInsert := config.SatuDataDB.Exec(query,
+		reqInsert.ID,
+		reqInsert.DateCreated,
+		reqInsert.Ruangan,
+		reqInsert.Dokter,
+		reqInsert.Kunjungan_pasien,
+		reqInsert.WaktuTransaksi).Error
+	if errInsert != nil {
+		log.Println(errInsert)
+		return errInsert
+	}
+	return nil
+}

database/satu_data/lokasi_ruang/daftar_lokasi_ruang.go

@@ -0,0 +1,24 @@
+package lokasiruang
+
+import (
+	"bridging-rssa/config"
+	"errors"
+	"log"
+
+	"gorm.io/gorm"
+)
+
+func GetDaftarLokasiRuang(idSimgos string) (int, error) {
+	var idRuangan int
+	query := `select dlr."id" from "daftar_lokasi_ruang" dlr where dlr."Id_location_simgos" = ?`
+	err := config.SatuDataDB.Raw(query, idSimgos).First(&idRuangan).Error
+	if err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			log.Println(err)
+			return 128, nil
+		}
+		log.Println(err)
+		return 0, err
+	}
+	return idRuangan, nil
+}

database/satu_data/pasien/kunjungan_pasien.go

@@ -0,0 +1,27 @@
+package pasien
+
+import (
+	"bridging-rssa/config"
+	"bridging-rssa/models/pasien"
+	"errors"
+	"log"
+
+	"gorm.io/gorm"
+)
+
+func GetDataKunjunganPasien(idxdaftar string) (*pasien.KunjunganPasien, error) {
+	var kunjunganPasien *pasien.KunjunganPasien
+	query := `select dks."id", dks."Ruangan" from "data_kunjungan_pasien" dks where dks."IDXDAFTAR" = ?`
+	err := config.SatuDataDB.Raw(query, idxdaftar).First(&kunjunganPasien).Error
+	if err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			errMsg := errors.New("Data Tidak Ditemukan")
+			log.Println(errMsg)
+			return nil, errMsg
+		}
+		log.Println(err)
+		return nil, err
+	}
+	log.Println("Data Kunjungan Pasien : ", kunjunganPasien)
+	return kunjunganPasien, nil
+}

database/satu_data/surat_kontrol/kunjungan_pasien.go

@@ -7,7 +7,7 @@ import (
 )
 
 func UpdateKunjunganPasien(req sk.RequestInsertRencanaKontrol) error {
-	err := config.SatuDataDB.Debug().Exec(`update "data_kunjungan_pasien" set "Nomor_sep" = ?, "Diagnosis_akhir_keluar" = ?, "Display_diagnosis_akhir_keluar" = ?, "Diagnosis_primer_utama" = ?, "Display_diagnosis_primer_utama" = ? where "IDXDAFTAR" = ?`, req.NoSEP, req.KodeDiagnosa, req.NamaDiagnosa, req.KodeDiagnosa, req.NamaDiagnosa, req.IDXDaftar).Error
+	err := config.SatuDataDB.Exec(`update "data_kunjungan_pasien" set "Nomor_sep" = ?, "Diagnosis_akhir_keluar" = ?, "Display_diagnosis_akhir_keluar" = ?, "Diagnosis_primer_utama" = ?, "Display_diagnosis_primer_utama" = ? where "IDXDAFTAR" = ?`, req.NoSEP, req.KodeDiagnosa, req.NamaDiagnosa, req.KodeDiagnosa, req.NamaDiagnosa, req.IDXDaftar).Error
 	if err != nil {
 		log.Println(err)
 		return err

database/satu_data/surat_kontrol/surat_kontrol.go

@@ -11,7 +11,7 @@ import (
 
 func GetDataKunjunganPasien(idxdaftar string) (*suratkontrol.KunjunganPasien, error) {
 	var kunjunganPasien *suratkontrol.KunjunganPasien
-	err := config.SatuDataDB.Debug().Raw(`select dkp."id", dkp."IDXDAFTAR" as idxdaftar, dkp."Nomor_sep" as nomorsep, 
+	err := config.SatuDataDB.Raw(`select dkp."id", dkp."IDXDAFTAR" as idxdaftar, dkp."Nomor_sep" as nomorsep, 
 										dlr."Nama" as namaklinik, dlr."Id_location_simgos" as idkliniksimgos, dlr."Kode_hfis_bpjs" as kodehfisklinik,
 										dk."Nama_lengkap" as namadokter, 
 										dp."KDDOKTER" as kodedokter, dp."HFIS_code" as kodehfisdokter,
@@ -30,7 +30,8 @@ func GetDataKunjunganPasien(idxdaftar string) (*suratkontrol.KunjunganPasien, er
 											where dpdgb.data_pegawai_id = dp.id
 										) AS gelarbelakang,
 										dkp."Ruangan" as ruangan,
-										dkp."DPJP" as id_dokter
+										dkp."DPJP" as id_dokter,
+										dkp."NOMR" as "No_rm"
 									from data_kunjungan_pasien dkp 
 									left join daftar_lokasi_ruang dlr on dkp."Ruangan" = dlr.id 
 									left join data_pegawai dp on dkp."DPJP" = dp.id 
@@ -55,9 +56,9 @@ func InsertDataSuratKontrol(reqInsert *suratkontrol.DataSuratKontrol) error {
 	log.Println("Req Insert Database : ", reqInsert)
 	insertQuery := `insert into "data_surat_kontrol" ("id", "date_created", "Tanggal_cetak_surat_kontrol", "Tanggal_rencana_kontrol", 
 					"Nomor_surat_kontrol", "Kunjungan_pasien", "Ruangan_surat_kontrol", "DPJP_surat_kontrol", "Status_surat_kontrol", 
-					"User_created_surat_kontrol", "Tipe_surat_kontrol", "User_updated_surat_kontrol")
-					values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`
-	err := config.SatuDataDB.Debug().Exec(insertQuery,
+					"User_created_surat_kontrol", "Tipe_surat_kontrol", "User_updated_surat_kontrol", "Tipe_rawat")
+					values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`
+	err := config.SatuDataDB.Exec(insertQuery,
 		reqInsert.ID,
 		reqInsert.DateCreated,
 		reqInsert.TglCetakSurKon,
@@ -70,6 +71,7 @@ func InsertDataSuratKontrol(reqInsert *suratkontrol.DataSuratKontrol) error {
 		reqInsert.UserCreatedSurKon,
 		reqInsert.TipeSurKon,
 		reqInsert.UserUpdatedSurKon,
+		reqInsert.TipeRawat,
 	).Error
 	if err != nil {
 		log.Println(err)
@@ -78,9 +80,9 @@ func InsertDataSuratKontrol(reqInsert *suratkontrol.DataSuratKontrol) error {
 	return nil
 }
 
-func GetDataSuratKontrol() ([]*suratkontrol.GetDataSuratKontrol, error) {
+func GetDataSuratKontrol(offset, limit string) ([]*suratkontrol.GetDataSuratKontrol, error) {
 	var dataSurKon []*suratkontrol.GetDataSuratKontrol
-	err := config.SatuDataDB.Debug().Raw(`select dsk."id", dsk."Tanggal_cetak_surat_kontrol", dsk."Tanggal_rencana_kontrol",
+	err := config.SatuDataDB.Raw(`select dsk."id", dsk."Tanggal_cetak_surat_kontrol", dsk."Tanggal_rencana_kontrol",
 		dsk."Nomor_surat_kontrol", 
 		(select dlr."Nama"
 		from data_kunjungan_pasien dkp
@@ -103,6 +105,7 @@ func GetDataSuratKontrol() ([]*suratkontrol.GetDataSuratKontrol, error) {
 		ds."id" as "ID_poli",
 		dp."HFIS_code" as "Kode_dokter",
 		dp."id" as "id_dokter",
+		dp."Code_dpjp" as "Kode_dpjp",
 		dkp2."NOMR" as "No_rm",
 		dkp2."Diagnosis_primer_utama" as "Kode_diagnosa",
 		dkp2."Display_diagnosis_primer_utama" as "Nama_diagnosa",
@@ -113,23 +116,68 @@ func GetDataSuratKontrol() ([]*suratkontrol.GetDataSuratKontrol, error) {
 		left join data_pegawai dp on dsk."DPJP_surat_kontrol" = dp."id"
 		left join data_ktp dk on dp."KTP" = dk. "id"
 		left join daftar_subspesialis ds on dp."Subspesialis" = ds."id"
-		where dsk."Status_surat_kontrol" = '1'`).Scan(&dataSurKon).Error
+		where dsk."Status_surat_kontrol" = '1' offset ? limit ?`, offset, limit).Scan(&dataSurKon).Error
 	if err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			errMsg := errors.New("DPJP anda belum ada subspesialis")
 			log.Println(errMsg)
 			return nil, errMsg
 		}
-		log.Println(err)
-		return nil, err
 	}
-	log.Println("Data Surat Kontrol : ", dataSurKon)
+	return dataSurKon, nil
+}
+
+func GetDataSuratKontrolByIDTipe(idxdaftar string, tipe string) (*suratkontrol.GetDataSuratKontrol, error) {
+	var dataSurKon *suratkontrol.GetDataSuratKontrol
+	err := config.SatuDataDB.Raw(`select dsk."id", dsk."Tanggal_cetak_surat_kontrol", dsk."Tanggal_rencana_kontrol",
+		dsk."Nomor_surat_kontrol", 
+		(select dlr."Nama"
+		from data_kunjungan_pasien dkp
+		left join daftar_lokasi_ruang dlr on dkp."Ruangan" = dlr.id where dkp."id" = dsk."Kunjungan_pasien" LIMIT 1) as "Poli_asal", 
+		dlr."Nama" as "Poli_tuju",
+		dkp2."Nomor_sep", dkp2."Nama_lengkap", dkp2."IDXDAFTAR",
+		array(
+			select dgd. "Gelar_depan"
+			from data_pegawai_daftar_gelar_depan dpdgd
+			left join daftar_gelar_depan dgd on dpdgd.daftar_gelar_depan_id = dgd.id where dpdgd.data_pegawai_id = dp.id
+		) AS gelardepan ,
+		dk."Nama_lengkap" as "Nama_lengkap_dokter",
+		array(
+			select dgb. "Gelar_belakang"
+			from data_pegawai_daftar_gelar_belakang dpdgb
+			left join daftar_gelar_belakang dgb on dpdgb.daftar_gelar_belakang_id = dgb.id where dpdgb.data_pegawai_id = dp.id
+		) AS gelarbelakang,
+		ds."Subspesialis",
+		ds."Kode" as "Kode_poli",
+		ds."id" as "ID_poli",
+		dp."HFIS_code" as "Kode_dokter",
+		dp."id" as "id_dokter",
+		dp."Code_dpjp" as "Kode_dpjp",
+		dkp2."NOMR" as "No_rm",
+		dkp2."Diagnosis_primer_utama" as "Kode_diagnosa",
+		dkp2."Display_diagnosis_primer_utama" as "Nama_diagnosa",
+		dsk."Tipe_surat_kontrol" as "Tipe_SurKon",
+		dsk."User_created_surat_kontrol" as "User"
+		from data_surat_kontrol dsk
+		left join data_kunjungan_pasien dkp2 on dkp2."id" = dsk."Kunjungan_pasien"
+		left join daftar_lokasi_ruang dlr on dsk."Ruangan_surat_kontrol" = dlr."id"
+		left join data_pegawai dp on dsk."DPJP_surat_kontrol" = dp."id"
+		left join data_ktp dk on dp."KTP" = dk. "id"
+		left join daftar_subspesialis ds on dp."Subspesialis" = ds."id"
+		where dsk."Status_surat_kontrol" = '1' and dkp2."IDXDAFTAR" = ? and dsk."Tipe_rawat" = ?`, idxdaftar, tipe).First(&dataSurKon).Error
+	if err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			errMsg := errors.New("Data tidak ada")
+			log.Println(errMsg)
+			return nil, errMsg
+		}
+	}
 	return dataSurKon, nil
 }
 
 func GetDataSuratKontrolByID(idxdaftar string) (*suratkontrol.GetDataSuratKontrol, error) {
 	var dataSurKon *suratkontrol.GetDataSuratKontrol
-	err := config.SatuDataDB.Debug().Raw(`select dsk."id", dsk."Tanggal_cetak_surat_kontrol", dsk."Tanggal_rencana_kontrol",
+	err := config.SatuDataDB.Raw(`select dsk."id", dsk."Tanggal_cetak_surat_kontrol", dsk."Tanggal_rencana_kontrol",
 		dsk."Nomor_surat_kontrol", 
 		(select dlr."Nama"
 		from data_kunjungan_pasien dkp
@@ -152,41 +200,41 @@ func GetDataSuratKontrolByID(idxdaftar string) (*suratkontrol.GetDataSuratKontro
 		ds."id" as "ID_poli",
 		dp."HFIS_code" as "Kode_dokter",
 		dp."id" as "id_dokter",
+		dp."Code_dpjp" as "Kode_dpjp",
 		dkp2."NOMR" as "No_rm",
 		dkp2."Diagnosis_primer_utama" as "Kode_diagnosa",
 		dkp2."Display_diagnosis_primer_utama" as "Nama_diagnosa",
-		dsk."Tipe_surat_kontrol" as "Tipe_SurKon"
+		dsk."Tipe_surat_kontrol" as "Tipe_SurKon",
+		dsk."User_created_surat_kontrol" as "User"
 		from data_surat_kontrol dsk
 		left join data_kunjungan_pasien dkp2 on dkp2."id" = dsk."Kunjungan_pasien"
 		left join daftar_lokasi_ruang dlr on dsk."Ruangan_surat_kontrol" = dlr."id"
 		left join data_pegawai dp on dsk."DPJP_surat_kontrol" = dp."id"
 		left join data_ktp dk on dp."KTP" = dk. "id"
 		left join daftar_subspesialis ds on dp."Subspesialis" = ds."id"
-		where dsk."Status_surat_kontrol" = '1' and dkp2."IDXDAFTAR" = ?`, idxdaftar).First(&dataSurKon).Error
+		where dsk."Status_surat_kontrol" = '1' and dkp2."IDXDAFTAR" = ? and dsk."Tipe_rawat" is null`, idxdaftar).First(&dataSurKon).Error
 	if err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
-			errMsg := errors.New("DPJP anda belum ada subspesialis")
+			errMsg := errors.New("Data tidak ada")
 			log.Println(errMsg)
 			return nil, errMsg
 		}
-		log.Println(err)
-		return nil, err
 	}
-	log.Println("Data Surat Kontrol : ", dataSurKon)
 	return dataSurKon, nil
 }
 
 func UpdateDataSuratKontrol(reqUpdate *suratkontrol.DataSuratKontrol) error {
-	err := config.SatuDataDB.Debug().Exec(`update "data_surat_kontrol" set "date_updated" = ?, "Status_surat_kontrol" = ?, "User_updated_surat_kontrol" = ? where "id" = ?`, reqUpdate.DateUpdated, reqUpdate.StatusSurKon, reqUpdate.UserUpdatedSurKon, reqUpdate.ID).Error
+	err := config.SatuDataDB.Exec(`update "data_surat_kontrol" set "date_updated" = ?, "Status_surat_kontrol" = ?, "User_updated_surat_kontrol" = ? where "id" = ?`, reqUpdate.DateUpdated, reqUpdate.StatusSurKon, reqUpdate.UserUpdatedSurKon, reqUpdate.ID).Error
 	if err != nil {
 		log.Println(err)
 		return err
 	}
 	return nil
 }
+
 func GetIDXDaftarBySurKon(idSurKon string) (string, error) {
 	var idxDaftar string
-	err := config.SatuDataDB.Debug().Raw(`select dkp."IDXDAFTAR"
+	err := config.SatuDataDB.Raw(`select dkp."IDXDAFTAR"
 		from "data_surat_kontrol" dsk
 		left join "data_kunjungan_pasien" dkp on dkp."id" = dsk."Kunjungan_pasien"
 		where dsk."id" = ?`, idSurKon).First(&idxDaftar).Error
@@ -199,7 +247,7 @@ func GetIDXDaftarBySurKon(idSurKon string) (string, error) {
 
 func GetAllDataSuratKontrol(idSurKon string) (*suratkontrol.DataSuratKontrol, error) {
 	var dataSurKon *suratkontrol.DataSuratKontrol
-	err := config.SatuDataDB.Debug().Raw(`select * from "data_surat_kontrol" where "id" = ?`, idSurKon).First(&dataSurKon).Error
+	err := config.SatuDataDB.Raw(`select * from "data_surat_kontrol" where "id" = ?`, idSurKon).First(&dataSurKon).Error
 	if err != nil {
 		log.Println(err)
 		return nil, err
@@ -209,7 +257,7 @@ func GetAllDataSuratKontrol(idSurKon string) (*suratkontrol.DataSuratKontrol, er
 
 func SearchDataSurKon(req suratkontrol.RequestCariPasien, query string, args []interface{}) ([]*suratkontrol.GetDataSuratKontrol, error) {
 	var dataSurKon []*suratkontrol.GetDataSuratKontrol
-	query += ` and date(dsk."Tanggal_rencana_kontrol") between ? and ?`
+	query += ` and date(dsk."Tanggal_rencana_kontrol") between ? and ? offset ? limit ?`
 	querySelect := `select dsk."id", dsk."Tanggal_cetak_surat_kontrol", dsk."Tanggal_rencana_kontrol",
 		dsk."Nomor_surat_kontrol", 
 		(select dlr."Nama"
@@ -233,6 +281,7 @@ func SearchDataSurKon(req suratkontrol.RequestCariPasien, query string, args []i
 		ds."id" as "ID_poli",
 		dp."HFIS_code" as "Kode_dokter",
 		dp."id" as "id_dokter",
+		dp."Code_dpjp" as "Kode_dpjp",
 		dkp2."NOMR" as "No_rm",
 		dkp2."Diagnosis_primer_utama" as "Kode_diagnosa",
 		dkp2."Display_diagnosis_primer_utama" as "Nama_diagnosa",
@@ -243,13 +292,44 @@ func SearchDataSurKon(req suratkontrol.RequestCariPasien, query string, args []i
 		left join data_pegawai dp on dsk."DPJP_surat_kontrol" = dp."id"
 		left join data_ktp dk on dp."KTP" = dk. "id"
 		left join daftar_subspesialis ds on dp."Subspesialis" = ds."id"
-		where dsk."Status_surat_kontrol" = '1' `
+		where dsk."Status_surat_kontrol" = '1' and dsk."Tipe_surat_kontrol" = ? `
 	querySelect += query
-	err := config.SatuDataDB.Debug().Raw(querySelect, args...).Find(&dataSurKon).Error
+	err := config.SatuDataDB.Raw(querySelect, args...).Find(&dataSurKon).Error
 	if err != nil {
 		log.Println(err)
 		return nil, err
 	}
-	log.Println("Data Surat Kontrol : ", dataSurKon)
 	return dataSurKon, nil
 }
+
+func CountDataSurKon(req suratkontrol.RequestCariPasien, query string, args []interface{}) (int, error) {
+	var jumlahData int
+	query += ` and date(dsk."Tanggal_rencana_kontrol") between ? and ?`
+	querySelect := `select count(dsk.*)
+		from data_surat_kontrol dsk
+		left join data_kunjungan_pasien dkp2 on dkp2."id" = dsk."Kunjungan_pasien"
+		left join daftar_lokasi_ruang dlr on dsk."Ruangan_surat_kontrol" = dlr."id"
+		left join data_pegawai dp on dsk."DPJP_surat_kontrol" = dp."id"
+		left join data_ktp dk on dp."KTP" = dk. "id"
+		left join daftar_subspesialis ds on dp."Subspesialis" = ds."id"
+		where dsk."Status_surat_kontrol" = '1' and dsk."Tipe_surat_kontrol" = ? `
+	querySelect += query
+	err := config.SatuDataDB.Raw(querySelect, args...).Find(&jumlahData).Error
+	if err != nil {
+		log.Println(err)
+		return 0, err
+	}
+	return jumlahData, nil
+}
+
+func GetNomorSurKon(idPasien string) (string, error) {
+	var noSurKon string
+	querySelect := `select dsk."Nomor_surat_kontrol" from data_surat_kontrol dsk where dsk."Kunjungan_pasien" = ? and dsk."Tipe_surat_kontrol" <> '1' order by dsk."date_created"`
+	err := config.SatuDataDB.Raw(querySelect, idPasien).Scan(&noSurKon).Error
+	if err != nil {
+		log.Println(err)
+		return "", err
+	}
+	log.Println("Nomor SurKon :", noSurKon)
+	return noSurKon, nil
+}

docker-compose.yml

@@ -10,7 +10,11 @@ services:
       - 8080:8080
     volumes:
       - .:/app
+      - /etc/localtime:/etc/localtime:ro
+      - /etc/timezone:/etc/timezone:ro
     environment:
+    # TIMEZONE
+      - TZ=Asia/Jakarta
     # DATABASE SIMRS V3.0
       - POSTGRE_DB_HOST=10.10.123.223
       - POSTGRE_DB_PORT=5432
@@ -24,7 +28,7 @@ services:
       - SATUDATA_NAME=satu_db
       - SATUDATA_PORT=5000
     # BPJS
-      - BASEURL_BPJS=https://apijkn.bpjs-kesehatan.go.id
+      - BASEURL_BPJS=https://apijkn.bpjs-kesehatan.go.id/
       - CONS_ID=5257
       - USER_KEY=4cf1cbef8c008440bbe9ef9ba789e482
       - SECRET_KEY=1bV363512D

docker-push.sh

@@ -0,0 +1,27 @@
+!/bin/bash  
+
+#get image name
+remote_url=$(git remote get-url origin)
+image=$(echo $remote_url | sed 's|https://||g; s|.git||g')
+
+#get branch name 
+branch_name=$(git rev-parse --abbrev-ref HEAD)
+clean_branch_name=${branch_name##*/}
+
+#get timestamp for the tag  
+timestamp=$(date +%Y%m%d%H%M%S)  
+
+tag=$image:$timestamp-$clean_branch_name
+latest=$image:latest-$clean_branch_name
+
+#build image  
+docker build -t $tag .
+docker tag $tag $latest
+
+#push to dockerhub
+docker login git.rssa.top -u stim -p 4fde63b07906e7bfa6b3493d76d153a3981039b9
+docker push $tag
+docker push $latest
+
+#remove dangling images  
+docker system prune -f 

docs/utils/utils.go

@@ -1,7 +1,9 @@
 package utils
 
 import (
+	"fmt"
 	"log"
+	"strconv"
 	"strings"
 )
 
@@ -43,3 +45,17 @@ func ReplaceGelar(gelar string) string {
 	gelar = strings.ReplaceAll(gelar, ",", " ")
 	return gelar
 }
+
+func GetNoUrut(noSurKon string) (string, error) {
+	noSurKonSlice := strings.Split(noSurKon, "/")
+	noUrut := noSurKonSlice[3]
+	noUrutInt, err := strconv.Atoi(noUrut)
+	if err != nil {
+		return "", err
+	}
+
+	noUrutInt++
+	noUrutStr := fmt.Sprintf("%03d", noUrutInt)
+	log.Println("No Urut: ", noUrutStr)
+	return noUrutStr, nil
+}

go.mod

@@ -65,6 +65,7 @@ require (
 	github.com/google/uuid v1.6.0
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
+	github.com/robfig/cron/v3 v3.0.1
 	golang.org/x/text v0.18.0 // indirect
 	gorm.io/driver/postgres v1.5.9
 )

go.sum

@@ -96,6 +96,8 @@ github.com/pelletier/go-toml/v2 v2.2.3/go.mod h1:MfCQTFTvCcUyyvvwm1+G6H/jORL20Xl
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U=
 github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
+github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
 github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU5NdKM8=
 github.com/rogpeppe/go-internal v1.12.0/go.mod h1:E+RYuTGaKKdloAfM02xzb0FW3Paa99yedzYV+kq4uf4=
 github.com/rs/cors v1.11.1 h1:eU3gRzXLRK57F5rKMGMZURNdIG4EoAmX8k94r9wXWHA=

handlers/bpjs/i_care/i_care.go

@@ -0,0 +1,264 @@
+package icare
+
+import (
+	"bridging-rssa/database/satu_data/dokter"
+	log_api "bridging-rssa/database/satu_data/log_api"
+	"bridging-rssa/database/satu_data/pasien"
+	"bridging-rssa/models/config"
+	logapi "bridging-rssa/models/log_api"
+	"encoding/json"
+	"fmt"
+	"log"
+	"net/http"
+	"os"
+	"strconv"
+	"strings"
+	"time"
+
+	cfg "bridging-rssa/config"
+	ic "bridging-rssa/models/bpjs/i_care"
+
+	"github.com/gin-gonic/gin"
+	"github.com/google/uuid"
+)
+
+func GetFKRTL(c *gin.Context) {
+	baseUrl := os.Getenv("BASEURL_BPJS")
+	endpoint := os.Getenv("I_CARE_JKN")
+	param := os.Getenv("GET_FKRTL")
+	url := baseUrl + endpoint + param
+
+	log.Println("URL :", url)
+	var req *ic.ReqICare
+
+	err := c.Bind(&req)
+	if err != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+
+	reqICare := &ic.RequestICare{
+		Param:      req.Param,
+		KodeDokter: req.KodeDokter,
+	}
+
+	reqJson, errMarshal := json.Marshal(reqICare)
+	if errMarshal != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: errMarshal.Error(),
+		})
+		return
+	}
+
+	log.Println("REQUEST: ", string(reqJson))
+
+	conf := config.ConfigBpjs{}
+
+	icare := true
+	header := cfg.SetHeader(icare, conf)
+
+	headers := map[string]string{
+		"X-cons-id":    header.ConsID,
+		"X-timestamp":  header.TimeStamp,
+		"X-signature":  header.XSignature,
+		"user_key":     header.UserKey,
+		"Content-Type": "application/json",
+	}
+	log.Println("Headers : ", headers)
+
+	var headerStringBuilder strings.Builder
+	for key, value := range headers {
+		headerStringBuilder.WriteString(fmt.Sprintf("%s: %s; ", key, value))
+	}
+	headerString := strings.TrimSuffix(headerStringBuilder.String(), "; ")
+
+	dpjp := strconv.Itoa(req.KodeDokter)
+
+	dataDokter, err := dokter.GetHFISCode(dpjp)
+	if err != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+
+	reqICare.KodeDokter, err = strconv.Atoi(dataDokter.HfisCode)
+	if err != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+
+	kunjunganPasien, err := pasien.GetDataKunjunganPasien(req.IDXDaftar)
+	if err != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+
+	uuid := uuid.New().String()
+	logTimeStart := time.Now().Format("2006-01-02 15:04:05")
+	res, err := ResponseGetFKRTL(url, header, headers, reqICare)
+	if err != nil {
+		responJson, errMarshal2 := json.Marshal(res)
+		if errMarshal2 != nil {
+			log.Println(errMarshal2)
+			c.JSON(http.StatusInternalServerError, &ic.Metadata{
+				Code:    0,
+				Message: errMarshal2.Error(),
+			})
+			return
+		}
+		logTimeEnd := time.Now().Format("2006-01-02 15:04:05")
+		reqInsertLog := &logapi.DataLogAPI{
+			ID:              uuid,
+			DateCreated:     logTimeEnd,
+			UserAgent:       req.User,
+			IP:              c.ClientIP(),
+			Parameter:       "BPJS-ICare-FKRTL",
+			Header:          headerString,
+			Method:          "POST",
+			Url:             url,
+			Request:         reqJson,
+			Respon:          responJson,
+			ResponCode:      strconv.Itoa(res.MetaData.Code),
+			ResponTimeStart: logTimeStart,
+			ResponTimeEnd:   logTimeEnd,
+			Comment:         res.MetaData.Message,
+		}
+
+		errInsert := log_api.InsertLogAPI(reqInsertLog)
+		if errInsert != nil {
+			log.Println(errInsert)
+			c.JSON(http.StatusInternalServerError, &ic.Metadata{
+				Code:    0,
+				Message: errInsert.Error(),
+			})
+			return
+		}
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+	responJson, err := json.Marshal(res)
+	if err != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+	logTimeEnd := time.Now().Format("2006-01-02 15:04:05")
+	reqInsertLog := &logapi.DataLogAPI{
+		ID:              uuid,
+		DateCreated:     logTimeEnd,
+		UserAgent:       req.User,
+		IP:              c.ClientIP(),
+		Parameter:       "BPJS-ICare-FKRTL",
+		Header:          headerString,
+		Method:          "POST",
+		Url:             url,
+		Request:         reqJson,
+		Respon:          responJson,
+		ResponCode:      strconv.Itoa(res.MetaData.Code),
+		ResponTimeStart: logTimeStart,
+		ResponTimeEnd:   logTimeEnd,
+		Comment:         res.MetaData.Message,
+	}
+
+	err = log_api.InsertLogAPI(reqInsertLog)
+	if err != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+
+	reqInsert := &logapi.InsertLogICare{
+		ID:               uuid,
+		DateCreated:      logTimeEnd,
+		Ruangan:          kunjunganPasien.Ruangan,
+		Dokter:           dataDokter.ID,
+		Kunjungan_pasien: kunjunganPasien.ID,
+		WaktuTransaksi:   logTimeEnd,
+	}
+
+	errInsert := log_api.InsertLogICare(reqInsert)
+	if errInsert != nil {
+		log.Println(errInsert)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: errInsert.Error(),
+		})
+		return
+	}
+
+	c.JSON(http.StatusOK, res)
+}
+
+func GetFKTP(c *gin.Context) {
+	baseUrl := os.Getenv("BASEURL_BPJS")
+	endpoint := os.Getenv("I_CARE_JKN")
+	param := os.Getenv("GET_FKRTL")
+	url := baseUrl + endpoint + param
+
+	log.Println("URL :", url)
+	var req *ic.RequestICare
+
+	err := c.Bind(&req)
+	if err != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+
+	log.Println("REQUEST: ", req)
+
+	conf := config.ConfigBpjs{}
+
+	header := cfg.SetHeaderDev(conf)
+
+	headers := map[string]string{
+		"X-cons-id":    header.ConsID,
+		"X-timestamp":  header.TimeStamp,
+		"X-signature":  header.XSignature,
+		"user_key":     header.UserKey,
+		"Content-Type": "application/json",
+	}
+	log.Println("Headers : ", headers)
+
+	res, err := ResponseGetFKRTL(url, header, headers, req)
+	if err != nil {
+		log.Println(err)
+		c.JSON(http.StatusInternalServerError, &ic.Metadata{
+			Code:    0,
+			Message: err.Error(),
+		})
+		return
+	}
+
+	c.JSON(http.StatusOK, res)
+}

handlers/bpjs/i_care/response.go

@@ -0,0 +1,222 @@
+package icare
+
+import (
+	"bridging-rssa/docs"
+	ic "bridging-rssa/models/bpjs/i_care"
+	"bridging-rssa/models/config"
+	"bytes"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io"
+	"log"
+	"net/http"
+	"strings"
+	"time"
+)
+
+func ResponseGetFKRTL(url string, header *config.Header, headers map[string]string, request *ic.RequestICare) (*ic.ResponseGet, error) {
+	log.Println("URL", url)
+
+	reqMarshall, err := json.Marshal(request)
+	if err != nil {
+		log.Printf("Error json marshal: %v", err)
+	}
+
+	log.Println("REQUEST: ", string(reqMarshall))
+
+	req, err := http.NewRequest("POST", url, bytes.NewReader(reqMarshall))
+	if err != nil {
+		log.Printf("Error creating request: %v", err)
+		return nil, err
+	}
+	for key, value := range headers {
+		req.Header.Set(key, value)
+	}
+
+	log.Println("REQ", req.Header)
+	client := http.Client{
+		Timeout: 10 * time.Second,
+	}
+
+	responses := &ic.ResponseGet{}
+	response, err := client.Do(req)
+	if err != nil {
+		if strings.Contains(strings.ToLower(err.Error()), "deadline exceeded") {
+			errMsg := errors.New("Koneksi BPJS Terputus, Silahkan Coba Lagi")
+			log.Printf("error : %v", errMsg)
+			responses.MetaData.Message = errMsg.Error()
+			log.Println("responses: ", responses)
+			return responses, err
+		}
+		log.Printf("Error making external API request: %v", err)
+		return responses, err
+	}
+	log.Println("RESPONSE: ", response)
+
+	if response.StatusCode == http.StatusGatewayTimeout { // 504
+		errMsg := errors.New("Koneksi BPJS Terputus, Silahkan Coba Lagi")
+		log.Printf("error : %v", errMsg)
+		responses.MetaData.Code = 504
+		responses.MetaData.Message = errMsg.Error()
+		log.Println("responses: ", responses)
+		return responses, err
+	}
+
+	key := header.ConsID + header.SecretKey + header.TimeStamp
+	res, err := io.ReadAll(response.Body)
+	if err != nil {
+		fmt.Println(err)
+		return nil, err
+	}
+
+	log.Println("Res:", string(res))
+
+	var resFkrtlRaw ic.ResponseGetRaw
+	err = json.Unmarshal([]byte(string(res)), &resFkrtlRaw)
+	if err != nil {
+		log.Printf("Error Unmarshaling: %v", err)
+		return nil, err
+	}
+
+	log.Println("ResponseRaw : ", resFkrtlRaw)
+
+	if resFkrtlRaw.MetaData.Code != 200 {
+		errMsg := errors.New(resFkrtlRaw.MetaData.Message)
+		if strings.Contains(strings.ToLower(resFkrtlRaw.MetaData.Message), "Gagal simpan!") {
+			message := "Surat kontrol gagal diterbitkan, pastikan klinik tujuan sama dengan klinik asal pada rujukan awal"
+			resFkrtlRaw.MetaData.Message = message
+		}
+		log.Printf("error : %v", errMsg)
+		responses.MetaData.Code = resFkrtlRaw.MetaData.Code
+		responses.MetaData.Message = resFkrtlRaw.MetaData.Message
+		log.Println("responses: ", responses)
+		return responses, errMsg
+	}
+
+	dataResp, err := docs.StringDecrypt(key, resFkrtlRaw.Response)
+	if err != nil {
+		log.Printf("Error Decrypt: %v", err)
+		log.Println("res: ", dataResp)
+		return nil, err
+	}
+
+	var resFkrtl ic.Response
+
+	log.Println("dataresp: ", dataResp)
+
+	err = json.Unmarshal([]byte(dataResp), &resFkrtl)
+	if err != nil {
+		log.Printf("Error Decode: %v", err)
+		return nil, err
+	}
+
+	responses = &ic.ResponseGet{
+		Response: resFkrtl,
+		MetaData: resFkrtlRaw.MetaData,
+	}
+	return responses, nil
+}
+
+func ResponseGetFKTP(url string, header *config.Header, headers map[string]string, request *ic.ReqFKTP) (*ic.ResponseGet, error) {
+	log.Println("URL", url)
+
+	reqMarshall, err := json.Marshal(request)
+	if err != nil {
+		log.Printf("Error json marshal: %v", err)
+	}
+
+	log.Println("REQUEST: ", string(reqMarshall))
+
+	req, err := http.NewRequest("POST", url, bytes.NewReader(reqMarshall))
+	if err != nil {
+		log.Printf("Error creating request: %v", err)
+		return nil, err
+	}
+	for key, value := range headers {
+		req.Header.Set(key, value)
+	}
+
+	log.Println("REQ", req.Header)
+	client := http.Client{
+		Timeout: 10 * time.Second,
+	}
+
+	responses := &ic.ResponseGet{}
+	response, err := client.Do(req)
+	if err != nil {
+		if strings.Contains(strings.ToLower(err.Error()), "deadline exceeded") {
+			errMsg := errors.New("Koneksi BPJS Terputus, Silahkan Coba Lagi")
+			log.Printf("error : %v", errMsg)
+			responses.MetaData.Message = errMsg.Error()
+			log.Println("responses: ", responses)
+			return responses, err
+		}
+		log.Printf("Error making external API request: %v", err)
+		return responses, err
+	}
+	log.Println("RESPONSE: ", response)
+
+	if response.StatusCode == http.StatusGatewayTimeout { // 504
+		errMsg := errors.New("Koneksi BPJS Terputus, Silahkan Coba Lagi")
+		log.Printf("error : %v", errMsg)
+		responses.MetaData.Code = 504
+		responses.MetaData.Message = errMsg.Error()
+		log.Println("responses: ", responses)
+		return responses, err
+	}
+
+	key := header.ConsID + header.SecretKey + header.TimeStamp
+	res, err := io.ReadAll(response.Body)
+	if err != nil {
+		fmt.Println(err)
+		return nil, err
+	}
+
+	log.Println("Res:", string(res))
+
+	var resFkrtlRaw ic.ResponseGetRaw
+	err = json.Unmarshal([]byte(string(res)), &resFkrtlRaw)
+	if err != nil {
+		log.Printf("Error Unmarshaling: %v", err)
+		return nil, err
+	}
+
+	log.Println("ResponseRaw : ", resFkrtlRaw)
+
+	if resFkrtlRaw.MetaData.Code != 200 {
+		errMsg := errors.New(resFkrtlRaw.MetaData.Message)
+		if strings.Contains(strings.ToLower(resFkrtlRaw.MetaData.Message), "Gagal simpan!") {
+			message := "Surat kontrol gagal diterbitkan, pastikan klinik tujuan sama dengan klinik asal pada rujukan awal"
+			resFkrtlRaw.MetaData.Message = message
+		}
+		log.Printf("error : %v", errMsg)
+		responses.MetaData.Code = resFkrtlRaw.MetaData.Code
+		responses.MetaData.Message = resFkrtlRaw.MetaData.Message
+		log.Println("responses: ", responses)
+		return responses, errMsg
+	}
+
+	dataResp, err := docs.StringDecrypt(key, resFkrtlRaw.Response)
+	if err != nil {
+		log.Printf("Error Decrypt: %v", err)
+		log.Println("res: ", dataResp)
+		return nil, err
+	}
+
+	var resFkrtl ic.Response
+
+	log.Println("dataresp: ", dataResp)
+
+	err = json.Unmarshal([]byte(dataResp), &resFkrtl)
+	if err != nil {
+		log.Printf("Error Decode: %v", err)
+		return nil, err
+	}
+
+	responses = &ic.ResponseGet{
+		Response: resFkrtl,
+		MetaData: resFkrtlRaw.MetaData,
+	}
+	return responses, nil
+}

handlers/bpjs/jadwal_dokter/jadwal_dokter.go

@@ -1,331 +1,504 @@
-package jadwal_dokter
-
-import (
-	cfg "bridging-rssa/config"
-	"bridging-rssa/database/satu_data/dokter"
-	"bridging-rssa/docs/utils"
-	"bridging-rssa/models/bpjs/jadwal_dokter"
-	"bridging-rssa/models/config"
-	dktr "bridging-rssa/models/dokter"
-	"log"
-	"net/http"
-	"os"
-	"strconv"
-	"strings"
-	"time"
-
-	"github.com/gin-gonic/gin"
-)
-
-func GetJadwalDokter(c *gin.Context) {
-	baseUrl := os.Getenv("BASEURL_BPJS")
-	endpoint := os.Getenv("ANTREAN_RS")
-	url := baseUrl + endpoint
-
-	conf := config.ConfigBpjs{}
-
-	header := cfg.SetHeader(conf)
-
-	headers := map[string]string{
-		"X-cons-id":   header.ConsID,
-		"X-timestamp": header.TimeStamp,
-		"X-signature": header.XSignature,
-		"user_key":    header.UserKey,
-	}
-	log.Println("Headers : ", headers)
-
-	errTruncate := dokter.DeleteJadwalDokter()
-	if errTruncate != nil {
-		log.Fatal(errTruncate)
-		c.JSON(http.StatusInternalServerError, errTruncate)
-	}
-
-	errTruncateTemp := dokter.DeleteJadwalDokterTemp()
-	if errTruncateTemp != nil {
-		log.Fatal(errTruncateTemp)
-		c.JSON(http.StatusInternalServerError, errTruncateTemp)
-	}
-
-	// Select from daftar spesialis
-	spesialis, err := dokter.GetSpesialis()
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-
-	var listIdSpesialis = make(map[string]int)
-	for _, kodeDokter := range spesialis {
-		listIdSpesialis[kodeDokter.Kode] = kodeDokter.ID
-	}
-
-	subspesialis, err := dokter.GetSubspesialis()
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-
-	var listIdSubspesialis = make(map[string]int)
-	for _, kodeDokter := range subspesialis {
-		listIdSubspesialis[kodeDokter.Kode] = kodeDokter.ID
-	}
-
-	listDokter, err := dokter.GetDokter()
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-
-	var listIddokter = make(map[int]string)
-	for _, kodeDokter := range listDokter {
-		listIddokter[kodeDokter.HfisCode] = kodeDokter.ID
-	}
-
-	var reqInsert *jadwal_dokter.JadwalDokterSatuData
-	var res *[]jadwal_dokter.ListDokter
-
-	for _, value := range spesialis {
-		tanggal := time.Now().Format("2006-01-02")
-		for i := 0; i < 7; i++ {
-			kdPoly := value.Kode
-			res, err = JadwalDokterGetResponse(url, header, kdPoly, tanggal, headers)
-			if err != nil {
-				log.Fatalf("Error making external API request: %v", err)
-				c.JSON(http.StatusInternalServerError, err)
-			}
-			if res == nil {
-				log.Println("Skip Proses")
-				continue
-			}
-			for _, v := range *res {
-				idSpesialis := utils.KodeToIDConverter(v.KodePoli, listIdSpesialis)
-				idSubspesialis := utils.KodeToIDConverter(v.KodeSubspesialis, listIdSubspesialis)
-				idDokter := utils.HfisCodeToIDConverter(v.KodeDokter, listIddokter)
-				reqInsert = &jadwal_dokter.JadwalDokterSatuData{
-					Hari:         v.Hari,
-					NamaHari:     v.NamaHari,
-					Waktu:        v.Jadwal,
-					Dokter:       idDokter,
-					Spesialis:    idSpesialis,
-					SubSpesialis: idSubspesialis,
-					Status:       1, // When available always set to 1
-				}
-				if reqInsert.Dokter != "" {
-					errInsert := dokter.InsertJadwalDokter(reqInsert)
-					if errInsert != nil {
-						log.Println(errInsert)
-						c.JSON(http.StatusInternalServerError, errInsert)
-					}
-				} else {
-					reqInsert.Dokter = strconv.Itoa(v.KodeDokter)
-					errInsertTemp := dokter.InsertJadwalDokterTemp(reqInsert)
-					if errInsertTemp != nil {
-						log.Println(errInsertTemp)
-						c.JSON(http.StatusInternalServerError, errInsertTemp)
-					}
-				}
-			}
-			date, errParse := time.Parse("2006-01-02", tanggal)
-			if errParse != nil {
-				c.JSON(http.StatusInternalServerError, errParse)
-				return
-			}
-			tanggal = date.AddDate(0, 0, 1).Format("2006-01-02")
-			log.Println("Tanggal :", tanggal)
-		}
-	}
-	c.JSON(http.StatusOK, res)
-}
-
-func GetDokterByDPJP(c *gin.Context) {
-	dpjp := c.Param("dpjp")
-	idDokter, err := dokter.GetJadwalDokterByDPJP(dpjp)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-		return
-	}
-
-	listHari, err := dokter.GetJadwalHariDokterBySpesialis(idDokter)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-		return
-	}
-	log.Println("listHari: ", listHari)
-
-	var IDDokter []string
-	var idSubspesialis int
-	for _, v := range listHari {
-		IDDokter = append(IDDokter, v.Dokter)
-		idSubspesialis = v.SubSpesialis
-		break
-	}
-
-	namaDokter, err := dokter.GetNamaLengkapDokter(IDDokter)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-		return
-	}
-
-	listSubspesialis, err := dokter.GetSubspesialisByID(idSubspesialis)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-
-	var res *jadwal_dokter.ResponseListHari
-
-	for _, k := range namaDokter {
-		var jadwalDokter []jadwal_dokter.ListJadwalDokter
-		for _, key := range listHari {
-			jadwalDokter = append(jadwalDokter, jadwal_dokter.ListJadwalDokter{
-				NamaHari: key.NamaHari,
-				KodeHari: key.Hari,
-				Waktu:    key.Waktu,
-			})
-		}
-		gelarDepan := utils.ReplaceGelar(k.GelarDepan)
-		gelarBelakang := utils.ReplaceGelar(k.GelarBelakang)
-		namaLengkap := gelarDepan + " " + k.NamaLengkap + " " + gelarBelakang
-		namaLengkap = strings.TrimPrefix(namaLengkap, " ")
-		namaLengkap = strings.TrimSuffix(namaLengkap, " ")
-		hfisCode := strings.TrimSpace(k.HFISCode)
-		res = &jadwal_dokter.ResponseListHari{
-			IDSpesialis:    listSubspesialis.IDSpesialis,
-			Kode:           listSubspesialis.Kode,
-			Spesialis:      listSubspesialis.Spesialis,
-			Subspesialis:   listSubspesialis.Subspesialis,
-			IDSubspesialis: listSubspesialis.Kode,
-			NamaLengkap:    namaLengkap,
-			HFISCode:       hfisCode,
-			KodeDPJP:       dpjp,
-			JadwalDokter:   jadwalDokter,
-			IDDokter:       k.ID,
-		}
-	}
-	log.Println("Response :", res)
-	c.JSON(http.StatusOK, res)
-}
-
-func GetSpesialisByDate(c *gin.Context) {
-	tanggal := c.Param("tanggal")
-	date, err := time.Parse("2006-01-02", tanggal)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	hari := date.Local().Weekday().String()
-	hari = utils.ConvertDay(hari)
-	idSpesialis, err := dokter.GetJadwalDokterByDate(hari)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	listSpesialis, err := dokter.GetSpesialisByID(idSpesialis)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	c.JSON(http.StatusOK, listSpesialis)
-}
-
-func GetJadwalSubspesialisByDate(c *gin.Context) {
-	tanggal := c.Param("tanggal")
-	date, err := time.Parse("2006-01-02", tanggal)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-
-	log.Println("tanggal: ", tanggal)
-	hari := date.Local().Weekday().String()
-	hari = utils.ConvertDay(hari)
-	idsubspesialis, err := dokter.GetJadwalSubspesialisByDate(hari)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	listSpesialis, err := dokter.GetSubspesialisByIDBatch(idsubspesialis)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	c.JSON(http.StatusOK, listSpesialis)
-}
-
-func GetDokterBySpesialis(c *gin.Context) {
-	spesialis := c.Param("spesialis")
-	tanggal := c.Param("tanggal")
-	date, err := time.Parse("2006-01-02", tanggal)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	hari := date.Local().Weekday().String()
-	hari = utils.ConvertDay(hari)
-	idDokter, err := dokter.GetJadwalDokterBySpesialis(hari, spesialis)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	namaDokter, err := dokter.GetNamaLengkapDokter(idDokter)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	var resDokter []dktr.ResponseDokter
-	idSpesialis, err := strconv.Atoi(spesialis)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	for _, v := range namaDokter {
-		gelarDepan := utils.ReplaceGelar(v.GelarDepan)
-		gelarBelakang := utils.ReplaceGelar(v.GelarBelakang)
-		namaLengkap := gelarDepan + " " + v.NamaLengkap + " " + gelarBelakang
-		namaLengkap = strings.TrimPrefix(namaLengkap, " ")
-		namaLengkap = strings.TrimSuffix(namaLengkap, " ")
-		resDokter = append(resDokter, dktr.ResponseDokter{
-			ID:          v.ID,
-			NamaLengkap: namaLengkap,
-			Spesialis:   idSpesialis,
-			HFISCode:    v.HFISCode,
-		})
-	}
-	log.Println("Response :", resDokter)
-	c.JSON(http.StatusOK, resDokter)
-}
-
-func GetDokterBySubspesialis(c *gin.Context) {
-	subspesialis := c.Param("subspesialis")
-	tanggal := c.Param("tanggal")
-	date, err := time.Parse("2006-01-02", tanggal)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-
-	log.Println("subspesialis: ", subspesialis)
-	log.Println("tanggal: ", tanggal)
-
-	hari := date.Local().Weekday().String()
-	hari = utils.ConvertDay(hari)
-	idDokter, err := dokter.GetJadwalDokterBySubpesialis(hari, subspesialis)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	namaDokter, err := dokter.GetNamaLengkapDokter(idDokter)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-	var resDokter []dktr.ResponseDokterNew
-	idSubspesialis, err := strconv.Atoi(subspesialis)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-
-	listSubspesialis, err := dokter.GetSubspesialisByID(idSubspesialis)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, err)
-	}
-
-	for _, v := range namaDokter {
-		gelarDepan := utils.ReplaceGelar(v.GelarDepan)
-		gelarBelakang := utils.ReplaceGelar(v.GelarBelakang)
-		namaLengkap := gelarDepan + " " + v.NamaLengkap + " " + gelarBelakang
-		namaLengkap = strings.TrimPrefix(namaLengkap, " ")
-		namaLengkap = strings.TrimSuffix(namaLengkap, " ")
-		resDokter = append(resDokter, dktr.ResponseDokterNew{
-			ID:           v.ID,
-			NamaLengkap:  namaLengkap,
-			Subspesialis: idSubspesialis,
-			HFISCode:     v.HFISCode,
-			KodePoli:     listSubspesialis.Kode,
-		})
-	}
-	log.Println("Response :", resDokter)
-	c.JSON(http.StatusOK, resDokter)
-}
+package jadwal_dokter
+
+import (
+	cfg "bridging-rssa/config"
+	"bridging-rssa/database/satu_data/dokter"
+	log_api "bridging-rssa/database/satu_data/log_api"
+	"bridging-rssa/docs/utils"
+	"bridging-rssa/models/bpjs/jadwal_dokter"
+	"bridging-rssa/models/config"
+	dktr "bridging-rssa/models/dokter"
+	logapi "bridging-rssa/models/log_api"
+	"encoding/json"
+	"fmt"
+	"github.com/google/uuid"
+	"gorm.io/gorm"
+	"log"
+	"net/http"
+	"os"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/gin-gonic/gin"
+)
+
+func GetJadwalDokter() bool {
+	baseUrl := os.Getenv("BASEURL_BPJS")
+	endpoint := os.Getenv("ANTREAN_RS")
+	url := baseUrl + endpoint
+	conf := config.ConfigBpjs{}
+
+	header := cfg.SetHeader(false, conf)
+
+	headers := map[string]string{
+		"X-cons-id":   header.ConsID,
+		"X-timestamp": header.TimeStamp,
+		"X-signature": header.XSignature,
+		"user_key":    header.UserKey,
+	}
+
+	errTruncate := dokter.DeleteJadwalDokter()
+	if errTruncate != nil {
+		log.Println(errTruncate)
+		return false
+	}
+
+	errTruncateTemp := dokter.DeleteJadwalDokterTemp()
+	if errTruncateTemp != nil {
+		log.Println(errTruncateTemp)
+		return false
+	}
+
+	// Select from daftar spesialis
+	spesialis, err := dokter.GetSpesialis()
+	if err != nil {
+		return false
+	}
+
+	var listIdSpesialis = make(map[string]int)
+	for _, kodeDokter := range spesialis {
+		listIdSpesialis[kodeDokter.Kode] = kodeDokter.ID
+	}
+
+	subspesialis, err := dokter.GetSubspesialis()
+	if err != nil {
+		return false
+	}
+
+	var listIdSubspesialis = make(map[string]int)
+	for _, kodeDokter := range subspesialis {
+		listIdSubspesialis[kodeDokter.Kode] = kodeDokter.ID
+	}
+
+	listDokter, err := dokter.GetDokter()
+	if err != nil {
+		return false
+	}
+
+	var listIddokter = make(map[int]string)
+	for _, kodeDokter := range listDokter {
+		listIddokter[kodeDokter.HfisCode] = kodeDokter.ID
+	}
+
+	var reqInsert *jadwal_dokter.JadwalDokterSatuData
+
+	for _, value := range spesialis {
+		tanggal := time.Now().Format("2006-01-02")
+		for i := 0; i < 7; i++ {
+			kdPoly := value.Kode
+			res, err := JadwalDokterGetResponse(url, header, kdPoly, tanggal, headers)
+			if err != nil {
+				log.Println("Error making external API request: %v", err)
+				return false
+			}
+			date, errParse := time.Parse("2006-01-02", tanggal)
+			if errParse != nil {
+				return false
+			}
+			tanggal = date.AddDate(0, 0, 1).Format("2006-01-02")
+			log.Println("Tanggal :", tanggal)
+			if res == nil {
+				log.Println("Skip Proses")
+				continue
+			}
+			for _, v := range res.Response {
+				idSpesialis := utils.KodeToIDConverter(v.KodePoli, listIdSpesialis)
+				idSubspesialis := utils.KodeToIDConverter(v.KodeSubspesialis, listIdSubspesialis)
+				idDokter := utils.HfisCodeToIDConverter(v.KodeDokter, listIddokter)
+				reqInsert = &jadwal_dokter.JadwalDokterSatuData{
+					Hari:         v.Hari,
+					NamaHari:     v.NamaHari,
+					Waktu:        v.Jadwal,
+					Dokter:       idDokter,
+					Spesialis:    idSpesialis,
+					SubSpesialis: idSubspesialis,
+					Status:       1, // When available always set to 1
+				}
+				if reqInsert.Dokter != "" {
+					errInsert := dokter.InsertJadwalDokter(reqInsert)
+					if errInsert != nil {
+						log.Println(errInsert)
+						return false
+					}
+				} else {
+					reqInsert.Dokter = strconv.Itoa(v.KodeDokter)
+					errInsertTemp := dokter.InsertJadwalDokterTemp(reqInsert)
+					if errInsertTemp != nil {
+						log.Println(errInsertTemp)
+						return false
+					}
+				}
+			}
+		}
+	}
+	return true
+}
+
+func GetDokterByDPJP(c *gin.Context) {
+	dpjp := c.Param("dpjp")
+	idDokter, err := dokter.GetJadwalDokterByDPJP(dpjp)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+		return
+	}
+
+	listHari, err := dokter.GetJadwalHariDokterBySpesialis(idDokter)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+		return
+	}
+
+	var IDDokter []string
+	var idSubspesialis int
+	for _, v := range listHari {
+		IDDokter = append(IDDokter, v.Dokter)
+		idSubspesialis = v.SubSpesialis
+		break
+	}
+
+	namaDokter, err := dokter.GetNamaLengkapDokter(IDDokter)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+		return
+	}
+
+	listSubspesialis, err := dokter.GetSubspesialisByID(idSubspesialis)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+
+	var res *jadwal_dokter.ResponseListHari
+
+	for _, k := range namaDokter {
+		var jadwalDokter []jadwal_dokter.ListJadwalDokter
+		for _, key := range listHari {
+			jadwalDokter = append(jadwalDokter, jadwal_dokter.ListJadwalDokter{
+				NamaHari: key.NamaHari,
+				KodeHari: key.Hari,
+				Waktu:    key.Waktu,
+			})
+		}
+		gelarDepan := utils.ReplaceGelar(k.GelarDepan)
+		gelarBelakang := utils.ReplaceGelar(k.GelarBelakang)
+		namaLengkap := gelarDepan + " " + k.NamaLengkap + " " + gelarBelakang
+		namaLengkap = strings.TrimPrefix(namaLengkap, " ")
+		namaLengkap = strings.TrimSuffix(namaLengkap, " ")
+		hfisCode := strings.TrimSpace(k.HFISCode)
+		res = &jadwal_dokter.ResponseListHari{
+			IDSpesialis:    listSubspesialis.IDSpesialis,
+			Kode:           listSubspesialis.Kode,
+			Spesialis:      listSubspesialis.Spesialis,
+			Subspesialis:   listSubspesialis.Subspesialis,
+			IDSubspesialis: listSubspesialis.ID,
+			NamaLengkap:    namaLengkap,
+			HFISCode:       hfisCode,
+			KodeDPJP:       dpjp,
+			JadwalDokter:   jadwalDokter,
+			IDDokter:       k.ID,
+		}
+	}
+	log.Println("Response :", res)
+	c.JSON(http.StatusOK, res)
+}
+
+func GetSpesialisByDate(c *gin.Context) {
+	tanggal := c.Param("tanggal")
+	date, err := time.Parse("2006-01-02", tanggal)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	hari := date.Local().Weekday().String()
+	hari = utils.ConvertDay(hari)
+	idSpesialis, err := dokter.GetJadwalDokterByDate(hari)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	listSpesialis, err := dokter.GetSpesialisByID(idSpesialis)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	c.JSON(http.StatusOK, listSpesialis)
+}
+
+func GetJadwalSubspesialisByDate(c *gin.Context) {
+	tanggal := c.Param("tanggal")
+	date, err := time.Parse("2006-01-02", tanggal)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+
+	log.Println("tanggal: ", tanggal)
+	hari := date.Local().Weekday().String()
+	hari = utils.ConvertDay(hari)
+	idsubspesialis, err := dokter.GetJadwalSubspesialisByDate(hari)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	listSpesialis, err := dokter.GetSubspesialisByIDBatch(idsubspesialis)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	c.JSON(http.StatusOK, listSpesialis)
+}
+
+func GetDokterBySpesialis(c *gin.Context) {
+	spesialis := c.Param("spesialis")
+	tanggal := c.Param("tanggal")
+	date, err := time.Parse("2006-01-02", tanggal)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	hari := date.Local().Weekday().String()
+	hari = utils.ConvertDay(hari)
+	idDokter, err := dokter.GetJadwalDokterBySpesialis(hari, spesialis)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	namaDokter, err := dokter.GetNamaLengkapDokter(idDokter)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	var resDokter []dktr.ResponseDokter
+	idSpesialis, err := strconv.Atoi(spesialis)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	for _, v := range namaDokter {
+		gelarDepan := utils.ReplaceGelar(v.GelarDepan)
+		gelarBelakang := utils.ReplaceGelar(v.GelarBelakang)
+		namaLengkap := gelarDepan + " " + v.NamaLengkap + " " + gelarBelakang
+		namaLengkap = strings.TrimPrefix(namaLengkap, " ")
+		namaLengkap = strings.TrimSuffix(namaLengkap, " ")
+		resDokter = append(resDokter, dktr.ResponseDokter{
+			ID:          v.ID,
+			NamaLengkap: namaLengkap,
+			Spesialis:   idSpesialis,
+			HFISCode:    v.HFISCode,
+		})
+	}
+	log.Println("Response :", resDokter)
+	c.JSON(http.StatusOK, resDokter)
+}
+
+func GetDokterBySubspesialis(c *gin.Context) {
+	subspesialis := c.Param("subspesialis")
+	tanggal := c.Param("tanggal")
+	date, err := time.Parse("2006-01-02", tanggal)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+
+	log.Println("subspesialis: ", subspesialis)
+	log.Println("tanggal: ", tanggal)
+
+	hari := date.Local().Weekday().String()
+	hari = utils.ConvertDay(hari)
+	idDokter, err := dokter.GetJadwalDokterBySubpesialis(hari, subspesialis)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	namaDokter, err := dokter.GetNamaLengkapDokter(idDokter)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+	var resDokter []dktr.ResponseDokterNew
+	idSubspesialis, err := strconv.Atoi(subspesialis)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+
+	listSubspesialis, err := dokter.GetSubspesialisByID(idSubspesialis)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err)
+	}
+
+	for _, v := range namaDokter {
+		gelarDepan := utils.ReplaceGelar(v.GelarDepan)
+		gelarBelakang := utils.ReplaceGelar(v.GelarBelakang)
+		namaLengkap := gelarDepan + " " + v.NamaLengkap + " " + gelarBelakang
+		namaLengkap = strings.TrimPrefix(namaLengkap, " ")
+		namaLengkap = strings.TrimSuffix(namaLengkap, " ")
+		resDokter = append(resDokter, dktr.ResponseDokterNew{
+			ID:           v.ID,
+			NamaLengkap:  namaLengkap,
+			Subspesialis: idSubspesialis,
+			HFISCode:     v.HFISCode,
+			KodePoli:     listSubspesialis.Kode,
+			DPJPCode:     v.DPJPCode,
+		})
+	}
+	log.Println("Response :", resDokter)
+	c.JSON(http.StatusOK, resDokter)
+}
+
+func GetDataJadwalDokter() bool {
+	baseUrl := os.Getenv("BASEURL_BPJS")
+	endpoint := os.Getenv("ANTREAN_RS")
+
+	url := baseUrl + endpoint
+	log.Println("url", url)
+	conf := config.ConfigBpjs{}
+
+	spesialis, err := dokter.GetSpesialis()
+	if err != nil {
+		log.Println("Error getting spesialis", err)
+		return false
+	}
+
+	var listIdSpesialis = make(map[string]int)
+	for _, kodeDokter := range spesialis {
+		listIdSpesialis[kodeDokter.Kode] = kodeDokter.ID
+	}
+
+	subspesialis, err := dokter.GetSubspesialis()
+	if err != nil {
+		log.Println("Error getting subspesialis", err)
+		return false
+	}
+
+	var listIdSubspesialis = make(map[string]int)
+	for _, kodeDokter := range subspesialis {
+		listIdSubspesialis[kodeDokter.Kode] = kodeDokter.ID
+	}
+
+	listDokter, err := dokter.GetDokter()
+	if err != nil {
+		log.Println("Error getting dokter", err)
+		return false
+	}
+
+	var listIddokter = make(map[int]string)
+	for _, kodeDokter := range listDokter {
+		listIddokter[kodeDokter.HfisCode] = kodeDokter.ID
+	}
+	db := cfg.SatuDataDB
+	errTx := db.Transaction(func(tx *gorm.DB) error {
+		errTruncate := dokter.TruncateDataJadwalDokter()
+		if errTruncate != nil {
+			log.Println(errTruncate)
+			return errTruncate
+		}
+		for _, value := range spesialis {
+			url := baseUrl + endpoint + "/jadwaldokter/kodepoli/" + value.Kode
+
+			header := cfg.SetHeader(false, conf)
+
+			headers := map[string]string{
+				"X-cons-id":   header.ConsID,
+				"X-timestamp": header.TimeStamp,
+				"X-signature": header.XSignature,
+				"user_key":    header.UserKey,
+			}
+
+			log.Println("Headers : ", headers)
+			var headerStringBuilder strings.Builder
+			for key, value := range headers {
+				headerStringBuilder.WriteString(fmt.Sprintf("%s: %s; ", key, value))
+			}
+			headerString := strings.TrimSuffix(headerStringBuilder.String(), "; ")
+
+			startDate := time.Now()
+			endDate := startDate.AddDate(0, 1, 0)
+			logTimeStart := time.Now().Format("2006-01-02 15:04:05")
+			var res *jadwal_dokter.JadwalDokter
+			var reqLog []*jadwal_dokter.RequestJadwalDokter
+			var resLog []*jadwal_dokter.JadwalDokter
+
+			for current := startDate; current.Before(endDate); current = current.AddDate(0, 0, 1) {
+				tanggal := current.Format("2006-01-02")
+				log.Println("Tanggal :", tanggal)
+				urlReq := url + "/tanggal/" + tanggal
+
+				res, err = JadwalDokterGetResponse(urlReq, header, value.Kode, tanggal, headers)
+				if err != nil {
+					log.Printf("Error making external API request: %v", err)
+					return err
+				}
+
+				reqLog = append(reqLog, &jadwal_dokter.RequestJadwalDokter{
+					KodePoli: value.Kode,
+					Tanggal:  tanggal,
+				})
+
+				resLog = append(resLog, &jadwal_dokter.JadwalDokter{
+					Response: res.Response,
+					MetaData: res.MetaData,
+				})
+
+				if res.MetaData.Code != 200 {
+					resLog = append(resLog, &jadwal_dokter.JadwalDokter{
+						Response: res.Response,
+						MetaData: res.MetaData,
+					})
+					continue
+				}
+
+				for _, v := range res.Response {
+					idSpesialis := utils.KodeToIDConverter(v.KodePoli, listIdSpesialis)
+					idSubspesialis := utils.KodeToIDConverter(v.KodeSubspesialis, listIdSubspesialis)
+					idDokter := utils.HfisCodeToIDConverter(v.KodeDokter, listIddokter)
+					reqInsert := &jadwal_dokter.DataJadwalDokterSatuData{
+						ID:            uuid.NewString(),
+						DateCreated:   logTimeStart,
+						Hari:          strconv.Itoa(v.Hari),
+						NamaHari:      v.NamaHari,
+						Waktu:         v.Jadwal,
+						Dokter:        idDokter,
+						Spesialis:     idSpesialis,
+						SubSpesialis:  idSubspesialis,
+						TanggalJadwal: tanggal,
+					}
+					if reqInsert.Dokter != "" {
+						errInsert := dokter.InsertDataJadwalDokter(tx, reqInsert)
+						if errInsert != nil {
+							log.Println(errInsert)
+							return errInsert
+						}
+					} else {
+						log.Println("Dokter tidak punya HFIS")
+						continue
+					}
+				}
+			}
+
+			reqLogJson, errMarshal := json.Marshal(reqLog)
+			if errMarshal != nil {
+				log.Println(errMarshal)
+				return errMarshal
+			}
+			resLogJson, errMarshal2 := json.Marshal(resLog)
+			if errMarshal2 != nil {
+				log.Println(errMarshal2)
+				return errMarshal2
+			}
+			logTimeEnd := time.Now().Format("2006-01-02 15:04:05")
+			reqLogApi := &logapi.DataLogAPI{
+				ID:              uuid.NewString(),
+				DateCreated:     logTimeEnd,
+				Parameter:       "BPJS-AntreanRS-JadwalDokter",
+				Header:          headerString,
+				Method:          "GET",
+				Url:             url,
+				Request:         reqLogJson,
+				Respon:          resLogJson,
+				ResponCode:      strconv.Itoa(res.MetaData.Code),
+				ResponTimeStart: logTimeStart,
+				ResponTimeEnd:   logTimeEnd,
+				Comment:         res.MetaData.Message,
+			}
+			errLog := log_api.InsertLogAPI(reqLogApi)
+			if errLog != nil {
+				log.Printf("Error making external API request: %v", err)
+				return errLog
+			}
+		}
+		return nil
+	})
+	if errTx != nil {
+		log.Println(errTx)
+		return false
+	}
+	log.Println("Berhasil ambil jadwal data dokter")
+	return true
+}

handlers/bpjs/jadwal_dokter/response.go

@@ -1,69 +1,74 @@
-package jadwal_dokter
-
-import (
-	"bridging-rssa/docs"
-	"bridging-rssa/models/bpjs/jadwal_dokter"
-	"bridging-rssa/models/config"
-	"encoding/json"
-	"fmt"
-	"io"
-	"log"
-	"net/http"
-)
-
-func JadwalDokterGetResponse(url string, header *config.Header, kdPoly string, tanggal string, headers map[string]string) (*[]jadwal_dokter.ListDokter, error) {
-	param := "/jadwaldokter/kodepoli/" + kdPoly + "/tanggal/" + tanggal
-	url += param
-	log.Println("URL", url)
-	req, err := http.NewRequest("GET", url, nil)
-	if err != nil {
-		log.Printf("Error creating request: %v", err)
-	}
-
-	for key, value := range headers {
-		req.Header.Set(key, value)
-	}
-
-	log.Println("REQ", req.Header)
-	client := http.Client{}
-	response, err := client.Do(req)
-	if err != nil {
-		log.Printf("Error making external API request: %v", err)
-	}
-	log.Println("RESPONSE: ", response)
-
-	key := header.ConsID + header.SecretKey + header.TimeStamp
-	res, err := io.ReadAll(response.Body)
-	if err != nil {
-		fmt.Println(err)
-	}
-
-	var jadwalDokterRaw jadwal_dokter.JadwalDokterRaw
-	err = json.Unmarshal([]byte(res), &jadwalDokterRaw)
-	if err != nil {
-		log.Printf("Error Unmarshaling: %v", err)
-	}
-
-	if jadwalDokterRaw.MetaData.Code == 201 {
-		log.Println("No Data Found")
-		return nil, nil
-	}
-
-	dataResp, err := docs.StringDecrypt(key, jadwalDokterRaw.Response)
-	if err != nil {
-		log.Printf("Error Decrypt: %v", err)
-	}
-
-	var listDokter []jadwal_dokter.ListDokter
-
-	log.Println("dataresp: ", dataResp)
-
-	err = json.Unmarshal([]byte(dataResp), &listDokter)
-	if err != nil {
-		log.Printf("Error Decode: %v", err)
-	}
-
-	log.Println("res: ", &listDokter)
-
-	return &listDokter, nil
-}
+package jadwal_dokter
+
+import (
+	"bridging-rssa/docs"
+	"bridging-rssa/models/bpjs/jadwal_dokter"
+	"bridging-rssa/models/config"
+	"encoding/json"
+	"fmt"
+	"io"
+	"log"
+	"net/http"
+)
+
+func JadwalDokterGetResponse(url string, header *config.Header, kdPoly string, tanggal string, headers map[string]string) (*jadwal_dokter.JadwalDokter, error) {
+	log.Println("URL", url)
+	req, err := http.NewRequest("GET", url, nil)
+	if err != nil {
+		log.Printf("Error creating request: %v", err)
+	}
+
+	for key, value := range headers {
+		req.Header.Set(key, value)
+	}
+
+	log.Println("REQ", req.Header)
+	client := http.Client{}
+	response, err := client.Do(req)
+	if err != nil {
+		log.Printf("Error making external API request: %v", err)
+	}
+	log.Println("RESPONSE: ", response)
+
+	key := header.ConsID + header.SecretKey + header.TimeStamp
+	res, err := io.ReadAll(response.Body)
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	var jadwalDokterRaw jadwal_dokter.JadwalDokterRaw
+	err = json.Unmarshal([]byte(res), &jadwalDokterRaw)
+	if err != nil {
+		log.Printf("Error Unmarshaling: %v", err)
+	}
+
+	responses := &jadwal_dokter.JadwalDokter{}
+	if jadwalDokterRaw.MetaData.Code != 200 {
+		responses.MetaData.Code = jadwalDokterRaw.MetaData.Code
+		responses.MetaData.Message = jadwalDokterRaw.MetaData.Message
+		log.Println("No Data Found")
+		return responses, nil
+	}
+
+	dataResp, err := docs.StringDecrypt(key, jadwalDokterRaw.Response)
+	if err != nil {
+		log.Printf("Error Decrypt: %v", err)
+	}
+
+	var listDokter []*jadwal_dokter.ListDokter
+
+	log.Println("dataresp: ", dataResp)
+
+	err = json.Unmarshal([]byte(dataResp), &listDokter)
+	if err != nil {
+		log.Printf("Error Decode: %v", err)
+	}
+
+	log.Println("res: ", &listDokter)
+	responses = &jadwal_dokter.JadwalDokter{
+		Response: listDokter,
+		MetaData: jadwalDokterRaw.MetaData,
+	}
+
+	return responses, nil
+}

handlers/bpjs/surat_kontrol/response.go

@@ -12,7 +12,6 @@ import (
 	"log"
 	"net/http"
 	"strings"
-	"time"
 )
 
 func PostData(url string, header *config.Header, headers map[string]string, request *suratkontrol.RequestHeaderRencanaKontrol) (*suratkontrol.Response, error) {
@@ -37,13 +36,27 @@ func PostData(url string, header *config.Header, headers map[string]string, requ
 
 	log.Println("REQ", req.Header)
 	client := http.Client{}
+
+	responses := &suratkontrol.Response{}
 	response, err := client.Do(req)
 	if err != nil {
+		responses.MetaData.Code = "203"
+		responses.MetaData.Message = err.Error()
 		log.Printf("Error making external API request: %v", err)
-		return nil, err
+		log.Println("responses: ", responses)
+		return responses, err
 	}
 	log.Println("RESPONSE: ", response)
 
+	if response.StatusCode == http.StatusGatewayTimeout { // 504
+		errMsg := errors.New("Koneksi BPJS Terputus, Silahkan Coba Lagi")
+		log.Printf("error : %v", errMsg)
+		responses.MetaData.Code = "504"
+		responses.MetaData.Message = errMsg.Error()
+		log.Println("responses: ", responses)
+		return responses, errMsg
+	}
+
 	key := header.ConsID + header.SecretKey + header.TimeStamp
 	res, err := io.ReadAll(response.Body)
 	if err != nil {
@@ -62,12 +75,19 @@ func PostData(url string, header *config.Header, headers map[string]string, requ
 
 	log.Println("ResponseRaw : ", resSuratKontrolRaw)
 
-	responses := &suratkontrol.Response{}
 	if resSuratKontrolRaw.MetaData.Code != "200" {
-		errMsg := errors.New(resSuratKontrolRaw.MetaData.Message)
-		log.Printf("error : %v", errMsg)
+		if resSuratKontrolRaw.MetaData.Message == "Gagal simpan! Nomor SEP Sudah pernah digunakan!." {
+			message := "Gagal simpan! Nomor SEP pernah diterbitkan Surat Kontrol!."
+			resSuratKontrolRaw.MetaData.Message = message
+			log.Println("masuk sini kan")
+		} else if resSuratKontrolRaw.MetaData.Message == "Gagal simpan! Poli Tujuan Kontrol tidak sama dengan Poli Asal Rujukan Awal." {
+			message := "Surat kontrol gagal diterbitkan, pastikan klinik tujuan sama dengan klinik asal pada rujukan awal"
+			resSuratKontrolRaw.MetaData.Message = message
+		}
+		log.Printf("error : %v", resSuratKontrolRaw.MetaData.Message)
 		responses.MetaData.Code = resSuratKontrolRaw.MetaData.Code
 		responses.MetaData.Message = resSuratKontrolRaw.MetaData.Message
+		errMsg := errors.New(resSuratKontrolRaw.MetaData.Message)
 		log.Println("responses: ", responses)
 		return responses, errMsg
 	}
@@ -118,26 +138,20 @@ func ResponseUpdateSuratKontrol(url string, header *config.Header, headers map[s
 	}
 
 	log.Println("REQ", req.Header)
-	client := http.Client{
-		Timeout: 10 * time.Second,
-	}
+	client := http.Client{}
 	responses := &suratkontrol.Response{}
 	response, err := client.Do(req)
 	if err != nil {
-		if strings.Contains(strings.ToLower(err.Error()), "deadline exceeded") {
-			errMsg := errors.New("Gagal Proses Selama 10 Detik, Silahkan Coba Lagi")
-			log.Printf("error : %v", errMsg)
-			responses.MetaData.Message = errMsg.Error()
-			log.Println("responses: ", responses)
-			return responses, err
-		}
+		responses.MetaData.Code = "504"
+		responses.MetaData.Message = err.Error()
+		log.Println("responses: ", responses)
 		log.Printf("Error making external API request: %v", err)
 		return responses, err
 	}
 	log.Println("RESPONSE: ", response)
 
 	if response.StatusCode == http.StatusGatewayTimeout { // 504
-		errMsg := errors.New("Gagal Proses Selama 10 Detik, Silahkan Coba Lagi")
+		errMsg := errors.New("Koneksi BPJS Terputus, Silahkan Coba Lagi")
 		log.Printf("error : %v", errMsg)
 		responses.MetaData.Code = "504"
 		responses.MetaData.Message = errMsg.Error()
@@ -162,10 +176,18 @@ func ResponseUpdateSuratKontrol(url string, header *config.Header, headers map[s
 	}
 
 	if resSuratKontrolRaw.MetaData.Code != "200" {
-		errMsg := errors.New(resSuratKontrolRaw.MetaData.Message)
-		log.Printf("error : %v", errMsg)
+		if resSuratKontrolRaw.MetaData.Message == "Gagal simpan! Nomor SEP Sudah pernah digunakan!." {
+			message := "Gagal simpan! Nomor SEP pernah diterbitkan Surat Kontrol!."
+			resSuratKontrolRaw.MetaData.Message = message
+			log.Println("masuk sini kan")
+		} else if strings.Contains(strings.ToLower(resSuratKontrolRaw.MetaData.Message), "gagal simpan") {
+			message := "Surat kontrol gagal diterbitkan, pastikan klinik tujuan sama dengan klinik asal pada rujukan awal"
+			resSuratKontrolRaw.MetaData.Message = message
+		}
+		log.Printf("error : %v", resSuratKontrolRaw.MetaData.Message)
 		responses.MetaData.Code = resSuratKontrolRaw.MetaData.Code
 		responses.MetaData.Message = resSuratKontrolRaw.MetaData.Message
+		errMsg := errors.New(resSuratKontrolRaw.MetaData.Message)
 		log.Println("responses: ", responses)
 		return responses, errMsg
 	}
@@ -237,7 +259,17 @@ func ResponseDeleteSuratKontrol(url string, header *config.Header, headers map[s
 		return nil, err
 	}
 
-	responses := &suratkontrol.Response{
+	responses := &suratkontrol.Response{}
+	if resSuratKontrolRaw.MetaData.Code != "200" {
+		errMsg := errors.New(resSuratKontrolRaw.MetaData.Message)
+		log.Printf("error : %v", errMsg)
+		responses.MetaData.Code = resSuratKontrolRaw.MetaData.Code
+		responses.MetaData.Message = resSuratKontrolRaw.MetaData.Message
+		log.Println("responses: ", responses)
+		return responses, errMsg
+	}
+
+	responses = &suratkontrol.Response{
 		MetaData: resSuratKontrolRaw.MetaData,
 	}
 
@@ -280,6 +312,16 @@ func ResponseGetNomorSuratKontrol(url string, header *config.Header, headers map
 		return nil, err
 	}
 
+	responses := &suratkontrol.ResponseGetSuratKontrol{}
+	if resNoSuratKontrolRaw.MetaData.Code != "200" {
+		errMsg := errors.New(resNoSuratKontrolRaw.MetaData.Message)
+		log.Printf("error : %v", errMsg)
+		responses.MetaData.Code = resNoSuratKontrolRaw.MetaData.Code
+		responses.MetaData.Message = resNoSuratKontrolRaw.MetaData.Message
+		log.Println("responses: ", responses)
+		return responses, errMsg
+	}
+
 	dataResp, err := docs.StringDecrypt(key, resNoSuratKontrolRaw.Response)
 	if err != nil {
 		log.Printf("Error Decrypt: %v", err)
@@ -295,7 +337,7 @@ func ResponseGetNomorSuratKontrol(url string, header *config.Header, headers map
 		return nil, err
 	}
 
-	responses := &suratkontrol.ResponseGetSuratKontrol{
+	responses = &suratkontrol.ResponseGetSuratKontrol{
 		MetaData: resNoSuratKontrolRaw.MetaData,
 		Response: responseNoSuratKontrol,
 	}
@@ -337,6 +379,16 @@ func ResponseGetSuratKontrolBySEP(url string, header *config.Header, headers map
 		return nil, err
 	}
 
+	responses := &suratkontrol.ResponseGetSuratKontrolBySEP{}
+	if resSurKonSEP.MetaData.Code != "200" {
+		errMsg := errors.New(resSurKonSEP.MetaData.Message)
+		log.Printf("error : %v", errMsg)
+		responses.MetaData.Code = resSurKonSEP.MetaData.Code
+		responses.MetaData.Message = resSurKonSEP.MetaData.Message
+		log.Println("responses: ", responses)
+		return responses, errMsg
+	}
+
 	dataResp, err := docs.StringDecrypt(key, resSurKonSEP.Response)
 	if err != nil {
 		log.Printf("Error Decrypt: %v", err)
@@ -354,7 +406,7 @@ func ResponseGetSuratKontrolBySEP(url string, header *config.Header, headers map
 
 	log.Println("res: ", resSurKonSEP)
 
-	responses := &suratkontrol.ResponseGetSuratKontrolBySEP{
+	responses = &suratkontrol.ResponseGetSuratKontrolBySEP{
 		MetaData: resSurKonSEP.MetaData,
 		Response: responseNoSuratKontrol,
 	}

main.go

@@ -1,81 +1,116 @@
-package main
-
-import (
-	"bridging-rssa/config"
-	"bridging-rssa/handlers/bpjs"
-	"bridging-rssa/handlers/bpjs/jadwal_dokter"
-	suratkontrol "bridging-rssa/handlers/bpjs/surat_kontrol"
-	"log"
-
-	_ "bridging-rssa/docs"
-
-	"github.com/gin-contrib/cors"
-	"github.com/gin-gonic/gin"
-	"github.com/joho/godotenv"
-	swaggerFiles "github.com/swaggo/files"
-	ginSwagger "github.com/swaggo/gin-swagger"
-)
-
-// @title Crud User
-// @version 1
-// @Description Rest API CRUD User
-
-// @host localhost:8080
-
-func main() {
-	err := godotenv.Load()
-	if err != nil {
-		log.Fatal("Error loading .env file")
-	}
-
-	config.ConnectDB()
-
-	r := gin.Default()
-
-	v1 := r.Group("/api")
-
-	subspesialis := v1.Group("/subspesialis")
-	{
-		subspesialis.GET("/", bpjs.GetAllSubspesialis)
-	}
-
-	jadwalDokter := v1.Group("/jadwaldokter")
-	{
-		jadwalDokter.GET("/", jadwal_dokter.GetJadwalDokter)
-		jadwalDokter.GET("/dpjp/:dpjp", jadwal_dokter.GetDokterByDPJP)
-		// jadwalDokter.GET("/tanggal/:tanggal", jadwal_dokter.GetSpesialisByDate)
-		jadwalDokter.GET("/tanggal/:tanggal", jadwal_dokter.GetJadwalSubspesialisByDate)
-		jadwalDokter.GET("/tanggal/:tanggal/spesialis/:spesialis", jadwal_dokter.GetDokterBySpesialis)
-		jadwalDokter.GET("/tanggal/:tanggal/subspesialis/:subspesialis", jadwal_dokter.GetDokterBySubspesialis)
-	}
-
-	suratKontrol := v1.Group("/suratkontrol")
-	{
-		suratKontrol.GET("/", suratkontrol.GetDataSurKon)
-		suratKontrol.GET("/idxdaftar/:idxdaftar", suratkontrol.GetDataSurKonByID)
-		suratKontrol.GET("/noSuratKontrol/:noSuratKontrol", suratkontrol.GetNomorSuratKontrol)
-		suratKontrol.GET("/noSEP/:noSEP", suratkontrol.GetSuratKontrolBySEP)
-		suratKontrol.GET("/printSurKon/:idxdaftar", suratkontrol.PrintSurKon)
-		suratKontrol.POST("/cari", suratkontrol.CariPasienTPP)
-		suratKontrol.POST("/insert", suratkontrol.InsertSuratKontrol)
-		suratKontrol.PUT("/update", suratkontrol.UpdateSuratKontrol)
-		suratKontrol.POST("/delete", suratkontrol.DeleteSuratKontrol)
-	}
-
-	r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
-	r.POST("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
-	r.PUT("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
-	r.DELETE("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
-	r.Use(cors.New(cors.Config{
-		AllowOrigins:     []string{"*"}, // or specific domains like "http://example.com"
-		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE"},
-		AllowHeaders:     []string{"Origin", "Content-Type"},
-		AllowCredentials: true,
-	}))
-
-	log.Println("JALAN DI PORT : 8081")
-	err = r.Run(":8081")
-	if err != nil {
-		log.Fatal(err)
-	}
-}
+package main
+
+import (
+	"bridging-rssa/config"
+	"bridging-rssa/handlers/bpjs"
+	icare "bridging-rssa/handlers/bpjs/i_care"
+	"bridging-rssa/handlers/bpjs/jadwal_dokter"
+	suratkontrol "bridging-rssa/handlers/bpjs/surat_kontrol"
+	"log"
+
+	_ "bridging-rssa/docs"
+
+	"github.com/gin-contrib/cors"
+	"github.com/gin-gonic/gin"
+	"github.com/joho/godotenv"
+	cron "github.com/robfig/cron/v3"
+	swaggerFiles "github.com/swaggo/files"
+	ginSwagger "github.com/swaggo/gin-swagger"
+)
+
+// @title Crud User
+// @version 1
+// @Description Rest API CRUD User
+
+// @host localhost:8080
+
+func main() {
+	err := godotenv.Load()
+	if err != nil {
+		log.Fatal("Error loading .env file")
+	}
+
+	config.ConnectDB()
+
+	r := gin.Default()
+
+	scheduler := cron.New()
+
+	defer scheduler.Stop()
+
+	//scheduler.AddFunc("0 2 * * *", func() {
+	//	log.Println("=== RUNNING SCHEDULE GET JADWAL DOKTER ===")
+	//	for {
+	//		success := jadwal_dokter.GetJadwalDokter()
+	//		if success {
+	//			log.Println("=== SCHEDULE GET JADWAL DOKTER DONE ===")
+	//			break
+	//		}
+	//	}
+	//})
+
+	scheduler.AddFunc("10 2 8 * *", func() {
+		log.Println("=== RUNNING SCHEDULE GET JADWAL DOKTER MONTHLY===")
+		for {
+			success := jadwal_dokter.GetDataJadwalDokter()
+			if success {
+				log.Println("=== SCHEDULE GET JADWAL DOKTER MONTHLY DONE ===")
+				break
+			}
+		}
+	})
+
+	go scheduler.Start()
+
+	v1 := r.Group("/api")
+
+	subspesialis := v1.Group("/subspesialis")
+	{
+		subspesialis.GET("/", bpjs.GetAllSubspesialis)
+	}
+
+	jadwalDokter := v1.Group("/jadwaldokter")
+	{
+		// jadwalDokter.GET("/", jadwal_dokter.GetJadwalDokter)
+		jadwalDokter.GET("/dpjp/:dpjp", jadwal_dokter.GetDokterByDPJP)
+		// jadwalDokter.GET("/tanggal/:tanggal", jadwal_dokter.GetSpesialisByDate)
+		jadwalDokter.GET("/tanggal/:tanggal", jadwal_dokter.GetJadwalSubspesialisByDate)
+		jadwalDokter.GET("/tanggal/:tanggal/spesialis/:spesialis", jadwal_dokter.GetDokterBySpesialis)
+		jadwalDokter.GET("/tanggal/:tanggal/subspesialis/:subspesialis", jadwal_dokter.GetDokterBySubspesialis)
+	}
+
+	suratKontrol := v1.Group("/suratkontrol")
+	{
+		suratKontrol.GET("/offset/:offset/limit/:limit", suratkontrol.GetDataSurKon)
+		suratKontrol.GET("/idxdaftar/:idxdaftar/tiperawat/:tiperawat", suratkontrol.GetDataSurKonByID)
+		suratKontrol.GET("/noSuratKontrol/:noSuratKontrol", suratkontrol.GetNomorSuratKontrol)
+		suratKontrol.GET("/noSEP/:noSEP", suratkontrol.GetSuratKontrolBySEP)
+		suratKontrol.GET("/printSurKon/:idxdaftar/tiperawat/:tiperawat", suratkontrol.PrintSurKon)
+		suratKontrol.POST("/cari", suratkontrol.CariPasienTPP)
+		suratKontrol.POST("/insert", suratkontrol.InsertSuratKontrol)
+		suratKontrol.PUT("/update", suratkontrol.UpdateSuratKontrol)
+		suratKontrol.POST("/delete", suratkontrol.DeleteSuratKontrol)
+	}
+
+	iCare := v1.Group("/icare")
+	{
+		iCare.POST("/rs/validate", icare.GetFKRTL)
+		iCare.POST("/pcare/validate", icare.GetFKTP)
+	}
+	r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
+	r.POST("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
+	r.PUT("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
+	r.DELETE("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
+	r.Use(cors.New(cors.Config{
+		AllowOrigins:     []string{"*"}, // or specific domains like "http://example.com"
+		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE"},
+		AllowHeaders:     []string{"Origin", "Content-Type"},
+		AllowCredentials: true,
+	}))
+
+	log.Println("JALAN DI PORT : 8080")
+	err = r.Run(":8080")
+	if err != nil {
+		log.Fatal(err)
+	}
+}

models/bpjs/i_care/i_care.go

@@ -0,0 +1,36 @@
+package icare
+
+type ReqICare struct {
+	IDXDaftar  string `json:"idxdaftar"`
+	Param      string `json:"param"`
+	KodeDokter int    `json:"kodedokter"`
+	User       string `json:"user"`
+}
+
+type RequestICare struct {
+	Param      string `json:"param"`
+	KodeDokter int    `json:"kodedokter"`
+}
+
+type ReqFKTP struct {
+	Param string `json:"param"`
+}
+
+type Metadata struct {
+	Code    int    `json:"code"`
+	Message string `json:"message"`
+}
+
+type Response struct {
+	Url string `json:"url"`
+}
+
+type ResponseGet struct {
+	Response Response `json:"response"`
+	MetaData Metadata `json:"metaData"`
+}
+
+type ResponseGetRaw struct {
+	Response string   `json:"response"`
+	MetaData Metadata `json:"metaData"`
+}

models/bpjs/jadwal_dokter/jadwal_dokter.go

@@ -1,72 +1,94 @@
-package jadwal_dokter
-
-type JadwalDokterRaw struct {
-	Response string   `json:"response"`
-	MetaData Metadata `json:"metadata"`
-}
-
-type Metadata struct {
-	Code    int    `json:"code"`
-	Message string `json:"message"`
-}
-
-type ListDokter struct {
-	KodeSubspesialis string `json:"kodesubspesialis"`
-	Hari             int    `json:"hari"`
-	KapasitasPasien  int    `json:"kapasitaspasien"`
-	Libur            int    `json:"libur"`
-	NamaHari         string `json:"namahari"`
-	Jadwal           string `json:"jadwal"`
-	NamaSubspesialis string `json:"namasubspesialis"`
-	NamaDokter       string `json:"namadokter"`
-	KodePoli         string `json:"kodepoli"`
-	NamaPoli         string `json:"namapoli"`
-	KodeDokter       int    `json:"kodedokter"`
-}
-
-type DaftarSpesialis struct {
-	ID        int    `json:"id"`
-	Kode      string `json:"Kode"`
-	Spesialis string `json:"Spesialis"`
-}
-
-type JadwalDokterSatuData struct {
-	ID           int    `gorm:"column:id" json:"id"`
-	Hari         int    `gorm:"column:Hari" json:"Hari"`
-	NamaHari     string `gorm:"column:Nama_hari" json:"Nama_hari"`
-	Waktu        string `gorm:"column:Waktu" json:"Waktu"`
-	Dokter       string `gorm:"column:Dokter" json:"Dokter"`
-	Spesialis    int    `gorm:"column:Spesialis" json:"Spesialis"`
-	SubSpesialis int    `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
-	Status       int    `gorm:"column:Status" json:"Status"`
-}
-
-type JadwalDokterTempSatuData struct {
-	ID           int    `gorm:"column:id" json:"id"`
-	Hari         int    `gorm:"column:Hari" json:"Hari"`
-	NamaHari     string `gorm:"column:Nama_hari" json:"Nama_hari"`
-	Waktu        string `gorm:"column:Waktu" json:"Waktu"`
-	Dokter       string `gorm:"column:Dokter" json:"Dokter"`
-	Spesialis    string `gorm:"column:Spesialis" json:"Spesialis"`
-	SubSpesialis string `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
-	Status       int    `gorm:"column:Status" json:"Status"`
-}
-
-type ResponseListHari struct {
-	IDSpesialis    int                `json:"id_spesialis"`
-	Kode           string             `json:"Kode"`
-	Spesialis      string             `json:"Spesialis"`
-	Subspesialis   string             `json:"Subspesialis"`
-	IDSubspesialis string             `json:"id_subspesialis"`
-	NamaLengkap    string             `json:"nama_lengkap"`
-	HFISCode       string             `json:"HFIS_code"`
-	KodeDPJP       string             `json:"DPJP_code"`
-	IDDokter       string             `json:"id_dokter"`
-	JadwalDokter   []ListJadwalDokter `json:"Jadwal_dokter"`
-}
-
-type ListJadwalDokter struct {
-	NamaHari string `json:"Nama_hari"`
-	KodeHari int    `json:"Kode_hari"`
-	Waktu    string `json:"Waktu"`
-}
+package jadwal_dokter
+
+type JadwalDokterRaw struct {
+	Response string   `json:"response"`
+	MetaData Metadata `json:"metadata"`
+}
+
+type JadwalDokter struct {
+	Response []*ListDokter `json:"response"`
+	MetaData Metadata      `json:"metadata"`
+}
+
+type Metadata struct {
+	Code    int    `json:"code"`
+	Message string `json:"message"`
+}
+
+type ListDokter struct {
+	KodeSubspesialis string `json:"kodesubspesialis"`
+	Hari             int    `json:"hari"`
+	KapasitasPasien  int    `json:"kapasitaspasien"`
+	Libur            int    `json:"libur"`
+	NamaHari         string `json:"namahari"`
+	Jadwal           string `json:"jadwal"`
+	NamaSubspesialis string `json:"namasubspesialis"`
+	NamaDokter       string `json:"namadokter"`
+	KodePoli         string `json:"kodepoli"`
+	NamaPoli         string `json:"namapoli"`
+	KodeDokter       int    `json:"kodedokter"`
+}
+
+type DaftarSpesialis struct {
+	ID        int    `json:"id"`
+	Kode      string `json:"Kode"`
+	Spesialis string `json:"Spesialis"`
+}
+
+type JadwalDokterSatuData struct {
+	ID           int    `gorm:"column:id" json:"id"`
+	Hari         int    `gorm:"column:Hari" json:"Hari"`
+	NamaHari     string `gorm:"column:Nama_hari" json:"Nama_hari"`
+	Waktu        string `gorm:"column:Waktu" json:"Waktu"`
+	Dokter       string `gorm:"column:Dokter" json:"Dokter"`
+	Spesialis    int    `gorm:"column:Spesialis" json:"Spesialis"`
+	SubSpesialis int    `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
+	Status       int    `gorm:"column:Status" json:"Status"`
+}
+
+type DataJadwalDokterSatuData struct {
+	ID            string `gorm:"column:id" json:"id"`
+	DateCreated   string `gorm:"column:date_created" json:"Date_created"`
+	Hari          string `gorm:"column:Hari" json:"Hari"`
+	NamaHari      string `gorm:"column:Nama_hari" json:"Nama_hari"`
+	Waktu         string `gorm:"column:Waktu" json:"Waktu"`
+	Dokter        string `gorm:"column:Dokter" json:"Dokter"`
+	Spesialis     int    `gorm:"column:Spesialis" json:"Spesialis"`
+	SubSpesialis  int    `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
+	TanggalJadwal string `gorm:"column:Tanggal_jadwal" json:"Tanggal_jadwal"`
+}
+
+type JadwalDokterTempSatuData struct {
+	ID           int    `gorm:"column:id" json:"id"`
+	Hari         int    `gorm:"column:Hari" json:"Hari"`
+	NamaHari     string `gorm:"column:Nama_hari" json:"Nama_hari"`
+	Waktu        string `gorm:"column:Waktu" json:"Waktu"`
+	Dokter       string `gorm:"column:Dokter" json:"Dokter"`
+	Spesialis    string `gorm:"column:Spesialis" json:"Spesialis"`
+	SubSpesialis string `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
+	Status       int    `gorm:"column:Status" json:"Status"`
+}
+
+type ResponseListHari struct {
+	IDSpesialis    int                `json:"id_spesialis"`
+	Kode           string             `json:"Kode"`
+	Spesialis      string             `json:"Spesialis"`
+	Subspesialis   string             `json:"Subspesialis"`
+	IDSubspesialis int                `json:"id_subspesialis"`
+	NamaLengkap    string             `json:"nama_lengkap"`
+	HFISCode       string             `json:"HFIS_code"`
+	KodeDPJP       string             `json:"DPJP_code"`
+	IDDokter       string             `json:"id_dokter"`
+	JadwalDokter   []ListJadwalDokter `json:"Jadwal_dokter"`
+}
+
+type ListJadwalDokter struct {
+	NamaHari string `json:"Nama_hari"`
+	KodeHari int    `json:"Kode_hari"`
+	Waktu    string `json:"Waktu"`
+}
+
+type RequestJadwalDokter struct {
+	KodePoli string `json:"kodepoli"`
+	Tanggal  string `json:"tanggal"`
+}

models/bpjs/surat_kontrol/kunjugan_pasien.go

@@ -21,4 +21,5 @@ type KunjunganPasien struct {
 	DisplayDiagnosisAkhirKeluar string `gorm:"column:Display_diagnosis_akhir_keluar" json:"Display_diagnosis_akhir_keluar"`
 	DiagnosisPrimerUtama        string `gorm:"column:Diagnosis_primer_utama" json:"Diagnosis_primer_utama"`
 	DisplayDiagnosisPrimerUtama string `gorm:"column:Display_diagnosis_primer_utama" json:"Display_diagnosis_primer_utama"`
+	NomorRM                     string `gorm:"column:No_rm" json:"No_rm"`
 }

models/bpjs/surat_kontrol/surat_kontrol.go

@@ -30,14 +30,18 @@ type RequestInsertRencanaKontrol struct {
 	TglRencanaKontrol string `json:"tglRencanaKontrol"`
 	User              string `json:"user"`
 	IDDokter          string `json:"id_dokter"`
-	KodeDiagnosa      string `json:"kode_diagnosa"`
-	NamaDiagnosa      string `json:"nama_diagnosa"`
+	KodeDiagnosa      string `json:"Kode_diagnosa"`
+	NamaDiagnosa      string `json:"Nama_diagnosa"`
+	TipeSurKon        string `json:"tipe_surkon"`
+	TipeRawat         string `json:"tipe_rawat"`
+	Ruangan           string `json:"ruangan"`
 }
 
 type ReqDeleteRencanaKontrol struct {
 	IDDataSurKon string `json:"id_surat_kontrol"`
 	NomorSurKon  string `json:"Nomor_surat_kontrol"`
 	User         string `json:"user"`
+	TipeSurKon   string `json:"tipe_surkon"`
 }
 
 type RequestUpdateRencanaKontrol struct {
@@ -52,6 +56,8 @@ type RequestUpdateRencanaKontrol struct {
 	User              string `json:"user"`
 	KodeDiagnosa      string `json:"Kode_diagnosa"`
 	NamaDiagnosa      string `json:"Nama_diagnosa"`
+	TipeSurKon        string `json:"tipe_surkon"`
+	TipeRawat         string `json:"tipe_rawat"`
 }
 
 type TSuratKontrol struct {
@@ -181,8 +187,8 @@ type Peserta struct {
 }
 
 type ProvUmum struct {
-	KodedProvider string `json:"kdProvider"`
-	NamaProvider  string `json:"nmProvider"`
+	KodeProvider string `json:"kdProvider"`
+	NamaProvider string `json:"nmProvider"`
 }
 
 type ProvPerujuk struct {
@@ -211,6 +217,7 @@ type DataSuratKontrol struct {
 	UserCreatedSurKon string `gorm:"column:User_created_surat_kontrol" json:"User_created_surat_kontrol"`
 	TipeSurKon        string `gorm:"column:Tipe_surat_kontrol" json:"Tipe_surat_kontrol"`
 	UserUpdatedSurKon string `gorm:"column:User_updated_surat_kontrol" json:"User_updated_surat_kontrol"`
+	TipeRawat         string `gorm:"column:Tipe_rawat" json:"Tipe_rawat"`
 }
 
 type ResponseSuratKontrolBySEP struct {
@@ -243,10 +250,12 @@ type GetDataSuratKontrol struct {
 	NomorKartu        string `gorm:"column:No_kartu" json:"No_kartu"`
 	IDPoli            string `gorm:"column:ID_poli" json:"id_poli"`
 	IDDokter          string `gorm:"column:id_dokter" json:"id_dokter"`
+	KodeDPJP          string `gorm:"column:Kode_dpjp" json:"Kode_dpjp"`
 	NoRM              string `gorm:"column:No_rm" json:"No_rm"`
 	KodeDiagnosa      string `gorm:"column:Kode_diagnosa" json:"Kode_diagnosa"`
 	NamaDiagnosa      string `gorm:"column:Nama_diagnosa" json:"Nama_diagnosa"`
 	TipeSurKon        string `gorm:"column:Tipe_SurKon" json:"Tipe_SurKon"`
+	User              string `gorm:"column:User" json:"User"`
 }
 
 type ResponseGetDataSuratKontrol struct {
@@ -264,12 +273,19 @@ type ResponseGetDataSuratKontrol struct {
 	Subspesialis      string `json:"Subspesialis"`
 	KodePoli          string `json:"Kode_poli"`
 	KodeDokter        string `json:"Kode_dokter"`
+	KodeDPJP          string `json:"Kode_dpjp"`
 	IDPoli            string `json:"id_poli"`
 	IDDokter          string `json:"id_dokter"`
 	NoRM              string `json:"No_rm"`
 	KodeDiagnosa      string `json:"Kode_diagnosa"`
 	NamaDiagnosa      string `json:"Nama_diagnosa"`
 	TipeSurKon        string `json:"Tipe_SurKon"`
+	User              string `json:"User"`
+}
+
+type ResponseCariDataSuratKontrol struct {
+	JumlahData           int                            `json:"jumlah_data"`
+	ListDataSuratKontrol []*ResponseGetDataSuratKontrol `json:"list_data"`
 }
 
 type RequestCariPasien struct {
@@ -278,4 +294,7 @@ type RequestCariPasien struct {
 	PoliKlinik   string `json:"poliklinik"`
 	TanggalAwal  string `json:"tanggal_awal"`
 	TanggalAkhir string `json:"tanggal_akhir"`
+	TipeSurKon   string `json:"tipe_surkon"`
+	Offset       string `json:"offset"`
+	Limit        string `json:"limit"`
 }

models/dokter/dokter.go

@@ -16,6 +16,7 @@ type NamaLengkap struct {
 	NamaLengkap   string `gorm:"column:Nama_lengkap" json:"Nama_lengkap"`
 	GelarBelakang string `gorm:"column:gelarbelakang" json:"gelarbelakang"`
 	HFISCode      string `gorm:"column:HFIS_code" json:"HFIS_code"`
+	DPJPCode      string `gorm:"column:DPJP_code" json:"DPJP_code"`
 }
 
 type ResponseDokter struct {
@@ -31,4 +32,5 @@ type ResponseDokterNew struct {
 	Subspesialis int    `json:"subspesialis"`
 	HFISCode     string `json:"HFIS_code"`
 	KodePoli     string `json:"kode_poli"`
+	DPJPCode     string `json:"DPJP_code"`
 }

models/jadwal/jadwal_libur.go

@@ -0,0 +1,7 @@
+package jadwal
+
+type DaftarJadwalLiburPelayanan struct {
+	NamaLiburPelayanan       string `gorm:"column:Nama_libur_pelayanan" json:"Nama_libur_pelayanan"`
+	KeteranganLiburPelayanan string `gorm:"column:Keterangan_libur_pelayanan" json:"Keterangan_libur_pelayanan"`
+	TanggalLiburPelayanan    string `gorm:"column:Tanggal_libur_pelayanan" json:"Tanggal_libur_pelayanan"`
+}

models/log_api/log_api.go

@@ -0,0 +1,20 @@
+package logapi
+
+import "encoding/json"
+
+type DataLogAPI struct {
+	ID              string          `gorm:"column:id" json:"ID"`
+	DateCreated     string          `gorm:"column:date_created" json:"date_created"`
+	UserAgent       string          `gorm:"column:User_agent" json:"User_agent"`
+	IP              string          `gorm:"column:IP" json:"IP"`
+	Parameter       string          `gorm:"column:Parameter" json:"Parameter"`
+	Header          string          `gorm:"column:Header" json:"Header"`
+	Method          string          `gorm:"column:Method" json:"Method"`
+	Url             string          `gorm:"column:URL" json:"URL"`
+	Request         json.RawMessage `gorm:"column:Request" json:"Request"`
+	Respon          json.RawMessage `gorm:"column:Respon" json:"Respon"`
+	ResponCode      string          `gorm:"column:Respon_code" json:"Respon_code"`
+	ResponTimeStart string          `gorm:"column:Respontime_start" json:"Respontime_start"`
+	ResponTimeEnd   string          `gorm:"column:Respontime_end" json:"Respontime_end"`
+	Comment         string          `gorm:"column:Comment" json:"Comment"`
+}

models/log_api/log_icare.go

@@ -0,0 +1,10 @@
+package logapi
+
+type InsertLogICare struct {
+	ID               string `gorm:"column:id" json:"id"`
+	DateCreated      string `gorm:"column:date_created" json:"date_created"`
+	Ruangan          int    `gorm:"column:Ruangan" json:"Ruangan"`
+	Dokter           string `gorm:"column:Dokter" json:"Dokter"`
+	Kunjungan_pasien string `gorm:"column:Kunjungan_pasien" json:"Kunjungan_pasien"`
+	WaktuTransaksi   string `gorm:"column:Waktu_transaksi" json:"Waktu_transaksi"`
+}

models/pasien/kunjungan_pasien.go

@@ -0,0 +1,6 @@
+package pasien
+
+type KunjunganPasien struct {
+	ID      string `gorm:"column:id" json:"id"`
+	Ruangan int    `gorm:"column:Ruangan" json:"Ruangan"`
+}