lti-api/internal/modules/repports/services/repport.service.go

package service

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"math"
	"sort"
	"strconv"
	"strings"
	"time"

	"gitlab.com/mbugroup/lti-api.git/internal/modules/repports/dto"
	repportRepo "gitlab.com/mbugroup/lti-api.git/internal/modules/repports/repositories"
	validation "gitlab.com/mbugroup/lti-api.git/internal/modules/repports/validations"
	"gitlab.com/mbugroup/lti-api.git/internal/utils"

	approvalService "gitlab.com/mbugroup/lti-api.git/internal/common/service"
	approvalDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/approvals/dto"
	expenseRepo "gitlab.com/mbugroup/lti-api.git/internal/modules/expenses/repositories"
	marketingRepo "gitlab.com/mbugroup/lti-api.git/internal/modules/marketing/repositories"
	areaDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/master/areas/dto"
	customerRepo "gitlab.com/mbugroup/lti-api.git/internal/modules/master/customers/repositories"
	productionStandardRepository "gitlab.com/mbugroup/lti-api.git/internal/modules/master/production-standards/repositories"
	supplierDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/master/suppliers/dto"
	warehouseDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/master/warehouses/dto"
	chickinRepo "gitlab.com/mbugroup/lti-api.git/internal/modules/production/chickins/repositories"
	recordingRepo "gitlab.com/mbugroup/lti-api.git/internal/modules/production/recordings/repositories"
	purchaseRepo "gitlab.com/mbugroup/lti-api.git/internal/modules/purchases/repositories"

	entity "gitlab.com/mbugroup/lti-api.git/internal/entities"

	"github.com/go-playground/validator/v10"
	"github.com/gofiber/fiber/v2"
	"github.com/sirupsen/logrus"
	"gorm.io/gorm"
)

type RepportService interface {
	GetExpense(ctx *fiber.Ctx, params *validation.ExpenseQuery) ([]dto.RepportExpenseListDTO, int64, error)
	GetMarketing(ctx *fiber.Ctx, params *validation.MarketingQuery) ([]dto.RepportMarketingItemDTO, int64, error)
	GetPurchaseSupplier(ctx *fiber.Ctx, params *validation.PurchaseSupplierQuery) ([]dto.PurchaseSupplierDTO, int64, error)
	GetDebtSupplier(ctx *fiber.Ctx, params *validation.DebtSupplierQuery) ([]dto.DebtSupplierDTO, int64, error)
	GetHppPerKandang(ctx *fiber.Ctx) (*dto.HppPerKandangResponseData, *dto.HppPerKandangMetaDTO, error)
	GetProductionResult(ctx *fiber.Ctx, params *validation.ProductionResultQuery) ([]dto.ProductionResultDTO, int64, error)
	GetCustomerPayment(ctx *fiber.Ctx, params *validation.CustomerPaymentQuery) ([]dto.CustomerPaymentReportItem, int64, error)
}

type repportService struct {
	Log                          *logrus.Logger
	Validate                     *validator.Validate
	DB                           *gorm.DB
	ExpenseRealizationRepo       expenseRepo.ExpenseRealizationRepository
	MarketingDeliveryRepo        marketingRepo.MarketingDeliveryProductRepository
	PurchaseRepo                 purchaseRepo.PurchaseRepository
	ChickinRepo                  chickinRepo.ProjectChickinRepository
	RecordingRepo                recordingRepo.RecordingRepository
	ApprovalSvc                  approvalService.ApprovalService
	PurchaseSupplierRepo         repportRepo.PurchaseSupplierRepository
	DebtSupplierRepo             repportRepo.DebtSupplierRepository
	HppPerKandangRepo            repportRepo.HppPerKandangRepository
	ProductionResultRepo         repportRepo.ProductionResultRepository
	CustomerPaymentRepo          repportRepo.CustomerPaymentRepository
	CustomerRepo                 customerRepo.CustomerRepository
	StandardGrowthDetailRepo     productionStandardRepository.StandardGrowthDetailRepository
	ProductionStandardDetailRepo productionStandardRepository.ProductionStandardDetailRepository
}

type HppCostAggregate struct {
	FeedCost    float64
	OvkCost     float64
	DocCost     float64
	DocQty      float64
	BudgetCost  float64
	ExpenseCost float64
}

func NewRepportService(
	db *gorm.DB,
	validate *validator.Validate,
	expenseRealizationRepo expenseRepo.ExpenseRealizationRepository,
	marketingDeliveryRepo marketingRepo.MarketingDeliveryProductRepository,
	purchaseRepo purchaseRepo.PurchaseRepository,
	chickinRepo chickinRepo.ProjectChickinRepository,
	recordingRepo recordingRepo.RecordingRepository,
	approvalSvc approvalService.ApprovalService,
	purchaseSupplierRepo repportRepo.PurchaseSupplierRepository,
	debtSupplierRepo repportRepo.DebtSupplierRepository,
	hppPerKandangRepo repportRepo.HppPerKandangRepository,
	productionResultRepo repportRepo.ProductionResultRepository,
	customerPaymentRepo repportRepo.CustomerPaymentRepository,
	customerRepo customerRepo.CustomerRepository,
	standardGrowthDetailRepo productionStandardRepository.StandardGrowthDetailRepository,
	productionStandardDetailRepo productionStandardRepository.ProductionStandardDetailRepository,
) RepportService {
	return &repportService{
		Log:                          utils.Log,
		Validate:                     validate,
		DB:                           db,
		ExpenseRealizationRepo:       expenseRealizationRepo,
		MarketingDeliveryRepo:        marketingDeliveryRepo,
		PurchaseRepo:                 purchaseRepo,
		ChickinRepo:                  chickinRepo,
		RecordingRepo:                recordingRepo,
		ApprovalSvc:                  approvalSvc,
		PurchaseSupplierRepo:         purchaseSupplierRepo,
		DebtSupplierRepo:             debtSupplierRepo,
		HppPerKandangRepo:            hppPerKandangRepo,
		ProductionResultRepo:         productionResultRepo,
		CustomerPaymentRepo:          customerPaymentRepo,
		CustomerRepo:                 customerRepo,
		StandardGrowthDetailRepo:     standardGrowthDetailRepo,
		ProductionStandardDetailRepo: productionStandardDetailRepo,
	}
}

func (s *repportService) GetExpense(c *fiber.Ctx, params *validation.ExpenseQuery) ([]dto.RepportExpenseListDTO, int64, error) {
	if err := s.Validate.Struct(params); err != nil {
		return nil, 0, err
	}

	offset := (params.Page - 1) * params.Limit

	realizations, total, err := s.ExpenseRealizationRepo.GetAllWithFilters(c.Context(), offset, params.Limit, params)
	if err != nil {
		s.Log.Errorf("GetAllWithFilters error: %v", err)
		return nil, 0, err
	}

	result := dto.ToRepportExpenseListDTOs(realizations)

	expenseIDs := make([]uint, 0, len(result))
	for i := range result {
		expenseIDs = append(expenseIDs, uint(result[i].Id))
	}

	approvals, err := s.ApprovalSvc.LatestByTargets(c.Context(), utils.ApprovalWorkflowExpense, expenseIDs, func(db *gorm.DB) *gorm.DB {
		return db.Preload("ActionUser")
	})
	if err != nil {
		s.Log.Warnf("LatestByTargets error: %v", err)
	}

	for i := range result {
		expenseIDAsUint := uint(result[i].Id)
		if approval, exists := approvals[expenseIDAsUint]; exists && approval != nil {
			mapped := approvalDTO.ToApprovalDTO(*approval)
			result[i].LatestApproval = &mapped
		}
	}

	return result, total, nil
}

func (s *repportService) GetMarketing(c *fiber.Ctx, params *validation.MarketingQuery) ([]dto.RepportMarketingItemDTO, int64, error) {
	if err := s.Validate.Struct(params); err != nil {
		return nil, 0, err
	}

	offset := (params.Page - 1) * params.Limit

	deliveryProducts, total, err := s.MarketingDeliveryRepo.GetAllWithFilters(c.Context(), offset, params.Limit, params)
	if err != nil {
		return nil, 0, err
	}

	projectFlockIDMap := make(map[uint]bool)
	hppMap := make(map[uint]float64)

	for _, dp := range deliveryProducts {
		if projectFlockKandang := dp.MarketingProduct.ProductWarehouse.ProjectFlockKandang; projectFlockKandang != nil {
			projectFlockID := projectFlockKandang.ProjectFlockId
			if projectFlockID > 0 && !projectFlockIDMap[projectFlockID] {
				projectFlockIDMap[projectFlockID] = true

				category := projectFlockKandang.ProjectFlock.Category
				hppPerKg := s.calculateHppPricePerKg(c.Context(), projectFlockID, category)
				hppMap[projectFlockID] = hppPerKg
			}
		}
	}

	items := dto.ToMarketingReportItems(deliveryProducts, hppMap)
	return items, total, nil
}

