feat (patient): now also create vclaim member + hit bpjs service

cmd/main-api/config.yml-example

@@ -63,4 +63,7 @@ bpjsCfg:
 corsCfg:
   allowedOrigins:
     - http://example.com
-  allowedMethod: 
+  allowedMethod: 
+
+bpjsCfg:
+  baseUrl:

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 {

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()

internal/lib/auth/auth.go

@@ -1,4 +1,4 @@
-package authhelper
+package auth
 
 import (
 	"errors"

internal/lib/auth/tycovar.go

@@ -1,4 +1,4 @@
-package authhelper
+package auth
 
 import (
 	ero "simrs-vx/internal/domain/references/organization"

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)

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
+
+}

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
 		}

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")
+}

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
+}

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"`
+}

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)