message_business.go 2.4 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针对文章、2针对评论、3针对圆桌)
	CompanyId   int64           `json:"companyId"`   // 操作人公司ID
	UserId      int64           `json:"userId"`      // 操作人用户ID
	RecipientId int64           `json:"recipientId"` // 接收人用户ID
	ArticleId   int64           `json:"articleId"`   // 文章ID
	SectionId   int64           `json:"sectionId"`   // 段落ID
	CommentId   int64           `json:"commentId"`   // 评论ID
	Content     string          `json:"content"`     // 消息内容
	CreatedAt   int64           `json:",omitempty"`
	UpdatedAt   int64           `json:",omitempty"`
	DeletedAt   int64           `json:",omitempty"`
	Version     int             `json:",omitempty"`

	//DiscussionId        int64           `json:"discussionId"`        // 圆桌ID
	//DiscussionOpinionId int64           `json:"discussionOpinionId"` // 观点ID
}

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
}