Add excusive-summary endpoint

2026-06-15 17:01:47 +07:00
parent 8c4d9c69d0
commit b2db56f855
12 changed files with 1205 additions and 0 deletions
@@ -18,6 +18,7 @@ type AnalyticsRepository interface {
 	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)
 	GetProfitLossAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time, groupBy string) (*entities.ProfitLossAnalytics, error)
+	GetExclusiveSummaryAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) (*entities.ExclusiveSummaryAnalytics, error)
 }

 type AnalyticsRepositoryImpl struct {
@@ -703,3 +704,210 @@ func (r *AnalyticsRepositoryImpl) getOperationalExpenseItems(ctx context.Context

 	return results, err
 }
+
+func (r *AnalyticsRepositoryImpl) GetExclusiveSummaryAnalytics(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) (*entities.ExclusiveSummaryAnalytics, error) {
+	type salesResult struct {
+		SalesTotal float64
+		SalesCount int64
+	}
+
+	var sales salesResult
+	salesQuery := r.db.WithContext(ctx).
+		Table("orders o").
+		Select(`
+			COALESCE(SUM(o.total_amount), 0) as sales_total,
+			COUNT(o.id) as sales_count
+		`).
+		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)
+	salesQuery = r.resolveOutletID(salesQuery, outletID, "o.outlet_id")
+	if err := salesQuery.Scan(&sales).Error; err != nil {
+		return nil, err
+	}
+
+	hppBreakdown, err := r.getExclusiveSummaryHPPBreakdown(ctx, organizationID, outletID, dateFrom, dateTo)
+	if err != nil {
+		return nil, err
+	}
+
+	operationalExpenseBreakdown, err := r.getExclusiveSummaryOperationalExpenseBreakdown(ctx, organizationID, outletID, dateFrom, dateTo)
+	if err != nil {
+		return nil, err
+	}
+
+	dailySummary, err := r.getExclusiveSummaryDailySummary(ctx, organizationID, outletID, dateFrom, dateTo)
+	if err != nil {
+		return nil, err
+	}
+
+	dailyTransactions, err := r.getExclusiveSummaryDailyTransactions(ctx, organizationID, outletID, dateFrom, dateTo)
+	if err != nil {
+		return nil, err
+	}
+
+	return &entities.ExclusiveSummaryAnalytics{
+		SalesTotal:                  sales.SalesTotal,
+		SalesCount:                  sales.SalesCount,
+		HPPBreakdown:                hppBreakdown,
+		OperationalExpenseBreakdown: operationalExpenseBreakdown,
+		DailySummary:                dailySummary,
+		DailyTransactions:           dailyTransactions,
+	}, nil
+}
+
+func (r *AnalyticsRepositoryImpl) getExclusiveSummaryHPPBreakdown(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) ([]entities.ExclusiveSummaryCategoryTotal, error) {
+	var results []entities.ExclusiveSummaryCategoryTotal
+
+	query := r.db.WithContext(ctx).
+		Table("purchase_order_items poi").
+		Select(`
+			pc.code as category_code,
+			pc.name as category_name,
+			COALESCE(SUM(poi.amount), 0) as amount
+		`).
+		Joins("JOIN purchase_orders po ON poi.purchase_order_id = po.id").
+		Joins("JOIN purchase_categories pc ON poi.purchase_category_id = pc.id").
+		Joins("JOIN ingredients i ON poi.ingredient_id = i.id").
+		Joins("LEFT JOIN units u ON poi.unit_id = u.id").
+		Where("po.organization_id = ?", organizationID).
+		Where("pc.type = ?", entities.PurchaseCategoryTypeRawMaterial).
+		Where("po.status = ?", "received").
+		Where("po.transaction_date >= ? AND po.transaction_date <= ?", dateFrom, dateTo)
+	query = r.applyPurchaseOrderItemOutletFilter(query, outletID)
+
+	err := query.
+		Group("pc.id, pc.code, pc.name, pc.sort_order").
+		Order("pc.sort_order ASC, pc.name ASC").
+		Scan(&results).Error
+
+	return results, err
+}
+
+func (r *AnalyticsRepositoryImpl) getExclusiveSummaryOperationalExpenseBreakdown(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) ([]entities.ExclusiveSummaryCategoryTotal, error) {
+	var results []entities.ExclusiveSummaryCategoryTotal
+
+	query := r.db.WithContext(ctx).
+		Table("expense_items ei").
+		Select(`
+			pc.code as category_code,
+			pc.name as category_name,
+			COALESCE(SUM(ei.amount), 0) as amount
+		`).
+		Joins("JOIN expenses e ON ei.expense_id = e.id").
+		Joins("JOIN purchase_categories pc ON ei.purchase_category_id = pc.id").
+		Where("e.organization_id = ?", organizationID).
+		Where("pc.type = ?", entities.PurchaseCategoryTypeExpense).
+		Where("e.status = ?", "approved").
+		Where("e.transaction_date >= ? AND e.transaction_date <= ?", dateFrom, dateTo)
+
+	if outletID != nil {
+		query = query.Where("e.outlet_id = ?", *outletID)
+	}
+
+	err := query.
+		Group("pc.id, pc.code, pc.name, pc.sort_order").
+		Order("pc.sort_order ASC, pc.name ASC").
+		Scan(&results).Error
+
+	return results, err
+}
+
+func (r *AnalyticsRepositoryImpl) getExclusiveSummaryDailySummary(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) ([]entities.ExclusiveSummaryDailySummary, error) {
+	var results []entities.ExclusiveSummaryDailySummary
+	rawQuery, args := r.exclusiveSummaryTransactionUnionQuery(organizationID, outletID, dateFrom, dateTo)
+
+	err := r.db.WithContext(ctx).Raw(`
+		SELECT date, COUNT(*) as transaction_count, COALESCE(SUM(amount), 0) as total_cost
+		FROM (`+rawQuery+`) transactions
+		GROUP BY date
+		ORDER BY date ASC
+	`, args...).Scan(&results).Error
+
+	return results, err
+}
+
+func (r *AnalyticsRepositoryImpl) getExclusiveSummaryDailyTransactions(ctx context.Context, organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) ([]entities.ExclusiveSummaryDailyTransaction, error) {
+	var results []entities.ExclusiveSummaryDailyTransaction
+	rawQuery, args := r.exclusiveSummaryTransactionUnionQuery(organizationID, outletID, dateFrom, dateTo)
+
+	err := r.db.WithContext(ctx).Raw(`
+		SELECT date, category_code, category_name, description, amount, source
+		FROM (`+rawQuery+`) transactions
+		ORDER BY date ASC, source ASC, category_name ASC, description ASC
+	`, args...).Scan(&results).Error
+
+	return results, err
+}
+
+func (r *AnalyticsRepositoryImpl) exclusiveSummaryTransactionUnionQuery(organizationID uuid.UUID, outletID *uuid.UUID, dateFrom, dateTo time.Time) (string, []interface{}) {
+	poOutletFilter := ""
+	expenseOutletFilter := ""
+	args := []interface{}{
+		organizationID,
+		entities.PurchaseCategoryTypeRawMaterial,
+		"received",
+		dateFrom,
+		dateTo,
+	}
+
+	if outletID != nil {
+		poOutletFilter = "AND (i.outlet_id = ? OR u.outlet_id = ?)"
+		args = append(args, *outletID, *outletID)
+	}
+
+	args = append(args,
+		organizationID,
+		entities.PurchaseCategoryTypeExpense,
+		"approved",
+		dateFrom,
+		dateTo,
+	)
+
+	if outletID != nil {
+		expenseOutletFilter = "AND e.outlet_id = ?"
+		args = append(args, *outletID)
+	}
+
+	query := `
+		SELECT
+			DATE(po.transaction_date) as date,
+			pc.code as category_code,
+			pc.name as category_name,
+			COALESCE(NULLIF(poi.description, ''), i.name, pc.name) as description,
+			poi.amount as amount,
+			'purchase_order' as source
+		FROM purchase_order_items poi
+		JOIN purchase_orders po ON poi.purchase_order_id = po.id
+		JOIN purchase_categories pc ON poi.purchase_category_id = pc.id
+		JOIN ingredients i ON poi.ingredient_id = i.id
+		LEFT JOIN units u ON poi.unit_id = u.id
+		WHERE po.organization_id = ?
+		  AND pc.type = ?
+		  AND po.status = ?
+		  AND po.transaction_date >= ? AND po.transaction_date <= ?
+		  ` + poOutletFilter + `
+
+		UNION ALL
+
+		SELECT
+			DATE(e.transaction_date) as date,
+			pc.code as category_code,
+			pc.name as category_name,
+			COALESCE(NULLIF(ei.item, ''), NULLIF(ei.description, ''), pc.name) as description,
+			ei.amount as amount,
+			'expense' as source
+		FROM expense_items ei
+		JOIN expenses e ON ei.expense_id = e.id
+		JOIN purchase_categories pc ON ei.purchase_category_id = pc.id
+		WHERE e.organization_id = ?
+		  AND pc.type = ?
+		  AND e.status = ?
+		  AND e.transaction_date >= ? AND e.transaction_date <= ?
+		  ` + expenseOutletFilter + `
+	`
+
+	return query, args
+}