Compare commits
4
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a55a3f4ee2 | ||
|
|
024d9ee637 | ||
|
|
b8be29e110 | ||
|
|
da87d659df |
+11
-1
@@ -135,6 +135,8 @@ func (a *App) Initialize(cfg *config.Config) error {
|
|||||||
services.productOutletPriceService,
|
services.productOutletPriceService,
|
||||||
validators.productOutletPriceValidator,
|
validators.productOutletPriceValidator,
|
||||||
selfOrderHandler,
|
selfOrderHandler,
|
||||||
|
services.expenseService,
|
||||||
|
validators.expenseValidator,
|
||||||
)
|
)
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
@@ -236,6 +238,7 @@ type repositories struct {
|
|||||||
notificationReceiverRepo *repository.NotificationReceiverRepositoryImpl
|
notificationReceiverRepo *repository.NotificationReceiverRepositoryImpl
|
||||||
notificationDeliveryRepo *repository.NotificationDeliveryRepositoryImpl
|
notificationDeliveryRepo *repository.NotificationDeliveryRepositoryImpl
|
||||||
productOutletPriceRepo *repository.ProductOutletPriceRepositoryImpl
|
productOutletPriceRepo *repository.ProductOutletPriceRepositoryImpl
|
||||||
|
expenseRepo *repository.ExpenseRepositoryImpl
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *App) initRepositories() *repositories {
|
func (a *App) initRepositories() *repositories {
|
||||||
@@ -288,6 +291,7 @@ func (a *App) initRepositories() *repositories {
|
|||||||
notificationReceiverRepo: repository.NewNotificationReceiverRepository(a.db),
|
notificationReceiverRepo: repository.NewNotificationReceiverRepository(a.db),
|
||||||
notificationDeliveryRepo: repository.NewNotificationDeliveryRepository(a.db),
|
notificationDeliveryRepo: repository.NewNotificationDeliveryRepository(a.db),
|
||||||
productOutletPriceRepo: repository.NewProductOutletPriceRepositoryImpl(a.db),
|
productOutletPriceRepo: repository.NewProductOutletPriceRepositoryImpl(a.db),
|
||||||
|
expenseRepo: repository.NewExpenseRepositoryImpl(a.db),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -333,6 +337,7 @@ type processors struct {
|
|||||||
userDeviceProcessor *processor.UserDeviceProcessorImpl
|
userDeviceProcessor *processor.UserDeviceProcessorImpl
|
||||||
notificationProcessor *processor.NotificationProcessorImpl
|
notificationProcessor *processor.NotificationProcessorImpl
|
||||||
productOutletPriceProcessor processor.ProductOutletPriceProcessor
|
productOutletPriceProcessor processor.ProductOutletPriceProcessor
|
||||||
|
expenseProcessor *processor.ExpenseProcessorImpl
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *App) initProcessors(cfg *config.Config, repos *repositories) *processors {
|
func (a *App) initProcessors(cfg *config.Config, repos *repositories) *processors {
|
||||||
@@ -354,7 +359,7 @@ func (a *App) initProcessors(cfg *config.Config, repos *repositories) *processor
|
|||||||
paymentMethodProcessor: processor.NewPaymentMethodProcessorImpl(repos.paymentMethodRepo),
|
paymentMethodProcessor: processor.NewPaymentMethodProcessorImpl(repos.paymentMethodRepo),
|
||||||
fileProcessor: processor.NewFileProcessorImpl(repos.fileRepo, fileClient),
|
fileProcessor: processor.NewFileProcessorImpl(repos.fileRepo, fileClient),
|
||||||
customerProcessor: processor.NewCustomerProcessor(repos.customerRepo),
|
customerProcessor: processor.NewCustomerProcessor(repos.customerRepo),
|
||||||
analyticsProcessor: processor.NewAnalyticsProcessorImpl(repos.analyticsRepo),
|
analyticsProcessor: processor.NewAnalyticsProcessorImpl(repos.analyticsRepo, repos.expenseRepo),
|
||||||
tableProcessor: processor.NewTableProcessor(repos.tableRepo, repos.orderRepo),
|
tableProcessor: processor.NewTableProcessor(repos.tableRepo, repos.orderRepo),
|
||||||
unitProcessor: processor.NewUnitProcessor(repos.unitRepo),
|
unitProcessor: processor.NewUnitProcessor(repos.unitRepo),
|
||||||
ingredientProcessor: processor.NewIngredientProcessor(repos.ingredientRepo, repos.unitRepo, repos.ingredientCompositionRepo),
|
ingredientProcessor: processor.NewIngredientProcessor(repos.ingredientRepo, repos.unitRepo, repos.ingredientCompositionRepo),
|
||||||
@@ -383,6 +388,7 @@ func (a *App) initProcessors(cfg *config.Config, repos *repositories) *processor
|
|||||||
userDeviceProcessor: processor.NewUserDeviceProcessorImpl(repos.userDeviceRepo),
|
userDeviceProcessor: processor.NewUserDeviceProcessorImpl(repos.userDeviceRepo),
|
||||||
notificationProcessor: buildNotificationProcessor(cfg, repos),
|
notificationProcessor: buildNotificationProcessor(cfg, repos),
|
||||||
productOutletPriceProcessor: processor.NewProductOutletPriceProcessorImpl(repos.productOutletPriceRepo, repos.productRepo, repos.outletRepo),
|
productOutletPriceProcessor: processor.NewProductOutletPriceProcessorImpl(repos.productOutletPriceRepo, repos.productRepo, repos.outletRepo),
|
||||||
|
expenseProcessor: processor.NewExpenseProcessorImpl(repos.expenseRepo),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -422,6 +428,7 @@ type services struct {
|
|||||||
userDeviceService service.UserDeviceService
|
userDeviceService service.UserDeviceService
|
||||||
notificationService service.NotificationService
|
notificationService service.NotificationService
|
||||||
productOutletPriceService service.ProductOutletPriceService
|
productOutletPriceService service.ProductOutletPriceService
|
||||||
|
expenseService *service.ExpenseServiceImpl
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *App) initServices(processors *processors, repos *repositories, cfg *config.Config) *services {
|
func (a *App) initServices(processors *processors, repos *repositories, cfg *config.Config) *services {
|
||||||
@@ -499,6 +506,7 @@ func (a *App) initServices(processors *processors, repos *repositories, cfg *con
|
|||||||
userDeviceService: userDeviceService,
|
userDeviceService: userDeviceService,
|
||||||
notificationService: notificationService,
|
notificationService: notificationService,
|
||||||
productOutletPriceService: service.NewProductOutletPriceService(processors.productOutletPriceProcessor),
|
productOutletPriceService: service.NewProductOutletPriceService(processors.productOutletPriceProcessor),
|
||||||
|
expenseService: service.NewExpenseService(processors.expenseProcessor),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -541,6 +549,7 @@ type validators struct {
|
|||||||
userDeviceValidator *validator.UserDeviceValidatorImpl
|
userDeviceValidator *validator.UserDeviceValidatorImpl
|
||||||
notificationValidator *validator.NotificationValidatorImpl
|
notificationValidator *validator.NotificationValidatorImpl
|
||||||
productOutletPriceValidator *validator.ProductOutletPriceValidatorImpl
|
productOutletPriceValidator *validator.ProductOutletPriceValidatorImpl
|
||||||
|
expenseValidator *validator.ExpenseValidatorImpl
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *App) initValidators() *validators {
|
func (a *App) initValidators() *validators {
|
||||||
@@ -571,6 +580,7 @@ func (a *App) initValidators() *validators {
|
|||||||
userDeviceValidator: validator.NewUserDeviceValidator(),
|
userDeviceValidator: validator.NewUserDeviceValidator(),
|
||||||
notificationValidator: validator.NewNotificationValidator(),
|
notificationValidator: validator.NewNotificationValidator(),
|
||||||
productOutletPriceValidator: validator.NewProductOutletPriceValidator(),
|
productOutletPriceValidator: validator.NewProductOutletPriceValidator(),
|
||||||
|
expenseValidator: validator.NewExpenseValidator(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -60,6 +60,7 @@ const (
|
|||||||
NotificationServiceEntity = "notification_service"
|
NotificationServiceEntity = "notification_service"
|
||||||
NotificationHandlerEntity = "notification_handler"
|
NotificationHandlerEntity = "notification_handler"
|
||||||
ProductOutletPriceServiceEntity = "product_outlet_price_service"
|
ProductOutletPriceServiceEntity = "product_outlet_price_service"
|
||||||
|
ExpenseServiceEntity = "expense_service"
|
||||||
)
|
)
|
||||||
|
|
||||||
var HttpErrorMap = map[string]int{
|
var HttpErrorMap = map[string]int{
|
||||||
|
|||||||
@@ -236,68 +236,33 @@ type DashboardOverview struct {
|
|||||||
RefundedOrders int64 `json:"refunded_orders"`
|
RefundedOrders int64 `json:"refunded_orders"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossAnalyticsRequest represents the request for profit and loss analytics
|
|
||||||
type ProfitLossAnalyticsRequest struct {
|
type ProfitLossAnalyticsRequest struct {
|
||||||
OrganizationID uuid.UUID
|
OrganizationID uuid.UUID
|
||||||
OutletID *string `form:"outlet_id,omitempty"`
|
OutletID *string `form:"outlet_id,omitempty"`
|
||||||
DateFrom string `form:"date_from" validate:"required"`
|
Date string `form:"date" validate:"required"`
|
||||||
DateTo string `form:"date_to" validate:"required"`
|
|
||||||
GroupBy string `form:"group_by,default=day" validate:"omitempty,oneof=day hour week month"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossAnalyticsResponse represents the response for profit and loss analytics
|
|
||||||
type ProfitLossAnalyticsResponse struct {
|
type ProfitLossAnalyticsResponse struct {
|
||||||
OrganizationID uuid.UUID `json:"organization_id"`
|
OrganizationID uuid.UUID `json:"organization_id"`
|
||||||
OutletID *uuid.UUID `json:"outlet_id,omitempty"`
|
OutletID *uuid.UUID `json:"outlet_id,omitempty"`
|
||||||
DateFrom time.Time `json:"date_from"`
|
|
||||||
DateTo time.Time `json:"date_to"`
|
|
||||||
GroupBy string `json:"group_by"`
|
|
||||||
Summary ProfitLossSummary `json:"summary"`
|
|
||||||
Data []ProfitLossData `json:"data"`
|
|
||||||
ProductData []ProductProfitData `json:"product_data"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// ProfitLossSummary represents the summary of profit and loss analytics
|
|
||||||
type ProfitLossSummary struct {
|
|
||||||
TotalRevenue float64 `json:"total_revenue"`
|
|
||||||
TotalCost float64 `json:"total_cost"`
|
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
TotalTax float64 `json:"total_tax"`
|
|
||||||
TotalDiscount float64 `json:"total_discount"`
|
|
||||||
NetProfit float64 `json:"net_profit"`
|
|
||||||
NetProfitMargin float64 `json:"net_profit_margin"`
|
|
||||||
TotalOrders int64 `json:"total_orders"`
|
|
||||||
AverageProfit float64 `json:"average_profit"`
|
|
||||||
ProfitabilityRatio float64 `json:"profitability_ratio"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// ProfitLossData represents individual profit and loss data point by time period
|
|
||||||
type ProfitLossData struct {
|
|
||||||
Date time.Time `json:"date"`
|
Date time.Time `json:"date"`
|
||||||
Revenue float64 `json:"revenue"`
|
MainSummary []ProfitLossSummaryRow `json:"main_summary"`
|
||||||
Cost float64 `json:"cost"`
|
OperationalExpenses []OperationalExpenseItem `json:"operational_expenses"`
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
OperationalExpensesTotal float64 `json:"operational_expenses_total"`
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
Tax float64 `json:"tax"`
|
|
||||||
Discount float64 `json:"discount"`
|
|
||||||
NetProfit float64 `json:"net_profit"`
|
|
||||||
NetProfitMargin float64 `json:"net_profit_margin"`
|
|
||||||
Orders int64 `json:"orders"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProductProfitData represents profit data for individual products
|
type ProfitLossSummaryRow struct {
|
||||||
type ProductProfitData struct {
|
ID string `json:"id"`
|
||||||
ProductID uuid.UUID `json:"product_id"`
|
Label string `json:"label"`
|
||||||
ProductName string `json:"product_name"`
|
IsBold bool `json:"is_bold"`
|
||||||
CategoryID uuid.UUID `json:"category_id"`
|
TodayNominal float64 `json:"today_nominal"`
|
||||||
CategoryName string `json:"category_name"`
|
TodayPct float64 `json:"today_pct"`
|
||||||
QuantitySold int64 `json:"quantity_sold"`
|
MtdNominal float64 `json:"mtd_nominal"`
|
||||||
Revenue float64 `json:"revenue"`
|
MtdPct float64 `json:"mtd_pct"`
|
||||||
Cost float64 `json:"cost"`
|
SubItems []ProfitLossSummaryRow `json:"sub_items,omitempty"`
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
}
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
AveragePrice float64 `json:"average_price"`
|
type OperationalExpenseItem struct {
|
||||||
AverageCost float64 `json:"average_cost"`
|
Item string `json:"item"`
|
||||||
ProfitPerUnit float64 `json:"profit_per_unit"`
|
Nominal float64 `json:"nominal"`
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,86 @@
|
|||||||
|
package contract
|
||||||
|
|
||||||
|
import (
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
)
|
||||||
|
|
||||||
|
type CreateExpenseRequest struct {
|
||||||
|
ExpenseName string `json:"expense_name" validate:"required"`
|
||||||
|
Receiver string `json:"receiver" validate:"required"`
|
||||||
|
TransactionDate string `json:"transaction_date" validate:"required"`
|
||||||
|
CodeNumber string `json:"code_number" validate:"required"`
|
||||||
|
OutletID string `json:"outlet_id" validate:"required"`
|
||||||
|
Description *string `json:"description,omitempty"`
|
||||||
|
Tax float64 `json:"tax"`
|
||||||
|
Total float64 `json:"total" validate:"required"`
|
||||||
|
Items []CreateExpenseItemRequest `json:"items" validate:"required"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type CreateExpenseItemRequest struct {
|
||||||
|
ChartOfAccountID string `json:"chart_of_account_id" validate:"required"`
|
||||||
|
Description *string `json:"description,omitempty"`
|
||||||
|
Amount float64 `json:"amount" validate:"required"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type UpdateExpenseRequest struct {
|
||||||
|
ExpenseName *string `json:"expense_name,omitempty"`
|
||||||
|
Receiver *string `json:"receiver,omitempty"`
|
||||||
|
TransactionDate *string `json:"transaction_date,omitempty"`
|
||||||
|
CodeNumber *string `json:"code_number,omitempty"`
|
||||||
|
OutletID *string `json:"outlet_id,omitempty"`
|
||||||
|
Description *string `json:"description,omitempty"`
|
||||||
|
Tax *float64 `json:"tax,omitempty"`
|
||||||
|
Total *float64 `json:"total,omitempty"`
|
||||||
|
Reserved1 *string `json:"reserved1,omitempty"`
|
||||||
|
Items []UpdateExpenseItemRequest `json:"items,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type UpdateExpenseItemRequest struct {
|
||||||
|
ChartOfAccountID *string `json:"chart_of_account_id,omitempty"`
|
||||||
|
Description *string `json:"description,omitempty"`
|
||||||
|
Amount *float64 `json:"amount,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ExpenseResponse struct {
|
||||||
|
ID uuid.UUID `json:"id"`
|
||||||
|
OrganizationID uuid.UUID `json:"organization_id"`
|
||||||
|
OutletID uuid.UUID `json:"outlet_id"`
|
||||||
|
ExpenseName string `json:"expense_name"`
|
||||||
|
Receiver string `json:"receiver"`
|
||||||
|
TransactionDate time.Time `json:"transaction_date"`
|
||||||
|
CodeNumber string `json:"code_number"`
|
||||||
|
Description *string `json:"description"`
|
||||||
|
Tax float64 `json:"tax"`
|
||||||
|
Total float64 `json:"total"`
|
||||||
|
Reserved1 *string `json:"reserved1,omitempty"`
|
||||||
|
CreatedAt time.Time `json:"created_at"`
|
||||||
|
UpdatedAt time.Time `json:"updated_at"`
|
||||||
|
Items []ExpenseItemResponse `json:"items,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ExpenseItemResponse struct {
|
||||||
|
ID uuid.UUID `json:"id"`
|
||||||
|
ExpenseID uuid.UUID `json:"expense_id"`
|
||||||
|
ChartOfAccountID uuid.UUID `json:"chart_of_account_id"`
|
||||||
|
ChartOfAccountName string `json:"chart_of_account_name,omitempty"`
|
||||||
|
Description *string `json:"description"`
|
||||||
|
Amount float64 `json:"amount"`
|
||||||
|
CreatedAt time.Time `json:"created_at"`
|
||||||
|
UpdatedAt time.Time `json:"updated_at"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ListExpenseRequest struct {
|
||||||
|
Page int `json:"page" validate:"min=1"`
|
||||||
|
Limit int `json:"limit" validate:"min=1,max=100"`
|
||||||
|
Search string `json:"search,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ListExpenseResponse struct {
|
||||||
|
Expenses []ExpenseResponse `json:"expenses"`
|
||||||
|
TotalCount int `json:"total_count"`
|
||||||
|
Page int `json:"page"`
|
||||||
|
Limit int `json:"limit"`
|
||||||
|
TotalPages int `json:"total_pages"`
|
||||||
|
}
|
||||||
@@ -98,8 +98,6 @@ type OrderItemResponse struct {
|
|||||||
ProductName string `json:"product_name"`
|
ProductName string `json:"product_name"`
|
||||||
ProductVariantID *uuid.UUID `json:"product_variant_id"`
|
ProductVariantID *uuid.UUID `json:"product_variant_id"`
|
||||||
ProductVariantName *string `json:"product_variant_name,omitempty"`
|
ProductVariantName *string `json:"product_variant_name,omitempty"`
|
||||||
CategoryID *uuid.UUID `json:"category_id,omitempty"`
|
|
||||||
CategoryName *string `json:"category_name,omitempty"`
|
|
||||||
Quantity int `json:"quantity"`
|
Quantity int `json:"quantity"`
|
||||||
UnitPrice float64 `json:"unit_price"`
|
UnitPrice float64 `json:"unit_price"`
|
||||||
TotalPrice float64 `json:"total_price"`
|
TotalPrice float64 `json:"total_price"`
|
||||||
@@ -110,7 +108,6 @@ type OrderItemResponse struct {
|
|||||||
CreatedAt time.Time `json:"created_at"`
|
CreatedAt time.Time `json:"created_at"`
|
||||||
UpdatedAt time.Time `json:"updated_at"`
|
UpdatedAt time.Time `json:"updated_at"`
|
||||||
PrinterType string `json:"printer_type"`
|
PrinterType string `json:"printer_type"`
|
||||||
PrintToChecker bool `json:"print_to_checker"`
|
|
||||||
PaidQuantity int `json:"paid_quantity"`
|
PaidQuantity int `json:"paid_quantity"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -17,7 +17,6 @@ type CreateProductRequest struct {
|
|||||||
BusinessType *string `json:"business_type,omitempty"`
|
BusinessType *string `json:"business_type,omitempty"`
|
||||||
ImageURL *string `json:"image_url,omitempty" validate:"omitempty,max=500"`
|
ImageURL *string `json:"image_url,omitempty" validate:"omitempty,max=500"`
|
||||||
PrinterType *string `json:"printer_type,omitempty" validate:"omitempty,max=50"`
|
PrinterType *string `json:"printer_type,omitempty" validate:"omitempty,max=50"`
|
||||||
PrintToChecker *bool `json:"print_to_checker,omitempty"`
|
|
||||||
Metadata map[string]interface{} `json:"metadata,omitempty"`
|
Metadata map[string]interface{} `json:"metadata,omitempty"`
|
||||||
IsActive *bool `json:"is_active,omitempty"`
|
IsActive *bool `json:"is_active,omitempty"`
|
||||||
Variants []CreateProductVariantRequest `json:"variants,omitempty"`
|
Variants []CreateProductVariantRequest `json:"variants,omitempty"`
|
||||||
@@ -37,7 +36,6 @@ type UpdateProductRequest struct {
|
|||||||
BusinessType *string `json:"business_type,omitempty"`
|
BusinessType *string `json:"business_type,omitempty"`
|
||||||
ImageURL *string `json:"image_url,omitempty" validate:"omitempty,max=500"`
|
ImageURL *string `json:"image_url,omitempty" validate:"omitempty,max=500"`
|
||||||
PrinterType *string `json:"printer_type,omitempty" validate:"omitempty,max=50"`
|
PrinterType *string `json:"printer_type,omitempty" validate:"omitempty,max=50"`
|
||||||
PrintToChecker *bool `json:"print_to_checker,omitempty"`
|
|
||||||
Metadata map[string]interface{} `json:"metadata,omitempty"`
|
Metadata map[string]interface{} `json:"metadata,omitempty"`
|
||||||
IsActive *bool `json:"is_active,omitempty"`
|
IsActive *bool `json:"is_active,omitempty"`
|
||||||
ReorderLevel *int `json:"reorder_level,omitempty" validate:"omitempty,min=0"`
|
ReorderLevel *int `json:"reorder_level,omitempty" validate:"omitempty,min=0"`
|
||||||
@@ -73,7 +71,6 @@ type ProductResponse struct {
|
|||||||
BusinessType string `json:"business_type"`
|
BusinessType string `json:"business_type"`
|
||||||
ImageURL *string `json:"image_url"`
|
ImageURL *string `json:"image_url"`
|
||||||
PrinterType string `json:"printer_type"`
|
PrinterType string `json:"printer_type"`
|
||||||
PrintToChecker bool `json:"print_to_checker"`
|
|
||||||
Metadata map[string]interface{} `json:"metadata"`
|
Metadata map[string]interface{} `json:"metadata"`
|
||||||
IsActive bool `json:"is_active"`
|
IsActive bool `json:"is_active"`
|
||||||
CreatedAt time.Time `json:"created_at"`
|
CreatedAt time.Time `json:"created_at"`
|
||||||
|
|||||||
@@ -10,12 +10,10 @@ type CreateProductOutletPriceRequest struct {
|
|||||||
ProductID uuid.UUID `json:"product_id" validate:"required"`
|
ProductID uuid.UUID `json:"product_id" validate:"required"`
|
||||||
OutletID uuid.UUID `json:"outlet_id" validate:"required"`
|
OutletID uuid.UUID `json:"outlet_id" validate:"required"`
|
||||||
Price float64 `json:"price" validate:"required,min=0"`
|
Price float64 `json:"price" validate:"required,min=0"`
|
||||||
PrintToChecker bool `json:"print_to_checker"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type UpdateProductOutletPriceRequest struct {
|
type UpdateProductOutletPriceRequest struct {
|
||||||
Price float64 `json:"price" validate:"required,min=0"`
|
Price float64 `json:"price" validate:"required,min=0"`
|
||||||
PrintToChecker *bool `json:"print_to_checker"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type ProductOutletPriceResponse struct {
|
type ProductOutletPriceResponse struct {
|
||||||
@@ -24,7 +22,6 @@ type ProductOutletPriceResponse struct {
|
|||||||
OutletID uuid.UUID `json:"outlet_id"`
|
OutletID uuid.UUID `json:"outlet_id"`
|
||||||
OutletName string `json:"outlet_name,omitempty"`
|
OutletName string `json:"outlet_name,omitempty"`
|
||||||
Price float64 `json:"price"`
|
Price float64 `json:"price"`
|
||||||
PrintToChecker bool `json:"print_to_checker"`
|
|
||||||
CreatedAt time.Time `json:"created_at,omitempty"`
|
CreatedAt time.Time `json:"created_at,omitempty"`
|
||||||
UpdatedAt time.Time `json:"updated_at,omitempty"`
|
UpdatedAt time.Time `json:"updated_at,omitempty"`
|
||||||
}
|
}
|
||||||
@@ -42,5 +39,4 @@ type BulkCreateProductOutletPriceRequest struct {
|
|||||||
type CreateProductOutletPricePerOutletRequest struct {
|
type CreateProductOutletPricePerOutletRequest struct {
|
||||||
OutletID uuid.UUID `json:"outlet_id" validate:"required"`
|
OutletID uuid.UUID `json:"outlet_id" validate:"required"`
|
||||||
Price float64 `json:"price" validate:"required,min=0"`
|
Price float64 `json:"price" validate:"required,min=0"`
|
||||||
PrintToChecker bool `json:"print_to_checker"`
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -113,54 +113,22 @@ type DashboardOverview struct {
|
|||||||
RefundedOrders int64 `json:"refunded_orders"`
|
RefundedOrders int64 `json:"refunded_orders"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossAnalytics represents profit and loss analytics data
|
|
||||||
type ProfitLossAnalytics struct {
|
type ProfitLossAnalytics struct {
|
||||||
Summary ProfitLossSummary `json:"summary"`
|
TodayRevenue float64
|
||||||
Data []ProfitLossData `json:"data"`
|
TodayCost float64
|
||||||
ProductData []ProductProfitData `json:"product_data"`
|
MtdRevenue float64
|
||||||
|
MtdCost float64
|
||||||
|
TodayExpenseByCategory []ExpenseCategoryTotal
|
||||||
|
MtdExpenseByCategory []ExpenseCategoryTotal
|
||||||
|
OperationalExpenseItems []OperationalExpenseItem
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossSummary represents profit and loss summary data
|
type ExpenseCategoryTotal struct {
|
||||||
type ProfitLossSummary struct {
|
CategoryName string
|
||||||
TotalRevenue float64 `json:"total_revenue"`
|
Amount float64
|
||||||
TotalCost float64 `json:"total_cost"`
|
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
TotalTax float64 `json:"total_tax"`
|
|
||||||
TotalDiscount float64 `json:"total_discount"`
|
|
||||||
NetProfit float64 `json:"net_profit"`
|
|
||||||
NetProfitMargin float64 `json:"net_profit_margin"`
|
|
||||||
TotalOrders int64 `json:"total_orders"`
|
|
||||||
AverageProfit float64 `json:"average_profit"`
|
|
||||||
ProfitabilityRatio float64 `json:"profitability_ratio"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossData represents profit and loss data by time period
|
type OperationalExpenseItem struct {
|
||||||
type ProfitLossData struct {
|
Description string
|
||||||
Date time.Time `json:"date"`
|
Amount float64
|
||||||
Revenue float64 `json:"revenue"`
|
|
||||||
Cost float64 `json:"cost"`
|
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
Tax float64 `json:"tax"`
|
|
||||||
Discount float64 `json:"discount"`
|
|
||||||
NetProfit float64 `json:"net_profit"`
|
|
||||||
NetProfitMargin float64 `json:"net_profit_margin"`
|
|
||||||
Orders int64 `json:"orders"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// ProductProfitData represents profit data for individual products
|
|
||||||
type ProductProfitData struct {
|
|
||||||
ProductID uuid.UUID `json:"product_id"`
|
|
||||||
ProductName string `json:"product_name"`
|
|
||||||
CategoryID uuid.UUID `json:"category_id"`
|
|
||||||
CategoryName string `json:"category_name"`
|
|
||||||
QuantitySold int64 `json:"quantity_sold"`
|
|
||||||
Revenue float64 `json:"revenue"`
|
|
||||||
Cost float64 `json:"cost"`
|
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
AveragePrice float64 `json:"average_price"`
|
|
||||||
AverageCost float64 `json:"average_cost"`
|
|
||||||
ProfitPerUnit float64 `json:"profit_per_unit"`
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -42,6 +42,7 @@ func GetAllEntities() []interface{} {
|
|||||||
&NotificationReceiver{},
|
&NotificationReceiver{},
|
||||||
&NotificationDelivery{},
|
&NotificationDelivery{},
|
||||||
&ProductOutletPrice{},
|
&ProductOutletPrice{},
|
||||||
|
&Expense{},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,40 @@
|
|||||||
|
package entities
|
||||||
|
|
||||||
|
import (
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
|
||||||
|
"gorm.io/gorm"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Expense struct {
|
||||||
|
ID uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()" json:"id"`
|
||||||
|
OrganizationID uuid.UUID `gorm:"type:uuid;not null;index" json:"organization_id"`
|
||||||
|
OutletID uuid.UUID `gorm:"type:uuid;not null;index" json:"outlet_id"`
|
||||||
|
ExpenseName string `gorm:"not null;size:255" json:"expense_name"`
|
||||||
|
Receiver string `gorm:"not null;size:255" json:"receiver"`
|
||||||
|
TransactionDate time.Time `gorm:"type:date;not null" json:"transaction_date"`
|
||||||
|
CodeNumber string `gorm:"not null;size:50" json:"code_number"`
|
||||||
|
Description *string `gorm:"type:text" json:"description"`
|
||||||
|
Tax float64 `gorm:"type:decimal(15,2);not null;default:0" json:"tax"`
|
||||||
|
Total float64 `gorm:"type:decimal(15,2);not null;default:0" json:"total"`
|
||||||
|
Reserved1 *string `gorm:"type:text" json:"reserved1"`
|
||||||
|
CreatedAt time.Time `gorm:"autoCreateTime" json:"created_at"`
|
||||||
|
UpdatedAt time.Time `gorm:"autoUpdateTime" json:"updated_at"`
|
||||||
|
|
||||||
|
Organization *Organization `gorm:"foreignKey:OrganizationID" json:"organization,omitempty"`
|
||||||
|
Outlet *Outlet `gorm:"foreignKey:OutletID" json:"outlet,omitempty"`
|
||||||
|
Items []ExpenseItem `gorm:"foreignKey:ExpenseID" json:"items,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (e *Expense) BeforeCreate(tx *gorm.DB) error {
|
||||||
|
if e.ID == uuid.Nil {
|
||||||
|
e.ID = uuid.New()
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (Expense) TableName() string {
|
||||||
|
return "expenses"
|
||||||
|
}
|
||||||
@@ -0,0 +1,33 @@
|
|||||||
|
package entities
|
||||||
|
|
||||||
|
import (
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
|
||||||
|
"gorm.io/gorm"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ExpenseItem struct {
|
||||||
|
ID uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()" json:"id"`
|
||||||
|
ExpenseID uuid.UUID `gorm:"type:uuid;not null;index" json:"expense_id"`
|
||||||
|
ChartOfAccountID uuid.UUID `gorm:"type:uuid;not null;index" json:"chart_of_account_id"`
|
||||||
|
Description *string `gorm:"type:text" json:"description"`
|
||||||
|
Amount float64 `gorm:"type:decimal(15,2);not null;default:0" json:"amount"`
|
||||||
|
CreatedAt time.Time `gorm:"autoCreateTime" json:"created_at"`
|
||||||
|
UpdatedAt time.Time `gorm:"autoUpdateTime" json:"updated_at"`
|
||||||
|
|
||||||
|
Expense *Expense `gorm:"foreignKey:ExpenseID" json:"expense,omitempty"`
|
||||||
|
ChartOfAccount *ChartOfAccount `gorm:"foreignKey:ChartOfAccountID" json:"chart_of_account,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (e *ExpenseItem) BeforeCreate(tx *gorm.DB) error {
|
||||||
|
if e.ID == uuid.Nil {
|
||||||
|
e.ID = uuid.New()
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (ExpenseItem) TableName() string {
|
||||||
|
return "expense_items"
|
||||||
|
}
|
||||||
@@ -33,7 +33,6 @@ type Product struct {
|
|||||||
ProductRecipes []ProductRecipe `gorm:"foreignKey:ProductID" json:"product_recipes,omitempty"`
|
ProductRecipes []ProductRecipe `gorm:"foreignKey:ProductID" json:"product_recipes,omitempty"`
|
||||||
Inventory []Inventory `gorm:"foreignKey:ProductID" json:"inventory,omitempty"`
|
Inventory []Inventory `gorm:"foreignKey:ProductID" json:"inventory,omitempty"`
|
||||||
OrderItems []OrderItem `gorm:"foreignKey:ProductID" json:"order_items,omitempty"`
|
OrderItems []OrderItem `gorm:"foreignKey:ProductID" json:"order_items,omitempty"`
|
||||||
ProductOutletPrices []ProductOutletPrice `gorm:"foreignKey:ProductID" json:"product_outlet_prices,omitempty"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (p *Product) BeforeCreate(tx *gorm.DB) error {
|
func (p *Product) BeforeCreate(tx *gorm.DB) error {
|
||||||
|
|||||||
@@ -12,7 +12,6 @@ type ProductOutletPrice struct {
|
|||||||
ProductID uuid.UUID `gorm:"type:uuid;not null;index" json:"product_id"`
|
ProductID uuid.UUID `gorm:"type:uuid;not null;index" json:"product_id"`
|
||||||
OutletID uuid.UUID `gorm:"type:uuid;not null;index" json:"outlet_id"`
|
OutletID uuid.UUID `gorm:"type:uuid;not null;index" json:"outlet_id"`
|
||||||
Price float64 `gorm:"type:decimal(10,2);not null" json:"price"`
|
Price float64 `gorm:"type:decimal(10,2);not null" json:"price"`
|
||||||
PrintToChecker bool `gorm:"not null;default:true" json:"print_to_checker"`
|
|
||||||
CreatedAt time.Time `gorm:"autoCreateTime" json:"created_at"`
|
CreatedAt time.Time `gorm:"autoCreateTime" json:"created_at"`
|
||||||
UpdatedAt time.Time `gorm:"autoUpdateTime" json:"updated_at"`
|
UpdatedAt time.Time `gorm:"autoUpdateTime" json:"updated_at"`
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,181 @@
|
|||||||
|
package handler
|
||||||
|
|
||||||
|
import (
|
||||||
|
"apskel-pos-be/internal/appcontext"
|
||||||
|
"apskel-pos-be/internal/util"
|
||||||
|
"strconv"
|
||||||
|
|
||||||
|
"apskel-pos-be/internal/constants"
|
||||||
|
"apskel-pos-be/internal/contract"
|
||||||
|
"apskel-pos-be/internal/logger"
|
||||||
|
"apskel-pos-be/internal/service"
|
||||||
|
"apskel-pos-be/internal/validator"
|
||||||
|
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
|
"github.com/google/uuid"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ExpenseHandler struct {
|
||||||
|
expenseService service.ExpenseService
|
||||||
|
expenseValidator validator.ExpenseValidator
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewExpenseHandler(
|
||||||
|
expenseService service.ExpenseService,
|
||||||
|
expenseValidator validator.ExpenseValidator,
|
||||||
|
) *ExpenseHandler {
|
||||||
|
return &ExpenseHandler{
|
||||||
|
expenseService: expenseService,
|
||||||
|
expenseValidator: expenseValidator,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (h *ExpenseHandler) CreateExpense(c *gin.Context) {
|
||||||
|
ctx := c.Request.Context()
|
||||||
|
contextInfo := appcontext.FromGinContext(ctx)
|
||||||
|
|
||||||
|
var req contract.CreateExpenseRequest
|
||||||
|
if err := c.ShouldBindJSON(&req); err != nil {
|
||||||
|
logger.FromContext(ctx).WithError(err).Error("ExpenseHandler::CreateExpense -> request binding failed")
|
||||||
|
validationResponseError := contract.NewResponseError(constants.MissingFieldErrorCode, constants.RequestEntity, err.Error())
|
||||||
|
util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{validationResponseError}), "ExpenseHandler::CreateExpense")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
validationError, validationErrorCode := h.expenseValidator.ValidateCreateExpenseRequest(&req)
|
||||||
|
if validationError != nil {
|
||||||
|
validationResponseError := contract.NewResponseError(validationErrorCode, constants.RequestEntity, validationError.Error())
|
||||||
|
util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{validationResponseError}), "ExpenseHandler::CreateExpense")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
expenseResponse := h.expenseService.CreateExpense(ctx, contextInfo, &req)
|
||||||
|
if expenseResponse.HasErrors() {
|
||||||
|
errorResp := expenseResponse.GetErrors()[0]
|
||||||
|
logger.FromContext(ctx).WithError(errorResp).Error("ExpenseHandler::CreateExpense -> Failed to create expense from service")
|
||||||
|
}
|
||||||
|
|
||||||
|
util.HandleResponse(c.Writer, c.Request, expenseResponse, "ExpenseHandler::CreateExpense")
|
||||||
|
}
|
||||||
|
|
||||||
|
func (h *ExpenseHandler) UpdateExpense(c *gin.Context) {
|
||||||
|
ctx := c.Request.Context()
|
||||||
|
contextInfo := appcontext.FromGinContext(ctx)
|
||||||
|
|
||||||
|
expenseIDStr := c.Param("id")
|
||||||
|
expenseID, err := uuid.Parse(expenseIDStr)
|
||||||
|
if err != nil {
|
||||||
|
logger.FromContext(ctx).WithError(err).Error("ExpenseHandler::UpdateExpense -> Invalid expense ID")
|
||||||
|
validationResponseError := contract.NewResponseError(constants.MalformedFieldErrorCode, constants.RequestEntity, "Invalid expense ID")
|
||||||
|
util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{validationResponseError}), "ExpenseHandler::UpdateExpense")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
var req contract.UpdateExpenseRequest
|
||||||
|
if err := c.ShouldBindJSON(&req); err != nil {
|
||||||
|
logger.FromContext(ctx).WithError(err).Error("ExpenseHandler::UpdateExpense -> request binding failed")
|
||||||
|
validationResponseError := contract.NewResponseError(constants.MissingFieldErrorCode, constants.RequestEntity, "Invalid request body")
|
||||||
|
util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{validationResponseError}), "ExpenseHandler::UpdateExpense")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
validationError, validationErrorCode := h.expenseValidator.ValidateUpdateExpenseRequest(&req)
|
||||||
|
if validationError != nil {
|
||||||
|
validationResponseError := contract.NewResponseError(validationErrorCode, constants.RequestEntity, validationError.Error())
|
||||||
|
util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{validationResponseError}), "ExpenseHandler::UpdateExpense")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
expenseResponse := h.expenseService.UpdateExpense(ctx, contextInfo, expenseID, &req)
|
||||||
|
if expenseResponse.HasErrors() {
|
||||||
|
errorResp := expenseResponse.GetErrors()[0]
|
||||||
|
logger.FromContext(ctx).WithError(errorResp).Error("ExpenseHandler::UpdateExpense -> Failed to update expense from service")
|
||||||
|
}
|
||||||
|
|
||||||
|
util.HandleResponse(c.Writer, c.Request, expenseResponse, "ExpenseHandler::UpdateExpense")
|
||||||
|
}
|
||||||
|
|
||||||
|
func (h *ExpenseHandler) DeleteExpense(c *gin.Context) {
|
||||||
|
ctx := c.Request.Context()
|
||||||
|
contextInfo := appcontext.FromGinContext(ctx)
|
||||||
|
|
||||||
|
expenseIDStr := c.Param("id")
|
||||||
|
expenseID, err := uuid.Parse(expenseIDStr)
|
||||||
|
if err != nil {
|
||||||
|
logger.FromContext(ctx).WithError(err).Error("ExpenseHandler::DeleteExpense -> Invalid expense ID")
|
||||||
|
validationResponseError := contract.NewResponseError(constants.MalformedFieldErrorCode, constants.RequestEntity, "Invalid expense ID")
|
||||||
|
util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{validationResponseError}), "ExpenseHandler::DeleteExpense")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
expenseResponse := h.expenseService.DeleteExpense(ctx, contextInfo, expenseID)
|
||||||
|
if expenseResponse.HasErrors() {
|
||||||
|
errorResp := expenseResponse.GetErrors()[0]
|
||||||
|
logger.FromContext(ctx).WithError(errorResp).Error("ExpenseHandler::DeleteExpense -> Failed to delete expense from service")
|
||||||
|
}
|
||||||
|
|
||||||
|
util.HandleResponse(c.Writer, c.Request, expenseResponse, "ExpenseHandler::DeleteExpense")
|
||||||
|
}
|
||||||
|
|
||||||
|
func (h *ExpenseHandler) GetExpense(c *gin.Context) {
|
||||||
|
ctx := c.Request.Context()
|
||||||
|
contextInfo := appcontext.FromGinContext(ctx)
|
||||||
|
|
||||||
|
expenseIDStr := c.Param("id")
|
||||||
|
expenseID, err := uuid.Parse(expenseIDStr)
|
||||||
|
if err != nil {
|
||||||
|
logger.FromContext(ctx).WithError(err).Error("ExpenseHandler::GetExpense -> Invalid expense ID")
|
||||||
|
validationResponseError := contract.NewResponseError(constants.MalformedFieldErrorCode, constants.RequestEntity, "Invalid expense ID")
|
||||||
|
util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{validationResponseError}), "ExpenseHandler::GetExpense")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
expenseResponse := h.expenseService.GetExpenseByID(ctx, contextInfo, expenseID)
|
||||||
|
if expenseResponse.HasErrors() {
|
||||||
|
errorResp := expenseResponse.GetErrors()[0]
|
||||||
|
logger.FromContext(ctx).WithError(errorResp).Error("ExpenseHandler::GetExpense -> Failed to get expense from service")
|
||||||
|
}
|
||||||
|
|
||||||
|
util.HandleResponse(c.Writer, c.Request, expenseResponse, "ExpenseHandler::GetExpense")
|
||||||
|
}
|
||||||
|
|
||||||
|
func (h *ExpenseHandler) ListExpenses(c *gin.Context) {
|
||||||
|
ctx := c.Request.Context()
|
||||||
|
contextInfo := appcontext.FromGinContext(ctx)
|
||||||
|
|
||||||
|
req := &contract.ListExpenseRequest{
|
||||||
|
Page: 1,
|
||||||
|
Limit: 10,
|
||||||
|
}
|
||||||
|
|
||||||
|
if pageStr := c.Query("page"); pageStr != "" {
|
||||||
|
if page, err := strconv.Atoi(pageStr); err == nil {
|
||||||
|
req.Page = page
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if limitStr := c.Query("limit"); limitStr != "" {
|
||||||
|
if limit, err := strconv.Atoi(limitStr); err == nil {
|
||||||
|
req.Limit = limit
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if search := c.Query("search"); search != "" {
|
||||||
|
req.Search = search
|
||||||
|
}
|
||||||
|
|
||||||
|
validationError, validationErrorCode := h.expenseValidator.ValidateListExpenseRequest(req)
|
||||||
|
if validationError != nil {
|
||||||
|
validationResponseError := contract.NewResponseError(validationErrorCode, constants.RequestEntity, validationError.Error())
|
||||||
|
util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{validationResponseError}), "ExpenseHandler::ListExpenses")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
expenseResponse := h.expenseService.ListExpenses(ctx, contextInfo, req)
|
||||||
|
if expenseResponse.HasErrors() {
|
||||||
|
errorResp := expenseResponse.GetErrors()[0]
|
||||||
|
logger.FromContext(ctx).WithError(errorResp).Error("ExpenseHandler::ListExpenses -> Failed to list expenses from service")
|
||||||
|
}
|
||||||
|
|
||||||
|
util.HandleResponse(c.Writer, c.Request, expenseResponse, "ExpenseHandler::ListExpenses")
|
||||||
|
}
|
||||||
@@ -0,0 +1,127 @@
|
|||||||
|
package mappers
|
||||||
|
|
||||||
|
import (
|
||||||
|
"apskel-pos-be/internal/entities"
|
||||||
|
"apskel-pos-be/internal/models"
|
||||||
|
)
|
||||||
|
|
||||||
|
func ExpenseEntityToModel(entity *entities.Expense) *models.Expense {
|
||||||
|
if entity == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
return &models.Expense{
|
||||||
|
ID: entity.ID,
|
||||||
|
OrganizationID: entity.OrganizationID,
|
||||||
|
OutletID: entity.OutletID,
|
||||||
|
ExpenseName: entity.ExpenseName,
|
||||||
|
Receiver: entity.Receiver,
|
||||||
|
TransactionDate: entity.TransactionDate,
|
||||||
|
CodeNumber: entity.CodeNumber,
|
||||||
|
Description: entity.Description,
|
||||||
|
Tax: entity.Tax,
|
||||||
|
Total: entity.Total,
|
||||||
|
Reserved1: entity.Reserved1,
|
||||||
|
CreatedAt: entity.CreatedAt,
|
||||||
|
UpdatedAt: entity.UpdatedAt,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExpenseModelToEntity(model *models.Expense) *entities.Expense {
|
||||||
|
if model == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
return &entities.Expense{
|
||||||
|
ID: model.ID,
|
||||||
|
OrganizationID: model.OrganizationID,
|
||||||
|
OutletID: model.OutletID,
|
||||||
|
ExpenseName: model.ExpenseName,
|
||||||
|
Receiver: model.Receiver,
|
||||||
|
TransactionDate: model.TransactionDate,
|
||||||
|
CodeNumber: model.CodeNumber,
|
||||||
|
Description: model.Description,
|
||||||
|
Tax: model.Tax,
|
||||||
|
Total: model.Total,
|
||||||
|
Reserved1: model.Reserved1,
|
||||||
|
CreatedAt: model.CreatedAt,
|
||||||
|
UpdatedAt: model.UpdatedAt,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExpenseEntityToResponse(entity *entities.Expense) *models.ExpenseResponse {
|
||||||
|
if entity == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
resp := &models.ExpenseResponse{
|
||||||
|
ID: entity.ID,
|
||||||
|
OrganizationID: entity.OrganizationID,
|
||||||
|
OutletID: entity.OutletID,
|
||||||
|
ExpenseName: entity.ExpenseName,
|
||||||
|
Receiver: entity.Receiver,
|
||||||
|
TransactionDate: entity.TransactionDate,
|
||||||
|
CodeNumber: entity.CodeNumber,
|
||||||
|
Description: entity.Description,
|
||||||
|
Tax: entity.Tax,
|
||||||
|
Total: entity.Total,
|
||||||
|
Reserved1: entity.Reserved1,
|
||||||
|
CreatedAt: entity.CreatedAt,
|
||||||
|
UpdatedAt: entity.UpdatedAt,
|
||||||
|
}
|
||||||
|
|
||||||
|
if entity.Items != nil {
|
||||||
|
resp.Items = ExpenseItemEntitiesToResponses(entity.Items)
|
||||||
|
}
|
||||||
|
|
||||||
|
return resp
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExpenseEntitiesToResponses(entities []*entities.Expense) []*models.ExpenseResponse {
|
||||||
|
if entities == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
responses := make([]*models.ExpenseResponse, len(entities))
|
||||||
|
for i, entity := range entities {
|
||||||
|
responses[i] = ExpenseEntityToResponse(entity)
|
||||||
|
}
|
||||||
|
return responses
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExpenseItemEntityToResponse(entity *entities.ExpenseItem) *models.ExpenseItemResponse {
|
||||||
|
if entity == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
response := &models.ExpenseItemResponse{
|
||||||
|
ID: entity.ID,
|
||||||
|
ExpenseID: entity.ExpenseID,
|
||||||
|
ChartOfAccountID: entity.ChartOfAccountID,
|
||||||
|
Description: entity.Description,
|
||||||
|
Amount: entity.Amount,
|
||||||
|
CreatedAt: entity.CreatedAt,
|
||||||
|
UpdatedAt: entity.UpdatedAt,
|
||||||
|
}
|
||||||
|
|
||||||
|
if entity.ChartOfAccount != nil {
|
||||||
|
response.ChartOfAccountName = entity.ChartOfAccount.Name
|
||||||
|
}
|
||||||
|
|
||||||
|
return response
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExpenseItemEntitiesToResponses(entities []entities.ExpenseItem) []models.ExpenseItemResponse {
|
||||||
|
if entities == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
responses := make([]models.ExpenseItemResponse, len(entities))
|
||||||
|
for i, entity := range entities {
|
||||||
|
response := ExpenseItemEntityToResponse(&entity)
|
||||||
|
if response != nil {
|
||||||
|
responses[i] = *response
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return responses
|
||||||
|
}
|
||||||
@@ -82,7 +82,7 @@ func OrderEntityToResponse(order *entities.Order) *models.OrderResponse {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for i, item := range order.OrderItems {
|
for i, item := range order.OrderItems {
|
||||||
resp := OrderItemEntityToResponse(&item, order.OutletID)
|
resp := OrderItemEntityToResponse(&item)
|
||||||
if resp != nil {
|
if resp != nil {
|
||||||
resp.PaidQuantity = paidQtyByOrderItem[item.ID]
|
resp.PaidQuantity = paidQtyByOrderItem[item.ID]
|
||||||
response.OrderItems[i] = *resp
|
response.OrderItems[i] = *resp
|
||||||
@@ -101,20 +101,11 @@ func OrderEntityToResponse(order *entities.Order) *models.OrderResponse {
|
|||||||
return response
|
return response
|
||||||
}
|
}
|
||||||
|
|
||||||
func OrderItemEntityToResponse(item *entities.OrderItem, outletID uuid.UUID) *models.OrderItemResponse {
|
func OrderItemEntityToResponse(item *entities.OrderItem) *models.OrderItemResponse {
|
||||||
if item == nil {
|
if item == nil {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Resolve print_to_checker from preloaded outlet prices
|
|
||||||
printToChecker := true // default
|
|
||||||
for _, op := range item.Product.ProductOutletPrices {
|
|
||||||
if op.OutletID == outletID {
|
|
||||||
printToChecker = op.PrintToChecker
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
response := &models.OrderItemResponse{
|
response := &models.OrderItemResponse{
|
||||||
ID: item.ID,
|
ID: item.ID,
|
||||||
OrderID: item.OrderID,
|
OrderID: item.OrderID,
|
||||||
@@ -139,19 +130,10 @@ func OrderItemEntityToResponse(item *entities.OrderItem, outletID uuid.UUID) *mo
|
|||||||
CreatedAt: item.CreatedAt,
|
CreatedAt: item.CreatedAt,
|
||||||
UpdatedAt: item.UpdatedAt,
|
UpdatedAt: item.UpdatedAt,
|
||||||
PrinterType: item.Product.PrinterType,
|
PrinterType: item.Product.PrinterType,
|
||||||
PrintToChecker: printToChecker,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if item.Product.ID != uuid.Nil {
|
if item.Product.ID != uuid.Nil {
|
||||||
response.ProductName = item.Product.Name
|
response.ProductName = item.Product.Name
|
||||||
if item.Product.CategoryID != uuid.Nil {
|
|
||||||
categoryID := item.Product.CategoryID
|
|
||||||
response.CategoryID = &categoryID
|
|
||||||
}
|
|
||||||
if item.Product.Category.ID != uuid.Nil {
|
|
||||||
categoryName := item.Product.Category.Name
|
|
||||||
response.CategoryName = &categoryName
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if item.ProductVariant != nil {
|
if item.ProductVariant != nil {
|
||||||
@@ -334,14 +316,14 @@ func OrderEntitiesToResponses(orders []*entities.Order) []models.OrderResponse {
|
|||||||
return responses
|
return responses
|
||||||
}
|
}
|
||||||
|
|
||||||
func OrderItemEntitiesToResponses(items []*entities.OrderItem, outletID uuid.UUID) []models.OrderItemResponse {
|
func OrderItemEntitiesToResponses(items []*entities.OrderItem) []models.OrderItemResponse {
|
||||||
if items == nil {
|
if items == nil {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
responses := make([]models.OrderItemResponse, len(items))
|
responses := make([]models.OrderItemResponse, len(items))
|
||||||
for i, item := range items {
|
for i, item := range items {
|
||||||
response := OrderItemEntityToResponse(item, outletID)
|
response := OrderItemEntityToResponse(item)
|
||||||
if response != nil {
|
if response != nil {
|
||||||
responses[i] = *response
|
responses[i] = *response
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -45,7 +45,7 @@ func TestOrderItemEntityToResponse_WithProductNames(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Act
|
// Act
|
||||||
result := OrderItemEntityToResponse(orderItem, uuid.Nil)
|
result := OrderItemEntityToResponse(orderItem)
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
assert.NotNil(t, result)
|
assert.NotNil(t, result)
|
||||||
@@ -89,7 +89,7 @@ func TestOrderItemEntityToResponse_WithoutProductVariant(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Act
|
// Act
|
||||||
result := OrderItemEntityToResponse(orderItem, uuid.Nil)
|
result := OrderItemEntityToResponse(orderItem)
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
assert.NotNil(t, result)
|
assert.NotNil(t, result)
|
||||||
@@ -129,7 +129,7 @@ func TestOrderItemEntityToResponse_WithoutProductPreload(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Act
|
// Act
|
||||||
result := OrderItemEntityToResponse(orderItem, uuid.Nil)
|
result := OrderItemEntityToResponse(orderItem)
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
assert.NotNil(t, result)
|
assert.NotNil(t, result)
|
||||||
|
|||||||
@@ -15,7 +15,6 @@ func ProductOutletPriceEntityToModel(entity *entities.ProductOutletPrice) *model
|
|||||||
ProductID: entity.ProductID,
|
ProductID: entity.ProductID,
|
||||||
OutletID: entity.OutletID,
|
OutletID: entity.OutletID,
|
||||||
Price: entity.Price,
|
Price: entity.Price,
|
||||||
PrintToChecker: entity.PrintToChecker,
|
|
||||||
CreatedAt: entity.CreatedAt,
|
CreatedAt: entity.CreatedAt,
|
||||||
UpdatedAt: entity.UpdatedAt,
|
UpdatedAt: entity.UpdatedAt,
|
||||||
}
|
}
|
||||||
@@ -31,7 +30,6 @@ func ProductOutletPriceModelToEntity(model *models.ProductOutletPrice) *entities
|
|||||||
ProductID: model.ProductID,
|
ProductID: model.ProductID,
|
||||||
OutletID: model.OutletID,
|
OutletID: model.OutletID,
|
||||||
Price: model.Price,
|
Price: model.Price,
|
||||||
PrintToChecker: model.PrintToChecker,
|
|
||||||
CreatedAt: model.CreatedAt,
|
CreatedAt: model.CreatedAt,
|
||||||
UpdatedAt: model.UpdatedAt,
|
UpdatedAt: model.UpdatedAt,
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -246,68 +246,33 @@ type DashboardOverview struct {
|
|||||||
RefundedOrders int64 `json:"refunded_orders"`
|
RefundedOrders int64 `json:"refunded_orders"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossAnalyticsRequest represents the request for profit and loss analytics
|
|
||||||
type ProfitLossAnalyticsRequest struct {
|
type ProfitLossAnalyticsRequest struct {
|
||||||
OrganizationID uuid.UUID `validate:"required"`
|
OrganizationID uuid.UUID `validate:"required"`
|
||||||
OutletID *uuid.UUID `validate:"omitempty"`
|
OutletID *uuid.UUID `validate:"omitempty"`
|
||||||
DateFrom time.Time `validate:"required"`
|
Date time.Time `validate:"required"`
|
||||||
DateTo time.Time `validate:"required"`
|
|
||||||
GroupBy string `validate:"omitempty,oneof=day hour week month"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossAnalyticsResponse represents the response for profit and loss analytics
|
|
||||||
type ProfitLossAnalyticsResponse struct {
|
type ProfitLossAnalyticsResponse struct {
|
||||||
OrganizationID uuid.UUID `json:"organization_id"`
|
OrganizationID uuid.UUID `json:"organization_id"`
|
||||||
OutletID *uuid.UUID `json:"outlet_id,omitempty"`
|
OutletID *uuid.UUID `json:"outlet_id,omitempty"`
|
||||||
DateFrom time.Time `json:"date_from"`
|
|
||||||
DateTo time.Time `json:"date_to"`
|
|
||||||
GroupBy string `json:"group_by"`
|
|
||||||
Summary ProfitLossSummary `json:"summary"`
|
|
||||||
Data []ProfitLossData `json:"data"`
|
|
||||||
ProductData []ProductProfitData `json:"product_data"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// ProfitLossSummary represents the summary of profit and loss analytics
|
|
||||||
type ProfitLossSummary struct {
|
|
||||||
TotalRevenue float64 `json:"total_revenue"`
|
|
||||||
TotalCost float64 `json:"total_cost"`
|
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
TotalTax float64 `json:"total_tax"`
|
|
||||||
TotalDiscount float64 `json:"total_discount"`
|
|
||||||
NetProfit float64 `json:"net_profit"`
|
|
||||||
NetProfitMargin float64 `json:"net_profit_margin"`
|
|
||||||
TotalOrders int64 `json:"total_orders"`
|
|
||||||
AverageProfit float64 `json:"average_profit"`
|
|
||||||
ProfitabilityRatio float64 `json:"profitability_ratio"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// ProfitLossData represents individual profit and loss data point by time period
|
|
||||||
type ProfitLossData struct {
|
|
||||||
Date time.Time `json:"date"`
|
Date time.Time `json:"date"`
|
||||||
Revenue float64 `json:"revenue"`
|
MainSummary []ProfitLossSummaryRow `json:"main_summary"`
|
||||||
Cost float64 `json:"cost"`
|
OperationalExpenses []OperationalExpenseItem `json:"operational_expenses"`
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
OperationalExpensesTotal float64 `json:"operational_expenses_total"`
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
Tax float64 `json:"tax"`
|
|
||||||
Discount float64 `json:"discount"`
|
|
||||||
NetProfit float64 `json:"net_profit"`
|
|
||||||
NetProfitMargin float64 `json:"net_profit_margin"`
|
|
||||||
Orders int64 `json:"orders"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProductProfitData represents profit data for individual products
|
type ProfitLossSummaryRow struct {
|
||||||
type ProductProfitData struct {
|
ID string `json:"id"`
|
||||||
ProductID uuid.UUID `json:"product_id"`
|
Label string `json:"label"`
|
||||||
ProductName string `json:"product_name"`
|
IsBold bool `json:"is_bold"`
|
||||||
CategoryID uuid.UUID `json:"category_id"`
|
TodayNominal float64 `json:"today_nominal"`
|
||||||
CategoryName string `json:"category_name"`
|
TodayPct float64 `json:"today_pct"`
|
||||||
QuantitySold int64 `json:"quantity_sold"`
|
MtdNominal float64 `json:"mtd_nominal"`
|
||||||
Revenue float64 `json:"revenue"`
|
MtdPct float64 `json:"mtd_pct"`
|
||||||
Cost float64 `json:"cost"`
|
SubItems []ProfitLossSummaryRow `json:"sub_items,omitempty"`
|
||||||
GrossProfit float64 `json:"gross_profit"`
|
}
|
||||||
GrossProfitMargin float64 `json:"gross_profit_margin"`
|
|
||||||
AveragePrice float64 `json:"average_price"`
|
type OperationalExpenseItem struct {
|
||||||
AverageCost float64 `json:"average_cost"`
|
Item string `json:"item"`
|
||||||
ProfitPerUnit float64 `json:"profit_per_unit"`
|
Nominal float64 `json:"nominal"`
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,112 @@
|
|||||||
|
package models
|
||||||
|
|
||||||
|
import (
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Expense struct {
|
||||||
|
ID uuid.UUID `json:"id"`
|
||||||
|
OrganizationID uuid.UUID `json:"organization_id"`
|
||||||
|
OutletID uuid.UUID `json:"outlet_id"`
|
||||||
|
ExpenseName string `json:"expense_name"`
|
||||||
|
Receiver string `json:"receiver"`
|
||||||
|
TransactionDate time.Time `json:"transaction_date"`
|
||||||
|
CodeNumber string `json:"code_number"`
|
||||||
|
Description *string `json:"description"`
|
||||||
|
Tax float64 `json:"tax"`
|
||||||
|
Total float64 `json:"total"`
|
||||||
|
Reserved1 *string `json:"reserved1"`
|
||||||
|
CreatedAt time.Time `json:"created_at"`
|
||||||
|
UpdatedAt time.Time `json:"updated_at"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ExpenseItem struct {
|
||||||
|
ID uuid.UUID `json:"id"`
|
||||||
|
ExpenseID uuid.UUID `json:"expense_id"`
|
||||||
|
ChartOfAccountID uuid.UUID `json:"chart_of_account_id"`
|
||||||
|
Description *string `json:"description"`
|
||||||
|
Amount float64 `json:"amount"`
|
||||||
|
CreatedAt time.Time `json:"created_at"`
|
||||||
|
UpdatedAt time.Time `json:"updated_at"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ExpenseResponse struct {
|
||||||
|
ID uuid.UUID `json:"id"`
|
||||||
|
OrganizationID uuid.UUID `json:"organization_id"`
|
||||||
|
OutletID uuid.UUID `json:"outlet_id"`
|
||||||
|
ExpenseName string `json:"expense_name"`
|
||||||
|
Receiver string `json:"receiver"`
|
||||||
|
TransactionDate time.Time `json:"transaction_date"`
|
||||||
|
CodeNumber string `json:"code_number"`
|
||||||
|
Description *string `json:"description"`
|
||||||
|
Tax float64 `json:"tax"`
|
||||||
|
Total float64 `json:"total"`
|
||||||
|
Reserved1 *string `json:"reserved1"`
|
||||||
|
CreatedAt time.Time `json:"created_at"`
|
||||||
|
UpdatedAt time.Time `json:"updated_at"`
|
||||||
|
Items []ExpenseItemResponse `json:"items,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ExpenseItemResponse struct {
|
||||||
|
ID uuid.UUID `json:"id"`
|
||||||
|
ExpenseID uuid.UUID `json:"expense_id"`
|
||||||
|
ChartOfAccountID uuid.UUID `json:"chart_of_account_id"`
|
||||||
|
ChartOfAccountName string `json:"chart_of_account_name,omitempty"`
|
||||||
|
Description *string `json:"description"`
|
||||||
|
Amount float64 `json:"amount"`
|
||||||
|
CreatedAt time.Time `json:"created_at"`
|
||||||
|
UpdatedAt time.Time `json:"updated_at"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type CreateExpenseRequest struct {
|
||||||
|
ExpenseName string `json:"expense_name"`
|
||||||
|
Receiver string `json:"receiver"`
|
||||||
|
TransactionDate string `json:"transaction_date"`
|
||||||
|
CodeNumber string `json:"code_number"`
|
||||||
|
OutletID string `json:"outlet_id"`
|
||||||
|
Description *string `json:"description"`
|
||||||
|
Tax float64 `json:"tax"`
|
||||||
|
Total float64 `json:"total"`
|
||||||
|
Items []CreateExpenseItemRequest `json:"items"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type CreateExpenseItemRequest struct {
|
||||||
|
ChartOfAccountID string `json:"chart_of_account_id"`
|
||||||
|
Description *string `json:"description,omitempty"`
|
||||||
|
Amount float64 `json:"amount"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type UpdateExpenseRequest struct {
|
||||||
|
ExpenseName *string `json:"expense_name,omitempty"`
|
||||||
|
Receiver *string `json:"receiver,omitempty"`
|
||||||
|
TransactionDate *string `json:"transaction_date,omitempty"`
|
||||||
|
CodeNumber *string `json:"code_number,omitempty"`
|
||||||
|
OutletID *string `json:"outlet_id,omitempty"`
|
||||||
|
Description *string `json:"description,omitempty"`
|
||||||
|
Tax *float64 `json:"tax,omitempty"`
|
||||||
|
Total *float64 `json:"total,omitempty"`
|
||||||
|
Reserved1 *string `json:"reserved1,omitempty"`
|
||||||
|
Items []UpdateExpenseItemRequest `json:"items,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type UpdateExpenseItemRequest struct {
|
||||||
|
ChartOfAccountID *string `json:"chart_of_account_id,omitempty"`
|
||||||
|
Description *string `json:"description,omitempty"`
|
||||||
|
Amount *float64 `json:"amount,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ListExpenseRequest struct {
|
||||||
|
Page int `json:"page"`
|
||||||
|
Limit int `json:"limit"`
|
||||||
|
Search string `json:"search,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ListExpenseResponse struct {
|
||||||
|
Expenses []*ExpenseResponse `json:"expenses"`
|
||||||
|
TotalCount int `json:"total_count"`
|
||||||
|
Page int `json:"page"`
|
||||||
|
Limit int `json:"limit"`
|
||||||
|
TotalPages int `json:"total_pages"`
|
||||||
|
}
|
||||||
@@ -188,8 +188,6 @@ type OrderItemResponse struct {
|
|||||||
ProductName string
|
ProductName string
|
||||||
ProductVariantID *uuid.UUID
|
ProductVariantID *uuid.UUID
|
||||||
ProductVariantName *string
|
ProductVariantName *string
|
||||||
CategoryID *uuid.UUID
|
|
||||||
CategoryName *string
|
|
||||||
Quantity int
|
Quantity int
|
||||||
UnitPrice float64
|
UnitPrice float64
|
||||||
TotalPrice float64
|
TotalPrice float64
|
||||||
@@ -209,7 +207,6 @@ type OrderItemResponse struct {
|
|||||||
CreatedAt time.Time
|
CreatedAt time.Time
|
||||||
UpdatedAt time.Time
|
UpdatedAt time.Time
|
||||||
PrinterType string
|
PrinterType string
|
||||||
PrintToChecker bool
|
|
||||||
PaidQuantity int
|
PaidQuantity int
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -50,7 +50,6 @@ type CreateProductRequest struct {
|
|||||||
BusinessType constants.BusinessType `validate:"required"`
|
BusinessType constants.BusinessType `validate:"required"`
|
||||||
ImageURL *string `validate:"omitempty,max=500"`
|
ImageURL *string `validate:"omitempty,max=500"`
|
||||||
PrinterType *string `validate:"omitempty,max=50"`
|
PrinterType *string `validate:"omitempty,max=50"`
|
||||||
PrintToChecker *bool `validate:"omitempty"`
|
|
||||||
UnitID *uuid.UUID `validate:"omitempty"`
|
UnitID *uuid.UUID `validate:"omitempty"`
|
||||||
HasIngredients bool `validate:"omitempty"`
|
HasIngredients bool `validate:"omitempty"`
|
||||||
Metadata map[string]interface{}
|
Metadata map[string]interface{}
|
||||||
@@ -71,7 +70,6 @@ type UpdateProductRequest struct {
|
|||||||
Cost *float64 `validate:"omitempty,min=0"`
|
Cost *float64 `validate:"omitempty,min=0"`
|
||||||
ImageURL *string `validate:"omitempty,max=500"`
|
ImageURL *string `validate:"omitempty,max=500"`
|
||||||
PrinterType *string `validate:"omitempty,max=50"`
|
PrinterType *string `validate:"omitempty,max=50"`
|
||||||
PrintToChecker *bool `validate:"omitempty"`
|
|
||||||
UnitID *uuid.UUID `validate:"omitempty"`
|
UnitID *uuid.UUID `validate:"omitempty"`
|
||||||
HasIngredients *bool `validate:"omitempty"`
|
HasIngredients *bool `validate:"omitempty"`
|
||||||
Metadata map[string]interface{}
|
Metadata map[string]interface{}
|
||||||
@@ -110,7 +108,6 @@ type ProductResponse struct {
|
|||||||
BusinessType constants.BusinessType
|
BusinessType constants.BusinessType
|
||||||
ImageURL *string
|
ImageURL *string
|
||||||
PrinterType string
|
PrinterType string
|
||||||
PrintToChecker bool
|
|
||||||
UnitID *uuid.UUID
|
UnitID *uuid.UUID
|
||||||
HasIngredients bool
|
HasIngredients bool
|
||||||
Metadata map[string]interface{}
|
Metadata map[string]interface{}
|
||||||
@@ -124,7 +121,6 @@ type OutletPrice struct {
|
|||||||
OutletID uuid.UUID
|
OutletID uuid.UUID
|
||||||
OutletName string
|
OutletName string
|
||||||
Price float64
|
Price float64
|
||||||
PrintToChecker bool
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type ProductVariantResponse struct {
|
type ProductVariantResponse struct {
|
||||||
|
|||||||
@@ -11,7 +11,6 @@ type ProductOutletPrice struct {
|
|||||||
ProductID uuid.UUID
|
ProductID uuid.UUID
|
||||||
OutletID uuid.UUID
|
OutletID uuid.UUID
|
||||||
Price float64
|
Price float64
|
||||||
PrintToChecker bool
|
|
||||||
CreatedAt time.Time
|
CreatedAt time.Time
|
||||||
UpdatedAt time.Time
|
UpdatedAt time.Time
|
||||||
}
|
}
|
||||||
@@ -20,12 +19,10 @@ type CreateProductOutletPriceRequest struct {
|
|||||||
ProductID uuid.UUID `validate:"required"`
|
ProductID uuid.UUID `validate:"required"`
|
||||||
OutletID uuid.UUID `validate:"required"`
|
OutletID uuid.UUID `validate:"required"`
|
||||||
Price float64 `validate:"required,min=0"`
|
Price float64 `validate:"required,min=0"`
|
||||||
PrintToChecker bool
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type UpdateProductOutletPriceRequest struct {
|
type UpdateProductOutletPriceRequest struct {
|
||||||
Price *float64 `validate:"required,min=0"`
|
Price *float64 `validate:"required,min=0"`
|
||||||
PrintToChecker *bool
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type ProductOutletPriceResponse struct {
|
type ProductOutletPriceResponse struct {
|
||||||
|
|||||||
@@ -3,8 +3,10 @@ package processor
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"apskel-pos-be/internal/entities"
|
||||||
"apskel-pos-be/internal/models"
|
"apskel-pos-be/internal/models"
|
||||||
"apskel-pos-be/internal/repository"
|
"apskel-pos-be/internal/repository"
|
||||||
)
|
)
|
||||||
@@ -21,11 +23,13 @@ type AnalyticsProcessor interface {
|
|||||||
|
|
||||||
type AnalyticsProcessorImpl struct {
|
type AnalyticsProcessorImpl struct {
|
||||||
analyticsRepo repository.AnalyticsRepository
|
analyticsRepo repository.AnalyticsRepository
|
||||||
|
expenseRepo ExpenseRepository
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewAnalyticsProcessorImpl(analyticsRepo repository.AnalyticsRepository) *AnalyticsProcessorImpl {
|
func NewAnalyticsProcessorImpl(analyticsRepo repository.AnalyticsRepository, expenseRepo ExpenseRepository) *AnalyticsProcessorImpl {
|
||||||
return &AnalyticsProcessorImpl{
|
return &AnalyticsProcessorImpl{
|
||||||
analyticsRepo: analyticsRepo,
|
analyticsRepo: analyticsRepo,
|
||||||
|
expenseRepo: expenseRepo,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -394,71 +398,127 @@ func (p *AnalyticsProcessorImpl) GetDashboardAnalytics(ctx context.Context, req
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (p *AnalyticsProcessorImpl) GetProfitLossAnalytics(ctx context.Context, req *models.ProfitLossAnalyticsRequest) (*models.ProfitLossAnalyticsResponse, error) {
|
func (p *AnalyticsProcessorImpl) GetProfitLossAnalytics(ctx context.Context, req *models.ProfitLossAnalyticsRequest) (*models.ProfitLossAnalyticsResponse, error) {
|
||||||
if req.DateFrom.After(req.DateTo) {
|
if req.Date.IsZero() {
|
||||||
return nil, fmt.Errorf("date_from cannot be after date_to")
|
return nil, fmt.Errorf("date is required")
|
||||||
}
|
}
|
||||||
|
|
||||||
// Get analytics data from repository
|
result, err := p.analyticsRepo.GetProfitLossAnalytics(ctx, req.OrganizationID, req.OutletID, req.Date)
|
||||||
result, err := p.analyticsRepo.GetProfitLossAnalytics(ctx, req.OrganizationID, req.OutletID, req.DateFrom, req.DateTo, req.GroupBy)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("failed to get profit/loss analytics: %w", err)
|
return nil, fmt.Errorf("failed to get profit/loss analytics: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Transform entities to models
|
todayPromosi := getExpenseAmountByCategory(result.TodayExpenseByCategory, "promosi")
|
||||||
data := make([]models.ProfitLossData, len(result.Data))
|
todayLainLain := getExpenseAmountByCategory(result.TodayExpenseByCategory, "lain")
|
||||||
for i, item := range result.Data {
|
todayTotalOps := todayPromosi + todayLainLain
|
||||||
data[i] = models.ProfitLossData{
|
todayGaji := getExpenseAmountByCategory(result.TodayExpenseByCategory, "gaji")
|
||||||
Date: item.Date,
|
|
||||||
Revenue: item.Revenue,
|
mtdPromosi := getExpenseAmountByCategory(result.MtdExpenseByCategory, "promosi")
|
||||||
Cost: item.Cost,
|
mtdLainLain := getExpenseAmountByCategory(result.MtdExpenseByCategory, "lain")
|
||||||
GrossProfit: item.GrossProfit,
|
mtdTotalOps := mtdPromosi + mtdLainLain
|
||||||
GrossProfitMargin: item.GrossProfitMargin,
|
mtdGaji := getExpenseAmountByCategory(result.MtdExpenseByCategory, "gaji")
|
||||||
Tax: item.Tax,
|
|
||||||
Discount: item.Discount,
|
todayGrossProfit := result.TodayRevenue - result.TodayCost
|
||||||
NetProfit: item.NetProfit,
|
mtdGrossProfit := result.MtdRevenue - result.MtdCost
|
||||||
NetProfitMargin: item.NetProfitMargin,
|
|
||||||
Orders: item.Orders,
|
todayProfitBeforeGaji := todayGrossProfit - todayTotalOps
|
||||||
|
mtdProfitBeforeGaji := mtdGrossProfit - mtdTotalOps
|
||||||
|
|
||||||
|
todayNetProfit := todayProfitBeforeGaji - todayGaji
|
||||||
|
mtdNetProfit := mtdProfitBeforeGaji - mtdGaji
|
||||||
|
|
||||||
|
todayPct := func(nominal float64) float64 {
|
||||||
|
if result.TodayRevenue == 0 {
|
||||||
|
return 0
|
||||||
}
|
}
|
||||||
|
return (nominal / result.TodayRevenue) * 100
|
||||||
|
}
|
||||||
|
mtdPct := func(nominal float64) float64 {
|
||||||
|
if result.MtdRevenue == 0 {
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
return (nominal / result.MtdRevenue) * 100
|
||||||
}
|
}
|
||||||
|
|
||||||
productData := make([]models.ProductProfitData, len(result.ProductData))
|
mainSummary := []models.ProfitLossSummaryRow{
|
||||||
for i, item := range result.ProductData {
|
{
|
||||||
productData[i] = models.ProductProfitData{
|
ID: "total_omset", Label: "TOTAL OMSET",
|
||||||
ProductID: item.ProductID,
|
TodayNominal: result.TodayRevenue, TodayPct: todayPct(result.TodayRevenue),
|
||||||
ProductName: item.ProductName,
|
MtdNominal: result.MtdRevenue, MtdPct: mtdPct(result.MtdRevenue),
|
||||||
CategoryID: item.CategoryID,
|
},
|
||||||
CategoryName: item.CategoryName,
|
{
|
||||||
QuantitySold: item.QuantitySold,
|
ID: "hpp", Label: "HPP",
|
||||||
Revenue: item.Revenue,
|
TodayNominal: result.TodayCost, TodayPct: todayPct(result.TodayCost),
|
||||||
Cost: item.Cost,
|
MtdNominal: result.MtdCost, MtdPct: mtdPct(result.MtdCost),
|
||||||
GrossProfit: item.GrossProfit,
|
},
|
||||||
GrossProfitMargin: item.GrossProfitMargin,
|
{
|
||||||
AveragePrice: item.AveragePrice,
|
ID: "laba_kotor", Label: "Laba Kotor (1-2)",
|
||||||
AverageCost: item.AverageCost,
|
TodayNominal: todayGrossProfit, TodayPct: todayPct(todayGrossProfit),
|
||||||
ProfitPerUnit: item.ProfitPerUnit,
|
MtdNominal: mtdGrossProfit, MtdPct: mtdPct(mtdGrossProfit),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
ID: "biaya_ops", Label: "BIAYA OPS",
|
||||||
|
TodayNominal: todayTotalOps, TodayPct: todayPct(todayTotalOps),
|
||||||
|
MtdNominal: mtdTotalOps, MtdPct: mtdPct(mtdTotalOps),
|
||||||
|
SubItems: []models.ProfitLossSummaryRow{
|
||||||
|
{
|
||||||
|
ID: "by_promosi", Label: "1. By Promosi",
|
||||||
|
TodayNominal: todayPromosi, TodayPct: todayPct(todayPromosi),
|
||||||
|
MtdNominal: mtdPromosi, MtdPct: mtdPct(mtdPromosi),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
ID: "by_lain_lain", Label: "2. By Lain lain",
|
||||||
|
TodayNominal: todayLainLain, TodayPct: todayPct(todayLainLain),
|
||||||
|
MtdNominal: mtdLainLain, MtdPct: mtdPct(mtdLainLain),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
ID: "total_biaya_ops", Label: "Total Biaya OPS (4.1+4.2)", IsBold: true,
|
||||||
|
TodayNominal: todayTotalOps, TodayPct: todayPct(todayTotalOps),
|
||||||
|
MtdNominal: mtdTotalOps, MtdPct: mtdPct(mtdTotalOps),
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
ID: "laba_rugi_sblm_gaji", Label: "Laba/Rugi sblm Gaji (3-4)",
|
||||||
|
TodayNominal: todayProfitBeforeGaji, TodayPct: todayPct(todayProfitBeforeGaji),
|
||||||
|
MtdNominal: mtdProfitBeforeGaji, MtdPct: mtdPct(mtdProfitBeforeGaji),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
ID: "biaya_gaji", Label: "BIAYA GAJI",
|
||||||
|
TodayNominal: todayGaji, TodayPct: todayPct(todayGaji),
|
||||||
|
MtdNominal: mtdGaji, MtdPct: mtdPct(mtdGaji),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
ID: "laba_rugi", Label: "Laba/Rugi (5-6)", IsBold: true,
|
||||||
|
TodayNominal: todayNetProfit, TodayPct: todayPct(todayNetProfit),
|
||||||
|
MtdNominal: mtdNetProfit, MtdPct: mtdPct(mtdNetProfit),
|
||||||
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
|
opsItems := make([]models.OperationalExpenseItem, len(result.OperationalExpenseItems))
|
||||||
|
var opsTotal float64
|
||||||
|
for i, item := range result.OperationalExpenseItems {
|
||||||
|
opsItems[i] = models.OperationalExpenseItem{
|
||||||
|
Item: item.Description,
|
||||||
|
Nominal: item.Amount,
|
||||||
|
}
|
||||||
|
opsTotal += item.Amount
|
||||||
}
|
}
|
||||||
|
|
||||||
return &models.ProfitLossAnalyticsResponse{
|
return &models.ProfitLossAnalyticsResponse{
|
||||||
OrganizationID: req.OrganizationID,
|
OrganizationID: req.OrganizationID,
|
||||||
OutletID: req.OutletID,
|
OutletID: req.OutletID,
|
||||||
DateFrom: req.DateFrom,
|
Date: req.Date,
|
||||||
DateTo: req.DateTo,
|
MainSummary: mainSummary,
|
||||||
GroupBy: req.GroupBy,
|
OperationalExpenses: opsItems,
|
||||||
Summary: models.ProfitLossSummary{
|
OperationalExpensesTotal: opsTotal,
|
||||||
TotalRevenue: result.Summary.TotalRevenue,
|
|
||||||
TotalCost: result.Summary.TotalCost,
|
|
||||||
GrossProfit: result.Summary.GrossProfit,
|
|
||||||
GrossProfitMargin: result.Summary.GrossProfitMargin,
|
|
||||||
TotalTax: result.Summary.TotalTax,
|
|
||||||
TotalDiscount: result.Summary.TotalDiscount,
|
|
||||||
NetProfit: result.Summary.NetProfit,
|
|
||||||
NetProfitMargin: result.Summary.NetProfitMargin,
|
|
||||||
TotalOrders: result.Summary.TotalOrders,
|
|
||||||
AverageProfit: result.Summary.AverageProfit,
|
|
||||||
ProfitabilityRatio: result.Summary.ProfitabilityRatio,
|
|
||||||
},
|
|
||||||
Data: data,
|
|
||||||
ProductData: productData,
|
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func getExpenseAmountByCategory(categories []entities.ExpenseCategoryTotal, keyword string) float64 {
|
||||||
|
for _, cat := range categories {
|
||||||
|
if strings.Contains(strings.ToLower(cat.CategoryName), keyword) {
|
||||||
|
return cat.Amount
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
|||||||
@@ -40,10 +40,27 @@ func (analyticsRepositoryStub) GetDashboardOverview(context.Context, uuid.UUID,
|
|||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (analyticsRepositoryStub) GetProfitLossAnalytics(context.Context, uuid.UUID, *uuid.UUID, time.Time, time.Time, string) (*entities.ProfitLossAnalytics, error) {
|
func (analyticsRepositoryStub) GetProfitLossAnalytics(context.Context, uuid.UUID, *uuid.UUID, time.Time) (*entities.ProfitLossAnalytics, error) {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type expenseRepositoryStub struct{}
|
||||||
|
|
||||||
|
func (expenseRepositoryStub) Create(context.Context, *entities.Expense) error { return nil }
|
||||||
|
func (expenseRepositoryStub) GetByID(context.Context, uuid.UUID) (*entities.Expense, error) {
|
||||||
|
return nil, nil
|
||||||
|
}
|
||||||
|
func (expenseRepositoryStub) GetByIDAndOrganizationID(context.Context, uuid.UUID, uuid.UUID) (*entities.Expense, error) {
|
||||||
|
return nil, nil
|
||||||
|
}
|
||||||
|
func (expenseRepositoryStub) Update(context.Context, *entities.Expense) error { return nil }
|
||||||
|
func (expenseRepositoryStub) Delete(context.Context, uuid.UUID) error { return nil }
|
||||||
|
func (expenseRepositoryStub) List(context.Context, uuid.UUID, map[string]interface{}, int, int) ([]*entities.Expense, int64, error) {
|
||||||
|
return nil, 0, nil
|
||||||
|
}
|
||||||
|
func (expenseRepositoryStub) CreateItem(context.Context, *entities.ExpenseItem) error { return nil }
|
||||||
|
func (expenseRepositoryStub) DeleteItemsByExpenseID(context.Context, uuid.UUID) error { return nil }
|
||||||
|
|
||||||
func TestAnalyticsProcessorGetPurchasingAnalyticsPassesOutletName(t *testing.T) {
|
func TestAnalyticsProcessorGetPurchasingAnalyticsPassesOutletName(t *testing.T) {
|
||||||
outletID := uuid.New()
|
outletID := uuid.New()
|
||||||
outletName := "Main Outlet"
|
outletName := "Main Outlet"
|
||||||
@@ -55,7 +72,7 @@ func TestAnalyticsProcessorGetPurchasingAnalyticsPassesOutletName(t *testing.T)
|
|||||||
TotalPurchases: 125,
|
TotalPurchases: 125,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
})
|
}, expenseRepositoryStub{})
|
||||||
|
|
||||||
result, err := processor.GetPurchasingAnalytics(context.Background(), &models.PurchasingAnalyticsRequest{
|
result, err := processor.GetPurchasingAnalytics(context.Background(), &models.PurchasingAnalyticsRequest{
|
||||||
OrganizationID: uuid.New(),
|
OrganizationID: uuid.New(),
|
||||||
|
|||||||
@@ -0,0 +1,211 @@
|
|||||||
|
package processor
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"fmt"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"apskel-pos-be/internal/entities"
|
||||||
|
"apskel-pos-be/internal/mappers"
|
||||||
|
"apskel-pos-be/internal/models"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ExpenseProcessor interface {
|
||||||
|
CreateExpense(ctx context.Context, organizationID uuid.UUID, req *models.CreateExpenseRequest) (*models.ExpenseResponse, error)
|
||||||
|
UpdateExpense(ctx context.Context, id, organizationID uuid.UUID, req *models.UpdateExpenseRequest) (*models.ExpenseResponse, error)
|
||||||
|
DeleteExpense(ctx context.Context, id, organizationID uuid.UUID) error
|
||||||
|
GetExpenseByID(ctx context.Context, id, organizationID uuid.UUID) (*models.ExpenseResponse, error)
|
||||||
|
ListExpenses(ctx context.Context, organizationID uuid.UUID, filters map[string]interface{}, page, limit int) ([]*models.ExpenseResponse, int, error)
|
||||||
|
}
|
||||||
|
|
||||||
|
type ExpenseProcessorImpl struct {
|
||||||
|
expenseRepo ExpenseRepository
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewExpenseProcessorImpl(expenseRepo ExpenseRepository) *ExpenseProcessorImpl {
|
||||||
|
return &ExpenseProcessorImpl{
|
||||||
|
expenseRepo: expenseRepo,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (p *ExpenseProcessorImpl) CreateExpense(ctx context.Context, organizationID uuid.UUID, req *models.CreateExpenseRequest) (*models.ExpenseResponse, error) {
|
||||||
|
outletID, err := uuid.Parse(req.OutletID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("invalid outlet_id: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
transactionDate, err := time.Parse("2006-01-02", req.TransactionDate)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("invalid transaction_date format, expected YYYY-MM-DD: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
expenseEntity := &entities.Expense{
|
||||||
|
OrganizationID: organizationID,
|
||||||
|
OutletID: outletID,
|
||||||
|
ExpenseName: req.ExpenseName,
|
||||||
|
Receiver: req.Receiver,
|
||||||
|
TransactionDate: transactionDate,
|
||||||
|
CodeNumber: req.CodeNumber,
|
||||||
|
Description: req.Description,
|
||||||
|
Tax: req.Tax,
|
||||||
|
Total: req.Total,
|
||||||
|
}
|
||||||
|
|
||||||
|
err = p.expenseRepo.Create(ctx, expenseEntity)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("failed to create expense: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, itemReq := range req.Items {
|
||||||
|
chartOfAccountID, err := uuid.Parse(itemReq.ChartOfAccountID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("invalid chart_of_account_id for item: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
itemEntity := &entities.ExpenseItem{
|
||||||
|
ExpenseID: expenseEntity.ID,
|
||||||
|
ChartOfAccountID: chartOfAccountID,
|
||||||
|
Description: itemReq.Description,
|
||||||
|
Amount: itemReq.Amount,
|
||||||
|
}
|
||||||
|
|
||||||
|
err = p.expenseRepo.CreateItem(ctx, itemEntity)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("failed to create expense item: %w", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
created, err := p.expenseRepo.GetByID(ctx, expenseEntity.ID)
|
||||||
|
if err != nil {
|
||||||
|
return mappers.ExpenseEntityToResponse(expenseEntity), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
return mappers.ExpenseEntityToResponse(created), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (p *ExpenseProcessorImpl) UpdateExpense(ctx context.Context, id, organizationID uuid.UUID, req *models.UpdateExpenseRequest) (*models.ExpenseResponse, error) {
|
||||||
|
expenseEntity, err := p.expenseRepo.GetByIDAndOrganizationID(ctx, id, organizationID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("expense not found: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.ExpenseName != nil {
|
||||||
|
expenseEntity.ExpenseName = *req.ExpenseName
|
||||||
|
}
|
||||||
|
if req.Receiver != nil {
|
||||||
|
expenseEntity.Receiver = *req.Receiver
|
||||||
|
}
|
||||||
|
if req.TransactionDate != nil {
|
||||||
|
parsedDate, err := time.Parse("2006-01-02", *req.TransactionDate)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("invalid transaction_date format, expected YYYY-MM-DD: %w", err)
|
||||||
|
}
|
||||||
|
expenseEntity.TransactionDate = parsedDate
|
||||||
|
}
|
||||||
|
if req.CodeNumber != nil {
|
||||||
|
expenseEntity.CodeNumber = *req.CodeNumber
|
||||||
|
}
|
||||||
|
if req.OutletID != nil {
|
||||||
|
outletID, err := uuid.Parse(*req.OutletID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("invalid outlet_id: %w", err)
|
||||||
|
}
|
||||||
|
expenseEntity.OutletID = outletID
|
||||||
|
}
|
||||||
|
if req.Description != nil {
|
||||||
|
expenseEntity.Description = req.Description
|
||||||
|
}
|
||||||
|
if req.Tax != nil {
|
||||||
|
expenseEntity.Tax = *req.Tax
|
||||||
|
}
|
||||||
|
if req.Total != nil {
|
||||||
|
expenseEntity.Total = *req.Total
|
||||||
|
}
|
||||||
|
if req.Reserved1 != nil {
|
||||||
|
expenseEntity.Reserved1 = req.Reserved1
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Items != nil {
|
||||||
|
err = p.expenseRepo.DeleteItemsByExpenseID(ctx, expenseEntity.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("failed to delete existing items: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, itemReq := range req.Items {
|
||||||
|
chartOfAccountID := uuid.Nil
|
||||||
|
if itemReq.ChartOfAccountID != nil {
|
||||||
|
chartOfAccountID, err = uuid.Parse(*itemReq.ChartOfAccountID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("invalid chart_of_account_id for item: %w", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
amount := 0.0
|
||||||
|
if itemReq.Amount != nil {
|
||||||
|
amount = *itemReq.Amount
|
||||||
|
}
|
||||||
|
|
||||||
|
itemEntity := &entities.ExpenseItem{
|
||||||
|
ExpenseID: expenseEntity.ID,
|
||||||
|
ChartOfAccountID: chartOfAccountID,
|
||||||
|
Description: itemReq.Description,
|
||||||
|
Amount: amount,
|
||||||
|
}
|
||||||
|
|
||||||
|
err = p.expenseRepo.CreateItem(ctx, itemEntity)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("failed to create expense item: %w", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
err = p.expenseRepo.Update(ctx, expenseEntity)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("failed to update expense: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
updated, err := p.expenseRepo.GetByID(ctx, id)
|
||||||
|
if err != nil {
|
||||||
|
return mappers.ExpenseEntityToResponse(expenseEntity), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
return mappers.ExpenseEntityToResponse(updated), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (p *ExpenseProcessorImpl) DeleteExpense(ctx context.Context, id, organizationID uuid.UUID) error {
|
||||||
|
_, err := p.expenseRepo.GetByIDAndOrganizationID(ctx, id, organizationID)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("expense not found: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
err = p.expenseRepo.Delete(ctx, id)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to delete expense: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (p *ExpenseProcessorImpl) GetExpenseByID(ctx context.Context, id, organizationID uuid.UUID) (*models.ExpenseResponse, error) {
|
||||||
|
expenseEntity, err := p.expenseRepo.GetByIDAndOrganizationID(ctx, id, organizationID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("expense not found: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return mappers.ExpenseEntityToResponse(expenseEntity), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (p *ExpenseProcessorImpl) ListExpenses(ctx context.Context, organizationID uuid.UUID, filters map[string]interface{}, page, limit int) ([]*models.ExpenseResponse, int, error) {
|
||||||
|
offset := (page - 1) * limit
|
||||||
|
expenseEntities, total, err := p.expenseRepo.List(ctx, organizationID, filters, limit, offset)
|
||||||
|
if err != nil {
|
||||||
|
return nil, 0, fmt.Errorf("failed to list expenses: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
expenseResponses := mappers.ExpenseEntitiesToResponses(expenseEntities)
|
||||||
|
totalPages := int((total + int64(limit) - 1) / int64(limit))
|
||||||
|
|
||||||
|
return expenseResponses, totalPages, nil
|
||||||
|
}
|
||||||
@@ -0,0 +1,19 @@
|
|||||||
|
package processor
|
||||||
|
|
||||||
|
import (
|
||||||
|
"apskel-pos-be/internal/entities"
|
||||||
|
"context"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ExpenseRepository interface {
|
||||||
|
Create(ctx context.Context, expense *entities.Expense) error
|
||||||
|
GetByID(ctx context.Context, id uuid.UUID) (*entities.Expense, error)
|
||||||
|
GetByIDAndOrganizationID(ctx context.Context, id, organizationID uuid.UUID) (*entities.Expense, error)
|
||||||
|
Update(ctx context.Context, expense *entities.Expense) error
|
||||||
|
Delete(ctx context.Context, id uuid.UUID) error
|
||||||
|
List(ctx context.Context, organizationID uuid.UUID, filters map[string]interface{}, limit, offset int) ([]*entities.Expense, int64, error)
|
||||||
|
CreateItem(ctx context.Context, item *entities.ExpenseItem) error
|
||||||
|
DeleteItemsByExpenseID(ctx context.Context, expenseID uuid.UUID) error
|
||||||
|
}
|
||||||
@@ -1,6 +1,7 @@
|
|||||||
package processor
|
package processor
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"apskel-pos-be/internal/constants"
|
||||||
"context"
|
"context"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
@@ -387,10 +388,31 @@ func (p *OrderProcessorImpl) AddToOrder(ctx context.Context, orderID uuid.UUID,
|
|||||||
return nil, fmt.Errorf("failed to create order item: %w", err)
|
return nil, fmt.Errorf("failed to create order item: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
itemResponse := mappers.OrderItemEntityToResponse(orderItem, order.OutletID)
|
itemResponse := models.OrderItemResponse{
|
||||||
if itemResponse != nil {
|
ID: orderItem.ID,
|
||||||
addedItemResponses = append(addedItemResponses, *itemResponse)
|
OrderID: orderItem.OrderID,
|
||||||
|
ProductID: orderItem.ProductID,
|
||||||
|
ProductVariantID: orderItem.ProductVariantID,
|
||||||
|
Quantity: orderItem.Quantity,
|
||||||
|
UnitPrice: orderItem.UnitPrice,
|
||||||
|
TotalPrice: orderItem.TotalPrice,
|
||||||
|
UnitCost: orderItem.UnitCost,
|
||||||
|
TotalCost: orderItem.TotalCost,
|
||||||
|
RefundAmount: orderItem.RefundAmount,
|
||||||
|
RefundQuantity: orderItem.RefundQuantity,
|
||||||
|
IsPartiallyRefunded: orderItem.IsPartiallyRefunded,
|
||||||
|
IsFullyRefunded: orderItem.IsFullyRefunded,
|
||||||
|
RefundReason: orderItem.RefundReason,
|
||||||
|
RefundedAt: orderItem.RefundedAt,
|
||||||
|
RefundedBy: orderItem.RefundedBy,
|
||||||
|
Modifiers: []map[string]interface{}(orderItem.Modifiers),
|
||||||
|
Notes: orderItem.Notes,
|
||||||
|
Metadata: map[string]interface{}(orderItem.Metadata),
|
||||||
|
Status: constants.OrderItemStatus(orderItem.Status),
|
||||||
|
CreatedAt: orderItem.CreatedAt,
|
||||||
|
UpdatedAt: orderItem.UpdatedAt,
|
||||||
}
|
}
|
||||||
|
addedItemResponses = append(addedItemResponses, itemResponse)
|
||||||
}
|
}
|
||||||
|
|
||||||
orderWithRelations, err := p.orderRepo.GetWithRelations(ctx, orderID)
|
orderWithRelations, err := p.orderRepo.GetWithRelations(ctx, orderID)
|
||||||
|
|||||||
@@ -49,7 +49,6 @@ func (p *ProductOutletPriceProcessorImpl) Upsert(ctx context.Context, req *model
|
|||||||
ProductID: req.ProductID,
|
ProductID: req.ProductID,
|
||||||
OutletID: req.OutletID,
|
OutletID: req.OutletID,
|
||||||
Price: req.Price,
|
Price: req.Price,
|
||||||
PrintToChecker: req.PrintToChecker,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := p.repo.Upsert(ctx, entity); err != nil {
|
if err := p.repo.Upsert(ctx, entity); err != nil {
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"apskel-pos-be/internal/entities"
|
"apskel-pos-be/internal/entities"
|
||||||
"apskel-pos-be/internal/logger"
|
|
||||||
"apskel-pos-be/internal/mappers"
|
"apskel-pos-be/internal/mappers"
|
||||||
"apskel-pos-be/internal/models"
|
"apskel-pos-be/internal/models"
|
||||||
"apskel-pos-be/internal/repository"
|
"apskel-pos-be/internal/repository"
|
||||||
@@ -126,15 +125,10 @@ func (p *ProductProcessorImpl) CreateProduct(ctx context.Context, req *models.Cr
|
|||||||
|
|
||||||
// Upsert outlet-specific price if outlet context is present
|
// Upsert outlet-specific price if outlet context is present
|
||||||
if req.OutletID != uuid.Nil {
|
if req.OutletID != uuid.Nil {
|
||||||
printToChecker := true // default
|
|
||||||
if req.PrintToChecker != nil {
|
|
||||||
printToChecker = *req.PrintToChecker
|
|
||||||
}
|
|
||||||
outletPriceEntity := &entities.ProductOutletPrice{
|
outletPriceEntity := &entities.ProductOutletPrice{
|
||||||
ProductID: productEntity.ID,
|
ProductID: productEntity.ID,
|
||||||
OutletID: req.OutletID,
|
OutletID: req.OutletID,
|
||||||
Price: req.Price,
|
Price: req.Price,
|
||||||
PrintToChecker: printToChecker,
|
|
||||||
}
|
}
|
||||||
if err := p.outletPriceRepo.Upsert(ctx, outletPriceEntity); err != nil {
|
if err := p.outletPriceRepo.Upsert(ctx, outletPriceEntity); err != nil {
|
||||||
return nil, fmt.Errorf("failed to assign outlet price: %w", err)
|
return nil, fmt.Errorf("failed to assign outlet price: %w", err)
|
||||||
@@ -202,39 +196,16 @@ func (p *ProductProcessorImpl) UpdateProduct(ctx context.Context, id uuid.UUID,
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Upsert outlet-specific price if outlet context is present and price or print_to_checker is provided
|
// Upsert outlet-specific price if outlet context is present
|
||||||
if req.OutletID != uuid.Nil && (req.Price != nil || req.PrintToChecker != nil) {
|
if req.OutletID != uuid.Nil && req.Price != nil {
|
||||||
// Fetch existing outlet price to use as fallback for fields not provided
|
|
||||||
existing, _ := p.outletPriceRepo.GetByProductAndOutlet(ctx, id, req.OutletID)
|
|
||||||
|
|
||||||
price := float64(0)
|
|
||||||
if existing != nil {
|
|
||||||
price = existing.Price
|
|
||||||
}
|
|
||||||
if req.Price != nil {
|
|
||||||
price = *req.Price
|
|
||||||
}
|
|
||||||
|
|
||||||
printToChecker := true // default
|
|
||||||
if existing != nil {
|
|
||||||
printToChecker = existing.PrintToChecker
|
|
||||||
}
|
|
||||||
if req.PrintToChecker != nil {
|
|
||||||
printToChecker = *req.PrintToChecker
|
|
||||||
}
|
|
||||||
|
|
||||||
outletPriceEntity := &entities.ProductOutletPrice{
|
outletPriceEntity := &entities.ProductOutletPrice{
|
||||||
ProductID: id,
|
ProductID: id,
|
||||||
OutletID: req.OutletID,
|
OutletID: req.OutletID,
|
||||||
Price: price,
|
Price: *req.Price,
|
||||||
PrintToChecker: printToChecker,
|
|
||||||
}
|
}
|
||||||
logger.FromContext(ctx).Infof("ProductProcessor::UpdateProduct -> upserting outlet price: productID=%s outletID=%s price=%f printToChecker=%v", id, req.OutletID, price, printToChecker)
|
|
||||||
if err := p.outletPriceRepo.Upsert(ctx, outletPriceEntity); err != nil {
|
if err := p.outletPriceRepo.Upsert(ctx, outletPriceEntity); err != nil {
|
||||||
return nil, fmt.Errorf("failed to assign outlet price: %w", err)
|
return nil, fmt.Errorf("failed to assign outlet price: %w", err)
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
logger.FromContext(ctx).Infof("ProductProcessor::UpdateProduct -> skipping outlet price upsert: outletID=%s price=%v printToChecker=%v", req.OutletID, req.Price, req.PrintToChecker)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
productWithCategory, err := p.productRepo.GetWithCategory(ctx, id)
|
productWithCategory, err := p.productRepo.GetWithCategory(ctx, id)
|
||||||
@@ -285,7 +256,6 @@ func (p *ProductProcessorImpl) GetProductByID(ctx context.Context, id uuid.UUID,
|
|||||||
outletPrice, err := p.outletPriceRepo.GetByProductAndOutlet(ctx, id, outletID)
|
outletPrice, err := p.outletPriceRepo.GetByProductAndOutlet(ctx, id, outletID)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
response.OutletPrice = &outletPrice.Price
|
response.OutletPrice = &outletPrice.Price
|
||||||
response.PrintToChecker = outletPrice.PrintToChecker
|
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
// No outlet context — return all outlet prices for this product
|
// No outlet context — return all outlet prices for this product
|
||||||
@@ -297,7 +267,6 @@ func (p *ProductProcessorImpl) GetProductByID(ctx context.Context, id uuid.UUID,
|
|||||||
OutletID: op.OutletID,
|
OutletID: op.OutletID,
|
||||||
OutletName: op.Outlet.Name,
|
OutletName: op.Outlet.Name,
|
||||||
Price: op.Price,
|
Price: op.Price,
|
||||||
PrintToChecker: op.PrintToChecker,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
response.OutletPrices = prices
|
response.OutletPrices = prices
|
||||||
@@ -334,37 +303,12 @@ func (p *ProductProcessorImpl) ListProducts(ctx context.Context, filters map[str
|
|||||||
}
|
}
|
||||||
|
|
||||||
responses := make([]models.ProductResponse, len(productEntities))
|
responses := make([]models.ProductResponse, len(productEntities))
|
||||||
if outletID != uuid.Nil && len(productEntities) > 0 {
|
|
||||||
// Bulk-fetch outlet prices to populate OutletPrice and PrintToChecker per product
|
|
||||||
productIDs := make([]uuid.UUID, len(productEntities))
|
|
||||||
for i, e := range productEntities {
|
|
||||||
productIDs[i] = e.ID
|
|
||||||
}
|
|
||||||
outletPrices, opErr := p.outletPriceRepo.GetByProductsAndOutlet(ctx, productIDs, outletID)
|
|
||||||
priceMap := make(map[uuid.UUID]*entities.ProductOutletPrice)
|
|
||||||
if opErr == nil {
|
|
||||||
for _, op := range outletPrices {
|
|
||||||
priceMap[op.ProductID] = op
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for i, entity := range productEntities {
|
|
||||||
response := mappers.ProductEntityToResponse(entity)
|
|
||||||
if response != nil {
|
|
||||||
if op, ok := priceMap[entity.ID]; ok {
|
|
||||||
response.OutletPrice = &op.Price
|
|
||||||
response.PrintToChecker = op.PrintToChecker
|
|
||||||
}
|
|
||||||
responses[i] = *response
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
for i, entity := range productEntities {
|
for i, entity := range productEntities {
|
||||||
response := mappers.ProductEntityToResponse(entity)
|
response := mappers.ProductEntityToResponse(entity)
|
||||||
if response != nil {
|
if response != nil {
|
||||||
responses[i] = *response
|
responses[i] = *response
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
return responses, int(total), nil
|
return responses, int(total), nil
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ type AnalyticsRepository interface {
|
|||||||
GetProductAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time, limit int) ([]*entities.ProductAnalytics, error)
|
GetProductAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time, limit int) ([]*entities.ProductAnalytics, error)
|
||||||
GetProductAnalyticsPerCategory(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) ([]*entities.ProductAnalyticsPerCategory, error)
|
GetProductAnalyticsPerCategory(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) ([]*entities.ProductAnalyticsPerCategory, error)
|
||||||
GetDashboardOverview(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) (*entities.DashboardOverview, error)
|
GetDashboardOverview(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) (*entities.DashboardOverview, error)
|
||||||
GetProfitLossAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time, groupBy string) (*entities.ProfitLossAnalytics, error)
|
GetProfitLossAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, date time.Time) (*entities.ProfitLossAnalytics, error)
|
||||||
}
|
}
|
||||||
|
|
||||||
type AnalyticsRepositoryImpl struct {
|
type AnalyticsRepositoryImpl struct {
|
||||||
@@ -432,152 +432,119 @@ func (r *AnalyticsRepositoryImpl) GetDashboardOverview(ctx context.Context, orga
|
|||||||
return &result, nil
|
return &result, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *AnalyticsRepositoryImpl) GetProfitLossAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time, groupBy string) (*entities.ProfitLossAnalytics, error) {
|
func (r *AnalyticsRepositoryImpl) GetProfitLossAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, date time.Time) (*entities.ProfitLossAnalytics, error) {
|
||||||
// Summary query
|
mtdStart := time.Date(date.Year(), date.Month(), 1, 0, 0, 0, 0, date.Location())
|
||||||
var summary entities.ProfitLossSummary
|
todayStart := time.Date(date.Year(), date.Month(), date.Day(), 0, 0, 0, 0, date.Location())
|
||||||
|
todayEnd := todayStart.Add(24 * time.Hour).Add(-time.Nanosecond)
|
||||||
|
|
||||||
summaryQuery := r.db.WithContext(ctx).
|
type revenueCostResult struct {
|
||||||
Table("orders o").
|
Revenue float64
|
||||||
Select(`
|
Cost float64
|
||||||
COALESCE(SUM(o.total_amount), 0) as total_revenue,
|
|
||||||
COALESCE(SUM(o.total_cost), 0) as total_cost,
|
|
||||||
COALESCE(SUM(o.total_amount - o.total_cost), 0) as gross_profit,
|
|
||||||
CASE
|
|
||||||
WHEN SUM(o.total_amount) > 0
|
|
||||||
THEN (SUM(o.total_amount - o.total_cost) / SUM(o.total_amount)) * 100
|
|
||||||
ELSE 0
|
|
||||||
END as gross_profit_margin,
|
|
||||||
COALESCE(SUM(o.tax_amount), 0) as total_tax,
|
|
||||||
COALESCE(SUM(o.discount_amount), 0) as total_discount,
|
|
||||||
COALESCE(SUM(o.total_amount - o.total_cost - o.discount_amount), 0) as net_profit,
|
|
||||||
CASE
|
|
||||||
WHEN SUM(o.total_amount) > 0
|
|
||||||
THEN (SUM(o.total_amount - o.total_cost - o.discount_amount) / SUM(o.total_amount)) * 100
|
|
||||||
ELSE 0
|
|
||||||
END as net_profit_margin,
|
|
||||||
COUNT(o.id) as total_orders,
|
|
||||||
CASE
|
|
||||||
WHEN COUNT(o.id) > 0
|
|
||||||
THEN SUM(o.total_amount - o.total_cost - o.discount_amount) / COUNT(o.id)
|
|
||||||
ELSE 0
|
|
||||||
END as average_profit,
|
|
||||||
CASE
|
|
||||||
WHEN SUM(o.total_cost) > 0
|
|
||||||
THEN (SUM(o.total_amount - o.total_cost) / SUM(o.total_cost)) * 100
|
|
||||||
ELSE 0
|
|
||||||
END as profitability_ratio
|
|
||||||
`).
|
|
||||||
Where("o.organization_id = ?", organizationID).
|
|
||||||
Where("o.status = ?", entities.OrderStatusCompleted).
|
|
||||||
Where("o.payment_status = ?", entities.PaymentStatusCompleted).
|
|
||||||
Where("o.is_void = false AND o.is_refund = false").
|
|
||||||
Where("o.created_at >= ? AND o.created_at <= ?", dateFrom, dateTo)
|
|
||||||
|
|
||||||
summaryQuery = r.resolveOutletID(summaryQuery, outletID, "o.outlet_id")
|
|
||||||
|
|
||||||
err := summaryQuery.Scan(&summary).Error
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Time series data query
|
var todayRC revenueCostResult
|
||||||
var timeFormat string
|
todayQuery := r.db.WithContext(ctx).
|
||||||
switch groupBy {
|
|
||||||
case "hour":
|
|
||||||
timeFormat = "DATE_TRUNC('hour', o.created_at)"
|
|
||||||
case "week":
|
|
||||||
timeFormat = "DATE_TRUNC('week', o.created_at)"
|
|
||||||
case "month":
|
|
||||||
timeFormat = "DATE_TRUNC('month', o.created_at)"
|
|
||||||
default: // day
|
|
||||||
timeFormat = "DATE_TRUNC('day', o.created_at)"
|
|
||||||
}
|
|
||||||
|
|
||||||
var data []entities.ProfitLossData
|
|
||||||
|
|
||||||
dataQuery := r.db.WithContext(ctx).
|
|
||||||
Table("orders o").
|
Table("orders o").
|
||||||
Select(`
|
Select(`
|
||||||
`+timeFormat+` as date,
|
|
||||||
COALESCE(SUM(o.total_amount), 0) as revenue,
|
COALESCE(SUM(o.total_amount), 0) as revenue,
|
||||||
COALESCE(SUM(o.total_cost), 0) as cost,
|
COALESCE(SUM(o.total_cost), 0) as cost
|
||||||
COALESCE(SUM(o.total_amount - o.total_cost), 0) as gross_profit,
|
|
||||||
CASE
|
|
||||||
WHEN SUM(o.total_amount) > 0
|
|
||||||
THEN (SUM(o.total_amount - o.total_cost) / SUM(o.total_amount)) * 100
|
|
||||||
ELSE 0
|
|
||||||
END as gross_profit_margin,
|
|
||||||
COALESCE(SUM(o.tax_amount), 0) as tax,
|
|
||||||
COALESCE(SUM(o.discount_amount), 0) as discount,
|
|
||||||
COALESCE(SUM(o.total_amount - o.total_cost - o.discount_amount), 0) as net_profit,
|
|
||||||
CASE
|
|
||||||
WHEN SUM(o.total_amount) > 0
|
|
||||||
THEN (SUM(o.total_amount - o.total_cost - o.discount_amount) / SUM(o.total_amount)) * 100
|
|
||||||
ELSE 0
|
|
||||||
END as net_profit_margin,
|
|
||||||
COUNT(o.id) as orders
|
|
||||||
`).
|
`).
|
||||||
Where("o.organization_id = ?", organizationID).
|
Where("o.organization_id = ?", organizationID).
|
||||||
Where("o.status = ?", entities.OrderStatusCompleted).
|
Where("o.status = ?", entities.OrderStatusCompleted).
|
||||||
Where("o.payment_status = ?", entities.PaymentStatusCompleted).
|
Where("o.payment_status = ?", entities.PaymentStatusCompleted).
|
||||||
Where("o.is_void = false AND o.is_refund = false").
|
Where("o.is_void = false AND o.is_refund = false").
|
||||||
Where("o.created_at >= ? AND o.created_at <= ?", dateFrom, dateTo).
|
Where("o.created_at >= ? AND o.created_at <= ?", todayStart, todayEnd)
|
||||||
Group(timeFormat).
|
todayQuery = r.resolveOutletID(todayQuery, outletID, "o.outlet_id")
|
||||||
Order(timeFormat)
|
if err := todayQuery.Scan(&todayRC).Error; err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
dataQuery = r.resolveOutletID(dataQuery, outletID, "o.outlet_id")
|
var mtdRC revenueCostResult
|
||||||
|
mtdQuery := r.db.WithContext(ctx).
|
||||||
|
Table("orders o").
|
||||||
|
Select(`
|
||||||
|
COALESCE(SUM(o.total_amount), 0) as revenue,
|
||||||
|
COALESCE(SUM(o.total_cost), 0) as cost
|
||||||
|
`).
|
||||||
|
Where("o.organization_id = ?", organizationID).
|
||||||
|
Where("o.status = ?", entities.OrderStatusCompleted).
|
||||||
|
Where("o.payment_status = ?", entities.PaymentStatusCompleted).
|
||||||
|
Where("o.is_void = false AND o.is_refund = false").
|
||||||
|
Where("o.created_at >= ? AND o.created_at <= ?", mtdStart, todayEnd)
|
||||||
|
mtdQuery = r.resolveOutletID(mtdQuery, outletID, "o.outlet_id")
|
||||||
|
if err := mtdQuery.Scan(&mtdRC).Error; err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
err = dataQuery.Scan(&data).Error
|
todayExpenseByCategory, err := r.getExpenseByCategory(ctx, organizationID, outletID, todayStart, todayEnd)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Product profit data query
|
mtdExpenseByCategory, err := r.getExpenseByCategory(ctx, organizationID, outletID, mtdStart, todayEnd)
|
||||||
var productData []entities.ProductProfitData
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
productQuery := r.db.WithContext(ctx).
|
opsItems, err := r.getOperationalExpenseItems(ctx, organizationID, outletID, mtdStart, todayEnd)
|
||||||
Table("order_items oi").
|
|
||||||
Select(`
|
|
||||||
p.id as product_id,
|
|
||||||
p.name as product_name,
|
|
||||||
c.id as category_id,
|
|
||||||
c.name as category_name,
|
|
||||||
SUM(CASE WHEN oi.is_fully_refunded = false THEN oi.quantity - COALESCE(oi.refund_quantity, 0) ELSE 0 END) as quantity_sold,
|
|
||||||
SUM(CASE WHEN oi.is_fully_refunded = false THEN oi.total_price - COALESCE(oi.refund_amount, 0) ELSE 0 END) as revenue,
|
|
||||||
SUM(CASE WHEN oi.is_fully_refunded = false THEN oi.total_cost * ((oi.quantity - COALESCE(oi.refund_quantity, 0))::float / NULLIF(oi.quantity, 0)) ELSE 0 END) as cost,
|
|
||||||
SUM(CASE WHEN oi.is_fully_refunded = false THEN (oi.total_price - COALESCE(oi.refund_amount, 0)) - (oi.total_cost * ((oi.quantity - COALESCE(oi.refund_quantity, 0))::float / NULLIF(oi.quantity, 0))) ELSE 0 END) as gross_profit,
|
|
||||||
CASE
|
|
||||||
WHEN SUM(CASE WHEN oi.is_fully_refunded = false THEN oi.total_price - COALESCE(oi.refund_amount, 0) ELSE 0 END) > 0
|
|
||||||
THEN (SUM(CASE WHEN oi.is_fully_refunded = false THEN (oi.total_price - COALESCE(oi.refund_amount, 0)) - (oi.total_cost * ((oi.quantity - COALESCE(oi.refund_quantity, 0))::float / NULLIF(oi.quantity, 0))) ELSE 0 END) / SUM(CASE WHEN oi.is_fully_refunded = false THEN oi.total_price - COALESCE(oi.refund_amount, 0) ELSE 0 END)) * 100
|
|
||||||
ELSE 0
|
|
||||||
END as gross_profit_margin,
|
|
||||||
AVG(CASE WHEN oi.is_fully_refunded = false THEN oi.unit_price ELSE NULL END) as average_price,
|
|
||||||
AVG(CASE WHEN oi.is_fully_refunded = false THEN oi.unit_cost ELSE NULL END) as average_cost,
|
|
||||||
AVG(CASE WHEN oi.is_fully_refunded = false THEN oi.unit_price - oi.unit_cost ELSE NULL END) as profit_per_unit
|
|
||||||
`).
|
|
||||||
Joins("JOIN orders o ON oi.order_id = o.id").
|
|
||||||
Joins("JOIN products p ON oi.product_id = p.id").
|
|
||||||
Joins("JOIN categories c ON p.category_id = c.id").
|
|
||||||
Where("o.organization_id = ?", organizationID).
|
|
||||||
Where("o.status = ?", entities.OrderStatusCompleted).
|
|
||||||
Where("o.payment_status = ?", entities.PaymentStatusCompleted).
|
|
||||||
Where("o.is_void = false AND o.is_refund = false").
|
|
||||||
Where("oi.status != ?", entities.OrderItemStatusCancelled).
|
|
||||||
Where("o.created_at >= ? AND o.created_at <= ?", dateFrom, dateTo).
|
|
||||||
Group("p.id, p.name, c.id, c.name").
|
|
||||||
Order("p.name ASC").
|
|
||||||
Limit(1000)
|
|
||||||
|
|
||||||
productQuery = r.resolveOutletID(productQuery, outletID, "o.outlet_id")
|
|
||||||
|
|
||||||
err = productQuery.Scan(&productData).Error
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
return &entities.ProfitLossAnalytics{
|
return &entities.ProfitLossAnalytics{
|
||||||
Summary: summary,
|
TodayRevenue: todayRC.Revenue,
|
||||||
Data: data,
|
TodayCost: todayRC.Cost,
|
||||||
ProductData: productData,
|
MtdRevenue: mtdRC.Revenue,
|
||||||
|
MtdCost: mtdRC.Cost,
|
||||||
|
TodayExpenseByCategory: todayExpenseByCategory,
|
||||||
|
MtdExpenseByCategory: mtdExpenseByCategory,
|
||||||
|
OperationalExpenseItems: opsItems,
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (r *AnalyticsRepositoryImpl) getExpenseByCategory(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) ([]entities.ExpenseCategoryTotal, error) {
|
||||||
|
var results []entities.ExpenseCategoryTotal
|
||||||
|
|
||||||
|
query := r.db.WithContext(ctx).
|
||||||
|
Table("expense_items ei").
|
||||||
|
Select(`COALESCE(parent_coa.name, 'Lain-lain') as category_name, COALESCE(SUM(ei.amount), 0) as amount`).
|
||||||
|
Joins("JOIN expenses e ON ei.expense_id = e.id").
|
||||||
|
Joins("JOIN chart_of_accounts coa ON ei.chart_of_account_id = coa.id").
|
||||||
|
Joins("LEFT JOIN chart_of_accounts parent_coa ON coa.parent_id = parent_coa.id").
|
||||||
|
Where("e.organization_id = ?", organizationID).
|
||||||
|
Where("e.transaction_date >= ? AND e.transaction_date <= ?", dateFrom, dateTo)
|
||||||
|
|
||||||
|
if outletID != nil {
|
||||||
|
query = query.Where("e.outlet_id = ?", *outletID)
|
||||||
|
}
|
||||||
|
|
||||||
|
err := query.
|
||||||
|
Group("parent_coa.name").
|
||||||
|
Order("parent_coa.name").
|
||||||
|
Scan(&results).Error
|
||||||
|
|
||||||
|
return results, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *AnalyticsRepositoryImpl) getOperationalExpenseItems(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) ([]entities.OperationalExpenseItem, error) {
|
||||||
|
var results []entities.OperationalExpenseItem
|
||||||
|
|
||||||
|
query := r.db.WithContext(ctx).
|
||||||
|
Table("expense_items ei").
|
||||||
|
Select(`COALESCE(ei.description, coa.name) as description, COALESCE(SUM(ei.amount), 0) as amount`).
|
||||||
|
Joins("JOIN expenses e ON ei.expense_id = e.id").
|
||||||
|
Joins("JOIN chart_of_accounts coa ON ei.chart_of_account_id = coa.id").
|
||||||
|
Where("e.organization_id = ?", organizationID).
|
||||||
|
Where("e.transaction_date >= ? AND e.transaction_date <= ?", dateFrom, dateTo)
|
||||||
|
|
||||||
|
if outletID != nil {
|
||||||
|
query = query.Where("e.outlet_id = ?", *outletID)
|
||||||
|
}
|
||||||
|
|
||||||
|
err := query.
|
||||||
|
Group("COALESCE(ei.description, coa.name)").
|
||||||
|
Order("amount DESC").
|
||||||
|
Scan(&results).Error
|
||||||
|
|
||||||
|
return results, err
|
||||||
|
}
|
||||||
|
|||||||
@@ -0,0 +1,101 @@
|
|||||||
|
package repository
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
|
||||||
|
"apskel-pos-be/internal/entities"
|
||||||
|
|
||||||
|
"gorm.io/gorm"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ExpenseRepositoryImpl struct {
|
||||||
|
db *gorm.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewExpenseRepositoryImpl(db *gorm.DB) *ExpenseRepositoryImpl {
|
||||||
|
return &ExpenseRepositoryImpl{
|
||||||
|
db: db,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *ExpenseRepositoryImpl) Create(ctx context.Context, expense *entities.Expense) error {
|
||||||
|
return r.db.WithContext(ctx).Create(expense).Error
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *ExpenseRepositoryImpl) GetByID(ctx context.Context, id uuid.UUID) (*entities.Expense, error) {
|
||||||
|
var expense entities.Expense
|
||||||
|
err := r.db.WithContext(ctx).
|
||||||
|
Preload("Items.ChartOfAccount").
|
||||||
|
First(&expense, "id = ?", id).Error
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &expense, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *ExpenseRepositoryImpl) GetByIDAndOrganizationID(ctx context.Context, id, organizationID uuid.UUID) (*entities.Expense, error) {
|
||||||
|
var expense entities.Expense
|
||||||
|
err := r.db.WithContext(ctx).
|
||||||
|
Preload("Items.ChartOfAccount").
|
||||||
|
Where("id = ? AND organization_id = ?", id, organizationID).
|
||||||
|
First(&expense).Error
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &expense, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *ExpenseRepositoryImpl) Update(ctx context.Context, expense *entities.Expense) error {
|
||||||
|
return r.db.WithContext(ctx).Save(expense).Error
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *ExpenseRepositoryImpl) Delete(ctx context.Context, id uuid.UUID) error {
|
||||||
|
return r.db.WithContext(ctx).Delete(&entities.Expense{}, "id = ?", id).Error
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *ExpenseRepositoryImpl) List(ctx context.Context, organizationID uuid.UUID, filters map[string]interface{}, limit, offset int) ([]*entities.Expense, int64, error) {
|
||||||
|
var expenses []*entities.Expense
|
||||||
|
var total int64
|
||||||
|
|
||||||
|
query := r.db.WithContext(ctx).Model(&entities.Expense{}).Where("organization_id = ?", organizationID)
|
||||||
|
|
||||||
|
for key, value := range filters {
|
||||||
|
switch key {
|
||||||
|
case "search":
|
||||||
|
if searchStr, ok := value.(string); ok && searchStr != "" {
|
||||||
|
searchPattern := "%" + strings.ToLower(searchStr) + "%"
|
||||||
|
query = query.Where("LOWER(expense_name) LIKE ? OR LOWER(receiver) LIKE ? OR LOWER(code_number) LIKE ? OR LOWER(description) LIKE ?",
|
||||||
|
searchPattern, searchPattern, searchPattern, searchPattern)
|
||||||
|
}
|
||||||
|
case "outlet_id":
|
||||||
|
if outletID, ok := value.(uuid.UUID); ok {
|
||||||
|
query = query.Where("outlet_id = ?", outletID)
|
||||||
|
}
|
||||||
|
default:
|
||||||
|
query = query.Where(key+" = ?", value)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if err := query.Count(&total).Error; err != nil {
|
||||||
|
return nil, 0, err
|
||||||
|
}
|
||||||
|
|
||||||
|
err := query.
|
||||||
|
Preload("Items.ChartOfAccount").
|
||||||
|
Order("created_at DESC").
|
||||||
|
Limit(limit).
|
||||||
|
Offset(offset).
|
||||||
|
Find(&expenses).Error
|
||||||
|
return expenses, total, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *ExpenseRepositoryImpl) CreateItem(ctx context.Context, item *entities.ExpenseItem) error {
|
||||||
|
return r.db.WithContext(ctx).Create(item).Error
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *ExpenseRepositoryImpl) DeleteItemsByExpenseID(ctx context.Context, expenseID uuid.UUID) error {
|
||||||
|
return r.db.WithContext(ctx).Delete(&entities.ExpenseItem{}, "expense_id = ?", expenseID).Error
|
||||||
|
}
|
||||||
@@ -60,8 +60,6 @@ func (r *OrderRepositoryImpl) GetWithRelations(ctx context.Context, id uuid.UUID
|
|||||||
Preload("User").
|
Preload("User").
|
||||||
Preload("OrderItems").
|
Preload("OrderItems").
|
||||||
Preload("OrderItems.Product").
|
Preload("OrderItems.Product").
|
||||||
Preload("OrderItems.Product.Category").
|
|
||||||
Preload("OrderItems.Product.ProductOutletPrices").
|
|
||||||
Preload("OrderItems.ProductVariant").
|
Preload("OrderItems.ProductVariant").
|
||||||
Preload("Payments").
|
Preload("Payments").
|
||||||
Preload("Payments.PaymentMethod").
|
Preload("Payments.PaymentMethod").
|
||||||
@@ -141,8 +139,6 @@ func (r *OrderRepositoryImpl) List(ctx context.Context, filters map[string]inter
|
|||||||
Preload("User").
|
Preload("User").
|
||||||
Preload("OrderItems").
|
Preload("OrderItems").
|
||||||
Preload("OrderItems.Product").
|
Preload("OrderItems.Product").
|
||||||
Preload("OrderItems.Product.Category").
|
|
||||||
Preload("OrderItems.Product.ProductOutletPrices").
|
|
||||||
Preload("OrderItems.ProductVariant").
|
Preload("OrderItems.ProductVariant").
|
||||||
Preload("Payments").
|
Preload("Payments").
|
||||||
Preload("Payments.PaymentMethod").
|
Preload("Payments.PaymentMethod").
|
||||||
@@ -159,8 +155,6 @@ func (r *OrderRepositoryImpl) ListBySessionID(ctx context.Context, sessionID str
|
|||||||
Preload("User").
|
Preload("User").
|
||||||
Preload("OrderItems").
|
Preload("OrderItems").
|
||||||
Preload("OrderItems.Product").
|
Preload("OrderItems.Product").
|
||||||
Preload("OrderItems.Product.Category").
|
|
||||||
Preload("OrderItems.Product.ProductOutletPrices").
|
|
||||||
Preload("OrderItems.ProductVariant").
|
Preload("OrderItems.ProductVariant").
|
||||||
Preload("Payments").
|
Preload("Payments").
|
||||||
Preload("Payments.PaymentMethod").
|
Preload("Payments.PaymentMethod").
|
||||||
|
|||||||
@@ -7,6 +7,7 @@ import (
|
|||||||
|
|
||||||
"github.com/google/uuid"
|
"github.com/google/uuid"
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
|
"gorm.io/gorm/clause"
|
||||||
)
|
)
|
||||||
|
|
||||||
type ProductOutletPriceRepository interface {
|
type ProductOutletPriceRepository interface {
|
||||||
@@ -52,18 +53,10 @@ func (r *ProductOutletPriceRepositoryImpl) GetByOutlet(ctx context.Context, outl
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (r *ProductOutletPriceRepositoryImpl) Upsert(ctx context.Context, price *entities.ProductOutletPrice) error {
|
func (r *ProductOutletPriceRepositoryImpl) Upsert(ctx context.Context, price *entities.ProductOutletPrice) error {
|
||||||
if price.ID == uuid.Nil {
|
return r.db.WithContext(ctx).Clauses(clause.OnConflict{
|
||||||
price.ID = uuid.New()
|
Columns: []clause.Column{{Name: "product_id"}, {Name: "outlet_id"}},
|
||||||
}
|
DoUpdates: clause.AssignmentColumns([]string{"price", "updated_at"}),
|
||||||
return r.db.WithContext(ctx).Exec(`
|
}).Create(price).Error
|
||||||
INSERT INTO product_outlet_prices (id, product_id, outlet_id, price, print_to_checker, created_at, updated_at)
|
|
||||||
VALUES (?, ?, ?, ?, ?, NOW(), NOW())
|
|
||||||
ON CONFLICT (product_id, outlet_id)
|
|
||||||
DO UPDATE SET
|
|
||||||
price = EXCLUDED.price,
|
|
||||||
print_to_checker = EXCLUDED.print_to_checker,
|
|
||||||
updated_at = NOW()
|
|
||||||
`, price.ID, price.ProductID, price.OutletID, price.Price, price.PrintToChecker).Error
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *ProductOutletPriceRepositoryImpl) Delete(ctx context.Context, id uuid.UUID) error {
|
func (r *ProductOutletPriceRepositoryImpl) Delete(ctx context.Context, id uuid.UUID) error {
|
||||||
|
|||||||
@@ -50,11 +50,12 @@ type Router struct {
|
|||||||
notificationHandler *handler.NotificationHandler
|
notificationHandler *handler.NotificationHandler
|
||||||
selfOrderHandler *handler.SelfOrderHandler
|
selfOrderHandler *handler.SelfOrderHandler
|
||||||
productOutletPriceHandler *handler.ProductOutletPriceHandler
|
productOutletPriceHandler *handler.ProductOutletPriceHandler
|
||||||
|
expenseHandler *handler.ExpenseHandler
|
||||||
authMiddleware *middleware.AuthMiddleware
|
authMiddleware *middleware.AuthMiddleware
|
||||||
customerAuthMiddleware *middleware.CustomerAuthMiddleware
|
customerAuthMiddleware *middleware.CustomerAuthMiddleware
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewRouter(cfg *config.Config, healthHandler *handler.HealthHandler, authService service.AuthService, authMiddleware *middleware.AuthMiddleware, userService *service.UserServiceImpl, userValidator *validator.UserValidatorImpl, organizationService service.OrganizationService, organizationValidator validator.OrganizationValidator, outletService service.OutletService, outletValidator validator.OutletValidator, outletSettingService service.OutletSettingService, categoryService service.CategoryService, categoryValidator validator.CategoryValidator, productService service.ProductService, productValidator validator.ProductValidator, productVariantService service.ProductVariantService, productVariantValidator validator.ProductVariantValidator, inventoryService service.InventoryService, inventoryValidator validator.InventoryValidator, orderService service.OrderService, orderValidator validator.OrderValidator, fileService service.FileService, fileValidator validator.FileValidator, customerService service.CustomerService, customerValidator validator.CustomerValidator, paymentMethodService service.PaymentMethodService, paymentMethodValidator validator.PaymentMethodValidator, analyticsService *service.AnalyticsServiceImpl, reportService service.ReportService, tableService *service.TableServiceImpl, tableValidator *validator.TableValidator, unitService handler.UnitService, ingredientService handler.IngredientService, productRecipeService service.ProductRecipeService, vendorService service.VendorService, vendorValidator validator.VendorValidator, purchaseOrderService service.PurchaseOrderService, purchaseOrderValidator validator.PurchaseOrderValidator, unitConverterService service.IngredientUnitConverterService, unitConverterValidator validator.IngredientUnitConverterValidator, chartOfAccountTypeService service.ChartOfAccountTypeService, chartOfAccountTypeValidator validator.ChartOfAccountTypeValidator, chartOfAccountService service.ChartOfAccountService, chartOfAccountValidator validator.ChartOfAccountValidator, accountService service.AccountService, accountValidator validator.AccountValidator, orderIngredientTransactionService service.OrderIngredientTransactionService, orderIngredientTransactionValidator validator.OrderIngredientTransactionValidator, gamificationService service.GamificationService, gamificationValidator validator.GamificationValidator, rewardService service.RewardService, rewardValidator validator.RewardValidator, campaignService service.CampaignService, campaignValidator validator.CampaignValidator, customerAuthService service.CustomerAuthService, customerAuthValidator validator.CustomerAuthValidator, customerPointsService service.CustomerPointsService, spinGameService service.SpinGameService, customerAuthMiddleware *middleware.CustomerAuthMiddleware, userDeviceService service.UserDeviceService, userDeviceValidator validator.UserDeviceValidator, notificationService service.NotificationService, notificationValidator validator.NotificationValidator, productOutletPriceService service.ProductOutletPriceService, productOutletPriceValidator validator.ProductOutletPriceValidator, selfOrderHandler *handler.SelfOrderHandler) *Router {
|
func NewRouter(cfg *config.Config, healthHandler *handler.HealthHandler, authService service.AuthService, authMiddleware *middleware.AuthMiddleware, userService *service.UserServiceImpl, userValidator *validator.UserValidatorImpl, organizationService service.OrganizationService, organizationValidator validator.OrganizationValidator, outletService service.OutletService, outletValidator validator.OutletValidator, outletSettingService service.OutletSettingService, categoryService service.CategoryService, categoryValidator validator.CategoryValidator, productService service.ProductService, productValidator validator.ProductValidator, productVariantService service.ProductVariantService, productVariantValidator validator.ProductVariantValidator, inventoryService service.InventoryService, inventoryValidator validator.InventoryValidator, orderService service.OrderService, orderValidator validator.OrderValidator, fileService service.FileService, fileValidator validator.FileValidator, customerService service.CustomerService, customerValidator validator.CustomerValidator, paymentMethodService service.PaymentMethodService, paymentMethodValidator validator.PaymentMethodValidator, analyticsService *service.AnalyticsServiceImpl, reportService service.ReportService, tableService *service.TableServiceImpl, tableValidator *validator.TableValidator, unitService handler.UnitService, ingredientService handler.IngredientService, productRecipeService service.ProductRecipeService, vendorService service.VendorService, vendorValidator validator.VendorValidator, purchaseOrderService service.PurchaseOrderService, purchaseOrderValidator validator.PurchaseOrderValidator, unitConverterService service.IngredientUnitConverterService, unitConverterValidator validator.IngredientUnitConverterValidator, chartOfAccountTypeService service.ChartOfAccountTypeService, chartOfAccountTypeValidator validator.ChartOfAccountTypeValidator, chartOfAccountService service.ChartOfAccountService, chartOfAccountValidator validator.ChartOfAccountValidator, accountService service.AccountService, accountValidator validator.AccountValidator, orderIngredientTransactionService service.OrderIngredientTransactionService, orderIngredientTransactionValidator validator.OrderIngredientTransactionValidator, gamificationService service.GamificationService, gamificationValidator validator.GamificationValidator, rewardService service.RewardService, rewardValidator validator.RewardValidator, campaignService service.CampaignService, campaignValidator validator.CampaignValidator, customerAuthService service.CustomerAuthService, customerAuthValidator validator.CustomerAuthValidator, customerPointsService service.CustomerPointsService, spinGameService service.SpinGameService, customerAuthMiddleware *middleware.CustomerAuthMiddleware, userDeviceService service.UserDeviceService, userDeviceValidator validator.UserDeviceValidator, notificationService service.NotificationService, notificationValidator validator.NotificationValidator, productOutletPriceService service.ProductOutletPriceService, productOutletPriceValidator validator.ProductOutletPriceValidator, selfOrderHandler *handler.SelfOrderHandler, expenseService *service.ExpenseServiceImpl, expenseValidator *validator.ExpenseValidatorImpl) *Router {
|
||||||
|
|
||||||
return &Router{
|
return &Router{
|
||||||
config: cfg,
|
config: cfg,
|
||||||
@@ -97,6 +98,7 @@ func NewRouter(cfg *config.Config, healthHandler *handler.HealthHandler, authSer
|
|||||||
notificationHandler: handler.NewNotificationHandler(notificationService, notificationValidator),
|
notificationHandler: handler.NewNotificationHandler(notificationService, notificationValidator),
|
||||||
selfOrderHandler: selfOrderHandler,
|
selfOrderHandler: selfOrderHandler,
|
||||||
productOutletPriceHandler: handler.NewProductOutletPriceHandler(productOutletPriceService, productOutletPriceValidator),
|
productOutletPriceHandler: handler.NewProductOutletPriceHandler(productOutletPriceService, productOutletPriceValidator),
|
||||||
|
expenseHandler: handler.NewExpenseHandler(expenseService, expenseValidator),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -444,6 +446,16 @@ func (r *Router) addAppRoutes(rg *gin.Engine) {
|
|||||||
accounts.GET("/:id/balance", r.accountHandler.GetAccountBalance)
|
accounts.GET("/:id/balance", r.accountHandler.GetAccountBalance)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
expenses := protected.Group("/expenses")
|
||||||
|
expenses.Use(r.authMiddleware.RequireAdminOrManager())
|
||||||
|
{
|
||||||
|
expenses.POST("", r.expenseHandler.CreateExpense)
|
||||||
|
expenses.GET("", r.expenseHandler.ListExpenses)
|
||||||
|
expenses.GET("/:id", r.expenseHandler.GetExpense)
|
||||||
|
expenses.PUT("/:id", r.expenseHandler.UpdateExpense)
|
||||||
|
expenses.DELETE("/:id", r.expenseHandler.DeleteExpense)
|
||||||
|
}
|
||||||
|
|
||||||
orderIngredientTransactions := protected.Group("/order-ingredient-transactions")
|
orderIngredientTransactions := protected.Group("/order-ingredient-transactions")
|
||||||
orderIngredientTransactions.Use(r.authMiddleware.RequireAdminOrManager())
|
orderIngredientTransactions.Use(r.authMiddleware.RequireAdminOrManager())
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -306,20 +306,8 @@ func (s *AnalyticsServiceImpl) validateProfitLossAnalyticsRequest(req *models.Pr
|
|||||||
return fmt.Errorf("organization_id is required")
|
return fmt.Errorf("organization_id is required")
|
||||||
}
|
}
|
||||||
|
|
||||||
if req.DateFrom.IsZero() {
|
if req.Date.IsZero() {
|
||||||
return fmt.Errorf("date_from is required")
|
return fmt.Errorf("date is required")
|
||||||
}
|
|
||||||
|
|
||||||
if req.DateTo.IsZero() {
|
|
||||||
return fmt.Errorf("date_to is required")
|
|
||||||
}
|
|
||||||
|
|
||||||
if req.DateFrom.After(req.DateTo) {
|
|
||||||
return fmt.Errorf("date_from cannot be after date_to")
|
|
||||||
}
|
|
||||||
|
|
||||||
if req.GroupBy != "" && req.GroupBy != "hour" && req.GroupBy != "day" && req.GroupBy != "week" && req.GroupBy != "month" {
|
|
||||||
return fmt.Errorf("invalid group_by value, must be one of: hour, day, week, month")
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
@@ -0,0 +1,107 @@
|
|||||||
|
package service
|
||||||
|
|
||||||
|
import (
|
||||||
|
"apskel-pos-be/internal/appcontext"
|
||||||
|
"context"
|
||||||
|
|
||||||
|
"apskel-pos-be/internal/constants"
|
||||||
|
"apskel-pos-be/internal/contract"
|
||||||
|
"apskel-pos-be/internal/processor"
|
||||||
|
"apskel-pos-be/internal/transformer"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ExpenseService interface {
|
||||||
|
CreateExpense(ctx context.Context, apctx *appcontext.ContextInfo, req *contract.CreateExpenseRequest) *contract.Response
|
||||||
|
UpdateExpense(ctx context.Context, apctx *appcontext.ContextInfo, id uuid.UUID, req *contract.UpdateExpenseRequest) *contract.Response
|
||||||
|
DeleteExpense(ctx context.Context, apctx *appcontext.ContextInfo, id uuid.UUID) *contract.Response
|
||||||
|
GetExpenseByID(ctx context.Context, apctx *appcontext.ContextInfo, id uuid.UUID) *contract.Response
|
||||||
|
ListExpenses(ctx context.Context, apctx *appcontext.ContextInfo, req *contract.ListExpenseRequest) *contract.Response
|
||||||
|
}
|
||||||
|
|
||||||
|
type ExpenseServiceImpl struct {
|
||||||
|
expenseProcessor processor.ExpenseProcessor
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewExpenseService(expenseProcessor processor.ExpenseProcessor) *ExpenseServiceImpl {
|
||||||
|
return &ExpenseServiceImpl{
|
||||||
|
expenseProcessor: expenseProcessor,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *ExpenseServiceImpl) CreateExpense(ctx context.Context, apctx *appcontext.ContextInfo, req *contract.CreateExpenseRequest) *contract.Response {
|
||||||
|
modelReq := transformer.CreateExpenseRequestToModel(req)
|
||||||
|
|
||||||
|
expenseResponse, err := s.expenseProcessor.CreateExpense(ctx, apctx.OrganizationID, modelReq)
|
||||||
|
if err != nil {
|
||||||
|
errorResp := contract.NewResponseError(constants.InternalServerErrorCode, constants.ExpenseServiceEntity, err.Error())
|
||||||
|
return contract.BuildErrorResponse([]*contract.ResponseError{errorResp})
|
||||||
|
}
|
||||||
|
|
||||||
|
contractResponse := transformer.ExpenseModelResponseToResponse(expenseResponse)
|
||||||
|
return contract.BuildSuccessResponse(contractResponse)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *ExpenseServiceImpl) UpdateExpense(ctx context.Context, apctx *appcontext.ContextInfo, id uuid.UUID, req *contract.UpdateExpenseRequest) *contract.Response {
|
||||||
|
modelReq := transformer.UpdateExpenseRequestToModel(req)
|
||||||
|
|
||||||
|
expenseResponse, err := s.expenseProcessor.UpdateExpense(ctx, id, apctx.OrganizationID, modelReq)
|
||||||
|
if err != nil {
|
||||||
|
errorResp := contract.NewResponseError(constants.InternalServerErrorCode, constants.ExpenseServiceEntity, err.Error())
|
||||||
|
return contract.BuildErrorResponse([]*contract.ResponseError{errorResp})
|
||||||
|
}
|
||||||
|
|
||||||
|
contractResponse := transformer.ExpenseModelResponseToResponse(expenseResponse)
|
||||||
|
return contract.BuildSuccessResponse(contractResponse)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *ExpenseServiceImpl) DeleteExpense(ctx context.Context, apctx *appcontext.ContextInfo, id uuid.UUID) *contract.Response {
|
||||||
|
err := s.expenseProcessor.DeleteExpense(ctx, id, apctx.OrganizationID)
|
||||||
|
if err != nil {
|
||||||
|
errorResp := contract.NewResponseError(constants.InternalServerErrorCode, constants.ExpenseServiceEntity, err.Error())
|
||||||
|
return contract.BuildErrorResponse([]*contract.ResponseError{errorResp})
|
||||||
|
}
|
||||||
|
|
||||||
|
return contract.BuildSuccessResponse(map[string]interface{}{
|
||||||
|
"message": "Expense deleted successfully",
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *ExpenseServiceImpl) GetExpenseByID(ctx context.Context, apctx *appcontext.ContextInfo, id uuid.UUID) *contract.Response {
|
||||||
|
expenseResponse, err := s.expenseProcessor.GetExpenseByID(ctx, id, apctx.OrganizationID)
|
||||||
|
if err != nil {
|
||||||
|
errorResp := contract.NewResponseError(constants.InternalServerErrorCode, constants.ExpenseServiceEntity, err.Error())
|
||||||
|
return contract.BuildErrorResponse([]*contract.ResponseError{errorResp})
|
||||||
|
}
|
||||||
|
|
||||||
|
contractResponse := transformer.ExpenseModelResponseToResponse(expenseResponse)
|
||||||
|
return contract.BuildSuccessResponse(contractResponse)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *ExpenseServiceImpl) ListExpenses(ctx context.Context, apctx *appcontext.ContextInfo, req *contract.ListExpenseRequest) *contract.Response {
|
||||||
|
modelReq := transformer.ListExpenseRequestToModel(req)
|
||||||
|
|
||||||
|
filters := make(map[string]interface{})
|
||||||
|
if modelReq.Search != "" {
|
||||||
|
filters["search"] = modelReq.Search
|
||||||
|
}
|
||||||
|
|
||||||
|
expenses, totalPages, err := s.expenseProcessor.ListExpenses(ctx, apctx.OrganizationID, filters, modelReq.Page, modelReq.Limit)
|
||||||
|
if err != nil {
|
||||||
|
errorResp := contract.NewResponseError(constants.InternalServerErrorCode, constants.ExpenseServiceEntity, err.Error())
|
||||||
|
return contract.BuildErrorResponse([]*contract.ResponseError{errorResp})
|
||||||
|
}
|
||||||
|
|
||||||
|
contractResponses := transformer.ExpenseModelResponsesToResponses(expenses)
|
||||||
|
|
||||||
|
response := contract.ListExpenseResponse{
|
||||||
|
Expenses: contractResponses,
|
||||||
|
TotalCount: len(contractResponses),
|
||||||
|
Page: modelReq.Page,
|
||||||
|
Limit: modelReq.Limit,
|
||||||
|
TotalPages: totalPages,
|
||||||
|
}
|
||||||
|
|
||||||
|
return contract.BuildSuccessResponse(response)
|
||||||
|
}
|
||||||
@@ -108,7 +108,6 @@ func (s *ProductOutletPriceServiceImpl) BulkUpsert(ctx context.Context, req *con
|
|||||||
ProductID: req.ProductID,
|
ProductID: req.ProductID,
|
||||||
OutletID: p.OutletID,
|
OutletID: p.OutletID,
|
||||||
Price: p.Price,
|
Price: p.Price,
|
||||||
PrintToChecker: p.PrintToChecker,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -113,7 +113,8 @@ func (s *ReportServiceImpl) GenerateDailyTransactionPDF(ctx context.Context, org
|
|||||||
end := day.Add(24*time.Hour - time.Nanosecond)
|
end := day.Add(24*time.Hour - time.Nanosecond)
|
||||||
|
|
||||||
salesReq := &models.SalesAnalyticsRequest{OrganizationID: orgID, OutletID: &outID, DateFrom: start, DateTo: end, GroupBy: "day"}
|
salesReq := &models.SalesAnalyticsRequest{OrganizationID: orgID, OutletID: &outID, DateFrom: start, DateTo: end, GroupBy: "day"}
|
||||||
plReq := &models.ProfitLossAnalyticsRequest{OrganizationID: orgID, OutletID: &outID, DateFrom: start, DateTo: end, GroupBy: "day"}
|
plReq := &models.ProfitLossAnalyticsRequest{OrganizationID: orgID, OutletID: &outID, Date: day}
|
||||||
|
productReq := &models.ProductAnalyticsRequest{OrganizationID: orgID, OutletID: &outID, DateFrom: start, DateTo: end, Limit: 1000}
|
||||||
|
|
||||||
sales, err := s.analyticsService.GetSalesAnalytics(ctx, salesReq)
|
sales, err := s.analyticsService.GetSalesAnalytics(ctx, salesReq)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -123,6 +124,15 @@ func (s *ReportServiceImpl) GenerateDailyTransactionPDF(ctx context.Context, org
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return "", "", fmt.Errorf("get profit/loss analytics: %w", err)
|
return "", "", fmt.Errorf("get profit/loss analytics: %w", err)
|
||||||
}
|
}
|
||||||
|
products, err := s.analyticsService.GetProductAnalytics(ctx, productReq)
|
||||||
|
if err != nil {
|
||||||
|
return "", "", fmt.Errorf("get product analytics: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
totalOmset := getPLNominalByID(pl.MainSummary, "total_omset")
|
||||||
|
hpp := getPLNominalByID(pl.MainSummary, "hpp")
|
||||||
|
labaKotor := getPLNominalByID(pl.MainSummary, "laba_kotor")
|
||||||
|
labaKotorPct := getPLPctByID(pl.MainSummary, "laba_kotor")
|
||||||
|
|
||||||
data := reportTemplateData{
|
data := reportTemplateData{
|
||||||
OrganizationName: org.Name,
|
OrganizationName: org.Name,
|
||||||
@@ -133,28 +143,28 @@ func (s *ReportServiceImpl) GenerateDailyTransactionPDF(ctx context.Context, org
|
|||||||
GeneratedBy: generatedBy,
|
GeneratedBy: generatedBy,
|
||||||
PrintTime: time.Now().Format("02/01/2006 15:04:05"),
|
PrintTime: time.Now().Format("02/01/2006 15:04:05"),
|
||||||
Summary: reportSummary{
|
Summary: reportSummary{
|
||||||
TotalTransactions: pl.Summary.TotalOrders,
|
TotalTransactions: sales.Summary.TotalOrders,
|
||||||
TotalItems: sales.Summary.TotalItems,
|
TotalItems: sales.Summary.TotalItems,
|
||||||
GrossSales: formatCurrency(pl.Summary.TotalRevenue),
|
GrossSales: formatCurrency(totalOmset),
|
||||||
Discount: formatCurrency(pl.Summary.TotalDiscount),
|
Discount: formatCurrency(sales.Summary.TotalDiscount),
|
||||||
Tax: formatCurrency(pl.Summary.TotalTax),
|
Tax: formatCurrency(sales.Summary.TotalTax),
|
||||||
NetSales: formatCurrency(sales.Summary.NetSales),
|
NetSales: formatCurrency(sales.Summary.NetSales),
|
||||||
COGS: formatCurrency(pl.Summary.TotalCost),
|
COGS: formatCurrency(hpp),
|
||||||
GrossProfit: formatCurrency(pl.Summary.GrossProfit),
|
GrossProfit: formatCurrency(labaKotor),
|
||||||
GrossMarginPercent: fmt.Sprintf("%.2f", pl.Summary.GrossProfitMargin),
|
GrossMarginPercent: fmt.Sprintf("%.2f", labaKotorPct),
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
items := make([]reportItem, 0, len(pl.ProductData))
|
items := make([]reportItem, 0, len(products.Data))
|
||||||
for _, p := range pl.ProductData {
|
for _, p := range products.Data {
|
||||||
items = append(items, reportItem{
|
items = append(items, reportItem{
|
||||||
Name: p.ProductName,
|
Name: p.ProductName,
|
||||||
Quantity: p.QuantitySold,
|
Quantity: p.QuantitySold,
|
||||||
GrossSales: formatCurrency(p.Revenue),
|
GrossSales: formatCurrency(p.Revenue),
|
||||||
Discount: formatCurrency(0),
|
Discount: formatCurrency(0),
|
||||||
NetSales: formatCurrency(p.Revenue),
|
NetSales: formatCurrency(p.Revenue),
|
||||||
COGS: formatCurrency(p.Cost),
|
COGS: formatCurrency(p.StandardHppTotal),
|
||||||
GrossProfit: formatCurrency(p.GrossProfit),
|
GrossProfit: formatCurrency(p.Revenue - p.StandardHppTotal),
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
data.Items = items
|
data.Items = items
|
||||||
@@ -190,3 +200,21 @@ func (s *ReportServiceImpl) GenerateDailyTransactionPDF(ctx context.Context, org
|
|||||||
|
|
||||||
return publicURL, fileName, nil
|
return publicURL, fileName, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func getPLNominalByID(rows []models.ProfitLossSummaryRow, id string) float64 {
|
||||||
|
for _, row := range rows {
|
||||||
|
if row.ID == id {
|
||||||
|
return row.TodayNominal
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
|
||||||
|
func getPLPctByID(rows []models.ProfitLossSummaryRow, id string) float64 {
|
||||||
|
for _, row := range rows {
|
||||||
|
if row.ID == id {
|
||||||
|
return row.TodayPct
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
|||||||
@@ -427,93 +427,68 @@ func DashboardAnalyticsModelToContract(resp *models.DashboardAnalyticsResponse)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossAnalyticsContractToModel transforms contract request to model
|
|
||||||
func ProfitLossAnalyticsContractToModel(req *contract.ProfitLossAnalyticsRequest) (*models.ProfitLossAnalyticsRequest, error) {
|
func ProfitLossAnalyticsContractToModel(req *contract.ProfitLossAnalyticsRequest) (*models.ProfitLossAnalyticsRequest, error) {
|
||||||
if req == nil {
|
if req == nil {
|
||||||
return nil, fmt.Errorf("request cannot be nil")
|
return nil, fmt.Errorf("request cannot be nil")
|
||||||
}
|
}
|
||||||
|
|
||||||
// Parse date range using utility function
|
dateTime, err := util.ParseDateToJakartaTime(req.Date)
|
||||||
dateFrom, dateTo, err := util.ParseDateRangeToJakartaTime(req.DateFrom, req.DateTo)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("invalid date format: %w", err)
|
return nil, fmt.Errorf("invalid date format: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if dateFrom == nil || dateTo == nil {
|
if dateTime == nil {
|
||||||
return nil, fmt.Errorf("both date_from and date_to are required")
|
return nil, fmt.Errorf("date is required")
|
||||||
}
|
}
|
||||||
|
|
||||||
return &models.ProfitLossAnalyticsRequest{
|
return &models.ProfitLossAnalyticsRequest{
|
||||||
OrganizationID: req.OrganizationID,
|
OrganizationID: req.OrganizationID,
|
||||||
OutletID: parseOutletID(req.OutletID),
|
OutletID: parseOutletID(req.OutletID),
|
||||||
DateFrom: *dateFrom,
|
Date: *dateTime,
|
||||||
DateTo: *dateTo,
|
|
||||||
GroupBy: req.GroupBy,
|
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProfitLossAnalyticsModelToContract transforms model response to contract
|
|
||||||
func ProfitLossAnalyticsModelToContract(resp *models.ProfitLossAnalyticsResponse) *contract.ProfitLossAnalyticsResponse {
|
func ProfitLossAnalyticsModelToContract(resp *models.ProfitLossAnalyticsResponse) *contract.ProfitLossAnalyticsResponse {
|
||||||
if resp == nil {
|
if resp == nil {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Transform profit/loss data
|
mainSummary := make([]contract.ProfitLossSummaryRow, len(resp.MainSummary))
|
||||||
data := make([]contract.ProfitLossData, len(resp.Data))
|
for i, row := range resp.MainSummary {
|
||||||
for i, item := range resp.Data {
|
mainSummary[i] = profitLossSummaryRowModelToContract(row)
|
||||||
data[i] = contract.ProfitLossData{
|
|
||||||
Date: item.Date,
|
|
||||||
Revenue: item.Revenue,
|
|
||||||
Cost: item.Cost,
|
|
||||||
GrossProfit: item.GrossProfit,
|
|
||||||
GrossProfitMargin: item.GrossProfitMargin,
|
|
||||||
Tax: item.Tax,
|
|
||||||
Discount: item.Discount,
|
|
||||||
NetProfit: item.NetProfit,
|
|
||||||
NetProfitMargin: item.NetProfitMargin,
|
|
||||||
Orders: item.Orders,
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Transform product profit data
|
opsItems := make([]contract.OperationalExpenseItem, len(resp.OperationalExpenses))
|
||||||
productData := make([]contract.ProductProfitData, len(resp.ProductData))
|
for i, item := range resp.OperationalExpenses {
|
||||||
for i, item := range resp.ProductData {
|
opsItems[i] = contract.OperationalExpenseItem{
|
||||||
productData[i] = contract.ProductProfitData{
|
Item: item.Item,
|
||||||
ProductID: item.ProductID,
|
Nominal: item.Nominal,
|
||||||
ProductName: item.ProductName,
|
|
||||||
CategoryID: item.CategoryID,
|
|
||||||
CategoryName: item.CategoryName,
|
|
||||||
QuantitySold: item.QuantitySold,
|
|
||||||
Revenue: item.Revenue,
|
|
||||||
Cost: item.Cost,
|
|
||||||
GrossProfit: item.GrossProfit,
|
|
||||||
GrossProfitMargin: item.GrossProfitMargin,
|
|
||||||
AveragePrice: item.AveragePrice,
|
|
||||||
AverageCost: item.AverageCost,
|
|
||||||
ProfitPerUnit: item.ProfitPerUnit,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return &contract.ProfitLossAnalyticsResponse{
|
return &contract.ProfitLossAnalyticsResponse{
|
||||||
OrganizationID: resp.OrganizationID,
|
OrganizationID: resp.OrganizationID,
|
||||||
OutletID: resp.OutletID,
|
OutletID: resp.OutletID,
|
||||||
DateFrom: resp.DateFrom,
|
Date: resp.Date,
|
||||||
DateTo: resp.DateTo,
|
MainSummary: mainSummary,
|
||||||
GroupBy: resp.GroupBy,
|
OperationalExpenses: opsItems,
|
||||||
Summary: contract.ProfitLossSummary{
|
OperationalExpensesTotal: resp.OperationalExpensesTotal,
|
||||||
TotalRevenue: resp.Summary.TotalRevenue,
|
}
|
||||||
TotalCost: resp.Summary.TotalCost,
|
}
|
||||||
GrossProfit: resp.Summary.GrossProfit,
|
|
||||||
GrossProfitMargin: resp.Summary.GrossProfitMargin,
|
func profitLossSummaryRowModelToContract(row models.ProfitLossSummaryRow) contract.ProfitLossSummaryRow {
|
||||||
TotalTax: resp.Summary.TotalTax,
|
subItems := make([]contract.ProfitLossSummaryRow, len(row.SubItems))
|
||||||
TotalDiscount: resp.Summary.TotalDiscount,
|
for i, sub := range row.SubItems {
|
||||||
NetProfit: resp.Summary.NetProfit,
|
subItems[i] = profitLossSummaryRowModelToContract(sub)
|
||||||
NetProfitMargin: resp.Summary.NetProfitMargin,
|
}
|
||||||
TotalOrders: resp.Summary.TotalOrders,
|
return contract.ProfitLossSummaryRow{
|
||||||
AverageProfit: resp.Summary.AverageProfit,
|
ID: row.ID,
|
||||||
ProfitabilityRatio: resp.Summary.ProfitabilityRatio,
|
Label: row.Label,
|
||||||
},
|
IsBold: row.IsBold,
|
||||||
Data: data,
|
TodayNominal: row.TodayNominal,
|
||||||
ProductData: productData,
|
TodayPct: row.TodayPct,
|
||||||
|
MtdNominal: row.MtdNominal,
|
||||||
|
MtdPct: row.MtdPct,
|
||||||
|
SubItems: subItems,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,129 @@
|
|||||||
|
package transformer
|
||||||
|
|
||||||
|
import (
|
||||||
|
"apskel-pos-be/internal/contract"
|
||||||
|
"apskel-pos-be/internal/models"
|
||||||
|
)
|
||||||
|
|
||||||
|
func CreateExpenseRequestToModel(req *contract.CreateExpenseRequest) *models.CreateExpenseRequest {
|
||||||
|
items := make([]models.CreateExpenseItemRequest, len(req.Items))
|
||||||
|
for i, item := range req.Items {
|
||||||
|
items[i] = CreateExpenseItemRequestToModel(&item)
|
||||||
|
}
|
||||||
|
|
||||||
|
return &models.CreateExpenseRequest{
|
||||||
|
ExpenseName: req.ExpenseName,
|
||||||
|
Receiver: req.Receiver,
|
||||||
|
TransactionDate: req.TransactionDate,
|
||||||
|
CodeNumber: req.CodeNumber,
|
||||||
|
OutletID: req.OutletID,
|
||||||
|
Description: req.Description,
|
||||||
|
Tax: req.Tax,
|
||||||
|
Total: req.Total,
|
||||||
|
Items: items,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func CreateExpenseItemRequestToModel(req *contract.CreateExpenseItemRequest) models.CreateExpenseItemRequest {
|
||||||
|
return models.CreateExpenseItemRequest{
|
||||||
|
ChartOfAccountID: req.ChartOfAccountID,
|
||||||
|
Description: req.Description,
|
||||||
|
Amount: req.Amount,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func UpdateExpenseRequestToModel(req *contract.UpdateExpenseRequest) *models.UpdateExpenseRequest {
|
||||||
|
modelReq := &models.UpdateExpenseRequest{
|
||||||
|
ExpenseName: req.ExpenseName,
|
||||||
|
Receiver: req.Receiver,
|
||||||
|
TransactionDate: req.TransactionDate,
|
||||||
|
CodeNumber: req.CodeNumber,
|
||||||
|
OutletID: req.OutletID,
|
||||||
|
Description: req.Description,
|
||||||
|
Tax: req.Tax,
|
||||||
|
Total: req.Total,
|
||||||
|
Reserved1: req.Reserved1,
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Items != nil {
|
||||||
|
items := make([]models.UpdateExpenseItemRequest, len(req.Items))
|
||||||
|
for i, item := range req.Items {
|
||||||
|
items[i] = UpdateExpenseItemRequestToModel(&item)
|
||||||
|
}
|
||||||
|
modelReq.Items = items
|
||||||
|
}
|
||||||
|
|
||||||
|
return modelReq
|
||||||
|
}
|
||||||
|
|
||||||
|
func UpdateExpenseItemRequestToModel(req *contract.UpdateExpenseItemRequest) models.UpdateExpenseItemRequest {
|
||||||
|
return models.UpdateExpenseItemRequest{
|
||||||
|
ChartOfAccountID: req.ChartOfAccountID,
|
||||||
|
Description: req.Description,
|
||||||
|
Amount: req.Amount,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ListExpenseRequestToModel(req *contract.ListExpenseRequest) *models.ListExpenseRequest {
|
||||||
|
return &models.ListExpenseRequest{
|
||||||
|
Page: req.Page,
|
||||||
|
Limit: req.Limit,
|
||||||
|
Search: req.Search,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExpenseModelResponseToResponse(expense *models.ExpenseResponse) *contract.ExpenseResponse {
|
||||||
|
if expense == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
items := make([]contract.ExpenseItemResponse, len(expense.Items))
|
||||||
|
for i, item := range expense.Items {
|
||||||
|
items[i] = ExpenseItemModelResponseToResponse(&item)
|
||||||
|
}
|
||||||
|
|
||||||
|
return &contract.ExpenseResponse{
|
||||||
|
ID: expense.ID,
|
||||||
|
OrganizationID: expense.OrganizationID,
|
||||||
|
OutletID: expense.OutletID,
|
||||||
|
ExpenseName: expense.ExpenseName,
|
||||||
|
Receiver: expense.Receiver,
|
||||||
|
TransactionDate: expense.TransactionDate,
|
||||||
|
CodeNumber: expense.CodeNumber,
|
||||||
|
Description: expense.Description,
|
||||||
|
Tax: expense.Tax,
|
||||||
|
Total: expense.Total,
|
||||||
|
Reserved1: expense.Reserved1,
|
||||||
|
CreatedAt: expense.CreatedAt,
|
||||||
|
UpdatedAt: expense.UpdatedAt,
|
||||||
|
Items: items,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExpenseItemModelResponseToResponse(item *models.ExpenseItemResponse) contract.ExpenseItemResponse {
|
||||||
|
return contract.ExpenseItemResponse{
|
||||||
|
ID: item.ID,
|
||||||
|
ExpenseID: item.ExpenseID,
|
||||||
|
ChartOfAccountID: item.ChartOfAccountID,
|
||||||
|
ChartOfAccountName: item.ChartOfAccountName,
|
||||||
|
Description: item.Description,
|
||||||
|
Amount: item.Amount,
|
||||||
|
CreatedAt: item.CreatedAt,
|
||||||
|
UpdatedAt: item.UpdatedAt,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExpenseModelResponsesToResponses(expenses []*models.ExpenseResponse) []contract.ExpenseResponse {
|
||||||
|
if expenses == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
responses := make([]contract.ExpenseResponse, len(expenses))
|
||||||
|
for i, expense := range expenses {
|
||||||
|
response := ExpenseModelResponseToResponse(expense)
|
||||||
|
if response != nil {
|
||||||
|
responses[i] = *response
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return responses
|
||||||
|
}
|
||||||
@@ -100,8 +100,6 @@ func OrderModelToContract(resp *models.OrderResponse) *contract.OrderResponse {
|
|||||||
ProductName: item.ProductName,
|
ProductName: item.ProductName,
|
||||||
ProductVariantID: item.ProductVariantID,
|
ProductVariantID: item.ProductVariantID,
|
||||||
ProductVariantName: item.ProductVariantName,
|
ProductVariantName: item.ProductVariantName,
|
||||||
CategoryID: item.CategoryID,
|
|
||||||
CategoryName: item.CategoryName,
|
|
||||||
Quantity: item.Quantity,
|
Quantity: item.Quantity,
|
||||||
UnitPrice: item.UnitPrice,
|
UnitPrice: item.UnitPrice,
|
||||||
TotalPrice: item.TotalPrice,
|
TotalPrice: item.TotalPrice,
|
||||||
@@ -112,7 +110,6 @@ func OrderModelToContract(resp *models.OrderResponse) *contract.OrderResponse {
|
|||||||
CreatedAt: item.CreatedAt,
|
CreatedAt: item.CreatedAt,
|
||||||
UpdatedAt: item.UpdatedAt,
|
UpdatedAt: item.UpdatedAt,
|
||||||
PrinterType: item.PrinterType,
|
PrinterType: item.PrinterType,
|
||||||
PrintToChecker: item.PrintToChecker,
|
|
||||||
PaidQuantity: item.PaidQuantity,
|
PaidQuantity: item.PaidQuantity,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -171,8 +168,6 @@ func AddToOrderModelToContract(resp *models.AddToOrderResponse) *contract.AddToO
|
|||||||
ProductName: item.ProductName,
|
ProductName: item.ProductName,
|
||||||
ProductVariantID: item.ProductVariantID,
|
ProductVariantID: item.ProductVariantID,
|
||||||
ProductVariantName: item.ProductVariantName,
|
ProductVariantName: item.ProductVariantName,
|
||||||
CategoryID: item.CategoryID,
|
|
||||||
CategoryName: item.CategoryName,
|
|
||||||
Quantity: item.Quantity,
|
Quantity: item.Quantity,
|
||||||
UnitPrice: item.UnitPrice,
|
UnitPrice: item.UnitPrice,
|
||||||
TotalPrice: item.TotalPrice,
|
TotalPrice: item.TotalPrice,
|
||||||
@@ -182,7 +177,6 @@ func AddToOrderModelToContract(resp *models.AddToOrderResponse) *contract.AddToO
|
|||||||
Status: string(item.Status),
|
Status: string(item.Status),
|
||||||
CreatedAt: item.CreatedAt,
|
CreatedAt: item.CreatedAt,
|
||||||
UpdatedAt: item.UpdatedAt,
|
UpdatedAt: item.UpdatedAt,
|
||||||
PrintToChecker: item.PrintToChecker,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return &contract.AddToOrderResponse{
|
return &contract.AddToOrderResponse{
|
||||||
|
|||||||
@@ -14,7 +14,6 @@ func CreateProductOutletPriceRequestToModel(req *contract.CreateProductOutletPri
|
|||||||
ProductID: req.ProductID,
|
ProductID: req.ProductID,
|
||||||
OutletID: req.OutletID,
|
OutletID: req.OutletID,
|
||||||
Price: req.Price,
|
Price: req.Price,
|
||||||
PrintToChecker: req.PrintToChecker,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -25,7 +24,6 @@ func UpdateProductOutletPriceRequestToModel(req *contract.UpdateProductOutletPri
|
|||||||
|
|
||||||
return &models.UpdateProductOutletPriceRequest{
|
return &models.UpdateProductOutletPriceRequest{
|
||||||
Price: &req.Price,
|
Price: &req.Price,
|
||||||
PrintToChecker: req.PrintToChecker,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -39,7 +37,6 @@ func ProductOutletPriceModelToResponse(m *models.ProductOutletPrice) *contract.P
|
|||||||
ProductID: m.ProductID,
|
ProductID: m.ProductID,
|
||||||
OutletID: m.OutletID,
|
OutletID: m.OutletID,
|
||||||
Price: m.Price,
|
Price: m.Price,
|
||||||
PrintToChecker: m.PrintToChecker,
|
|
||||||
CreatedAt: m.CreatedAt,
|
CreatedAt: m.CreatedAt,
|
||||||
UpdatedAt: m.UpdatedAt,
|
UpdatedAt: m.UpdatedAt,
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -57,7 +57,6 @@ func CreateProductRequestToModel(apctx *appcontext.ContextInfo, req *contract.Cr
|
|||||||
BusinessType: businessType,
|
BusinessType: businessType,
|
||||||
ImageURL: req.ImageURL,
|
ImageURL: req.ImageURL,
|
||||||
PrinterType: req.PrinterType,
|
PrinterType: req.PrinterType,
|
||||||
PrintToChecker: req.PrintToChecker,
|
|
||||||
Metadata: metadata,
|
Metadata: metadata,
|
||||||
Variants: variants,
|
Variants: variants,
|
||||||
}
|
}
|
||||||
@@ -85,7 +84,6 @@ func UpdateProductRequestToModel(apctx *appcontext.ContextInfo, req *contract.Up
|
|||||||
Cost: req.Cost,
|
Cost: req.Cost,
|
||||||
ImageURL: req.ImageURL,
|
ImageURL: req.ImageURL,
|
||||||
PrinterType: req.PrinterType,
|
PrinterType: req.PrinterType,
|
||||||
PrintToChecker: req.PrintToChecker,
|
|
||||||
Metadata: metadata,
|
Metadata: metadata,
|
||||||
IsActive: req.IsActive,
|
IsActive: req.IsActive,
|
||||||
}
|
}
|
||||||
@@ -124,7 +122,6 @@ func ProductModelResponseToResponse(prod *models.ProductResponse) *contract.Prod
|
|||||||
OutletID: op.OutletID,
|
OutletID: op.OutletID,
|
||||||
OutletName: op.OutletName,
|
OutletName: op.OutletName,
|
||||||
Price: op.Price,
|
Price: op.Price,
|
||||||
PrintToChecker: op.PrintToChecker,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -144,7 +141,6 @@ func ProductModelResponseToResponse(prod *models.ProductResponse) *contract.Prod
|
|||||||
BusinessType: string(prod.BusinessType),
|
BusinessType: string(prod.BusinessType),
|
||||||
ImageURL: prod.ImageURL,
|
ImageURL: prod.ImageURL,
|
||||||
PrinterType: prod.PrinterType,
|
PrinterType: prod.PrinterType,
|
||||||
PrintToChecker: prod.PrintToChecker,
|
|
||||||
Metadata: prod.Metadata,
|
Metadata: prod.Metadata,
|
||||||
IsActive: prod.IsActive,
|
IsActive: prod.IsActive,
|
||||||
CreatedAt: prod.CreatedAt,
|
CreatedAt: prod.CreatedAt,
|
||||||
|
|||||||
@@ -0,0 +1,149 @@
|
|||||||
|
package validator
|
||||||
|
|
||||||
|
import (
|
||||||
|
"errors"
|
||||||
|
"fmt"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"apskel-pos-be/internal/constants"
|
||||||
|
"apskel-pos-be/internal/contract"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ExpenseValidator interface {
|
||||||
|
ValidateCreateExpenseRequest(req *contract.CreateExpenseRequest) (error, string)
|
||||||
|
ValidateUpdateExpenseRequest(req *contract.UpdateExpenseRequest) (error, string)
|
||||||
|
ValidateListExpenseRequest(req *contract.ListExpenseRequest) (error, string)
|
||||||
|
}
|
||||||
|
|
||||||
|
type ExpenseValidatorImpl struct{}
|
||||||
|
|
||||||
|
func NewExpenseValidator() *ExpenseValidatorImpl {
|
||||||
|
return &ExpenseValidatorImpl{}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (v *ExpenseValidatorImpl) ValidateCreateExpenseRequest(req *contract.CreateExpenseRequest) (error, string) {
|
||||||
|
if req == nil {
|
||||||
|
return errors.New("request body is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if strings.TrimSpace(req.ExpenseName) == "" {
|
||||||
|
return errors.New("expense_name is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if strings.TrimSpace(req.Receiver) == "" {
|
||||||
|
return errors.New("receiver is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if strings.TrimSpace(req.TransactionDate) == "" {
|
||||||
|
return errors.New("transaction_date is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if strings.TrimSpace(req.CodeNumber) == "" {
|
||||||
|
return errors.New("code_number is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if strings.TrimSpace(req.OutletID) == "" {
|
||||||
|
return errors.New("outlet_id is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if _, err := uuid.Parse(req.OutletID); err != nil {
|
||||||
|
return errors.New("outlet_id must be a valid UUID"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Total <= 0 {
|
||||||
|
return errors.New("total must be greater than 0"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Tax < 0 {
|
||||||
|
return errors.New("tax cannot be negative"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(req.Items) == 0 {
|
||||||
|
return errors.New("at least one item is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
for i, item := range req.Items {
|
||||||
|
if strings.TrimSpace(item.ChartOfAccountID) == "" {
|
||||||
|
return fmt.Errorf("item %d: chart_of_account_id is required", i), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
if _, err := uuid.Parse(item.ChartOfAccountID); err != nil {
|
||||||
|
return fmt.Errorf("item %d: chart_of_account_id must be a valid UUID", i), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
if item.Amount <= 0 {
|
||||||
|
return fmt.Errorf("item %d: amount must be greater than 0", i), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil, ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func (v *ExpenseValidatorImpl) ValidateUpdateExpenseRequest(req *contract.UpdateExpenseRequest) (error, string) {
|
||||||
|
if req == nil {
|
||||||
|
return errors.New("request body is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.ExpenseName != nil && strings.TrimSpace(*req.ExpenseName) == "" {
|
||||||
|
return errors.New("expense_name cannot be empty"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Receiver != nil && strings.TrimSpace(*req.Receiver) == "" {
|
||||||
|
return errors.New("receiver cannot be empty"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.CodeNumber != nil && strings.TrimSpace(*req.CodeNumber) == "" {
|
||||||
|
return errors.New("code_number cannot be empty"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.OutletID != nil {
|
||||||
|
if strings.TrimSpace(*req.OutletID) == "" {
|
||||||
|
return errors.New("outlet_id cannot be empty"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
if _, err := uuid.Parse(*req.OutletID); err != nil {
|
||||||
|
return errors.New("outlet_id must be a valid UUID"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Total != nil && *req.Total <= 0 {
|
||||||
|
return errors.New("total must be greater than 0"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Tax != nil && *req.Tax < 0 {
|
||||||
|
return errors.New("tax cannot be negative"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Items != nil {
|
||||||
|
for i, item := range req.Items {
|
||||||
|
if item.ChartOfAccountID != nil {
|
||||||
|
if strings.TrimSpace(*item.ChartOfAccountID) == "" {
|
||||||
|
return fmt.Errorf("item %d: chart_of_account_id cannot be empty", i), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
if _, err := uuid.Parse(*item.ChartOfAccountID); err != nil {
|
||||||
|
return fmt.Errorf("item %d: chart_of_account_id must be a valid UUID", i), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if item.Amount != nil && *item.Amount <= 0 {
|
||||||
|
return fmt.Errorf("item %d: amount must be greater than 0", i), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil, ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func (v *ExpenseValidatorImpl) ValidateListExpenseRequest(req *contract.ListExpenseRequest) (error, string) {
|
||||||
|
if req == nil {
|
||||||
|
return errors.New("request body is required"), constants.MissingFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Page < 1 {
|
||||||
|
return errors.New("page must be at least 1"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Limit < 1 || req.Limit > 100 {
|
||||||
|
return errors.New("limit must be between 1 and 100"), constants.MalformedFieldErrorCode
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil, ""
|
||||||
|
}
|
||||||
@@ -1 +0,0 @@
|
|||||||
ALTER TABLE product_outlet_prices DROP COLUMN IF EXISTS print_to_checker;
|
|
||||||
@@ -1 +0,0 @@
|
|||||||
ALTER TABLE product_outlet_prices ADD COLUMN print_to_checker BOOLEAN NOT NULL DEFAULT TRUE;
|
|
||||||
@@ -0,0 +1,2 @@
|
|||||||
|
DROP TABLE IF EXISTS expense_items;
|
||||||
|
DROP TABLE IF EXISTS expenses;
|
||||||
@@ -0,0 +1,33 @@
|
|||||||
|
CREATE TABLE expenses (
|
||||||
|
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
|
||||||
|
organization_id UUID NOT NULL REFERENCES organizations(id) ON DELETE CASCADE,
|
||||||
|
outlet_id UUID NOT NULL REFERENCES outlets(id) ON DELETE CASCADE,
|
||||||
|
receiver VARCHAR(255) NOT NULL,
|
||||||
|
transaction_date DATE NOT NULL,
|
||||||
|
code_number VARCHAR(50) NOT NULL,
|
||||||
|
description TEXT,
|
||||||
|
tax DECIMAL(15,2) NOT NULL DEFAULT 0,
|
||||||
|
total DECIMAL(15,2) NOT NULL DEFAULT 0,
|
||||||
|
reserved1 TEXT,
|
||||||
|
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
|
||||||
|
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW()
|
||||||
|
);
|
||||||
|
|
||||||
|
CREATE INDEX idx_expenses_organization_id ON expenses(organization_id);
|
||||||
|
CREATE INDEX idx_expenses_outlet_id ON expenses(outlet_id);
|
||||||
|
CREATE INDEX idx_expenses_transaction_date ON expenses(transaction_date);
|
||||||
|
CREATE INDEX idx_expenses_code_number ON expenses(code_number);
|
||||||
|
CREATE INDEX idx_expenses_created_at ON expenses(created_at);
|
||||||
|
|
||||||
|
CREATE TABLE expense_items (
|
||||||
|
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
|
||||||
|
expense_id UUID NOT NULL REFERENCES expenses(id) ON DELETE CASCADE,
|
||||||
|
chart_of_account_id UUID NOT NULL REFERENCES chart_of_accounts(id) ON DELETE RESTRICT,
|
||||||
|
description TEXT,
|
||||||
|
amount DECIMAL(15,2) NOT NULL DEFAULT 0,
|
||||||
|
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
|
||||||
|
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW()
|
||||||
|
);
|
||||||
|
|
||||||
|
CREATE INDEX idx_expense_items_expense_id ON expense_items(expense_id);
|
||||||
|
CREATE INDEX idx_expense_items_chart_of_account_id ON expense_items(chart_of_account_id);
|
||||||
@@ -0,0 +1,2 @@
|
|||||||
|
DROP INDEX IF EXISTS idx_expenses_expense_name;
|
||||||
|
ALTER TABLE expenses DROP COLUMN expense_name;
|
||||||
@@ -0,0 +1,2 @@
|
|||||||
|
ALTER TABLE expenses ADD COLUMN expense_name VARCHAR(255) NOT NULL DEFAULT '';
|
||||||
|
CREATE INDEX idx_expenses_expense_name ON expenses(expense_name);
|
||||||
Reference in New Issue
Block a user