package model

import (
	"fmt"
	"strconv"
	"time"

	"go.uber.org/zap"
	"gorm.io/gorm"
)

type Sign struct {
	Id        int64      `form:"id" json:"id,omitempty" gorm:"primaryKey;autoIncrement;column:id;comment:;"`
	UserId    int64      `form:"user_id" json:"user_id,omitempty" gorm:"column:user_id;type:bigint(20);size:20;default:0;index:idx_user_id;index:idx_user_sign_at,unique;comment:签到的用户ID;"`
	Ip        string     `form:"ip" json:"ip,omitempty" gorm:"column:ip;type:varchar(64);size:64;comment:签到的用户IP;"`
	SignAt    int        `form:"sign_at" json:"sign_at,omitempty" gorm:"column:sign_at;type:int(11);size:11;default:0;index:idx_user_sign_at,unique;comment:签到时间，格式20060102;"`
	CreatedAt *time.Time `form:"created_at" json:"created_at,omitempty" gorm:"column:created_at;type:datetime;comment:创建时间;"`
	UpdatedAt *time.Time `form:"updated_at" json:"updated_at,omitempty" gorm:"column:updated_at;type:datetime;comment:更新时间;"`
	Award     int32      `form:"award" json:"award,omitempty" gorm:"column:award;type:int(11);size:11;default:0;comment:奖励积分;"`
}

func (Sign) TableName() string {
	return tablePrefix + "sign"
}

// CreateSign 用户签到
// 1. 创建签到记录
// 2. 更新用户签积分
func (m *DBModel) CreateSign(userId int64, ip string) (sign *Sign, err error) {
	now := time.Now()
	signAt, _ := strconv.Atoi(now.Format("20060102"))
	sign = &Sign{
		UserId: userId,
		Ip:     ip,
		SignAt: signAt,
	}

	cfg := m.GetConfigOfScore(ConfigScoreSignIn, ConfigScoreCreditName)
	sign.Award = cfg.SignIn

	tx := m.db.Begin()
	defer func() {
		if err != nil {
			tx.Rollback()
		} else {
			tx.Commit()
		}
	}()

	err = tx.Create(sign).Error
	if err != nil {
		m.logger.Error("CreateSign Create", zap.Error(err))
		return
	}

	content := "完成了每日签到"
	if cfg.SignIn > 0 {
		// 1. 更新用户积分
		err = tx.Model(&User{}).Where("id=?", userId).Update("credit_count", gorm.Expr("credit_count + ?", cfg.SignIn)).Error
		if err != nil {
			m.logger.Error("CreateSign Update", zap.Error(err))
			return
		}
		content = fmt.Sprintf("签到成功，获得 %d %s奖励", cfg.SignIn, cfg.CreditName)
	}

	dynamic := Dynamic{
		UserId:  userId,
		Type:    DynamicTypeSign,
		Content: content,
	}
	err = tx.Create(&dynamic).Error
	if err != nil {
		m.logger.Error("CreateSign Create Dynamic", zap.Error(err))
		return
	}
	return
}

// 用户今日是否已签到
func (m *DBModel) GetSignedToday(userId int64) (sign Sign) {
	signAt, _ := strconv.Atoi(time.Now().Format("20060102"))
	err := m.db.Where("user_id=? and sign_at=?", userId, signAt).First(&sign).Error
	if err != nil && err != gorm.ErrRecordNotFound {
		m.logger.Error("GetSignedToday", zap.Error(err))
	}
	return
}