first commit

Reviewed-on: #11

.env

@@ -4,8 +4,8 @@ SATUDATA_PASSWORD=stim*RS54
 SATUDATA_NAME=satu_db
 SATUDATA_PORT=5000
 
-BASEURL_BPJS=https://apijkn.bpjs-kesehatan.go.id/
+BASEURL_BPJS=https://apijkn.bpjs-kesehatan.go.id
-ANTREAN_RS=antreanrs
+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,11 +12,15 @@ 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/
 
 COPY --from=builder /app/main .
 COPY --from=builder /app/.env .
-EXPOSE 8080
+EXPOSE 8083
 CMD  ["./main"]

config/config.go

@@ -1,107 +1,106 @@
-package config
+package config
-
+
-import (
+import (
-	"bridging-rssa/models/config"
+	"bridging-rssa/models/config"
-	"crypto/hmac"
+	"crypto/hmac"
-	"crypto/sha256"
+	"crypto/sha256"
-	"encoding/base64"
+	"encoding/base64"
-	"encoding/hex"
+	"encoding/hex"
-	"fmt"
+	"fmt"
-	"log"
+	"log"
-	"os"
+	"os"
-	"time"
+	"time"
-
+
-	"gorm.io/driver/postgres"
+	"gorm.io/driver/postgres"
-	"gorm.io/gorm"
+	"gorm.io/gorm"
-)
+)
-
+
-var DB *gorm.DB
+var DB *gorm.DB
-var SatuDataDB *gorm.DB
+var SatuDataDB *gorm.DB
-var err error
+var err error
-
+
-func ConnectDB() {
+func ConnectDB() {
-	hostSatuData := os.Getenv("SATUDATA_HOST")
+	hostSatuData := os.Getenv("SATUDATA_HOST")
-	userNameSatuData := os.Getenv("SATUDATA_USERNAME")
+	userNameSatuData := os.Getenv("SATUDATA_USERNAME")
-	passwordSatuData := os.Getenv("SATUDATA_PASSWORD")
+	passwordSatuData := os.Getenv("SATUDATA_PASSWORD")
-	dbNameSatuData := os.Getenv("SATUDATA_NAME")
+	dbNameSatuData := os.Getenv("SATUDATA_NAME")
-	portSatuData := os.Getenv("SATUDATA_PORT")
+	portSatuData := os.Getenv("SATUDATA_PORT")
-
+
-	satuData := fmt.Sprintf("host=%s user=%s password=%s dbname=%s port=%s sslmode=disable TimeZone=Asia/Jakarta", hostSatuData, userNameSatuData, passwordSatuData, dbNameSatuData, portSatuData)
+	satuData := fmt.Sprintf("host=%s user=%s password=%s dbname=%s port=%s sslmode=disable TimeZone=Asia/Jakarta", hostSatuData, userNameSatuData, passwordSatuData, dbNameSatuData, portSatuData)
-
+
-	SatuDataDB, err = gorm.Open(postgres.Open(satuData), &gorm.Config{})
+	SatuDataDB, err = gorm.Open(postgres.Open(satuData), &gorm.Config{})
-	if err != nil {
+	if err != nil {
-		log.Fatal("Failed to connect to Satu Data database: ", err)
+		log.Fatal("Failed to connect to Satu Data database: ", err)
-	} else {
+	} else {
-		log.Println("Successfully connected to the database")
+		log.Println("Successfully connected to the database")
-	}
+	}
-}
+}
-
+
-func SetHeader(cfg config.ConfigBpjs) *config.Header {
+func SetHeader(isIcare bool, cfg config.ConfigBpjs) *config.Header {
-
+
-	timenow := time.Now().UTC()
+	timenow := time.Now().UTC()
-	time := time.Date(1970, 1, 1, 0, 0, 0, 0, time.UTC)
+	time := time.Date(1970, 1, 1, 0, 0, 0, 0, time.UTC)
-	tstamp := timenow.Unix() - time.Unix()
+	tstamp := timenow.Unix() - time.Unix()
-
+
-	// cfg.Cons_id = os.Getenv("CONS_ID_DEV")
+	cfg.Cons_id = os.Getenv("CONS_ID")
-	// cfg.User_key = os.Getenv("USER_KEY_DEV")
+	cfg.User_key = os.Getenv("USER_KEY")
-	// cfg.Secret_key = os.Getenv("SECRET_KEY_DEV")
+	cfg.Secret_key = os.Getenv("SECRET_KEY")
-
+
-	cfg.Cons_id = os.Getenv("CONS_ID")
+	if isIcare {
-	cfg.User_key = os.Getenv("USER_KEY")
+		cfg.User_key = os.Getenv("USER_KEY_ICARE")
-	cfg.Secret_key = os.Getenv("SECRET_KEY")
+	}
-
+	secret := []byte(cfg.Secret_key)
-	secret := []byte(cfg.Secret_key)
+	message := []byte(cfg.Cons_id + "&" + fmt.Sprint(tstamp))
-	message := []byte(cfg.Cons_id + "&" + fmt.Sprint(tstamp))
+	hash := hmac.New(sha256.New, secret)
-	hash := hmac.New(sha256.New, secret)
+	hash.Write(message)
-	hash.Write(message)
+	// to lowercase hexits
-	// to lowercase hexits
+	hex.EncodeToString(hash.Sum(nil))
-	hex.EncodeToString(hash.Sum(nil))
+	// to base64
-	// to base64
+	X_signature := base64.StdEncoding.EncodeToString(hash.Sum(nil))
-	X_signature := base64.StdEncoding.EncodeToString(hash.Sum(nil))
+
-
+	header := &config.Header{
-	header := &config.Header{
+		ConsID:     cfg.Cons_id,
-		ConsID:     cfg.Cons_id,
+		SecretKey:  cfg.Secret_key,
-		SecretKey:  cfg.Secret_key,
+		UserKey:    cfg.User_key,
-		UserKey:    cfg.User_key,
+		TimeStamp:  fmt.Sprint(tstamp),
-		TimeStamp:  fmt.Sprint(tstamp),
+		XSignature: X_signature,
-		XSignature: X_signature,
+	}
-	}
+
-
+	return header
-	return header
+
-
+}
-}
+
-
+func SetHeaderDev(b bool, cfg config.ConfigBpjs) *config.Header {
-func SetHeaderDev(cfg config.ConfigBpjs) *config.Header {
+
-
+	timenow := time.Now().UTC()
-	timenow := time.Now().UTC()
+	time := time.Date(1970, 1, 1, 0, 0, 0, 0, time.UTC)
-	time := time.Date(1970, 1, 1, 0, 0, 0, 0, time.UTC)
+	tstamp := timenow.Unix() - time.Unix()
-	tstamp := timenow.Unix() - time.Unix()
+
-
+	cfg.Cons_id = os.Getenv("CONS_ID_DEV")
-	cfg.Cons_id = os.Getenv("CONS_ID_DEV")
+	cfg.User_key = os.Getenv("USER_KEY_DEV")
-	cfg.User_key = os.Getenv("USER_KEY_DEV")
+	cfg.Secret_key = os.Getenv("SECRET_KEY_DEV")
-	cfg.Secret_key = os.Getenv("SECRET_KEY_DEV")
+
-
+	// cfg.Cons_id = os.Getenv("CONS_ID")
-	// cfg.Cons_id = os.Getenv("CONS_ID")
+	// cfg.User_key = os.Getenv("USER_KEY")
-	// cfg.User_key = os.Getenv("USER_KEY")
+	// cfg.Secret_key = os.Getenv("SECRET_KEY")
-	// cfg.Secret_key = os.Getenv("SECRET_KEY")
+
-
+	secret := []byte(cfg.Secret_key)
-	secret := []byte(cfg.Secret_key)
+	message := []byte(cfg.Cons_id + "&" + fmt.Sprint(tstamp))
-	message := []byte(cfg.Cons_id + "&" + fmt.Sprint(tstamp))
+	hash := hmac.New(sha256.New, secret)
-	hash := hmac.New(sha256.New, secret)
+	hash.Write(message)
-	hash.Write(message)
+	// to lowercase hexits
-	// to lowercase hexits
+	hex.EncodeToString(hash.Sum(nil))
-	hex.EncodeToString(hash.Sum(nil))
+	// to base64
-	// to base64
+	X_signature := base64.StdEncoding.EncodeToString(hash.Sum(nil))
-	X_signature := base64.StdEncoding.EncodeToString(hash.Sum(nil))
+
-
+	header := &config.Header{
-	header := &config.Header{
+		ConsID:     cfg.Cons_id,
-		ConsID:     cfg.Cons_id,
+		SecretKey:  cfg.Secret_key,
-		SecretKey:  cfg.Secret_key,
+		UserKey:    cfg.User_key,
-		UserKey:    cfg.User_key,
+		TimeStamp:  fmt.Sprint(tstamp),
-		TimeStamp:  fmt.Sprint(tstamp),
+		XSignature: X_signature,
-		XSignature: X_signature,
+	}
-	}
+
-
+	return header
-	return header
+
-
+}
-}

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
@@ -68,9 +69,9 @@ func GetJadwalDokterBySpesialis(hari string, spesialis string) ([]string, error)
 	return listDokter, nil
 }
 
