package shanghu

import (
	orm "duoduo/database"
	"duoduo/tools"
	"errors"
	"time"
)

// 中奖活动商品 库存，中奖率
type MerchantActiveDrawProduct struct {
	ID              int64     `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"`
	MerchantOpenID  string    `gorm:"column:merchant_open_id;type:varchar(255)" json:"merchant_open_id"`
	DrawProductName string    `gorm:"column:draw_product_name;type:varchar(255)" json:"draw_product_name"` // 抽奖名称
	DrawOdds        int       `gorm:"column:draw_odds;type:int(11)" json:"draw_odds"`                      // 中奖概率
	Stock           int       `gorm:"column:stock;type:int(11)" json:"stock"`                              // 剩余库存
	Version         int       `gorm:"column:version;type:int(11)" json:"version"`                          // Version
	IsPrize         bool      `gorm:"column:is_prize;type:tinyint(1)" json:"is_prize"`                     // 是否需要兑奖  谢谢惠顾不需要兑奖
	DrawUrl         string    `gorm:"column:draw_url;type:varchar(255)" json:"draw_url"`                   // 中奖图片
	TotalStock      int       `gorm:"column:total_stock;type:int(11)" json:"total_stock"`                  // 总库存
	ActiveConfigID  int64     `gorm:"column:active_config_id;type:bigint(20)" json:"active_config_id"`     // 关联活动
	CreateBy        int64     `gorm:"column:create_by;type:bigint(20)" json:"create_by"`                   // 创建者
	UpdateBy        int64     `gorm:"column:update_by;type:bigint(20)" json:"update_by"`                   // 更新者
	CreatedAt       time.Time `gorm:"column:created_at;type:datetime(3)" json:"created_at"`                // 创建时间
	UpdatedAt       time.Time `gorm:"column:updated_at;type:datetime(3)" json:"updated_at"`                // 最后更新时间
	DeletedAt       time.Time `gorm:"column:deleted_at;type:datetime(3);default:null" json:"deleted_at"`   // 删除时间
}

func (m *MerchantActiveDrawProduct) TableName() string {
	return "merchant_active_draw_product"
}

func (u *MerchantActiveDrawProduct) Create() (MerchantActiveDrawProduct, error) {
	var doc MerchantActiveDrawProduct
	var err error

	doc = *u
	err = orm.ShMysql.Table(u.TableName()).Create(&doc).Error
	if err != nil {
		return doc, err
	}

	return doc, nil
}

func (u *MerchantActiveDrawProduct) UpdateConfigId(drawId int64) error {
	res := orm.ShMysql.Table(u.TableName()).Where("id = ? and active_config_id = 0", drawId).Updates(
		map[string]interface{}{
			"active_config_id": u.ActiveConfigID,
			"updated_at":       time.Now(),
		})
	if res.Error != nil {
		return res.Error
	}
	if res.RowsAffected <= 0 {
		return errors.New("未更新抽奖数据")
	}
	return nil

}

// 中奖商品列表
func (m *MerchantActiveDrawProduct) GetDrawProductList() ([]MerchantActiveDrawProduct, int, error) {
	var doc []MerchantActiveDrawProduct

	table := orm.ShMysql.Table(m.TableName())

	table = table.Where("active_config_id = ?  ", m.ActiveConfigID)
	var count int
	if err := table.Select("*").Order("id desc").Find(&doc).Error; err != nil {
		return nil, 0, err
	}
	table.Count(&count)
	return doc, count, nil
}

func (m *MerchantActiveDrawProduct) GetDrawProductListByOpenId(pageSize int, pageIndex int) ([]MerchantActiveDrawProduct, int, error) {
	var doc []MerchantActiveDrawProduct

	table := orm.ShMysql.Table(m.TableName())

	table = table.Where("merchant_open_id = ? and  active_config_id = 0", m.MerchantOpenID)
	var count int
	if err := table.Select("*").Order("id desc").Offset((pageIndex - 1) * pageSize).Limit(pageSize).Find(&doc).Error; err != nil {
		return nil, 0, err
	}
	table.Count(&count)
	return doc, count, nil
}

// 中奖商品列表
func (m *MerchantActiveDrawProduct) GetDrawProductListById(idList []int64) ([]MerchantActiveDrawProduct, int, error) {
	var doc []MerchantActiveDrawProduct

	table := orm.ShMysql.Table(m.TableName())

	table = table.Where("id in (?) ", idList)
	var count int
	if err := table.Select("*").Order("id desc").Find(&doc).Error; err != nil {
		return nil, 0, err
	}
	table.Count(&count)
	return doc, count, nil
}

// 中奖商品
func (m *MerchantActiveDrawProduct) GetDrawProductById() (MerchantActiveDrawProduct, error) {
	var doc MerchantActiveDrawProduct

	table := orm.ShMysql.Table(m.TableName())

	table = table.Where("id = ? ", m.ID)
	var count int
	if err := table.Select("*").First(&doc).Error; err != nil {
		return doc, err
	}
	table.Count(&count)
	return doc, nil
}

// 奖品列表
func (m *MerchantActiveDrawProduct) GetDrawProductListByActiveId() ([]MerchantActiveDrawProduct, int, error) {
	var doc []MerchantActiveDrawProduct

	table := orm.ShMysql.Table(m.TableName())

	table = table.Where("active_config_id = ? ", m.ActiveConfigID)
	var count int
	if err := table.Select("*").Order("id desc").Find(&doc).Error; err != nil {
		return nil, 0, err
	}
	table.Count(&count)
	return doc, count, nil
}

func (m *MerchantActiveDrawProduct) SubStock() error {

	table := orm.ShMysql.Table(m.TableName())
	result := table.Model(&MerchantActiveDrawProduct{}).Where("id = ? and version = ? ", m.ID, m.Version).Updates(
		map[string]interface{}{
			"version":    m.Version + 1,
			"stock":      m.Stock - 1,
			"updated_at": tools.GetCurrntTimeStr()})

	if result.Error != nil {
		return result.Error
	}
	if result.RowsAffected <= 0 {
		err := errors.New("减库存失败，请重新再试。")
		return err
	}
	return nil
}