fix[BE]: adjust chickin if product warehouse have more than one DOC product

2026-05-24 15:25:43 +00:00 · 2025-10-22 14:56:32 +07:00
parent e2818b11f0
commit 6dd45c3289
7 changed files with 170 additions and 66 deletions
@@ -8,8 +8,6 @@ import (
 	KandangRepo "gitlab.com/mbugroup/lti-api.git/internal/modules/master/kandangs/repositories"
 	rWarehouse "gitlab.com/mbugroup/lti-api.git/internal/modules/master/warehouses/repositories"
 	repository "gitlab.com/mbugroup/lti-api.git/internal/modules/production/chickins/repositories"
-	rProjectFlockKandang "gitlab.com/mbugroup/lti-api.git/internal/modules/production/project_flocks/repositories"
-
 	validation "gitlab.com/mbugroup/lti-api.git/internal/modules/production/chickins/validations"
 	rProjectFlock "gitlab.com/mbugroup/lti-api.git/internal/modules/production/project_flocks/repositories"
 	"gitlab.com/mbugroup/lti-api.git/internal/utils"
@@ -37,11 +35,12 @@ type chickinService struct {
 	WarehouseRepo              rWarehouse.WarehouseRepository
 	ProductWarehouseRepo       rProductWarehouse.ProductWarehouseRepository
 	ProjectFlockRepo           rProjectFlock.ProjectflockRepository
-	ProjectflockKandangRepo    rProjectFlockKandang.ProjectFlockKandangRepository
+	ProjectflockKandangRepo    rProjectFlock.ProjectFlockKandangRepository
 	ProjectflockPopulationRepo rProjectFlock.ProjectFlockPopulationRepository
+	ProjectChickinDetailRepo   repository.ProjectChickinDetailRepository
 }

-func NewChickinService(repo repository.ProjectChickinRepository, kandangRepo KandangRepo.KandangRepository, warehouseRepo rWarehouse.WarehouseRepository, productWarehouseRepo rProductWarehouse.ProductWarehouseRepository, projectFlockRepo rProjectFlock.ProjectflockRepository, projectflockkandangRepo rProjectFlockKandang.ProjectFlockKandangRepository, projectflockpopulationRepo rProjectFlock.ProjectFlockPopulationRepository, validate *validator.Validate) ChickinService {
+func NewChickinService(repo repository.ProjectChickinRepository, kandangRepo KandangRepo.KandangRepository, warehouseRepo rWarehouse.WarehouseRepository, productWarehouseRepo rProductWarehouse.ProductWarehouseRepository, projectFlockRepo rProjectFlock.ProjectflockRepository, projectflockkandangRepo rProjectFlock.ProjectFlockKandangRepository, projectflockpopulationRepo rProjectFlock.ProjectFlockPopulationRepository, projectChickinDetailRepo repository.ProjectChickinDetailRepository, validate *validator.Validate) ChickinService {
 	return &chickinService{
 		Log:                        utils.Log,
 		Validate:                   validate,
@@ -52,6 +51,7 @@ func NewChickinService(repo repository.ProjectChickinRepository, kandangRepo Kan
 		ProjectFlockRepo:           projectFlockRepo,
 		ProjectflockKandangRepo:    projectflockkandangRepo,
 		ProjectflockPopulationRepo: projectflockpopulationRepo,
+		ProjectChickinDetailRepo:   projectChickinDetailRepo,
 	}
 }

@@ -121,23 +121,12 @@ func (s *chickinService) CreateOne(c *fiber.Ctx, req *validation.Create) (*entit
 		return nil, err
 	}

-	projectFlock, err := s.ProjectFlockRepo.GetByID(
-		c.Context(),
-		projectflockkandang.ProjectFlockId,
-		func(db *gorm.DB) *gorm.DB {
-			return db
-		},
-	)
-	if err != nil {
-		s.Log.Errorf("Failed to get project flock: %+v", err)
-		return nil, fiber.NewError(fiber.StatusNotFound, "Project Flock not found")
-	}
 	var productWarehouses []entity.ProductWarehouse
 	err = s.ProductWarehouseRepo.DB().
 		WithContext(c.Context()).
 		Joins("JOIN products ON products.id = product_warehouses.product_id").
 		Joins("JOIN product_categories ON product_categories.id = products.product_category_id").
-		Where("product_categories.code = ? AND product_warehouses.warehouse_id = ?", projectFlock.Category, warehouse.Id).
+		Where("product_categories.code = ? AND product_warehouses.warehouse_id = ?", "DOC", warehouse.Id).
 		Order("created_at DESC").
 		Find(&productWarehouses).Error
 	if err != nil {
@@ -186,6 +175,19 @@ func (s *chickinService) CreateOne(c *fiber.Ctx, req *validation.Create) (*entit
 			s.Log.Errorf("Failed to update product warehouse quantity: %+v", err)
 			return nil, err
 		}
+
+		// add ke detail chickin
+		newChickinDetail := &entity.ProjectChickinDetail{
+			ProjectChickinId:   newChickin.Id,
+			ProductWarehouseId: pw.Id,
+			Quantity:           pw.Quantity,
+			CreatedBy:          1, // todo: ganti dengan user login
+		}
+		err = s.ProjectChickinDetailRepo.CreateOne(c.Context(), newChickinDetail, nil)
+		if err != nil {
+			s.Log.Errorf("Failed to create chickin detail: %+v", err)
+			return nil, err
+		}
 	}

 	existingPopulation, err := s.ProjectflockPopulationRepo.GetByProjectFlockKandangID(c.Context(), req.ProjectFlockKandangId)
@@ -246,85 +248,98 @@ func (s chickinService) UpdateOne(c *fiber.Ctx, req *validation.Update, id uint)
 }

 func (s chickinService) DeleteOne(c *fiber.Ctx, id uint) error {
-	// todo: cek apakah chickin sudah di approve atau belum
+	db := s.Repository.DB()

-	chickin, err := s.Repository.GetByID(c.Context(), id, nil)
+	tx := db.WithContext(c.Context()).Begin()
+	if tx.Error != nil {
+		s.Log.Errorf("Failed to begin transaction: %+v", tx.Error)
+		return tx.Error
+	}
+	rollback := func(err error) error {
+		if rerr := tx.Rollback().Error; rerr != nil {
+			s.Log.Errorf("Rollback failed: %+v", rerr)
+		}
+		return err
+	}
+	chickinRepoTx := s.Repository.WithTx(tx)
+	pfkRepoTx := s.ProjectflockKandangRepo.WithTx(tx)
+	productWarehouseRepoTx := s.ProductWarehouseRepo.WithTx(tx)
+
+	chickin, err := chickinRepoTx.GetByID(c.Context(), id, nil)
 	if errors.Is(err, gorm.ErrRecordNotFound) {
-		return fiber.NewError(fiber.StatusNotFound, "Chickin not found")
+		return rollback(fiber.NewError(fiber.StatusNotFound, "Chickin not found"))
 	}
 	if err != nil {
 		s.Log.Errorf("Failed get chickin by id: %+v", err)
-		return err
+		return rollback(err)
 	}

-	population, err := s.ProjectflockPopulationRepo.GetByProjectFlockKandangID(c.Context(), chickin.ProjectFlockKandangId)
-	if err != nil {
-		s.Log.Errorf("Failed to get project flock population: %+v", err)
-		return err
-	}
-
-	err = s.ProjectflockPopulationRepo.PatchOne(c.Context(), population.Id, map[string]any{
-		"reserved_quantity": population.ReservedQuantity - chickin.Quantity,
-	}, nil)
-	if err != nil {
-		s.Log.Errorf("Failed to update project flock population: %+v", err)
-		return err
-	}
-
-	if err := s.Repository.DeleteOne(c.Context(), id); err != nil {
+	var population entity.ProjectFlockPopulation
+	if err := tx.WithContext(c.Context()).Where("project_flock_kandang_id = ?", chickin.ProjectFlockKandangId).First(&population).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
-			return fiber.NewError(fiber.StatusNotFound, "Chickin not found")
+			return rollback(fiber.NewError(fiber.StatusNotFound, "Project flock population not found"))
+		}
+		s.Log.Errorf("Failed to get project flock population: %+v", err)
+		return rollback(err)
+	}
+
+	newReserved := population.ReservedQuantity - chickin.Quantity
+	if newReserved < 0 {
+		newReserved = 0
+	}
+	if err := tx.WithContext(c.Context()).Model(&entity.ProjectFlockPopulation{}).Where("id = ?", population.Id).Updates(map[string]any{"reserved_quantity": newReserved}).Error; err != nil {
+		s.Log.Errorf("Failed to update project flock population: %+v", err)
+		return rollback(err)
+	}
+
+	if err := chickinRepoTx.DeleteOne(c.Context(), id); err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			return rollback(fiber.NewError(fiber.StatusNotFound, "Chickin not found"))
 		}
 		s.Log.Errorf("Failed to delete chickin: %+v", err)
-		return err
+		return rollback(err)
 	}

