update Order History

internal/common/mycontext/kinoscontext.go

@@ -13,6 +13,7 @@ type Context interface {
 
 	RequestedBy() int64
 	IsSuperAdmin() bool
+	IsAdmin() bool
 	IsCasheer() bool
 	GetPartnerID() *int64
 	GetSiteID() *int64
@@ -36,6 +37,10 @@ func (m *MyContextImpl) IsSuperAdmin() bool {
 	return m.roleID == int(role.SuperAdmin)
 }
 
+func (m *MyContextImpl) IsAdmin() bool {
+	return m.roleID == int(role.SuperAdmin) || m.roleID == int(role.Admin)
+}
+
 func (m *MyContextImpl) IsCasheer() bool {
 	return m.roleID == int(role.Casheer)
 }

internal/entity/order.go

@@ -100,6 +100,8 @@ type HistoryOrderDB struct {
 }
 
 type HistoryOrderSearch struct {
+	PartnerID *int64
+	IsAdmin   bool
 	Limit     int
 	Offset    int
 }

internal/handlers/http/order/order.go

@@ -2,12 +2,12 @@ package order
 
 import (
 	"furtuna-be/internal/common/errors"
+	"furtuna-be/internal/common/mycontext"
 	"furtuna-be/internal/entity"
 	"furtuna-be/internal/handlers/request"
 	"furtuna-be/internal/handlers/response"
 	"furtuna-be/internal/services"
 	"net/http"
-	"strings"
 	"time"
 
 	"github.com/gin-gonic/gin"
@@ -171,23 +171,14 @@ func (h *Handler) toHistoryOrderResponse(resp *entity.HistoryOrder) response.His
 }
 
 func (h *Handler) GetAllHistoryOrders(c *gin.Context) {
-	tokenString := c.GetHeader("Authorization")
-
-	if tokenString == "" {
-		c.JSON(http.StatusUnauthorized, gin.H{"error": "Authorization header is required"})
-		c.Abort()
-		return
-	}
-
-	tokenString = strings.TrimPrefix(tokenString, "Bearer ")
-
 	var req request.HistoryOrderParam
 	if err := c.ShouldBindQuery(&req); err != nil {
 		response.ErrorWrapper(c, errors.ErrorBadRequest)
 		return
 	}
 
-	orders, total, err := h.service.GetAllHistoryOrders(c.Request.Context(), tokenString, req.ToEntity())
+	ctx := mycontext.NewContext(c.Request.Context())
+	orders, total, err := h.service.GetAllHistoryOrders(ctx, req.ToEntity(ctx))
 	if err != nil {
 		response.ErrorWrapper(c, err)
 		return

internal/handlers/request/order.go

@@ -1,6 +1,7 @@
 package request
 
 import (
+	"furtuna-be/internal/common/mycontext"
 	"furtuna-be/internal/constants/transaction"
 	"furtuna-be/internal/entity"
 )
@@ -16,8 +17,10 @@ type HistoryOrderParam struct {
 	Offset int `form:"offset" json:"offset" example:"0"`
 }
 
-func (o *HistoryOrderParam) ToEntity() entity.HistoryOrderSearch {
+func (o *HistoryOrderParam) ToEntity(ctx mycontext.Context) entity.HistoryOrderSearch {
 	return entity.HistoryOrderSearch{
+		PartnerID: ctx.GetPartnerID(),
+		IsAdmin:   ctx.IsAdmin(),
 		Limit:     o.Limit,
 		Offset:    o.Offset,
 	}

internal/repository/orders/order.go

@@ -83,7 +83,7 @@ func (r *OrderRepository) Update(ctx context.Context, order *entity.Order) (*ent
 	return order, nil
 }
 
-func (b *OrderRepository) GetAllHystoryOrders(ctx context.Context, claims entity.JWTAuthClaims, req entity.HistoryOrderSearch) (entity.HistoryOrderList, int, error) {
+func (b *OrderRepository) GetAllHystoryOrders(ctx context.Context, req entity.HistoryOrderSearch) (entity.HistoryOrderList, int, error) {
 	var orders []*entity.HistoryOrderDB
 	var total int64
 
@@ -94,8 +94,8 @@ func (b *OrderRepository) GetAllHystoryOrders(ctx context.Context, claims entity
 		Joins("left join partners on orders.partner_id = partners.id").
 		Joins("left join sites on partners.id = sites.partner_id")
 
-	if claims.Role == 3 {
-		query = query.Where("orders.partner_id = ?", claims.PartnerID)
+	if !req.IsAdmin {
+		query = query.Where("orders.partner_id = ?", req.PartnerID)
 	}
 
 	query = query.Group("orders.id, users.name, sites.name, orders.created_at, orders.payment_type, orders.status")

internal/repository/repository.go

@@ -130,7 +130,7 @@ type Order interface {
 	FindByID(ctx context.Context, id int64) (*entity.Order, error)
 	Update(ctx context.Context, order *entity.Order) (*entity.Order, error)
 	SetOrderStatus(ctx context.Context, db *gorm.DB, orderID int64, status string) error
-	GetAllHystoryOrders(ctx context.Context, claims entity.JWTAuthClaims, req entity.HistoryOrderSearch) (entity.HistoryOrderList, int, error)
+	GetAllHystoryOrders(ctx context.Context, req entity.HistoryOrderSearch) (entity.HistoryOrderList, int, error)
 }
 
 type OSSRepository interface {

internal/services/order/order.go

@@ -6,6 +6,7 @@ import (
 	"errors"
 	"fmt"
 	"furtuna-be/internal/common/logger"
+	"furtuna-be/internal/common/mycontext"
 	order2 "furtuna-be/internal/constants/order"
 	"furtuna-be/internal/entity"
 	"furtuna-be/internal/repository"
@@ -297,15 +298,8 @@ func (s *OrderService) updateWalletBalance(ctx context.Context, tx *gorm.DB, par
 	return err
 }
 
-func (s *OrderService) GetAllHistoryOrders(ctx context.Context, tokenString string, req entity.HistoryOrderSearch) ([]*entity.HistoryOrder, int, error) {
-	claims, err := s.crypt.ParseAndValidateJWT(tokenString)
-
-	if err != nil {
-		logger.ContextLogger(ctx).Error("error when get data token", zap.Error(err))
-		return nil, 0, err
-	}
-	
-	historyOrders, total, err := s.repo.GetAllHystoryOrders(ctx, *claims, req)
+func (s *OrderService) GetAllHistoryOrders(ctx mycontext.Context, req entity.HistoryOrderSearch) ([]*entity.HistoryOrder, int, error) {
+	historyOrders, total, err := s.repo.GetAllHystoryOrders(ctx, req)
 	if err != nil {
 		logger.ContextLogger(ctx).Error("error when get all history orders", zap.Error(err))
 		return nil, 0, err

internal/services/service.go

@@ -101,7 +101,7 @@ type Order interface {
 	CreateOrder(ctx context.Context, req *entity.OrderRequest) (*entity.OrderResponse, error)
 	Execute(ctx context.Context, req *entity.OrderExecuteRequest) (*entity.ExecuteOrderResponse, error)
 	ProcessCallback(ctx context.Context, req *entity.CallbackRequest) error
-	GetAllHistoryOrders(ctx context.Context, tokenString string, req entity.HistoryOrderSearch) ([]*entity.HistoryOrder, int, error)
+	GetAllHistoryOrders(ctx mycontext.Context, req entity.HistoryOrderSearch) ([]*entity.HistoryOrder, int, error)
 }
 
 type OSSService interface {