udpate code
This commit is contained in:
@@ -1,55 +0,0 @@
|
||||
package bpjs
|
||||
|
||||
import (
|
||||
"bridging-rssa/docs"
|
||||
"bridging-rssa/models/jadwal_dokter"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"io"
|
||||
"log"
|
||||
"net/http"
|
||||
|
||||
lzstring "github.com/daku10/go-lz-string"
|
||||
)
|
||||
|
||||
func BPJSGetResponse(url string, secretKey string, cons_id string, User_keys string, tstamp string, X_signature string, kdPoly string, tanggal string, headers map[string]string) (string, error) {
|
||||
param := "/jadwaldokter/kodepoli/" + kdPoly + "/tanggal/" + tanggal
|
||||
url += param
|
||||
log.Println("URL", url)
|
||||
req, err := http.NewRequest("GET", url, nil)
|
||||
if err != nil {
|
||||
log.Fatalf("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.Fatalf("Error making external API request: %v", err)
|
||||
}
|
||||
log.Println("RESPONSE: ", response)
|
||||
|
||||
key := cons_id + secretKey + tstamp
|
||||
res, err := io.ReadAll(response.Body)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
|
||||
var jadwalDokter jadwal_dokter.JadwalDokter
|
||||
err = json.Unmarshal([]byte(res), &jadwalDokter)
|
||||
if err != nil {
|
||||
log.Fatalf("Error Unmarshaling: %v", err)
|
||||
}
|
||||
log.Println("RESPONSE DATA", jadwalDokter.Response)
|
||||
dataResp, err := lzstring.DecompressFromEncodedURIComponent((docs.StringDecrypt(key, jadwalDokter.Response)))
|
||||
if err != nil {
|
||||
log.Fatalf("Error Decrypt: %v", err)
|
||||
}
|
||||
log.Println("res: ", dataResp)
|
||||
|
||||
return string(res), nil
|
||||
}
|
||||
64
handlers/bpjs/jadwal_dokter/jadwal_dokter.go
Normal file
64
handlers/bpjs/jadwal_dokter/jadwal_dokter.go
Normal file
@@ -0,0 +1,64 @@
|
||||
package jadwal_dokter
|
||||
|
||||
import (
|
||||
cfg "bridging-rssa/config"
|
||||
"bridging-rssa/database/satu_data/dokter"
|
||||
"bridging-rssa/models/bpjs/jadwal_dokter"
|
||||
"bridging-rssa/models/config"
|
||||
"log"
|
||||
"net/http"
|
||||
"os"
|
||||
"time"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
)
|
||||
|
||||
func GetJadwalDokter(c *gin.Context) {
|
||||
baseUrl := os.Getenv("BASEURL_BPJS")
|
||||
endpoint := os.Getenv("ANTREAN_RS")
|
||||
url := baseUrl + endpoint
|
||||
|
||||
// Select from daftar spesialis
|
||||
spesialis, err := dokter.GetSpesialis()
|
||||
if err != nil {
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
|
||||
|
||||
|
||||
conf := config.ConfigBpjs{}
|
||||
|
||||
cons_id, secretKey, User_key, tstamp, X_signature := cfg.SetHeader(conf)
|
||||
|
||||
headers := map[string]string{
|
||||
"X-cons-id": cons_id,
|
||||
"X-timestamp": tstamp,
|
||||
"X-signature": X_signature,
|
||||
"user_key": User_key,
|
||||
}
|
||||
var res *[]jadwal_dokter.ListDokter
|
||||
log.Println("Headers : ", headers)
|
||||
tanggal := time.Now().Format("2006-01-02")
|
||||
for _, value := range *spesialis {
|
||||
for i := 0; i < 7; i++ {
|
||||
kdPoly := value.Kode
|
||||
res, err = JadwalDokterGetResponse(url, secretKey, cons_id, User_key, tstamp, X_signature, kdPoly, tanggal, headers)
|
||||
if err != nil {
|
||||
log.Fatalf("Error making external API request: %v", err)
|
||||
c.JSON(http.StatusInternalServerError, err)
|
||||
}
|
||||
|
||||
for _, key := range *res {
|
||||
key.KodeDokter
|
||||
}
|
||||
|
||||
date, errParse := time.Parse("2006-01-02", tanggal)
|
||||
if errParse != nil {
|
||||
c.JSON(http.StatusInternalServerError, errParse)
|
||||
}
|
||||
tanggal = date.AddDate(0, 0, 1).Format("2006-01-02")
|
||||
}
|
||||
}
|
||||
|
||||
c.JSON(http.StatusOK, res)
|
||||
}
|
||||
66
handlers/bpjs/jadwal_dokter/response.go
Normal file
66
handlers/bpjs/jadwal_dokter/response.go
Normal file
@@ -0,0 +1,66 @@
|
||||
package jadwal_dokter
|
||||
|
||||
import (
|
||||
"bridging-rssa/docs"
|
||||
"bridging-rssa/models/bpjs/jadwal_dokter"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"io"
|
||||
"log"
|
||||
"net/http"
|
||||
)
|
||||
|
||||
func JadwalDokterGetResponse(url string, secretKey string, cons_id string, User_keys string, tstamp string, X_signature string, kdPoly string, tanggal string, headers map[string]string) (*[]jadwal_dokter.ListDokter, error) {
|
||||
param := "/jadwaldokter/kodepoli/" + kdPoly + "/tanggal/" + tanggal
|
||||
url += param
|
||||
log.Println("URL", url)
|
||||
req, err := http.NewRequest("GET", url, nil)
|
||||
if err != nil {
|
||||
log.Fatalf("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.Fatalf("Error making external API request: %v", err)
|
||||
}
|
||||
log.Println("RESPONSE: ", response)
|
||||
|
||||
key := cons_id + secretKey + tstamp
|
||||
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.Fatalf("Error Unmarshaling: %v", err)
|
||||
}
|
||||
|
||||
dataResp, err := docs.StringDecrypt(key, jadwalDokterRaw.Response)
|
||||
if err != nil {
|
||||
log.Fatalf("Error Decrypt: %v", err)
|
||||
log.Println("res: ", dataResp)
|
||||
|
||||
}
|
||||
|
||||
var listDokter []jadwal_dokter.ListDokter
|
||||
|
||||
log.Println("dataresp: ", dataResp)
|
||||
|
||||
// err = mapstructure.Decode(dataResp, &listDokter)
|
||||
err = json.Unmarshal([]byte(dataResp), &listDokter)
|
||||
if err != nil {
|
||||
log.Fatalf("Error Decode: %v", err)
|
||||
}
|
||||
|
||||
log.Println("res: ", &listDokter)
|
||||
|
||||
return &listDokter, nil
|
||||
}
|
||||
@@ -1,24 +1,24 @@
|
||||
package bpjs
|
||||
|
||||
import (
|
||||
"bridging-rssa/database"
|
||||
"bridging-rssa/models/dokter"
|
||||
"net/http"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
"gorm.io/gorm"
|
||||
)
|
||||
|
||||
func GetAllSubspesialis(c *gin.Context) {
|
||||
var subspesialis []dokter.DaftarSubspesialis
|
||||
result := database.SatuDataDB.Debug().Raw(`SELECT * FROM "daftar_subspesialis"`).Find(&subspesialis)
|
||||
if result.Error != nil {
|
||||
if result.Error == gorm.ErrRecordNotFound {
|
||||
c.JSON(http.StatusNotFound, result.Error)
|
||||
} else {
|
||||
c.JSON(http.StatusInternalServerError, result.Error)
|
||||
}
|
||||
return
|
||||
}
|
||||
c.JSON(http.StatusOK, subspesialis)
|
||||
}
|
||||
package bpjs
|
||||
|
||||
import (
|
||||
"bridging-rssa/config"
|
||||
"bridging-rssa/models/dokter"
|
||||
"net/http"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
"gorm.io/gorm"
|
||||
)
|
||||
|
||||
func GetAllSubspesialis(c *gin.Context) {
|
||||
var subspesialis []dokter.DaftarSubspesialis
|
||||
result := config.SatuDataDB.Debug().Raw(`SELECT * FROM "daftar_subspesialis"`).Find(&subspesialis)
|
||||
if result.Error != nil {
|
||||
if result.Error == gorm.ErrRecordNotFound {
|
||||
c.JSON(http.StatusNotFound, result.Error)
|
||||
} else {
|
||||
c.JSON(http.StatusInternalServerError, result.Error)
|
||||
}
|
||||
return
|
||||
}
|
||||
c.JSON(http.StatusOK, subspesialis)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user