diff --git a/cmd/main-api/config.yml-example b/cmd/main-api/config.yml-example index f131a725..60b1644c 100644 --- a/cmd/main-api/config.yml-example +++ b/cmd/main-api/config.yml-example @@ -63,4 +63,7 @@ bpjsCfg: corsCfg: allowedOrigins: - http://example.com - allowedMethod: \ No newline at end of file + allowedMethod: + +bpjsCfg: + baseUrl: \ No newline at end of file diff --git a/internal/domain/main-entities/patient/dto.go b/internal/domain/main-entities/patient/dto.go index abe3b46b..1190ce22 100644 --- a/internal/domain/main-entities/patient/dto.go +++ b/internal/domain/main-entities/patient/dto.go @@ -14,7 +14,7 @@ import ( erc "simrs-vx/internal/domain/references/common" ere "simrs-vx/internal/domain/references/encounter" - pa "simrs-vx/pkg/auth-helper" + pa "simrs-vx/internal/lib/auth" ) type CreateDto struct { diff --git a/internal/interface/main-handler/main-handler.go b/internal/interface/main-handler/main-handler.go index b2c78cb5..bedf3b71 100644 --- a/internal/interface/main-handler/main-handler.go +++ b/internal/interface/main-handler/main-handler.go @@ -50,6 +50,7 @@ import ( hk "github.com/karincake/hongkue" /******************** infra ********************/ + ibpjs "simrs-vx/internal/infra/bpjs" gs "simrs-vx/internal/infra/gorm-setting" minio "simrs-vx/internal/infra/minio" ssdb "simrs-vx/internal/infra/ss-db" @@ -118,6 +119,7 @@ func SetRoutes() http.Handler { a.RegisterExtCall(lh.Populate) a.RegisterExtCall(minio.Connect) a.RegisterExtCall(mh.I.SetClient) + a.RegisterExtCall(ibpjs.SetConfig) a.RegisterExtCall(validation.RegisterValidation) r := http.NewServeMux() diff --git a/internal/lib/auth/auth.go b/internal/lib/auth/auth.go index 934d8d61..3efa980f 100644 --- a/internal/lib/auth/auth.go +++ b/internal/lib/auth/auth.go @@ -1,4 +1,4 @@ -package authhelper +package auth import ( "errors" diff --git a/internal/lib/auth/tycovar.go b/internal/lib/auth/tycovar.go index 654115fc..881a9072 100644 --- a/internal/lib/auth/tycovar.go +++ b/internal/lib/auth/tycovar.go @@ -1,4 +1,4 @@ -package authhelper +package auth import ( ero "simrs-vx/internal/domain/references/organization" diff --git a/internal/use-case/bpjs-use-case/vclaim-member/case.go b/internal/use-case/bpjs-use-case/vclaim-member/case.go index 7c572f5e..14c6aaff 100644 --- a/internal/use-case/bpjs-use-case/vclaim-member/case.go +++ b/internal/use-case/bpjs-use-case/vclaim-member/case.go @@ -303,10 +303,17 @@ func Delete(input e.DeleteDto) (*d.Data, error) { // return err // } -// if err := CreateOrUpdateData(input, data, &event, tx); err != nil { +// if data.Person_Id == input.Person_Id { +// return nil +// } +// if err := UpdateData(e.UpdateDto{CreateDto: input}, data, &event, tx); err != nil { // return err // } +// // if err := CreateOrUpdateData(input, data, &event, tx); err != nil { +// // return err +// // } + // pl.SetLogInfo(&event, nil, "complete") // mwRunner.setMwType(pu.MWTPost) diff --git a/internal/use-case/bpjs-use-case/vclaim-member/lib.go b/internal/use-case/bpjs-use-case/vclaim-member/lib.go index 9044664d..3c477298 100644 --- a/internal/use-case/bpjs-use-case/vclaim-member/lib.go +++ b/internal/use-case/bpjs-use-case/vclaim-member/lib.go @@ -145,3 +145,35 @@ func DeleteData(data *e.VclaimMember, event *pl.Event, dbx ...*gorm.DB) error { pl.SetLogInfo(event, nil, "complete") return nil } + +func CreateOrUpdateData(input e.CreateDto, event *pl.Event, dbx ...*gorm.DB) error { + pl.SetLogInfo(event, nil, "started", "createOrUpdateData") + + var tx *gorm.DB + if len(dbx) > 0 { + tx = dbx[0] + } else { + tx = dg.I + } + + data, err := ReadDetailData(e.ReadDetailDto{CardNumber: input.CardNumber}, event, tx) + if err != nil { + if !pu.IsDataNotFoundError(err) { + return err + } + } + + if data == nil { + if _, err := CreateData(input, event, tx); err != nil { + return err + } + } else { + if err := UpdateData(e.UpdateDto{CreateDto: input}, data, event, tx); err != nil { + return err + } + } + + pl.SetLogInfo(event, nil, "complete") + return nil + +} diff --git a/internal/use-case/main-use-case/patient/case.go b/internal/use-case/main-use-case/patient/case.go index b52215ac..cee92a77 100644 --- a/internal/use-case/main-use-case/patient/case.go +++ b/internal/use-case/main-use-case/patient/case.go @@ -4,8 +4,10 @@ import ( "errors" "strconv" + evm "simrs-vx/internal/domain/bpjs-entities/vclaim-member" e "simrs-vx/internal/domain/main-entities/patient" + uvm "simrs-vx/internal/use-case/bpjs-use-case/vclaim-member" upe "simrs-vx/internal/use-case/main-use-case/person" upa "simrs-vx/internal/use-case/main-use-case/person-address" upc "simrs-vx/internal/use-case/main-use-case/person-contact" @@ -49,6 +51,12 @@ func Create(input e.CreateDto) (*d.Data, error) { input.Person_Id = person_id } + if input.Person.VclaimMember_CardNumber != nil && input.Person.ResidentIdentityNumber != nil { + if err := uvm.CreateOrUpdateData(evm.CreateDto{CardNumber: input.Person.VclaimMember_CardNumber, Person_Id: input.Person_Id}, &event, tx); err != nil { + return err + } + } + for idx := range input.PersonAddresses { input.PersonAddresses[idx].Person_Id = *input.Person_Id } diff --git a/internal/use-case/main-use-case/patient/helper.go b/internal/use-case/main-use-case/patient/helper.go index 8abfeaf3..aac8d677 100644 --- a/internal/use-case/main-use-case/patient/helper.go +++ b/internal/use-case/main-use-case/patient/helper.go @@ -12,6 +12,7 @@ import ( "time" e "simrs-vx/internal/domain/main-entities/patient" + ibpjs "simrs-vx/internal/infra/bpjs" pl "simrs-vx/pkg/logger" pmh "simrs-vx/pkg/minio-helper" @@ -135,3 +136,13 @@ func removeUploadedFile(bucket, fileUrl string, event *pl.Event) error { pl.SetLogInfo(event, nil, "complete") return nil } + +func endpointMapper(noBpjs string) string { + today := getTodayDate() + return fmt.Sprintf("%speserta/nokartu?noKartu=%s&tglpelayanan=%s", ibpjs.O.BaseUrl, noBpjs, today) + +} + +func getTodayDate() string { + return time.Now().Format("2006-01-02") +} diff --git a/internal/use-case/main-use-case/patient/middleware.go b/internal/use-case/main-use-case/patient/middleware.go index 5fe75e0a..6b0175dc 100644 --- a/internal/use-case/main-use-case/patient/middleware.go +++ b/internal/use-case/main-use-case/patient/middleware.go @@ -1,9 +1,65 @@ package patient +import ( + "encoding/json" + "fmt" + "io" + "net/http" + + e "simrs-vx/internal/domain/main-entities/patient" + + "gorm.io/gorm" +) + // example of middleware -// func init() { -// createPreMw = append(createPreMw, -// CreateMw{Name: "modif-input", Func: pm.ModifInput}, -// CreateMw{Name: "check-data", Func: pm.CheckData}, -// ) -// } +func init() { + createPreMw = append(createPreMw, + createMw{Name: "check-vclaim-member", Func: checkVclaimMember}, + ) +} + +func checkVclaimMember(input *e.CreateDto, data *e.Patient, tx *gorm.DB) error { + if input.Person.VclaimMember_CardNumber != nil && input.Person.ResidentIdentityNumber != nil { + return isVclaimMemberMatch(input) + } + return nil +} + +func isVclaimMemberMatch(input *e.CreateDto) error { + endpoint := endpointMapper(*input.Person.VclaimMember_CardNumber) + req, err := http.NewRequest("GET", endpoint, nil) + if err != nil { + return err + } + req.Header.Set("Content-Type", "application/json") + + resp, err := http.DefaultClient.Do(req) + if err != nil { + return err + } + defer resp.Body.Close() + + body, err := io.ReadAll(resp.Body) + if err != nil { + return err + } + + var data BPJSResponse + + if err := json.Unmarshal(body, &data); err != nil { + return fmt.Errorf("failed to parse response JSON: %w", err) + } + + if data.MetaData.Code != "200" { + return fmt.Errorf("failed to get vclaim member: %s", data.MetaData.Message) + } + + if data.Response.Peserta.NoKartu == "" || data.Response.Peserta.NIK == "" { + return fmt.Errorf("failed to get vclaim member: noKartu or nik is empty") + } + + if data.Response.Peserta.NIK != *input.Person.ResidentIdentityNumber { + return fmt.Errorf("nik(residentIdentityNumber) is not match with bpjs number(vclaimMember_cardNumber)") + } + return nil +} diff --git a/internal/use-case/main-use-case/patient/tycovar.go b/internal/use-case/main-use-case/patient/tycovar.go index d7e9abfe..29e5c368 100644 --- a/internal/use-case/main-use-case/patient/tycovar.go +++ b/internal/use-case/main-use-case/patient/tycovar.go @@ -42,3 +42,16 @@ var updatePreMw []readDetailMw var updatePostMw []readDetailMw var deletePreMw []readDetailMw var deletePostMw []readDetailMw + +type BPJSResponse struct { + MetaData struct { + Code string `json:"code"` + Message string `json:"message"` + } `json:"metaData"` + Response *struct { + Peserta struct { + NoKartu string `json:"noKartu"` + NIK string `json:"nik"` + } `json:"peserta"` + } `json:"response"` +} diff --git a/pkg/use-case-helper/use-case-helper.go b/pkg/use-case-helper/use-case-helper.go index 8c41266f..0df8fe3e 100644 --- a/pkg/use-case-helper/use-case-helper.go +++ b/pkg/use-case-helper/use-case-helper.go @@ -97,7 +97,7 @@ func HandleMiddlewareError(event *pl.Event, mwType, mwName string, logData inter event.Status = "failed" event.ErrInfo = pl.ErrorInfo{ Code: GetMiddlewareErrorCode(MWType(mwType)), - Detail: fmt.Sprintf("%s middleware %s failed", mwType, mwName), + Detail: fmt.Sprintf("%s middleware %s failed: %s", mwType, mwName, err.Error()), Raw: err, } return pl.SetLogError(event, logData)