func (s *repportService) calculateHppPricePerKg(ctx context.Context, projectFlockID uint, category string) float64 {
	totalCost := s.getTotalProjectCost(ctx, projectFlockID)
	if totalCost == 0 {
		return 0
	}

	chickinQty, err := s.ChickinRepo.GetTotalChickinQtyByProjectFlockID(ctx, projectFlockID)
	if err != nil {
		s.Log.Warnf("HPP calculation: Failed to get chickin qty for project flock ID %d: %v", projectFlockID, err)
	}

	depletion, err := s.RecordingRepo.GetTotalDepletionByProjectFlockID(ctx, projectFlockID)
	if err != nil {
		s.Log.Warnf("HPP calculation: Failed to get depletion for project flock ID %d: %v", projectFlockID, err)
	}

	avgWeight, err := s.RecordingRepo.GetLatestAvgWeightByProjectFlockID(ctx, projectFlockID)
	if err != nil {
		s.Log.Warnf("HPP calculation: Failed to get avg weight for project flock ID %d: %v", projectFlockID, err)
	}

	var totalWeight float64
	if utils.ProjectFlockCategory(category) == utils.ProjectFlockCategoryGrowing {
		totalWeight = (chickinQty - depletion) * avgWeight
	} else {
		eggWeight, err := s.RecordingRepo.GetTotalEggProductionWeightByProjectFlockID(ctx, projectFlockID)
		if err != nil {
			s.Log.Warnf("HPP calculation: Failed to get egg weight for project flock ID %d: %v", projectFlockID, err)
		}
		totalWeight = (chickinQty-depletion)*avgWeight + eggWeight
	}

	if totalWeight == 0 {
		return 0
	}

	hppPricePerKg := totalCost / totalWeight
	return hppPricePerKg
}

func (s *repportService) getTotalProjectCost(ctx context.Context, projectFlockID uint) float64 {
	if projectFlockID == 0 {
		return 0
	}

	purchases, err := s.PurchaseRepo.GetItemsByProjectFlockID(ctx, projectFlockID)
	if err != nil {
		s.Log.Errorf("getTotalProjectCost: GetItemsByProjectFlockID error for project flock ID %d: %v", projectFlockID, err)
		return 0
	}

	cost := float64(0)
	purchaseCost := float64(0)
	for _, p := range purchases {
		purchaseCost += p.TotalPrice
	}
	cost += purchaseCost

	realizations, err := s.ExpenseRealizationRepo.GetByProjectFlockID(ctx, projectFlockID)
	if err != nil {
		s.Log.Warnf("getTotalProjectCost: GetByProjectFlockID error for project flock ID %d: %v", projectFlockID, err)
	}

	bopCost := float64(0)
	for _, r := range realizations {
		if r.ExpenseNonstock != nil && r.ExpenseNonstock.Expense != nil &&
			r.ExpenseNonstock.Expense.Category == string(utils.ExpenseCategoryBOP) {
			bopCost += r.Price * r.Qty
		}
	}
	cost += bopCost

	return cost
}

func (s *repportService) GetProductionResult(ctx *fiber.Ctx, params *validation.ProductionResultQuery) ([]dto.ProductionResultDTO, int64, error) {
	if err := s.Validate.Struct(params); err != nil {
		return nil, 0, err
	}

	const (
		recordsPerWeek     = 7
		defaultStartWoa    = 18
		defaultStdBw       = 1951
		defaultBw          = 0
		defaultUniformText = "90% up"
	)

	if params.Limit <= 0 {
		params.Limit = 10
	}
	if params.Page <= 0 {
		params.Page = 1
	}

	weeksPerPage := params.Limit
	recordLimit := weeksPerPage * recordsPerWeek
	if recordLimit <= 0 {
		recordLimit = recordsPerWeek
	}
	recordOffset := (params.Page - 1) * recordLimit
	if recordOffset < 0 {
		recordOffset = 0
	}

	recordings, totalRecordings, err := s.ProductionResultRepo.GetRecordingsByProjectFlockKandang(ctx.Context(), params.ProjectFlockKandangID, recordOffset, recordLimit)
	if err != nil {
		return nil, 0, err
	}

	dailyResults := make([]dto.ProductionResultDTO, len(recordings))
	for i := range recordings {
		dailyResults[i] = mapRecordingToProductionResultDTO(recordings[i])
		if dailyResults[i].StdUniformity == "" {
			dailyResults[i].StdUniformity = defaultUniformText
		}
	}

	weeklyResults := summarizeProductionResults(dailyResults, recordsPerWeek)

	var productionStandardID uint
	if s.ProductionResultRepo != nil {
		standardID, err := s.ProductionResultRepo.GetProductionStandardIDByProjectFlockKandangID(ctx.Context(), params.ProjectFlockKandangID)
		if err != nil {
			if !errors.Is(err, gorm.ErrRecordNotFound) {
				return nil, 0, err
			}
		} else {
			productionStandardID = standardID
		}
	}

	standardDetailCache := make(map[int]*entity.ProductionStandardDetail)
	growthDetailCache := make(map[int]*entity.StandardGrowthDetail)

	weeks := make([]int, len(weeklyResults))
	for i := range weeklyResults {
		weeks[i] = defaultStartWoa + i
	}
	uniformityMap, err := s.getUniformityByWeek(ctx.Context(), params.ProjectFlockKandangID, weeks)
	if err != nil {
		return nil, 0, err
	}

	var cumulativeButir int64
	var cumulativeKg float64
	for i := range weeklyResults {
		weeklyResults[i].Woa = float64(defaultStartWoa + i)
		weeklyResults[i].StdBw = defaultStdBw
		weeklyResults[i].Bw = defaultBw
		if weeklyResults[i].StdUniformity == "" {
			weeklyResults[i].StdUniformity = defaultUniformText
		}
		if uniformity, ok := uniformityMap[defaultStartWoa+i]; ok {
			weeklyResults[i].Uniformity = uniformity.Uniformity
			if uniformity.AvgWeight != nil {
				weeklyResults[i].Bw = *uniformity.AvgWeight
			}
		}

		cumulativeButir += weeklyResults[i].ButiranJumlah
		weeklyResults[i].TotalButir = cumulativeButir

		cumulativeKg += weeklyResults[i].KgJumlah
		weeklyResults[i].TotalKg = cumulativeKg

		if productionStandardID == 0 {
			continue
		}

		week := int(weeklyResults[i].Woa)
		if s.ProductionStandardDetailRepo != nil {
			detail, ok := standardDetailCache[week]
			if !ok {
				fetched, fetchErr := s.ProductionStandardDetailRepo.GetByStandardIDAndWeek(ctx.Context(), productionStandardID, week)
				if fetchErr != nil {
					if !errors.Is(fetchErr, gorm.ErrRecordNotFound) {
						return nil, 0, fetchErr
					}
				} else {
					detail = fetched
				}
				standardDetailCache[week] = detail
			}

			if detail != nil {
				if detail.TargetHenDayProduction != nil {
					weeklyResults[i].HdStd = *detail.TargetHenDayProduction
				}
				if detail.TargetHenHouseProduction != nil {
					weeklyResults[i].HhStd = *detail.TargetHenHouseProduction
				}
				if detail.TargetEggWeight != nil {
					weeklyResults[i].EwStd = *detail.TargetEggWeight
				}
				if detail.TargetEggMass != nil {
					weeklyResults[i].EmStd = *detail.TargetEggMass
				}
				if detail.StandardFCR != nil {
					weeklyResults[i].FcrStd = *detail.StandardFCR
				}
			}
		}

		if s.StandardGrowthDetailRepo != nil {
			detail, ok := growthDetailCache[week]
			if !ok {
				fetched, fetchErr := s.StandardGrowthDetailRepo.GetByStandardIDAndWeek(ctx.Context(), productionStandardID, week)
				if fetchErr != nil {
					if !errors.Is(fetchErr, gorm.ErrRecordNotFound) {
						return nil, 0, fetchErr
					}
				} else {
					detail = fetched
				}
				growthDetailCache[week] = detail
			}

			if detail != nil && detail.FeedIntake != nil {
				weeklyResults[i].FiStd = *detail.FeedIntake
			}
			if detail != nil && detail.TargetMeanBw != nil {
				weeklyResults[i].StdBw = *detail.TargetMeanBw
			}
		}
	}

	totalWeeks := int64(math.Ceil(float64(totalRecordings) / float64(recordsPerWeek)))

	return weeklyResults, totalWeeks, nil
}

