api-bpjs-surkon/database/satu_data/dokter/jadwal_dokter.go

package dokter

import (
	"bridging-rssa/config"
	"bridging-rssa/models/bpjs/jadwal_dokter"
	"errors"
	"log"
	"strconv"

	"github.com/google/uuid"
	"gorm.io/gorm"
)

func GetJadwalDokterByDPJP(dpjp string) ([]jadwal_dokter.JadwalDokterSatuData, error) {
	var hari []jadwal_dokter.JadwalDokterSatuData
	errSelect := config.SatuDataDB.Debug().Raw(`select djd.* from "daftar_jadwal_dokter" djd 
	left join "data_pegawai" dp on djd."Dokter" = dp."id" where dp."Code_dpjp" = ? order by djd."id"`, dpjp).Scan(&hari).Error
	if errSelect != nil {
		if errors.Is(errSelect, gorm.ErrRecordNotFound) {
			errMsg := errors.New("Dokter Tidak Terdaftar di HFIS")
			log.Println(errMsg)
			return nil, errMsg
		}
		log.Printf("Failed get data : %v", errSelect)
		return nil, errSelect
	}
	return hari, nil
}

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
	if errSelect != nil {
		if errors.Is(errSelect, gorm.ErrRecordNotFound) {
			errMsg := errors.New("Dokter Tidak Terdaftar di HFIS")
			log.Println(errMsg)
			return nil, errMsg
		}
		log.Printf("Failed get data : %v", errSelect)
		return nil, errSelect
	}
	return hari, nil
}

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
	if errSelect != nil {
		log.Printf("Failed get data : %v", errSelect)
		return nil, errSelect
	}
	return spesialis, nil
}

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
	if errSelect != nil {
		log.Printf("Failed get data : %v", errSelect)
		return nil, errSelect
	}
	return subspesialis, nil
}

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
	if errSelect != nil {
		log.Printf("Failed get data : %v", errSelect)
		return nil, errSelect
	}
	return listDokter, nil
}

func GetJadwalDokterBySubpesialis(hari string, subspesialis string) ([]string, error) {
	var listDokter []string
	errSelect := config.SatuDataDB.Debug().Raw(`select "Dokter" from "daftar_jadwal_dokter" where "Nama_hari" = ? and "Sub_spesialis" = ? order by "Sub_spesialis"`, hari, subspesialis).Scan(&listDokter).Error
	if errSelect != nil {
		log.Printf("Failed get data : %v", errSelect)
		return nil, errSelect
	}
	return listDokter, nil
}

func DeleteJadwalDokter() error {
	err := config.SatuDataDB.Debug().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 DeleteJadwalDokterTemp() error {
	err := config.SatuDataDB.Debug().Exec(`truncate table "daftar_jadwal_dokter_temp"`).Error
	if err != nil {
		log.Printf("Failed truncate data : %v", err)
		return err
	}
	log.Println("Success truncate data")
	return nil
}

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
	if err != nil {
		log.Printf("Failed insert data : %v", err)
		return err
	}
	log.Println("Success insert data")
	return nil
}

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
	if err != nil {
		log.Printf("Failed insert data : %v", err)
		return err
	}
	log.Println("Success insert data")
	return nil
}

func GetAllJadwalDokter() ([]*jadwal_dokter.ListDaftarJadwalDokter, error) {
	var listDokter []*jadwal_dokter.ListDaftarJadwalDokter
	query := `select djd."Hari" as valuehari, djd."Nama_hari" as hari, djd."Waktu" as waktu, ds."Spesialis" as spesialis, dss."Subspesialis" as 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,
		dkt. "Nama_lengkap" as namalengkap,
		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
		from daftar_jadwal_dokter djd
		join daftar_spesialis ds on ds.id = djd."Spesialis"
		join daftar_subspesialis dss on dss.id = djd."Sub_spesialis"
		join data_pegawai dp on dp.id = djd."Dokter"
		join data_ktp dkt on dkt.id = dp."KTP"
		order by djd."Hari" asc, ds."Spesialis" asc, dss."Subspesialis" asc, djd."Waktu" asc`
	err := config.SatuDataDB.Debug().Raw(query).Scan(&listDokter).Error
	if err != nil {
		log.Printf("Failed Get data : %v", err)
		return nil, err
	}
	return listDokter, nil
}