-func GetJadwalDokterBySubpesialis(hari string, subspesialis string) ([]string, error) {
+func GetJadwalDokterBySubpesialis(tanggal 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 "data_jadwal_dokter" where "Tanggal_jadwal" = ? and "Sub_spesialis" = ? order by "Sub_spesialis"`, tanggal, 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

@@ -3,6 +3,7 @@ package logapi
 import (
 	"bridging-rssa/config"
 	logapi "bridging-rssa/models/log_api"
+	"fmt"
 	"log"
 )
 
@@ -10,7 +11,7 @@ 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.Debug().Exec(query,
+	err := config.SatuDataDB.Exec(query,
 		reqInsert.ID,
 		reqInsert.DateCreated,
 		reqInsert.UserAgent,
@@ -30,5 +31,7 @@ func InsertLogAPI(reqInsert *logapi.DataLogAPI) error {
 		log.Println(err)
 		return err
 	}
+	log.Println(err)
+	fmt.Printf("insert log: ", 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")
+					"User_created_surat_kontrol", "Tipe_surat_kontrol", "User_updated_surat_kontrol", "Tipe_rawat")
-					values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`
+					values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`
-	err := config.SatuDataDB.Debug().Exec(insertQuery,
+	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)
@@ -80,7 +82,7 @@ func InsertDataSuratKontrol(reqInsert *suratkontrol.DataSuratKontrol) 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(offset, limit string) ([]*suratkontrol.GetDataSuratKont
 		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",
@@ -124,9 +127,9 @@ func GetDataSuratKontrol(offset, limit string) ([]*suratkontrol.GetDataSuratKont
 	return dataSurKon, nil
 }
 
-func GetDataSuratKontrolByID(idxdaftar string) (*suratkontrol.GetDataSuratKontrol, error) {
+func GetDataSuratKontrolByIDTipe(idxdaftar string, tipe 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
@@ -149,20 +152,70 @@ 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" = ?`, idxdaftar, tipe).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
+		}
+	}
+	return dataSurKon, nil
+}
+
+func GetDataSuratKontrolByID(idxdaftar 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" is null`, idxdaftar).First(&dataSurKon).Error
+	if err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			errMsg := errors.New("Data tidak ada")
 			log.Println(errMsg)
 			return nil, errMsg
 		}
