lc_finance/server/dao/notice.go

package dao

import "server/global"

type Notice struct {
	global.GVA_MODEL
	Title   string  `json:"title" form:"title" gorm:"comment:标题"`
	Content string  `json:"content" form:"content" gorm:"comment:内容"`
	Type    string  `json:"type" form:"type" gorm:"comment:类型"`
	UserId  int     `json:"userId" form:"userId" gorm:"comment:接收者ID"`
	User    SysUser `json:"user" form:"user" gorm:"foreignKey:UserId;references:id;"`
	IsRead  bool    `json:"isRead" form:"isRead" gorm:"default:false;comment:是否已读"`
}

func (Notice) TableName() string {
	return "notice"
}

// QueryUserUnreadNotice 查询用户未读通知
func QueryUserUnreadNotice(userId int) (notices []Notice, err error) {
	err = global.GVA_DB.Where("user_id = ? AND is_read = ?", userId, false).Find(&notices).Error
	return
}

func QueryUserAllNotice(userId int) (notices []Notice, err error) {
	err = global.GVA_DB.Where("user_id =?", userId).Order("id").Find(&notices).Error
	return
}

// QueryAllNotices 查询所有通知
func QueryAllNotices() (notices []Notice, err error) {
	err = global.GVA_DB.Find(&notices).Error
	return
}

func (n Notice) CreateNotice() error {
	return global.GVA_DB.Create(&n).Error
}

func ReadNotice(id int) error {
	return global.GVA_DB.Model(&Notice{}).Where("id =?", id).Update("is_read", true).Error
}

func (n Notice) UpdateNotice() error {
	return global.GVA_DB.Model(&n).Updates(&n).Error
}

func (n Notice) DeleteNotice() error {
	return global.GVA_DB.Unscoped().Delete(&n).Error
}