Compare commits

..

10 Commits

Author SHA1 Message Date
Anang Yusman 2360ed406d clientId add 2026-02-05 20:23:59 +08:00
Anang Yusman 0f46937b14 update category 2026-02-03 19:10:10 +08:00
Anang Yusman 99aa77e60a add category 2026-02-03 18:44:24 +08:00
hanif salafi 53b16cc0bc feat: fixing update spesification product 2026-01-28 08:39:11 +07:00
hanif salafi 95f48ba56b feat: fixing upload product 2026-01-28 07:30:00 +07:00
Anang Yusman 976b7bc021 fix 2026-01-27 18:37:08 +08:00
Anang Yusman 42e856f068 fix 2026-01-27 18:32:47 +08:00
Anang Yusman 13b95c0109 update api product 2026-01-27 18:13:54 +08:00
Anang Yusman 6ac6e6ea9c update 2026-01-27 18:05:34 +08:00
Anang Yusman 1098c22738 update:api product 2026-01-27 17:28:17 +08:00
18 changed files with 578 additions and 96 deletions

View File

@ -13,5 +13,7 @@ type Galleries struct {
IsActive *bool `json:"is_active" gorm:"type:bool;default:true"`
CreatedAt time.Time `json:"created_at" gorm:"default:now()"`
UpdatedAt time.Time `json:"updated_at" gorm:"default:now()"`
Category string `json:"category" db:"category"`
}

View File

@ -11,10 +11,10 @@ type Products struct {
Price *string `json:"price" gorm:"type:varchar"`
ThumbnailPath *string `json:"thumbnail_path" gorm:"type:varchar"`
Colors *string `json:"colors" gorm:"type:text"` // JSON array stored as text
Specifications *string `json:"specifications" gorm:"type:text"` // JSON array stored as text
Status *string `json:"status" gorm:"type:varchar"`
StatusId *int `json:"status_id" gorm:"type:int4;default:1"`
IsActive *bool `json:"is_active" gorm:"type:bool;default:true"`
CreatedAt time.Time `json:"created_at" gorm:"default:now()"`
UpdatedAt time.Time `json:"updated_at" gorm:"default:now()"`
}

View File

@ -1,18 +1,21 @@
package controller
import (
"jaecoo-be/app/middleware"
"jaecoo-be/app/module/banners/request"
"jaecoo-be/app/module/banners/service"
"jaecoo-be/utils/paginator"
"strconv"
"github.com/gofiber/fiber/v2"
"github.com/rs/zerolog"
utilRes "jaecoo-be/utils/response"
)
type bannersController struct {
bannersService service.BannersService
Log zerolog.Logger
}
@ -61,7 +64,14 @@ func (_i *bannersController) All(c *fiber.Ctx) error {
req := reqContext.ToParamRequest()
req.Pagination = paginate
bannersData, paging, err := _i.bannersService.GetAll(req)
// ✅ ambil ClientId dari middleware
clientId := middleware.GetClientID(c)
// ✅ ambil Authorization token (kalau dibutuhkan)
_i.Log.Info().Interface("clientId", clientId).Msg("")
bannersData, paging, err := _i.bannersService.GetAll(clientId,req)
if err != nil {
return err
}
@ -74,6 +84,7 @@ func (_i *bannersController) All(c *fiber.Ctx) error {
})
}
// Show Banner
// @Summary Get Banner by ID
// @Description API for getting Banner by ID

View File