func (s *repportService) GetCustomerPayment(ctx *fiber.Ctx, params *validation.CustomerPaymentQuery) ([]dto.CustomerPaymentReportItem, int64, error) {
	if err := s.Validate.Struct(params); err != nil {
		return nil, 0, err
	}

	// Determine customer IDs to process
	var customerIDs []uint
	var totalCustomers int64

	if len(params.CustomerIDs) > 0 {
		// Specific customer IDs mode (no pagination)
		customerIDs = params.CustomerIDs
		totalCustomers = int64(len(customerIDs))

		if len(customerIDs) == 0 {
			return []dto.CustomerPaymentReportItem{}, 0, nil
		}
	} else {
		// Multiple customers mode with pagination
		page := params.Page
		limit := params.Limit
		if page < 1 {
			page = 1
		}
		if limit < 1 {
			limit = 10
		}

		offset := (page - 1) * limit

		var err error
		customerIDs, totalCustomers, err = s.CustomerPaymentRepo.GetCustomerIDsWithTransactions(ctx.Context(), limit, offset)
		if err != nil {
			return nil, 0, err
		}

		if len(customerIDs) == 0 {
			return []dto.CustomerPaymentReportItem{}, 0, nil
		}
	}

	var result []dto.CustomerPaymentReportItem
	for _, customerID := range customerIDs {
		item, err := s.processCustomerPayment(ctx.Context(), customerID, params)
		if err != nil {
			return nil, 0, err
		}

		if len(item.Rows) > 0 {
			result = append(result, item)
		}
	}

	totalCustomers = int64(len(result))
	return result, totalCustomers, nil
}

func (s *repportService) processCustomerPayment(ctx context.Context, customerID uint, params *validation.CustomerPaymentQuery) (dto.CustomerPaymentReportItem, error) {

	customer, err := s.CustomerRepo.GetByID(ctx, customerID, nil)
	if err != nil {
		return dto.CustomerPaymentReportItem{}, err
	}

	initialBalance, err := s.CustomerPaymentRepo.GetInitialBalanceByCustomer(ctx, customerID)
	if err != nil {
		return dto.CustomerPaymentReportItem{}, err
	}

	cid := customerID
	transactions, err := s.CustomerPaymentRepo.GetCustomerPaymentTransactions(ctx, &cid)
	if err != nil {
		return dto.CustomerPaymentReportItem{}, err
	}

	rows := make([]dto.CustomerPaymentReportRow, 0, len(transactions))
	runningBalance := initialBalance

	for i, tx := range transactions {

		previousBalance := runningBalance

		row := dto.ToCustomerPaymentReportRow(tx)

		if tx.TransactionType == "SALES" {
			runningBalance -= tx.TotalPrice
			status, paymentDate := s.determineSalesStatusAndPaymentDate(transactions, i, previousBalance, runningBalance)
			row.Status = status

			if status == "LUNAS" {
				if paymentDate != nil {
					days := int(paymentDate.Sub(tx.TransDate).Hours() / 24)
					row.AgingDay = &days
				} else {
					days := 0
					row.AgingDay = &days
				}
			} else {
				days := int(time.Since(tx.TransDate).Hours() / 24)
				row.AgingDay = &days
			}
		} else if tx.TransactionType == "PAYMENT" {
			runningBalance += tx.PaymentAmount
			row.Status = ""
			row.AgingDay = nil
		}

		row.AccountsReceivable = runningBalance
		rows = append(rows, row)
	}

	if params.StartDate != "" || params.EndDate != "" {
		filteredRows := make([]dto.CustomerPaymentReportRow, 0, len(rows))
		location, err := time.LoadLocation("Asia/Jakarta")
		if err != nil {
			return dto.CustomerPaymentReportItem{}, err
		}

		var startDate, endDate *time.Time
		if params.StartDate != "" {
			parsed, err := time.ParseInLocation("2006-01-02", params.StartDate, location)
			if err != nil {
				return dto.CustomerPaymentReportItem{}, err
			}
			startDate = &parsed
		}
		if params.EndDate != "" {
			parsed, err := time.ParseInLocation("2006-01-02", params.EndDate, location)
			if err != nil {
				return dto.CustomerPaymentReportItem{}, err
			}
			endOfDay := time.Date(parsed.Year(), parsed.Month(), parsed.Day(), 23, 59, 59, 999999999, location)
			endDate = &endOfDay
		}

		for _, row := range rows {
			transDate := row.TransDate.In(location)
			if startDate != nil && transDate.Before(*startDate) {
				continue
			}
			if endDate != nil && transDate.After(*endDate) {
				continue
			}
			filteredRows = append(filteredRows, row)
		}

		rows = filteredRows
	}

	summary := dto.ToCustomerPaymentReportSummary(rows, initialBalance)

	return dto.ToCustomerPaymentReportItem(*customer, initialBalance, rows, summary), nil
}

func (s *repportService) determineSalesStatusAndPaymentDate(transactions []repportRepo.CustomerPaymentTransaction, currentIndex int, previousBalance, currentBalance float64) (string, *time.Time) {
	currentSales := transactions[currentIndex]

	// Status Logic:
	// 1. LUNAS: previousBalance >= salesAmount (paid from deposit)
	// 2. LUNAS: future payments make AR >= 0 (eventually paid)
	// 3. DIBAYAR SEBAGIAN: has payment but not enough
	// 4. BELUM LUNAS: no payment at all

	if previousBalance >= currentSales.TotalPrice {
		// Cari payment yang digunakan untuk melunasi sales ini dengan FIFO
		// Track payment allocations that are consumed by previous sales
		type paymentAllocation struct {
			date     time.Time
			amount   float64
			consumed float64
		}
		allocations := []paymentAllocation{}
		runningBalance := 0.0

		// Process all transactions before current sales to build allocation map
		for i := 0; i < currentIndex; i++ {
			if transactions[i].TransactionType == "PAYMENT" {
				allocations = append(allocations, paymentAllocation{
					date:     transactions[i].TransDate,
					amount:   transactions[i].PaymentAmount,
					consumed: 0,
				})
				runningBalance += transactions[i].PaymentAmount
			} else if transactions[i].TransactionType == "SALES" {
				salesAmount := transactions[i].TotalPrice
				remainingToConsume := salesAmount

				// Consume from oldest allocations first (FIFO)
				for j := range allocations {
					if remainingToConsume <= 0 {
						break
					}
					available := allocations[j].amount - allocations[j].consumed
					if available > 0 {
						consume := available
						if consume > remainingToConsume {
							consume = remainingToConsume
						}
						allocations[j].consumed += consume
						remainingToConsume -= consume
					}
				}
				runningBalance -= salesAmount
			}
		}

		// Now find which allocation covers the current sales
		amountNeeded := currentSales.TotalPrice
		for _, alloc := range allocations {
			available := alloc.amount - alloc.consumed
			if available > 0 {
				if amountNeeded <= available {
					// This allocation fully covers the sales
					return "LUNAS", &alloc.date
				} else {
					// This allocation partially covers, continue to next
					amountNeeded -= available
				}
			}
		}

		// If we get here, use the oldest allocation
		if len(allocations) > 0 {
			return "LUNAS", &allocations[0].date
		}
		return "LUNAS", nil
	}

	hasPartialPaymentFromBalance := previousBalance > 0 && previousBalance < currentSales.TotalPrice

	futureBalance := currentBalance
	hasPayment := false
	var paymentDateThatMadeItLunas *time.Time

	for i := currentIndex + 1; i < len(transactions); i++ {
		if transactions[i].TransactionType == "PAYMENT" {
			futureBalance += transactions[i].PaymentAmount
			hasPayment = true

			if futureBalance >= 0 {
				paymentDateThatMadeItLunas = &transactions[i].TransDate
				return "LUNAS", paymentDateThatMadeItLunas
			}
		} else if transactions[i].TransactionType == "SALES" {
			futureBalance -= transactions[i].TotalPrice
		}
	}

	if hasPayment || hasPartialPaymentFromBalance {
		return "DIBAYAR SEBAGIAN", nil
	}

	return "BELUM LUNAS", nil
}

func mapRecordingToProductionResultDTO(record entity.Recording) dto.ProductionResultDTO {
	result := dto.ProductionResultDTO{
		CreatedAt:     record.CreatedAt,
		UpdatedAt:     record.UpdatedAt,
		StdUniformity: "90% up",
		DepKum:        valueOrZero(record.CumDepletionRate),
		DepStd:        valueOrZero(record.TotalDepletionQty),
		Hd:            valueOrZero(record.HenDay),
		Fi:            valueOrZero(record.FeedIntake),
		Fcr:           valueOrZero(record.FcrValue),
		Hh:            valueOrZero(record.HenHouse),
		Em:            valueOrZero(record.EggMass),
		Ew:            valueOrZero(record.EggWeight),
	}

	if record.Day != nil {
		result.Woa = float64(*record.Day)
	}
	// avgWeight := calculateAverageBodyWeight(record.BodyWeights)
	avgWeight := 1.0
	if avgWeight > 0 {
		result.Bw = avgWeight
	}

	eggSummary := summarizeEggs(record.Eggs)
	result.ButiranUtuh = eggSummary.Utuh
	result.ButiranPutih = eggSummary.Putih
	result.ButiranRetak = eggSummary.Retak
	result.ButiranPecah = eggSummary.Pecah
	result.ButiranJumlah = eggSummary.TotalQty
	result.TotalButir = eggSummary.TotalQty
	result.KgUtuh = eggSummary.KgUtuh
	result.KgPutih = eggSummary.KgPutih
	result.KgRetak = eggSummary.KgRetak
	result.KgPecah = eggSummary.KgPecah
	result.KgJumlah = eggSummary.TotalKg
	result.TotalKg = eggSummary.TotalKg

	if eggSummary.TotalQty > 0 {
		total := float64(eggSummary.TotalQty)
		result.PersenUtuh = roundFloat((float64(result.ButiranUtuh)/total)*100, 2)
		result.PersenPutih = roundFloat((float64(result.ButiranPutih)/total)*100, 2)
		result.PersenRetak = roundFloat((float64(result.ButiranRetak)/total)*100, 2)
		result.PersenPecah = roundFloat((float64(result.ButiranPecah)/total)*100, 2)
	}

	return result
}

