duoduo/models/shanghu/active.user.go

package shanghu

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

// 商户账号
type ActiveUser struct {
	ID        int64     `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` // 主键
	Code      string    `gorm:"column:code;type:varchar(255)" json:"code"`
	OpenID    string    `gorm:"column:open_id;type:varchar(255)" json:"open_id"`                   // open_id 唯一索引
	Phone     string    `gorm:"column:phone;type:varchar(24)" json:"phone"`                        // 手机号
	NickName  string    `gorm:"column:nick_name;type:varchar(255)" json:"nick_name"`               // 微信用户名
	AvatarUrl string    `gorm:"column:avatar_url;type:varchar(255)" json:"avatar_url"`             // 头像url
	Admin     int       `gorm:"column:admin;type:int(11)" json:"admin"`                            // 1-管理员  2-销售 3-霸王卡商家 4-店员  5-商家充值 6-商家霸王卡+充值 7-充值店员
	Pid       string    `gorm:"column:pid;type:varchar(10)" json:"pid"`                            // 上级
	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 *ActiveUser) TableName() string {
	return "active_user"
}

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

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

	return doc, nil
}

func (m *ActiveUser) GetNum() int {
	var count int

	tableCount := orm.ShMysql.Table(m.TableName()).Where("open_id = ? ", m.OpenID)
	tableCount.Count(&count)
	return count

}

func (m *ActiveUser) GetCodeNum() int {
	var count int

	tableCount := orm.ShMysql.Table(m.TableName()).Where("code = ? ", m.Code)
	tableCount.Count(&count)
	return count

}

func (m *ActiveUser) GetUserInfo() (ActiveUser, error) {
	var doc ActiveUser

	table := orm.ShMysql.Table(m.TableName())
	table = table.Where("open_id = ?  ", m.OpenID)

	if err := table.Select("*").First(&doc).Error; err != nil {
		return doc, err
	}

	return doc, nil

}

func (m *ActiveUser) GetUserInfoByCode() (ActiveUser, error) {
	var doc ActiveUser

	table := orm.ShMysql.Table(m.TableName())
	table = table.Where("code = ?  ", m.Code)

	if err := table.Select("*").First(&doc).Error; err != nil {
		return doc, err
	}

	return doc, nil
}