message_business.go 2.5 KB
package domain

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

type MessageBusiness struct {
	Id                  int64           // 唯一标识
	Type                MsgBusinessType `json:"type"`                // 分类   (1回复 2点赞 3被采纳)
	OptType             MsgBusinessOpt  `json:"optType"`             // 操作类型(1针对文章、1针对评论、2针对圆桌)
	CompanyId           int64           `json:"companyId"`           // 操作人公司ID
	UserId              int64           `json:"userId"`              // 操作人用户ID
	RecipientId         int64           `json:"recipientId"`         // 接收人用户ID
	ArticleId           int64           `json:"articleId"`           // 文章ID
	CommentId           int64           `json:"commentId"`           // 评论ID
	DiscussionId        int64           `json:"discussionId"`        // 圆桌ID
	DiscussionOpinionId int64           `json:"discussionOpinionId"` // 观点ID
	Content             string          `json:"content"`             // 消息内容
	CreatedAt           int64           `json:",omitempty"`
	UpdatedAt           int64           `json:",omitempty"`
	DeletedAt           int64           `json:",omitempty"`
	Version             int             `json:",omitempty"`
}

type MsgBusinessType int
type MsgBusinessOpt int

const (
	MsgTypeReply  MsgBusinessType = 1 // 消息分类-评论
	MsgTypeLike   MsgBusinessType = 2 // 消息分类-点赞
	MsgTypeAccept MsgBusinessType = 3 // 消息分类-被采纳
)

const (
	OptTypeArticle    MsgBusinessOpt = 1 // 操作分类-针对文章
	OptTypeComment    MsgBusinessOpt = 2 // 操作分类-针对评论
	OptTypeDiscussion MsgBusinessOpt = 3 // 操作分类-针对讨论
)

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

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