mirror of
https://gitlab.com/mbugroup/lti-api.git
synced 2026-05-25 15:55:44 +00:00
Compare commits
56 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 2da476b276 | |||
| 3232fc90bb | |||
| ef985b5da5 | |||
| 55666c1dcd | |||
| c107f0f683 | |||
| ba8f00a560 | |||
| 65a1282312 | |||
| 1ca632d838 | |||
| f0403e2699 | |||
| 3e34da7385 | |||
| 8750e2ffec | |||
| 3429529162 | |||
| 32b8acb9dc | |||
| 1992005b01 | |||
| 0d7a0e30cd | |||
| b12f563bc4 | |||
| d0e7b7aad1 | |||
| c676aed371 | |||
| e781115390 | |||
| 7bbb6a836c | |||
| 6bbab2f1d5 | |||
| 70546c2302 | |||
| 6c7d8ac83e | |||
| 1e48bc8762 | |||
| 77a30837e2 | |||
| a63460e853 | |||
| 1be0fa1a5f | |||
| c9e3905a65 | |||
| 495f5f5cc1 | |||
| 71e80634b1 | |||
| 621d0d2bfd | |||
| 1fd3f96038 | |||
| cf0fc9e7e6 | |||
| d9041a89bb | |||
| c75281ebd9 | |||
| ca3ad810c6 | |||
| 655b1ad5fe | |||
| 84db5fe37a | |||
| 63a78da18d | |||
| ac50c06cd7 | |||
| b60649f59d | |||
| 6acc9416c1 | |||
| bb4e5d6e3e | |||
| 170c221957 | |||
| 812327f148 | |||
| cd192128f1 | |||
| a5d4d6c11d | |||
| 1452f8d083 | |||
| 33c6706181 | |||
| c9618e1095 | |||
| cae7f3ef63 | |||
| 42793d94bd | |||
| 1369bf0e36 | |||
| 361d14bd3e | |||
| 7923352535 | |||
| 010240066a |
@@ -0,0 +1,4 @@
|
||||
UPDATE adjustment_stocks
|
||||
SET price = 9535,
|
||||
grand_total = ROUND(8700 * 9535, 3)
|
||||
WHERE id = 532 AND adj_number = 'ADJ-00507';
|
||||
@@ -0,0 +1,5 @@
|
||||
|
||||
UPDATE adjustment_stocks
|
||||
SET price = 12635,
|
||||
grand_total = ROUND(8700 * 12635, 3)
|
||||
WHERE id = 532 AND adj_number = 'ADJ-00507';
|
||||
+31
@@ -0,0 +1,31 @@
|
||||
BEGIN;
|
||||
|
||||
-- Rollback konsolidasi: kembalikan data ke loc 18 / 25 sesuai snapshot pre-migration.
|
||||
-- Order: un-soft-delete locations dulu agar FK tidak gagal saat UPDATE child.
|
||||
|
||||
-- 1. Un-soft-delete locations
|
||||
UPDATE locations SET deleted_at = NULL WHERE id IN (18, 25);
|
||||
|
||||
-- 2. project_flocks: PF 30 -> 18, PF 25 & 31 -> 25
|
||||
UPDATE project_flocks SET location_id = 18, updated_at = NOW() WHERE id = 30;
|
||||
UPDATE project_flocks SET location_id = 25, updated_at = NOW() WHERE id IN (25, 31);
|
||||
|
||||
-- 3. kandangs: K9, K72, K117 -> 18; K10, K73, K116 -> 25
|
||||
UPDATE kandangs SET location_id = 18, updated_at = NOW() WHERE id IN (9, 72, 117);
|
||||
UPDATE kandangs SET location_id = 25, updated_at = NOW() WHERE id IN (10, 73, 116);
|
||||
|
||||
-- 4. kandang_groups: KG 26, 68 -> 18; KG 27, 67 -> 25
|
||||
UPDATE kandang_groups SET location_id = 18, updated_at = NOW() WHERE id IN (26, 68);
|
||||
UPDATE kandang_groups SET location_id = 25, updated_at = NOW() WHERE id IN (27, 67);
|
||||
|
||||
-- 5. warehouses: W27, W145, W152 -> 18; W3, W146, W153 -> 25
|
||||
UPDATE warehouses SET location_id = 18, updated_at = NOW() WHERE id IN (27, 145, 152);
|
||||
UPDATE warehouses SET location_id = 25, updated_at = NOW() WHERE id IN (3, 146, 153);
|
||||
|
||||
-- 6. expenses: list eksplisit per location
|
||||
UPDATE expenses SET location_id = 18, updated_at = NOW()
|
||||
WHERE id IN (36, 345, 500, 501, 502, 503, 504, 505, 506, 507, 508);
|
||||
UPDATE expenses SET location_id = 25, updated_at = NOW()
|
||||
WHERE id IN (9, 37, 509, 510, 511, 512, 513, 514, 515, 516, 517, 518);
|
||||
|
||||
COMMIT;
|
||||
+34
@@ -0,0 +1,34 @@
|
||||
BEGIN;
|
||||
|
||||
-- Konsolidasi 3 lokasi "Pullet Cikaum" jadi 1.
|
||||
-- Pindahkan semua data di loc 18 (Pullet Cikaum 1) & 25 (Pullet Cikaum 2) ke loc 2 (Pullet Cikaum).
|
||||
-- Urutan wajib: semua UPDATE child harus selesai SEBELUM soft-delete locations,
|
||||
-- karena trigger trg_soft_delete_fk_locations akan RAISE EXCEPTION untuk FK
|
||||
-- RESTRICT (project_flocks, kandangs, kandang_groups, expenses) atau SET NULL
|
||||
-- untuk warehouses kalau masih ada child yang reference.
|
||||
|
||||
-- 1. project_flocks (PF 25, 30, 31)
|
||||
UPDATE project_flocks SET location_id = 2, updated_at = NOW()
|
||||
WHERE location_id IN (18, 25);
|
||||
|
||||
-- 2. kandangs (K9, K72, K117, K10, K73, K116)
|
||||
UPDATE kandangs SET location_id = 2, updated_at = NOW()
|
||||
WHERE location_id IN (18, 25);
|
||||
|
||||
-- 3. kandang_groups (KG 26, 68, 27, 67)
|
||||
UPDATE kandang_groups SET location_id = 2, updated_at = NOW()
|
||||
WHERE location_id IN (18, 25);
|
||||
|
||||
-- 4. warehouses (W3, W27, W145, W146, W152, W153)
|
||||
UPDATE warehouses SET location_id = 2, updated_at = NOW()
|
||||
WHERE location_id IN (18, 25);
|
||||
|
||||
-- 5. expenses (23 row BOP)
|
||||
UPDATE expenses SET location_id = 2, updated_at = NOW()
|
||||
WHERE location_id IN (18, 25);
|
||||
|
||||
-- 6. Soft-delete locations 18 & 25 (kosong, aman karena semua child sudah pindah)
|
||||
UPDATE locations SET deleted_at = NOW()
|
||||
WHERE id IN (18, 25) AND deleted_at IS NULL;
|
||||
|
||||
COMMIT;
|
||||
@@ -5,6 +5,7 @@ import (
|
||||
"strconv"
|
||||
"strings"
|
||||
|
||||
entity "gitlab.com/mbugroup/lti-api.git/internal/entities"
|
||||
"gitlab.com/mbugroup/lti-api.git/internal/modules/finance/transactions/dto"
|
||||
service "gitlab.com/mbugroup/lti-api.git/internal/modules/finance/transactions/services"
|
||||
validation "gitlab.com/mbugroup/lti-api.git/internal/modules/finance/transactions/validations"
|
||||
@@ -13,6 +14,8 @@ import (
|
||||
"github.com/gofiber/fiber/v2"
|
||||
)
|
||||
|
||||
const transactionExcelExportFetchLimit = 99999999
|
||||
|
||||
type TransactionController struct {
|
||||
TransactionService service.TransactionService
|
||||
}
|
||||
@@ -107,6 +110,14 @@ func (u *TransactionController) GetAll(c *fiber.Ctx) error {
|
||||
return fiber.NewError(fiber.StatusBadRequest, "page and limit must be greater than 0")
|
||||
}
|
||||
|
||||
if isTransactionExcelExportRequest(c) {
|
||||
results, err := u.getAllTransactionsForExcel(c, query)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return exportTransactionListExcel(c, results)
|
||||
}
|
||||
|
||||
result, totalResults, err := u.TransactionService.GetAll(c, query)
|
||||
if err != nil {
|
||||
return err
|
||||
@@ -149,6 +160,32 @@ func (u *TransactionController) GetOne(c *fiber.Ctx) error {
|
||||
})
|
||||
}
|
||||
|
||||
func isTransactionExcelExportRequest(c *fiber.Ctx) bool {
|
||||
return strings.EqualFold(strings.TrimSpace(c.Query("export")), "excel")
|
||||
}
|
||||
|
||||
func (u *TransactionController) getAllTransactionsForExcel(c *fiber.Ctx, baseQuery *validation.Query) ([]entity.Payment, error) {
|
||||
query := *baseQuery
|
||||
query.Page = 1
|
||||
query.Limit = transactionExcelExportFetchLimit
|
||||
results := make([]entity.Payment, 0)
|
||||
for {
|
||||
pageResults, total, err := u.TransactionService.GetAll(c, &query)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if len(pageResults) == 0 || total == 0 {
|
||||
break
|
||||
}
|
||||
results = append(results, pageResults...)
|
||||
if int64(len(results)) >= total {
|
||||
break
|
||||
}
|
||||
query.Page++
|
||||
}
|
||||
return results, nil
|
||||
}
|
||||
|
||||
func (u *TransactionController) DeleteOne(c *fiber.Ctx) error {
|
||||
param := c.Params("id")
|
||||
|
||||
|
||||
@@ -0,0 +1,307 @@
|
||||
package controller
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/gofiber/fiber/v2"
|
||||
"github.com/xuri/excelize/v2"
|
||||
entity "gitlab.com/mbugroup/lti-api.git/internal/entities"
|
||||
)
|
||||
|
||||
const transactionExportSheetName = "Transaksi"
|
||||
|
||||
func exportTransactionListExcel(c *fiber.Ctx, payments []entity.Payment) error {
|
||||
content, err := buildTransactionExportWorkbook(payments)
|
||||
if err != nil {
|
||||
return fiber.NewError(fiber.StatusInternalServerError, "failed to generate excel file")
|
||||
}
|
||||
|
||||
filename := fmt.Sprintf("transaksi_%s.xlsx", time.Now().Format("20060102_150405"))
|
||||
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 buildTransactionExportWorkbook(payments []entity.Payment) ([]byte, error) {
|
||||
file := excelize.NewFile()
|
||||
defer file.Close()
|
||||
|
||||
defaultSheet := file.GetSheetName(file.GetActiveSheetIndex())
|
||||
if defaultSheet != transactionExportSheetName {
|
||||
if err := file.SetSheetName(defaultSheet, transactionExportSheetName); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
|
||||
if err := setTransactionExportColumns(file); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := setTransactionExportHeaders(file); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := setTransactionExportRows(file, payments); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := file.SetPanes(transactionExportSheetName, &excelize.Panes{
|
||||
Freeze: true,
|
||||
YSplit: 1,
|
||||
TopLeftCell: "A2",
|
||||
ActivePane: "bottomLeft",
|
||||
}); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
buffer, err := file.WriteToBuffer()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return buffer.Bytes(), nil
|
||||
}
|
||||
|
||||
func setTransactionExportColumns(file *excelize.File) error {
|
||||
columnWidths := map[string]float64{
|
||||
"A": 20,
|
||||
"B": 22,
|
||||
"C": 18,
|
||||
"D": 25,
|
||||
"E": 14,
|
||||
"F": 16,
|
||||
"G": 16,
|
||||
"H": 22,
|
||||
"I": 22,
|
||||
"J": 18,
|
||||
"K": 18,
|
||||
"L": 18,
|
||||
"M": 30,
|
||||
"N": 22,
|
||||
"O": 20,
|
||||
}
|
||||
|
||||
sheet := transactionExportSheetName
|
||||
for col, width := range columnWidths {
|
||||
if err := file.SetColWidth(sheet, col, col, width); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return file.SetRowHeight(sheet, 1, 24)
|
||||
}
|
||||
|
||||
func setTransactionExportHeaders(file *excelize.File) error {
|
||||
sheet := transactionExportSheetName
|
||||
headers := []string{
|
||||
"Kode Pembayaran",
|
||||
"No. Referensi",
|
||||
"Tipe Transaksi",
|
||||
"Pihak",
|
||||
"Tipe Pihak",
|
||||
"Tanggal Bayar",
|
||||
"Metode Bayar",
|
||||
"Bank",
|
||||
"No. Rekening Bank",
|
||||
"Pemasukan",
|
||||
"Pengeluaran",
|
||||
"Nominal",
|
||||
"Catatan",
|
||||
"Dibuat Oleh",
|
||||
"Status",
|
||||
}
|
||||
|
||||
for i, header := range headers {
|
||||
colName, err := excelize.ColumnNumberToName(i + 1)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, colName+"1", header); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
headerStyle, err := file.NewStyle(&excelize.Style{
|
||||
Font: &excelize.Font{Bold: true, Color: "1F2937"},
|
||||
Fill: excelize.Fill{Type: "pattern", Pattern: 1, Color: []string{"DCEBFA"}},
|
||||
Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"},
|
||||
Border: []excelize.Border{
|
||||
{Type: "left", Color: "D1D5DB", Style: 1},
|
||||
{Type: "top", Color: "D1D5DB", Style: 1},
|
||||
{Type: "bottom", Color: "D1D5DB", Style: 1},
|
||||
{Type: "right", Color: "D1D5DB", Style: 1},
|
||||
},
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return file.SetCellStyle(sheet, "A1", "O1", headerStyle)
|
||||
}
|
||||
|
||||
func setTransactionExportRows(file *excelize.File, payments []entity.Payment) error {
|
||||
if len(payments) == 0 {
|
||||
return nil
|
||||
}
|
||||
|
||||
sheet := transactionExportSheetName
|
||||
for i, p := range payments {
|
||||
row := strconv.Itoa(i + 2)
|
||||
if err := writeTransactionExportRow(file, sheet, row, p); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
lastRow := strconv.Itoa(len(payments) + 1)
|
||||
|
||||
dataStyle, err := file.NewStyle(&excelize.Style{
|
||||
Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center", WrapText: true},
|
||||
Border: []excelize.Border{
|
||||
{Type: "left", Color: "D1D5DB", Style: 1},
|
||||
{Type: "top", Color: "D1D5DB", Style: 1},
|
||||
{Type: "bottom", Color: "D1D5DB", Style: 1},
|
||||
{Type: "right", Color: "D1D5DB", Style: 1},
|
||||
},
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "A2", "O"+lastRow, dataStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
numericStyle, err := file.NewStyle(&excelize.Style{
|
||||
Alignment: &excelize.Alignment{Horizontal: "right", Vertical: "center"},
|
||||
Border: []excelize.Border{
|
||||
{Type: "left", Color: "D1D5DB", Style: 1},
|
||||
{Type: "top", Color: "D1D5DB", Style: 1},
|
||||
{Type: "bottom", Color: "D1D5DB", Style: 1},
|
||||
{Type: "right", Color: "D1D5DB", Style: 1},
|
||||
},
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return file.SetCellStyle(sheet, "J2", "L"+lastRow, numericStyle)
|
||||
}
|
||||
|
||||
func writeTransactionExportRow(file *excelize.File, sheet, row string, p entity.Payment) error {
|
||||
incomeAmount, expenseAmount := txAmounts(p.Direction, p.Nominal)
|
||||
|
||||
values := []interface{}{
|
||||
safeTxText(p.PaymentCode),
|
||||
safeTxRefNumber(p.ReferenceNumber),
|
||||
safeTxText(txTransactionType(p)),
|
||||
safeTxText(txPartyName(p)),
|
||||
safeTxText(p.PartyType),
|
||||
formatTxDate(p.PaymentDate),
|
||||
safeTxText(p.PaymentMethod),
|
||||
safeTxBank(p),
|
||||
safeTxBankAccount(p),
|
||||
incomeAmount,
|
||||
expenseAmount,
|
||||
p.Nominal,
|
||||
safeTxText(p.Notes),
|
||||
safeTxText(txCreatedBy(p)),
|
||||
formatTxStatus(p),
|
||||
}
|
||||
|
||||
for colIdx, val := range values {
|
||||
colName, err := excelize.ColumnNumberToName(colIdx + 1)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, colName+row, val); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func safeTxText(s string) string {
|
||||
trimmed := strings.TrimSpace(s)
|
||||
if trimmed == "" {
|
||||
return "-"
|
||||
}
|
||||
return trimmed
|
||||
}
|
||||
|
||||
func safeTxRefNumber(s *string) string {
|
||||
if s == nil {
|
||||
return "-"
|
||||
}
|
||||
return safeTxText(*s)
|
||||
}
|
||||
|
||||
func safeTxBank(p entity.Payment) string {
|
||||
if p.BankWarehouse.Id == 0 {
|
||||
return "-"
|
||||
}
|
||||
return safeTxText(p.BankWarehouse.Name)
|
||||
}
|
||||
|
||||
func safeTxBankAccount(p entity.Payment) string {
|
||||
if p.BankWarehouse.Id == 0 {
|
||||
return "-"
|
||||
}
|
||||
return safeTxText(p.BankWarehouse.AccountNumber)
|
||||
}
|
||||
|
||||
func formatTxDate(t time.Time) string {
|
||||
if t.IsZero() {
|
||||
return "-"
|
||||
}
|
||||
loc, err := time.LoadLocation("Asia/Jakarta")
|
||||
if err == nil {
|
||||
t = t.In(loc)
|
||||
}
|
||||
return t.Format("02-01-2006")
|
||||
}
|
||||
|
||||
func formatTxStatus(p entity.Payment) string {
|
||||
if p.LatestApproval == nil {
|
||||
return "-"
|
||||
}
|
||||
return safeTxText(p.LatestApproval.StepName)
|
||||
}
|
||||
|
||||
func txTransactionType(p entity.Payment) string {
|
||||
if p.TransactionType != "" {
|
||||
return p.TransactionType
|
||||
}
|
||||
return p.Direction
|
||||
}
|
||||
|
||||
func txPartyName(p entity.Payment) string {
|
||||
switch p.PartyType {
|
||||
case "CUSTOMER":
|
||||
if p.Customer != nil && p.Customer.Id != 0 {
|
||||
return p.Customer.Name
|
||||
}
|
||||
case "SUPPLIER":
|
||||
if p.Supplier != nil && p.Supplier.Id != 0 {
|
||||
return p.Supplier.Name
|
||||
}
|
||||
}
|
||||
return ""
|
||||
}
|
||||
|
||||
func txCreatedBy(p entity.Payment) string {
|
||||
if p.CreatedUser.Id == 0 {
|
||||
return ""
|
||||
}
|
||||
return p.CreatedUser.Name
|
||||
}
|
||||
|
||||
func txAmounts(direction string, nominal float64) (income, expense float64) {
|
||||
switch strings.ToUpper(direction) {
|
||||
case "IN":
|
||||
return nominal, 0
|
||||
case "OUT":
|
||||
return 0, nominal
|
||||
default:
|
||||
return 0, 0
|
||||
}
|
||||
}
|
||||
@@ -10,7 +10,7 @@ type Update struct {
|
||||
|
||||
type Query struct {
|
||||
Page int `query:"page" validate:"omitempty,number,min=1,gt=0"`
|
||||
Limit int `query:"limit" validate:"omitempty,number,min=1,max=100,gt=0"`
|
||||
Limit int `query:"limit" validate:"omitempty,number,min=1,gt=0"`
|
||||
Search string `query:"search" validate:"omitempty,max=50"`
|
||||
TransactionTypes []string `query:"transaction_types" validate:"omitempty,dive,max=50"`
|
||||
BankIDs []uint `query:"bank_ids" validate:"omitempty,dive,gt=0"`
|
||||
|
||||
@@ -2,7 +2,6 @@ package controller
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"math"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -76,9 +75,18 @@ func setMarketingExportColumns(file *excelize.File, sheet string) error {
|
||||
"B": 14,
|
||||
"C": 18,
|
||||
"D": 20,
|
||||
"E": 18,
|
||||
"F": 60,
|
||||
"G": 24,
|
||||
"E": 14,
|
||||
"F": 40,
|
||||
"G": 10,
|
||||
"H": 12,
|
||||
"I": 12,
|
||||
"J": 12,
|
||||
"K": 16,
|
||||
"L": 16,
|
||||
"M": 18,
|
||||
"N": 18,
|
||||
"O": 18,
|
||||
"P": 24,
|
||||
}
|
||||
|
||||
for col, width := range columnWidths {
|
||||
@@ -96,13 +104,22 @@ func setMarketingExportColumns(file *excelize.File, sheet string) error {
|
||||
|
||||
func setMarketingExportHeaders(file *excelize.File, sheet string) error {
|
||||
headers := []string{
|
||||
"No. Order",
|
||||
"Tanggal",
|
||||
"Status",
|
||||
"Customer",
|
||||
"Grand Total",
|
||||
"Products",
|
||||
"Notes",
|
||||
"No. Order", // A
|
||||
"Tanggal", // B
|
||||
"Status", // C
|
||||
"Customer", // D
|
||||
"Tipe", // E
|
||||
"Nama Produk", // F
|
||||
"Week", // G
|
||||
"Jumlah", // H
|
||||
"Satuan", // I
|
||||
"Qty Peti", // J
|
||||
"Berat Rata-rata (kg)", // K
|
||||
"Total Berat (kg)", // L
|
||||
"Harga Satuan", // M
|
||||
"Total Harga", // N
|
||||
"Grand Total", // O
|
||||
"Catatan", // P
|
||||
}
|
||||
|
||||
for i, header := range headers {
|
||||
@@ -131,7 +148,7 @@ func setMarketingExportHeaders(file *excelize.File, sheet string) error {
|
||||
return err
|
||||
}
|
||||
|
||||
return file.SetCellStyle(sheet, "A1", "G1", headerStyle)
|
||||
return file.SetCellStyle(sheet, "A1", "P1", headerStyle)
|
||||
}
|
||||
|
||||
func setMarketingExportRows(file *excelize.File, sheet string, items []dto.MarketingListDTO) error {
|
||||
@@ -139,70 +156,154 @@ func setMarketingExportRows(file *excelize.File, sheet string, items []dto.Marke
|
||||
return nil
|
||||
}
|
||||
|
||||
for i, item := range items {
|
||||
rowNumber := i + 2
|
||||
if err := file.SetCellValue(sheet, "A"+strconv.Itoa(rowNumber), safeMarketingExportText(item.SoNumber)); err != nil {
|
||||
row := 1
|
||||
for _, item := range items {
|
||||
soNumber := safeMarketingExportText(item.SoNumber)
|
||||
soDate := formatMarketingExportDate(item.SoDate)
|
||||
status := formatMarketingExportStatus(item)
|
||||
customer := safeMarketingExportText(item.Customer.Name)
|
||||
grandTotal := sumMarketingGrandTotal(item.SalesOrder)
|
||||
notes := safeMarketingExportText(item.Notes)
|
||||
|
||||
if len(item.SalesOrder) == 0 {
|
||||
row++
|
||||
r := strconv.Itoa(row)
|
||||
vals := map[string]interface{}{
|
||||
"A": soNumber, "B": soDate, "C": status, "D": customer,
|
||||
"E": "-", "F": "-", "G": "-", "H": "-", "I": "-", "J": "-",
|
||||
"K": "-", "L": "-", "M": "-", "N": "-",
|
||||
"O": grandTotal, "P": notes,
|
||||
}
|
||||
for col, val := range vals {
|
||||
if err := file.SetCellValue(sheet, col+r, val); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "B"+strconv.Itoa(rowNumber), formatMarketingExportDate(item.SoDate)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "C"+strconv.Itoa(rowNumber), formatMarketingExportStatus(item)); err != nil {
|
||||
return err
|
||||
continue
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "D"+strconv.Itoa(rowNumber), safeMarketingExportText(item.Customer.Name)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "E"+strconv.Itoa(rowNumber), formatMarketingRupiah(sumMarketingGrandTotal(item.SalesOrder))); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "F"+strconv.Itoa(rowNumber), formatMarketingProducts(item.SalesOrder)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "G"+strconv.Itoa(rowNumber), safeMarketingExportText(item.Notes)); err != nil {
|
||||
return err
|
||||
|
||||
for _, prod := range item.SalesOrder {
|
||||
row++
|
||||
r := strconv.Itoa(row)
|
||||
|
||||
productName := "-"
|
||||
if prod.ProductWarehouse != nil && prod.ProductWarehouse.Product != nil {
|
||||
if n := strings.TrimSpace(prod.ProductWarehouse.Product.Name); n != "" {
|
||||
productName = n
|
||||
}
|
||||
}
|
||||
|
||||
lastRow := len(items) + 1
|
||||
week := "-"
|
||||
if prod.Week != nil {
|
||||
week = strconv.Itoa(*prod.Week)
|
||||
}
|
||||
|
||||
satuan := "-"
|
||||
if prod.ConvertionUnit != nil && strings.TrimSpace(*prod.ConvertionUnit) != "" {
|
||||
satuan = *prod.ConvertionUnit
|
||||
}
|
||||
|
||||
if err := file.SetCellValue(sheet, "A"+r, soNumber); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "B"+r, soDate); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "C"+r, status); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "D"+r, customer); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "E"+r, safeMarketingExportText(prod.MarketingType)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "F"+r, productName); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "G"+r, week); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "H"+r, prod.Qty); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "I"+r, satuan); err != nil {
|
||||
return err
|
||||
}
|
||||
if prod.TotalPeti != nil {
|
||||
if err := file.SetCellValue(sheet, "J"+r, *prod.TotalPeti); err != nil {
|
||||
return err
|
||||
}
|
||||
} else {
|
||||
if err := file.SetCellValue(sheet, "J"+r, "-"); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "K"+r, prod.AvgWeight); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "L"+r, prod.TotalWeight); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "M"+r, prod.UnitPrice); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "N"+r, prod.TotalPrice); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "O"+r, grandTotal); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "P"+r, notes); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
lastRow := row
|
||||
lastRowStr := strconv.Itoa(lastRow)
|
||||
border := []excelize.Border{
|
||||
{Type: "left", Color: "D1D5DB", Style: 1},
|
||||
{Type: "top", Color: "D1D5DB", Style: 1},
|
||||
{Type: "bottom", Color: "D1D5DB", Style: 1},
|
||||
{Type: "right", Color: "D1D5DB", Style: 1},
|
||||
}
|
||||
|
||||
dataStyle, err := file.NewStyle(&excelize.Style{
|
||||
Alignment: &excelize.Alignment{
|
||||
Horizontal: "left",
|
||||
Vertical: "center",
|
||||
WrapText: true,
|
||||
},
|
||||
Border: []excelize.Border{
|
||||
{Type: "left", Color: "D1D5DB", Style: 1},
|
||||
{Type: "top", Color: "D1D5DB", Style: 1},
|
||||
{Type: "bottom", Color: "D1D5DB", Style: 1},
|
||||
{Type: "right", Color: "D1D5DB", Style: 1},
|
||||
},
|
||||
Alignment: &excelize.Alignment{Horizontal: "left", Vertical: "center", WrapText: true},
|
||||
Border: border,
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := file.SetCellStyle(sheet, "A2", "G"+strconv.Itoa(lastRow), dataStyle); err != nil {
|
||||
if err := file.SetCellStyle(sheet, "A2", "P"+lastRowStr, dataStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
moneyStyle, err := file.NewStyle(&excelize.Style{
|
||||
Alignment: &excelize.Alignment{
|
||||
Horizontal: "right",
|
||||
Vertical: "center",
|
||||
},
|
||||
Border: []excelize.Border{
|
||||
{Type: "left", Color: "D1D5DB", Style: 1},
|
||||
{Type: "top", Color: "D1D5DB", Style: 1},
|
||||
{Type: "bottom", Color: "D1D5DB", Style: 1},
|
||||
{Type: "right", Color: "D1D5DB", Style: 1},
|
||||
},
|
||||
numberStyle, err := file.NewStyle(&excelize.Style{
|
||||
Alignment: &excelize.Alignment{Horizontal: "right", Vertical: "center"},
|
||||
Border: border,
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "K2", "O"+lastRowStr, numberStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return file.SetCellStyle(sheet, "E2", "E"+strconv.Itoa(lastRow), moneyStyle)
|
||||
centerStyle, err := file.NewStyle(&excelize.Style{
|
||||
Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"},
|
||||
Border: border,
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
for _, col := range []string{"G", "H", "J"} {
|
||||
if err := file.SetCellStyle(sheet, col+"2", col+lastRowStr, centerStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func formatMarketingExportDate(value time.Time) string {
|
||||
@@ -226,36 +327,6 @@ func formatMarketingExportStatus(item dto.MarketingListDTO) string {
|
||||
return safeMarketingExportText(item.LatestApproval.StepName)
|
||||
}
|
||||
|
||||
func formatMarketingProducts(items []dto.DeliveryMarketingProductDTO) string {
|
||||
if len(items) == 0 {
|
||||
return "-"
|
||||
}
|
||||
|
||||
seen := make(map[string]struct{})
|
||||
names := make([]string, 0, len(items))
|
||||
for _, item := range items {
|
||||
if item.ProductWarehouse == nil || item.ProductWarehouse.Product == nil {
|
||||
continue
|
||||
}
|
||||
|
||||
name := strings.TrimSpace(item.ProductWarehouse.Product.Name)
|
||||
if name == "" {
|
||||
continue
|
||||
}
|
||||
|
||||
if _, exists := seen[name]; exists {
|
||||
continue
|
||||
}
|
||||
seen[name] = struct{}{}
|
||||
names = append(names, name)
|
||||
}
|
||||
|
||||
if len(names) == 0 {
|
||||
return "-"
|
||||
}
|
||||
|
||||
return strings.Join(names, ", ")
|
||||
}
|
||||
|
||||
func sumMarketingGrandTotal(items []dto.DeliveryMarketingProductDTO) float64 {
|
||||
total := 0.0
|
||||
@@ -266,40 +337,6 @@ func sumMarketingGrandTotal(items []dto.DeliveryMarketingProductDTO) float64 {
|
||||
return total
|
||||
}
|
||||
|
||||
func formatMarketingRupiah(value float64) string {
|
||||
if math.IsNaN(value) || math.IsInf(value, 0) {
|
||||
return "Rp 0"
|
||||
}
|
||||
|
||||
rounded := int64(math.Round(value))
|
||||
sign := ""
|
||||
if rounded < 0 {
|
||||
sign = "-"
|
||||
rounded = -rounded
|
||||
}
|
||||
|
||||
raw := strconv.FormatInt(rounded, 10)
|
||||
if raw == "" {
|
||||
raw = "0"
|
||||
}
|
||||
|
||||
var grouped strings.Builder
|
||||
rem := len(raw) % 3
|
||||
if rem > 0 {
|
||||
grouped.WriteString(raw[:rem])
|
||||
if len(raw) > rem {
|
||||
grouped.WriteString(".")
|
||||
}
|
||||
}
|
||||
for i := rem; i < len(raw); i += 3 {
|
||||
grouped.WriteString(raw[i : i+3])
|
||||
if i+3 < len(raw) {
|
||||
grouped.WriteString(".")
|
||||
}
|
||||
}
|
||||
|
||||
return "Rp " + sign + grouped.String()
|
||||
}
|
||||
|
||||
func safeMarketingExportText(value string) string {
|
||||
trimmed := strings.TrimSpace(value)
|
||||
|
||||
@@ -29,6 +29,7 @@ type MarketingListDTO struct {
|
||||
SalesPerson userDTO.UserRelationDTO `json:"sales_person"`
|
||||
SoDocs string `json:"so_docs"`
|
||||
SalesOrder []DeliveryMarketingProductDTO `json:"sales_order"`
|
||||
DeliveryOrder []DeliveryGroupDTO `json:"delivery_order"`
|
||||
CreatedUser userDTO.UserRelationDTO `json:"created_user"`
|
||||
CreatedAt time.Time `json:"created_at"`
|
||||
UpdatedAt time.Time `json:"updated_at"`
|
||||
@@ -203,6 +204,7 @@ func ToMarketingListDTO(marketing *entity.Marketing, deliveryProducts []entity.M
|
||||
SalesPerson: salesPerson,
|
||||
SoDocs: marketing.SoDocs,
|
||||
SalesOrder: salesOrderProducts,
|
||||
DeliveryOrder: extractDeliveryGroupsFromProducts(marketing),
|
||||
CreatedUser: createdUser,
|
||||
CreatedAt: marketing.CreatedAt,
|
||||
UpdatedAt: marketing.UpdatedAt,
|
||||
@@ -376,6 +378,23 @@ func GenerateDeliveryOrderNumber(soNumber string, deliveryDate *time.Time, wareh
|
||||
return numberPrefix
|
||||
}
|
||||
|
||||
func extractDeliveryGroupsFromProducts(marketing *entity.Marketing) []DeliveryGroupDTO {
|
||||
var dps []MarketingDeliveryProductDTO
|
||||
for _, product := range marketing.Products {
|
||||
if product.DeliveryProduct == nil || product.DeliveryProduct.DeliveryDate == nil {
|
||||
continue
|
||||
}
|
||||
dp := ToMarketingDeliveryProductDTO(*product.DeliveryProduct)
|
||||
if product.ProductWarehouse.Id != 0 {
|
||||
mapped := productwarehouseDTO.ToProductWarehouseNestedDTO(product.ProductWarehouse)
|
||||
dp.ProductWarehouse = &mapped
|
||||
}
|
||||
dp.ConvertionUnit = product.ConvertionUnit
|
||||
dps = append(dps, dp)
|
||||
}
|
||||
return groupDeliveryProducts(dps, marketing.SoNumber)
|
||||
}
|
||||
|
||||
func collectDoNumbers(marketing *entity.Marketing) []string {
|
||||
if marketing == nil || len(marketing.Products) == 0 {
|
||||
return nil
|
||||
|
||||
@@ -91,11 +91,9 @@ func buildPurchaseQuery(c *fiber.Ctx) *validation.Query {
|
||||
Limit: c.QueryInt("limit", 10),
|
||||
Search: strings.TrimSpace(c.Query("search")),
|
||||
ApprovalStatus: strings.TrimSpace(c.Query("approval_status")),
|
||||
PoDate: strings.TrimSpace(c.Query("po_date")),
|
||||
PoDateFrom: strings.TrimSpace(c.Query("po_date_from")),
|
||||
PoDateTo: strings.TrimSpace(c.Query("po_date_to")),
|
||||
CreatedFrom: strings.TrimSpace(c.Query("created_from")),
|
||||
CreatedTo: strings.TrimSpace(c.Query("created_to")),
|
||||
StartDate: strings.TrimSpace(c.Query("start_date")),
|
||||
EndDate: strings.TrimSpace(c.Query("end_date")),
|
||||
FilterBy: strings.TrimSpace(c.Query("filter_by")),
|
||||
SupplierID: uint(c.QueryInt("supplier_id", 0)),
|
||||
AreaID: uint(c.QueryInt("area_id", 0)),
|
||||
LocationID: uint(c.QueryInt("location_id", 0)),
|
||||
|
||||
@@ -2,7 +2,6 @@ package controller
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"math"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -43,15 +42,13 @@ func buildPurchaseExportWorkbook(purchases []entity.Purchase) ([]byte, error) {
|
||||
}
|
||||
}
|
||||
|
||||
grandTotals := buildPurchaseGrandTotalMap(purchases)
|
||||
|
||||
if err := setPurchaseExportColumns(file, purchaseExportSheetName); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := setPurchaseExportHeaders(file, purchaseExportSheetName); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := setPurchaseExportRows(file, purchaseExportSheetName, purchases, grandTotals); err != nil {
|
||||
if err := setPurchaseExportRows(file, purchaseExportSheetName, purchases); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := file.SetPanes(purchaseExportSheetName, &excelize.Panes{
|
||||
@@ -80,9 +77,17 @@ func setPurchaseExportColumns(file *excelize.File, sheet string) error {
|
||||
"F": 22,
|
||||
"G": 22,
|
||||
"H": 32,
|
||||
"I": 18,
|
||||
"J": 18,
|
||||
"K": 24,
|
||||
"I": 10,
|
||||
"J": 12,
|
||||
"K": 16,
|
||||
"L": 16,
|
||||
"M": 22,
|
||||
"N": 12,
|
||||
"O": 16,
|
||||
"P": 16,
|
||||
"Q": 18,
|
||||
"R": 18,
|
||||
"S": 24,
|
||||
}
|
||||
|
||||
for col, width := range columnWidths {
|
||||
@@ -99,17 +104,25 @@ func setPurchaseExportColumns(file *excelize.File, sheet string) error {
|
||||
|
||||
func setPurchaseExportHeaders(file *excelize.File, sheet string) error {
|
||||
headers := []string{
|
||||
"PR Number",
|
||||
"PO Number",
|
||||
"Tanggal PO",
|
||||
"Tanggal Terima",
|
||||
"Supplier",
|
||||
"Lokasi",
|
||||
"Gudang",
|
||||
"Product",
|
||||
"Status",
|
||||
"Grand Total",
|
||||
"Notes",
|
||||
"PR Number", // A
|
||||
"PO Number", // B
|
||||
"Tanggal PO", // C
|
||||
"Tanggal Terima", // D
|
||||
"Supplier", // E
|
||||
"Lokasi", // F
|
||||
"Gudang", // G
|
||||
"Product", // H
|
||||
"Qty", // I
|
||||
"Satuan", // J
|
||||
"Price", // K
|
||||
"Total Produk", // L
|
||||
"Vendor Ekspedisi",// M
|
||||
"Qty Ekspedisi", // N
|
||||
"Price Ekspedisi", // O
|
||||
"Total Ekspedisi", // P
|
||||
"Grand Total All", // Q
|
||||
"Status", // R
|
||||
"Notes", // S
|
||||
}
|
||||
|
||||
for i, header := range headers {
|
||||
@@ -137,34 +150,36 @@ func setPurchaseExportHeaders(file *excelize.File, sheet string) error {
|
||||
return err
|
||||
}
|
||||
|
||||
return file.SetCellStyle(sheet, "A1", "K1", headerStyle)
|
||||
return file.SetCellStyle(sheet, "A1", "S1", headerStyle)
|
||||
}
|
||||
|
||||
func setPurchaseExportRows(file *excelize.File, sheet string, purchases []entity.Purchase, grandTotals map[uint]float64) error {
|
||||
func setPurchaseExportRows(file *excelize.File, sheet string, purchases []entity.Purchase) error {
|
||||
if len(purchases) == 0 {
|
||||
return nil
|
||||
}
|
||||
|
||||
var sumL, sumP, sumQ float64
|
||||
|
||||
rowIdx := 2
|
||||
for p := range purchases {
|
||||
purchase := &purchases[p]
|
||||
total := grandTotals[purchase.Id]
|
||||
if len(purchase.Items) == 0 {
|
||||
if err := writePurchaseExportRow(file, sheet, rowIdx, purchase, nil, total); err != nil {
|
||||
if err := writePurchaseExportRow(file, sheet, rowIdx, purchase, nil, &sumL, &sumP, &sumQ); err != nil {
|
||||
return err
|
||||
}
|
||||
rowIdx++
|
||||
continue
|
||||
}
|
||||
for it := range purchase.Items {
|
||||
if err := writePurchaseExportRow(file, sheet, rowIdx, purchase, &purchase.Items[it], total); err != nil {
|
||||
if err := writePurchaseExportRow(file, sheet, rowIdx, purchase, &purchase.Items[it], &sumL, &sumP, &sumQ); err != nil {
|
||||
return err
|
||||
}
|
||||
rowIdx++
|
||||
}
|
||||
}
|
||||
|
||||
lastRow := rowIdx - 1
|
||||
lastDataRow := rowIdx - 1
|
||||
|
||||
dataStyle, err := file.NewStyle(&excelize.Style{
|
||||
Alignment: &excelize.Alignment{
|
||||
Horizontal: "left",
|
||||
@@ -181,7 +196,7 @@ func setPurchaseExportRows(file *excelize.File, sheet string, purchases []entity
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "A2", "K"+strconv.Itoa(lastRow), dataStyle); err != nil {
|
||||
if err := file.SetCellStyle(sheet, "A2", "S"+strconv.Itoa(lastDataRow), dataStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
@@ -200,14 +215,17 @@ func setPurchaseExportRows(file *excelize.File, sheet string, purchases []entity
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "K2", "Q"+strconv.Itoa(lastDataRow), moneyStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return file.SetCellStyle(sheet, "J2", "J"+strconv.Itoa(lastRow), moneyStyle)
|
||||
return addPurchaseExportSumRow(file, sheet, rowIdx, sumL, sumP, sumQ)
|
||||
}
|
||||
|
||||
func writePurchaseExportRow(file *excelize.File, sheet string, rowIdx int, purchase *entity.Purchase, item *entity.PurchaseItem, grandTotal float64) error {
|
||||
func writePurchaseExportRow(file *excelize.File, sheet string, rowIdx int, purchase *entity.Purchase, item *entity.PurchaseItem, sumL, sumP, sumQ *float64) error {
|
||||
row := strconv.Itoa(rowIdx)
|
||||
|
||||
// Purchase-level columns (repeat across rows of the same purchase)
|
||||
// Purchase-level columns (repeat for every item row of the same purchase)
|
||||
if err := file.SetCellValue(sheet, "A"+row, safePurchaseExportText(purchase.PrNumber)); err != nil {
|
||||
return err
|
||||
}
|
||||
@@ -220,26 +238,40 @@ func writePurchaseExportRow(file *excelize.File, sheet string, rowIdx int, purch
|
||||
if err := file.SetCellValue(sheet, "E"+row, safePurchaseExportEntitySupplierName(purchase)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "I"+row, formatPurchaseExportEntityStatus(purchase)); err != nil {
|
||||
if err := file.SetCellValue(sheet, "R"+row, formatPurchaseExportEntityStatus(purchase)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "J"+row, formatPurchaseRupiah(grandTotal)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "K"+row, safePurchaseExportPointerText(purchase.Notes)); err != nil {
|
||||
if err := file.SetCellValue(sheet, "S"+row, safePurchaseExportPointerText(purchase.Notes)); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// Item-level columns
|
||||
if item == nil {
|
||||
for _, col := range []string{"D", "F", "G", "H"} {
|
||||
for _, col := range []string{"D", "F", "G", "H", "J", "M"} {
|
||||
if err := file.SetCellValue(sheet, col+row, "-"); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
for _, col := range []string{"I", "K", "L", "N", "O", "P", "Q"} {
|
||||
if err := file.SetCellValue(sheet, col+row, 0); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// Item-level columns
|
||||
var expeditionQty, expeditionPrice, expeditionTotal float64
|
||||
if item.ExpenseNonstock != nil {
|
||||
expeditionQty = item.ExpenseNonstock.Qty
|
||||
expeditionPrice = item.ExpenseNonstock.Price
|
||||
expeditionTotal = expeditionQty * expeditionPrice
|
||||
}
|
||||
itemGrandTotal := item.TotalPrice + expeditionTotal
|
||||
|
||||
*sumL += item.TotalPrice
|
||||
*sumP += expeditionTotal
|
||||
*sumQ += itemGrandTotal
|
||||
|
||||
if err := file.SetCellValue(sheet, "D"+row, formatPurchaseExportDate(item.ReceivedDate)); err != nil {
|
||||
return err
|
||||
}
|
||||
@@ -252,20 +284,96 @@ func writePurchaseExportRow(file *excelize.File, sheet string, rowIdx int, purch
|
||||
if err := file.SetCellValue(sheet, "H"+row, safePurchaseItemProductName(item)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "I"+row, item.TotalQty); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "J"+row, safePurchaseItemUomName(item)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "K"+row, item.Price); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "L"+row, item.TotalPrice); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "M"+row, safePurchaseItemExpeditionVendorName(item)); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "N"+row, expeditionQty); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "O"+row, expeditionPrice); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "P"+row, expeditionTotal); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "Q"+row, itemGrandTotal); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func buildPurchaseGrandTotalMap(items []entity.Purchase) map[uint]float64 {
|
||||
result := make(map[uint]float64, len(items))
|
||||
for i := range items {
|
||||
total := 0.0
|
||||
for j := range items[i].Items {
|
||||
total += items[i].Items[j].TotalPrice
|
||||
func addPurchaseExportSumRow(file *excelize.File, sheet string, rowIdx int, sumL, sumP, sumQ float64) error {
|
||||
row := strconv.Itoa(rowIdx)
|
||||
|
||||
sumStyle, err := file.NewStyle(&excelize.Style{
|
||||
Font: &excelize.Font{Bold: true, Color: "1F2937"},
|
||||
Fill: excelize.Fill{Type: "pattern", Pattern: 1, Color: []string{"FEF3C7"}},
|
||||
Alignment: &excelize.Alignment{
|
||||
Horizontal: "left",
|
||||
Vertical: "center",
|
||||
},
|
||||
Border: []excelize.Border{
|
||||
{Type: "left", Color: "D1D5DB", Style: 1},
|
||||
{Type: "top", Color: "D1D5DB", Style: 2},
|
||||
{Type: "bottom", Color: "D1D5DB", Style: 1},
|
||||
{Type: "right", Color: "D1D5DB", Style: 1},
|
||||
},
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
result[items[i].Id] = total
|
||||
|
||||
sumMoneyStyle, err := file.NewStyle(&excelize.Style{
|
||||
Font: &excelize.Font{Bold: true, Color: "1F2937"},
|
||||
Fill: excelize.Fill{Type: "pattern", Pattern: 1, Color: []string{"FEF3C7"}},
|
||||
Alignment: &excelize.Alignment{
|
||||
Horizontal: "right",
|
||||
Vertical: "center",
|
||||
},
|
||||
Border: []excelize.Border{
|
||||
{Type: "left", Color: "D1D5DB", Style: 1},
|
||||
{Type: "top", Color: "D1D5DB", Style: 2},
|
||||
{Type: "bottom", Color: "D1D5DB", Style: 1},
|
||||
{Type: "right", Color: "D1D5DB", Style: 1},
|
||||
},
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return result
|
||||
|
||||
if err := file.SetCellStyle(sheet, "A"+row, "S"+row, sumStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "L"+row, "L"+row, sumMoneyStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "P"+row, "Q"+row, sumMoneyStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := file.SetCellValue(sheet, "A"+row, "TOTAL"); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "L"+row, sumL); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "P"+row, sumP); err != nil {
|
||||
return err
|
||||
}
|
||||
return file.SetCellValue(sheet, "Q"+row, sumQ)
|
||||
}
|
||||
|
||||
func safePurchaseExportEntitySupplierName(purchase *entity.Purchase) string {
|
||||
@@ -296,6 +404,24 @@ func safePurchaseItemProductName(item *entity.PurchaseItem) string {
|
||||
return safePurchaseExportText(item.Product.Name)
|
||||
}
|
||||
|
||||
func safePurchaseItemUomName(item *entity.PurchaseItem) string {
|
||||
if item.Product == nil || item.Product.Uom.Id == 0 {
|
||||
return "-"
|
||||
}
|
||||
return safePurchaseExportText(item.Product.Uom.Name)
|
||||
}
|
||||
|
||||
func safePurchaseItemExpeditionVendorName(item *entity.PurchaseItem) string {
|
||||
if item.ExpenseNonstock == nil || item.ExpenseNonstock.Expense == nil {
|
||||
return "-"
|
||||
}
|
||||
exp := item.ExpenseNonstock.Expense
|
||||
if exp.Supplier == nil || exp.Supplier.Id == 0 {
|
||||
return "-"
|
||||
}
|
||||
return safePurchaseExportText(exp.Supplier.Name)
|
||||
}
|
||||
|
||||
func formatPurchaseExportEntityStatus(purchase *entity.Purchase) string {
|
||||
if purchase.LatestApproval == nil {
|
||||
return "-"
|
||||
@@ -309,6 +435,21 @@ func formatPurchaseExportEntityStatus(purchase *entity.Purchase) string {
|
||||
return safePurchaseExportText(purchase.LatestApproval.StepName)
|
||||
}
|
||||
|
||||
var purchaseIndonesianMonths = map[time.Month]string{
|
||||
time.January: "Jan",
|
||||
time.February: "Feb",
|
||||
time.March: "Mar",
|
||||
time.April: "Apr",
|
||||
time.May: "Mei",
|
||||
time.June: "Jun",
|
||||
time.July: "Jul",
|
||||
time.August: "Ags",
|
||||
time.September: "Sep",
|
||||
time.October: "Okt",
|
||||
time.November: "Nov",
|
||||
time.December: "Des",
|
||||
}
|
||||
|
||||
func formatPurchaseExportDate(value *time.Time) string {
|
||||
if value == nil || value.IsZero() {
|
||||
return "-"
|
||||
@@ -320,7 +461,8 @@ func formatPurchaseExportDate(value *time.Time) string {
|
||||
t = t.In(location)
|
||||
}
|
||||
|
||||
return t.Format("02-01-2006")
|
||||
month := purchaseIndonesianMonths[t.Month()]
|
||||
return fmt.Sprintf("%d-%s-%02d", t.Day(), month, t.Year()%100)
|
||||
}
|
||||
|
||||
func safePurchaseExportPointerText(value *string) string {
|
||||
@@ -338,37 +480,3 @@ func safePurchaseExportText(value string) string {
|
||||
return trimmed
|
||||
}
|
||||
|
||||
func formatPurchaseRupiah(value float64) string {
|
||||
if math.IsNaN(value) || math.IsInf(value, 0) {
|
||||
return "Rp 0"
|
||||
}
|
||||
|
||||
rounded := int64(math.Round(value))
|
||||
sign := ""
|
||||
if rounded < 0 {
|
||||
sign = "-"
|
||||
rounded = -rounded
|
||||
}
|
||||
|
||||
raw := strconv.FormatInt(rounded, 10)
|
||||
if raw == "" {
|
||||
raw = "0"
|
||||
}
|
||||
|
||||
var grouped strings.Builder
|
||||
rem := len(raw) % 3
|
||||
if rem > 0 {
|
||||
grouped.WriteString(raw[:rem])
|
||||
if len(raw) > rem {
|
||||
grouped.WriteString(".")
|
||||
}
|
||||
}
|
||||
for i := rem; i < len(raw); i += 3 {
|
||||
grouped.WriteString(raw[i : i+3])
|
||||
if i+3 < len(raw) {
|
||||
grouped.WriteString(".")
|
||||
}
|
||||
}
|
||||
|
||||
return "Rp " + sign + grouped.String()
|
||||
}
|
||||
|
||||
@@ -22,9 +22,8 @@ func TestBuildPurchaseExportWorkbookHeadersAndRows(t *testing.T) {
|
||||
nil,
|
||||
"catatan",
|
||||
[]entity.PurchaseItem{
|
||||
buildPurchaseItemForExportTest(11, "Pakan Starter", 1000000, "Location A"),
|
||||
buildPurchaseItemForExportTest(12, "Vitamin A", 350000, "Location B"),
|
||||
buildPurchaseItemForExportTest(11, "Pakan Starter", 0, ""),
|
||||
buildPurchaseItemForExportTest(11, "Pakan Starter", 500, 2, 1000000, "Location A", "kg"),
|
||||
buildPurchaseItemForExportTest(12, "Vitamin A", 350, 1, 350000, "Location B", "botol"),
|
||||
},
|
||||
),
|
||||
buildPurchaseForExportTest(
|
||||
@@ -37,7 +36,7 @@ func TestBuildPurchaseExportWorkbookHeadersAndRows(t *testing.T) {
|
||||
ptrApprovalAction(entity.ApprovalActionRejected),
|
||||
"",
|
||||
[]entity.PurchaseItem{
|
||||
buildPurchaseItemForExportTest(21, "Obat X", 75000, ""),
|
||||
buildPurchaseItemForExportTest(21, "Obat X", 75000, 1, 75000, "", ""),
|
||||
},
|
||||
),
|
||||
})
|
||||
@@ -51,16 +50,27 @@ func TestBuildPurchaseExportWorkbookHeadersAndRows(t *testing.T) {
|
||||
}
|
||||
defer file.Close()
|
||||
|
||||
// Verify all 19 headers
|
||||
expectedHeaders := map[string]string{
|
||||
"A1": "PR Number",
|
||||
"B1": "PO Number",
|
||||
"C1": "Tanggal PO",
|
||||
"D1": "Supplier",
|
||||
"E1": "Lokasi",
|
||||
"F1": "Status",
|
||||
"G1": "Grand Total",
|
||||
"H1": "Products",
|
||||
"I1": "Notes",
|
||||
"D1": "Tanggal Terima",
|
||||
"E1": "Supplier",
|
||||
"F1": "Lokasi",
|
||||
"G1": "Gudang",
|
||||
"H1": "Product",
|
||||
"I1": "Qty",
|
||||
"J1": "Satuan",
|
||||
"K1": "Price",
|
||||
"L1": "Total Produk",
|
||||
"M1": "Vendor Ekspedisi",
|
||||
"N1": "Qty Ekspedisi",
|
||||
"O1": "Price Ekspedisi",
|
||||
"P1": "Total Ekspedisi",
|
||||
"Q1": "Grand Total All",
|
||||
"R1": "Status",
|
||||
"S1": "Notes",
|
||||
}
|
||||
for cell, expected := range expectedHeaders {
|
||||
got, err := file.GetCellValue(purchaseExportSheetName, cell)
|
||||
@@ -72,24 +82,46 @@ func TestBuildPurchaseExportWorkbookHeadersAndRows(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
// Row 2: Purchase 1, Item 1 (Pakan Starter)
|
||||
assertPurchaseCellEquals(t, file, "A2", "PR-00011")
|
||||
assertPurchaseCellEquals(t, file, "B2", "PO-00011")
|
||||
assertPurchaseCellEquals(t, file, "C2", "22-04-2026")
|
||||
assertPurchaseCellEquals(t, file, "D2", "Supplier A")
|
||||
assertPurchaseCellEquals(t, file, "E2", "Location A")
|
||||
assertPurchaseCellEquals(t, file, "F2", "Manager Purchase")
|
||||
assertPurchaseCellEquals(t, file, "G2", "Rp 1.350.000")
|
||||
assertPurchaseCellEquals(t, file, "H2", "Pakan Starter, Vitamin A")
|
||||
assertPurchaseCellEquals(t, file, "I2", "catatan")
|
||||
assertPurchaseCellEquals(t, file, "E2", "Supplier A")
|
||||
assertPurchaseCellEquals(t, file, "F2", "Location A")
|
||||
assertPurchaseCellEquals(t, file, "H2", "Pakan Starter")
|
||||
assertPurchaseCellEquals(t, file, "J2", "kg")
|
||||
assertPurchaseCellEquals(t, file, "K2", "500")
|
||||
assertPurchaseCellEquals(t, file, "L2", "1000000")
|
||||
assertPurchaseCellEquals(t, file, "M2", "-")
|
||||
assertPurchaseCellEquals(t, file, "P2", "0")
|
||||
assertPurchaseCellEquals(t, file, "Q2", "1000000")
|
||||
assertPurchaseCellEquals(t, file, "R2", "Manager Purchase")
|
||||
assertPurchaseCellEquals(t, file, "S2", "catatan")
|
||||
|
||||
assertPurchaseCellEquals(t, file, "A3", "PR-00012")
|
||||
assertPurchaseCellEquals(t, file, "B3", "-")
|
||||
assertPurchaseCellEquals(t, file, "C3", "-")
|
||||
assertPurchaseCellEquals(t, file, "E3", "-")
|
||||
assertPurchaseCellEquals(t, file, "F3", "Ditolak")
|
||||
assertPurchaseCellEquals(t, file, "G3", "Rp 75.000")
|
||||
assertPurchaseCellEquals(t, file, "H3", "Obat X")
|
||||
assertPurchaseCellEquals(t, file, "I3", "-")
|
||||
// Row 3: Purchase 1, Item 2 (Vitamin A)
|
||||
assertPurchaseCellEquals(t, file, "A3", "PR-00011")
|
||||
assertPurchaseCellEquals(t, file, "H3", "Vitamin A")
|
||||
assertPurchaseCellEquals(t, file, "J3", "botol")
|
||||
assertPurchaseCellEquals(t, file, "L3", "350000")
|
||||
assertPurchaseCellEquals(t, file, "Q3", "350000")
|
||||
|
||||
// Row 4: Purchase 2, Item 1 (Obat X) — no location, rejected
|
||||
assertPurchaseCellEquals(t, file, "A4", "PR-00012")
|
||||
assertPurchaseCellEquals(t, file, "B4", "-")
|
||||
assertPurchaseCellEquals(t, file, "C4", "-")
|
||||
assertPurchaseCellEquals(t, file, "F4", "-")
|
||||
assertPurchaseCellEquals(t, file, "H4", "Obat X")
|
||||
assertPurchaseCellEquals(t, file, "J4", "-")
|
||||
assertPurchaseCellEquals(t, file, "L4", "75000")
|
||||
assertPurchaseCellEquals(t, file, "Q4", "75000")
|
||||
assertPurchaseCellEquals(t, file, "R4", "Ditolak")
|
||||
assertPurchaseCellEquals(t, file, "S4", "-")
|
||||
|
||||
// Row 5: SUM row — total produk=1425000, ekspedisi=0, grand total all=1425000
|
||||
assertPurchaseCellEquals(t, file, "A5", "TOTAL")
|
||||
assertPurchaseCellEquals(t, file, "L5", "1425000")
|
||||
assertPurchaseCellEquals(t, file, "P5", "0")
|
||||
assertPurchaseCellEquals(t, file, "Q5", "1425000")
|
||||
}
|
||||
|
||||
func assertPurchaseCellEquals(t *testing.T, file *excelize.File, cell, expected string) {
|
||||
@@ -144,13 +176,20 @@ func buildPurchaseForExportTest(
|
||||
}
|
||||
}
|
||||
|
||||
func buildPurchaseItemForExportTest(productID uint, productName string, totalPrice float64, locationName string) entity.PurchaseItem {
|
||||
func buildPurchaseItemForExportTest(productID uint, productName string, price, totalQty, totalPrice float64, locationName, uomName string) entity.PurchaseItem {
|
||||
uomID := uint(0)
|
||||
if uomName != "" {
|
||||
uomID = productID + 2000
|
||||
}
|
||||
item := entity.PurchaseItem{
|
||||
ProductId: productID,
|
||||
Price: price,
|
||||
TotalQty: totalQty,
|
||||
TotalPrice: totalPrice,
|
||||
Product: &entity.Product{
|
||||
Id: productID,
|
||||
Name: productName,
|
||||
Uom: entity.Uom{Id: uomID, Name: uomName},
|
||||
},
|
||||
}
|
||||
|
||||
|
||||
@@ -38,6 +38,9 @@ type PurchaseListDTO struct {
|
||||
CreatedAt time.Time `json:"created_at"`
|
||||
UpdatedAt time.Time `json:"updated_at"`
|
||||
LatestApproval *approvalDTO.ApprovalRelationDTO `json:"latest_approval"`
|
||||
ProductsTotal float64 `json:"products_total"`
|
||||
ExpeditionTotal float64 `json:"expedition_total"`
|
||||
GrandTotalAll float64 `json:"grand_total_all"`
|
||||
}
|
||||
|
||||
type PurchaseDetailDTO struct {
|
||||
@@ -69,6 +72,8 @@ type PurchaseItemDTO struct {
|
||||
VehicleNumber *string `json:"vehicle_number"`
|
||||
TransportPerItem *float64 `json:"transport_per_item,omitempty"`
|
||||
ExpeditionVendor *supplierDTO.SupplierRelationDTO `json:"expedition_vendor,omitempty"`
|
||||
ExpeditionQty float64 `json:"expedition_qty"`
|
||||
ExpeditionTotal float64 `json:"expedition_total"`
|
||||
HasChickin bool `json:"has_chickin"`
|
||||
}
|
||||
|
||||
@@ -127,6 +132,8 @@ func ToPurchaseItemDTO(item entity.PurchaseItem) PurchaseItemDTO {
|
||||
if item.ExpenseNonstock != nil {
|
||||
priceCopy := item.ExpenseNonstock.Price
|
||||
dto.TransportPerItem = &priceCopy
|
||||
dto.ExpeditionQty = item.ExpenseNonstock.Qty
|
||||
dto.ExpeditionTotal = item.ExpenseNonstock.Qty * item.ExpenseNonstock.Price
|
||||
|
||||
if item.ExpenseNonstock.Expense != nil {
|
||||
exp := item.ExpenseNonstock.Expense
|
||||
@@ -177,11 +184,17 @@ func ToPurchaseListDTO(p entity.Purchase) PurchaseListDTO {
|
||||
location *locationDTO.LocationRelationDTO
|
||||
area *areaDTO.AreaRelationDTO
|
||||
receivedDate *time.Time
|
||||
productsTotal float64
|
||||
expeditionTotal float64
|
||||
)
|
||||
productMap := make(map[uint]productDTO.ProductRelationDTO)
|
||||
expeditionRefSet := make(map[uint64]struct{})
|
||||
for i := range p.Items {
|
||||
item := p.Items[i]
|
||||
productsTotal += item.TotalPrice
|
||||
if item.ExpenseNonstock != nil {
|
||||
expeditionTotal += item.ExpenseNonstock.Qty * item.ExpenseNonstock.Price
|
||||
}
|
||||
if item.Product != nil && item.Product.Id != 0 {
|
||||
if _, exists := productMap[item.Product.Id]; !exists {
|
||||
productMap[item.Product.Id] = productDTO.ToProductRelationDTO(*item.Product)
|
||||
@@ -235,6 +248,9 @@ func ToPurchaseListDTO(p entity.Purchase) PurchaseListDTO {
|
||||
CreatedAt: p.CreatedAt,
|
||||
UpdatedAt: p.UpdatedAt,
|
||||
LatestApproval: latestApproval,
|
||||
ProductsTotal: productsTotal,
|
||||
ExpeditionTotal: expeditionTotal,
|
||||
GrandTotalAll: productsTotal + expeditionTotal,
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -145,33 +145,16 @@ func (s *purchaseService) GetAll(c *fiber.Ctx, params *validation.Query) ([]enti
|
||||
|
||||
offset := (params.Page - 1) * params.Limit
|
||||
|
||||
createdFrom, createdTo, err := utils.ParseDateRangeForQuery(params.CreatedFrom, params.CreatedTo)
|
||||
if err != nil {
|
||||
return nil, 0, utils.BadRequest(err.Error())
|
||||
}
|
||||
|
||||
productCategoryIDs, err := parseUintCSVFilter(params.ProductCategoryID, "product_category_id")
|
||||
if err != nil {
|
||||
return nil, 0, utils.BadRequest(err.Error())
|
||||
}
|
||||
|
||||
var poDateStart *time.Time
|
||||
var poDateEnd *time.Time
|
||||
|
||||
if strings.TrimSpace(params.PoDate) != "" {
|
||||
poDate, parseErr := utils.ParseDateString(strings.TrimSpace(params.PoDate))
|
||||
if parseErr != nil {
|
||||
return nil, 0, utils.BadRequest("po_date must use format YYYY-MM-DD")
|
||||
}
|
||||
poDateStart = &poDate
|
||||
poDateEndValue := poDate.AddDate(0, 0, 1)
|
||||
poDateEnd = &poDateEndValue
|
||||
} else {
|
||||
poDateStart, poDateEnd, err = parsePoDateRangeForQuery(params.PoDateFrom, params.PoDateTo)
|
||||
dateStart, dateEnd, err := parsePurchaseDateRangeForQuery(params.StartDate, params.EndDate, "date")
|
||||
if err != nil {
|
||||
return nil, 0, utils.BadRequest(err.Error())
|
||||
}
|
||||
}
|
||||
filterBy := strings.TrimSpace(params.FilterBy)
|
||||
|
||||
search := strings.ToLower(strings.TrimSpace(params.Search))
|
||||
approvalStatuses := parseStringCSVFilter(params.ApprovalStatus)
|
||||
@@ -187,23 +170,41 @@ func (s *purchaseService) GetAll(c *fiber.Ctx, params *validation.Query) ([]enti
|
||||
db = db.Where("supplier_id = ?", params.SupplierID)
|
||||
}
|
||||
|
||||
if createdFrom != nil {
|
||||
db = db.Where("created_at >= ?", *createdFrom)
|
||||
switch filterBy {
|
||||
case "po_date":
|
||||
if dateStart != nil {
|
||||
db = db.Where("purchases.po_date >= ?", *dateStart)
|
||||
}
|
||||
|
||||
if createdTo != nil {
|
||||
db = db.Where("created_at < ?", *createdTo)
|
||||
if dateEnd != nil {
|
||||
db = db.Where("purchases.po_date < ?", *dateEnd)
|
||||
}
|
||||
if poDateStart != nil {
|
||||
db = db.Where("purchases.po_date >= ?", *poDateStart)
|
||||
case "due_date":
|
||||
if dateStart != nil {
|
||||
db = db.Where("purchases.due_date >= ?", *dateStart)
|
||||
}
|
||||
|
||||
if poDateStart != nil {
|
||||
db = db.Where("purchases.po_date >= ?", *poDateStart)
|
||||
if dateEnd != nil {
|
||||
db = db.Where("purchases.due_date < ?", *dateEnd)
|
||||
}
|
||||
case "received_date":
|
||||
if dateStart != nil {
|
||||
db = db.Where(
|
||||
`EXISTS (SELECT 1 FROM purchase_items pi WHERE pi.purchase_id = purchases.id AND pi.received_date >= ?)`,
|
||||
*dateStart,
|
||||
)
|
||||
}
|
||||
if dateEnd != nil {
|
||||
db = db.Where(
|
||||
`EXISTS (SELECT 1 FROM purchase_items pi WHERE pi.purchase_id = purchases.id AND pi.received_date < ?)`,
|
||||
*dateEnd,
|
||||
)
|
||||
}
|
||||
default:
|
||||
if dateStart != nil {
|
||||
db = db.Where("purchases.created_at >= ?", *dateStart)
|
||||
}
|
||||
if dateEnd != nil {
|
||||
db = db.Where("purchases.created_at < ?", *dateEnd)
|
||||
}
|
||||
|
||||
if poDateEnd != nil {
|
||||
db = db.Where("purchases.po_date < ?", *poDateEnd)
|
||||
}
|
||||
|
||||
if scope.Restrict {
|
||||
@@ -263,6 +264,14 @@ func (s *purchaseService) GetAll(c *fiber.Ctx, params *validation.Query) ([]enti
|
||||
|
||||
sortBy := strings.TrimSpace(params.SortBy)
|
||||
sortOrder := strings.ToUpper(strings.TrimSpace(params.SortOrder))
|
||||
|
||||
if sortBy == "" && (filterBy == "po_date" || filterBy == "due_date" || filterBy == "received_date" || filterBy == "created_at") {
|
||||
sortBy = filterBy
|
||||
if sortOrder == "" {
|
||||
sortOrder = "ASC"
|
||||
}
|
||||
}
|
||||
|
||||
if sortOrder == "" {
|
||||
sortOrder = "DESC"
|
||||
}
|
||||
@@ -2238,30 +2247,36 @@ func (s *purchaseService) attachLatestApprovals(ctx context.Context, items []ent
|
||||
return nil
|
||||
}
|
||||
|
||||
func parsePoDateRangeForQuery(fromStr, toStr string) (*time.Time, *time.Time, error) {
|
||||
func parsePurchaseDateRangeForQuery(fromStr, toStr, fieldName string) (*time.Time, *time.Time, error) {
|
||||
jakartaLoc, err := time.LoadLocation("Asia/Jakarta")
|
||||
if err != nil {
|
||||
jakartaLoc = time.FixedZone("WIB", 7*60*60)
|
||||
}
|
||||
|
||||
var fromPtr *time.Time
|
||||
var toPtr *time.Time
|
||||
|
||||
if strings.TrimSpace(fromStr) != "" {
|
||||
parsed, err := utils.ParseDateString(strings.TrimSpace(fromStr))
|
||||
if err != nil {
|
||||
return nil, nil, errors.New("po_date_from must use format YYYY-MM-DD")
|
||||
return nil, nil, errors.New(fieldName + "_from must use format YYYY-MM-DD")
|
||||
}
|
||||
fromValue := parsed
|
||||
fromPtr = &fromValue
|
||||
t := time.Date(parsed.Year(), parsed.Month(), parsed.Day(), 0, 0, 0, 0, jakartaLoc)
|
||||
fromPtr = &t
|
||||
}
|
||||
|
||||
if strings.TrimSpace(toStr) != "" {
|
||||
parsed, err := utils.ParseDateString(strings.TrimSpace(toStr))
|
||||
if err != nil {
|
||||
return nil, nil, errors.New("po_date_to must use format YYYY-MM-DD")
|
||||
return nil, nil, errors.New(fieldName + "_to must use format YYYY-MM-DD")
|
||||
}
|
||||
nextDay := parsed.AddDate(0, 0, 1)
|
||||
t := time.Date(parsed.Year(), parsed.Month(), parsed.Day(), 0, 0, 0, 0, jakartaLoc)
|
||||
nextDay := t.AddDate(0, 0, 1)
|
||||
toPtr = &nextDay
|
||||
}
|
||||
|
||||
if fromPtr != nil && toPtr != nil && fromPtr.After(*toPtr) {
|
||||
return nil, nil, errors.New("po_date_from must be earlier than po_date_to")
|
||||
return nil, nil, errors.New(fieldName + "_from must be earlier than " + fieldName + "_to")
|
||||
}
|
||||
|
||||
return fromPtr, toPtr, nil
|
||||
|
||||
@@ -75,12 +75,10 @@ type Query struct {
|
||||
ProjectFlockKandangID uint `query:"project_flock_kandang_id" validate:"omitempty,gt=0"`
|
||||
ProductCategoryID string `query:"product_category_id" validate:"omitempty,max=500"`
|
||||
ApprovalStatus string `query:"approval_status" validate:"omitempty,max=500"`
|
||||
PoDate string `query:"po_date" validate:"omitempty,datetime=2006-01-02"`
|
||||
PoDateFrom string `query:"po_date_from" validate:"omitempty,datetime=2006-01-02"`
|
||||
PoDateTo string `query:"po_date_to" validate:"omitempty,datetime=2006-01-02"`
|
||||
StartDate string `query:"start_date" validate:"omitempty,datetime=2006-01-02"`
|
||||
EndDate string `query:"end_date" validate:"omitempty,datetime=2006-01-02"`
|
||||
FilterBy string `query:"filter_by" validate:"omitempty,oneof=po_date due_date received_date created_at"`
|
||||
Search string `query:"search" validate:"omitempty,max=100"`
|
||||
CreatedFrom string `query:"created_from" validate:"omitempty,datetime=2006-01-02"`
|
||||
CreatedTo string `query:"created_to" validate:"omitempty,datetime=2006-01-02"`
|
||||
SortBy string `query:"sort_by" validate:"omitempty,oneof=po_expedition supplier requester_name products location po_date received_date due_date status created_at po_number"`
|
||||
SortOrder string `query:"sort_order" validate:"omitempty,oneof=asc desc ASC DESC"`
|
||||
}
|
||||
|
||||
@@ -0,0 +1,286 @@
|
||||
package controller
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/gofiber/fiber/v2"
|
||||
"github.com/xuri/excelize/v2"
|
||||
"gitlab.com/mbugroup/lti-api.git/internal/modules/repports/dto"
|
||||
)
|
||||
|
||||
func isBalanceMonitoringExcelExportRequest(c *fiber.Ctx) bool {
|
||||
return strings.EqualFold(strings.TrimSpace(c.Query("export")), "excel")
|
||||
}
|
||||
|
||||
func exportBalanceMonitoringExcel(c *fiber.Ctx, items []dto.BalanceMonitoringRowDTO, totals dto.BalanceMonitoringTotalsDTO) error {
|
||||
content, err := buildBalanceMonitoringWorkbook(items, totals)
|
||||
if err != nil {
|
||||
return fiber.NewError(fiber.StatusInternalServerError, "failed to generate excel file")
|
||||
}
|
||||
|
||||
filename := fmt.Sprintf("laporan-balance-monitoring-%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 buildBalanceMonitoringWorkbook(items []dto.BalanceMonitoringRowDTO, totals dto.BalanceMonitoringTotalsDTO) ([]byte, error) {
|
||||
file := excelize.NewFile()
|
||||
defer file.Close()
|
||||
|
||||
const sheet = "Balance Monitoring"
|
||||
defaultSheet := file.GetSheetName(file.GetActiveSheetIndex())
|
||||
if defaultSheet != sheet {
|
||||
if err := file.SetSheetName(defaultSheet, sheet); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
|
||||
if err := setBalanceMonitoringColumns(file, sheet); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := setBalanceMonitoringHeaders(file, sheet); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := writeBalanceMonitoringRows(file, sheet, items, totals); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := file.SetPanes(sheet, &excelize.Panes{
|
||||
Freeze: true,
|
||||
YSplit: 2,
|
||||
TopLeftCell: "A3",
|
||||
ActivePane: "bottomLeft",
|
||||
}); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
buf, err := file.WriteToBuffer()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return buf.Bytes(), nil
|
||||
}
|
||||
|
||||
var bmColumnWidths = map[string]float64{
|
||||
"A": 5,
|
||||
"B": 28,
|
||||
"C": 18,
|
||||
"D": 12,
|
||||
"E": 12,
|
||||
"F": 20,
|
||||
"G": 12,
|
||||
"H": 12,
|
||||
"I": 20,
|
||||
"J": 20,
|
||||
"K": 18,
|
||||
"L": 12,
|
||||
"M": 16,
|
||||
"N": 20,
|
||||
}
|
||||
|
||||
func setBalanceMonitoringColumns(file *excelize.File, sheet string) error {
|
||||
for col, width := range bmColumnWidths {
|
||||
if err := file.SetColWidth(sheet, col, col, width); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
if err := file.SetRowHeight(sheet, 1, 24); err != nil {
|
||||
return err
|
||||
}
|
||||
return file.SetRowHeight(sheet, 2, 24)
|
||||
}
|
||||
|
||||
func setBalanceMonitoringHeaders(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
|
||||
}
|
||||
|
||||
// Single-column headers: merge rows 1 and 2 vertically
|
||||
singleColHeaders := map[string]string{
|
||||
"A": "No",
|
||||
"B": "Customer",
|
||||
"C": "Saldo Awal",
|
||||
"J": "Penjualan Trading",
|
||||
"K": "Pembayaran",
|
||||
"L": "Aging",
|
||||
"M": "Aging Rata-Rata",
|
||||
"N": "Saldo Akhir",
|
||||
}
|
||||
for col, header := range singleColHeaders {
|
||||
if err := file.SetCellValue(sheet, col+"1", header); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.MergeCell(sheet, col+"1", col+"2"); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
// Group headers: merge columns horizontally in row 1
|
||||
if err := file.SetCellValue(sheet, "D1", "Penjualan Ayam"); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.MergeCell(sheet, "D1", "F1"); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "G1", "Penjualan Telur"); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.MergeCell(sheet, "G1", "I1"); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// Sub-column headers in row 2
|
||||
subHeaders := map[string]string{
|
||||
"D": "Ekor",
|
||||
"E": "Kg",
|
||||
"F": "Nominal",
|
||||
"G": "Butir",
|
||||
"H": "Kg",
|
||||
"I": "Nominal",
|
||||
}
|
||||
for col, header := range subHeaders {
|
||||
if err := file.SetCellValue(sheet, col+"2", header); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return file.SetCellStyle(sheet, "A1", "N2", headerStyle)
|
||||
}
|
||||
|
||||
func writeBalanceMonitoringRows(file *excelize.File, sheet string, items []dto.BalanceMonitoringRowDTO, totals dto.BalanceMonitoringTotalsDTO) 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
|
||||
}
|
||||
|
||||
for i, row := range items {
|
||||
rowNum := i + 3
|
||||
rowStr := strconv.Itoa(rowNum)
|
||||
|
||||
cells := map[string]interface{}{
|
||||
"A": i + 1,
|
||||
"B": row.Customer.Name,
|
||||
"C": row.SaldoAwal,
|
||||
"D": row.PenjualanAyam.Ekor,
|
||||
"E": row.PenjualanAyam.Kg,
|
||||
"F": row.PenjualanAyam.Nominal,
|
||||
"G": row.PenjualanTelur.Butir,
|
||||
"H": row.PenjualanTelur.Kg,
|
||||
"I": row.PenjualanTelur.Nominal,
|
||||
"J": row.PenjualanTrading.Nominal,
|
||||
"K": row.Pembayaran,
|
||||
"L": fmt.Sprintf("%d hari", row.Aging),
|
||||
"M": formatBMAging(row.AgingRataRata),
|
||||
"N": row.SaldoAkhir,
|
||||
}
|
||||
for col, val := range cells {
|
||||
if err := file.SetCellValue(sheet, col+rowStr, val); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "A"+rowStr, "N"+rowStr, dataStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
if row.SaldoAkhir < 0 {
|
||||
if err := file.SetCellStyle(sheet, "N"+rowStr, "N"+rowStr, redDataStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Totals row
|
||||
totalRowStr := strconv.Itoa(len(items) + 3)
|
||||
totalCells := map[string]interface{}{
|
||||
"A": "Total",
|
||||
"C": totals.SaldoAwal,
|
||||
"D": totals.PenjualanAyam.Ekor,
|
||||
"E": totals.PenjualanAyam.Kg,
|
||||
"F": totals.PenjualanAyam.Nominal,
|
||||
"G": totals.PenjualanTelur.Butir,
|
||||
"H": totals.PenjualanTelur.Kg,
|
||||
"I": totals.PenjualanTelur.Nominal,
|
||||
"J": totals.PenjualanTrading.Nominal,
|
||||
"K": totals.Pembayaran,
|
||||
"N": totals.SaldoAkhir,
|
||||
}
|
||||
for col, val := range totalCells {
|
||||
if err := file.SetCellValue(sheet, col+totalRowStr, val); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "A"+totalRowStr, "N"+totalRowStr, totalStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
if totals.SaldoAkhir < 0 {
|
||||
if err := file.SetCellStyle(sheet, "N"+totalRowStr, "N"+totalRowStr, redTotalStyle); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func formatBMAging(v float64) string {
|
||||
s := strconv.FormatFloat(v, 'f', 2, 64)
|
||||
s = strings.ReplaceAll(s, ".", ",")
|
||||
return s + " hari"
|
||||
}
|
||||
@@ -324,6 +324,13 @@ func (c *RepportController) GetPurchaseSupplier(ctx *fiber.Ctx) error {
|
||||
return err
|
||||
}
|
||||
|
||||
if isPurchaseSupplierExcelExportRequest(ctx) {
|
||||
return exportPurchaseSupplierExcel(ctx, result)
|
||||
}
|
||||
if isPurchaseSupplierExcelAllExportRequest(ctx) {
|
||||
return exportPurchaseSupplierExcelAll(ctx, result)
|
||||
}
|
||||
|
||||
filters := map[string]interface{}{
|
||||
"area_id": query.AreaIDs,
|
||||
"supplier_id": query.SupplierIDs,
|
||||
@@ -555,6 +562,10 @@ func (c *RepportController) GetBalanceMonitoring(ctx *fiber.Ctx) error {
|
||||
return err
|
||||
}
|
||||
|
||||
if isBalanceMonitoringExcelExportRequest(ctx) {
|
||||
return exportBalanceMonitoringExcel(ctx, result, totals)
|
||||
}
|
||||
|
||||
limit := query.Limit
|
||||
if limit < 1 {
|
||||
limit = 10
|
||||
|
||||
@@ -214,8 +214,7 @@ func writeCustomerPaymentSheet(file *excelize.File, sheet string, item dto.Custo
|
||||
}
|
||||
|
||||
// Row 2: saldo awal
|
||||
initialFormatted := formatCPRupiah(item.InitialBalance)
|
||||
if err := file.SetCellValue(sheet, "N2", initialFormatted); err != nil {
|
||||
if err := file.SetCellValue(sheet, "N2", item.InitialBalance); err != nil {
|
||||
return err
|
||||
}
|
||||
if item.InitialBalance < 0 {
|
||||
@@ -248,14 +247,14 @@ func writeCustomerPaymentSheet(file *excelize.File, sheet string, item dto.Custo
|
||||
totalRowNum := len(item.Rows) + 3
|
||||
totalRowStr := fmt.Sprintf("%d", totalRowNum)
|
||||
|
||||
totalCells := map[string]string{
|
||||
totalCells := map[string]interface{}{
|
||||
"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),
|
||||
"K": item.Summary.TotalFinalAmount,
|
||||
"L": item.Summary.TotalGrandAmount,
|
||||
"M": item.Summary.TotalPayment,
|
||||
"N": item.Summary.TotalAccountsReceivable,
|
||||
}
|
||||
for col, val := range totalCells {
|
||||
if err := file.SetCellValue(sheet, col+totalRowStr, val); err != nil {
|
||||
@@ -369,8 +368,7 @@ func writeCustomerPaymentAllRows(file *excelize.File, sheet string, items []dto.
|
||||
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 {
|
||||
if err := file.SetCellValue(sheet, "O"+saldoStr, item.InitialBalance); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellStyle(sheet, "A"+saldoStr, lastHeaderCol+saldoStr, dataStyle); err != nil {
|
||||
@@ -409,15 +407,15 @@ func writeCustomerPaymentAllRows(file *excelize.File, sheet string, items []dto.
|
||||
|
||||
// Total row
|
||||
totalStr := fmt.Sprintf("%d", currentRow)
|
||||
totalCells := map[string]string{
|
||||
totalCells := map[string]interface{}{
|
||||
"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),
|
||||
"L": item.Summary.TotalFinalAmount,
|
||||
"M": item.Summary.TotalGrandAmount,
|
||||
"N": item.Summary.TotalPayment,
|
||||
"O": item.Summary.TotalAccountsReceivable,
|
||||
}
|
||||
for col, val := range totalCells {
|
||||
if err := file.SetCellValue(sheet, col+totalStr, val); err != nil {
|
||||
@@ -453,11 +451,11 @@ func customerPaymentRowCells(row dto.CustomerPaymentReportRow, seq int) []interf
|
||||
formatCPIDInteger(row.Qty),
|
||||
formatCPIDInteger(row.Weight),
|
||||
formatCPAvg(row.AverageWeight),
|
||||
formatCPRupiah(row.UnitPrice),
|
||||
formatCPRupiah(row.FinalPrice),
|
||||
formatCPRupiah(row.TotalPrice),
|
||||
formatCPRupiah(row.PaymentAmount),
|
||||
formatCPRupiah(row.AccountsReceivable),
|
||||
row.UnitPrice,
|
||||
row.FinalPrice,
|
||||
row.TotalPrice,
|
||||
row.PaymentAmount,
|
||||
row.AccountsReceivable,
|
||||
safeCPText(row.Status),
|
||||
joinCPStrings(row.PickupInfo),
|
||||
safeCPText(row.SalesPerson),
|
||||
@@ -546,13 +544,6 @@ func formatCPIDInteger(v float64) 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 {
|
||||
|
||||
@@ -2,7 +2,6 @@ package controller
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"math"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -197,9 +196,9 @@ func setMarketingReportRows(file *excelize.File, items []dto.RepportMarketingIte
|
||||
item.Qty,
|
||||
item.AverageWeightKg,
|
||||
item.TotalWeightKg,
|
||||
formatMarketingRupiah(item.SalesPricePerKg),
|
||||
formatMarketingRupiah(item.HppPricePerKg),
|
||||
formatMarketingRupiah(item.SalesAmount),
|
||||
item.SalesPricePerKg,
|
||||
item.HppPricePerKg,
|
||||
item.SalesAmount,
|
||||
}
|
||||
|
||||
for colIdx, val := range values {
|
||||
@@ -229,13 +228,13 @@ func setMarketingReportRows(file *excelize.File, items []dto.RepportMarketingIte
|
||||
if err := file.SetCellValue(sheet, "N"+totalRow, summary.TotalWeightKg); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "O"+totalRow, formatMarketingRupiah(summary.AverageSalesPrice)); err != nil {
|
||||
if err := file.SetCellValue(sheet, "O"+totalRow, summary.AverageSalesPrice); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "P"+totalRow, formatMarketingRupiah(summary.TotalHppPricePerKg)); err != nil {
|
||||
if err := file.SetCellValue(sheet, "P"+totalRow, summary.TotalHppPricePerKg); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := file.SetCellValue(sheet, "Q"+totalRow, formatMarketingRupiah(float64(summary.TotalSalesAmount))); err != nil {
|
||||
if err := file.SetCellValue(sheet, "Q"+totalRow, float64(summary.TotalSalesAmount)); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
@@ -333,30 +332,3 @@ func safeMarketingExportText(value string) string {
|
||||
return trimmed
|
||||
}
|
||||
|
||||
// formatMarketingRupiah formats a float64 as Indonesian Rupiah string.
|
||||
// e.g. 1000000 → "Rp 1.000.000"
|
||||
func formatMarketingRupiah(value float64) string {
|
||||
rounded := int64(math.Round(value))
|
||||
|
||||
negative := rounded < 0
|
||||
abs := rounded
|
||||
if negative {
|
||||
abs = -rounded
|
||||
}
|
||||
|
||||
numStr := strconv.FormatInt(abs, 10)
|
||||
n := len(numStr)
|
||||
|
||||
var b strings.Builder
|
||||
for i, c := range numStr {
|
||||
if i > 0 && (n-i)%3 == 0 {
|
||||
b.WriteByte('.')
|
||||
}
|
||||
b.WriteRune(c)
|
||||
}
|
||||
|
||||
if negative {
|
||||
return "Rp -" + b.String()
|
||||
}
|
||||
return "Rp " + b.String()
|
||||
}
|
||||
|
||||
@@ -0,0 +1,415 @@
|
||||
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 isPurchaseSupplierExcelExportRequest(c *fiber.Ctx) bool {
|
||||
return strings.EqualFold(strings.TrimSpace(c.Query("export")), "excel")
|
||||
}
|
||||
|
||||
func isPurchaseSupplierExcelAllExportRequest(c *fiber.Ctx) bool {
|
||||
return strings.EqualFold(strings.TrimSpace(c.Query("export")), "excel-all")
|
||||
}
|
||||
|
||||
func exportPurchaseSupplierExcel(c *fiber.Ctx, items []dto.PurchaseSupplierDTO) error {
|
||||
content, err := buildPurchaseSupplierWorkbook(items)
|
||||
if err != nil {
|
||||
return fiber.NewError(fiber.StatusInternalServerError, "failed to generate excel file")
|
||||
}
|
||||
|
||||
filename := fmt.Sprintf("laporan-pembelian-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 exportPurchaseSupplierExcelAll(c *fiber.Ctx, items []dto.PurchaseSupplierDTO) error {
|
||||
content, err := buildPurchaseSupplierAllWorkbook(items)
|
||||
if err != nil {
|
||||
return fiber.NewError(fiber.StatusInternalServerError, "failed to generate excel file")
|
||||
}
|
||||
|
||||
filename := fmt.Sprintf("laporan-pembelian-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)
|
||||
}
|
||||
|
||||
// buildPurchaseSupplierWorkbook creates a workbook with one sheet per supplier.
|
||||
func buildPurchaseSupplierWorkbook(items []dto.PurchaseSupplierDTO) ([]byte, error) {
|
||||
file := excelize.NewFile()
|
||||
defer file.Close()
|
||||
|
||||
defaultSheet := file.GetSheetName(file.GetActiveSheetIndex())
|
||||
|
||||
if len(items) == 0 {
|
||||
if err := writePurchaseSupplierSheet(file, defaultSheet, dto.PurchaseSupplierDTO{}); 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 := sanitizePurchaseSupplierSheetName(purchaseSupplierName(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 := writePurchaseSupplierSheet(file, sheetName, item); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
|
||||
buf, err := file.WriteToBuffer()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return buf.Bytes(), nil
|
||||
}
|
||||
|
||||
// buildPurchaseSupplierAllWorkbook creates a single-sheet workbook with all suppliers.
|
||||
func buildPurchaseSupplierAllWorkbook(items []dto.PurchaseSupplierDTO) ([]byte, error) {
|
||||
file := excelize.NewFile()
|
||||
defer file.Close()
|
||||
|
||||
const sheet = "Rekap Pembelian Supplier"
|
||||
defaultSheet := file.GetSheetName(file.GetActiveSheetIndex())
|
||||
if defaultSheet != sheet {
|
||||
if err := file.SetSheetName(defaultSheet, sheet); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
|
||||
if err := setPurchaseSupplierAllColumns(file, sheet); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := setPurchaseSupplierAllHeaders(file, sheet); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := writePurchaseSupplierAllRows(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 purchaseSupplierSheetHeaders = []string{
|
||||
"No",
|
||||
"Tanggal Terima",
|
||||
"Tanggal PO",
|
||||
"No. Referensi",
|
||||
"Nama Produk",
|
||||
"Tujuan",
|
||||
"QTY",
|
||||
"Harga Beli (Rp)",
|
||||
"Value Harga Beli (Rp)",
|
||||
"Transport (Rp)",
|
||||
"Value Transport (Rp)",
|
||||
"Jumlah (Rp)",
|
||||
"Ekspedisi",
|
||||
"Surat Jalan",
|
||||
}
|
||||
|
||||
var purchaseSupplierAllSheetHeaders = append([]string{"Supplier"}, purchaseSupplierSheetHeaders...)
|
||||
|
||||
var purchaseSupplierSheetColumnWidths = map[string]float64{
|
||||
"A": 5,
|
||||
"B": 14,
|
||||
"C": 12,
|
||||
"D": 16,
|
||||
"E": 20,
|
||||
"F": 20,
|
||||
"G": 10,
|
||||
"H": 20,
|
||||
"I": 20,
|
||||
"J": 22,
|
||||
"K": 22,
|
||||
"L": 16,
|
||||
"M": 20,
|
||||
"N": 20,
|
||||
}
|
||||
|
||||
var purchaseSupplierAllSheetColumnWidths = map[string]float64{
|
||||
"A": 24,
|
||||
"B": 6,
|
||||
"C": 14,
|
||||
"D": 12,
|
||||
"E": 16,
|
||||
"F": 20,
|
||||
"G": 20,
|
||||
"H": 10,
|
||||
"I": 20,
|
||||
"J": 20,
|
||||
"K": 22,
|
||||
"L": 22,
|
||||
"M": 16,
|
||||
"N": 20,
|
||||
"O": 20,
|
||||
}
|
||||
|
||||
func writePurchaseSupplierSheet(file *excelize.File, sheet string, item dto.PurchaseSupplierDTO) error {
|
||||
for col, width := range purchaseSupplierSheetColumnWidths {
|
||||
if err := file.SetColWidth(sheet, col, col, width); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
for i, h := range purchaseSupplierSheetHeaders {
|
||||
col, _ := excelize.ColumnNumberToName(i + 1)
|
||||
if err := file.SetCellValue(sheet, col+"1", h); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
for i, row := range item.Rows {
|
||||
rowNum := i + 2
|
||||
rowStr := fmt.Sprintf("%d", rowNum)
|
||||
|
||||
values := purchaseSupplierRowCells(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
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Summary row
|
||||
totalRowNum := len(item.Rows) + 2
|
||||
totalRowStr := fmt.Sprintf("%d", totalRowNum)
|
||||
totalCells := map[string]interface{}{
|
||||
"A": "Total",
|
||||
"G": item.Summary.TotalQty,
|
||||
"H": item.Summary.TotalUnitPrice,
|
||||
"I": item.Summary.TotalPurchaseValue,
|
||||
"J": item.Summary.TotalTransportUnitPrice,
|
||||
"K": item.Summary.TotalTransportValue,
|
||||
"L": item.Summary.TotalAmount,
|
||||
}
|
||||
for col, val := range totalCells {
|
||||
if err := file.SetCellValue(sheet, col+totalRowStr, val); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func setPurchaseSupplierAllColumns(file *excelize.File, sheet string) error {
|
||||
for col, width := range purchaseSupplierAllSheetColumnWidths {
|
||||
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 setPurchaseSupplierAllHeaders(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 purchaseSupplierAllSheetHeaders {
|
||||
col, _ := excelize.ColumnNumberToName(i + 1)
|
||||
if err := file.SetCellValue(sheet, col+"1", h); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
lastCol, _ := excelize.ColumnNumberToName(len(purchaseSupplierAllSheetHeaders))
|
||||
return file.SetCellStyle(sheet, "A1", lastCol+"1", headerStyle)
|
||||
}
|
||||
|
||||
func writePurchaseSupplierAllRows(file *excelize.File, sheet string, items []dto.PurchaseSupplierDTO) 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(purchaseSupplierAllSheetHeaders))
|
||||
|
||||
currentRow := 2
|
||||
for _, item := range items {
|
||||
supplierName := purchaseSupplierName(item)
|
||||
|
||||
// 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 := purchaseSupplierRowCells(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++
|
||||
}
|
||||
|
||||
// Summary row
|
||||
totalRowStr := fmt.Sprintf("%d", currentRow)
|
||||
totalCells := map[string]interface{}{
|
||||
"A": supplierName,
|
||||
"B": "Total",
|
||||
"H": item.Summary.TotalQty,
|
||||
"I": item.Summary.TotalUnitPrice,
|
||||
"J": item.Summary.TotalPurchaseValue,
|
||||
"K": item.Summary.TotalTransportUnitPrice,
|
||||
"L": item.Summary.TotalTransportValue,
|
||||
"M": item.Summary.TotalAmount,
|
||||
}
|
||||
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
|
||||
}
|
||||
|
||||
// purchaseSupplierRowCells returns cell values for one data row.
|
||||
func purchaseSupplierRowCells(row dto.PurchaseSupplierRowDTO, seq int) []interface{} {
|
||||
productName := "-"
|
||||
if row.Product != nil && strings.TrimSpace(row.Product.Name) != "" {
|
||||
productName = row.Product.Name
|
||||
}
|
||||
warehouseName := "-"
|
||||
if row.Warehouse != nil && strings.TrimSpace(row.Warehouse.Name) != "" {
|
||||
warehouseName = row.Warehouse.Name
|
||||
}
|
||||
|
||||
return []interface{}{
|
||||
seq,
|
||||
safePurchaseSupplierText(row.ReceiveDate),
|
||||
safePurchaseSupplierText(row.PoDate),
|
||||
safePurchaseSupplierText(row.PoNumber),
|
||||
productName,
|
||||
warehouseName,
|
||||
row.Qty,
|
||||
row.UnitPrice,
|
||||
row.PurchaseValue,
|
||||
row.TransportUnitPrice,
|
||||
row.TransportValue,
|
||||
row.TotalAmount,
|
||||
safePurchaseSupplierText(row.Expedition),
|
||||
safePurchaseSupplierText(row.DeliveryNumber),
|
||||
}
|
||||
}
|
||||
|
||||
func purchaseSupplierName(item dto.PurchaseSupplierDTO) string {
|
||||
if item.Supplier != nil && strings.TrimSpace(item.Supplier.Name) != "" {
|
||||
return item.Supplier.Name
|
||||
}
|
||||
return "Supplier"
|
||||
}
|
||||
|
||||
func sanitizePurchaseSupplierSheetName(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 safePurchaseSupplierText(s string) string {
|
||||
t := strings.TrimSpace(s)
|
||||
if t == "" {
|
||||
return "-"
|
||||
}
|
||||
return t
|
||||
}
|
||||
@@ -240,14 +240,16 @@ func (r *balanceMonitoringRepositoryImpl) GetSalesTotalsBeforeDate(ctx context.C
|
||||
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).
|
||||
|
||||
var db *gorm.DB
|
||||
if strings.ToLower(strings.TrimSpace(filters.FilterBy)) == "realized_at" {
|
||||
// realized_at: gunakan data DO (mdp.total_price), filter by delivery_date < startDate
|
||||
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").
|
||||
@@ -255,7 +257,19 @@ func (r *balanceMonitoringRepositoryImpl) GetSalesTotalsBeforeDate(ctx context.C
|
||||
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("DATE(mdp.delivery_date) < ?", startDate)
|
||||
} else {
|
||||
// sold_at: SO-date sebelum startDate DAN approval terbaru sudah DO — gunakan data DO (mdp.total_price)
|
||||
db = r.db.WithContext(ctx).
|
||||
Table("marketing_products mp").
|
||||
Select("m.customer_id AS customer_id, COALESCE(SUM(mdp.total_price), 0) AS total").
|
||||
Joins("INNER JOIN marketings m ON m.id = mp.marketing_id").
|
||||
Joins("INNER JOIN marketing_delivery_products mdp ON mdp.marketing_product_id = mp.id").
|
||||
Where("m.customer_id IN ?", customerIDs).
|
||||
Where("m.deleted_at IS NULL").
|
||||
Where("DATE(m.so_date) < ?", startDate).
|
||||
Where("(SELECT step_number FROM approvals WHERE approvable_type = 'MARKETINGS' AND approvable_id = mp.marketing_id ORDER BY id DESC LIMIT 1) >= ?", uint16(utils.MarketingDeliveryOrder))
|
||||
}
|
||||
|
||||
if len(filters.SalesIDs) > 0 {
|
||||
db = db.Where("m.sales_person_id IN ?", filters.SalesIDs)
|
||||
@@ -318,28 +332,46 @@ func (r *balanceMonitoringRepositoryImpl) GetSalesByCategoryInPeriod(ctx context
|
||||
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,
|
||||
// Gunakan data DO (mdp) bukan SO (mp) agar nominal/qty/kg mencerminkan nilai aktual DO
|
||||
const selectCols = `m.customer_id AS customer_id,
|
||||
COALESCE(SUM(CASE WHEN m.marketing_type IN ('AYAM','AYAM_PULLET') THEN (mdp.usage_qty + mdp.pending_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.usage_qty + mdp.pending_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.usage_qty + mdp.pending_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`).
|
||||
COALESCE(SUM(CASE WHEN m.marketing_type = 'TRADING' THEN mdp.total_price ELSE 0 END), 0) AS trading_nominal`
|
||||
|
||||
rows := make([]BalanceMonitoringCategoryRow, 0)
|
||||
|
||||
var db *gorm.DB
|
||||
if strings.ToLower(strings.TrimSpace(filters.FilterBy)) == "realized_at" {
|
||||
// realized_at: FROM mdp langsung, filter by delivery_date in period — data DO
|
||||
db = r.db.WithContext(ctx).
|
||||
Table("marketing_delivery_products mdp").
|
||||
Select(selectCols).
|
||||
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)
|
||||
Where("DATE(mdp.delivery_date) >= ?", startDate).
|
||||
Where("DATE(mdp.delivery_date) <= ?", endDate)
|
||||
} else {
|
||||
// sold_at: SO-date dalam period DAN approval terbaru DO — JOIN mdp untuk data DO
|
||||
db = r.db.WithContext(ctx).
|
||||
Table("marketing_products mp").
|
||||
Select(selectCols).
|
||||
Joins("INNER JOIN marketings m ON m.id = mp.marketing_id").
|
||||
Joins("INNER JOIN marketing_delivery_products mdp ON mdp.marketing_product_id = mp.id").
|
||||
Where("m.customer_id IN ?", customerIDs).
|
||||
Where("m.deleted_at IS NULL").
|
||||
Where("DATE(m.so_date) >= ?", startDate).
|
||||
Where("DATE(m.so_date) <= ?", endDate).
|
||||
Where("(SELECT step_number FROM approvals WHERE approvable_type = 'MARKETINGS' AND approvable_id = mp.marketing_id ORDER BY id DESC LIMIT 1) >= ?", uint16(utils.MarketingDeliveryOrder))
|
||||
}
|
||||
|
||||
if len(filters.SalesIDs) > 0 {
|
||||
db = db.Where("m.sales_person_id IN ?", filters.SalesIDs)
|
||||
|
||||
@@ -514,7 +514,7 @@ func (r *debtSupplierRepositoryImpl) baseExpenseSupplierIDs(ctx context.Context,
|
||||
Table("expenses").
|
||||
Select("DISTINCT expenses.supplier_id").
|
||||
Joins("JOIN (?) AS la ON la.approvable_id = expenses.id", r.latestExpenseApproval(ctx)).
|
||||
Where("la.step_number >= ?", uint16(utils.ExpenseStepFinance)).
|
||||
Where("la.step_number >= ?", uint16(utils.ExpenseStepRealisasi)).
|
||||
Where("(la.action IS NULL OR la.action != ?)", string(entity.ApprovalActionRejected)).
|
||||
Where("expenses.deleted_at IS NULL")
|
||||
|
||||
@@ -623,7 +623,7 @@ func (r *debtSupplierRepositoryImpl) GetExpensesBySuppliers(ctx context.Context,
|
||||
Model(&entity.Expense{}).
|
||||
Joins("JOIN (?) AS la ON la.approvable_id = expenses.id", r.latestExpenseApproval(ctx)).
|
||||
Where("expenses.supplier_id IN ?", supplierIDs).
|
||||
Where("la.step_number >= ?", uint16(utils.ExpenseStepFinance)).
|
||||
Where("la.step_number >= ?", uint16(utils.ExpenseStepRealisasi)).
|
||||
Where("(la.action IS NULL OR la.action != ?)", string(entity.ApprovalActionRejected)).
|
||||
Where("expenses.deleted_at IS NULL")
|
||||
|
||||
@@ -692,7 +692,7 @@ func (r *debtSupplierRepositoryImpl) GetExpenseTotalsBeforeDate(ctx context.Cont
|
||||
Joins("JOIN expense_nonstocks en ON en.expense_id = expenses.id").
|
||||
Joins("JOIN (?) AS la ON la.approvable_id = expenses.id", r.latestExpenseApproval(ctx)).
|
||||
Where("expenses.supplier_id IN ?", supplierIDs).
|
||||
Where("la.step_number >= ?", uint16(utils.ExpenseStepFinance)).
|
||||
Where("la.step_number >= ?", uint16(utils.ExpenseStepRealisasi)).
|
||||
Where("(la.action IS NULL OR la.action != ?)", string(entity.ApprovalActionRejected)).
|
||||
Where("expenses.deleted_at IS NULL").
|
||||
Where("DATE(expenses.transaction_date) < ?", dateFrom).
|
||||
|
||||
Reference in New Issue
Block a user