feat (vclaim-sep): create, read, delete done

internal/use-case/bpjs-plugin/vclaim-sep/plugin.go

@@ -14,7 +14,11 @@ import (
 )
 
 func CreateSep(input *e.CreateDto, data *e.VclaimSep, tx *gorm.DB) error {
-	req, err := http.NewRequest("POST", ibpjs.O.BaseUrl+"/sep", bytes.NewReader(input.RequestPayload))
+	payload, err := input.RequestPayloadIntoJson()
+	if err != nil {
+		return err
+	}
+	req, err := http.NewRequest("POST", ibpjs.O.BaseUrl+"sep", bytes.NewBuffer(payload))
 	if err != nil {
 		return err
 	}
@@ -43,7 +47,11 @@ func CreateSep(input *e.CreateDto, data *e.VclaimSep, tx *gorm.DB) error {
 	}
 
 	// Save request/response details in DTO for further use
-	input.VclaimSepHist.RequestPayload = string(input.RequestPayload)
+	reqPayload, err := input.RequestPayloadWithEncounterId()
+	if err != nil {
+		return err
+	}
+	input.VclaimSepHist.RequestPayload = string(reqPayload)
 	input.VclaimSepHist.ResponseBody = string(body)
 	input.VclaimSepHist.Message = msg
 	input.Number = func() *string {
@@ -56,3 +64,72 @@ func CreateSep(input *e.CreateDto, data *e.VclaimSep, tx *gorm.DB) error {
 
 	return nil
 }
+
+func ReadDetailSep(input *e.ReadDetailDto, data *e.VclaimSep, tx *gorm.DB) error {
+	endpoint := fmt.Sprintf("sep/%s", *data.Number)
+	req, err := http.NewRequest("GET", ibpjs.O.BaseUrl+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 detail e.SepResponse
+	if err := json.Unmarshal(body, &detail); err != nil {
+		return fmt.Errorf("failed to parse response JSON: %w", err)
+	}
+
+	data.Detail = detail.Response
+
+	return nil
+}
+
+func DeleteSep(input *e.DeleteDto, data *e.VclaimSep, tx *gorm.DB) error {
+	payload := e.SepDeleteRequest{}
+	payload.Request.TSep.NoSep = *data.Number
+	payload.Request.TSep.User = "Coba Ws"
+
+	jsonPayload, err := json.Marshal(payload)
+	if err != nil {
+		return err
+	}
+
+	req, err := http.NewRequest("DELETE", ibpjs.O.BaseUrl+"sep", bytes.NewBuffer(jsonPayload))
+	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 detail e.SepResponse
+	if err := json.Unmarshal(body, &detail); err != nil {
+		return fmt.Errorf("failed to parse response JSON: %w", err)
+	}
+
+	if detail.MetaData.Message == SepNotFound {
+		return fmt.Errorf("sep with number %s not found", *data.Number)
+	}
+
+	return nil
+}

internal/use-case/bpjs-plugin/vclaim-sep/tycovar.go

@@ -10,3 +10,5 @@ type vclaimResponse struct {
 		} `json:"sep"`
 	} `json:"response"`
 }
+
+const SepNotFound = "Data Tidak Ditemukan"

internal/use-case/bpjs-use-case/vclaim-sep/case.go

@@ -1,6 +1,7 @@
 package vclaimsep
 
 import (
+	"fmt"
 	"strconv"
 
 	e "simrs-vx/internal/domain/bpjs-entities/vclaim-sep"
@@ -31,6 +32,17 @@ func Create(input e.CreateDto) (*d.Data, error) {
 	pl.SetLogInfo(&event, input, "started", "create")
 
 	err := dg.I.Transaction(func(tx *gorm.DB) error {
+		rDto := e.ReadDetailDto{Encounter_Id: input.Encounter_Id}
+		if vSep, err := ReadDetailData(rDto, &event, tx); err != nil {
+			if !pu.IsDataNotFoundError(err) {
+				return err
+			}
+
+			if vSep != nil {
+				return fmt.Errorf("sep with encounter id %d already exist with number %s", input.Encounter_Id, *vSep.Number)
+			}
+		}
+
 		mwRunner := newMiddlewareRunner(&event, tx)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
@@ -38,12 +50,12 @@ func Create(input e.CreateDto) (*d.Data, error) {
 			return err
 		}
 
-		if _, err := uvsh.CreateData(input.VclaimSepHist, &event, tx); err != nil {
+		if _, err := uvsh.CreateData(input.VclaimSepHist, &event); err != nil {
 			return err
 		}
 
 		if !input.IsMessageSuccess() {
-			return nil
+			return fmt.Errorf("%s", input.VclaimSepHist.Message)
 		}
 
 		if resData, err := CreateData(input, &event, tx); err != nil {
@@ -234,7 +246,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
 }
 
 func Delete(input e.DeleteDto) (*d.Data, error) {
-	rdDto := e.ReadDetailDto{Number: input.Number}
+	rdDto := e.ReadDetailDto{Id: input.Id}
 	var data *e.VclaimSep
 	var err error
 
@@ -255,7 +267,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 		mwRunner := newMiddlewareRunner(&event, tx)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
-		if err := mwRunner.RunDeleteMiddleware(readDetailPreMw, &rdDto, data); err != nil {
+		if err := mwRunner.RunDeleteMiddleware(deletePreMw, &e.DeleteDto{}, data); err != nil {
 			return err
 		}
 
@@ -265,7 +277,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 
 		mwRunner.setMwType(pu.MWTPost)
 		// Run post-middleware
-		if err := mwRunner.RunDeleteMiddleware(readDetailPostMw, &rdDto, data); err != nil {
+		if err := mwRunner.RunDeleteMiddleware(deletePostMw, &e.DeleteDto{}, data); err != nil {
 			return err
 		}
 

internal/use-case/bpjs-use-case/vclaim-sep/lib.go

@@ -87,6 +87,9 @@ func ReadDetailData(input e.ReadDetailDto, event *pl.Event, dbx ...*gorm.DB) (*e
 	if input.Id != 0 {
 		tx = tx.Where("\"Id\" = ?", input.Id)
 	}
+	if input.Encounter_Id != nil {
+		tx = tx.Where("\"Encounter_Id\" = ?", *input.Encounter_Id)
+	}
 
 	if err := tx.First(&data).Error; err != nil {
 		if processedErr := pu.HandleReadError(err, event, source, input.Id, data); processedErr != nil {

internal/use-case/bpjs-use-case/vclaim-sep/middleware-runner.go

@@ -83,7 +83,7 @@ func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, inpu
 	return nil
 }
 
-func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.VclaimSep) error {
+func (me *middlewareRunner) RunDeleteMiddleware(middlewares []deleteMw, input *e.DeleteDto, data *e.VclaimSep) error {
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, data)
 

internal/use-case/bpjs-use-case/vclaim-sep/middleware.go

@@ -9,5 +9,10 @@ func init() {
 	createPreMw = append(createPreMw,
 		createMw{Name: "create-sep", Func: pvs.CreateSep},
 	)
-
+	readDetailPostMw = append(readDetailPostMw,
+		readDetailMw{Name: "read-detail-sep", Func: pvs.ReadDetailSep},
+	)
+	deletePreMw = append(deletePreMw,
+		deleteMw{Name: "delete-sep", Func: pvs.DeleteSep},
+	)
 }

internal/use-case/bpjs-use-case/vclaim-sep/tycovar.go

@@ -29,8 +29,12 @@ type readDetailMw struct {
 	Func func(input *e.ReadDetailDto, data *e.VclaimSep, tx *gorm.DB) error
 }
 
+type deleteMw struct {
+	Name string
+	Func func(input *e.DeleteDto, data *e.VclaimSep, tx *gorm.DB) error
+}
+
 type UpdateMw = readDetailMw
-type DeleteMw = readDetailMw
 
 var createPreMw []createMw      // preprocess middleware
 var createPostMw []createMw     // postprocess middleware
@@ -40,5 +44,5 @@ var readDetailPreMw []readDetailMw
 var readDetailPostMw []readDetailMw
 var updatePreMw []readDetailMw
 var updatePostMw []readDetailMw
-var deletePreMw []readDetailMw
-var deletePostMw []readDetailMw
+var deletePreMw []deleteMw
+var deletePostMw []deleteMw

internal/use-case/main-use-case/generate-file/helper.go

@@ -244,6 +244,10 @@ func generateResume(input GenerateDto, event pl.Event, tx *gorm.DB) (*ResponseDt
 		return nil, err
 	}
 
+	if !r.IsValidated() {
+		return nil, errors.New("resume is not validated")
+	}
+
 	if r.FileUrl != nil {
 		if err := removeFile(string(input.EntityType_Code), *r.FileUrl); err != nil {
 			return nil, err

internal/use-case/main-use-case/resume/case.go

@@ -50,7 +50,6 @@ func Create(input e.CreateDto) (*d.Data, error) {
 			return errors.New("encounter is already done")
 		}
 
-		input.Status_Code = erc.DVCNew
 		if resData, err := CreateData(input, &event, tx); err != nil {
 			return err
 		} else {
@@ -345,16 +344,16 @@ func UpdateStatusCode(input e.UpdateDto) (*d.Data, error) {
 
 		switch input.Status_Code {
 		case erc.DVCValidated:
-			if !enc.IsSameResponsibleDoctor(input.AuthInfo.Doctor_Code) {
-				return errors.New("validation doctor is not the same as encounter responsible doctor")
-			}
-
 			if data.IsNew() {
 				return errors.New("resume need to be verified first")
 			}
 			if data.IsValidated() {
 				return errors.New("resume already validated")
 			}
+			if !enc.IsSameResponsibleDoctor(input.AuthInfo.Doctor_Code) {
+				return errors.New("validation doctor is not the same as encounter responsible doctor")
+			}
+
 			data.Status_Code = erc.DVCValidated
 			err = tx.Save(&data).Error
 			if err != nil {

internal/use-case/main-use-case/resume/helper.go

@@ -6,12 +6,15 @@ package resume
 
 import (
 	e "simrs-vx/internal/domain/main-entities/resume"
+
+	erc "simrs-vx/internal/domain/references/common"
 )
 
 func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Resume) {
 	var inputSrc *e.CreateDto
 	if inputT, ok := any(input).(*e.CreateDto); ok {
 		inputSrc = inputT
+		data.Status_Code = erc.DVCNew
 	} else {
 		inputTemp := any(input).(*e.UpdateDto)
 		inputSrc = &inputTemp.CreateDto
@@ -20,5 +23,4 @@ func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.Resume) {
 	data.Encounter_Id = inputSrc.Encounter_Id
 	data.Doctor_Code = inputSrc.AuthInfo.Doctor_Code
 	data.Value = inputSrc.Value
-	data.Status_Code = inputSrc.Status_Code
 }