Merge branch 'development' into 'production'

Development

See merge request mbugroup/lti-api!541

internal/modules/expenses/repositories/expense_realization.repository.go

@@ -98,7 +98,6 @@ func (r *ExpenseRealizationRepositoryImpl) GetAllWithFilters(ctx context.Context
 			return db.
 				Preload("Expense").
 				Preload("Expense.Supplier").
-				Preload("Expense.Location").
 				Preload("Kandang").
 				Preload("Kandang.Location").
 				Preload("Nonstock").

internal/modules/repports/controllers/repport.controller.go

@@ -392,13 +392,6 @@ func (c *RepportController) GetDebtSupplier(ctx *fiber.Ctx) error {
 		return err
 	}
 
-	if isDebtSupplierExcelExportRequest(ctx) {
-		return exportDebtSupplierExcel(ctx, result)
-	}
-	if isDebtSupplierExcelAllExportRequest(ctx) {
-		return exportDebtSupplierExcelAll(ctx, result)
-	}
-
 	supplierIDs = query.SupplierIDs
 	if supplierIDs == nil {
 		supplierIDs = []int64{}
@@ -485,13 +478,6 @@ func (c *RepportController) GetCustomerPayment(ctx *fiber.Ctx) error {
 		return err
 	}
 
-	if isCustomerPaymentExcelExportRequest(ctx) {
-		return exportCustomerPaymentExcel(ctx, result)
-	}
-	if isCustomerPaymentExcelAllExportRequest(ctx) {
-		return exportCustomerPaymentExcelAll(ctx, result)
-	}
-
 	// If single customer mode (only 1 customer ID), return without pagination
 	if len(customerIDs) == 1 {
 		return ctx.Status(fiber.StatusOK).
@@ -519,83 +505,6 @@ func (c *RepportController) GetCustomerPayment(ctx *fiber.Ctx) error {
 		})
 }
 
-type BalanceMonitoringResponse struct {
-	Code    int                              `json:"code"`
-	Status  string                           `json:"status"`
-	Message string                           `json:"message"`
-	Meta    response.Meta                    `json:"meta"`
-	Data    []dto.BalanceMonitoringRowDTO    `json:"data"`
-	Totals  dto.BalanceMonitoringTotalsDTO   `json:"totals"`
-}
-
-func (c *RepportController) GetBalanceMonitoring(ctx *fiber.Ctx) error {
-	customerIDs, err := parseUintCSV(ctx.Query("customer_ids"))
-	if err != nil {
-		return fiber.NewError(fiber.StatusBadRequest, "customer_ids must be comma separated positive integers")
-	}
-	salesIDs, err := parseUintCSV(ctx.Query("sales_ids"))
-	if err != nil {
-		return fiber.NewError(fiber.StatusBadRequest, "sales_ids must be comma separated positive integers")
-	}
-
-	query := &validation.BalanceMonitoringQuery{
-		Page:        ctx.QueryInt("page", 1),
-		Limit:       ctx.QueryInt("limit", 10),
-		CustomerIDs: customerIDs,
-		SalesIDs:    salesIDs,
-		FilterBy:    strings.ToLower(ctx.Query("filter_by", "")),
-		SortBy:      ctx.Query("sort_by", ""),
-		SortOrder:   ctx.Query("sort_order", ""),
-		StartDate:   ctx.Query("start_date", ""),
-		EndDate:     ctx.Query("end_date", ""),
-	}
-
-	result, totals, totalResults, err := c.RepportService.GetBalanceMonitoring(ctx, query)
-	if err != nil {
-		return err
-	}
-
-	limit := query.Limit
-	if limit < 1 {
-		limit = 10
-	}
-
-	return ctx.Status(fiber.StatusOK).JSON(BalanceMonitoringResponse{
-		Code:    fiber.StatusOK,
-		Status:  "success",
-		Message: "Get balance monitoring report successfully",
-		Meta: response.Meta{
-			Page:         query.Page,
-			Limit:        limit,
-			TotalPages:   int64(math.Ceil(float64(totalResults) / float64(limit))),
-			TotalResults: totalResults,
-		},
-		Data:   result,
-		Totals: totals,
-	})
-}
-
-func parseUintCSV(raw string) ([]uint, error) {
-	raw = strings.TrimSpace(raw)
-	if raw == "" {
-		return nil, nil
-	}
-	parts := strings.Split(raw, ",")
-	result := make([]uint, 0, len(parts))
-	for _, part := range parts {
-		part = strings.TrimSpace(part)
-		if part == "" {
-			continue
-		}
-		id, err := strconv.ParseUint(part, 10, 32)
-		if err != nil || id == 0 {
-			return nil, fmt.Errorf("invalid id: %s", part)
-		}
-		result = append(result, uint(id))
-	}
-	return result, nil
-}
-
 func (c *RepportController) GetProductionResult(ctx *fiber.Ctx) error {
 	idParam := ctx.Params("idProjectFlockKandang")
 	if idParam == "" {

internal/modules/repports/controllers/repport.customer_payment.export.go

@@ -1,585 +0,0 @@
-package controller
-
-import (
-	"fmt"
-	"math"
-	"strconv"
-	"strings"
-	"time"
-
-	"github.com/gofiber/fiber/v2"
-	"github.com/xuri/excelize/v2"
-	"gitlab.com/mbugroup/lti-api.git/internal/modules/repports/dto"
-)
-
-func isCustomerPaymentExcelExportRequest(c *fiber.Ctx) bool {
-	return strings.EqualFold(strings.TrimSpace(c.Query("export")), "excel")
-}
-
-func isCustomerPaymentExcelAllExportRequest(c *fiber.Ctx) bool {
-	return strings.EqualFold(strings.TrimSpace(c.Query("export")), "excel-all")
-}
-
-func exportCustomerPaymentExcel(c *fiber.Ctx, items []dto.CustomerPaymentReportItem) error {
-	content, err := buildCustomerPaymentWorkbook(items)
-	if err != nil {
-		return fiber.NewError(fiber.StatusInternalServerError, "failed to generate excel file")
-	}
-
-	filename := fmt.Sprintf("laporan-kontrol-pembayaran-customer-%s.xlsx", time.Now().Format("2006-01-02-1504"))
-	c.Set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
-	c.Set("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"`, filename))
-	return c.Status(fiber.StatusOK).Send(content)
-}
-
-func exportCustomerPaymentExcelAll(c *fiber.Ctx, items []dto.CustomerPaymentReportItem) error {
-	content, err := buildCustomerPaymentAllWorkbook(items)
-	if err != nil {
-		return fiber.NewError(fiber.StatusInternalServerError, "failed to generate excel file")
-	}
-
-	filename := fmt.Sprintf("laporan-kontrol-pembayaran-customer-all-%s.xlsx", time.Now().Format("2006-01-02-1504"))
-	c.Set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
-	c.Set("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"`, filename))
-	return c.Status(fiber.StatusOK).Send(content)
-}
-
-func buildCustomerPaymentWorkbook(items []dto.CustomerPaymentReportItem) ([]byte, error) {
-	file := excelize.NewFile()
-	defer file.Close()
-
-	defaultSheet := file.GetSheetName(file.GetActiveSheetIndex())
-
-	if len(items) == 0 {
-		if err := writeCustomerPaymentSheet(file, defaultSheet, dto.CustomerPaymentReportItem{}); err != nil {
-			return nil, err
-		}
-		buf, err := file.WriteToBuffer()
-		if err != nil {
-			return nil, err
-		}
-		return buf.Bytes(), nil
-	}
-
-	for idx, item := range items {
-		sheetName := sanitizeCustomerPaymentSheetName(customerPaymentName(item))
-		if sheetName == "" {
-			sheetName = fmt.Sprintf("Customer %d", idx+1)
-		}
-
-		if idx == 0 {
-			if defaultSheet != sheetName {
-				if err := file.SetSheetName(defaultSheet, sheetName); err != nil {
-					return nil, err
-				}
-			}
-		} else {
-			if _, err := file.NewSheet(sheetName); err != nil {
-				return nil, err
-			}
-		}
-
-		if err := writeCustomerPaymentSheet(file, sheetName, item); err != nil {
-			return nil, err
-		}
-	}
-
-	buf, err := file.WriteToBuffer()
-	if err != nil {
-		return nil, err
-	}
-	return buf.Bytes(), nil
-}
-
-func buildCustomerPaymentAllWorkbook(items []dto.CustomerPaymentReportItem) ([]byte, error) {
-	file := excelize.NewFile()
-	defer file.Close()
-
-	const sheet = "Kontrol Pembayaran Customer"
-	defaultSheet := file.GetSheetName(file.GetActiveSheetIndex())
-	if defaultSheet != sheet {
-		if err := file.SetSheetName(defaultSheet, sheet); err != nil {
-			return nil, err
-		}
-	}
-
-	if err := setCustomerPaymentAllColumns(file, sheet); err != nil {
-		return nil, err
-	}
-	if err := setCustomerPaymentAllHeaders(file, sheet); err != nil {
-		return nil, err
-	}
-	if err := writeCustomerPaymentAllRows(file, sheet, items); err != nil {
-		return nil, err
-	}
-	if err := file.SetPanes(sheet, &excelize.Panes{
-		Freeze:      true,
-		YSplit:      1,
-		TopLeftCell: "A2",
-		ActivePane:  "bottomLeft",
-	}); err != nil {
-		return nil, err
-	}
-
-	buf, err := file.WriteToBuffer()
-	if err != nil {
-		return nil, err
-	}
-	return buf.Bytes(), nil
-}
-
-var cpSheetHeaders = []string{
-	"No",
-	"Tanggal DO/Bayar",
-	"Tanggal Realisasi",
-	"Aging",
-	"Referensi",
-	"Nomor Polisi",
-	"Ekor/Qty",
-	"Berat (Kg)",
-	"AVG",
-	"Harga/Unit (Rp)",
-	"Harga Akhir (Rp)",
-	"Total (Rp)",
-	"Pembayaran (Rp)",
-	"Saldo Piutang (Rp)",
-	"Keterangan",
-	"Pengambilan",
-	"Sales/Marketing",
-}
-
-var cpAllSheetHeaders = append([]string{"Customer"}, cpSheetHeaders...)
-
-var cpSheetColumnWidths = map[string]float64{
-	"A": 5,
-	"B": 15,
-	"C": 12,
-	"D": 8,
-	"E": 12,
-	"F": 15,
-	"G": 10,
-	"H": 12,
-	"I": 10,
-	"J": 15,
-	"K": 15,
-	"L": 15,
-	"M": 15,
-	"N": 15,
-	"O": 20,
-	"P": 15,
-	"Q": 20,
-}
-
-var cpAllSheetColumnWidths = map[string]float64{
-	"A": 22,
-	"B": 6,
-	"C": 15,
-	"D": 15,
-	"E": 8,
-	"F": 12,
-	"G": 15,
-	"H": 10,
-	"I": 12,
-	"J": 10,
-	"K": 15,
-	"L": 15,
-	"M": 15,
-	"N": 15,
-	"O": 15,
-	"P": 20,
-	"Q": 15,
-	"R": 20,
-}
-
-func writeCustomerPaymentSheet(file *excelize.File, sheet string, item dto.CustomerPaymentReportItem) error {
-	for col, width := range cpSheetColumnWidths {
-		if err := file.SetColWidth(sheet, col, col, width); err != nil {
-			return err
-		}
-	}
-
-	// Row 1: headers
-	for i, h := range cpSheetHeaders {
-		col, _ := excelize.ColumnNumberToName(i + 1)
-		if err := file.SetCellValue(sheet, col+"1", h); err != nil {
-			return err
-		}
-	}
-
-	redStyle, err := file.NewStyle(&excelize.Style{
-		Font: &excelize.Font{Color: "FF0000"},
-	})
-	if err != nil {
-		return err
-	}
-
-	// Row 2: saldo awal
-	initialFormatted := formatCPRupiah(item.InitialBalance)
-	if err := file.SetCellValue(sheet, "N2", initialFormatted); err != nil {
-		return err
-	}
-	if item.InitialBalance < 0 {
-		if err := file.SetCellStyle(sheet, "N2", "N2", redStyle); err != nil {
-			return err
-		}
-	}
-
-	// Rows 3+: data rows
-	for i, row := range item.Rows {
-		rowNum := i + 3
-		rowStr := fmt.Sprintf("%d", rowNum)
-
-		cells := customerPaymentRowCells(row, i+1)
-		for colIdx, val := range cells {
-			col, _ := excelize.ColumnNumberToName(colIdx + 1)
-			if err := file.SetCellValue(sheet, col+rowStr, val); err != nil {
-				return err
-			}
-		}
-
-		if row.AccountsReceivable < 0 {
-			if err := file.SetCellStyle(sheet, "N"+rowStr, "N"+rowStr, redStyle); err != nil {
-				return err
-			}
-		}
-	}
-
-	// Total row
-	totalRowNum := len(item.Rows) + 3
-	totalRowStr := fmt.Sprintf("%d", totalRowNum)
-
-	totalCells := map[string]string{
-		"A": "Total",
-		"G": formatCPIDInteger(item.Summary.TotalQty),
-		"H": formatCPIDInteger(item.Summary.TotalWeight),
-		"K": formatCPRupiah(item.Summary.TotalFinalAmount),
-		"L": formatCPRupiah(item.Summary.TotalGrandAmount),
-		"M": formatCPRupiah(item.Summary.TotalPayment),
-		"N": formatCPRupiah(item.Summary.TotalAccountsReceivable),
-	}
-	for col, val := range totalCells {
-		if err := file.SetCellValue(sheet, col+totalRowStr, val); err != nil {
-			return err
-		}
-	}
-	if item.Summary.TotalAccountsReceivable < 0 {
-		if err := file.SetCellStyle(sheet, "N"+totalRowStr, "N"+totalRowStr, redStyle); err != nil {
-			return err
-		}
-	}
-
-	return nil
-}
-
-func setCustomerPaymentAllColumns(file *excelize.File, sheet string) error {
-	for col, width := range cpAllSheetColumnWidths {
-		if err := file.SetColWidth(sheet, col, col, width); err != nil {
-			return err
-		}
-	}
-	return file.SetRowHeight(sheet, 1, 24)
-}
-
-func setCustomerPaymentAllHeaders(file *excelize.File, sheet string) error {
-	borderStyle := []excelize.Border{
-		{Type: "left", Color: "000000", Style: 1},
-		{Type: "top", Color: "000000", Style: 1},
-		{Type: "bottom", Color: "000000", Style: 1},
-		{Type: "right", Color: "000000", Style: 1},
-	}
-	headerStyle, err := file.NewStyle(&excelize.Style{
-		Font: &excelize.Font{Bold: true, Color: "FFFFFF", Family: "Arial", Size: 10},
-		Fill: excelize.Fill{Type: "pattern", Pattern: 1, Color: []string{"4472C4"}},
-		Alignment: &excelize.Alignment{
-			Horizontal: "center",
-			Vertical:   "center",
-			WrapText:   true,
-		},
-		Border: borderStyle,
-	})
-	if err != nil {
-		return err
-	}
-
-	for i, h := range cpAllSheetHeaders {
-		col, _ := excelize.ColumnNumberToName(i + 1)
-		if err := file.SetCellValue(sheet, col+"1", h); err != nil {
-			return err
-		}
-	}
-
-	lastCol, _ := excelize.ColumnNumberToName(len(cpAllSheetHeaders))
-	return file.SetCellStyle(sheet, "A1", lastCol+"1", headerStyle)
-}
-
-func writeCustomerPaymentAllRows(file *excelize.File, sheet string, items []dto.CustomerPaymentReportItem) error {
-	borderStyle := []excelize.Border{
-		{Type: "left", Color: "000000", Style: 1},
-		{Type: "top", Color: "000000", Style: 1},
-		{Type: "bottom", Color: "000000", Style: 1},
-		{Type: "right", Color: "000000", Style: 1},
-	}
-
-	dataStyle, err := file.NewStyle(&excelize.Style{
-		Font:      &excelize.Font{Color: "000000", Family: "Arial", Size: 10},
-		Alignment: &excelize.Alignment{Vertical: "center", WrapText: true},
-		Border:    borderStyle,
-	})
-	if err != nil {
-		return err
-	}
-
-	totalStyle, err := file.NewStyle(&excelize.Style{
-		Font:      &excelize.Font{Bold: true, Color: "000000", Family: "Arial", Size: 10},
-		Fill:      excelize.Fill{Type: "pattern", Pattern: 1, Color: []string{"E2EFDA"}},
-		Alignment: &excelize.Alignment{Vertical: "center", WrapText: true},
-		Border:    borderStyle,
-	})
-	if err != nil {
-		return err
-	}
-
-	redDataStyle, err := file.NewStyle(&excelize.Style{
-		Font:      &excelize.Font{Color: "FF0000", Family: "Arial", Size: 10},
-		Alignment: &excelize.Alignment{Vertical: "center", WrapText: true},
-		Border:    borderStyle,
-	})
-	if err != nil {
-		return err
-	}
-
-	redTotalStyle, err := file.NewStyle(&excelize.Style{
-		Font:      &excelize.Font{Bold: true, Color: "FF0000", Family: "Arial", Size: 10},
-		Fill:      excelize.Fill{Type: "pattern", Pattern: 1, Color: []string{"E2EFDA"}},
-		Alignment: &excelize.Alignment{Vertical: "center", WrapText: true},
-		Border:    borderStyle,
-	})
-	if err != nil {
-		return err
-	}
-
-	lastHeaderCol, _ := excelize.ColumnNumberToName(len(cpAllSheetHeaders))
-	currentRow := 2
-
-	for _, item := range items {
-		name := customerPaymentName(item)
-
-		// Saldo awal row
-		saldoStr := fmt.Sprintf("%d", currentRow)
-		if err := file.SetCellValue(sheet, "A"+saldoStr, name); err != nil {
-			return err
-		}
-		initialFormatted := formatCPRupiah(item.InitialBalance)
-		if err := file.SetCellValue(sheet, "O"+saldoStr, initialFormatted); err != nil {
-			return err
-		}
-		if err := file.SetCellStyle(sheet, "A"+saldoStr, lastHeaderCol+saldoStr, dataStyle); err != nil {
-			return err
-		}
-		if item.InitialBalance < 0 {
-			if err := file.SetCellStyle(sheet, "O"+saldoStr, "O"+saldoStr, redDataStyle); err != nil {
-				return err
-			}
-		}
-		currentRow++
-
-		// Data rows
-		for seq, row := range item.Rows {
-			rowStr := fmt.Sprintf("%d", currentRow)
-			if err := file.SetCellValue(sheet, "A"+rowStr, name); err != nil {
-				return err
-			}
-			cells := customerPaymentRowCells(row, seq+1)
-			for colIdx, val := range cells {
-				col, _ := excelize.ColumnNumberToName(colIdx + 2)
-				if err := file.SetCellValue(sheet, col+rowStr, val); err != nil {
-					return err
-				}
-			}
-			if err := file.SetCellStyle(sheet, "A"+rowStr, lastHeaderCol+rowStr, dataStyle); err != nil {
-				return err
-			}
-			if row.AccountsReceivable < 0 {
-				if err := file.SetCellStyle(sheet, "O"+rowStr, "O"+rowStr, redDataStyle); err != nil {
-					return err
-				}
-			}
-			currentRow++
-		}
-
-		// Total row
-		totalStr := fmt.Sprintf("%d", currentRow)
-		totalCells := map[string]string{
-			"A": name,
-			"B": "Total",
-			"H": formatCPIDInteger(item.Summary.TotalQty),
-			"I": formatCPIDInteger(item.Summary.TotalWeight),
-			"L": formatCPRupiah(item.Summary.TotalFinalAmount),
-			"M": formatCPRupiah(item.Summary.TotalGrandAmount),
-			"N": formatCPRupiah(item.Summary.TotalPayment),
-			"O": formatCPRupiah(item.Summary.TotalAccountsReceivable),
-		}
-		for col, val := range totalCells {
-			if err := file.SetCellValue(sheet, col+totalStr, val); err != nil {
-				return err
-			}
-		}
-		if err := file.SetCellStyle(sheet, "A"+totalStr, lastHeaderCol+totalStr, totalStyle); err != nil {
-			return err
-		}
-		if item.Summary.TotalAccountsReceivable < 0 {
-			if err := file.SetCellStyle(sheet, "O"+totalStr, "O"+totalStr, redTotalStyle); err != nil {
-				return err
-			}
-		}
-		currentRow++
-
-		// Empty separator row
-		currentRow++
-	}
-
-	return nil
-}
-
-// customerPaymentRowCells returns 17 cell values for cols A..Q.
-func customerPaymentRowCells(row dto.CustomerPaymentReportRow, seq int) []interface{} {
-	return []interface{}{
-		seq,
-		formatCPDate(row.TransDate),
-		formatCPOptionalDate(row.DeliveryDate),
-		formatCPAging(row.AgingDay),
-		safeCPText(row.Reference),
-		joinCPStrings(row.VehicleNumbers),
-		formatCPIDInteger(row.Qty),
-		formatCPIDInteger(row.Weight),
-		formatCPAvg(row.AverageWeight),
-		formatCPRupiah(row.UnitPrice),
-		formatCPRupiah(row.FinalPrice),
-		formatCPRupiah(row.TotalPrice),
-		formatCPRupiah(row.PaymentAmount),
-		formatCPRupiah(row.AccountsReceivable),
-		safeCPText(row.Status),
-		joinCPStrings(row.PickupInfo),
-		safeCPText(row.SalesPerson),
-	}
-}
-
-func customerPaymentName(item dto.CustomerPaymentReportItem) string {
-	name := strings.TrimSpace(item.Customer.Name)
-	if name == "" {
-		return "Customer"
-	}
-	return name
-}
-
-func sanitizeCustomerPaymentSheetName(name string) string {
-	replacer := strings.NewReplacer(
-		":", " ", "\\", " ", "/", " ",
-		"?", " ", "*", " ", "[", " ", "]", " ",
-	)
-	sanitized := strings.TrimSpace(replacer.Replace(name))
-	if sanitized == "" {
-		return "Sheet"
-	}
-	runes := []rune(sanitized)
-	if len(runes) > 31 {
-		return string(runes[:31])
-	}
-	return sanitized
-}
-
-var cpIndonesianMonths = [12]string{
-	"Jan", "Feb", "Mar", "Apr", "Mei", "Jun",
-	"Jul", "Agu", "Sep", "Okt", "Nov", "Des",
-}
-
-func formatCPDate(t time.Time) string {
-	if t.IsZero() {
-		return "-"
-	}
-	loc, err := time.LoadLocation("Asia/Jakarta")
-	if err == nil {
-		t = t.In(loc)
-	}
-	return fmt.Sprintf("%02d %s %d", t.Day(), cpIndonesianMonths[t.Month()-1], t.Year())
-}
-
-func formatCPOptionalDate(t *time.Time) string {
-	if t == nil || t.IsZero() {
-		return "-"
-	}
-	return formatCPDate(*t)
-}
-
-func formatCPAging(v *int) string {
-	if v == nil {
-		return "-"
-	}
-	return strconv.Itoa(*v)
-}
-
-func formatCPIDInteger(v float64) string {
-	n := int64(math.Round(v))
-	if n == 0 {
-		return "0"
-	}
-	negative := n < 0
-	abs := n
-	if negative {
-		abs = -n
-	}
-	s := strconv.FormatInt(abs, 10)
-	// insert dots as thousand separators
-	var b strings.Builder
-	start := len(s) % 3
-	if start == 0 {
-		start = 3
-	}
-	b.WriteString(s[:start])
-	for i := start; i < len(s); i += 3 {
-		b.WriteByte('.')
-		b.WriteString(s[i : i+3])
-	}
-	if negative {
-		return "-" + b.String()
-	}
-	return b.String()
-}
-
-func formatCPRupiah(v float64) string {
-	const nbsp = " "
-	if v < 0 {
-		return "-Rp" + nbsp + formatCPIDInteger(-v)
-	}
-	return "Rp" + nbsp + formatCPIDInteger(v)
-}
-
-func formatCPAvg(v float64) string {
-	if v == 0 {
-		return "0"
-	}
-	s := strconv.FormatFloat(v, 'f', 2, 64)
-	return strings.ReplaceAll(s, ".", ",")
-}
-
-func safeCPText(s string) string {
-	t := strings.TrimSpace(s)
-	if t == "" {
-		return "-"
-	}
-	return t
-}
-
-func joinCPStrings(ss []string) string {
-	var parts []string
-	for _, s := range ss {
-		s = strings.TrimSpace(s)
-		if s != "" {
-			parts = append(parts, s)
-		}
-	}
-	if len(parts) == 0 {
-		return "-"
-	}
-	return strings.Join(parts, "\n")
-}

internal/modules/repports/controllers/repport.debt_supplier.export.go

@@ -1,452 +0,0 @@
-package controller
-
-import (
-	"fmt"
-	"strings"
-	"time"
-
-	"github.com/gofiber/fiber/v2"
-	"github.com/xuri/excelize/v2"
-	"gitlab.com/mbugroup/lti-api.git/internal/modules/repports/dto"
-)
-
-func isDebtSupplierExcelExportRequest(c *fiber.Ctx) bool {
-	return strings.EqualFold(strings.TrimSpace(c.Query("export")), "excel")
-}
-
-func isDebtSupplierExcelAllExportRequest(c *fiber.Ctx) bool {
-	return strings.EqualFold(strings.TrimSpace(c.Query("export")), "excel-all")
-}
-
-func exportDebtSupplierExcel(c *fiber.Ctx, items []dto.DebtSupplierDTO) error {
-	content, err := buildDebtSupplierWorkbook(items)
-	if err != nil {
-		return fiber.NewError(fiber.StatusInternalServerError, "failed to generate excel file")
-	}
-
-	filename := fmt.Sprintf("laporan-hutang-supplier-%s.xlsx", time.Now().Format("2006-01-02-1504"))
-	c.Set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
-	c.Set("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"`, filename))
-	return c.Status(fiber.StatusOK).Send(content)
-}
-
-func exportDebtSupplierExcelAll(c *fiber.Ctx, items []dto.DebtSupplierDTO) error {
-	content, err := buildDebtSupplierAllWorkbook(items)
-	if err != nil {
-		return fiber.NewError(fiber.StatusInternalServerError, "failed to generate excel file")
-	}
-
-	filename := fmt.Sprintf("laporan-hutang-supplier-all-%s.xlsx", time.Now().Format("2006-01-02-1504"))
-	c.Set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
-	c.Set("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"`, filename))
-	return c.Status(fiber.StatusOK).Send(content)
-}
-
-// buildDebtSupplierWorkbook creates a workbook with one sheet per supplier.
-func buildDebtSupplierWorkbook(items []dto.DebtSupplierDTO) ([]byte, error) {
-	file := excelize.NewFile()
-	defer file.Close()
-
-	defaultSheet := file.GetSheetName(file.GetActiveSheetIndex())
-
-	if len(items) == 0 {
-		if err := writeDebtSupplierSheet(file, defaultSheet, dto.DebtSupplierDTO{}); err != nil {
-			return nil, err
-		}
-		buf, err := file.WriteToBuffer()
-		if err != nil {
-			return nil, err
-		}
-		return buf.Bytes(), nil
-	}
-
-	for idx, item := range items {
-		sheetName := sanitizeDebtSupplierSheetName(debtSupplierName(item))
-		if sheetName == "" {
-			sheetName = fmt.Sprintf("Supplier %d", idx+1)
-		}
-
-		if idx == 0 {
-			if defaultSheet != sheetName {
-				if err := file.SetSheetName(defaultSheet, sheetName); err != nil {
-					return nil, err
-				}
-			}
-		} else {
-			if _, err := file.NewSheet(sheetName); err != nil {
-				return nil, err
-			}
-		}
-
-		if err := writeDebtSupplierSheet(file, sheetName, item); err != nil {
-			return nil, err
-		}
-	}
-
-	buf, err := file.WriteToBuffer()
-	if err != nil {
-		return nil, err
-	}
-	return buf.Bytes(), nil
-}
-
-// buildDebtSupplierAllWorkbook creates a single-sheet workbook with purchase-supplier styling.
-func buildDebtSupplierAllWorkbook(items []dto.DebtSupplierDTO) ([]byte, error) {
-	file := excelize.NewFile()
-	defer file.Close()
-
-	const sheet = "Rekap Hutang Supplier"
-	defaultSheet := file.GetSheetName(file.GetActiveSheetIndex())
-	if defaultSheet != sheet {
-		if err := file.SetSheetName(defaultSheet, sheet); err != nil {
-			return nil, err
-		}
-	}
-
-	if err := setDebtSupplierAllColumns(file, sheet); err != nil {
-		return nil, err
-	}
-	if err := setDebtSupplierAllHeaders(file, sheet); err != nil {
-		return nil, err
-	}
-	if err := writeDebtSupplierAllRows(file, sheet, items); err != nil {
-		return nil, err
-	}
-	if err := file.SetPanes(sheet, &excelize.Panes{
-		Freeze:      true,
-		YSplit:      1,
-		TopLeftCell: "A2",
-		ActivePane:  "bottomLeft",
-	}); err != nil {
-		return nil, err
-	}
-
-	buf, err := file.WriteToBuffer()
-	if err != nil {
-		return nil, err
-	}
-	return buf.Bytes(), nil
-}
-
-var debtSupplierSheetHeaders = []string{
-	"No",
-	"Nomor PR",
-	"Nomor PO",
-	"Tanggal Terima/Bayar",
-	"Tanggal PO",
-	"Aging (Hari)",
-	"Area",
-	"Gudang",
-	"Jatuh Tempo",
-	"Status Jatuh Tempo",
-	"Nominal Pembelian (Rp)",
-	"Pembayaran (Rp)",
-	"Sisa Saldo Hutang (Rp)",
-	"Status",
-	"Nomor Perjalanan",
-}
-
-var debtSupplierAllSheetHeaders = append([]string{"Supplier"}, debtSupplierSheetHeaders...)
-
-var debtSupplierSheetColumnWidths = map[string]float64{
-	"A": 5,
-	"B": 14,
-	"C": 12,
-	"D": 20,
-	"E": 10,
-	"F": 12,
-	"G": 15,
-	"H": 20,
-	"I": 12,
-	"J": 20,
-	"K": 20,
-	"L": 15,
-	"M": 20,
-	"N": 12,
-	"O": 15,
-}
-
-var debtSupplierAllSheetColumnWidths = map[string]float64{
-	"A": 24,
-	"B": 6,
-	"C": 14,
-	"D": 14,
-	"E": 20,
-	"F": 12,
-	"G": 10,
-	"H": 16,
-	"I": 22,
-	"J": 12,
-	"K": 22,
-	"L": 20,
-	"M": 18,
-	"N": 22,
-	"O": 14,
-	"P": 18,
-}
-
-func writeDebtSupplierSheet(file *excelize.File, sheet string, item dto.DebtSupplierDTO) error {
-	for col, width := range debtSupplierSheetColumnWidths {
-		if err := file.SetColWidth(sheet, col, col, width); err != nil {
-			return err
-		}
-	}
-
-	// Row 1: headers
-	for i, h := range debtSupplierSheetHeaders {
-		col, _ := excelize.ColumnNumberToName(i + 1)
-		if err := file.SetCellValue(sheet, col+"1", h); err != nil {
-			return err
-		}
-	}
-
-	// Row 2: saldo awal
-	if err := file.SetCellValue(sheet, "M2", item.InitialBalance); err != nil {
-		return err
-	}
-
-	// Rows 3+: data
-	redStyle, err := file.NewStyle(&excelize.Style{
-		Font: &excelize.Font{Color: "FF0000"},
-	})
-	if err != nil {
-		return err
-	}
-
-	for i, row := range item.Rows {
-		rowNum := i + 3
-		rowStr := fmt.Sprintf("%d", rowNum)
-
-		values := debtSupplierRowCells(row, i+1)
-		for colIdx, val := range values {
-			col, _ := excelize.ColumnNumberToName(colIdx + 1)
-			if err := file.SetCellValue(sheet, col+rowStr, val); err != nil {
-				return err
-			}
-		}
-
-		if row.DebtPrice < 0 {
-			if err := file.SetCellStyle(sheet, "M"+rowStr, "M"+rowStr, redStyle); err != nil {
-				return err
-			}
-		}
-	}
-
-	// Total row
-	totalRowNum := len(item.Rows) + 3
-	totalRowStr := fmt.Sprintf("%d", totalRowNum)
-	totalCells := map[string]interface{}{
-		"A": "Total",
-		"F": item.Total.Aging,
-		"K": item.Total.TotalPrice,
-		"L": item.Total.PaymentPrice,
-		"M": item.Total.DebtPrice,
-	}
-	for col, val := range totalCells {
-		if err := file.SetCellValue(sheet, col+totalRowStr, val); err != nil {
-			return err
-		}
-	}
-	if item.Total.DebtPrice < 0 {
-		if err := file.SetCellStyle(sheet, "M"+totalRowStr, "M"+totalRowStr, redStyle); err != nil {
-			return err
-		}
-	}
-
-	return nil
-}
-
-func setDebtSupplierAllColumns(file *excelize.File, sheet string) error {
-	for col, width := range debtSupplierAllSheetColumnWidths {
-		if err := file.SetColWidth(sheet, col, col, width); err != nil {
-			return err
-		}
-	}
-	if err := file.SetRowHeight(sheet, 1, 24); err != nil {
-		return err
-	}
-	return nil
-}
-
-func setDebtSupplierAllHeaders(file *excelize.File, sheet string) error {
-	headerStyle, err := file.NewStyle(&excelize.Style{
-		Font: &excelize.Font{Bold: true, Color: "FFFFFF", Family: "Arial", Size: 10},
-		Fill: excelize.Fill{Type: "pattern", Pattern: 1, Color: []string{"4472C4"}},
-		Alignment: &excelize.Alignment{
-			Horizontal: "center",
-			Vertical:   "center",
-			WrapText:   true,
-		},
-		Border: []excelize.Border{
-			{Type: "left", Color: "000000", Style: 1},
-			{Type: "top", Color: "000000", Style: 1},
-			{Type: "bottom", Color: "000000", Style: 1},
-			{Type: "right", Color: "000000", Style: 1},
-		},
-	})
-	if err != nil {
-		return err
-	}
-
-	for i, h := range debtSupplierAllSheetHeaders {
-		col, _ := excelize.ColumnNumberToName(i + 1)
-		if err := file.SetCellValue(sheet, col+"1", h); err != nil {
-			return err
-		}
-	}
-
-	lastCol, _ := excelize.ColumnNumberToName(len(debtSupplierAllSheetHeaders))
-	return file.SetCellStyle(sheet, "A1", lastCol+"1", headerStyle)
-}
-
-func writeDebtSupplierAllRows(file *excelize.File, sheet string, items []dto.DebtSupplierDTO) error {
-	borderStyle := []excelize.Border{
-		{Type: "left", Color: "000000", Style: 1},
-		{Type: "top", Color: "000000", Style: 1},
-		{Type: "bottom", Color: "000000", Style: 1},
-		{Type: "right", Color: "000000", Style: 1},
-	}
-
-	dataStyle, err := file.NewStyle(&excelize.Style{
-		Font:      &excelize.Font{Color: "000000", Family: "Arial", Size: 10},
-		Alignment: &excelize.Alignment{Vertical: "center", WrapText: true},
-		Border:    borderStyle,
-	})
-	if err != nil {
-		return err
-	}
-
-	totalStyle, err := file.NewStyle(&excelize.Style{
-		Font:      &excelize.Font{Bold: true, Color: "000000", Family: "Arial", Size: 10},
-		Fill:      excelize.Fill{Type: "pattern", Pattern: 1, Color: []string{"E2EFDA"}},
-		Alignment: &excelize.Alignment{Vertical: "center", WrapText: true},
-		Border:    borderStyle,
-	})
-	if err != nil {
-		return err
-	}
-
-	lastHeaderCol, _ := excelize.ColumnNumberToName(len(debtSupplierAllSheetHeaders))
-
-	currentRow := 2
-	for _, item := range items {
-		supplierName := debtSupplierName(item)
-
-		// Saldo awal row
-		saldoRowStr := fmt.Sprintf("%d", currentRow)
-		if err := file.SetCellValue(sheet, "A"+saldoRowStr, supplierName); err != nil {
-			return err
-		}
-		if err := file.SetCellValue(sheet, "N"+saldoRowStr, item.InitialBalance); err != nil {
-			return err
-		}
-		if err := file.SetCellStyle(sheet, "A"+saldoRowStr, lastHeaderCol+saldoRowStr, dataStyle); err != nil {
-			return err
-		}
-		currentRow++
-
-		// Data rows
-		for seq, row := range item.Rows {
-			rowStr := fmt.Sprintf("%d", currentRow)
-			if err := file.SetCellValue(sheet, "A"+rowStr, supplierName); err != nil {
-				return err
-			}
-			values := debtSupplierRowCells(row, seq+1)
-			for colIdx, val := range values {
-				col, _ := excelize.ColumnNumberToName(colIdx + 2)
-				if err := file.SetCellValue(sheet, col+rowStr, val); err != nil {
-					return err
-				}
-			}
-			if err := file.SetCellStyle(sheet, "A"+rowStr, lastHeaderCol+rowStr, dataStyle); err != nil {
-				return err
-			}
-			currentRow++
-		}
-
-		// Total row
-		totalRowStr := fmt.Sprintf("%d", currentRow)
-		totalCells := map[string]interface{}{
-			"A": supplierName,
-			"B": "Total",
-			"L": item.Total.TotalPrice,
-			"M": item.Total.PaymentPrice,
-			"N": item.Total.DebtPrice,
-		}
-		for col, val := range totalCells {
-			if err := file.SetCellValue(sheet, col+totalRowStr, val); err != nil {
-				return err
-			}
-		}
-		if err := file.SetCellStyle(sheet, "A"+totalRowStr, lastHeaderCol+totalRowStr, totalStyle); err != nil {
-			return err
-		}
-		currentRow++
-
-		// Empty separator row
-		currentRow++
-	}
-
-	return nil
-}
-
-// debtSupplierRowCells returns cell values for one data row (columns: No, PR, PO, ReceivedDate, PoDate, Aging, Area, Warehouse, DueDate, DueStatus, TotalPrice, PaymentPrice, DebtPrice, Status, TravelNumber).
-func debtSupplierRowCells(row dto.DebtSupplierRowDTO, seq int) []interface{} {
-	areaName := "-"
-	if row.Area != nil && strings.TrimSpace(row.Area.Name) != "" {
-		areaName = row.Area.Name
-	}
-	warehouseName := "-"
-	if row.Warehouse != nil && strings.TrimSpace(row.Warehouse.Name) != "" {
-		warehouseName = row.Warehouse.Name
-	}
-
-	return []interface{}{
-		seq,
-		safeDebtSupplierText(row.PrNumber),
-		safeDebtSupplierText(row.PoNumber),
-		safeDebtSupplierText(row.ReceivedDate),
-		safeDebtSupplierText(row.PoDate),
-		row.Aging,
-		areaName,
-		warehouseName,
-		safeDebtSupplierText(row.DueDate),
-		safeDebtSupplierText(row.DueStatus),
-		row.TotalPrice,
-		row.PaymentPrice,
-		row.DebtPrice,
-		safeDebtSupplierText(row.Status),
-		safeDebtSupplierText(row.TravelNumber),
-	}
-}
-
-func debtSupplierName(item dto.DebtSupplierDTO) string {
-	if item.Supplier != nil && strings.TrimSpace(item.Supplier.Name) != "" {
-		return item.Supplier.Name
-	}
-	return "Supplier"
-}
-
-func sanitizeDebtSupplierSheetName(name string) string {
-	replacer := strings.NewReplacer(
-		":", " ", "\\", " ", "/", " ",
-		"?", " ", "*", " ", "[", " ", "]", " ",
-	)
-	sanitized := strings.TrimSpace(replacer.Replace(name))
-	if sanitized == "" {
-		return "Sheet"
-	}
-	runes := []rune(sanitized)
-	if len(runes) > 31 {
-		return string(runes[:31])
-	}
-	return sanitized
-}
-
-func safeDebtSupplierText(s string) string {
-	t := strings.TrimSpace(s)
-	if t == "" {
-		return "-"
-	}
-	return t
-}

internal/modules/repports/dto/repportBalanceMonitoring.dto.go

@@ -1,71 +0,0 @@
-package dto
-
-import (
-	entity "gitlab.com/mbugroup/lti-api.git/internal/entities"
-	customerDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/master/customers/dto"
-)
-
-type BalanceMonitoringAyamDTO struct {
-	Ekor    float64 `json:"ekor"`
-	Kg      float64 `json:"kg"`
-	Nominal float64 `json:"nominal"`
-}
-
-type BalanceMonitoringTelurDTO struct {
-	Butir   float64 `json:"butir"`
-	Kg      float64 `json:"kg"`
-	Nominal float64 `json:"nominal"`
-}
-
-type BalanceMonitoringTradingDTO struct {
-	Qty     float64 `json:"qty"`
-	Kg      float64 `json:"kg"`
-	Nominal float64 `json:"nominal"`
-}
-
-type BalanceMonitoringRowDTO struct {
-	Customer         customerDTO.CustomerRelationDTO `json:"customer"`
-	SaldoAwal        float64                         `json:"saldo_awal"`
-	PenjualanAyam    BalanceMonitoringAyamDTO        `json:"penjualan_ayam"`
-	PenjualanTelur   BalanceMonitoringTelurDTO       `json:"penjualan_telur"`
-	PenjualanTrading BalanceMonitoringTradingDTO     `json:"penjualan_trading"`
-	Pembayaran       float64                         `json:"pembayaran"`
-	Aging            int                             `json:"aging"`
-	AgingRataRata    float64                         `json:"aging_rata_rata"`
-	SaldoAkhir       float64                         `json:"saldo_akhir"`
-}
-
-type BalanceMonitoringTotalsDTO struct {
-	SaldoAwal        float64                     `json:"saldo_awal"`
-	PenjualanAyam    BalanceMonitoringAyamDTO    `json:"penjualan_ayam"`
-	PenjualanTelur   BalanceMonitoringTelurDTO   `json:"penjualan_telur"`
-	PenjualanTrading BalanceMonitoringTradingDTO `json:"penjualan_trading"`
-	Pembayaran       float64                     `json:"pembayaran"`
-	Aging            int                         `json:"aging"`
-	AgingRataRata    float64                     `json:"aging_rata_rata"`
-	SaldoAkhir       float64                     `json:"saldo_akhir"`
-}
-
-func ToBalanceMonitoringRowDTO(
-	customer entity.Customer,
-	saldoAwal float64,
-	ayam BalanceMonitoringAyamDTO,
-	telur BalanceMonitoringTelurDTO,
-	trading BalanceMonitoringTradingDTO,
-	pembayaran float64,
-	aging int,
-	agingRataRata float64,
-) BalanceMonitoringRowDTO {
-	saldoAkhir := saldoAwal + pembayaran - (ayam.Nominal + telur.Nominal + trading.Nominal)
-	return BalanceMonitoringRowDTO{
-		Customer:         customerDTO.ToCustomerRelationDTO(customer),
-		SaldoAwal:        saldoAwal,
-		PenjualanAyam:    ayam,
-		PenjualanTelur:   telur,
-		PenjualanTrading: trading,
-		Pembayaran:       pembayaran,
-		Aging:            aging,
-		AgingRataRata:    agingRataRata,
-		SaldoAkhir:       saldoAkhir,
-	}
-}

internal/modules/repports/dto/repportExpense.dto.go

@@ -6,7 +6,6 @@ import (
 	entity "gitlab.com/mbugroup/lti-api.git/internal/entities"
 	approvalDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/approvals/dto"
 	kandangDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/master/kandangs/dto"
-	locationDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/master/locations/dto"
 	nonstockDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/master/nonstocks/dto"
 	supplierDTO "gitlab.com/mbugroup/lti-api.git/internal/modules/master/suppliers/dto"
 )
@@ -49,7 +48,6 @@ type RepportExpenseRealisasiDTO struct {
 
 type RepportExpenseListDTO struct {
 	RepportExpenseBaseDTO
-	Location       *locationDTO.LocationRelationDTO `json:"location,omitempty"`
 	Kandang        *kandangDTO.KandangRelationDTO   `json:"kandang,omitempty"`
 	Pengajuan      RepportExpensePengajuanDTO       `json:"pengajuan"`
 	Realisasi      RepportExpenseRealisasiDTO       `json:"realisasi"`
@@ -135,15 +133,6 @@ func ToRepportExpenseListDTO(baseDTO RepportExpenseBaseDTO, ns *entity.ExpenseNo
 		totalRealisasi = ns.Realization.Qty * ns.Realization.Price
 	}
 
-	var location *locationDTO.LocationRelationDTO
-	if ns.Expense != nil && ns.Expense.Location != nil && ns.Expense.Location.Id != 0 {
-		mapped := locationDTO.ToLocationRelationDTO(*ns.Expense.Location)
-		location = &mapped
-	} else if ns.Kandang != nil && ns.Kandang.Location.Id != 0 {
-		mapped := locationDTO.ToLocationRelationDTO(ns.Kandang.Location)
-		location = &mapped
-	}
-
 	// Get kandang data at the main level
 	var kandang *kandangDTO.KandangRelationDTO
 	if ns.Kandang != nil && ns.Kandang.Id != 0 {
@@ -153,7 +142,6 @@ func ToRepportExpenseListDTO(baseDTO RepportExpenseBaseDTO, ns *entity.ExpenseNo
 
 	return RepportExpenseListDTO{
 		RepportExpenseBaseDTO: baseDTO,
-		Location:              location,
 		Kandang:               kandang,
 		Pengajuan:             ToRepportExpensePengajuanDTO(ns),
 		Realisasi:             realisasi,

internal/modules/repports/module.go

@@ -40,7 +40,6 @@ func (RepportModule) RegisterRoutes(router fiber.Router, db *gorm.DB, validate *
 	expenseDepreciationRepository := repportRepo.NewExpenseDepreciationRepository(db)
 	productionResultRepository := repportRepo.NewProductionResultRepository(db)
 	customerPaymentRepository := repportRepo.NewCustomerPaymentRepository(db)
-	balanceMonitoringRepository := repportRepo.NewBalanceMonitoringRepository(db)
 	customerRepository := customerRepo.NewCustomerRepository(db)
 	standardGrowthDetailRepository := productionStandardRepo.NewStandardGrowthDetailRepository(db)
 	productionStandardDetailRepository := productionStandardRepo.NewProductionStandardDetailRepository(db)
@@ -67,7 +66,6 @@ func (RepportModule) RegisterRoutes(router fiber.Router, db *gorm.DB, validate *
 		hppPerKandangRepository,
 		productionResultRepository,
 		customerPaymentRepository,
-		balanceMonitoringRepository,
 		customerRepository,
 		standardGrowthDetailRepository,
 		productionStandardDetailRepository,

internal/modules/repports/repositories/balance_monitoring.repository.go

@@ -1,518 +0,0 @@
-package repositories
-
-import (
-	"context"
-	"fmt"
-	"strings"
-	"time"
-
-	entity "gitlab.com/mbugroup/lti-api.git/internal/entities"
-	validation "gitlab.com/mbugroup/lti-api.git/internal/modules/repports/validations"
-	"gitlab.com/mbugroup/lti-api.git/internal/utils"
-
-	"gorm.io/gorm"
-)
-
-type BalanceMonitoringCategoryRow struct {
-	CustomerID     uint    `gorm:"column:customer_id"`
-	AyamQty        float64 `gorm:"column:ayam_qty"`
-	AyamKg         float64 `gorm:"column:ayam_kg"`
-	AyamNominal    float64 `gorm:"column:ayam_nominal"`
-	TelurQty       float64 `gorm:"column:telur_qty"`
-	TelurKg        float64 `gorm:"column:telur_kg"`
-	TelurNominal   float64 `gorm:"column:telur_nominal"`
-	TradingQty     float64 `gorm:"column:trading_qty"`
-	TradingKg      float64 `gorm:"column:trading_kg"`
-	TradingNominal float64 `gorm:"column:trading_nominal"`
-}
-
-type BalanceMonitoringAgingRow struct {
-	CustomerID    uint    `gorm:"column:customer_id"`
-	AgingMax      int     `gorm:"column:aging_max"`
-	AgingRataRata float64 `gorm:"column:aging_rata_rata"`
-}
-
-type BalanceMonitoringGrandTotalsRow struct {
-	SaldoAwalLifetime float64 `gorm:"column:saldo_awal_lifetime"`
-	SalesBeforeStart  float64 `gorm:"column:sales_before_start"`
-	PaymentBeforeStart float64 `gorm:"column:payment_before_start"`
-	AyamQty           float64 `gorm:"column:ayam_qty"`
-	AyamKg            float64 `gorm:"column:ayam_kg"`
-	AyamNominal       float64 `gorm:"column:ayam_nominal"`
-	TelurQty          float64 `gorm:"column:telur_qty"`
-	TelurKg           float64 `gorm:"column:telur_kg"`
-	TelurNominal      float64 `gorm:"column:telur_nominal"`
-	TradingQty        float64 `gorm:"column:trading_qty"`
-	TradingKg         float64 `gorm:"column:trading_kg"`
-	TradingNominal    float64 `gorm:"column:trading_nominal"`
-	PaymentInPeriod   float64 `gorm:"column:payment_in_period"`
-	AgingMax          int     `gorm:"column:aging_max"`
-	AgingRataRata     float64 `gorm:"column:aging_rata_rata"`
-}
-
-type BalanceMonitoringRepository interface {
-	GetCustomerIDsForBalanceMonitoring(ctx context.Context, offset, limit int, filters *validation.BalanceMonitoringQuery) ([]uint, int64, error)
-	GetAllFilteredCustomerIDs(ctx context.Context, filters *validation.BalanceMonitoringQuery) ([]uint, error)
-	GetSaldoAwalLifetime(ctx context.Context, customerIDs []uint) (map[uint]float64, error)
-	GetSalesTotalsBeforeDate(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]float64, error)
-	GetPaymentTotalsBeforeDate(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]float64, error)
-	GetSalesByCategoryInPeriod(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]BalanceMonitoringCategoryRow, error)
-	GetPaymentTotalsInPeriod(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]float64, error)
-	GetAgingPerCustomer(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]BalanceMonitoringAgingRow, error)
-	GetGrandTotals(ctx context.Context, filters *validation.BalanceMonitoringQuery) (BalanceMonitoringGrandTotalsRow, error)
-}
-
-type balanceMonitoringRepositoryImpl struct {
-	db *gorm.DB
-}
-
-func NewBalanceMonitoringRepository(db *gorm.DB) BalanceMonitoringRepository {
-	return &balanceMonitoringRepositoryImpl{db: db}
-}
-
-func resolveBalanceMonitoringDateColumn(filterBy string) string {
-	switch strings.ToLower(strings.TrimSpace(filterBy)) {
-	case "realized_at":
-		return "mdp.delivery_date"
-	case "sold_at", "":
-		return "m.so_date"
-	default:
-		return "m.so_date"
-	}
-}
-
-func resolveBalanceMonitoringDateRange(filters *validation.BalanceMonitoringQuery) (time.Time, time.Time, error) {
-	var startDate time.Time
-	var endDate time.Time
-	var err error
-
-	if strings.TrimSpace(filters.StartDate) != "" {
-		startDate, err = utils.ParseDateString(filters.StartDate)
-		if err != nil {
-			return time.Time{}, time.Time{}, err
-		}
-	} else {
-		startDate = time.Date(1970, 1, 1, 0, 0, 0, 0, time.UTC)
-	}
-
-	if strings.TrimSpace(filters.EndDate) != "" {
-		endDate, err = utils.ParseDateString(filters.EndDate)
-		if err != nil {
-			return time.Time{}, time.Time{}, err
-		}
-	} else {
-		endDate = time.Now()
-	}
-
-	return startDate, endDate, nil
-}
-
-func resolveBalanceMonitoringSortClause(filters *validation.BalanceMonitoringQuery) string {
-	direction := "ASC"
-	if strings.EqualFold(strings.TrimSpace(filters.SortOrder), "desc") {
-		direction = "DESC"
-	}
-	switch strings.ToLower(strings.TrimSpace(filters.SortBy)) {
-	case "customer":
-		return "customers.name " + direction
-	default:
-		return "customers.name ASC"
-	}
-}
-
-func (r *balanceMonitoringRepositoryImpl) baseCustomerQuery(ctx context.Context, filters *validation.BalanceMonitoringQuery) *gorm.DB {
-	db := r.db.WithContext(ctx).
-		Model(&entity.Customer{}).
-		Where("customers.deleted_at IS NULL")
-
-	if len(filters.CustomerIDs) > 0 {
-		db = db.Where("customers.id IN ?", filters.CustomerIDs)
-	}
-
-	if len(filters.SalesIDs) > 0 {
-		db = db.Where("EXISTS (SELECT 1 FROM marketings m WHERE m.customer_id = customers.id AND m.deleted_at IS NULL AND m.sales_person_id IN ?)", filters.SalesIDs)
-	}
-
-	if filters.AllowedAreaIDs != nil || filters.AllowedLocationIDs != nil {
-		scopeSub := r.db.WithContext(ctx).
-			Table("marketings m").
-			Select("1").
-			Joins("JOIN marketing_products mp ON mp.marketing_id = m.id").
-			Joins("JOIN marketing_delivery_products mdp ON mdp.marketing_product_id = mp.id").
-			Joins("JOIN product_warehouses pw ON pw.id = mdp.product_warehouse_id").
-			Joins("JOIN warehouses w ON w.id = pw.warehouse_id").
-			Where("m.customer_id = customers.id").
-			Where("m.deleted_at IS NULL").
-			Where("mdp.delivery_date IS NOT NULL")
-
-		if filters.AllowedAreaIDs != nil {
-			if len(filters.AllowedAreaIDs) == 0 {
-				db = db.Where("1 = 0")
-			} else {
-				scopeSub = scopeSub.Where("w.area_id IN ?", filters.AllowedAreaIDs)
-			}
-		}
-		if filters.AllowedLocationIDs != nil {
-			if len(filters.AllowedLocationIDs) == 0 {
-				db = db.Where("1 = 0")
-			} else {
-				scopeSub = scopeSub.Where("w.location_id IN ?", filters.AllowedLocationIDs)
-			}
-		}
-
-		db = db.Where("EXISTS (?)", scopeSub)
-	}
-
-	return db
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetCustomerIDsForBalanceMonitoring(ctx context.Context, offset, limit int, filters *validation.BalanceMonitoringQuery) ([]uint, int64, error) {
-	var total int64
-	if err := r.baseCustomerQuery(ctx, filters).Count(&total).Error; err != nil {
-		return nil, 0, err
-	}
-	if total == 0 {
-		return []uint{}, 0, nil
-	}
-
-	if offset < 0 {
-		offset = 0
-	}
-
-	var customerIDs []uint
-	err := r.baseCustomerQuery(ctx, filters).
-		Order(resolveBalanceMonitoringSortClause(filters)).
-		Limit(limit).
-		Offset(offset).
-		Pluck("customers.id", &customerIDs).
-		Error
-	if err != nil {
-		return nil, 0, err
-	}
-
-	return customerIDs, total, nil
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetAllFilteredCustomerIDs(ctx context.Context, filters *validation.BalanceMonitoringQuery) ([]uint, error) {
-	var customerIDs []uint
-	if err := r.baseCustomerQuery(ctx, filters).Pluck("customers.id", &customerIDs).Error; err != nil {
-		return nil, err
-	}
-	return customerIDs, nil
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetSaldoAwalLifetime(ctx context.Context, customerIDs []uint) (map[uint]float64, error) {
-	if len(customerIDs) == 0 {
-		return map[uint]float64{}, nil
-	}
-
-	type row struct {
-		CustomerID uint    `gorm:"column:customer_id"`
-		Total      float64 `gorm:"column:total"`
-	}
-	rows := make([]row, 0)
-	err := r.db.WithContext(ctx).
-		Model(&entity.Payment{}).
-		Select("party_id AS customer_id, COALESCE(SUM(nominal), 0) AS total").
-		Where("party_type = ?", string(utils.PaymentPartyCustomer)).
-		Where("transaction_type = ?", string(utils.TransactionTypeSaldoAwal)).
-		Where("party_id IN ?", customerIDs).
-		Group("party_id").
-		Scan(&rows).Error
-	if err != nil {
-		return nil, err
-	}
-
-	result := make(map[uint]float64, len(rows))
-	for _, r := range rows {
-		result[r.CustomerID] = r.Total
-	}
-	return result, nil
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetSalesTotalsBeforeDate(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]float64, error) {
-	if len(customerIDs) == 0 {
-		return map[uint]float64{}, nil
-	}
-
-	startDate, _, err := resolveBalanceMonitoringDateRange(filters)
-	if err != nil {
-		return map[uint]float64{}, nil
-	}
-
-	dateColumn := resolveBalanceMonitoringDateColumn(filters.FilterBy)
-
-	type row struct {
-		CustomerID uint    `gorm:"column:customer_id"`
-		Total      float64 `gorm:"column:total"`
-	}
-	rows := make([]row, 0)
-	db := r.db.WithContext(ctx).
-		Table("marketing_delivery_products mdp").
-		Select("m.customer_id AS customer_id, COALESCE(SUM(mdp.total_price), 0) AS total").
-		Joins("INNER JOIN marketing_products mp ON mp.id = mdp.marketing_product_id").
-		Joins("INNER JOIN marketings m ON m.id = mp.marketing_id").
-		Where("m.customer_id IN ?", customerIDs).
-		Where("m.deleted_at IS NULL").
-		Where("mdp.delivery_date IS NOT NULL").
-		Where(fmt.Sprintf("DATE(%s) < ?", dateColumn), startDate)
-
-	if len(filters.SalesIDs) > 0 {
-		db = db.Where("m.sales_person_id IN ?", filters.SalesIDs)
-	}
-
-	if err := db.Group("m.customer_id").Scan(&rows).Error; err != nil {
-		return nil, err
-	}
-
-	result := make(map[uint]float64, len(rows))
-	for _, rr := range rows {
-		result[rr.CustomerID] = rr.Total
-	}
-	return result, nil
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetPaymentTotalsBeforeDate(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]float64, error) {
-	if len(customerIDs) == 0 {
-		return map[uint]float64{}, nil
-	}
-
-	startDate, _, err := resolveBalanceMonitoringDateRange(filters)
-	if err != nil {
-		return map[uint]float64{}, nil
-	}
-
-	type row struct {
-		CustomerID uint    `gorm:"column:customer_id"`
-		Total      float64 `gorm:"column:total"`
-	}
-	rows := make([]row, 0)
-	err = r.db.WithContext(ctx).
-		Model(&entity.Payment{}).
-		Select("party_id AS customer_id, COALESCE(SUM(nominal), 0) AS total").
-		Where("party_type = ?", string(utils.PaymentPartyCustomer)).
-		Where("transaction_type = ?", string(utils.TransactionTypePenjualan)).
-		Where("direction = ?", "IN").
-		Where("party_id IN ?", customerIDs).
-		Where("DATE(payment_date) < ?", startDate).
-		Group("party_id").
-		Scan(&rows).Error
-	if err != nil {
-		return nil, err
-	}
-
-	result := make(map[uint]float64, len(rows))
-	for _, rr := range rows {
-		result[rr.CustomerID] = rr.Total
-	}
-	return result, nil
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetSalesByCategoryInPeriod(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]BalanceMonitoringCategoryRow, error) {
-	if len(customerIDs) == 0 {
-		return map[uint]BalanceMonitoringCategoryRow{}, nil
-	}
-
-	startDate, endDate, err := resolveBalanceMonitoringDateRange(filters)
-	if err != nil {
-		return map[uint]BalanceMonitoringCategoryRow{}, nil
-	}
-
-	dateColumn := resolveBalanceMonitoringDateColumn(filters.FilterBy)
-
-	rows := make([]BalanceMonitoringCategoryRow, 0)
-	db := r.db.WithContext(ctx).
-		Table("marketing_delivery_products mdp").
-		Select(`m.customer_id AS customer_id,
-			COALESCE(SUM(CASE WHEN m.marketing_type IN ('AYAM','AYAM_PULLET') THEN mdp.usage_qty    ELSE 0 END), 0) AS ayam_qty,
-			COALESCE(SUM(CASE WHEN m.marketing_type IN ('AYAM','AYAM_PULLET') THEN mdp.total_weight ELSE 0 END), 0) AS ayam_kg,
-			COALESCE(SUM(CASE WHEN m.marketing_type IN ('AYAM','AYAM_PULLET') THEN mdp.total_price  ELSE 0 END), 0) AS ayam_nominal,
-			COALESCE(SUM(CASE WHEN m.marketing_type = 'TELUR' THEN mdp.usage_qty    ELSE 0 END), 0) AS telur_qty,
-			COALESCE(SUM(CASE WHEN m.marketing_type = 'TELUR' THEN mdp.total_weight ELSE 0 END), 0) AS telur_kg,
-			COALESCE(SUM(CASE WHEN m.marketing_type = 'TELUR' THEN mdp.total_price  ELSE 0 END), 0) AS telur_nominal,
-			COALESCE(SUM(CASE WHEN m.marketing_type = 'TRADING' THEN mdp.usage_qty    ELSE 0 END), 0) AS trading_qty,
-			COALESCE(SUM(CASE WHEN m.marketing_type = 'TRADING' THEN mdp.total_weight ELSE 0 END), 0) AS trading_kg,
-			COALESCE(SUM(CASE WHEN m.marketing_type = 'TRADING' THEN mdp.total_price  ELSE 0 END), 0) AS trading_nominal`).
-		Joins("INNER JOIN marketing_products mp ON mp.id = mdp.marketing_product_id").
-		Joins("INNER JOIN marketings m ON m.id = mp.marketing_id").
-		Where("m.customer_id IN ?", customerIDs).
-		Where("m.deleted_at IS NULL").
-		Where("mdp.delivery_date IS NOT NULL").
-		Where(fmt.Sprintf("DATE(%s) >= ?", dateColumn), startDate).
-		Where(fmt.Sprintf("DATE(%s) <= ?", dateColumn), endDate)
-
-	if len(filters.SalesIDs) > 0 {
-		db = db.Where("m.sales_person_id IN ?", filters.SalesIDs)
-	}
-
-	if err := db.Group("m.customer_id").Scan(&rows).Error; err != nil {
-		return nil, err
-	}
-
-	result := make(map[uint]BalanceMonitoringCategoryRow, len(rows))
-	for _, rr := range rows {
-		result[rr.CustomerID] = rr
-	}
-	return result, nil
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetPaymentTotalsInPeriod(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]float64, error) {
-	if len(customerIDs) == 0 {
-		return map[uint]float64{}, nil
-	}
-
-	startDate, endDate, err := resolveBalanceMonitoringDateRange(filters)
-	if err != nil {
-		return map[uint]float64{}, nil
-	}
-
-	type row struct {
-		CustomerID uint    `gorm:"column:customer_id"`
-		Total      float64 `gorm:"column:total"`
-	}
-	rows := make([]row, 0)
-	err = r.db.WithContext(ctx).
-		Model(&entity.Payment{}).
-		Select("party_id AS customer_id, COALESCE(SUM(nominal), 0) AS total").
-		Where("party_type = ?", string(utils.PaymentPartyCustomer)).
-		Where("transaction_type = ?", string(utils.TransactionTypePenjualan)).
-		Where("direction = ?", "IN").
-		Where("party_id IN ?", customerIDs).
-		Where("DATE(payment_date) >= ?", startDate).
-		Where("DATE(payment_date) <= ?", endDate).
-		Group("party_id").
-		Scan(&rows).Error
-	if err != nil {
-		return nil, err
-	}
-
-	result := make(map[uint]float64, len(rows))
-	for _, rr := range rows {
-		result[rr.CustomerID] = rr.Total
-	}
-	return result, nil
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetAgingPerCustomer(ctx context.Context, customerIDs []uint, filters *validation.BalanceMonitoringQuery) (map[uint]BalanceMonitoringAgingRow, error) {
-	if len(customerIDs) == 0 {
-		return map[uint]BalanceMonitoringAgingRow{}, nil
-	}
-
-	startDate, endDate, err := resolveBalanceMonitoringDateRange(filters)
-	if err != nil {
-		return map[uint]BalanceMonitoringAgingRow{}, nil
-	}
-
-	dateColumn := resolveBalanceMonitoringDateColumn(filters.FilterBy)
-
-	rows := make([]BalanceMonitoringAgingRow, 0)
-	db := r.db.WithContext(ctx).
-		Table("marketing_delivery_products mdp").
-		Select(`m.customer_id AS customer_id,
-			COALESCE(MAX(GREATEST(CURRENT_DATE - DATE(mdp.delivery_date), 0)), 0) AS aging_max,
-			COALESCE(
-				SUM(mdp.total_price * GREATEST(CURRENT_DATE - DATE(mdp.delivery_date), 0))::numeric
-				/ NULLIF(SUM(mdp.total_price), 0),
-				0
-			)::numeric(15,2) AS aging_rata_rata`).
-		Joins("INNER JOIN marketing_products mp ON mp.id = mdp.marketing_product_id").
-		Joins("INNER JOIN marketings m ON m.id = mp.marketing_id").
-		Where("m.customer_id IN ?", customerIDs).
-		Where("m.deleted_at IS NULL").
-		Where("mdp.delivery_date IS NOT NULL").
-		Where(fmt.Sprintf("DATE(%s) >= ?", dateColumn), startDate).
-		Where(fmt.Sprintf("DATE(%s) <= ?", dateColumn), endDate)
-
-	if len(filters.SalesIDs) > 0 {
-		db = db.Where("m.sales_person_id IN ?", filters.SalesIDs)
-	}
-
-	if err := db.Group("m.customer_id").Scan(&rows).Error; err != nil {
-		return nil, err
-	}
-
-	result := make(map[uint]BalanceMonitoringAgingRow, len(rows))
-	for _, rr := range rows {
-		result[rr.CustomerID] = rr
-	}
-	return result, nil
-}
-
-func (r *balanceMonitoringRepositoryImpl) GetGrandTotals(ctx context.Context, filters *validation.BalanceMonitoringQuery) (BalanceMonitoringGrandTotalsRow, error) {
-	customerIDs, err := r.GetAllFilteredCustomerIDs(ctx, filters)
-	if err != nil {
-		return BalanceMonitoringGrandTotalsRow{}, err
-	}
-	if len(customerIDs) == 0 {
-		return BalanceMonitoringGrandTotalsRow{}, nil
-	}
-
-	saldoAwalLifetimeMap, err := r.GetSaldoAwalLifetime(ctx, customerIDs)
-	if err != nil {
-		return BalanceMonitoringGrandTotalsRow{}, err
-	}
-	salesBeforeMap, err := r.GetSalesTotalsBeforeDate(ctx, customerIDs, filters)
-	if err != nil {
-		return BalanceMonitoringGrandTotalsRow{}, err
-	}
-	paymentBeforeMap, err := r.GetPaymentTotalsBeforeDate(ctx, customerIDs, filters)
-	if err != nil {
-		return BalanceMonitoringGrandTotalsRow{}, err
-	}
-	categoryMap, err := r.GetSalesByCategoryInPeriod(ctx, customerIDs, filters)
-	if err != nil {
-		return BalanceMonitoringGrandTotalsRow{}, err
-	}
-	paymentInPeriodMap, err := r.GetPaymentTotalsInPeriod(ctx, customerIDs, filters)
-	if err != nil {
-		return BalanceMonitoringGrandTotalsRow{}, err
-	}
-	agingMap, err := r.GetAgingPerCustomer(ctx, customerIDs, filters)
-	if err != nil {
-		return BalanceMonitoringGrandTotalsRow{}, err
-	}
-
-	totals := BalanceMonitoringGrandTotalsRow{}
-	for _, total := range saldoAwalLifetimeMap {
-		totals.SaldoAwalLifetime += total
-	}
-	for _, total := range salesBeforeMap {
-		totals.SalesBeforeStart += total
-	}
-	for _, total := range paymentBeforeMap {
-		totals.PaymentBeforeStart += total
-	}
-	for _, cat := range categoryMap {
-		totals.AyamQty += cat.AyamQty
-		totals.AyamKg += cat.AyamKg
-		totals.AyamNominal += cat.AyamNominal
-		totals.TelurQty += cat.TelurQty
-		totals.TelurKg += cat.TelurKg
-		totals.TelurNominal += cat.TelurNominal
-		totals.TradingQty += cat.TradingQty
-		totals.TradingKg += cat.TradingKg
-		totals.TradingNominal += cat.TradingNominal
-	}
-	for _, total := range paymentInPeriodMap {
-		totals.PaymentInPeriod += total
-	}
-
-	for _, aging := range agingMap {
-		totals.AgingMax += aging.AgingMax
-	}
-
-	weightedSum := 0.0
-	weightTotal := 0.0
-	for cid, cat := range categoryMap {
-		nominal := cat.AyamNominal + cat.TelurNominal + cat.TradingNominal
-		if aging, ok := agingMap[cid]; ok && nominal > 0 {
-			weightedSum += nominal * aging.AgingRataRata
-			weightTotal += nominal
-		}
-	}
-	if weightTotal > 0 {
-		totals.AgingRataRata = weightedSum / weightTotal
-	}
-
-	return totals, nil
-}

internal/modules/repports/route.go

@@ -26,5 +26,4 @@ func RepportRoutes(v1 fiber.Router, u user.UserService, s repport.RepportService
 	route.Get("/hpp-v2-breakdown", m.RequirePermissions(m.P_ReportHppPerKandangGetAll), ctrl.GetHppV2Breakdown)
 	route.Get("/production-result/:idProjectFlockKandang", m.RequirePermissions(m.P_ReportProductionResultGetAll), ctrl.GetProductionResult)
 	route.Get("/customer-payment", m.RequirePermissions(m.P_ReportCustomerPaymentGetAll), ctrl.GetCustomerPayment)
-	route.Get("/balance-monitoring", m.RequirePermissions(m.P_ReportCustomerPaymentGetAll), ctrl.GetBalanceMonitoring)
 }

internal/modules/repports/services/repport.service.go

@@ -52,7 +52,6 @@ type RepportService interface {
 	GetHppV2Breakdown(ctx *fiber.Ctx, params *validation.HppV2BreakdownQuery) (*approvalService.HppV2Breakdown, error)
 	GetProductionResult(ctx *fiber.Ctx, params *validation.ProductionResultQuery) ([]dto.ProductionResultDTO, int64, error)
 	GetCustomerPayment(ctx *fiber.Ctx, params *validation.CustomerPaymentQuery) ([]dto.CustomerPaymentReportItem, int64, error)
-	GetBalanceMonitoring(ctx *fiber.Ctx, params *validation.BalanceMonitoringQuery) ([]dto.BalanceMonitoringRowDTO, dto.BalanceMonitoringTotalsDTO, int64, error)
 	DB() *gorm.DB
 }
 
@@ -75,7 +74,6 @@ type repportService struct {
 	HppPerKandangRepo            repportRepo.HppPerKandangRepository
 	ProductionResultRepo         repportRepo.ProductionResultRepository
 	CustomerPaymentRepo          repportRepo.CustomerPaymentRepository
-	BalanceMonitoringRepo        repportRepo.BalanceMonitoringRepository
 	CustomerRepo                 customerRepo.CustomerRepository
 	StandardGrowthDetailRepo     productionStandardRepository.StandardGrowthDetailRepository
 	ProductionStandardDetailRepo productionStandardRepository.ProductionStandardDetailRepository
@@ -108,7 +106,6 @@ func NewRepportService(
 	hppPerKandangRepo repportRepo.HppPerKandangRepository,
 	productionResultRepo repportRepo.ProductionResultRepository,
 	customerPaymentRepo repportRepo.CustomerPaymentRepository,
-	balanceMonitoringRepo repportRepo.BalanceMonitoringRepository,
 	customerRepo customerRepo.CustomerRepository,
 	standardGrowthDetailRepo productionStandardRepository.StandardGrowthDetailRepository,
 	productionStandardDetailRepo productionStandardRepository.ProductionStandardDetailRepository,
@@ -132,7 +129,6 @@ func NewRepportService(
 		HppPerKandangRepo:            hppPerKandangRepo,
 		ProductionResultRepo:         productionResultRepo,
 		CustomerPaymentRepo:          customerPaymentRepo,
-		BalanceMonitoringRepo:        balanceMonitoringRepo,
 		CustomerRepo:                 customerRepo,
 		StandardGrowthDetailRepo:     standardGrowthDetailRepo,
 		ProductionStandardDetailRepo: productionStandardDetailRepo,
@@ -2897,163 +2893,3 @@ func parseOptionalFloat64(raw string) (*float64, error) {
 
 	return &value, nil
 }
-
-func (s *repportService) GetBalanceMonitoring(ctx *fiber.Ctx, params *validation.BalanceMonitoringQuery) ([]dto.BalanceMonitoringRowDTO, dto.BalanceMonitoringTotalsDTO, int64, error) {
-	if params.SortBy == "" {
-		params.SortBy = "customer"
-	}
-	if params.SortOrder == "" {
-		params.SortOrder = "asc"
-	}
-	if params.FilterBy == "" {
-		params.FilterBy = "sold_at"
-	}
-	if params.Page < 1 {
-		params.Page = 1
-	}
-	if params.Limit < 1 {
-		params.Limit = 10
-	}
-
-	if err := s.Validate.Struct(params); err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-
-	locationScope, err := m.ResolveLocationScope(ctx, s.DB())
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	areaScope, err := m.ResolveAreaScope(ctx, s.DB())
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	if locationScope.Restrict {
-		params.AllowedLocationIDs = toInt64Slice(locationScope.IDs)
-	}
-	if areaScope.Restrict {
-		params.AllowedAreaIDs = toInt64Slice(areaScope.IDs)
-	}
-
-	offset := (params.Page - 1) * params.Limit
-
-	customerIDs, total, err := s.BalanceMonitoringRepo.GetCustomerIDsForBalanceMonitoring(ctx.Context(), offset, params.Limit, params)
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	if len(customerIDs) == 0 {
-		emptyTotals, gtErr := s.computeBalanceMonitoringTotals(ctx.Context(), params)
-		if gtErr != nil {
-			return nil, dto.BalanceMonitoringTotalsDTO{}, 0, gtErr
-		}
-		return []dto.BalanceMonitoringRowDTO{}, emptyTotals, total, nil
-	}
-
-	saldoAwalLifetimeMap, err := s.BalanceMonitoringRepo.GetSaldoAwalLifetime(ctx.Context(), customerIDs)
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	salesBeforeMap, err := s.BalanceMonitoringRepo.GetSalesTotalsBeforeDate(ctx.Context(), customerIDs, params)
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	paymentBeforeMap, err := s.BalanceMonitoringRepo.GetPaymentTotalsBeforeDate(ctx.Context(), customerIDs, params)
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	categoryMap, err := s.BalanceMonitoringRepo.GetSalesByCategoryInPeriod(ctx.Context(), customerIDs, params)
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	paymentInPeriodMap, err := s.BalanceMonitoringRepo.GetPaymentTotalsInPeriod(ctx.Context(), customerIDs, params)
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	agingMap, err := s.BalanceMonitoringRepo.GetAgingPerCustomer(ctx.Context(), customerIDs, params)
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-
-	customers, err := s.CustomerRepo.GetByIDs(ctx.Context(), customerIDs, func(db *gorm.DB) *gorm.DB {
-		return db.Preload("Pic")
-	})
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-	customerMap := make(map[uint]entity.Customer, len(customers))
-	for _, c := range customers {
-		customerMap[c.Id] = c
-	}
-
-	result := make([]dto.BalanceMonitoringRowDTO, 0, len(customerIDs))
-	for _, customerID := range customerIDs {
-		customer, ok := customerMap[customerID]
-		if !ok {
-			continue
-		}
-
-		saldoAwal := saldoAwalLifetimeMap[customerID] + paymentBeforeMap[customerID] - salesBeforeMap[customerID]
-
-		category := categoryMap[customerID]
-		ayam := dto.BalanceMonitoringAyamDTO{
-			Ekor:    category.AyamQty,
-			Kg:      category.AyamKg,
-			Nominal: category.AyamNominal,
-		}
-		telur := dto.BalanceMonitoringTelurDTO{
-			Butir:   category.TelurQty,
-			Kg:      category.TelurKg,
-			Nominal: category.TelurNominal,
-		}
-		trading := dto.BalanceMonitoringTradingDTO{
-			Qty:     category.TradingQty,
-			Kg:      category.TradingKg,
-			Nominal: category.TradingNominal,
-		}
-
-		pembayaran := paymentInPeriodMap[customerID]
-		aging := agingMap[customerID]
-
-		row := dto.ToBalanceMonitoringRowDTO(customer, saldoAwal, ayam, telur, trading, pembayaran, aging.AgingMax, aging.AgingRataRata)
-		result = append(result, row)
-	}
-
-	totals, err := s.computeBalanceMonitoringTotals(ctx.Context(), params)
-	if err != nil {
-		return nil, dto.BalanceMonitoringTotalsDTO{}, 0, err
-	}
-
-	return result, totals, total, nil
-}
-
-func (s *repportService) computeBalanceMonitoringTotals(ctx context.Context, params *validation.BalanceMonitoringQuery) (dto.BalanceMonitoringTotalsDTO, error) {
-	grand, err := s.BalanceMonitoringRepo.GetGrandTotals(ctx, params)
-	if err != nil {
-		return dto.BalanceMonitoringTotalsDTO{}, err
-	}
-
-	saldoAwal := grand.SaldoAwalLifetime + grand.PaymentBeforeStart - grand.SalesBeforeStart
-	saldoAkhir := saldoAwal + grand.PaymentInPeriod - (grand.AyamNominal + grand.TelurNominal + grand.TradingNominal)
-
-	return dto.BalanceMonitoringTotalsDTO{
-		SaldoAwal: saldoAwal,
-		PenjualanAyam: dto.BalanceMonitoringAyamDTO{
-			Ekor:    grand.AyamQty,
-			Kg:      grand.AyamKg,
-			Nominal: grand.AyamNominal,
-		},
-		PenjualanTelur: dto.BalanceMonitoringTelurDTO{
-			Butir:   grand.TelurQty,
-			Kg:      grand.TelurKg,
-			Nominal: grand.TelurNominal,
-		},
-		PenjualanTrading: dto.BalanceMonitoringTradingDTO{
-			Qty:     grand.TradingQty,
-			Kg:      grand.TradingKg,
-			Nominal: grand.TradingNominal,
-		},
-		Pembayaran:    grand.PaymentInPeriod,
-		Aging:         grand.AgingMax,
-		AgingRataRata: grand.AgingRataRata,
-		SaldoAkhir:    saldoAkhir,
-	}, nil
-}

internal/modules/repports/validations/repport.validation.go

@@ -116,17 +116,3 @@ type CustomerPaymentQuery struct {
 	StartDate   string `query:"start_date" validate:"omitempty,datetime=2006-01-02"`
 	EndDate     string `query:"end_date" validate:"omitempty,datetime=2006-01-02"`
 }
-
-type BalanceMonitoringQuery struct {
-	Page               int     `query:"page" validate:"omitempty,min=1,gt=0"`
-	Limit              int     `query:"limit" validate:"omitempty,min=1,gt=0"`
-	CustomerIDs        []uint  `query:"-" validate:"omitempty,dive,gt=0"`
-	SalesIDs           []uint  `query:"-" validate:"omitempty,dive,gt=0"`
-	FilterBy           string  `query:"filter_by" validate:"omitempty,oneof=sold_at realized_at"`
-	SortBy             string  `query:"sort_by" validate:"omitempty,oneof=customer"`
-	SortOrder          string  `query:"sort_order" validate:"omitempty,oneof=asc desc"`
-	StartDate          string  `query:"start_date" validate:"omitempty,datetime=2006-01-02"`
-	EndDate            string  `query:"end_date" validate:"omitempty,datetime=2006-01-02"`
-	AllowedAreaIDs     []int64 `query:"-"`
-	AllowedLocationIDs []int64 `query:"-"`
-}