message_system.go 1.5 KB
package domain

import (
	"context"
	"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
)

type MessageSystem struct {
	Id          int64  // 唯一标识
	CompanyId   int64  `json:"companyId"`   // 公司ID
	RecipientId int64  `json:"recipientId"` // 接收者ID
	Type        int    `json:"type"`        // 系统分类(0待定、1业务正常通知、2业务异常通知)
	Title       string `json:"title"`       // 标题
	Content     string `json:"content"`     // 内容
	CreatedAt   int64  `json:",omitempty"`
	UpdatedAt   int64  `json:",omitempty"`
	DeletedAt   int64  `json:",omitempty"`
	Version     int    `json:",omitempty"`
}

type MsgSystemType int

const (
	MsgTypeNormal   MsgSystemType = 1
	MsgTypeAbnormal MsgSystemType = 2
)

type MessageSystemRepository interface {
	Insert(ctx context.Context, conn transaction.Conn, dm *MessageSystem) (*MessageSystem, error)
	Update(ctx context.Context, conn transaction.Conn, dm *MessageSystem) (*MessageSystem, error)
	UpdateWithVersion(ctx context.Context, conn transaction.Conn, dm *MessageSystem) (*MessageSystem, error)
	Delete(ctx context.Context, conn transaction.Conn, dm *MessageSystem) (*MessageSystem, error)
	FindOne(ctx context.Context, conn transaction.Conn, id int64) (*MessageSystem, error)
	Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*MessageSystem, error)
}

func (m *MessageSystem) Identify() interface{} {
	if m.Id == 0 {
		return nil
	}
	return m.Id
}