mirror of
https://github.com/andwati/telecom-platform.git
synced 2026-10-29 16:12:15 +00:00
nutcas3
4fe9d22284
- Add Repository interface with rate plan CRUD, subscription management, usage tracking, and analytics operations - Add RatePlan struct with pricing, allowances, overage rates, discounts, and metadata fields - Add RatePlanSubscription struct with billing cycle, auto-renewal, and applied discounts support - Add RatePlanUsage struct with cycle tracking and data/voice/SMS usage metrics - Add filter types for rate plans, subscriptions, usage analytics, and revenue analytics
78 lines
2.2 KiB
Go
78 lines
2.2 KiB
Go
package services
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/nutcas3/telecom-platform/apps/carrier-connector/internal/repository"
|
|
)
|
|
|
|
func (s *Service) validateRatePlan(plan *repository.RatePlan) error {
|
|
if plan.Name == "" {
|
|
return fmt.Errorf("rate plan name is required")
|
|
}
|
|
if plan.CarrierID == "" {
|
|
return fmt.Errorf("carrier ID is required")
|
|
}
|
|
if plan.Region == "" {
|
|
return fmt.Errorf("region is required")
|
|
}
|
|
if plan.BasePrice < 0 {
|
|
return fmt.Errorf("base price cannot be negative")
|
|
}
|
|
if plan.Currency == "" {
|
|
return fmt.Errorf("currency is required")
|
|
}
|
|
if plan.BillingCycle == "" {
|
|
return fmt.Errorf("billing cycle is required")
|
|
}
|
|
if plan.ValidFrom.IsZero() {
|
|
return fmt.Errorf("valid from date is required")
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (s *Service) validateSubscribeRequest(req *repository.SubscribeRequest) error {
|
|
if req.ProfileID == "" {
|
|
return fmt.Errorf("profile ID is required")
|
|
}
|
|
if req.RatePlanID == "" {
|
|
return fmt.Errorf("rate plan ID is required")
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (s *Service) calculateNextBillingDate(cycle repository.BillingCycle, from time.Time) time.Time {
|
|
switch cycle {
|
|
case repository.BillingCycleDaily:
|
|
return from.AddDate(0, 0, 1)
|
|
case repository.BillingCycleWeekly:
|
|
return from.AddDate(0, 0, 7)
|
|
case repository.BillingCycleMonthly:
|
|
return from.AddDate(0, 1, 0)
|
|
case repository.BillingCycleQuarterly:
|
|
return from.AddDate(0, 3, 0)
|
|
case repository.BillingCycleYearly:
|
|
return from.AddDate(1, 0, 0)
|
|
default:
|
|
return from.AddDate(0, 1, 0) // Default to monthly
|
|
}
|
|
}
|
|
|
|
func (s *Service) calculateCycleEnd(cycle repository.BillingCycle, cycleStart time.Time) time.Time {
|
|
switch cycle {
|
|
case repository.BillingCycleDaily:
|
|
return cycleStart.AddDate(0, 0, 1).Add(-time.Nanosecond)
|
|
case repository.BillingCycleWeekly:
|
|
return cycleStart.AddDate(0, 0, 7).Add(-time.Nanosecond)
|
|
case repository.BillingCycleMonthly:
|
|
return cycleStart.AddDate(0, 1, 0).Add(-time.Nanosecond)
|
|
case repository.BillingCycleQuarterly:
|
|
return cycleStart.AddDate(0, 3, 0).Add(-time.Nanosecond)
|
|
case repository.BillingCycleYearly:
|
|
return cycleStart.AddDate(1, 0, 0).Add(-time.Nanosecond)
|
|
default:
|
|
return cycleStart.AddDate(0, 1, 0).Add(-time.Nanosecond) // Default to monthly
|
|
}
|
|
}
|