// func calculateAverageBodyWeight(bodyWeights []entity.RecordingBW) float64 {
// 	var totalQty float64
// 	var totalWeight float64

// 	for _, bw := range bodyWeights {
// 		totalQty += bw.Qty
// 		if bw.TotalWeight > 0 {
// 			totalWeight += bw.TotalWeight
// 		} else {
// 			totalWeight += bw.AvgWeight * bw.Qty
// 		}
// 	}

// 	if totalQty == 0 {
// 		return 0
// 	}

// 	return totalWeight / totalQty
// }

type eggSummary struct {
	TotalQty int64
	TotalKg  float64

	Utuh  int64
	Putih int64
	Retak int64
	Pecah int64

	KgUtuh  float64
	KgPutih float64
	KgRetak float64
	KgPecah float64
}

func summarizeEggs(eggs []entity.RecordingEgg) eggSummary {
	var summary eggSummary

	for _, egg := range eggs {
		qty := int64(egg.Qty)
		weightKg := valueOrZero(egg.Weight)

		summary.TotalQty += qty
		summary.TotalKg += weightKg

		if flagType, ok := getEggFlagType(egg); ok {
			switch flagType {
			case utils.FlagTelurUtuh:
				summary.Utuh += qty
				summary.KgUtuh += weightKg
			case utils.FlagTelurPutih:
				summary.Putih += qty
				summary.KgPutih += weightKg
			case utils.FlagTelurRetak:
				summary.Retak += qty
				summary.KgRetak += weightKg
			case utils.FlagTelurPecah:
				summary.Pecah += qty
				summary.KgPecah += weightKg
			}
		}
	}

	return summary
}

func valueOrZero(value *float64) float64 {
	if value == nil {
		return 0
	}
	return *value
}

func roundFloat(val float64, precision int) float64 {
	if precision < 0 {
		return val
	}
	factor := math.Pow(10, float64(precision))
	return math.Round(val*factor) / factor
}

func getEggFlagType(egg entity.RecordingEgg) (utils.FlagType, bool) {
	if egg.ProductFlagName == nil || *egg.ProductFlagName == "" {
		return "", false
	}

	flagType := utils.FlagType(*egg.ProductFlagName)
	switch flagType {
	case utils.FlagTelurUtuh, utils.FlagTelurPutih, utils.FlagTelurRetak, utils.FlagTelurPecah:
		return flagType, true
	}

	return "", false
}

type uniformityWeekData struct {
	Uniformity float64
	AvgWeight  *float64
}

type uniformityChartPayload struct {
	Statistics *uniformityChartStats `json:"statistics"`
}

type uniformityChartStats struct {
	AverageWeight *float64 `json:"average_weight"`
}

func (s *repportService) getUniformityByWeek(ctx context.Context, projectFlockKandangID uint, weeks []int) (map[int]uniformityWeekData, error) {
	result := make(map[int]uniformityWeekData, len(weeks))
	if projectFlockKandangID == 0 || len(weeks) == 0 {
		return result, nil
	}

	var rows []entity.ProjectFlockKandangUniformity
	if err := s.DB.WithContext(ctx).
		Model(&entity.ProjectFlockKandangUniformity{}).
		Select("week, uniformity, uniform_date, id").
		Where("project_flock_kandang_id = ?", projectFlockKandangID).
		Where("week IN ?", weeks).
		Order("uniform_date DESC").
		Order("id DESC").
		Find(&rows).Error; err != nil {
		return nil, err
	}

	for _, row := range rows {
		if _, exists := result[row.Week]; exists {
			continue
		}
		result[row.Week] = uniformityWeekData{
			Uniformity: row.Uniformity,
			AvgWeight:  extractAverageWeight(row.ChartData, s.Log),
		}
	}

	return result, nil
}

func extractAverageWeight(raw json.RawMessage, log *logrus.Logger) *float64 {
	if len(raw) == 0 {
		return nil
	}

	var payload uniformityChartPayload
	if err := json.Unmarshal(raw, &payload); err != nil {
		if log != nil {
			log.WithError(err).Warn("uniformity chart_data decode failed")
		}
		return nil
	}
	if payload.Statistics == nil {
		return nil
	}
	return payload.Statistics.AverageWeight
}

func summarizeProductionResults(daily []dto.ProductionResultDTO, groupSize int) []dto.ProductionResultDTO {
	if groupSize <= 0 || len(daily) == 0 {
		return daily
	}

	result := make([]dto.ProductionResultDTO, 0, (len(daily)+groupSize-1)/groupSize)
	for i := 0; i < len(daily); i += groupSize {
		end := i + groupSize
		if end > len(daily) {
			end = len(daily)
		}
		result = append(result, aggregateProductionResultGroup(daily[i:end], groupSize))
	}

	return result
}

func aggregateProductionResultGroup(group []dto.ProductionResultDTO, groupSize int) dto.ProductionResultDTO {
	count := len(group)
	if count == 0 {
		return dto.ProductionResultDTO{}
	}

	agg := dto.ProductionResultDTO{
		CreatedAt:     group[0].CreatedAt,
		UpdatedAt:     group[0].UpdatedAt,
		StdUniformity: group[0].StdUniformity,
	}

	var sumBw, sumStdBw, sumUniformity float64
	var sumDepStd float64
	var sumKgUtuh, sumKgPutih, sumKgRetak, sumKgPecah float64
	var sumKgJumlah, sumTotalKg float64
	var sumPersenUtuh, sumPersenPutih, sumPersenRetak, sumPersenPecah float64
	var percentSamples int
	var sumHd, sumHdStd float64
	var sumFi, sumFiStd float64
	var sumEm, sumEmStd float64
	var sumEw, sumEwStd float64
	var sumFcr, sumFcrStd float64
	var sumHh, sumHhStd float64

	var sumButiranUtuh, sumButiranPutih int64
	var sumButiranRetak, sumButiranPecah int64
	var sumButiranJumlah, sumTotalButir int64

	for _, item := range group {
		sumBw += item.Bw
		sumStdBw += item.StdBw
		sumUniformity += item.Uniformity
		sumDepStd += item.DepStd
		sumKgUtuh += item.KgUtuh
		sumKgPutih += item.KgPutih
		sumKgRetak += item.KgRetak
		sumKgPecah += item.KgPecah
		sumKgJumlah += item.KgJumlah
		sumTotalKg += item.TotalKg
		if item.ButiranJumlah > 0 {
			sumPersenUtuh += item.PersenUtuh
			sumPersenPutih += item.PersenPutih
			sumPersenRetak += item.PersenRetak
			sumPersenPecah += item.PersenPecah
			percentSamples++
		}
		sumHd += item.Hd
		sumHdStd += item.HdStd
		sumFi += item.Fi
		sumFiStd += item.FiStd
		sumEm += item.Em
		sumEmStd += item.EmStd
		sumEw += item.Ew
		sumEwStd += item.EwStd
		sumFcr += item.Fcr
		sumFcrStd += item.FcrStd
		sumHh += item.Hh
		sumHhStd += item.HhStd

		sumButiranUtuh += item.ButiranUtuh
		sumButiranPutih += item.ButiranPutih
		sumButiranRetak += item.ButiranRetak
		sumButiranPecah += item.ButiranPecah
		sumButiranJumlah += item.ButiranJumlah
		sumTotalButir += item.TotalButir
	}

	divider := float64(count)
	if divider == 0 {
		divider = 1
	}
	weeklyDivider := float64(groupSize)
	if weeklyDivider == 0 {
		weeklyDivider = divider
	}

	agg.Bw = sumBw / divider
	agg.StdBw = sumStdBw / divider
	agg.Uniformity = sumUniformity / divider
	agg.DepKum = group[count-1].DepKum
	agg.DepStd = sumDepStd / divider
	agg.KgUtuh = sumKgUtuh
	agg.KgPutih = sumKgPutih
	agg.KgRetak = sumKgRetak
	agg.KgPecah = sumKgPecah
	agg.KgJumlah = sumKgJumlah
	agg.TotalKg = sumTotalKg

	agg.ButiranUtuh = sumButiranUtuh
	agg.ButiranPutih = sumButiranPutih
	agg.ButiranRetak = sumButiranRetak
	agg.ButiranPecah = sumButiranPecah
	agg.ButiranJumlah = sumButiranJumlah
	agg.TotalButir = sumTotalButir

	if percentSamples > 0 {
		percentDivider := float64(percentSamples)
		agg.PersenUtuh = roundFloat(sumPersenUtuh/percentDivider, 2)
		agg.PersenPutih = roundFloat(sumPersenPutih/percentDivider, 2)
		agg.PersenRetak = roundFloat(sumPersenRetak/percentDivider, 2)
		agg.PersenPecah = roundFloat(sumPersenPecah/percentDivider, 2)
	}

	agg.Hd = roundFloat(sumHd/weeklyDivider, 2)
	agg.HdStd = sumHdStd / divider
	agg.Fi = roundFloat(sumFi/weeklyDivider, 2)
	agg.FiStd = sumFiStd / divider
	agg.Em = group[count-1].Em
	agg.EmStd = sumEmStd / divider
	agg.Ew = group[count-1].Ew
	agg.EwStd = sumEwStd / divider
	agg.Fcr = roundFloat(sumFcr/weeklyDivider, 2)
	agg.FcrStd = sumFcrStd / divider
	agg.Hh = roundFloat(sumHh/weeklyDivider, 2)
	agg.HhStd = sumHhStd / divider

	return agg
}

