add delete snapshoot if change chickin date

internal/modules/production/chickins/controllers/chickin.controller.go

@@ -172,6 +172,23 @@ func (u *ChickinController) DeleteOne(c *fiber.Ctx) error {
 		})
 }
 
+func (u *ChickinController) UpdateChickInDate(c *fiber.Ctx) error {
+	req := new(validation.UpdateChickInDate)
+	if err := c.BodyParser(req); err != nil {
+		return fiber.NewError(fiber.StatusBadRequest, "Invalid request body")
+	}
+
+	if err := u.ChickinService.UpdateChickInDate(c, req); err != nil {
+		return err
+	}
+
+	return c.Status(fiber.StatusOK).JSON(response.Common{
+		Code:    fiber.StatusOK,
+		Status:  "success",
+		Message: "Chick in date berhasil diperbarui",
+	})
+}
+
 func (u *ChickinController) Approval(c *fiber.Ctx) error {
 	req := new(validation.Approve)
 

internal/modules/production/chickins/repositories/project_chickin.repository.go

@@ -2,6 +2,7 @@ package repository
 
 import (
 	"context"
+	"time"
 
 	"gitlab.com/mbugroup/lti-api.git/internal/common/repository"
 	entity "gitlab.com/mbugroup/lti-api.git/internal/entities"
@@ -18,6 +19,7 @@ type ProjectChickinRepository interface {
 	GetTotalChickinQtyByProjectFlockID(ctx context.Context, projectFlockID uint) (float64, error)
 	GetByProjectFlockKandangIDForUpdate(ctx context.Context, projectFlockKandangID uint) ([]entity.ProjectChickin, error)
 	UpdateUsageFields(ctx context.Context, tx *gorm.DB, chickinID uint, usageQty, pendingUsageQty float64) error
+	UpdateChickInDateByProjectFlockKandangID(ctx context.Context, tx *gorm.DB, pfkID uint, newDate time.Time) error
 }
 
 type ChickinRepositoryImpl struct {
@@ -134,3 +136,10 @@ func (r *ChickinRepositoryImpl) UpdateUsageFields(ctx context.Context, tx *gorm.
 			"pending_usage_qty": pendingUsageQty,
 		}).Error
 }
+
+func (r *ChickinRepositoryImpl) UpdateChickInDateByProjectFlockKandangID(ctx context.Context, tx *gorm.DB, pfkID uint, newDate time.Time) error {
+	return tx.WithContext(ctx).
+		Model(&entity.ProjectChickin{}).
+		Where("project_flock_kandang_id = ? AND deleted_at IS NULL", pfkID).
+		Update("chick_in_date", newDate).Error
+}

internal/modules/production/chickins/route.go

@@ -17,6 +17,7 @@ func ChickinRoutes(v1 fiber.Router, u user.UserService, s chickin.ChickinService
 
 	route.Get("/", m.RequirePermissions(m.P_ChickinsGetAll), ctrl.GetAll)
 	route.Post("/", m.RequirePermissions(m.P_ChickinsCreateOne), ctrl.CreateOne)
+	route.Patch("/chick-in-date", m.RequirePermissions(m.P_ChickinsCreateOne), ctrl.UpdateChickInDate)
 	route.Get("/:id", m.RequirePermissions(m.P_ChickinsGetOne), ctrl.GetOne)
 	// route.Patch("/:id", ctrl.UpdateOne)
 	route.Delete("/:id", ctrl.DeleteOne)

internal/modules/production/chickins/services/chickin.service.go

@@ -48,6 +48,7 @@ type ChickinService interface {
 	DeleteOne(ctx *fiber.Ctx, id uint) error
 	Approval(ctx *fiber.Ctx, req *validation.Approve) ([]entity.ProjectChickin, error)
 	EnsureChickInExists(ctx context.Context, projectFlockKandangID uint) error
+	UpdateChickInDate(ctx *fiber.Ctx, req *validation.UpdateChickInDate) error
 }
 
 type chickinService struct {
@@ -2110,3 +2111,38 @@ func (s chickinService) EnsureChickInExists(ctx context.Context, projectFlockKan
 
 	return fiber.NewError(fiber.StatusBadRequest, "Chick in project flock belum disetujui sehingga belum dapat membuat recording")
 }
+
+func (s chickinService) UpdateChickInDate(ctx *fiber.Ctx, req *validation.UpdateChickInDate) error {
+	if err := s.Validate.Struct(req); err != nil {
+		return err
+	}
+
+	newDate, err := time.Parse("2006-01-02", req.ChickInDate)
+	if err != nil {
+		return fiber.NewError(fiber.StatusBadRequest, "Format tanggal tidak valid, gunakan YYYY-MM-DD")
+	}
+
+	_, err = s.ProjectflockKandangRepo.GetByID(ctx.Context(), req.ProjectFlockKandangId)
+	if err != nil {
+		return fiber.NewError(fiber.StatusNotFound, "Project flock kandang tidak ditemukan")
+	}
+
+	if err := s.Repository.DB().WithContext(ctx.Context()).Transaction(func(tx *gorm.DB) error {
+		if err := s.Repository.UpdateChickInDateByProjectFlockKandangID(ctx.Context(), tx, req.ProjectFlockKandangId, newDate); err != nil {
+			return err
+		}
+
+		return tx.Exec(`
+			UPDATE recordings
+			SET day = GREATEST(0, (record_datetime::date - ?::date)::int),
+			    updated_at = NOW()
+			WHERE project_flock_kandangs_id = ?
+			  AND deleted_at IS NULL
+		`, req.ChickInDate, req.ProjectFlockKandangId).Error
+	}); err != nil {
+		return err
+	}
+
+	s.invalidateDepreciationSnapshots(ctx.Context(), nil, []uint{req.ProjectFlockKandangId}, newDate)
+	return nil
+}

internal/modules/production/chickins/validations/chickin.validation.go

@@ -27,3 +27,8 @@ type Approve struct {
 	ApprovableIds []uint  `json:"approvable_ids" validate:"required_strict,min=1,dive,gt=0"`
 	Notes         *string `json:"notes,omitempty" validate:"omitempty,max=500"`
 }
+
+type UpdateChickInDate struct {
+	ProjectFlockKandangId uint   `json:"project_flock_kandang_id" validate:"required,gt=0"`
+	ChickInDate           string `json:"chick_in_date" validate:"required,datetime=2006-01-02"`
+}

internal/modules/production/recordings/services/recording.service.go

@@ -409,15 +409,8 @@ func (s *recordingService) CreateOne(c *fiber.Ctx, req *validation.Create) (*ent
 		return nil, err
 	}
 	if err := s.ChickinSvc.EnsureChickInExists(ctx, pfk.Id); err != nil {
-		if !isLaying {
 		return nil, err
 	}
-		// LAYING fallback: kandang laying tidak punya project_chickins sendiri —
-		// populasinya dari laying transfer. Cek apakah ada executed laying transfer.
-		if fallbackErr := s.ensureLayingTransferExecutedForKandang(ctx, pfk.Id); fallbackErr != nil {
-			return nil, err
-		}
-	}
 	if s.ProductionStandardSvc != nil {
 		if err := s.ProductionStandardSvc.EnsureWeekStart(ctx, pfk.ProjectFlock.ProductionStandardId, category); err != nil {
 			return nil, err
@@ -4005,27 +3998,6 @@ func (s *recordingService) reflowRollbackRecordingInventory(ctx context.Context,
 	return nil
 }
 
-func (s *recordingService) ensureLayingTransferExecutedForKandang(ctx context.Context, pfkID uint) error {
-	var count int64
-	err := s.Repository.DB().WithContext(ctx).
-		Table("laying_transfer_targets ltt").
-		Joins("JOIN laying_transfers lt ON lt.id = ltt.laying_transfer_id").
-		Where("ltt.target_project_flock_kandang_id = ?", pfkID).
-		Where("ltt.deleted_at IS NULL").
-		Where("lt.deleted_at IS NULL").
-		Where("lt.executed_at IS NOT NULL").
-		Where("ltt.total_qty > 0").
-		Count(&count).Error
-	if err != nil {
-		s.Log.Errorf("Failed to check executed laying transfer for pfk_id=%d: %+v", pfkID, err)
-		return fiber.NewError(fiber.StatusInternalServerError, "Gagal memeriksa transfer laying")
-	}
-	if count == 0 {
-		return fiber.NewError(fiber.StatusBadRequest, "Kandang laying belum memiliki transfer laying yang telah dieksekusi sehingga belum dapat membuat recording")
-	}
-	return nil
-}
-
 func (s *recordingService) requireFIFO() error {
 	if s.FifoStockV2Svc == nil {
 		s.Log.Errorf("FIFO v2 service is not available for recording operations")