feat(BE): enhance product warehouse handling and automatic calculations for delivery and sales orders

internal/modules/inventory/adjustments/services/adjustment.service.go

@@ -117,39 +117,37 @@ func (s *adjustmentService) Adjustment(c *fiber.Ctx, req *validation.Create) (*e
 
 	var createdLogId uint
 
-	isProductWarehouseExist, err := s.ProductWarehouseRepo.ProductWarehouseExistByProductAndWarehouseID(ctx, uint(req.ProductID), uint(req.WarehouseID))
-	if err != nil {
-		s.Log.Errorf("Failed to check product warehouse existence: %+v", err)
-		return nil, fiber.NewError(fiber.StatusInternalServerError, "Failed to validate product warehouse")
+	var projectFlockKandangID *uint
+	pfk, err := s.ProjectFlockKandangRepo.GetActiveByKandangID(ctx, uint(req.WarehouseID))
+	if err == nil && pfk != nil {
+		idCopy := uint(pfk.Id)
+		projectFlockKandangID = &idCopy
 	}
-	if !isProductWarehouseExist {
-		projectFlockKandangID, err := s.getActiveProjectFlockKandangID(ctx, uint(req.WarehouseID))
-		if err != nil {
-			return nil, err
+
+	pw, err := s.ProductWarehouseRepo.FindByProductWarehouseAndPfk(
+		ctx,
+		uint(req.ProductID),
+		uint(req.WarehouseID),
+		projectFlockKandangID,
+	)
+	if err != nil {
+		if !errors.Is(err, gorm.ErrRecordNotFound) {
+			s.Log.Errorf("Failed to find product warehouse: %+v", err)
+			return nil, fiber.NewError(fiber.StatusInternalServerError, "Failed to get product warehouse")
 		}
+
 		newPW := &entity.ProductWarehouse{
 			ProductId:             uint(req.ProductID),
 			WarehouseId:           uint(req.WarehouseID),
 			Quantity:              0,
-			ProjectFlockKandangId: &projectFlockKandangID,
-			// CreatedBy:   1, // TODO: should Get from auth middleware
+			ProjectFlockKandangId: projectFlockKandangID,
 		}
 
 		if err := s.ProductWarehouseRepo.CreateOne(ctx, newPW, nil); err != nil {
 			s.Log.Errorf("Failed to create product warehouse: %+v", err)
 			return nil, fiber.NewError(fiber.StatusInternalServerError, "Failed to create product warehouse")
 		}
-		s.Log.Infof("Product warehouse created: %+v", newPW.Id)
-	}
-
-	pw, err := s.ProductWarehouseRepo.GetProductWarehouseByProductAndWarehouseID(
-		ctx,
-		uint(req.ProductID),
-		uint(req.WarehouseID),
-	)
-	if err != nil {
-		s.Log.Errorf("Failed to get product warehouse for project flock check: %+v", err)
-		return nil, fiber.NewError(fiber.StatusInternalServerError, "Failed to validate product warehouse")
+		pw = newPW
 	}
 
 	if err := common.EnsureProjectFlockNotClosedForProductWarehouses(

internal/modules/inventory/product-warehouses/repositories/product_warehouse.repository.go

@@ -18,6 +18,7 @@ type ProductWarehouseRepository interface {
 	ProductWarehouseExistByProductAndWarehouseID(ctx context.Context, productId, warehouseId uint) (bool, error)
 	ExistsByID(ctx context.Context, id uint) (bool, error)
 	GetProductWarehouseByProductAndWarehouseID(ctx context.Context, productId, warehouseId uint) (*entity.ProductWarehouse, error)
+	FindByProductWarehouseAndPfk(ctx context.Context, productID uint, warehouseID uint, projectFlockKandangID *uint) (*entity.ProductWarehouse, error)
 	GetByCategoryCodeAndWarehouseID(ctx context.Context, categoryCode string, warehouseId uint) ([]entity.ProductWarehouse, error)
 	GetLatestByCategoryCodeAndWarehouseID(ctx context.Context, categoryCode string, warehouseId uint, db *gorm.DB) (*entity.ProductWarehouse, error)
 	GetByFlagAndWarehouseID(ctx context.Context, flagName string, warehouseId uint) ([]entity.ProductWarehouse, error)
@@ -107,6 +108,20 @@ func (r *ProductWarehouseRepositoryImpl) GetProductWarehouseByProductAndWarehous
 	return &productWarehouse, nil
 }
 
+func (r *ProductWarehouseRepositoryImpl) FindByProductWarehouseAndPfk(ctx context.Context, productID uint, warehouseID uint, projectFlockKandangID *uint) (*entity.ProductWarehouse, error) {
+	var productWarehouse entity.ProductWarehouse
+
+	err := r.DB().WithContext(ctx).
+		Where("product_id = ? AND warehouse_id = ? AND project_flock_kandang_id IS NOT DISTINCT FROM ?", productID, warehouseID, projectFlockKandangID).
+		First(&productWarehouse).Error
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &productWarehouse, nil
+}
+
 func (r *ProductWarehouseRepositoryImpl) GetByCategoryCodeAndWarehouseID(ctx context.Context, categoryCode string, warehouseId uint) ([]entity.ProductWarehouse, error) {
 	var productWarehouses []entity.ProductWarehouse
 	q := r.DB().WithContext(ctx).Model(&entity.ProductWarehouse{}).

internal/modules/inventory/transfers/services/transfer.service.go

@@ -106,23 +106,17 @@ func (s transferService) GetAll(c *fiber.Ctx, params *validation.Query) ([]entit
 }
 
 func (s transferService) GetOne(c *fiber.Ctx, id uint) (*entity.StockTransfer, error) {
-	s.Log.Infof("Attempting to get StockTransfer with ID: %d", id)
 
 	transferPtr, err := s.StockTransferRepo.GetByID(c.Context(), id, func(db *gorm.DB) *gorm.DB {
 		return s.withRelations(db)
 	})
 	if err != nil {
-		s.Log.Errorf("Error getting StockTransfer ID %d: %+v", id, err)
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, fiber.NewError(fiber.StatusNotFound, "Transfer not found")
 		}
 		return nil, fiber.NewError(fiber.StatusInternalServerError, "Failed to get transfer")
 	}
 
-	if transferPtr != nil {
-		s.Log.Infof("StockTransfer %d has %d documents", transferPtr.Id, len(transferPtr.Documents))
-	}
-
 	return transferPtr, nil
 }
 
@@ -336,7 +330,9 @@ func (s *transferService) CreateOne(c *fiber.Ctx, req *validation.TransferReques
 					Files:            documentFiles,
 				})
 				if err != nil {
-					return fiber.NewError(fiber.StatusInternalServerError, fmt.Sprintf("Failed to upload document for delivery %d", idx+1))
+					s.Log.WithError(err).Errorf("Failed to upload document for delivery %d (delivery_id: %d, filename: %s)",
+						idx+1, deliveries[idx].Id, file.Filename)
+					return fiber.NewError(fiber.StatusInternalServerError, fmt.Sprintf("Failed to upload document for delivery %d: %v", idx+1, err))
 				}
 			}
 		}
@@ -396,7 +392,6 @@ func (s *transferService) CreateOne(c *fiber.Ctx, req *validation.TransferReques
 	})
 
 	if err != nil {
-		s.Log.Errorf("Transaction failed in CreateOne: %+v", err)
 		return nil, fiber.NewError(fiber.StatusInternalServerError, fmt.Sprintf("Failed to process transfer transaction: %v", err))
 	}