func (s *repportService) GetPurchaseSupplier(c *fiber.Ctx, params *validation.PurchaseSupplierQuery) ([]dto.PurchaseSupplierDTO, int64, error) {
	if err := s.Validate.Struct(params); err != nil {
		return nil, 0, err
	}

	offset := (params.Page - 1) * params.Limit
	if offset < 0 {
		offset = 0
	}

	suppliers, totalSuppliers, err := s.PurchaseSupplierRepo.GetSuppliersWithPurchases(c.Context(), offset, params.Limit, params)
	if err != nil {
		return nil, 0, err
	}

	if totalSuppliers == 0 || len(suppliers) == 0 {
		return []dto.PurchaseSupplierDTO{}, totalSuppliers, nil
	}

	supplierMap := make(map[uint]entity.Supplier, len(suppliers))
	supplierIDs := make([]uint, 0, len(suppliers))
	for _, supplier := range suppliers {
		supplierMap[supplier.Id] = supplier
		supplierIDs = append(supplierIDs, supplier.Id)
	}

	items, err := s.PurchaseSupplierRepo.GetItemsBySuppliers(c.Context(), supplierIDs, params)
	if err != nil {
		return nil, 0, err
	}

	itemsBySupplier := make(map[uint][]entity.PurchaseItem)
	for _, item := range items {
		if item.Purchase == nil {
			continue
		}
		supplierID := item.Purchase.SupplierId
		itemsBySupplier[supplierID] = append(itemsBySupplier[supplierID], item)
	}

	result := make([]dto.PurchaseSupplierDTO, 0, len(supplierIDs))
	for _, supplierID := range supplierIDs {
		supplier, exists := supplierMap[supplierID]
		if !exists {
			continue
		}

		supplierItems := itemsBySupplier[supplierID]
		dtoItem := dto.ToPurchaseSupplierDTO(supplier, supplierItems)
		result = append(result, dtoItem)
	}

	return result, totalSuppliers, nil
}

func (s *repportService) GetDebtSupplier(c *fiber.Ctx, params *validation.DebtSupplierQuery) ([]dto.DebtSupplierDTO, int64, error) {
	if params.FilterBy == "" {
		params.FilterBy = "received_date"
	}

	if err := s.Validate.Struct(params); err != nil {
		return nil, 0, err
	}

	offset := (params.Page - 1) * params.Limit
	if offset < 0 {
		offset = 0
	}

	suppliers, totalSuppliers, err := s.DebtSupplierRepo.GetSuppliersWithPurchases(c.Context(), offset, params.Limit, params)
	if err != nil {
		return nil, 0, err
	}
	if totalSuppliers == 0 || len(suppliers) == 0 {
		return []dto.DebtSupplierDTO{}, totalSuppliers, nil
	}

	supplierMap := make(map[uint]entity.Supplier, len(suppliers))
	supplierIDs := make([]uint, 0, len(suppliers))
	for _, supplier := range suppliers {
		supplierMap[supplier.Id] = supplier
		supplierIDs = append(supplierIDs, supplier.Id)
	}

	purchases, err := s.DebtSupplierRepo.GetPurchasesBySuppliers(c.Context(), supplierIDs, params)
	if err != nil {
		return nil, 0, err
	}

	payments, err := s.DebtSupplierRepo.GetPaymentsBySuppliers(c.Context(), supplierIDs, params)
	if err != nil {
		return nil, 0, err
	}

	purchasesBySupplier := make(map[uint][]entity.Purchase, len(supplierIDs))
	for _, purchase := range purchases {
		purchasesBySupplier[purchase.SupplierId] = append(purchasesBySupplier[purchase.SupplierId], purchase)
	}

	paymentsBySupplier := make(map[uint][]entity.Payment, len(supplierIDs))
	for _, payment := range payments {
		paymentsBySupplier[payment.PartyId] = append(paymentsBySupplier[payment.PartyId], payment)
	}

	initialPurchaseTotals, err := s.DebtSupplierRepo.GetPurchaseTotalsBeforeDate(c.Context(), supplierIDs, params)
	if err != nil {
		return nil, 0, err
	}

	initialPaymentTotals, err := s.DebtSupplierRepo.GetPaymentTotalsBeforeDate(c.Context(), supplierIDs, params)
	if err != nil {
		return nil, 0, err
	}

	initialBalanceTotals, err := s.DebtSupplierRepo.GetInitialBalanceTotals(c.Context(), supplierIDs)
	if err != nil {
		return nil, 0, err
	}

	references := collectDebtSupplierReferences(purchases)
	paymentSummaries, err := s.DebtSupplierRepo.GetPaymentSummariesByReferences(c.Context(), supplierIDs, references)
	if err != nil {
		return nil, 0, err
	}

	location, err := time.LoadLocation("Asia/Jakarta")
	if err != nil {
		return nil, 0, fiber.NewError(fiber.StatusInternalServerError, "failed to load timezone configuration")
	}
	now := time.Now().In(location)

	result := make([]dto.DebtSupplierDTO, 0, len(supplierIDs))
	type debtSupplierRowItem struct {
		Row          dto.DebtSupplierRowDTO
		SortTime     time.Time
		Order        int
		DeltaBalance float64
		CountTotals  bool
	}

	for _, supplierID := range supplierIDs {
		supplier, exists := supplierMap[supplierID]
		if !exists {
			continue
		}

		initialBalance := initialBalanceTotals[supplierID] + (initialPaymentTotals[supplierID] - initialPurchaseTotals[supplierID])
		items := purchasesBySupplier[supplierID]
		paymentItems := paymentsBySupplier[supplierID]
		total := dto.DebtSupplierTotalDTO{}

		combinedRows := make([]debtSupplierRowItem, 0, len(items)+len(paymentItems))
		for _, purchase := range items {
			row := buildDebtSupplierRow(purchase, now, location)
			if reference := resolveDebtSupplierReference(purchase); reference != "" {
				if summary, ok := paymentSummaries[reference]; ok {
					if isDebtSupplierPaid(row.TotalPrice, summary.Total) {
						row.Status = "Lunas"
						if !summary.LatestPaymentDate.IsZero() {
							row.Aging = calculateDebtSupplierAging(purchase, summary.LatestPaymentDate, location)
						}
					}
				}
			}
			sortTime := resolveDebtSupplierSortTime(purchase, params.FilterBy, location)
			combinedRows = append(combinedRows, debtSupplierRowItem{
				Row:          row,
				SortTime:     sortTime,
				Order:        0,
				DeltaBalance: -row.TotalPrice,
				CountTotals:  true,
			})
		}

		for _, payment := range paymentItems {
			row := buildDebtSupplierPaymentRow(payment, location)
			sortTime := payment.PaymentDate.In(location)
			combinedRows = append(combinedRows, debtSupplierRowItem{
				Row:          row,
				SortTime:     sortTime,
				Order:        1,
				DeltaBalance: payment.Nominal,
				CountTotals:  false,
			})
		}

		sort.SliceStable(combinedRows, func(i, j int) bool {
			if combinedRows[i].SortTime.Equal(combinedRows[j].SortTime) {
				return combinedRows[i].Order < combinedRows[j].Order
			}
			return combinedRows[i].SortTime.Before(combinedRows[j].SortTime)
		})

		balance := initialBalance
		for i := range combinedRows {
			balance += combinedRows[i].DeltaBalance
			combinedRows[i].Row.DebtPrice = balance
			combinedRows[i].Row.Balance = balance

			if combinedRows[i].CountTotals {
				row := combinedRows[i].Row
				if row.Aging > total.Aging {
					total.Aging = row.Aging
				}
				total.TotalPrice += row.TotalPrice
			} else {
				total.PaymentPrice += combinedRows[i].Row.PaymentPrice
			}
		}
		total.DebtPrice = balance

		rows := make([]dto.DebtSupplierRowDTO, 0, len(combinedRows))
		sortDesc := strings.EqualFold(params.SortOrder, "desc")
		if sortDesc {
			for i := len(combinedRows) - 1; i >= 0; i-- {
				rows = append(rows, combinedRows[i].Row)
			}
		} else {
			for i := range combinedRows {
				rows = append(rows, combinedRows[i].Row)
			}
		}

		var supplierDTORef *supplierDTO.SupplierRelationDTO
		if supplier.Id != 0 {
			mapped := supplierDTO.ToSupplierRelationDTO(supplier)
			supplierDTORef = &mapped
		}

		result = append(result, dto.DebtSupplierDTO{
			Supplier:       supplierDTORef,
			InitialBalance: initialBalance,
			Rows:           rows,
			Total:          total,
		})
	}

	return result, totalSuppliers, nil
}