-	projectflockkandang, err := s.ProjectflockKandangRepo.GetByID(c.Context(), population.ProjectFlockKandangId)
+	projectflockkandang, err := pfkRepoTx.GetByID(c.Context(), population.ProjectFlockKandangId)
 	if err != nil {
 		s.Log.Errorf("Failed to get projectflock kandang: %+v", err)
-		return err
+		return rollback(err)
 	}
-	warehouse, err := s.WarehouseRepo.GetByKandangID(c.Context(), projectflockkandang.KandangId)
-	if err != nil {
+	var warehouse entity.Warehouse
+	if err := tx.WithContext(c.Context()).Where("kandang_id = ?", projectflockkandang.KandangId).First(&warehouse).Error; err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			return rollback(fiber.NewError(fiber.StatusNotFound, "Warehouse not found for kandang"))
+		}
 		s.Log.Errorf("Failed to get warehouse: %+v", err)
-		return err
+		return rollback(err)
 	}

-	projectFlock, err := s.ProjectFlockRepo.GetByID(
-		c.Context(),
-		projectflockkandang.ProjectFlockId,
-		func(db *gorm.DB) *gorm.DB {
-			return db
-		},
-	)
-
-	if err != nil {
-		s.Log.Errorf("Failed to get project flock: %+v", err)
-		return fiber.NewError(fiber.StatusNotFound, "Project Flock not found")
-	}
 	var productWarehouse entity.ProductWarehouse
