package models

import (
	"gat1400Exchange/vo"
)

type Subscribe struct {
	Id         string       `gorm:"column:id;primary_key;" json:"id"`
	Status     int          `gorm:"column:status" json:"status"` // 0：订阅中 1：已取消订阅 2：订阅到期 9：未订阅
	FromId     string       `gorm:"column:from_id" json:"from_id"`
	Ext        vo.Subscribe `gorm:"column:ext;type:json;not null;default '{}'" json:"ext"`
	CreateTime int64        `gorm:"column:create_time;autoCreateTime;" json:"create_time"`
	UpdateTime int64        `gorm:"column:update_time;autoUpdateTime" json:"-"`
	DeleteTime int64        `gorm:"column:delete_time" json:"-"`
}

func (s *Subscribe) TableName() string {
	return "subscribes"
}

func (s *Subscribe) FindById(id string) error {
	return db.Table(s.TableName()).First(&s, "id = ?", id).Error
}

func (s *Subscribe) Save() error {
	return db.Table(s.TableName()).Save(s).Error
}

func (s *Subscribe) DeleteById(id string) error {
	return db.Table(s.TableName()).Where("id = ?", id).Delete(s).Error
}

func (s *Subscribe) FindAll() ([]Subscribe, error) {
	var subs []Subscribe
	if err := db.Table(s.TableName()).Find(&subs).Error; err != nil {
		return nil, err
	}

	return subs, nil
}

func (s *Subscribe) FindByFromId(fromId string) ([]Subscribe, error) {
	var subs []Subscribe
	if err := db.Table(s.TableName()).Where("from_id = ?", fromId).Find(&subs).Error; err != nil {
		return nil, err
	}

	return subs, nil
}