func buildDebtSupplierRow(purchase entity.Purchase, now time.Time, loc *time.Location) dto.DebtSupplierRowDTO {
	prNumber := purchase.PrNumber
	poNumber := ""
	if purchase.PoNumber != nil {
		poNumber = *purchase.PoNumber
	}

	prDate := purchase.CreatedAt.In(loc)
	startDate := time.Date(prDate.Year(), prDate.Month(), prDate.Day(), 0, 0, 0, 0, loc)
	endDate := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, loc)
	aging := int(endDate.Sub(startDate).Hours() / 24)

	totalPrice := 0.0
	travelNumber := "-"
	receivedDate := ""
	var area *areaDTO.AreaRelationDTO
	var warehouse *warehouseDTO.WarehouseRelationDTO

	if len(purchase.Items) > 0 {
		firstItem := purchase.Items[0]
		if firstItem.TravelNumber != nil && strings.TrimSpace(*firstItem.TravelNumber) != "" {
			travelNumber = *firstItem.TravelNumber
		}

		if firstItem.Warehouse != nil && firstItem.Warehouse.Id != 0 {
			mappedWarehouse := warehouseDTO.ToWarehouseRelationDTO(*firstItem.Warehouse)
			warehouse = &mappedWarehouse
			if firstItem.Warehouse.Area.Id != 0 {
				mappedArea := areaDTO.ToAreaRelationDTO(firstItem.Warehouse.Area)
				area = &mappedArea
			}
		}

		earliestReceived := time.Time{}
		for _, item := range purchase.Items {
			totalPrice += item.TotalPrice
			if item.ReceivedDate == nil || item.ReceivedDate.IsZero() {
				continue
			}
			received := item.ReceivedDate.In(loc)
			if earliestReceived.IsZero() || received.Before(earliestReceived) {
				earliestReceived = received
			}
		}
		if !earliestReceived.IsZero() {
			receivedDate = earliestReceived.Format("2006-01-02")
		}
	}

	dueDate := ""
	dueStatus := "-"
	if purchase.DueDate != nil && !purchase.DueDate.IsZero() {
		due := purchase.DueDate.In(loc)
		dueDate = due.Format("2006-01-02")
		if now.After(due) {
			dueStatus = "Sudah Jatuh Tempo"
		} else {
			dueStatus = "Mendekati Jatuh Tempo"
		}
	}

	status := "Belum Lunas"
	poDate := ""
	if purchase.PoDate != nil && !purchase.PoDate.IsZero() {
		poDate = purchase.PoDate.In(loc).Format("2006-01-02")
	}

	return dto.DebtSupplierRowDTO{
		PrNumber:     prNumber,
		PoNumber:     poNumber,
		PoDate:       poDate,
		ReceivedDate: receivedDate,
		Aging:        aging,
		Area:         area,
		Warehouse:    warehouse,
		DueDate:      dueDate,
		DueStatus:    dueStatus,
		TotalPrice:   totalPrice,
		PaymentPrice: 0,
		DebtPrice:    0,
		Status:       status,
		TravelNumber: travelNumber,
		Balance:      0,
	}
}

func buildDebtSupplierPaymentRow(payment entity.Payment, loc *time.Location) dto.DebtSupplierRowDTO {
	referenceNumber := ""
	if payment.ReferenceNumber != nil {
		referenceNumber = *payment.ReferenceNumber
	}

	prNumber := payment.PaymentCode
	if strings.TrimSpace(prNumber) == "" {
		prNumber = referenceNumber
	}

	return dto.DebtSupplierRowDTO{
		PrNumber:     prNumber,
		PoNumber:     referenceNumber,
		PoDate:       "-",
		ReceivedDate: payment.PaymentDate.In(loc).Format("2006-01-02"),
		Aging:        0,
		Area:         nil,
		Warehouse:    nil,
		DueDate:      "-",
		DueStatus:    "-",
		TotalPrice:   0,
		PaymentPrice: payment.Nominal,
		DebtPrice:    0,
		Status:       "Pembayaran",
		TravelNumber: "-",
		Balance:      0,
	}
}

func resolveDebtSupplierSortTime(purchase entity.Purchase, filterBy string, loc *time.Location) time.Time {
	if strings.EqualFold(strings.TrimSpace(filterBy), "po_date") {
		if purchase.PoDate != nil && !purchase.PoDate.IsZero() {
			return purchase.PoDate.In(loc)
		}
	}

	earliest := time.Time{}
	for _, item := range purchase.Items {
		if item.ReceivedDate == nil || item.ReceivedDate.IsZero() {
			continue
		}
		received := item.ReceivedDate.In(loc)
		if earliest.IsZero() || received.Before(earliest) {
			earliest = received
		}
	}
	if !earliest.IsZero() {
		return earliest
	}

	return purchase.CreatedAt.In(loc)
}

func collectDebtSupplierReferences(purchases []entity.Purchase) []string {
	if len(purchases) == 0 {
		return nil
	}
	seen := make(map[string]struct{}, len(purchases))
	result := make([]string, 0, len(purchases))
	for _, purchase := range purchases {
		ref := resolveDebtSupplierReference(purchase)
		if ref == "" {
			continue
		}
		if _, ok := seen[ref]; ok {
			continue
		}
		seen[ref] = struct{}{}
		result = append(result, ref)
	}
	return result
}

func resolveDebtSupplierReference(purchase entity.Purchase) string {
	if purchase.PoNumber != nil {
		if ref := strings.TrimSpace(*purchase.PoNumber); ref != "" {
			return ref
		}
	}
	if ref := strings.TrimSpace(purchase.PrNumber); ref != "" {
		return ref
	}
	return ""
}

func isDebtSupplierPaid(totalPrice, paymentTotal float64) bool {
	if totalPrice <= 0 {
		return true
	}
	return paymentTotal >= totalPrice-0.000001
}

func calculateDebtSupplierAging(purchase entity.Purchase, endDate time.Time, loc *time.Location) int {
	prDate := purchase.CreatedAt.In(loc)
	startDate := time.Date(prDate.Year(), prDate.Month(), prDate.Day(), 0, 0, 0, 0, loc)
	stopDate := time.Date(endDate.Year(), endDate.Month(), endDate.Day(), 0, 0, 0, 0, loc)
	if stopDate.Before(startDate) {
		return 0
	}
	return int(stopDate.Sub(startDate).Hours() / 24)
}