-	err = s.ProductWarehouseRepo.DB().WithContext(c.Context()).
+	err = tx.WithContext(c.Context()).Table("product_warehouses").
+		Select("product_warehouses.*").
 		Joins("JOIN products ON products.id = product_warehouses.product_id").
 		Joins("JOIN product_categories ON product_categories.id = products.product_category_id").
-		Where("product_categories.code = ? AND product_warehouses.warehouse_id = ?", projectFlock.Category, warehouse.Id).
-		Order("created_at DESC").
+		Where("product_categories.code = ? AND product_warehouses.warehouse_id = ?", "DOC", warehouse.Id).
+		Order("product_warehouses.created_at DESC").
 		First(&productWarehouse).Error

 	if err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
-			return fiber.NewError(fiber.StatusNotFound, "Product Warehouse not found for the given Project Flock and Warehouse")
+			return rollback(fiber.NewError(fiber.StatusNotFound, "Product Warehouse not found for the given Project Flock and Warehouse"))
 		}
 		s.Log.Errorf("Failed to get product warehouse: %+v", err)
-		return err
+		return rollback(err)
 	}

 	updatedQuantity := productWarehouse.Quantity + chickin.Quantity
-	err = s.ProductWarehouseRepo.PatchOne(c.Context(), productWarehouse.Id, map[string]any{
-		"quantity": updatedQuantity,
-	}, nil)
-	if err != nil {
+	if err := productWarehouseRepoTx.PatchOne(c.Context(), productWarehouse.Id, map[string]any{"quantity": updatedQuantity}, nil); err != nil {
 		s.Log.Errorf("Failed to update product warehouse quantity: %+v", err)
-		return err
+		return rollback(err)
+	}
+
+	if err := tx.Commit().Error; err != nil {
+		s.Log.Errorf("Failed to commit transaction: %+v", err)
+		return rollback(err)
 	}

 	return nil