@@ -171,7 +224,7 @@ func GetDataSuratKontrolByID(idxdaftar string) (*suratkontrol.GetDataSuratKontro
 }
 
 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
@@ -181,7 +234,7 @@ func UpdateDataSuratKontrol(reqUpdate *suratkontrol.DataSuratKontrol) error {
 
 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
@@ -194,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
@@ -204,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"
@@ -228,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",
@@ -238,12 +292,78 @@ 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
 	}
 	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
+}
+
+func Getdatahistori(norm string, offset, limit string) ([]*suratkontrol.HistoriSurkon, error) {
+	var dataHistoriSurKon []*suratkontrol.HistoriSurkon
+	err := config.SatuDataDB.Raw(`select dkp2."Nama_lengkap",dkp2."Nomor_sep",dsk."id",dkp2."IDXDAFTAR",dsk."Nomor_surat_kontrol",dsk."Tanggal_rencana_kontrol",dsk."Tanggal_cetak_surat_kontrol",
+		ds2."Spesialis",ds."Subspesialis",
+		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,	dsk."User_created_surat_kontrol", dsk."User_updated_surat_kontrol",dsk."Tipe_rawat" ,
+		dsk."Status_surat_kontrol"
+		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"
+		left join daftar_spesialis ds2 on ds."FK_daftar_spesialis_ID" = ds2."id"
+		where dkp2."NOMR" = ? order by dsk."Tanggal_rencana_kontrol" desc offset ? limit ?`, norm, offset, limit).Scan(&dataHistoriSurKon).Error
+	if err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			errMsg := errors.New("data tidak ada")
+			log.Println(errMsg)
+			return nil, errMsg
+		}
+	}
+	return dataHistoriSurKon, nil
+}