func (s *repportService) GetHppPerKandang(ctx *fiber.Ctx) (*dto.HppPerKandangResponseData, *dto.HppPerKandangMetaDTO, error) {
	params, filters, err := s.parseHppPerKandangQuery(ctx)
	if err != nil {
		return nil, nil, err
	}

	if err := s.Validate.Struct(params); err != nil {
		return nil, nil, fiber.NewError(fiber.StatusBadRequest, err.Error())
	}

	location, err := time.LoadLocation("Asia/Jakarta")
	if err != nil {
		return nil, nil, fiber.NewError(fiber.StatusInternalServerError, "failed to load timezone configuration")
	}

	periodDate, err := time.ParseInLocation("2006-01-02", params.Period, location)
	if err != nil {
		return nil, nil, fiber.NewError(fiber.StatusBadRequest, "period must follow format YYYY-MM-DD")
	}

	startOfDay := time.Date(periodDate.Year(), periodDate.Month(), periodDate.Day(), 0, 0, 0, 0, location)
	endOfDay := startOfDay.Add(24 * time.Hour)

	repoRows, err := s.HppPerKandangRepo.GetRowsByPeriod(ctx.Context(), startOfDay, endOfDay, params.AreaIDs, params.LocationIDs, params.KandangIDs)
	if err != nil {
		return nil, nil, err
	}

	validPfkIDs := make([]uint, 0, len(repoRows))
	pfkIndex := make(map[uint]int, len(repoRows))
	for idx := range repoRows {
		row := repoRows[idx]
		pfkIndex[row.ProjectFlockKandangID] = idx
		if row.RecordingCount > 0 {
			validPfkIDs = append(validPfkIDs, row.ProjectFlockKandangID)
		}
	}

	costRows := make([]repportRepo.HppPerKandangCostRow, 0)
	supplierRows := make([]repportRepo.HppPerKandangSupplierRow, 0)
	if len(validPfkIDs) > 0 {
		costRows, supplierRows, err = s.HppPerKandangRepo.GetFeedOvkDocCostByPeriod(ctx.Context(), startOfDay, endOfDay, validPfkIDs)
		if err != nil {
			return nil, nil, err
		}

		eggMap, err := s.HppPerKandangRepo.GetEggProductionByProjectFlockKandangIDs(ctx.Context(), startOfDay, endOfDay, validPfkIDs)
		if err != nil {
			return nil, nil, err
		}
		for pfkID, egg := range eggMap {
			if rowIdx, ok := pfkIndex[pfkID]; ok {
				repoRows[rowIdx].EggProductionWeightKgRemaining = egg.EggProductionWeightKgRemaining
				repoRows[rowIdx].EggProductionPiecesRemaining = egg.EggProductionPiecesRemaining
				repoRows[rowIdx].EggProductionTotalWeightKg = egg.EggProductionTotalWeightKg
				repoRows[rowIdx].EggProductionTotalPieces = egg.EggProductionTotalPieces
			}
		}
	}

	costMap := make(map[uint]HppCostAggregate, len(costRows))
	for _, row := range costRows {
		costMap[row.ProjectFlockKandangID] = HppCostAggregate{
			FeedCost:    row.FeedCost,
			OvkCost:     row.OvkCost,
			DocCost:     row.DocCost,
			DocQty:      row.DocQty,
			BudgetCost:  row.BudgetCost,
			ExpenseCost: row.ExpenseCost,
		}
	}

	docSupplierMap := make(map[uint][]dto.HppPerKandangSupplierDTO)
	feedSupplierMap := make(map[uint][]dto.HppPerKandangSupplierDTO)
	docSeen := make(map[uint]map[uint]bool)
	feedSeen := make(map[uint]map[uint]bool)

	for _, sup := range supplierRows {
		if sup.SupplierID == 0 {
			continue
		}

		targetMap := feedSupplierMap
		seen := feedSeen
		category := "FEED"
		if strings.EqualFold(sup.Category, "DOC") {
			targetMap = docSupplierMap
			seen = docSeen
			category = "DOC"
		}

		if seen[sup.ProjectFlockKandangID] == nil {
			seen[sup.ProjectFlockKandangID] = make(map[uint]bool)
		}
		if seen[sup.ProjectFlockKandangID][sup.SupplierID] {
			continue
		}
		seen[sup.ProjectFlockKandangID][sup.SupplierID] = true

		targetMap[sup.ProjectFlockKandangID] = append(targetMap[sup.ProjectFlockKandangID], dto.HppPerKandangSupplierDTO{
			ID:       int64(sup.SupplierID),
			Name:     sup.SupplierName,
			Alias:    sup.SupplierAlias,
			Category: category,
		})
	}

	type weightRangeKey struct {
		Min float64
		Max float64
	}
	type weightRangeAggregate struct {
		Summary           *dto.HppPerKandangSummaryWeightRangeDTO
		RemainingBirds    int64
		RemainingWeightKg float64
		AvgWeightSum      float64
		AvgWeightCount    int64
		EggHppSum         float64
		EggHppCount       int
		FeedSuppliers     map[int64]dto.HppPerKandangSupplierDTO
		DocSuppliers      map[int64]dto.HppPerKandangSupplierDTO
	}

	dataRows := make([]dto.HppPerKandangRowDTO, 0, len(repoRows))
	perRangeMap := make(map[weightRangeKey]*weightRangeAggregate)
	var totalBirds int64
	// var totalWeight float64
	var totalEggPieces int64
	var totalEggKg float64
	// var totalRemainingValueRp int64
	var totalEggValueRp int64
	// var totalHppSum float64
	var totalHppCount int
	var totalDocPriceSum float64
	var totalDocPriceCount int
	var totalEggHppSum float64
	var totalEggHppCount int
	var totalAvgWeightSum float64
	var totalAvgWeightCount int64

	for _, row := range repoRows {
		if !params.ShowUnrecorded && row.RecordingCount == 0 {
			continue
		}

		// birdsFloat := row.RemainingChickenBirds
		// if math.IsNaN(birdsFloat) || math.IsInf(birdsFloat, 0) {
		// 	birdsFloat = 0
		// }
		// weightFloat := row.RemainingChickenWeight
		// if math.IsNaN(weightFloat) || math.IsInf(weightFloat, 0) {
		// 	weightFloat = 0
		// }
		eggPiecesFloatRemaining := row.EggProductionPiecesRemaining
		if math.IsNaN(eggPiecesFloatRemaining) || math.IsInf(eggPiecesFloatRemaining, 0) {
			eggPiecesFloatRemaining = 0
		}
		eggTotalPiecesFloat := row.EggProductionTotalPieces
		if math.IsNaN(eggTotalPiecesFloat) || math.IsInf(eggTotalPiecesFloat, 0) {
			eggTotalPiecesFloat = 0
		}
		eggRemainingWeightFloatRemaining := row.EggProductionWeightKgRemaining
		if math.IsNaN(eggRemainingWeightFloatRemaining) || math.IsInf(eggRemainingWeightFloatRemaining, 0) {
			eggRemainingWeightFloatRemaining = 0
		}
		eggWeightFloat := row.EggProductionTotalWeightKg
		if math.IsNaN(eggWeightFloat) || math.IsInf(eggWeightFloat, 0) {
			eggWeightFloat = 0
		}

		avgWeight := 0.0
		if eggTotalPiecesFloat > 0 {
			avgWeight = eggWeightFloat / eggTotalPiecesFloat
		}
		if params.WeightMin != nil && avgWeight < *params.WeightMin {
			continue
		}
		if params.WeightMax != nil && avgWeight > *params.WeightMax {
			continue
		}

		weightMin := math.Floor(avgWeight*10) / 10
		if weightMin < 0 {
			weightMin = 0
		}
		weightMax := weightMin + 0.09
		rangeKey := weightRangeKey{Min: weightMin, Max: weightMax}

		// rowBirds := int64(math.Round(birdsFloat))
		costEntry := costMap[row.ProjectFlockKandangID]
		totalCost := costEntry.FeedCost + costEntry.OvkCost + costEntry.DocCost + costEntry.BudgetCost + costEntry.ExpenseCost
		// hppRp := 0.0
		// if weightFloat > 0 {
		// 	hppRp = totalCost / weightFloat
		// }
		eggHpp := 0.0
		if eggWeightFloat > 0 {
			eggHpp = (totalCost / eggWeightFloat) / 1000
		}

		rowEggPieces := int64(math.Round(eggPiecesFloatRemaining))
		rowEggValue := int64(eggHpp * eggRemainingWeightFloatRemaining)
		// rowRemainingValue := int64(hppRp * weightFloat)
		avgDocPrice := int64(0)
		if costEntry.DocQty > 0 {
			avgDocPrice = int64(math.Round(costEntry.DocCost / costEntry.DocQty))
		}

		nameWithPeriod := fmt.Sprintf("%s Period %d", row.KandangName, row.ProjectFlockPeriod)

		dataRows = append(dataRows, dto.HppPerKandangRowDTO{
			ID: int(row.ProjectFlockKandangID),
			Kandang: dto.HppPerKandangRowKandangDTO{
				ID:     int64(row.KandangID),
				Name:   row.KandangName,
				Status: row.KandangStatus,
				Location: dto.HppPerKandangLocationDTO{
					ID:   int64(row.LocationID),
					Name: row.LocationName,
				},
				Pic: dto.HppPerKandangPICDTO{
					ID:   int64(row.PicID),
					Name: row.PicName,
				},
			},
			WeightRange: dto.HppPerKandangWeightRangeDTO{
				WeightMin: weightMin,
				WeightMax: weightMax,
			},
			AvgWeightKg:     avgWeight,
			NameWithPeriode: nameWithPeriod,
			// FeedCostRp:               costEntry.FeedCost,
			// OvkCostRp:                costEntry.OvkCost,
			DocSuppliers:        docSupplierMap[row.ProjectFlockKandangID],
			FeedSuppliers:       feedSupplierMap[row.ProjectFlockKandangID],
			EggProductionPieces: int64(math.Round(eggPiecesFloatRemaining)),
			EggProductionKg:     eggRemainingWeightFloatRemaining,
			// EggProductionTotalWeightKg: eggWeightFloat,
			// EggProductionTotalPieces:   int64(math.Round(eggTotalPiecesFloat)),
			AverageDocPriceRp: avgDocPrice,
			// HppRp:               hppRp,
			EggHppRpPerKg: eggHpp,
			// RemainingValueRp: rowRemainingValue,
			EggValueRp: rowEggValue,
		})

		// totalBirds += rowBirds
		// totalWeight += weightFloat
		totalEggPieces += rowEggPieces
		totalEggKg += eggRemainingWeightFloatRemaining
		// totalRemainingValueRp += rowRemainingValue
		totalEggValueRp += rowEggValue
		totalAvgWeightSum += avgWeight
		totalAvgWeightCount++
		// if weightFloat > 0 {
		// 	totalHppSum += hppRp
		// 	totalHppCount++
		// }
		if avgDocPrice > 0 {
			totalDocPriceSum += float64(avgDocPrice)
			totalDocPriceCount++
		}
		if eggWeightFloat > 0 {
			totalEggHppSum += eggHpp
			totalEggHppCount++
		}

		rangeAgg, exists := perRangeMap[rangeKey]
		if !exists {
			rangeAgg = &weightRangeAggregate{
				Summary: &dto.HppPerKandangSummaryWeightRangeDTO{
					WeightRange: dto.HppPerKandangWeightRangeDTO{
						WeightMin: weightMin,
						WeightMax: weightMax,
					},
					Label: fmt.Sprintf("%.2f - %.2f", weightMin, weightMax),
				},
				FeedSuppliers: make(map[int64]dto.HppPerKandangSupplierDTO),
				DocSuppliers:  make(map[int64]dto.HppPerKandangSupplierDTO),
			}
			perRangeMap[rangeKey] = rangeAgg
		}

		rangeSummary := rangeAgg.Summary
		// rangeAgg.RemainingBirds += rowBirds
		// rangeAgg.RemainingWeightKg += row.RemainingChickenWeight
		rangeAgg.AvgWeightSum += avgWeight
		rangeAgg.AvgWeightCount++
		for _, supplier := range feedSupplierMap[row.ProjectFlockKandangID] {
			if _, ok := rangeAgg.FeedSuppliers[supplier.ID]; !ok {
				rangeAgg.FeedSuppliers[supplier.ID] = supplier
			}
		}
		for _, supplier := range docSupplierMap[row.ProjectFlockKandangID] {
			if _, ok := rangeAgg.DocSuppliers[supplier.ID]; !ok {
				rangeAgg.DocSuppliers[supplier.ID] = supplier
			}
		}
		rangeSummary.EggProductionPieces += rowEggPieces
		rangeSummary.EggProductionKg += eggRemainingWeightFloatRemaining
		// rangeSummary.RemainingValueRp += rowRemainingValue
		rangeSummary.EggValueRp += rowEggValue
		if eggWeightFloat > 0 {
			rangeAgg.EggHppSum += eggHpp
			rangeAgg.EggHppCount++
		}
	}

	rangeKeys := make([]weightRangeKey, 0, len(perRangeMap))
	for key := range perRangeMap {
		rangeKeys = append(rangeKeys, key)
	}
	sort.Slice(rangeKeys, func(i, j int) bool {
		if rangeKeys[i].Min == rangeKeys[j].Min {
			return rangeKeys[i].Max < rangeKeys[j].Max
		}
		return rangeKeys[i].Min < rangeKeys[j].Min
	})

	perRangeSummary := make([]dto.HppPerKandangSummaryWeightRangeDTO, 0, len(rangeKeys))
	for idx, key := range rangeKeys {
		agg := perRangeMap[key]
		entry := agg.Summary
		entry.ID = idx + 1
		if agg.AvgWeightCount > 0 {
			entry.AvgWeightKg = agg.AvgWeightSum / float64(agg.AvgWeightCount)
		}
		if agg.EggHppCount > 0 {
			entry.EggHppRpPerKg = agg.EggHppSum / float64(agg.EggHppCount)
		}
		entry.FeedSuppliers = make([]dto.HppPerKandangSupplierDTO, 0, len(agg.FeedSuppliers))
		for _, supplier := range agg.FeedSuppliers {
			entry.FeedSuppliers = append(entry.FeedSuppliers, supplier)
		}
		entry.DocSuppliers = make([]dto.HppPerKandangSupplierDTO, 0, len(agg.DocSuppliers))
		for _, supplier := range agg.DocSuppliers {
			entry.DocSuppliers = append(entry.DocSuppliers, supplier)
		}
		perRangeSummary = append(perRangeSummary, *entry)
	}

	totalSummary := dto.HppPerKandangSummaryTotalDTO{
		TotalEggProductionPieces: totalEggPieces,
		TotalEggProductionKg:     totalEggKg,
		TotalEggValueRp:          totalEggValueRp,
	}
	if totalBirds > 0 {
	}
	if totalAvgWeightCount > 0 {
		totalSummary.AverageWeightKg = totalAvgWeightSum / float64(totalAvgWeightCount)
	}
	if totalEggHppCount > 0 {
		totalSummary.AverageEggHppRpPerKg = totalEggHppSum / float64(totalEggHppCount)
	}
	if totalHppCount > 0 {
	}
	if totalDocPriceCount > 0 {
		totalSummary.TotalAverageDocPriceRp = totalDocPriceSum / float64(totalDocPriceCount)
	}

	limit := params.Limit
	if limit <= 0 {
		limit = 10
	}
	totalCount := len(dataRows)
	offset := (params.Page - 1) * limit
	if offset < 0 {
		offset = 0
	}
	if offset > totalCount {
		offset = totalCount
	}
	end := offset + limit
	if end > totalCount {
		end = totalCount
	}
	pagedRows := dataRows[offset:end]

	data := dto.HppPerKandangResponseData{
		Period: params.Period,
		Rows:   pagedRows,
		Summary: dto.HppPerKandangSummaryDTO{
			PerWeightRange: perRangeSummary,
			Total:          totalSummary,
		},
	}

	totalResults := int64(totalCount)

	totalPages := int64(0)
	if totalResults > 0 {
		totalPages = int64(math.Ceil(float64(totalResults) / float64(limit)))
	}
	if totalPages == 0 {
		totalPages = 1
	}

	meta := &dto.HppPerKandangMetaDTO{
		Page:         params.Page,
		Limit:        limit,
		TotalPages:   totalPages,
		TotalResults: totalResults,
		Filters:      filters,
	}

	return &data, meta, nil
}

