Compare commits
19
Commits
| Author | SHA256 | Date | |
|---|---|---|---|
|
|
8d4ab7888c | ||
|
|
fea530f207 | ||
|
|
ac14b7cf87 | ||
|
|
17cc0e6cba | ||
|
|
17d07a4d6a | ||
|
|
c653299fa2 | ||
|
|
47bb4caaf2 | ||
|
|
1719419480 | ||
|
|
28123e595c | ||
|
|
fb0d7f4304 | ||
|
|
b518314068 | ||
|
|
ea04f403f6 | ||
|
|
ff7d766f23 | ||
|
|
f8cfe6c5d9 | ||
|
|
496865a652 | ||
|
|
bb47ece739 | ||
|
|
7111eba875 | ||
|
|
9fe12bf768 | ||
|
|
77546b908b |
@@ -333,3 +333,37 @@ func GetNomorSurKon(idPasien string) (string, error) {
|
||||
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."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
|
||||
}
|
||||
@@ -3,6 +3,7 @@ package jadwal_dokter
|
||||
import (
|
||||
cfg "bridging-rssa/config"
|
||||
"bridging-rssa/database/satu_data/dokter"
|
||||
"bridging-rssa/database/satu_data/jadwal"
|
||||
log_api "bridging-rssa/database/satu_data/log_api"
|
||||
"bridging-rssa/docs/utils"
|
||||
"bridging-rssa/models/bpjs/jadwal_dokter"
|
||||
@@ -11,8 +12,6 @@ import (
|
||||
logapi "bridging-rssa/models/log_api"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"github.com/google/uuid"
|
||||
"gorm.io/gorm"
|
||||
"log"
|
||||
"net/http"
|
||||
"os"
|
||||
@@ -20,40 +19,21 @@ import (
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/google/uuid"
|
||||
"gorm.io/gorm"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
)
|
||||
|
||||
func GetJadwalDokter() bool {
|
||||
func GetJadwalDokter(c *gin.Context) {
|
||||
baseUrl := os.Getenv("BASEURL_BPJS")
|
||||
endpoint := os.Getenv("ANTREAN_RS")
|
||||
url := baseUrl + endpoint
|
||||
conf := config.ConfigBpjs{}
|
||||
|
||||
header := cfg.SetHeader(false, conf)
|
||||
|
||||
headers := map[string]string{
|
||||
"X-cons-id": header.ConsID,
|
||||
"X-timestamp": header.TimeStamp,
|
||||
"X-signature": header.XSignature,
|
||||
"user_key": header.UserKey,
|
||||
}
|
||||
|
||||
errTruncate := dokter.DeleteJadwalDokter()
|
||||
if errTruncate != nil {
|
||||
log.Println(errTruncate)
|
||||
return false
|
||||
}
|
||||
|
||||
errTruncateTemp := dokter.DeleteJadwalDokterTemp()
|
||||
if errTruncateTemp != nil {
|
||||
log.Println(errTruncateTemp)
|
||||
return false
|
||||
}
|
||||
tanggal := c.Param("tanggal")
|
||||
|
||||
// Select from daftar spesialis
|
||||
spesialis, err := dokter.GetSpesialis()
|
||||
if err != nil {
|
||||
return false
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
|
||||
var listIdSpesialis = make(map[string]int)
|
||||
@@ -63,7 +43,7 @@ func GetJadwalDokter() bool {
|
||||
|
||||
subspesialis, err := dokter.GetSubspesialis()
|
||||
if err != nil {
|
||||
return false
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
|
||||
var listIdSubspesialis = make(map[string]int)
|
||||
@@ -73,7 +53,7 @@ func GetJadwalDokter() bool {
|
||||
|
||||
listDokter, err := dokter.GetDokter()
|
||||
if err != nil {
|
||||
return false
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
|
||||
var listIddokter = make(map[int]string)
|
||||
@@ -82,57 +62,107 @@ func GetJadwalDokter() bool {
|
||||
}
|
||||
|
||||
var reqInsert *jadwal_dokter.JadwalDokterSatuData
|
||||
|
||||
var response []*jadwal_dokter.JadwalDokterSatuData
|
||||
for _, value := range spesialis {
|
||||
tanggal := time.Now().Format("2006-01-02")
|
||||
for i := 0; i < 7; i++ {
|
||||
kdPoly := value.Kode
|
||||
res, err := JadwalDokterGetResponse(url, header, kdPoly, tanggal, headers)
|
||||
if err != nil {
|
||||
log.Println("Error making external API request: %v", err)
|
||||
return false
|
||||
conf := config.ConfigBpjs{}
|
||||
|
||||
header := cfg.SetHeader(false, conf)
|
||||
|
||||
headers := map[string]string{
|
||||
"X-cons-id": header.ConsID,
|
||||
"X-timestamp": header.TimeStamp,
|
||||
"X-signature": header.XSignature,
|
||||
"user_key": header.UserKey,
|
||||
}
|
||||
kdPoly := value.Kode
|
||||
url := baseUrl + endpoint
|
||||
param := "/jadwaldokter/kodepoli/" + kdPoly + "/tanggal/" + tanggal
|
||||
linkurl := url + param
|
||||
res, err := JadwalDokterGetResponse(linkurl, header, headers)
|
||||
if err != nil {
|
||||
log.Println("Error making external API request: %v", err)
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
log.Println("Tanggal :", tanggal)
|
||||
if res == nil {
|
||||
log.Println("Skip Proses")
|
||||
continue
|
||||
}
|
||||
jadwalLibur, isLibur, errLibur := jadwal.GetJadwalLibur(tanggal)
|
||||
if errLibur != nil {
|
||||
log.Println(errLibur)
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
if isLibur {
|
||||
tanggalTemp, errParseTemp := time.Parse("2006-01-02", tanggal)
|
||||
if errParseTemp != nil {
|
||||
log.Println(errParseTemp)
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
date, errParse := time.Parse("2006-01-02", tanggal)
|
||||
if errParse != nil {
|
||||
return false
|
||||
isLibur = false
|
||||
log.Println(jadwalLibur.NamaLiburPelayanan)
|
||||
tanggalTemp = tanggalTemp.AddDate(0, 0, 7)
|
||||
tanggalTempString := tanggalTemp.Format("2006-01-02")
|
||||
log.Println(tanggalTempString)
|
||||
paramLibur := "/jadwaldokter/kodepoli/" + kdPoly + "/tanggal/" + tanggalTempString
|
||||
linkUrl := url + paramLibur
|
||||
resNew, errRes := JadwalDokterGetResponse(linkUrl, header, headers)
|
||||
if errRes != nil {
|
||||
log.Println("Error making external API request: ", errRes)
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
tanggal = date.AddDate(0, 0, 1).Format("2006-01-02")
|
||||
log.Println("Tanggal :", tanggal)
|
||||
if res == nil {
|
||||
log.Println("Skip Proses")
|
||||
if resNew != nil {
|
||||
for _, v := range resNew.Response {
|
||||
res.Response = append(res.Response, &jadwal_dokter.ListDokter{
|
||||
KodeSubspesialis: v.KodeSubspesialis,
|
||||
Hari: v.Hari,
|
||||
KapasitasPasien: v.KapasitasPasien,
|
||||
Libur: v.Libur,
|
||||
NamaHari: v.NamaHari,
|
||||
Jadwal: v.Jadwal,
|
||||
NamaSubspesialis: v.NamaSubspesialis,
|
||||
NamaDokter: v.NamaDokter,
|
||||
KodePoli: v.KodePoli,
|
||||
NamaPoli: v.NamaPoli,
|
||||
KodeDokter: v.KodeDokter,
|
||||
})
|
||||
}
|
||||
} else {
|
||||
log.Println("Tidak ada data pada tanggal ", tanggalTempString)
|
||||
continue
|
||||
}
|
||||
for _, v := range res.Response {
|
||||
idSpesialis := utils.KodeToIDConverter(v.KodePoli, listIdSpesialis)
|
||||
idSubspesialis := utils.KodeToIDConverter(v.KodeSubspesialis, listIdSubspesialis)
|
||||
idDokter := utils.HfisCodeToIDConverter(v.KodeDokter, listIddokter)
|
||||
reqInsert = &jadwal_dokter.JadwalDokterSatuData{
|
||||
Hari: v.Hari,
|
||||
NamaHari: v.NamaHari,
|
||||
Waktu: v.Jadwal,
|
||||
Dokter: idDokter,
|
||||
Spesialis: idSpesialis,
|
||||
SubSpesialis: idSubspesialis,
|
||||
Status: 1, // When available always set to 1
|
||||
}
|
||||
for _, v := range res.Response {
|
||||
idSpesialis := utils.KodeToIDConverter(v.KodePoli, listIdSpesialis)
|
||||
idSubspesialis := utils.KodeToIDConverter(v.KodeSubspesialis, listIdSubspesialis)
|
||||
idDokter := utils.HfisCodeToIDConverter(v.KodeDokter, listIddokter)
|
||||
reqInsert = &jadwal_dokter.JadwalDokterSatuData{
|
||||
Hari: v.Hari,
|
||||
NamaHari: v.NamaHari,
|
||||
Waktu: v.Jadwal,
|
||||
Dokter: idDokter,
|
||||
Spesialis: idSpesialis,
|
||||
SubSpesialis: idSubspesialis,
|
||||
Status: 1, // When available always set to 1
|
||||
}
|
||||
if reqInsert.Dokter != "" {
|
||||
errInsert := dokter.InsertJadwalDokter(reqInsert)
|
||||
if errInsert != nil {
|
||||
log.Println(errInsert)
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
if reqInsert.Dokter != "" {
|
||||
errInsert := dokter.InsertJadwalDokter(reqInsert)
|
||||
if errInsert != nil {
|
||||
log.Println(errInsert)
|
||||
return false
|
||||
}
|
||||
} else {
|
||||
reqInsert.Dokter = strconv.Itoa(v.KodeDokter)
|
||||
errInsertTemp := dokter.InsertJadwalDokterTemp(reqInsert)
|
||||
if errInsertTemp != nil {
|
||||
log.Println(errInsertTemp)
|
||||
return false
|
||||
}
|
||||
} else {
|
||||
reqInsert.Dokter = strconv.Itoa(v.KodeDokter)
|
||||
errInsertTemp := dokter.InsertJadwalDokterTemp(reqInsert)
|
||||
if errInsertTemp != nil {
|
||||
log.Println(errInsertTemp)
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
}
|
||||
response = append(response, reqInsert)
|
||||
}
|
||||
}
|
||||
return true
|
||||
c.JSON(http.StatusOK, response)
|
||||
}
|
||||
|
||||
func GetDokterByDPJP(c *gin.Context) {
|
||||
@@ -202,25 +232,6 @@ func GetDokterByDPJP(c *gin.Context) {
|
||||
c.JSON(http.StatusOK, res)
|
||||
}
|
||||
|
||||
func GetSpesialisByDate(c *gin.Context) {
|
||||
tanggal := c.Param("tanggal")
|
||||
date, err := time.Parse("2006-01-02", tanggal)
|
||||
if err != nil {
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
hari := date.Local().Weekday().String()
|
||||
hari = utils.ConvertDay(hari)
|
||||
idSpesialis, err := dokter.GetJadwalDokterByDate(hari)
|
||||
if err != nil {
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
listSpesialis, err := dokter.GetSpesialisByID(idSpesialis)
|
||||
if err != nil {
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
c.JSON(http.StatusOK, listSpesialis)
|
||||
}
|
||||
|
||||
func GetJadwalSubspesialisByDate(c *gin.Context) {
|
||||
tanggal := c.Param("tanggal")
|
||||
date, err := time.Parse("2006-01-02", tanggal)
|
||||
@@ -336,8 +347,6 @@ func GetDataJadwalDokter() bool {
|
||||
baseUrl := os.Getenv("BASEURL_BPJS")
|
||||
endpoint := os.Getenv("ANTREAN_RS")
|
||||
|
||||
url := baseUrl + endpoint
|
||||
log.Println("url", url)
|
||||
conf := config.ConfigBpjs{}
|
||||
|
||||
spesialis, err := dokter.GetSpesialis()
|
||||
@@ -399,7 +408,7 @@ func GetDataJadwalDokter() bool {
|
||||
headerString := strings.TrimSuffix(headerStringBuilder.String(), "; ")
|
||||
|
||||
startDate := time.Now()
|
||||
endDate := startDate.AddDate(0, 1, 0)
|
||||
endDate := startDate.AddDate(0, 3, 0)
|
||||
logTimeStart := time.Now().Format("2006-01-02 15:04:05")
|
||||
var res *jadwal_dokter.JadwalDokter
|
||||
var reqLog []*jadwal_dokter.RequestJadwalDokter
|
||||
@@ -410,7 +419,7 @@ func GetDataJadwalDokter() bool {
|
||||
log.Println("Tanggal :", tanggal)
|
||||
urlReq := url + "/tanggal/" + tanggal
|
||||
|
||||
res, err = JadwalDokterGetResponse(urlReq, header, value.Kode, tanggal, headers)
|
||||
res, err = JadwalDokterGetResponse(urlReq, header, headers)
|
||||
if err != nil {
|
||||
log.Printf("Error making external API request: %v", err)
|
||||
return err
|
||||
@@ -502,3 +511,167 @@ func GetDataJadwalDokter() bool {
|
||||
log.Println("Berhasil ambil jadwal data dokter")
|
||||
return true
|
||||
}
|
||||
|
||||
func GetJadwalDokterNew() bool {
|
||||
baseUrl := os.Getenv("BASEURL_BPJS")
|
||||
endpoint := os.Getenv("ANTREAN_RS")
|
||||
url := baseUrl + endpoint
|
||||
|
||||
errTruncate := dokter.DeleteJadwalDokter()
|
||||
if errTruncate != nil {
|
||||
log.Println(errTruncate)
|
||||
return false
|
||||
}
|
||||
|
||||
errTruncateTemp := dokter.DeleteJadwalDokterTemp()
|
||||
if errTruncateTemp != nil {
|
||||
log.Println(errTruncateTemp)
|
||||
return false
|
||||
}
|
||||
|
||||
// Select from daftar spesialis
|
||||
spesialis, err := dokter.GetSpesialis()
|
||||
if err != nil {
|
||||
return false
|
||||
}
|
||||
|
||||
var listIdSpesialis = make(map[string]int)
|
||||
for _, kodeDokter := range spesialis {
|
||||
listIdSpesialis[kodeDokter.Kode] = kodeDokter.ID
|
||||
}
|
||||
|
||||
subspesialis, err := dokter.GetSubspesialis()
|
||||
if err != nil {
|
||||
return false
|
||||
}
|
||||
|
||||
var listIdSubspesialis = make(map[string]int)
|
||||
for _, kodeDokter := range subspesialis {
|
||||
listIdSubspesialis[kodeDokter.Kode] = kodeDokter.ID
|
||||
}
|
||||
|
||||
listDokter, err := dokter.GetDokter()
|
||||
if err != nil {
|
||||
return false
|
||||
}
|
||||
|
||||
var listIddokter = make(map[int]string)
|
||||
for _, kodeDokter := range listDokter {
|
||||
listIddokter[kodeDokter.HfisCode] = kodeDokter.ID
|
||||
}
|
||||
|
||||
var reqInsert *jadwal_dokter.JadwalDokterSatuData
|
||||
|
||||
for _, value := range spesialis {
|
||||
|
||||
tanggal := time.Now().Format("2006-01-02")
|
||||
// tanggal := "2025-04-11"
|
||||
for i := 0; i < 7; i++ {
|
||||
conf := config.ConfigBpjs{}
|
||||
|
||||
header := cfg.SetHeader(false, conf)
|
||||
|
||||
headers := map[string]string{
|
||||
"X-cons-id": header.ConsID,
|
||||
"X-timestamp": header.TimeStamp,
|
||||
"X-signature": header.XSignature,
|
||||
"user_key": header.UserKey,
|
||||
}
|
||||
kdPoly := value.Kode
|
||||
param := "/jadwaldokter/kodepoli/" + kdPoly + "/tanggal/" + tanggal
|
||||
linkurl := url + param
|
||||
res, err := JadwalDokterGetResponseApi(linkurl, header, headers)
|
||||
if err != nil {
|
||||
log.Println("Error making external API request: %v", err)
|
||||
return false
|
||||
}
|
||||
date, errParse := time.Parse("2006-01-02", tanggal)
|
||||
if errParse != nil {
|
||||
return false
|
||||
}
|
||||
tanggal = date.AddDate(0, 0, 1).Format("2006-01-02")
|
||||
log.Println("Tanggal :", tanggal)
|
||||
if res == nil {
|
||||
log.Println("Skip Proses")
|
||||
continue
|
||||
}
|
||||
jadwalLibur, isLibur, errLibur := jadwal.GetJadwalLibur(tanggal)
|
||||
if errLibur != nil {
|
||||
log.Println(errLibur)
|
||||
return false
|
||||
}
|
||||
if isLibur {
|
||||
tanggalTemp, errParseTemp := time.Parse("2006-01-02", tanggal)
|
||||
if errParseTemp != nil {
|
||||
log.Println(errParseTemp)
|
||||
return false
|
||||
}
|
||||
isLibur = false
|
||||
for i := 0; i < 7; i++ {
|
||||
log.Println(jadwalLibur.NamaLiburPelayanan)
|
||||
tanggalTemp = tanggalTemp.AddDate(0, 0, 7)
|
||||
tanggalTempString := tanggalTemp.Format("2006-01-02")
|
||||
log.Println(tanggalTempString)
|
||||
paramLibur := "/jadwaldokter/kodepoli/" + kdPoly + "/tanggal/" + tanggalTempString
|
||||
linkUrl := url + paramLibur
|
||||
resNew, errRes := JadwalDokterGetResponseApi(linkUrl, header, headers)
|
||||
if errRes != nil {
|
||||
log.Println("Error making external API request: ", errRes)
|
||||
return false
|
||||
}
|
||||
if resNew != nil {
|
||||
for _, v := range resNew {
|
||||
res = append(res, &jadwal_dokter.ListDokter{
|
||||
KodeSubspesialis: v.KodeSubspesialis,
|
||||
Hari: v.Hari,
|
||||
KapasitasPasien: v.KapasitasPasien,
|
||||
Libur: v.Libur,
|
||||
NamaHari: v.NamaHari,
|
||||
Jadwal: v.Jadwal,
|
||||
NamaSubspesialis: v.NamaSubspesialis,
|
||||
NamaDokter: v.NamaDokter,
|
||||
KodePoli: v.KodePoli,
|
||||
NamaPoli: v.NamaPoli,
|
||||
KodeDokter: v.KodeDokter,
|
||||
})
|
||||
}
|
||||
log.Println("Ada data pada tanggal ", tanggalTempString)
|
||||
break
|
||||
} else {
|
||||
log.Println("Tidak ada data pada tanggal ", tanggalTempString)
|
||||
continue
|
||||
}
|
||||
}
|
||||
}
|
||||
for _, v := range res {
|
||||
idSpesialis := utils.KodeToIDConverter(v.KodePoli, listIdSpesialis)
|
||||
idSubspesialis := utils.KodeToIDConverter(v.KodeSubspesialis, listIdSubspesialis)
|
||||
idDokter := utils.HfisCodeToIDConverter(v.KodeDokter, listIddokter)
|
||||
reqInsert = &jadwal_dokter.JadwalDokterSatuData{
|
||||
Hari: v.Hari,
|
||||
NamaHari: v.NamaHari,
|
||||
Waktu: v.Jadwal,
|
||||
Dokter: idDokter,
|
||||
Spesialis: idSpesialis,
|
||||
SubSpesialis: idSubspesialis,
|
||||
Status: 1, // When available always set to 1
|
||||
}
|
||||
if reqInsert.Dokter != "" {
|
||||
errInsert := dokter.InsertJadwalDokter(reqInsert)
|
||||
if errInsert != nil {
|
||||
log.Println(errInsert)
|
||||
return false
|
||||
}
|
||||
} else {
|
||||
reqInsert.Dokter = strconv.Itoa(v.KodeDokter)
|
||||
errInsertTemp := dokter.InsertJadwalDokterTemp(reqInsert)
|
||||
if errInsertTemp != nil {
|
||||
log.Println(errInsertTemp)
|
||||
return false
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return true
|
||||
}
|
||||
@@ -11,7 +11,7 @@ import (
|
||||
"net/http"
|
||||
)
|
||||
|
||||
func JadwalDokterGetResponse(url string, header *config.Header, kdPoly string, tanggal string, headers map[string]string) (*jadwal_dokter.JadwalDokter, error) {
|
||||
func JadwalDokterGetResponse(url string, header *config.Header, headers map[string]string) (*jadwal_dokter.JadwalDokter, error) {
|
||||
log.Println("URL", url)
|
||||
req, err := http.NewRequest("GET", url, nil)
|
||||
if err != nil {
|
||||
@@ -72,3 +72,58 @@ func JadwalDokterGetResponse(url string, header *config.Header, kdPoly string, t
|
||||
|
||||
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
|
||||
}
|
||||
@@ -35,7 +35,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
err := c.Bind(&req)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: err.Error(),
|
||||
@@ -43,11 +43,12 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
})
|
||||
return
|
||||
}
|
||||
log.Println(req)
|
||||
|
||||
jadwalLibur, isLibur, errLibur := jadwal.GetJadwalLibur(req.TglRencanaKontrol)
|
||||
if errLibur != nil {
|
||||
log.Println(errLibur)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: errLibur.Error(),
|
||||
@@ -56,7 +57,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
return
|
||||
} else if isLibur {
|
||||
log.Println(jadwalLibur.KeteranganLiburPelayanan)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: jadwalLibur.NamaLiburPelayanan,
|
||||
@@ -68,7 +69,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
reqJson, err := json.Marshal(req)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: err.Error(),
|
||||
@@ -101,7 +102,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
kunjunganPasien, err := suratkontrol.GetDataKunjunganPasien(req.IDXDaftar)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: err.Error(),
|
||||
@@ -117,7 +118,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
idRuangan, err = lokasiruang.GetDaftarLokasiRuang(req.Ruangan)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusInternalServerError, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: err.Error(),
|
||||
@@ -265,7 +266,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
responJson, err := json.Marshal(res)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: err.Error(),
|
||||
@@ -292,7 +293,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
err = suratkontrol.InsertDataSuratKontrol(reqInsert)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: err.Error(),
|
||||
@@ -310,7 +311,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
err = suratkontrol.UpdateKunjunganPasien(req)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: err.Error(),
|
||||
@@ -339,7 +340,7 @@ func InsertSuratKontrol(c *gin.Context) {
|
||||
err = log_api.InsertLogAPI(reqInsertLog)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusPreconditionFailed, &sk.ResponseInsertSuratKontrol{
|
||||
c.JSON(http.StatusOK, &sk.ResponseInsertSuratKontrol{
|
||||
MetaData: sk.MetadataString{
|
||||
Code: "203",
|
||||
Message: err.Error(),
|
||||
@@ -450,6 +451,7 @@ func UpdateSuratKontrol(c *gin.Context) {
|
||||
StatusSurKon: 1, // First Insert status always set to 1
|
||||
TipeSurKon: req.TipeSurKon,
|
||||
UserUpdatedSurKon: req.User,
|
||||
TipeRawat: req.TipeRawat,
|
||||
}
|
||||
reqUpdate := &sk.DataSuratKontrol{
|
||||
DateUpdated: timeNow,
|
||||
@@ -1196,3 +1198,45 @@ func CariPasienTPP(c *gin.Context) {
|
||||
}
|
||||
c.JSON(http.StatusOK, resSurKon)
|
||||
}
|
||||
|
||||
func GethistoribyNorm(c *gin.Context) {
|
||||
norm := c.Param("norm")
|
||||
offset := c.Param("offset")
|
||||
limit := c.Param("limit")
|
||||
data, err := suratkontrol.Getdatahistori(norm, offset, limit)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
c.JSON(http.StatusInternalServerError, &sk.MetadataString{
|
||||
Code: "",
|
||||
Message: err.Error(),
|
||||
})
|
||||
return
|
||||
}
|
||||
var resHisSurKon []*sk.Dataresponse
|
||||
for _, v := range data {
|
||||
gelarDepan := utils.ReplaceGelar(v.GelarDepan)
|
||||
gelarBelakang := utils.ReplaceGelar(v.GelarBelakang)
|
||||
namaLengkap := gelarDepan + " " + v.NamaDokter + " " + gelarBelakang
|
||||
namaLengkap = strings.TrimPrefix(namaLengkap, " ")
|
||||
namaLengkap = strings.TrimSuffix(namaLengkap, " ")
|
||||
dateCetakSurkon, _ := time.Parse(time.RFC3339, v.TanggalCetak)
|
||||
dateCetakSurkonString := dateCetakSurkon.Format("2006-01-02")
|
||||
dateRencanaSurkon, _ := time.Parse(time.RFC3339, v.TanggalRencana)
|
||||
dateRencanaSurkonString := dateRencanaSurkon.Format("2006-01-02")
|
||||
resHisSurKon = append(resHisSurKon, &sk.Dataresponse{
|
||||
NamaPasien: v.NamaPasien,
|
||||
NoSEP: v.NoSEP,
|
||||
NomorSuratkontrol: v.NomorSuratkontrol,
|
||||
TanggalRencana: dateRencanaSurkonString,
|
||||
TanggalCetak: dateCetakSurkonString,
|
||||
Spesialis: v.Spesialis,
|
||||
Subspesialis: v.Subspesialis,
|
||||
NamaLengkap: namaLengkap,
|
||||
Tiperawat: v.Tiperawat,
|
||||
UserCreate: v.UserCreate,
|
||||
UserUpdate: v.UserUpdate,
|
||||
Status: v.Status,
|
||||
})
|
||||
}
|
||||
c.JSON(http.StatusOK, resHisSurKon)
|
||||
}
|
||||
@@ -38,18 +38,20 @@ func main() {
|
||||
|
||||
defer scheduler.Stop()
|
||||
|
||||
//scheduler.AddFunc("0 2 * * *", func() {
|
||||
// log.Println("=== RUNNING SCHEDULE GET JADWAL DOKTER ===")
|
||||
// for {
|
||||
// success := jadwal_dokter.GetJadwalDokter()
|
||||
// if success {
|
||||
// log.Println("=== SCHEDULE GET JADWAL DOKTER DONE ===")
|
||||
// break
|
||||
// }
|
||||
// }
|
||||
//})
|
||||
// SCHEDULE HARIAN
|
||||
scheduler.AddFunc("15 2 * * *", func() {
|
||||
log.Println("=== RUNNING SCHEDULE GET JADWAL DOKTER ===")
|
||||
for {
|
||||
success := jadwal_dokter.GetJadwalDokterNew()
|
||||
if success {
|
||||
log.Println("=== SCHEDULE GET JADWAL DOKTER DONE ===")
|
||||
break
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
scheduler.AddFunc("10 2 8 * *", func() {
|
||||
//SCHEDULE TIAP 3 BULAN
|
||||
scheduler.AddFunc("20 2 * * 5", func() {
|
||||
log.Println("=== RUNNING SCHEDULE GET JADWAL DOKTER MONTHLY===")
|
||||
for {
|
||||
success := jadwal_dokter.GetDataJadwalDokter()
|
||||
@@ -69,16 +71,17 @@ func main() {
|
||||
subspesialis.GET("/", bpjs.GetAllSubspesialis)
|
||||
}
|
||||
|
||||
//API UNTUK JADWAL DOKTER
|
||||
jadwalDokter := v1.Group("/jadwaldokter")
|
||||
{
|
||||
// jadwalDokter.GET("/", jadwal_dokter.GetJadwalDokter)
|
||||
jadwalDokter.GET("/date/:tanggal", jadwal_dokter.GetJadwalDokter)
|
||||
jadwalDokter.GET("/dpjp/:dpjp", jadwal_dokter.GetDokterByDPJP)
|
||||
// jadwalDokter.GET("/tanggal/:tanggal", jadwal_dokter.GetSpesialisByDate)
|
||||
jadwalDokter.GET("/tanggal/:tanggal", jadwal_dokter.GetJadwalSubspesialisByDate)
|
||||
jadwalDokter.GET("/tanggal/:tanggal/spesialis/:spesialis", jadwal_dokter.GetDokterBySpesialis)
|
||||
jadwalDokter.GET("/tanggal/:tanggal/subspesialis/:subspesialis", jadwal_dokter.GetDokterBySubspesialis)
|
||||
}
|
||||
|
||||
// API UNTUK SURAT KONTROL
|
||||
suratKontrol := v1.Group("/suratkontrol")
|
||||
{
|
||||
suratKontrol.GET("/offset/:offset/limit/:limit", suratkontrol.GetDataSurKon)
|
||||
@@ -90,6 +93,7 @@ func main() {
|
||||
suratKontrol.POST("/insert", suratkontrol.InsertSuratKontrol)
|
||||
suratKontrol.PUT("/update", suratkontrol.UpdateSuratKontrol)
|
||||
suratKontrol.POST("/delete", suratkontrol.DeleteSuratKontrol)
|
||||
suratKontrol.GET("/norm/:norm/limit/:limit/offset/:offset", suratkontrol.GethistoribyNorm)
|
||||
}
|
||||
|
||||
iCare := v1.Group("/icare")
|
||||
|
||||
@@ -298,3 +298,35 @@ type RequestCariPasien struct {
|
||||
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"`
|
||||
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"`
|
||||
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"`
|
||||
}
|
||||
Reference in New Issue
Block a user