diff --git a/database/satu_data/dokter/jadwal_dokter.go b/database/satu_data/dokter/jadwal_dokter.go index 8d5c087..913a3f1 100644 --- a/database/satu_data/dokter/jadwal_dokter.go +++ b/database/satu_data/dokter/jadwal_dokter.go @@ -89,6 +89,16 @@ func DeleteJadwalDokter() error { 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 + } + log.Println("Success truncate data") + return nil +} + func DeleteJadwalDokterTemp() error { err := config.SatuDataDB.Exec(`truncate table "daftar_jadwal_dokter_temp"`).Error if err != nil { diff --git a/database/satu_data/surat_kontrol/surat_kontrol.go b/database/satu_data/surat_kontrol/surat_kontrol.go index a421ec0..617cfc1 100644 --- a/database/satu_data/surat_kontrol/surat_kontrol.go +++ b/database/satu_data/surat_kontrol/surat_kontrol.go @@ -212,7 +212,7 @@ func GetDataSuratKontrolByID(idxdaftar string) (*suratkontrol.GetDataSuratKontro 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("Data tidak ada") diff --git a/handlers/bpjs/jadwal_dokter/jadwal_dokter.go b/handlers/bpjs/jadwal_dokter/jadwal_dokter.go index aec0df2..6de4540 100644 --- a/handlers/bpjs/jadwal_dokter/jadwal_dokter.go +++ b/handlers/bpjs/jadwal_dokter/jadwal_dokter.go @@ -374,6 +374,11 @@ func GetDataJadwalDokter() bool { } 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 diff --git a/main.go b/main.go index ed949de..41edfe3 100644 --- a/main.go +++ b/main.go @@ -49,7 +49,7 @@ func main() { // } //}) - scheduler.AddFunc("0 2 15 * *", func() { + scheduler.AddFunc("10 2 8 * *", func() { log.Println("=== RUNNING SCHEDULE GET JADWAL DOKTER MONTHLY===") for { success := jadwal_dokter.GetDataJadwalDokter()