func (s *repportService) parseHppPerKandangQuery(ctx *fiber.Ctx) (*validation.HppPerKandangQuery, dto.HppPerKandangFiltersDTO, error) {
	page := ctx.QueryInt("page", 1)
	if page < 1 {
		page = 1
	}
	limit := ctx.QueryInt("limit", 10)
	if limit < 1 {
		limit = 10
	}

	rawArea := ctx.Query("area_id", "")
	rawLocation := ctx.Query("location_id", "")
	rawKandang := ctx.Query("kandang_id", "")
	rawWeightMin := ctx.Query("weight_min", "")
	rawWeightMax := ctx.Query("weight_max", "")
	period := ctx.Query("period", "")
	showUnrecorded := ctx.QueryBool("show_unrecorded", false)

	areaIDs, err := parseCommaSeparatedInt64s(rawArea)
	if err != nil {
		return nil, dto.HppPerKandangFiltersDTO{}, fiber.NewError(fiber.StatusBadRequest, err.Error())
	}
	locationIDs, err := parseCommaSeparatedInt64s(rawLocation)
	if err != nil {
		return nil, dto.HppPerKandangFiltersDTO{}, fiber.NewError(fiber.StatusBadRequest, err.Error())
	}
	kandangIDs, err := parseCommaSeparatedInt64s(rawKandang)
	if err != nil {
		return nil, dto.HppPerKandangFiltersDTO{}, fiber.NewError(fiber.StatusBadRequest, err.Error())
	}

	weightMin, err := parseOptionalFloat64(rawWeightMin)
	if err != nil {
		return nil, dto.HppPerKandangFiltersDTO{}, fiber.NewError(fiber.StatusBadRequest, err.Error())
	}
	weightMax, err := parseOptionalFloat64(rawWeightMax)
	if err != nil {
		return nil, dto.HppPerKandangFiltersDTO{}, fiber.NewError(fiber.StatusBadRequest, err.Error())
	}
	if weightMin != nil && weightMax != nil && *weightMin > *weightMax {
		return nil, dto.HppPerKandangFiltersDTO{}, fiber.NewError(fiber.StatusBadRequest, "weight_min must be less than or equal to weight_max")
	}

	params := &validation.HppPerKandangQuery{
		Page:           page,
		Limit:          limit,
		Period:         period,
		ShowUnrecorded: showUnrecorded,
		AreaIDs:        areaIDs,
		LocationIDs:    locationIDs,
		KandangIDs:     kandangIDs,
		WeightMin:      weightMin,
		WeightMax:      weightMax,
	}

	showUnrecordedFilter := ""
	if showUnrecorded {
		showUnrecordedFilter = "true"
	}

	filters := dto.NewHppPerKandangFiltersDTO(
		rawArea,
		rawLocation,
		rawKandang,
		rawWeightMin,
		rawWeightMax,
		period,
		showUnrecordedFilter,
	)

	return params, filters, nil
}

func parseCommaSeparatedInt64s(raw string) ([]int64, error) {
	raw = strings.TrimSpace(raw)
	if raw == "" {
		return nil, nil
	}

	parts := strings.Split(raw, ",")
	result := make([]int64, 0, len(parts))
	for _, part := range parts {
		part = strings.TrimSpace(part)
		if part == "" {
			continue
		}

		id, err := strconv.ParseInt(part, 10, 64)
		if err != nil {
			return nil, fmt.Errorf("invalid integer value '%s'", part)
		}
		result = append(result, id)
	}

	return result, nil
}

func parseOptionalFloat64(raw string) (*float64, error) {
	raw = strings.TrimSpace(raw)
	if raw == "" {
		return nil, nil
	}

	value, err := strconv.ParseFloat(raw, 64)
	if err != nil {
		return nil, fmt.Errorf("invalid float value '%s'", raw)
	}

	return &value, nil
}