diff --git a/.gitea/workflows/ci.yml b/.gitea/workflows/ci.yml new file mode 100644 index 0000000..73a0fe5 --- /dev/null +++ b/.gitea/workflows/ci.yml @@ -0,0 +1,24 @@ +name: CI + +on: + push: + branches: [dev] + +jobs: + ci: + runs-on: ubuntu-latest + steps: + - uses: actions/checkout@v4 + + - uses: actions/setup-go@v5 + with: + go-version: '1.22' + + - name: Vet + run: go vet ./... + + - name: Test + run: go test ./... -v + + - name: Build + run: CGO_ENABLED=0 go build -o main ./cmd/api diff --git a/.gitea/workflows/deploy-prod.yml b/.gitea/workflows/deploy-prod.yml new file mode 100644 index 0000000..6327d52 --- /dev/null +++ b/.gitea/workflows/deploy-prod.yml @@ -0,0 +1,21 @@ +name: Deploy Production + +on: + push: + branches: [main] + +jobs: + deploy: + runs-on: ubuntu-latest + steps: + - uses: actions/checkout@v4 + + - uses: actions/setup-go@v5 + with: + go-version: '1.22' + + - name: Build + run: CGO_ENABLED=0 go build -o main ./cmd/api + + - name: Deploy + run: echo "Production deploy via docker" diff --git a/cmd/api/main.go b/cmd/api/main.go index dcbd487..b8d73ea 100644 --- a/cmd/api/main.go +++ b/cmd/api/main.go @@ -71,6 +71,7 @@ func main() { profileHandler := handler.NewProfileHandler(userRepo) habitFreezeHandler := handler.NewHabitFreezeHandler(habitFreezeRepo, habitRepo) savingsHandler := handler.NewSavingsHandler(savingsRepo) + interestHandler := handler.NewInterestHandler(db) // Initialize middleware authMiddleware := customMiddleware.NewAuthMiddleware(cfg.JWTSecret) @@ -103,6 +104,9 @@ func main() { r.Post("/auth/forgot-password", authHandler.ForgotPassword) r.Post("/auth/reset-password", authHandler.ResetPassword) + // Internal routes (API key protected) + interestHandler.RegisterRoutes(r) + // Protected routes r.Group(func(r chi.Router) { r.Use(authMiddleware.Authenticate) diff --git a/internal/handler/interest.go b/internal/handler/interest.go new file mode 100644 index 0000000..6a06ef5 --- /dev/null +++ b/internal/handler/interest.go @@ -0,0 +1,58 @@ +package handler + +import ( + "encoding/json" + "net/http" + "os" + + "github.com/go-chi/chi/v5" + "github.com/jmoiron/sqlx" + + "github.com/daniil/homelab-api/internal/service" +) + +type InterestHandler struct { + service *service.InterestService + secretKey string +} + +func NewInterestHandler(db *sqlx.DB) *InterestHandler { + secretKey := os.Getenv("INTERNAL_API_KEY") + if secretKey == "" { + secretKey = "pulse-internal-2026" + } + return &InterestHandler{ + service: service.NewInterestService(db), + secretKey: secretKey, + } +} + +// RegisterRoutes регистрирует internal routes +func (h *InterestHandler) RegisterRoutes(r chi.Router) { + r.Post("/internal/calculate-interest", h.CalculateInterest) +} + +// CalculateInterest запускает расчёт процентов для всех вкладов +// POST /internal/calculate-interest +// Header: X-Internal-Key: +func (h *InterestHandler) CalculateInterest(w http.ResponseWriter, r *http.Request) { + // Verify internal API key + key := r.Header.Get("X-Internal-Key") + if key != h.secretKey { + http.Error(w, "Unauthorized", http.StatusUnauthorized) + return + } + + results, err := h.service.CalculateAllDepositsInterest() + if err != nil { + w.Header().Set("Content-Type", "application/json") + json.NewEncoder(w).Encode(map[string]string{"error": err.Error()}) + return + } + + w.Header().Set("Content-Type", "application/json") + json.NewEncoder(w).Encode(map[string]interface{}{ + "message": "Interest calculation completed", + "results": results, + }) +} diff --git a/internal/health/health_test.go b/internal/health/health_test.go new file mode 100644 index 0000000..7aecb47 --- /dev/null +++ b/internal/health/health_test.go @@ -0,0 +1,10 @@ +package health + +import "testing" + +func TestHealthCheck(t *testing.T) { + status := "ok" + if status != "ok" { + t.Errorf("expected ok, got %s", status) + } +} diff --git a/internal/service/interest.go b/internal/service/interest.go new file mode 100644 index 0000000..89bb385 --- /dev/null +++ b/internal/service/interest.go @@ -0,0 +1,123 @@ +package service + +import ( + "fmt" + "log" + "math" + "time" + + "github.com/daniil/homelab-api/internal/model" + "github.com/jmoiron/sqlx" +) + +type InterestService struct { + db *sqlx.DB +} + +func NewInterestService(db *sqlx.DB) *InterestService { + return &InterestService{db: db} +} + +// CalculateAllDepositsInterest проверяет все вклады и начисляет проценты где нужно +func (s *InterestService) CalculateAllDepositsInterest() ([]string, error) { + var results []string + + // Получаем все активные вклады + var deposits []model.SavingsCategory + err := s.db.Select(&deposits, ` + SELECT * FROM savings_categories + WHERE is_deposit = true AND interest_rate > 0 + `) + if err != nil { + return nil, fmt.Errorf("failed to fetch deposits: %w", err) + } + + log.Printf("Found %d deposits to check", len(deposits)) + + for _, deposit := range deposits { + result, err := s.CalculateInterestForDeposit(&deposit) + if err != nil { + log.Printf("Error calculating interest for %s: %v", deposit.Name, err) + results = append(results, fmt.Sprintf("❌ %s: %v", deposit.Name, err)) + continue + } + if result != "" { + results = append(results, result) + } + } + + return results, nil +} + +// CalculateInterestForDeposit рассчитывает проценты для одного вклада +func (s *InterestService) CalculateInterestForDeposit(deposit *model.SavingsCategory) (string, error) { + if !deposit.IsDeposit || deposit.InterestRate <= 0 { + return "", nil + } + + if !deposit.DepositStartDate.Valid { + return "", fmt.Errorf("no start date") + } + + now := time.Now() + startDate := deposit.DepositStartDate.Time + + // Проверяем не истёк ли срок вклада + if deposit.DepositTerm > 0 { + endDate := startDate.AddDate(0, deposit.DepositTerm, 0) + if now.After(endDate) { + log.Printf("Deposit %s expired on %v", deposit.Name, endDate) + return "", nil + } + } + + // День начисления = день открытия вклада + interestDay := startDate.Day() + + // Сегодня день начисления? + if now.Day() != interestDay { + return "", nil + } + + // Проверяем не начислены ли уже проценты за этот месяц + currentMonth := fmt.Sprintf("%02d.%d", now.Month(), now.Year()) + searchPattern := "%" + currentMonth + "%" + var count int + err := s.db.Get(&count, `SELECT COUNT(*) FROM savings_transactions WHERE category_id = $1 AND description LIKE $2`, deposit.ID, searchPattern) + if err != nil { + return "", err + } + if count > 0 { + log.Printf("Interest for %s already calculated for %s", deposit.Name, currentMonth) + return "", nil + } + + // Получаем текущий баланс + var balance float64 + err = s.db.Get(&balance, `SELECT COALESCE(SUM(CASE WHEN type = 'deposit' THEN amount ELSE -amount END), 0) FROM savings_transactions WHERE category_id = $1`, deposit.ID) + if err != nil { + return "", err + } + + // Рассчитываем проценты (годовая ставка / 12) + monthlyRate := deposit.InterestRate / 12 / 100 + interest := balance * monthlyRate + interest = math.Round(interest*100) / 100 + + if interest <= 0 { + return "", nil + } + + // Добавляем транзакцию + description := fmt.Sprintf("Проценты за %s (%.2f%% годовых)", currentMonth, deposit.InterestRate) + + _, err = s.db.Exec(`INSERT INTO savings_transactions (user_id, category_id, type, amount, date, description) VALUES ($1, $2, 'deposit', $3, $4, $5)`, deposit.UserID, deposit.ID, interest, now.Format("2006-01-02"), description) + if err != nil { + return "", err + } + + result := fmt.Sprintf("✅ %s: +%.2f₽ (баланс: %.2f₽)", deposit.Name, interest, balance+interest) + log.Printf(result) + + return result, nil +}