@ -7,6 +7,7 @@ import (
"jaecoo-be/utils/paginator"
"strings"
"github.com/google/uuid"
"github.com/rs/zerolog"
)
@ -16,7 +17,7 @@ type bannersRepository struct {
}
type BannersRepository interface {
GetAll(req request.BannersQueryRequest) (banners []*entity.Banners, paging paginator.Pagination, err error)
GetAll(clientId *uuid.UUID, req request.BannersQueryRequest) (banners []*entity.Banners, paging paginator.Pagination, err error)
FindOne(id uint) (banner *entity.Banners, err error)
Create(banner *entity.Banners) (bannerReturn *entity.Banners, err error)
Update(id uint, banner *entity.Banners) (err error)
@ -34,11 +35,15 @@ func NewBannersRepository(db *database.Database, log zerolog.Logger) BannersRepo
}
}
func (_i *bannersRepository) GetAll(req request.BannersQueryRequest) (banners []*entity.Banners, paging paginator.Pagination, err error) {
func (_i *bannersRepository) GetAll(clientId *uuid.UUID, req request.BannersQueryRequest) (banners []*entity.Banners, paging paginator.Pagination, err error) {
var count int64
query := _i.DB.DB.Model(&entity.Banners{})
if clientId != nil {
query = query.Where("banners.client_id = ?", clientId)
}
if req.Title != nil && *req.Title != "" {
title := strings.ToLower(*req.Title)
query = query.Where("LOWER(title) LIKE ?", "%"+title+"%")

View File

@ -23,6 +23,7 @@ import (
"time"
"github.com/gofiber/fiber/v2"
"github.com/google/uuid"
"github.com/minio/minio-go/v7"
"github.com/rs/zerolog"
)
@ -37,7 +38,7 @@ type bannersService struct {
}
type BannersService interface {
GetAll(req request.BannersQueryRequest) (banners []*response.BannersResponse, paging paginator.Pagination, err error)
GetAll(clientId *uuid.UUID,req request.BannersQueryRequest) (banners []*response.BannersResponse, paging paginator.Pagination, err error)
GetOne(id uint) (banner *response.BannersResponse, err error)
Create(c *fiber.Ctx, req request.BannersCreateRequest) (banner *response.BannersResponse, err error)
Update(c *fiber.Ctx, id uint, req request.BannersUpdateRequest) (banner *response.BannersResponse, err error)
@ -60,14 +61,17 @@ func NewBannersService(repo repository.BannersRepository, log zerolog.Logger, cf
}
}
func (_i *bannersService) GetAll(req request.BannersQueryRequest) (banners []*response.BannersResponse, paging paginator.Pagination, err error) {
bannersEntity, paging, err := _i.Repo.GetAll(req)
func (_i *bannersService) GetAll(
clientId *uuid.UUID,
req request.BannersQueryRequest,
) (banners []*response.BannersResponse, paging paginator.Pagination, err error) {
bannersEntity, paging, err := _i.Repo.GetAll(clientId, req)
if err != nil {
return
}
host := _i.Cfg.App.Domain
for _, banner := range bannersEntity {
banners = append(banners, mapper.BannersResponseMapper(banner, host))
}

View File

@ -13,6 +13,7 @@ func GalleriesResponseMapper(gallery *entity.Galleries, host string) *res.Galler
response := &res.GalleriesResponse{
ID: gallery.ID,
Title: gallery.Title,
Category: gallery.Category,
Description: gallery.Description,
ThumbnailPath: gallery.ThumbnailPath,
StatusId: gallery.StatusId,

View File

@ -33,6 +33,8 @@ type GalleriesCreateRequest struct {
Title string `json:"title" validate:"required"`
Description *string `json:"description"`
ThumbnailPath *string `json:"thumbnail_path"`
Category string `json:"category" validate:"required"`
}
func (req GalleriesCreateRequest) ToEntity() *entity.Galleries {
@ -40,6 +42,7 @@ func (req GalleriesCreateRequest) ToEntity() *entity.Galleries {
Title: req.Title,
Description: req.Description,
ThumbnailPath: req.ThumbnailPath,
Category: req.Category,
}
}
@ -47,14 +50,18 @@ type GalleriesUpdateRequest struct {
Title *string `json:"title"`
Description *string `json:"description"`
ThumbnailPath *string `json:"thumbnail_path"`
Category string `json:"category" validate:"required"`
IsActive *bool `json:"is_active"`
}
func (req GalleriesUpdateRequest) ToEntity() *entity.Galleries {
return &entity.Galleries{
Title: getStringValue(req.Title),
Description: req.Description,
ThumbnailPath: req.ThumbnailPath,
Category: req.Category,
IsActive: req.IsActive,
}
}

View File

@ -7,6 +7,7 @@ import (
type GalleriesResponse struct {
ID uint `json:"id"`
Title string `json:"title"`
Category string `json:"category"`
Description *string `json:"description"`
ThumbnailPath *string `json:"thumbnail_path"`
ThumbnailUrl *string `json:"thumbnail_url"`

View File

@ -229,9 +229,9 @@ func (_i *productsController) Update(c *fiber.Ctx) error {
req.Price = &price
}
// Handle colors (JSON array string)
// Handle colors (JSON array of objects with name and image_path)
if colorsStr := c.FormValue("colors"); colorsStr != "" {
var colors []string
var colors []request.ProductColorRequest
if err := json.Unmarshal([]byte(colorsStr), &colors); err == nil {
req.Colors = colors
}

View File

@ -39,6 +39,32 @@ if product.Colors != nil && *product.Colors != "" {
}
}
var specifications []res.ProductSpecificationResponse
if product.Specifications != nil && *product.Specifications != "" {
var rawSpecs []struct {
Title string `json:"title"`
ImagePaths []string `json:"image_paths"`
}
_ = json.Unmarshal([]byte(*product.Specifications), &rawSpecs)
for _, s := range rawSpecs {
var imageUrls []string
for _, imagePath := range s.ImagePaths {
filename := filepath.Base(imagePath)
url := host + "/products/viewer/" + filename
imageUrls = append(imageUrls, url)
}
specifications = append(specifications, res.ProductSpecificationResponse{
Title: s.Title,
ImagePaths: s.ImagePaths,
ImageUrls: imageUrls,
})
}
}
response := &res.ProductsResponse{
ID: product.ID,
@ -47,6 +73,7 @@ if product.Colors != nil && *product.Colors != "" {
Price: product.Price,
ThumbnailPath: product.ThumbnailPath,
Colors: colors,
Specifications: specifications,
Status: product.Status,
StatusId: product.StatusId,
IsActive: product.IsActive,

View File

@ -99,7 +99,7 @@ type ProductsUpdateRequest struct {
Variant *string `json:"variant"`
Price *string `json:"price"`
ThumbnailPath *string `json:"thumbnail_path"`
Colors []string `json:"colors"`
Colors []ProductColorRequest `json:"colors"`
Status *string `json:"status"`
IsActive *bool `json:"is_active"`
}

View File

@ -10,6 +10,12 @@ type ProductColorResponse struct {
ImageUrl *string `json:"image_url"`
}
type ProductSpecificationResponse struct {
Title string `json:"title"`
ImagePaths []string `json:"image_paths"`
ImageUrls []string `json:"image_urls"`
}
type ProductsResponse struct {
ID uint `json:"id"`
Title string `json:"title"`
@ -18,6 +24,7 @@ type ProductsResponse struct {
ThumbnailPath *string `json:"thumbnail_path"`
ThumbnailUrl *string `json:"thumbnail_url"`
Colors []ProductColorResponse `json:"colors"`
Specifications []ProductSpecificationResponse `json:"specifications"`
Status *string `json:"status"`
StatusId *int `json:"status_id"`
IsActive *bool `json:"is_active"`

View File

@ -30,7 +30,6 @@ import (
"github.com/rs/zerolog"
)
type productsService struct {
Repo repository.ProductsRepository
Log zerolog.Logger
@ -145,20 +144,79 @@ func (_i *productsService) uploadColorFile(
return &objectName, nil
}
func (_i *productsService) uploadSpecFile(
fileHeader *multipart.FileHeader,
) (*string, error) {
minioClient, err := _i.MinioStorage.ConnectMinio()
if err != nil {
return nil, err
}
src, err := fileHeader.Open()
if err != nil {
return nil, err
}
defer src.Close()
now := time.Now()
ext := filepath.Ext(fileHeader.Filename)
name := strings.TrimSuffix(fileHeader.Filename, ext)
name = strings.ReplaceAll(name, " ", "")
filename := fmt.Sprintf(
"%s_%d%s",
name,
rand.Intn(999999),
ext,
)
objectName := fmt.Sprintf(
"products/specifications/%d/%d/%s",
now.Year(),
now.Month(),
filename,
)
_, err = minioClient.PutObject(
context.Background(),
_i.MinioStorage.Cfg.ObjectStorage.MinioStorage.BucketName,
objectName,
src,
fileHeader.Size,
minio.PutObjectOptions{},
)
if err != nil {
return nil, err
}
return &objectName, nil
}
func (_i *productsService) Create(c *fiber.Ctx, req request.ProductsCreateRequest) (product *response.ProductsResponse, err error) {
_i.Log.Info().
Str("title", req.Title).
Interface("colors", req.Colors).
Msg("🚀 Starting Create Product")
// Handle file upload if exists
if filePath, uploadErr := _i.UploadFileToMinio(c, "file"); uploadErr == nil && filePath != nil {
req.ThumbnailPath = filePath
_i.Log.Info().Str("thumbnailPath", *filePath).Msg("✅ Uploaded thumbnail")
}
// 🔥 CONVERT REQUEST KE ENTITY
productEntity := req.ToEntity()
// ===============================
// 3⃣ 🔥 HANDLE COLORS + IMAGE
// ===============================
form, _ := c.MultipartForm()
colorFiles := form.File["color_images"]
colorsStr := c.FormValue("colors")
_i.Log.Info().
Str("colorsStr", colorsStr).
Int("colorFilesCount", len(colorFiles)).
Msg("🎨 Processing colors")
var colorEntities []struct {
Name string `json:"name"`
@ -195,19 +253,119 @@ func (_i *productsService) Create(c *fiber.Ctx, req request.ProductsCreateReques
bytes, _ := json.Marshal(colorEntities)
str := string(bytes)
productEntity.Colors = &str
_i.Log.Info().
Int("colorsCount", len(colorEntities)).
Str("json", str).
Msg("💾 Saved colors to entity")
}
// 4⃣ DEFAULT ACTIVE
// 6⃣ HANDLE SPECIFICATIONS (as JSON array like colors)
form, _ = c.MultipartForm()
specFiles := form.File["specification_images"]
specificationsStr := c.FormValue("specifications")
_i.Log.Info().
Str("specificationsStr", specificationsStr).
Int("specFilesCount", len(specFiles)).
Msg("📦 Processing specifications in Create")
var specEntities []struct {
Title string `json:"title"`
ImagePaths []string `json:"image_paths"`
}
if specificationsStr != "" {
var specifications []struct {
Title string `json:"title"`
ImageCount int `json:"imageCount"`
}
if err := json.Unmarshal([]byte(specificationsStr), &specifications); err != nil {
_i.Log.Error().Err(err).Str("specificationsStr", specificationsStr).Msg("❌ Failed to unmarshal specifications")
} else {
_i.Log.Info().Int("specsCount", len(specifications)).Msg("✅ Parsed specifications JSON")
fileIndex := 0
for specIdx, spec := range specifications {
if spec.Title == "" {
_i.Log.Warn().Int("specIndex", specIdx).Msg("⚠️ Skipping spec with empty title")
continue
}
specEntity := struct {
Title string `json:"title"`
ImagePaths []string `json:"image_paths"`
}{
Title: spec.Title,
ImagePaths: []string{},
}
_i.Log.Info().
Int("specIndex", specIdx).
Str("title", spec.Title).
Int("imageCount", spec.ImageCount).
Int("fileIndex", fileIndex).
Msg("📝 Processing spec")
// Upload files for this specification
imageCount := spec.ImageCount
if imageCount > 0 && fileIndex < len(specFiles) {
for i := 0; i < imageCount && fileIndex < len(specFiles); i++ {
fileHeader := specFiles[fileIndex]
_i.Log.Info().
Int("fileIndex", fileIndex).
Str("filename", fileHeader.Filename).
Msg("📤 Uploading spec image")
path, uploadErr := _i.uploadSpecFile(fileHeader)
if uploadErr != nil {
_i.Log.Error().Err(uploadErr).Int("fileIndex", fileIndex).Msg("❌ Failed to upload spec file")
} else if path != nil {
specEntity.ImagePaths = append(specEntity.ImagePaths, *path)
_i.Log.Info().Str("path", *path).Msg("✅ Uploaded spec image")
}
fileIndex++
}
}
specEntities = append(specEntities, specEntity)
_i.Log.Info().
Str("title", specEntity.Title).
Int("imagesCount", len(specEntity.ImagePaths)).
Msg("✅ Added spec entity")
}
}
} else {
_i.Log.Warn().Msg("⚠️ No specifications string in form")
}
// Save specifications as JSON string
if len(specEntities) > 0 {
bytes, _ := json.Marshal(specEntities)
str := string(bytes)
productEntity.Specifications = &str
_i.Log.Info().
Int("specsCount", len(specEntities)).
Str("json", str).
Msg("💾 Saved specifications to entity")
} else {
_i.Log.Warn().Msg("⚠️ No spec entities to save")
}
// 7⃣ DEFAULT ACTIVE & SAVE TO DB
isActive := true
productEntity.IsActive = &isActive
// 5⃣ SIMPAN KE DB
productEntity, err = _i.Repo.Create(productEntity)
if err != nil {
_i.Log.Error().Err(err).Msg("❌ Failed to create product in DB")
return
}
_i.Log.Info().
Uint("productId", productEntity.ID).
Interface("colors", productEntity.Colors).
Interface("specifications", productEntity.Specifications).
Msg("✅ Product created in DB with all data")
// 6⃣ RESPONSE
// 8️⃣ RESPONSE
host := _i.Cfg.App.Domain
product = mapper.ProductsResponseMapper(productEntity, host)
return
@ -284,8 +442,187 @@ func (_i *productsService) Update(c *fiber.Ctx, id uint, req request.ProductsUpd
req.ThumbnailPath = filePath
}
// Get existing product to preserve existing colors if no new color images uploaded
existingProduct, err := _i.Repo.FindOne(id)
if err != nil {
return
}
productEntity := req.ToEntity()
// Handle color images if uploaded (similar to Create)
form, _ := c.MultipartForm()
colorFiles := form.File["color_images"]
// If color images are uploaded, process them
if len(colorFiles) > 0 {
var colorEntities []struct {
Name string `json:"name"`
ImagePath *string `json:"image_path"`
}
// Use colors from request if available, otherwise preserve existing
var existingColors []struct {
Name string `json:"name"`
ImagePath *string `json:"image_path"`
}
if existingProduct.Colors != nil && *existingProduct.Colors != "" {
_ = json.Unmarshal([]byte(*existingProduct.Colors), &existingColors)
}
// Process color files and merge with request colors
for i, cReq := range req.Colors {
if cReq.Name == "" {
continue
}
color := struct {
Name string `json:"name"`
ImagePath *string `json:"image_path"`
}{
Name: cReq.Name,
}
// If there's a new file uploaded for this color index, use it
if len(colorFiles) > i {
fileHeader := colorFiles[i]
path, err := _i.uploadColorFile(fileHeader)
if err == nil && path != nil {
color.ImagePath = path
} else if i < len(existingColors) {
// Keep existing image path if upload failed
color.ImagePath = existingColors[i].ImagePath
}
} else if i < len(existingColors) {
// No new file, preserve existing image path
color.ImagePath = existingColors[i].ImagePath
}
colorEntities = append(colorEntities, color)
}
// Update colors JSON if we have colors
if len(colorEntities) > 0 {
bytes, _ := json.Marshal(colorEntities)
str := string(bytes)
productEntity.Colors = &str
}
} else if len(req.Colors) > 0 {
// No new color images uploaded, but colors data is provided
// Preserve existing image paths and update names
var existingColors []struct {
Name string `json:"name"`
ImagePath *string `json:"image_path"`
}
if existingProduct.Colors != nil && *existingProduct.Colors != "" {
_ = json.Unmarshal([]byte(*existingProduct.Colors), &existingColors)
}
var colorEntities []struct {
Name string `json:"name"`
ImagePath *string `json:"image_path"`
}
for i, cReq := range req.Colors {
if cReq.Name == "" {
continue
}
color := struct {
Name string `json:"name"`
ImagePath *string `json:"image_path"`
}{
Name: cReq.Name,
}
// Preserve existing image path if available
if i < len(existingColors) {
color.ImagePath = existingColors[i].ImagePath
}
colorEntities = append(colorEntities, color)
}
if len(colorEntities) > 0 {
bytes, _ := json.Marshal(colorEntities)
str := string(bytes)
productEntity.Colors = &str
}
} else if existingProduct.Colors != nil {
// No colors in request, preserve existing colors
productEntity.Colors = existingProduct.Colors
}
// Handle specifications update (as JSON array like colors)
specFiles := form.File["specification_images"]
specificationsStr := c.FormValue("specifications")
var specEntities []struct {
Title string `json:"title"`
ImagePaths []string `json:"image_paths"`
}
if specificationsStr != "" {
var specifications []struct {
Title string `json:"title"`
ImageCount int `json:"imageCount"`
}
if err := json.Unmarshal([]byte(specificationsStr), &specifications); err == nil {
// Get existing specifications to preserve existing images if no new files uploaded
var existingSpecs []struct {
Title string `json:"title"`
ImagePaths []string `json:"image_paths"`
}
if existingProduct.Specifications != nil && *existingProduct.Specifications != "" {
_ = json.Unmarshal([]byte(*existingProduct.Specifications), &existingSpecs)
}
fileIndex := 0
for i, spec := range specifications {
if spec.Title == "" {
continue
}
specEntity := struct {
Title string `json:"title"`
ImagePaths []string `json:"image_paths"`
}{
Title: spec.Title,
ImagePaths: []string{},
}
// If there are new files uploaded for this spec index, use them
imageCount := spec.ImageCount
if imageCount > 0 && fileIndex < len(specFiles) {
// Upload new files
for j := 0; j < imageCount && fileIndex < len(specFiles); j++ {
fileHeader := specFiles[fileIndex]
path, uploadErr := _i.uploadSpecFile(fileHeader)
if uploadErr == nil && path != nil {
specEntity.ImagePaths = append(specEntity.ImagePaths, *path)
}
fileIndex++
}
} else if i < len(existingSpecs) {
// No new files, preserve existing image paths
specEntity.ImagePaths = existingSpecs[i].ImagePaths
}
specEntities = append(specEntities, specEntity)
}
}
} else if existingProduct.Specifications != nil {
// No specifications in request, preserve existing
productEntity.Specifications = existingProduct.Specifications
}
// Save specifications as JSON string
if len(specEntities) > 0 {
bytes, _ := json.Marshal(specEntities)
str := string(bytes)
productEntity.Specifications = &str
}
err = _i.Repo.Update(id, productEntity)
if err != nil {
return
@ -310,25 +647,90 @@ func (_i *productsService) Delete(id uint) (err error) {
func (_i *productsService) Viewer(c *fiber.Ctx) (err error) {
filename := c.Params("filename")
// Find product by filename (repository will search using LIKE pattern)
var objectName string
var found bool
// First, try to find by ThumbnailPath (for main product images)
result, err := _i.Repo.FindByThumbnailPath(filename)
if err != nil {
if err == nil && result != nil && result.ThumbnailPath != nil && *result.ThumbnailPath != "" {
// Check if the filename matches the thumbnail
if strings.Contains(*result.ThumbnailPath, filename) {
objectName = *result.ThumbnailPath
found = true
}
}
// If not found in ThumbnailPath, search in Colors JSON field
if !found {
// Create a query request with large limit to search all products
queryReq := request.ProductsQueryRequest{
Pagination: &paginator.Pagination{
Page: 1,
Limit: 1000, // Large limit to search all products
},
}
allProducts, _, err := _i.Repo.GetAll(queryReq)
if err == nil {
for _, product := range allProducts {
// Search in Colors
if product.Colors != nil && *product.Colors != "" {
var rawColors []struct {
Name string `json:"name"`
ImagePath *string `json:"image_path"`
}
if err := json.Unmarshal([]byte(*product.Colors), &rawColors); err == nil {
for _, color := range rawColors {
if color.ImagePath != nil && strings.Contains(*color.ImagePath, filename) {
objectName = *color.ImagePath
found = true
break
}
}
}
if found {
break
}
}
// Search in Specifications
if !found && product.Specifications != nil && *product.Specifications != "" {
var rawSpecs []struct {
Title string `json:"title"`
ImagePaths []string `json:"image_paths"`
}
if err := json.Unmarshal([]byte(*product.Specifications), &rawSpecs); err == nil {
for _, spec := range rawSpecs {
for _, imagePath := range spec.ImagePaths {
if strings.Contains(imagePath, filename) {
objectName = imagePath
found = true
break
}
}
if found {
break
}
}
}
if found {
break
}
}
}
}
}
if !found || objectName == "" {
return c.Status(fiber.StatusNotFound).JSON(fiber.Map{
"error": true,
"msg": "Product file not found",
})
}
if result.ThumbnailPath == nil || *result.ThumbnailPath == "" {
return c.Status(fiber.StatusNotFound).JSON(fiber.Map{
"error": true,
"msg": "Product thumbnail path not found",
})
}
ctx := context.Background()
bucketName := _i.MinioStorage.Cfg.ObjectStorage.MinioStorage.BucketName
objectName := *result.ThumbnailPath
_i.Log.Info().Str("timestamp", time.Now().
Format(time.RFC3339)).Str("Service:Resource", "Products:Viewer").

View File

@ -2,18 +2,21 @@ package controller
import (
"encoding/json"
"jaecoo-be/app/middleware"
"jaecoo-be/app/module/sales_agents/request"
"jaecoo-be/app/module/sales_agents/service"
"jaecoo-be/utils/paginator"
"strconv"
"github.com/gofiber/fiber/v2"
"github.com/rs/zerolog"
utilRes "jaecoo-be/utils/response"
)
type salesAgentsController struct {
salesAgentsService service.SalesAgentsService
Log zerolog.Logger
}
type SalesAgentsController interface {
@ -61,7 +64,13 @@ func (_i *salesAgentsController) All(c *fiber.Ctx) error {
req := reqContext.ToParamRequest()
req.Pagination = paginate
agentsData, paging, err := _i.salesAgentsService.GetAll(req)
clientId := middleware.GetClientID(c)
// ✅ ambil Authorization token (kalau dibutuhkan)
_i.Log.Info().Interface("clientId", clientId).Msg("")
agentsData, paging, err := _i.salesAgentsService.GetAll(clientId,req)
if err != nil {
return err
}

View File

@ -7,6 +7,7 @@ import (
"jaecoo-be/utils/paginator"
"strings"
"github.com/google/uuid"
"github.com/rs/zerolog"
)
@ -16,7 +17,7 @@ type salesAgentsRepository struct {
}
type SalesAgentsRepository interface {
GetAll(req request.SalesAgentsQueryRequest) (agents []*entity.SalesAgents, paging paginator.Pagination, err error)
GetAll(clientId *uuid.UUID, req request.SalesAgentsQueryRequest) (agents []*entity.SalesAgents, paging paginator.Pagination, err error)
FindOne(id uint) (agent *entity.SalesAgents, err error)
Create(agent *entity.SalesAgents) (agentReturn *entity.SalesAgents, err error)
Update(id uint, agent *entity.SalesAgents) (err error)
@ -33,7 +34,7 @@ func NewSalesAgentsRepository(db *database.Database, log zerolog.Logger) SalesAg
}
}
func (_i *salesAgentsRepository) GetAll(req request.SalesAgentsQueryRequest) (agents []*entity.SalesAgents, paging paginator.Pagination, err error) {
func (_i *salesAgentsRepository) GetAll(clientId *uuid.UUID, req request.SalesAgentsQueryRequest) (agents []*entity.SalesAgents, paging paginator.Pagination, err error) {
var count int64
query := _i.DB.DB.Model(&entity.SalesAgents{})
@ -47,6 +48,10 @@ func (_i *salesAgentsRepository) GetAll(req request.SalesAgentsQueryRequest) (ag
query = query.Where("job_title = ?", *req.JobTitle)
}
if clientId != nil {
query = query.Where("client_id = ?", clientId)
}
if req.AgentType != nil && *req.AgentType != "" {
query = query.Where("agent_type LIKE ?", "%"+*req.AgentType+"%")
}

View File

@ -23,6 +23,7 @@ import (
"time"
"github.com/gofiber/fiber/v2"
"github.com/google/uuid"
"github.com/minio/minio-go/v7"
"github.com/rs/zerolog"
)
@ -37,7 +38,7 @@ type salesAgentsService struct {
}
type SalesAgentsService interface {
GetAll(req request.SalesAgentsQueryRequest) (agents []*response.SalesAgentsResponse, paging paginator.Pagination, err error)
GetAll(clientId *uuid.UUID, req request.SalesAgentsQueryRequest) (agents []*response.SalesAgentsResponse, paging paginator.Pagination, err error)
GetOne(id uint) (agent *response.SalesAgentsResponse, err error)
Create(c *fiber.Ctx, req request.SalesAgentsCreateRequest) (agent *response.SalesAgentsResponse, err error)
Update(c *fiber.Ctx, id uint, req request.SalesAgentsUpdateRequest) (agent *response.SalesAgentsResponse, err error)
@ -60,8 +61,8 @@ func NewSalesAgentsService(repo repository.SalesAgentsRepository, log zerolog.Lo
}
}
func (_i *salesAgentsService) GetAll(req request.SalesAgentsQueryRequest) (agents []*response.SalesAgentsResponse, paging paginator.Pagination, err error) {
agentsEntity, paging, err := _i.Repo.GetAll(req)
func (_i *salesAgentsService) GetAll(clientId *uuid.UUID, req request.SalesAgentsQueryRequest) (agents []*response.SalesAgentsResponse, paging paginator.Pagination, err error) {
agentsEntity, paging, err := _i.Repo.GetAll(clientId,req)
if err != nil {
return
}

2
go.mod
View File

@ -13,6 +13,7 @@ require (
github.com/go-playground/validator/v10 v10.17.0
github.com/gofiber/fiber/v2 v2.52.4
github.com/golang-jwt/jwt/v5 v5.2.1
github.com/google/uuid v1.6.0
github.com/minio/minio-go/v7 v7.0.68
github.com/pelletier/go-toml/v2 v2.1.1
github.com/rs/zerolog v1.31.0
@ -34,7 +35,6 @@ require (
github.com/go-openapi/spec v0.20.15 // indirect
github.com/go-openapi/swag v0.22.10 // indirect
github.com/go-resty/resty/v2 v2.7.0 // indirect
github.com/google/uuid v1.6.0 // indirect
github.com/jackc/pgpassfile v1.0.0 // indirect
github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a // indirect
github.com/jackc/pgx/v5 v5.4.3 // indirect

Binary file not shown.