hongze_yb_en_api/models/english_report_email/email.go

package english_report_email

import (
	"hongze/hongze_yb_en_api/global"
	"hongze/hongze_yb_en_api/models/base"
	"time"
)

// 英文研报-邮箱
type Email struct {
	Id           uint      `gorm:"primaryKey;column:id" json:"id"`
	CompanyId    uint      `gorm:"column:company_id" json:"company_id"`         //客户ID
	Name         string    `gorm:"column:name" json:"name"`                     //客户名称
	Email        string    `gorm:"column:email" json:"email"`                   //邮箱地址
	ViewTotal    uint      `gorm:"column:view_total" json:"view_total"`         //累计点击量/阅读量
	LastViewTime time.Time `gorm:"column:last_view_time" json:"last_view_time"` //最后阅读时间
	IsDeleted    uint8     `gorm:"column:is_deleted" json:"is_deleted"`         //删除状态：0-正常；1-已删除
	AdminId      uint      `gorm:"column:admin_id" json:"admin_id"`             //创建人ID
	AdminName    string    `gorm:"column:admin_name" json:"admin_name"`         //创建人名称
	base.TimeBase
}

// TableName get sql table name.获取数据库表名
func (e *Email) TableName() string {
	return "english_report_email"
}

// Add 新增
func (e *Email) Add() (err error) {
	err = global.DEFAULT_MYSQL.Create(e).Error
	return
}

// 修改
func (e *Email) Update(updateCols []string) (err error) {
	err = global.DEFAULT_MYSQL.Model(e).Select(updateCols).Updates(e).Error
	return
}

func (e *Email) GetById(id int) (item *Email, err error) {
	err = global.MYSQL["rddp"].Model(e).Where("is_deleted = 0 AND id= ?", id).First(&item).Error
	return
}

func (e *Email) UpdateViewTotalById(Id uint) (err error) {
	sql := `UPDATE english_report_email SET view_total = view_total+1, last_view_time = NOW() WHERE id = ? `
	err = global.DEFAULT_MYSQL.Exec(sql, Id).Error
	return
}