docker-compose.yml

@@ -7,10 +7,14 @@ services:
     container_name: api-rssa
     restart: always
     ports:
-      - 8080:8080
+      - 8083:8083
     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(false, 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/response.go

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

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)
+		if resSuratKontrolRaw.MetaData.Message == "Gagal simpan! Nomor SEP Sudah pernah digunakan!." {
-		log.Printf("error : %v", errMsg)
+			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{
+	client := http.Client{}
-		Timeout: 10 * time.Second,
-	}
 	responses := &suratkontrol.Response{}
 	response, err := client.Do(req)
 	if err != nil {
-		if strings.Contains(strings.ToLower(err.Error()), "deadline exceeded") {
+		responses.MetaData.Code = "504"
-			errMsg := errors.New("Gagal Proses Selama 10 Detik, Silahkan Coba Lagi")
+		responses.MetaData.Message = err.Error()
-			log.Printf("error : %v", errMsg)
+		log.Println("responses: ", responses)
-			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("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)
+		if resSuratKontrolRaw.MetaData.Message == "Gagal simpan! Nomor SEP Sudah pernah digunakan!." {
-		log.Printf("error : %v", errMsg)
+			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,120 @@
-package main
+package main
-
+
-import (
+import (
-	"bridging-rssa/config"
+	"bridging-rssa/config"
-	"bridging-rssa/handlers/bpjs"
+	"bridging-rssa/handlers/bpjs"
-	"bridging-rssa/handlers/bpjs/jadwal_dokter"
+	icare "bridging-rssa/handlers/bpjs/i_care"
-	suratkontrol "bridging-rssa/handlers/bpjs/surat_kontrol"
+	"bridging-rssa/handlers/bpjs/jadwal_dokter"
-	"log"
+	suratkontrol "bridging-rssa/handlers/bpjs/surat_kontrol"
-
+	"github.com/gin-contrib/cors"
-	_ "bridging-rssa/docs"
+	"log"
-
+
-	"github.com/gin-contrib/cors"
+	_ "bridging-rssa/docs"
-	"github.com/gin-gonic/gin"
+
-	"github.com/joho/godotenv"
+	"github.com/gin-gonic/gin"
-	swaggerFiles "github.com/swaggo/files"
+	"github.com/joho/godotenv"
-	ginSwagger "github.com/swaggo/gin-swagger"
+	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
+// @title Crud User
-
+// @version 1
-// @host localhost:8080
+// @Description Rest API CRUD User
-
+
-func main() {
+// @host localhost:8080
-	err := godotenv.Load()
+
-	if err != nil {
+func main() {
-		log.Fatal("Error loading .env file")
+	err := godotenv.Load()
-	}
+	if err != nil {
-
+		log.Fatal("Error loading .env file")
-	config.ConnectDB()
+	}
-
+
-	r := gin.Default()
+	config.ConnectDB()
-
+
-	v1 := r.Group("/api")
+	r := gin.Default()
-
+	r.Use(cors.New(cors.Config{
-	subspesialis := v1.Group("/subspesialis")
+		AllowOrigins:     []string{"*"}, // or specific domains like "http://example.com"
-	{
+		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE"},
-		subspesialis.GET("/", bpjs.GetAllSubspesialis)
+		AllowHeaders:     []string{"Origin", "Content-Type"},
-	}
+		AllowCredentials: true,
-
+	}))
-	jadwalDokter := v1.Group("/jadwaldokter")
+	scheduler := cron.New()
-	{
+
-		jadwalDokter.GET("/", jadwal_dokter.GetJadwalDokter)
+	defer scheduler.Stop()
-		jadwalDokter.GET("/dpjp/:dpjp", jadwal_dokter.GetDokterByDPJP)
+
-		// jadwalDokter.GET("/tanggal/:tanggal", jadwal_dokter.GetSpesialisByDate)
+	// SCHEDULE HARIAN
-		jadwalDokter.GET("/tanggal/:tanggal", jadwal_dokter.GetJadwalSubspesialisByDate)
+	scheduler.AddFunc("15 2 * * *", func() {
-		jadwalDokter.GET("/tanggal/:tanggal/spesialis/:spesialis", jadwal_dokter.GetDokterBySpesialis)
+		log.Println("=== RUNNING SCHEDULE GET JADWAL DOKTER ===")
-		jadwalDokter.GET("/tanggal/:tanggal/subspesialis/:subspesialis", jadwal_dokter.GetDokterBySubspesialis)
+		for {
-	}
+			success := jadwal_dokter.GetJadwalDokterNew()
-
+			if success {
-	suratKontrol := v1.Group("/suratkontrol")
+				log.Println("=== SCHEDULE GET JADWAL DOKTER DONE ===")
-	{
+				break
-		suratKontrol.GET("/offset/:offset/limit/:limit", 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)
+	//SCHEDULE TIAP 3 BULAN
-		suratKontrol.POST("/cari", suratkontrol.CariPasienTPP)
+	scheduler.AddFunc("20 2 * * 5", func() {
-		suratKontrol.POST("/insert", suratkontrol.InsertSuratKontrol)
+		log.Println("=== RUNNING SCHEDULE GET JADWAL DOKTER MONTHLY===")
-		suratKontrol.PUT("/update", suratkontrol.UpdateSuratKontrol)
+		for {
-		suratKontrol.POST("/delete", suratkontrol.DeleteSuratKontrol)
+			success := jadwal_dokter.GetDataJadwalDokter()
-	}
+			if success {
-
+				log.Println("=== SCHEDULE GET JADWAL DOKTER MONTHLY DONE ===")
-	r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
+				break
-	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"
+	go scheduler.Start()
-		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE"},
+
-		AllowHeaders:     []string{"Origin", "Content-Type"},
+	v1 := r.Group("/api")
-		AllowCredentials: true,
+
-	}))
+	subspesialis := v1.Group("/subspesialis")
-
+	{
-	log.Println("JALAN DI PORT : 8081")
+		subspesialis.GET("/", bpjs.GetAllSubspesialis)
-	err = r.Run(":8081")
+	}
-	if err != nil {
+
-		log.Fatal(err)
+	//API UNTUK JADWAL DOKTER
-	}
+	jadwalDokter := v1.Group("/jadwaldokter")
-}
+	{
+		jadwalDokter.GET("/date/:tanggal", jadwal_dokter.GetJadwalDokter)
+		jadwalDokter.GET("/dpjp/:dpjp", jadwal_dokter.GetDokterByDPJP)
+		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)
+	}
+
+	// API UNTUK SURAT KONTROL
+	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.POST("/insertnew", suratkontrol.InsertSuratkontrolNew)
+		suratKontrol.PUT("/update", suratkontrol.UpdateSuratKontrol)
+		suratKontrol.POST("/delete", suratkontrol.DeleteSuratKontrol)
+		suratKontrol.GET("/norm/:norm/limit/:limit/offset/:offset", suratkontrol.GethistoribyNorm)
+	}
+
+	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))
+
+	log.Println("JALAN DI PORT : 8080")
+	err = r.Run(":8083")
+	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
+package jadwal_dokter
-
+
-type JadwalDokterRaw struct {
+type JadwalDokterRaw struct {
-	Response string   `json:"response"`
+	Response string   `json:"response"`
-	MetaData Metadata `json:"metadata"`
+	MetaData Metadata `json:"metadata"`
-}
+}
-
+
-type Metadata struct {
+type JadwalDokter struct {
-	Code    int    `json:"code"`
+	Response []*ListDokter `json:"response"`
-	Message string `json:"message"`
+	MetaData Metadata      `json:"metadata"`
-}
+}
-
+
-type ListDokter struct {
+type Metadata struct {
-	KodeSubspesialis string `json:"kodesubspesialis"`
+	Code    int    `json:"code"`
-	Hari             int    `json:"hari"`
+	Message string `json:"message"`
-	KapasitasPasien  int    `json:"kapasitaspasien"`
+}
-	Libur            int    `json:"libur"`
+
-	NamaHari         string `json:"namahari"`
+type ListDokter struct {
-	Jadwal           string `json:"jadwal"`
+	KodeSubspesialis string `json:"kodesubspesialis"`
-	NamaSubspesialis string `json:"namasubspesialis"`
+	Hari             int    `json:"hari"`
-	NamaDokter       string `json:"namadokter"`
+	KapasitasPasien  int    `json:"kapasitaspasien"`
-	KodePoli         string `json:"kodepoli"`
+	Libur            int    `json:"libur"`
-	NamaPoli         string `json:"namapoli"`
+	NamaHari         string `json:"namahari"`
-	KodeDokter       int    `json:"kodedokter"`
+	Jadwal           string `json:"jadwal"`
-}
+	NamaSubspesialis string `json:"namasubspesialis"`
-
+	NamaDokter       string `json:"namadokter"`
-type DaftarSpesialis struct {
+	KodePoli         string `json:"kodepoli"`
-	ID        int    `json:"id"`
+	NamaPoli         string `json:"namapoli"`
-	Kode      string `json:"Kode"`
+	KodeDokter       int    `json:"kodedokter"`
-	Spesialis string `json:"Spesialis"`
+}
-}
+
-
+type DaftarSpesialis struct {
-type JadwalDokterSatuData struct {
+	ID        int    `json:"id"`
-	ID           int    `gorm:"column:id" json:"id"`
+	Kode      string `json:"Kode"`
-	Hari         int    `gorm:"column:Hari" json:"Hari"`
+	Spesialis string `json:"Spesialis"`
-	NamaHari     string `gorm:"column:Nama_hari" json:"Nama_hari"`
+}
-	Waktu        string `gorm:"column:Waktu" json:"Waktu"`
+
-	Dokter       string `gorm:"column:Dokter" json:"Dokter"`
+type JadwalDokterSatuData struct {
-	Spesialis    int    `gorm:"column:Spesialis" json:"Spesialis"`
+	ID           int    `gorm:"column:id" json:"id"`
-	SubSpesialis int    `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
+	Hari         int    `gorm:"column:Hari" json:"Hari"`
-	Status       int    `gorm:"column:Status" json:"Status"`
+	NamaHari     string `gorm:"column:Nama_hari" json:"Nama_hari"`
-}
+	Waktu        string `gorm:"column:Waktu" json:"Waktu"`
-
+	Dokter       string `gorm:"column:Dokter" json:"Dokter"`
-type JadwalDokterTempSatuData struct {
+	Spesialis    int    `gorm:"column:Spesialis" json:"Spesialis"`
-	ID           int    `gorm:"column:id" json:"id"`
+	SubSpesialis int    `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
-	Hari         int    `gorm:"column:Hari" json:"Hari"`
+	Status       int    `gorm:"column:Status" json:"Status"`
-	NamaHari     string `gorm:"column:Nama_hari" json:"Nama_hari"`
+}
-	Waktu        string `gorm:"column:Waktu" json:"Waktu"`
+
-	Dokter       string `gorm:"column:Dokter" json:"Dokter"`
+type DataJadwalDokterSatuData struct {
-	Spesialis    string `gorm:"column:Spesialis" json:"Spesialis"`
+	ID            string `gorm:"column:id" json:"id"`
-	SubSpesialis string `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
+	DateCreated   string `gorm:"column:date_created" json:"Date_created"`
-	Status       int    `gorm:"column:Status" json:"Status"`
+	Hari          string `gorm:"column:Hari" json:"Hari"`
-}
+	NamaHari      string `gorm:"column:Nama_hari" json:"Nama_hari"`
-
+	Waktu         string `gorm:"column:Waktu" json:"Waktu"`
-type ResponseListHari struct {
+	Dokter        string `gorm:"column:Dokter" json:"Dokter"`
-	IDSpesialis    int                `json:"id_spesialis"`
+	Spesialis     int    `gorm:"column:Spesialis" json:"Spesialis"`
-	Kode           string             `json:"Kode"`
+	SubSpesialis  int    `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
-	Spesialis      string             `json:"Spesialis"`
+	TanggalJadwal string `gorm:"column:Tanggal_jadwal" json:"Tanggal_jadwal"`
-	Subspesialis   string             `json:"Subspesialis"`
+}
-	IDSubspesialis string             `json:"id_subspesialis"`
+
-	NamaLengkap    string             `json:"nama_lengkap"`
+type JadwalDokterTempSatuData struct {
-	HFISCode       string             `json:"HFIS_code"`
+	ID           int    `gorm:"column:id" json:"id"`
-	KodeDPJP       string             `json:"DPJP_code"`
+	Hari         int    `gorm:"column:Hari" json:"Hari"`
-	IDDokter       string             `json:"id_dokter"`
+	NamaHari     string `gorm:"column:Nama_hari" json:"Nama_hari"`
-	JadwalDokter   []ListJadwalDokter `json:"Jadwal_dokter"`
+	Waktu        string `gorm:"column:Waktu" json:"Waktu"`
-}
+	Dokter       string `gorm:"column:Dokter" json:"Dokter"`
-
+	Spesialis    string `gorm:"column:Spesialis" json:"Spesialis"`
-type ListJadwalDokter struct {
+	SubSpesialis string `gorm:"column:Sub_spesialis" json:"Sub_spesialis"`
-	NamaHari string `json:"Nama_hari"`
+	Status       int    `gorm:"column:Status" json:"Status"`
-	KodeHari int    `json:"Kode_hari"`
+}
-	Waktu    string `json:"Waktu"`
+
-}
+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

@@ -24,20 +24,25 @@ type ReqUpdateRencanaKontrol struct {
 type RequestInsertRencanaKontrol struct {
 	IDXDaftar         string `json:"idxdaftar"`
 	NoSEP             string `json:"noSEP"`
+	NoRM              string `json:"noRM"`
 	KodeHFIS          string `json:"kodeHFIS"`
 	KodePoli          string `json:"kodePoli"`
 	Subspesialis      string `json:"subspesialis"`
 	TglRencanaKontrol string `json:"tglRencanaKontrol"`
 	User              string `json:"user"`
 	IDDokter          string `json:"id_dokter"`
-	KodeDiagnosa      string `json:"kode_diagnosa"`
+	KodeDiagnosa      string `json:"Kode_diagnosa"`
-	NamaDiagnosa      string `json:"nama_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 +57,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 +188,8 @@ type Peserta struct {
 }
 
 type ProvUmum struct {
-	KodedProvider string `json:"kdProvider"`
+	KodeProvider string `json:"kdProvider"`
-	NamaProvider  string `json:"nmProvider"`
+	NamaProvider string `json:"nmProvider"`
 }
 
 type ProvPerujuk struct {
@@ -211,6 +218,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 +251,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 +274,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,6 +295,43 @@ 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"`
-}
+}
+
+type HistoriSurkon struct {
+	NamaPasien        string `gorm:"column:Nama_lengkap" json:"Nama_pasien"`
+	NoSEP             string `gorm:"column:Nomor_sep" json:"No_SEP"`
+	IdSurkon          string `gorm:"column:id" json:"id"`
+	Idxdaftar         string `gorm:"column:IDXDAFTAR" json:"IDXDAFTAR"`
+	NomorSuratkontrol string `gorm:"column:Nomor_surat_kontrol" json:"Nomor_surat_kontrol"`
+	TanggalRencana    string `gorm:"column:Tanggal_rencana_kontrol" json:"Tanggal_rencana_kontrol"`
+	TanggalCetak      string `gorm:"column:Tanggal_cetak_surat_kontrol" json:"Tanggal_cetak_surat_kontrol"`
+	Spesialis         string `gorm:"column:Spesialis" json:"Spesialis"`
+	Subspesialis      string `gorm:"column:Subspesialis" json:"Subspesialis"`
+	GelarDepan        string `gorm:"column:gelardepan" json:"Gelar_depan"`
+	NamaDokter        string `gorm:"column:Nama_lengkap_dokter" json:"Nama_dokter"`
+	GelarBelakang     string `gorm:"column:gelarbelakang" json:"Gelar_belakang"`
+	Tiperawat         string `gorm:"column:Tipe_rawat" json:"Tipe_rawat"`
+	UserCreate        string `gorm:"column:User_created_surat_kontrol" json:"User_create"`
+	UserUpdate        string `gorm:"column:User_updated_surat_kontrol" json:"User_update"`
+	Status            string `gorm:"column:Status_surat_kontrol" json:"Status_surat_kontrol"`
+}
+
+type Dataresponse struct {
+	NamaPasien        string `json:"Nama_pasien"`
+	NoSEP             string `json:"No_SEP"`
+	IdSurkon          string `json:"id_surkon"`
+	Idxdaftar         string `json:"Idxdaftar"`
+	NomorSuratkontrol string `json:"Nomor_surat_kontrol"`
+	TanggalRencana    string `json:"Tanggal_rencana_kontrol"`
+	TanggalCetak      string `json:"Tanggal_cetak_surat_kontrol"`
+	Spesialis         string `json:"Spesialis"`
+	Subspesialis      string `json:"Subspesialis"`
+	NamaLengkap       string `json:"Dpjp"`
+	Tiperawat         string `json:"Tipe_rawat"`
+	UserCreate        string `json:"User_create"`
+	UserUpdate        string `json:"User_update"`
+	Status            string `json:"Status_surat_kontrol"`
+}

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_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"`
+}