feat (user): use case done

2025-08-18 13:02:14 +07:00
parent db6af776a3
commit 0c5aa0becf
6 changed files with 181 additions and 13 deletions
@@ -3,6 +3,7 @@ package user
 import (
 	"fmt"
 	e "simrs-vx/internal/domain/main-entities/user"
+	"strconv"

 	dg "github.com/karincake/apem/db-gorm-pg"
 	d "github.com/karincake/dodol"
@@ -17,7 +18,7 @@ const source = "user"
 func Create(input e.CreateDto) (*d.Data, error) {
 	data := e.User{}

-	setData(input, &data)
+	setCreate(input, &data)

 	event := pl.Event{
 		Feature: "Create",
@@ -104,3 +105,166 @@ func Create(input e.CreateDto) (*d.Data, error) {
 		Data: data,
 	}, nil
 }
+
+func ReadList(input e.ReadListDto) (*d.Data, error) {
+	var data *e.User
+	var dataList []e.User
+	var metaList *e.MetaDto
+	var err error
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		for i := range readListPreMw {
+			if err := readListPreMw[i](&input, data, tx); err != nil {
+				return nil
+			}
+		}
+
+		dataList, metaList, err = ReadListData(input, tx)
+		if err != nil {
+			return err
+		}
+
+		for i := range readListPostMw {
+			if err := readListPostMw[i](&input, data, tx); err != nil {
+				return nil
+			}
+		}
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":            source,
+			"structure":         "list-data",
+			"status":            "fetched",
+			"page_number":       strconv.Itoa(metaList.PageNumber),
+			"page_size":         strconv.Itoa(metaList.PageSize),
+			"record_totalCount": strconv.Itoa(metaList.Count),
+		},
+		Data: dataList,
+	}, nil
+}
+
+func ReadDetail(input e.ReadDetailDto) (*d.Data, error) {
+	var data *e.User
+	var err error
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		for i := range readDetailPreMw {
+			if err := readDetailPreMw[i](&input, data, tx); err != nil {
+				return nil
+			}
+		}
+		data, err := ReadDetailData(input, tx)
+		if err != nil {
+			return err
+		}
+		for i := range readDetailPostMw {
+			if err := readDetailPostMw[i](&input, data, tx); err != nil {
+				return nil
+			}
+		}
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "fetched",
+		},
+		Data: data,
+	}, nil
+}
+
+func Update(input e.Updatedto) (*d.Data, error) {
+	rdDto := e.ReadDetailDto{Id: input.Id}
+	var data *e.User
+	var err error
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		data, err = ReadDetailData(rdDto, tx)
+		if err != nil {
+			return nil
+		}
+
+		err = setUpdate(input, data)
+		if err != nil {
+			return err
+		}
+		for i := range updatePreMw {
+			if err := updatePreMw[i](&rdDto, data, tx); err != nil {
+				return nil
+			}
+		}
+		if err := UpdateData(*data, tx); err != nil {
+			return nil
+		}
+		for i := range updatePostMw {
+			if err := updatePostMw[i](&rdDto, data, tx); err != nil {
+				return nil
+			}
+		}
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "updated",
+		},
+		Data: data,
+	}, nil
+
+}
+
+func Delete(input e.Deletedto) (*d.Data, error) {
+	rdDto := e.ReadDetailDto{Id: input.Id}
+	var data *e.User
+	var err error
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		data, err = ReadDetailData(rdDto, tx)
+		if err != nil {
+			return nil
+		}
+		for i := range deletePreMw {
+			if err := deletePreMw[i](&rdDto, data, tx); err != nil {
+				return nil
+			}
+		}
+		if err := DeleteData(data, tx); err != nil {
+			return nil
+		}
+		for i := range deletePostMw {
+			if err := deletePostMw[i](&rdDto, data, tx); err != nil {
+				return nil
+			}
+		}
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "deleted",
+		},
+		Data: data,
+	}, nil
+
+}