// 功能描述：供气订单支付完成后原子生成正式押金事实；版本：1.0.0。
package payment

import (
	"fmt"
	"time"

	"git.apinb.com/heqiapp/platforms/backend/api/internal/models"
	"gorm.io/gorm"
	"gorm.io/gorm/clause"
)

// CompleteGasDeposits 将下单时锁定的押金快照转为用户押金记录，重复回调不会重复入账。
func CompleteGasDeposits(tx *gorm.DB, orderIdentity string, paidAt time.Time) error {
	var order models.GasorderBasic
	if err := tx.Clauses(clause.Locking{Strength: "UPDATE"}).Where("identity = ?", orderIdentity).First(&order).Error; err != nil {
		return err
	}
	var snapshots []models.GasorderDeposit
	if err := tx.Clauses(clause.Locking{Strength: "UPDATE"}).Where("gasorder_basic_id = ? AND deposit_status = ?", order.ID, 10).Find(&snapshots).Error; err != nil {
		return err
	}
	for _, snapshot := range snapshots {
		var existing int64
		if err := tx.Model(&models.DepositRecord{}).Where("gasorder_id = ? AND product_info_id = ? AND status <> ?", order.ID, snapshot.ProductInfoID, 3).Count(&existing).Error; err != nil {
			return err
		}
		if existing == 0 {
			record := models.DepositRecord{Entity: models.Entity{Identity: models.NewIdentity(), Status: 1}, DepositStatus: 10,
				DepositNo: fmt.Sprintf("DEP%s-%s", paidAt.Format("20060102150405.000000"), snapshot.Identity), UserAccountID: order.UserAccountID, ProductInfoID: snapshot.ProductInfoID,
				PolicyID: snapshot.PolicyID, GasorderID: order.ID, Amount: snapshot.Amount, PaidAt: paidAt}
			if err := tx.Create(&record).Error; err != nil {
				return err
			}
		}
		if err := tx.Model(&snapshot).Where("deposit_status = ?", 10).Update("deposit_status", 23).Error; err != nil {
			return err
		}
	}
	return nil
}