129 lines
3.8 KiB
Go
129 lines
3.8 KiB
Go
package handlers
|
|
|
|
import (
|
|
"fmt"
|
|
"log/slog"
|
|
"time"
|
|
|
|
"terminalShop/pkg/database"
|
|
"terminalShop/pkg/models"
|
|
"terminalShop/pkg/notify"
|
|
|
|
"github.com/stripe/stripe-go/v78"
|
|
"github.com/stripe/stripe-go/v78/paymentintent"
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
func reconcileLog() *slog.Logger { return slog.With("component", "reconcile") }
|
|
|
|
// ReconcileOrders finds pending orders with no Stripe ID older than 10 minutes
|
|
// and checks whether Stripe has a succeeded PaymentIntent for them. This fixes
|
|
// the case where the server crashed after charging but before the DB transaction
|
|
// completed.
|
|
func ReconcileOrders(stripeKey string) {
|
|
stripe.Key = stripeKey
|
|
db := database.GetDB()
|
|
|
|
var orders []models.Order
|
|
cutoff := time.Now().Add(-10 * time.Minute)
|
|
db.Where("status = ? AND stripe_payment_id = '' AND created_at < ?",
|
|
models.OrderStatusPending, cutoff).Find(&orders)
|
|
|
|
if len(orders) == 0 {
|
|
return
|
|
}
|
|
|
|
reconcileLog().Info("checking pending orders", "count", len(orders))
|
|
|
|
for _, order := range orders {
|
|
params := &stripe.PaymentIntentSearchParams{
|
|
SearchParams: stripe.SearchParams{
|
|
Query: fmt.Sprintf("metadata['order_id']:'%d' AND status:'succeeded'", order.ID),
|
|
},
|
|
}
|
|
|
|
iter := paymentintent.Search(params)
|
|
for iter.Next() {
|
|
pi := iter.PaymentIntent()
|
|
reconcileLog().Warn("found succeeded payment intent for unrecorded order — patching",
|
|
"order_id", order.ID, "pi", pi.ID)
|
|
|
|
txErr := db.Transaction(func(tx *gorm.DB) error {
|
|
if err := tx.Model(&order).Updates(map[string]any{
|
|
"status": models.OrderStatusPaid,
|
|
"stripe_payment_id": pi.ID,
|
|
}).Error; err != nil {
|
|
return err
|
|
}
|
|
var cart models.Cart
|
|
if err := tx.Where("user_id = ?", order.UserID).First(&cart).Error; err != nil {
|
|
return nil // cart already gone, nothing to clear
|
|
}
|
|
if err := tx.Where("cart_id = ?", cart.ID).Delete(&models.CartItem{}).Error; err != nil {
|
|
return err
|
|
}
|
|
return tx.Model(&cart).Updates(map[string]any{
|
|
"address_id": nil,
|
|
"card_id": nil,
|
|
}).Error
|
|
})
|
|
if txErr != nil {
|
|
reconcileLog().Error("failed to patch order", "order_id", order.ID, "error", txErr)
|
|
}
|
|
}
|
|
if err := iter.Err(); err != nil {
|
|
reconcileLog().Error("stripe search error", "order_id", order.ID, "error", err)
|
|
}
|
|
}
|
|
}
|
|
|
|
// ReconcileExpiredCards removes saved cards whose retention deadline elapsed.
|
|
// Read paths filter out expired rows so users never see them; this job drives
|
|
// the Stripe detach + audit + physical row delete out of band so request
|
|
// handlers never block on Stripe API calls during a card sweep.
|
|
func ReconcileExpiredCards(stripeKey string) {
|
|
db := database.GetDB()
|
|
|
|
var cards []models.Card
|
|
if err := db.Where(
|
|
"storage_expires_at IS NOT NULL AND storage_expires_at <= ?",
|
|
time.Now(),
|
|
).Find(&cards).Error; err != nil {
|
|
reconcileLog().Error("expired card scan failed", "error", err)
|
|
return
|
|
}
|
|
if len(cards) == 0 {
|
|
return
|
|
}
|
|
|
|
reconcileLog().Info("expiring inactive saved cards", "count", len(cards))
|
|
for i := range cards {
|
|
if err := expireStoredCard(db, &cards[i], stripeKey); err != nil {
|
|
reconcileLog().Error("expire card failed", "card_id", cards[i].ID, "error", err)
|
|
}
|
|
}
|
|
}
|
|
|
|
// ReconcileUnshipped finds paid order orlder than 24h with no tracking
|
|
// number and posts single Slack reminder. Pure read + notif
|
|
func ReconcileUnshipped() {
|
|
db := database.GetDB()
|
|
|
|
var orders []models.Order
|
|
cutoff := time.Now().Add(-24 * time.Hour)
|
|
err := db.Where(
|
|
"status = ? AND (tracking_number = '' OR tracking_number IS NULL) AND created_at < ?",
|
|
models.OrderStatusPaid, cutoff,
|
|
).Order("created_at ASC").Find(&orders).Error
|
|
if err != nil {
|
|
reconcileLog().Error("unshipped query failed", "error", err)
|
|
return
|
|
}
|
|
if len(orders) == 0 {
|
|
return
|
|
}
|
|
|
|
reconcileLog().Info("unshipped orders found", "count", len(orders))
|
|
notify.SlackUnshippedReminder(orders)
|
|
}
|